diff --git a/src/cpp/ripple/JobQueue.cpp b/src/cpp/ripple/JobQueue.cpp index dd730dcb6..e8840537b 100644 --- a/src/cpp/ripple/JobQueue.cpp +++ b/src/cpp/ripple/JobQueue.cpp @@ -24,6 +24,7 @@ const char* Job::toString(JobType t) case jtPEER: return "peerCommand"; case jtDISK: return "diskAccess"; case jtLEDGER: return "acceptLedger"; + case jtRPC: return "rpc"; default: assert(false); return "unknown"; } } diff --git a/src/cpp/ripple/JobQueue.h b/src/cpp/ripple/JobQueue.h index 1101cc2f7..4f0ce559c 100644 --- a/src/cpp/ripple/JobQueue.h +++ b/src/cpp/ripple/JobQueue.h @@ -37,6 +37,7 @@ enum JobType jtPEER = 11, jtDISK = 12, jtLEDGER = 13, + jtRPC = 14, }; #define NUM_JOB_TYPES 16 diff --git a/src/cpp/ripple/RPCHandler.cpp b/src/cpp/ripple/RPCHandler.cpp index ba9f6f78b..a9564872c 100644 --- a/src/cpp/ripple/RPCHandler.cpp +++ b/src/cpp/ripple/RPCHandler.cpp @@ -1318,6 +1318,8 @@ Json::Value RPCHandler::doCommand(const std::string& command, Json::Value& param cLog(lsTRACE) << "RPC:" << command; cLog(lsTRACE) << "RPC params:" << params; + LoadEvent::pointer le = theApp->getJobQueue().getLoadEvent(jtRPC); + mRole = role; static struct {