From aa46b1d99f26cbefc38b293c39c37f221f54dbf3 Mon Sep 17 00:00:00 2001
From: xsren <285808407@qq.com>
Date: Mon, 29 Jul 2024 14:58:47 +0800
Subject: [PATCH] return:queryUtil

---
 docs/examples/c/subscribe_demo.c | 66 --------------------------------
 source/libs/qcom/src/queryUtil.c |  2 +-
 2 files changed, 1 insertion(+), 67 deletions(-)
 delete mode 100644 docs/examples/c/subscribe_demo.c

diff --git a/docs/examples/c/subscribe_demo.c b/docs/examples/c/subscribe_demo.c
deleted file mode 100644
index a769c184f2..0000000000
--- a/docs/examples/c/subscribe_demo.c
+++ /dev/null
@@ -1,66 +0,0 @@
-// A simple demo for asynchronous subscription.
-// compile with:
-// gcc -o subscribe_demo subscribe_demo.c -ltaos
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <taos.h>
-
-int nTotalRows;
-
-/**
- * @brief callback function of subscription.
- *
- * @param tsub
- * @param res
- * @param param. the additional parameter passed to  taos_subscribe
- * @param code. error code
- */
-void subscribe_callback(TAOS_SUB* tsub, TAOS_RES* res, void* param, int code) {
-  if (code != 0) {
-    printf("error: %d\n", code);
-    exit(EXIT_FAILURE);
-  }
-
-  TAOS_ROW    row = NULL;
-  int         num_fields = taos_num_fields(res);
-  TAOS_FIELD* fields = taos_fetch_fields(res);
-  int         nRows = 0;
-
-  while ((row = taos_fetch_row(res))) {
-    char buf[4096] = {0};
-    taos_print_row(buf, row, fields, num_fields);
-    puts(buf);
-    nRows++;
-  }
-
-  nTotalRows += nRows;
-  printf("%d rows consumed.\n", nRows);
-}
-
-int main() {
-  TAOS* taos = taos_connect("localhost", "root", "taosdata", NULL, 6030);
-  if (taos == NULL) {
-    printf("failed to connect to server\n");
-    exit(EXIT_FAILURE);
-  }
-
-  int         restart = 1;  // if the topic already exists, where to subscribe from the begin.
-  const char* topic = "topic-meter-current-bg-10";
-  const char* sql = "select * from power.meters where current > 10";
-  void*       param = NULL;     // additional parameter.
-  int         interval = 2000;  // consumption interval in microseconds.
-  TAOS_SUB*   tsub = taos_subscribe(taos, restart, topic, sql, subscribe_callback, NULL, interval);
-
-  // wait for insert from others process. you can open TDengine CLI to insert some records for test.
-  
-  getchar();  // press Enter to stop
-
-  printf("total rows consumed: %d\n", nTotalRows);
-  int keep = 0;  // whether to keep subscribe process
-  (void)taos_unsubscribe(tsub, keep);
-
-  taos_close(taos);
-  taos_cleanup();
-}
diff --git a/source/libs/qcom/src/queryUtil.c b/source/libs/qcom/src/queryUtil.c
index 3d344a8a20..bce8cda125 100644
--- a/source/libs/qcom/src/queryUtil.c
+++ b/source/libs/qcom/src/queryUtil.c
@@ -128,7 +128,7 @@ static STaskQueue taskQueue = {0};
 
 static void processTaskQueue(SQueueInfo *pInfo, SSchedMsg *pSchedMsg) {
   __async_exec_fn_t execFn = (__async_exec_fn_t)pSchedMsg->ahandle;
-  execFn(pSchedMsg->thandle);
+  (void)execFn(pSchedMsg->thandle);
   taosFreeQitem(pSchedMsg);
 }