christoph/fail
1
Fork 0
Code Releases Activity

jobserver: gracefully handle thread creation failures

Browse Source 
Due to the previous DatabaseCampaign fix, this may not be necessary
anymore, but it's nevertheless a good idea to handle thread creation
failures properly.

Change-Id: I8317a77dd5338509727e737040944320e7755ae3
This commit is contained in:
Horst Schirmeier
2014-02-19 18:53:18 +01:00
parent 25a390970a
commit 5ee96032c9
1 changed files with 24 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/core/cpn/JobServer.cc
View File

@ -171,18 +171,30 @@ void JobServer::run()
continue;
}
}
// Spawn a thread for further communication,
// and add this thread to a list threads
// We can limit the generation of threads here.
if (m_threadlist.size() >= m_maxThreads) {
// Run over list with a timed_join,
// removing finished threads.
do {
m_threadlist.remove_if(timed_join_successful(m_threadtimeout));
} while (m_threadlist.size() == m_maxThreads);
}
// Start new thread
th = new boost::thread(CommThread(cs, *this));
bool creation_failed = false;
do {
// Spawn a thread for further communication,
// and add this thread to a list threads
// We can limit the generation of threads here.
if (m_threadlist.size() >= m_maxThreads || creation_failed) {
// Run over list with a timed_join,
// removing finished threads.
do {
m_threadlist.remove_if(timed_join_successful(m_threadtimeout));
} while (m_threadlist.size() >= m_maxThreads);
}
// Start new thread
try {
th = new boost::thread(CommThread(cs, *this));
creation_failed = false;
} catch (boost::thread_resource_error e) {
cout << "failed to spawn thread, throttling ..." << endl;
creation_failed = true;
sleep(1);
}
} while (creation_failed);
m_threadlist.push_back(th);
}
close(s);