ARCHIVE/xahaud
3
0
Fork 0
mirror of https://github.com/Xahau/xahaud.git synced 2025-12-06 17:27:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix for job destruction race condition.

Browse Source
This commit is contained in:
JoelKatz
2013-03-01 18:27:07 -08:00
parent d31fa25b95
commit c984f83eb6
1 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/cpp/ripple/JobQueue.cpp
View File

@@ -256,16 +256,18 @@ void JobQueue::threadEntry()
break;
std::set<Job>::iterator it = mJobSet.begin();
Job job(*it);
mJobSet.erase(it);
--mJobCounts[job.getType()];
{
Job job(*it);
mJobSet.erase(it);
--mJobCounts[job.getType()];
if (job.getType() == jtDEATH)
break;
if (job.getType() == jtDEATH)
break;
sl.unlock();
cLog(lsTRACE) << "Doing " << Job::toString(job.getType()) << " job";
job.doJob();
sl.unlock();
cLog(lsTRACE) << "Doing " << Job::toString(job.getType()) << " job";
job.doJob();
} // must destroy job without holding lock
sl.lock();
}
--mThreadCount;