mirror of
https://github.com/XRPLF/rippled.git
synced 2025-11-27 14:35:52 +00:00
Add RPC to load tracking.
This commit is contained in:
@@ -24,6 +24,7 @@ const char* Job::toString(JobType t)
|
|||||||
case jtPEER: return "peerCommand";
|
case jtPEER: return "peerCommand";
|
||||||
case jtDISK: return "diskAccess";
|
case jtDISK: return "diskAccess";
|
||||||
case jtLEDGER: return "acceptLedger";
|
case jtLEDGER: return "acceptLedger";
|
||||||
|
case jtRPC: return "rpc";
|
||||||
default: assert(false); return "unknown";
|
default: assert(false); return "unknown";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -37,6 +37,7 @@ enum JobType
|
|||||||
jtPEER = 11,
|
jtPEER = 11,
|
||||||
jtDISK = 12,
|
jtDISK = 12,
|
||||||
jtLEDGER = 13,
|
jtLEDGER = 13,
|
||||||
|
jtRPC = 14,
|
||||||
};
|
};
|
||||||
#define NUM_JOB_TYPES 16
|
#define NUM_JOB_TYPES 16
|
||||||
|
|
||||||
|
|||||||
@@ -1318,6 +1318,8 @@ Json::Value RPCHandler::doCommand(const std::string& command, Json::Value& param
|
|||||||
cLog(lsTRACE) << "RPC:" << command;
|
cLog(lsTRACE) << "RPC:" << command;
|
||||||
cLog(lsTRACE) << "RPC params:" << params;
|
cLog(lsTRACE) << "RPC params:" << params;
|
||||||
|
|
||||||
|
LoadEvent::pointer le = theApp->getJobQueue().getLoadEvent(jtRPC);
|
||||||
|
|
||||||
mRole = role;
|
mRole = role;
|
||||||
|
|
||||||
static struct {
|
static struct {
|
||||||
|
|||||||
Reference in New Issue
Block a user