recursorThread(currentThreadId++);
}
else {
- g_log<<Logger::Warning<<"Launching "<< g_numWorkerThreads <<" worker threads"<<endl;
if (g_weDistributeQueries) {
g_log<<Logger::Warning<<"Launching "<< g_numDistributorThreads <<" distributor threads"<<endl;
}
}
+ g_log<<Logger::Warning<<"Launching "<< g_numWorkerThreads <<" worker threads"<<endl;
+
for(unsigned int n=0; n < g_numWorkerThreads; ++n) {
auto& infos = s_threadInfos.at(currentThreadId);
infos.isListener = g_weDistributeQueries ? false : true;