database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-12-09 10:41:14 +03:00
Code Activity

Added some debugging lines to track down spurious threads. Looks like

Browse Source 
they're created by the s3 lib.  The lines are commented but left in
it we need them later.
This commit is contained in:
Patrick LeBlanc
2019-05-24 15:52:24 -05:00
parent 0cad8308f1
commit be01adb150
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/ThreadPool.cpp
View File

@@ -119,7 +119,7 @@ void ThreadPool::processingLoop()
void ThreadPool::_processingLoop(boost::unique_lock<boost::mutex> &s)
{
//cout << "Thread started" << endl;
while (threads.size() - pruneable.size() <= maxThreads) // this is the scale-down mechanism when maxThreads is changed
{
while (jobs.empty() && !die)
@@ -128,10 +128,15 @@ void ThreadPool::_processingLoop(boost::unique_lock<boost::mutex> &s)
bool timedout = !jobAvailable.timed_wait<>(s, idleThreadTimeout);
threadsWaiting--;
if (timedout && jobs.empty())
{
//cout << "Thread exiting b/c of timeout" << endl;
return;
}
}
if (jobs.empty()) // die was set, and there are no jobs left to process
if (jobs.empty()) { // die was set, and there are no jobs left to process
//cout << "Thread exiting b/c of die (?)" << endl;
return;
}
boost::shared_ptr<Job> job = jobs.front();
jobs.pop_front();
@@ -146,7 +151,7 @@ void ThreadPool::_processingLoop(boost::unique_lock<boost::mutex> &s)
}
s.lock();
}
//cout << "Thread exiting b/c of pruning logic" << endl;
}
inline bool ThreadPool::id_compare::operator()(const ID_Thread &t1, const ID_Thread &t2) const