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

Dispatch save accepted ledger better.

Browse Source
This commit is contained in:
JoelKatz
2013-03-06 16:33:53 -08:00
parent 0e4b1e00a7
commit 6a298872cc
2 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/cpp/ripple/Ledger.cpp
View File

@@ -400,8 +400,8 @@ uint256 Ledger::getHash()
return mHash; return mHash;
} }
void Ledger::saveAcceptedLedger(bool fromConsensus, LoadEvent::pointer event) void Ledger::saveAcceptedLedger(Job&, bool fromConsensus)
{ // can be called in a different thread {
cLog(lsTRACE) << "saveAcceptedLedger " << (fromConsensus ? "fromConsensus " : "fromAcquire ") << getLedgerSeq(); cLog(lsTRACE) << "saveAcceptedLedger " << (fromConsensus ? "fromConsensus " : "fromAcquire ") << getLedgerSeq();
static boost::format ledgerExists("SELECT LedgerSeq FROM Ledgers INDEXED BY SeqLedger where LedgerSeq = %d;"); static boost::format ledgerExists("SELECT LedgerSeq FROM Ledgers INDEXED BY SeqLedger where LedgerSeq = %d;");
static boost::format deleteLedger("DELETE FROM Ledgers WHERE LedgerSeq = %d;"); static boost::format deleteLedger("DELETE FROM Ledgers WHERE LedgerSeq = %d;");
@@ -1530,8 +1530,8 @@ void Ledger::pendSave(bool fromConsensus)
++sPendingSaves; ++sPendingSaves;
} }
boost::thread(boost::bind(&Ledger::saveAcceptedLedger, shared_from_this(), fromConsensus, theApp->getJobQueue().addJob(jtPUBOLDLEDGER, // FIXME not old if fromConsensus
theApp->getJobQueue().getLoadEvent(jtDISK, fromConsensus ? "Ledger::cSave" : "Ledger::save"))).detach(); boost::bind(&Ledger::saveAcceptedLedger, shared_from_this(), _1, fromConsensus));
} }

3
src/cpp/ripple/Ledger.h
View File

@@ -19,6 +19,7 @@
#include "SHAMap.h" #include "SHAMap.h"
#include "InstanceCounter.h" #include "InstanceCounter.h"
#include "LoadMonitor.h" #include "LoadMonitor.h"
#include "JobQueue.h"
enum LedgerStateParms enum LedgerStateParms
{ {
@@ -102,7 +103,7 @@ protected:
static void incPendingSaves(); static void incPendingSaves();
static void decPendingSaves(); static void decPendingSaves();
void saveAcceptedLedger(bool fromConsensus, LoadEvent::pointer); void saveAcceptedLedger(Job&, bool fromConsensus);
void updateFees(); void updateFees();
void zeroFees(); void zeroFees();