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

Put ledgerAdvance jobs in their own class.

Browse Source
This commit is contained in:
JoelKatz
2013-08-13 14:05:32 -07:00
parent e94f895754
commit fcd7522922
4 changed files with 15 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
modules/ripple_app/ledger/LedgerMaster.cpp
View File

@@ -746,7 +746,7 @@ void LedgerMaster::tryAdvance()
if (!mAdvanceThread && mValidLedger) if (!mAdvanceThread && mValidLedger)
{ {
mAdvanceThread = true; mAdvanceThread = true;
getApp().getJobQueue ().addJob (jtPUBLEDGER, "Ledger::advanceThread", getApp().getJobQueue ().addJob (jtADVANCE, "advanceLedger",
BIND_TYPE (&LedgerMaster::advanceThread, this)); BIND_TYPE (&LedgerMaster::advanceThread, this));
} }
} }

3
modules/ripple_core/functional/ripple_Job.cpp
View File

@@ -88,6 +88,9 @@ const char* Job::toString (JobType t)
case jtPUBLEDGER: case jtPUBLEDGER:
return "publishNewLedger"; return "publishNewLedger";
case jtADVANCE:
return "advanceLedger";
case jtVALIDATION_t: case jtVALIDATION_t:
return "trustedValidation"; return "trustedValidation";

17
modules/ripple_core/functional/ripple_Job.h
View File

@@ -23,14 +23,15 @@ enum JobType
jtUPDATE_PF = 8, // Update pathfinding requests jtUPDATE_PF = 8, // Update pathfinding requests
jtCLIENT = 9, // A websocket command from the client jtCLIENT = 9, // A websocket command from the client
jtTRANSACTION = 10, // A transaction received from the network jtTRANSACTION = 10, // A transaction received from the network
jtPUBLEDGER = 11, // Publish a fully-accepted ledger jtADVANCE = 11, // Advance validated/acquired ledgers
jtTXN_DATA = 12, // Fetch a proposed set jtPUBLEDGER = 12, // Publish a fully-accepted ledger
jtWAL = 13, // Write-ahead logging jtTXN_DATA = 13, // Fetch a proposed set
jtVALIDATION_t = 14, // A validation from a trusted source jtWAL = 14, // Write-ahead logging
jtWRITE = 15, // Write out hashed objects jtVALIDATION_t = 15, // A validation from a trusted source
jtPROPOSAL_t = 16, // A proposal from a trusted source jtWRITE = 16, // Write out hashed objects
jtSWEEP = 17, // Sweep for stale structures jtPROPOSAL_t = 17, // A proposal from a trusted source
jtADMIN = 18, // An administrative operation jtSWEEP = 18, // Sweep for stale structures
jtADMIN = 19, // An administrative operation
// special types not dispatched by the job pool // special types not dispatched by the job pool
jtPEER = 24, jtPEER = 24,

1
modules/ripple_core/functional/ripple_JobQueue.cpp
View File

@@ -454,6 +454,7 @@ int JobQueue::getJobLimit (JobType type)
case jtCLIENT: case jtCLIENT:
case jtTRANSACTION: case jtTRANSACTION:
case jtPUBLEDGER: case jtPUBLEDGER:
case jtADVANCE:
case jtWAL: case jtWAL:
case jtVALIDATION_t: case jtVALIDATION_t:
case jtWRITE: case jtWRITE: