xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add the log for query queue initializing.

This commit is contained in:
hjxilinx 2019-12-17 14:18:00 +08:00
parent abfac9ab09
commit 60f98e31ce
1 changed files with 13 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/system/detail/src/vnodeSystem.c
View File

@ -36,8 +36,14 @@ void vnodeCleanUpSystem() {
bool vnodeInitQueryHandle() { bool vnodeInitQueryHandle() {
int numOfThreads = tsRatioOfQueryThreads * tsNumOfCores * tsNumOfThreadsPerCore; int numOfThreads = tsRatioOfQueryThreads * tsNumOfCores * tsNumOfThreadsPerCore;
if (numOfThreads < 1) numOfThreads = 1; if (numOfThreads < 1) {
queryQhandle = taosInitScheduler(tsNumOfVnodesPerCore * tsNumOfCores * tsSessionsPerVnode, numOfThreads, "query"); 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; return true;
} }
@ -52,13 +58,13 @@ bool vnodeInitTmrCtl() {
int vnodeInitSystem() { int vnodeInitSystem() {
if (!vnodeInitQueryHandle()) { if (!vnodeInitTmrCtl()) {
dError("failed to init query qhandle, exit"); dError("failed to init timer, exit");
return -1; return -1;
} }
if (!vnodeInitTmrCtl()) { if (!vnodeInitQueryHandle()) {
dError("failed to init timer, exit"); dError("failed to init query qhandle, exit");
return -1; return -1;
} }