christoph/fail
1
Fork 0
Code Releases Activity

spacing

Browse Source 
git-svn-id: https://www4.informatik.uni-erlangen.de/i4svn/danceos/trunk/devel/fail@1585 8c4709b5-6ec9-48aa-a5cd-a96041d1645a
This commit is contained in:
hsc
2012-09-02 10:17:00 +00:00
parent d9b24a7c60
commit f992f53d5d
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -153,7 +153,7 @@ void JobServer::run()
// TODO: Log-level?
#ifndef __puma
boost::thread* th;
while(!m_finish){
while (!m_finish){
// Accept connection
int cs = accept(s, (struct sockaddr*)&clientaddr, &clen);
if (cs == -1) {
@ -169,12 +169,11 @@ void JobServer::run()
// removing finished threads.
do {
m_threadlist.remove_if(timed_join_successful(m_threadtimeout));
} while(m_threadlist.size() == m_maxThreads);
} while (m_threadlist.size() == m_maxThreads);
}
// Start new thread
th = new boost::thread(CommThread(cs, *this));
m_threadlist.push_back(th);
// Start new thread
th = new boost::thread(CommThread(cs, *this));
m_threadlist.push_back(th);
}
close(s);
// when all undone Jobs are distributed -> call a timed_join on all spawned