From 60f98e31ce59a838d60fe5d13a5cc4543c396ef9 Mon Sep 17 00:00:00 2001
From: hjxilinx <hjxilinx@163.com>
Date: Tue, 17 Dec 2019 14:18:00 +0800
Subject: [PATCH] add the log for query queue initializing.

---
 src/system/detail/src/vnodeSystem.c | 20 +++++++++++++-------
 1 file changed, 13 insertions(+), 7 deletions(-)

diff --git a/src/system/detail/src/vnodeSystem.c b/src/system/detail/src/vnodeSystem.c
index 631e258b25..b23050ab03 100644
--- a/src/system/detail/src/vnodeSystem.c
+++ b/src/system/detail/src/vnodeSystem.c
@@ -36,8 +36,14 @@ void vnodeCleanUpSystem() {
 
 bool vnodeInitQueryHandle() {
   int numOfThreads = tsRatioOfQueryThreads * tsNumOfCores * tsNumOfThreadsPerCore;
-  if (numOfThreads < 1) numOfThreads = 1;
-  queryQhandle = taosInitScheduler(tsNumOfVnodesPerCore * tsNumOfCores * tsSessionsPerVnode, numOfThreads, "query");
+  if (numOfThreads < 1) {
+    numOfThreads = 1;
+  }
+  
+  int32_t maxQueueSize = tsNumOfVnodesPerCore * tsNumOfCores * tsSessionsPerVnode;
+  dTrace("query task queue initialized, max slot:%d, task threads:%d", maxQueueSize,numOfThreads);
+  
+  queryQhandle = taosInitSchedulerWithInfo(maxQueueSize, numOfThreads, "query", vnodeTmrCtrl);
   return true;
 }
 
@@ -52,15 +58,15 @@ bool vnodeInitTmrCtl() {
 
 int vnodeInitSystem() {
 
-  if (!vnodeInitQueryHandle()) {
-    dError("failed to init query qhandle, exit");
-    return -1;
-  }
-
   if (!vnodeInitTmrCtl()) {
     dError("failed to init timer, exit");
     return -1;
   }
+  
+  if (!vnodeInitQueryHandle()) {
+    dError("failed to init query qhandle, exit");
+    return -1;
+  }
 
   if (vnodeInitStore() < 0) {
     dError("failed to init vnode storage");
-- 
GitLab