ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-20 02:55:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

There's a proper way to workaround the silliness, io_service::work

Browse Source
This commit is contained in:
JoelKatz
2012-09-18 13:21:07 -07:00
parent 77c06a1ca0
commit 73c5b6addb
2 changed files with 4 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/Application.cpp
View File

@@ -35,14 +35,8 @@ DatabaseCon::~DatabaseCon()
delete mDatabase;
}
static void resetTimer(boost::asio::deadline_timer* timer)
{ // ugly workaround for Boost IO service weirdness
timer->expires_from_now(boost::posix_time::hours(24));
timer->async_wait(boost::bind(resetTimer, timer));
}
Application::Application() :
mIOTimer(mIOService), mAuxTimer(mAuxService), mUNL(mIOService),
mIOWork(mIOService), mAuxWork(mAuxService), mUNL(mIOService),
mNetOps(mIOService, &mMasterLedger), mTempNodeCache(16384, 90), mHashedObjectStore(16384, 300),
mSNTPClient(mAuxService), mRpcDB(NULL), mTxnDB(NULL), mLedgerDB(NULL), mWalletDB(NULL),
mHashNodeDB(NULL), mNetNodeDB(NULL),
@@ -50,9 +44,6 @@ Application::Application() :
{
RAND_bytes(mNonce256.begin(), mNonce256.size());
RAND_bytes(reinterpret_cast<unsigned char *>(&mNonceST), sizeof(mNonceST));
resetTimer(&mIOTimer);
resetTimer(&mAuxTimer);
}
extern const char *RpcDBInit[], *TxnDBInit[], *LedgerDBInit[], *WalletDBInit[], *HashNodeDBInit[], *NetNodeDBInit[];
@@ -60,10 +51,10 @@ extern int RpcDBCount, TxnDBCount, LedgerDBCount, WalletDBCount, HashNodeDBCount
void Application::stop()
{
mAuxService.stop();
mIOService.stop();
mHashedObjectStore.bulkWrite();
mValidations.flush();
mAuxService.stop();
Log(lsINFO) << "Stopped: " << mIOService.stopped();
}

4
src/Application.h
View File

@@ -39,8 +39,8 @@ public:
class Application
{
boost::asio::io_service mIOService, mAuxService;
boost::asio::deadline_timer mIOTimer, mAuxTimer;
boost::asio::io_service mIOService, mAuxService;
boost::asio::io_service::work mIOWork, mAuxWork;
Wallet mWallet;
UniqueNodeList mUNL;