ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-27 22:45:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Thread dispatch fixes. (code is commented out)

Browse Source
This commit is contained in:
JoelKatz
2013-03-29 18:28:16 -07:00
parent 4f029e25b6
commit 8215463879
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/cpp/ripple/Application.cpp
View File

@@ -46,6 +46,7 @@ DatabaseCon::~DatabaseCon()
} }
Application::Application() : Application::Application() :
// mIOService(2),
mIOWork(mIOService), mAuxWork(mAuxService), mUNL(mIOService), mNetOps(mIOService, &mLedgerMaster), mIOWork(mIOService), mAuxWork(mAuxService), mUNL(mIOService), mNetOps(mIOService, &mLedgerMaster),
mTempNodeCache("NodeCache", 16384, 90), mHashedObjectStore(16384, 300), mSLECache("LedgerEntryCache", 4096, 120), mTempNodeCache("NodeCache", 16384, 90), mHashedObjectStore(16384, 300), mSLECache("LedgerEntryCache", 4096, 120),
mSNTPClient(mAuxService), mJobQueue(mIOService), mFeeTrack(), mSNTPClient(mAuxService), mJobQueue(mIOService), mFeeTrack(),

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

@@ -272,9 +272,7 @@ void JobQueue::IOThread(boost::mutex::scoped_lock& sl)
NameThread("IO+"); NameThread("IO+");
try try
{ {
do mIOService.poll();
NameThread("IO+");
while ((mIOService.poll_one() == 1) && !theApp->isShutdown());
} }
catch (...) catch (...)
{ {