ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-26 14:05:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

On non-tiny nodes, use an extra I/O thread.

Browse Source
This commit is contained in:
JoelKatz
2013-04-07 23:44:36 -07:00
parent 5928b3dcbf
commit 7e429dd14c
1 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -46,7 +46,7 @@ DatabaseCon::~DatabaseCon()
}
Application::Application() :
// mIOService(2),
mIOService((theConfig.NODE_SIZE >= 2) ? 2 : 1),
mIOWork(mIOService), mAuxWork(mAuxService), mUNL(mIOService), mNetOps(mIOService, &mLedgerMaster),
mTempNodeCache("NodeCache", 16384, 90), mHashedObjectStore(16384, 300), mSLECache("LedgerEntryCache", 4096, 120),
mSNTPClient(mAuxService), mJobQueue(mIOService), mFeeTrack(),
@@ -100,6 +100,12 @@ static void runAux(boost::asio::io_service& svc)
svc.run();
}
static void runIO(boost::asio::io_service& io)
{
NameThread("io");
io.run();
}
void Application::setup()
{
mJobQueue.setThreadCount();
@@ -307,6 +313,11 @@ void Application::setup()
void Application::run()
{
if (theConfig.NODE_SIZE >= 2)
{
boost::thread(boost::bind(runIO, boost::ref(mIOService))).detach();
}
mIOService.run(); // This blocks
if (mWSPublicDoor)