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

log request and duration for every RPC call

Browse Source
This commit is contained in:
CJ Cobb
2021-11-11 16:09:25 -05:00
committed by manojsdoshi
parent db720a59e4
commit 915fe31274
1 changed files with 26 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
src/ripple/rpc/impl/ServerHandlerImp.cpp
View File

@@ -377,6 +377,25 @@ ServerHandlerImp::onStopped(Server&)
//------------------------------------------------------------------------------ //------------------------------------------------------------------------------
template <class T>
void
logDuration(
Json::Value const& request,
T const& duration,
beast::Journal& journal)
{
using namespace std::chrono_literals;
auto const level = (duration >= 10s)
? journal.error()
: (duration >= 1s) ? journal.warn() : journal.debug();
JLOG(level) << "RPC request processing duration = "
<< std::chrono::duration_cast<std::chrono::microseconds>(
duration)
.count()
<< " microseconds. request = " << request;
}
Json::Value Json::Value
ServerHandlerImp::processSession( ServerHandlerImp::processSession(
std::shared_ptr<WSSession> const& session, std::shared_ptr<WSSession> const& session,
@@ -458,7 +477,10 @@ ServerHandlerImp::processSession(
jv, jv,
{is->user(), is->forwarded_for()}}; {is->user(), is->forwarded_for()}};
auto start = std::chrono::system_clock::now();
RPC::doCommand(context, jr[jss::result]); RPC::doCommand(context, jr[jss::result]);
auto end = std::chrono::system_clock::now();
logDuration(jv, end - start, m_journal);
} }
} }
catch (std::exception const& ex) catch (std::exception const& ex)
@@ -851,7 +873,11 @@ ServerHandlerImp::processRequest(
params, params,
{user, forwardedFor}}; {user, forwardedFor}};
Json::Value result; Json::Value result;
auto start = std::chrono::system_clock::now();
RPC::doCommand(context, result); RPC::doCommand(context, result);
auto end = std::chrono::system_clock::now();
logDuration(params, end - start, m_journal);
usage.charge(loadType); usage.charge(loadType);
if (usage.warn()) if (usage.warn())
result[jss::warning] = jss::load; result[jss::warning] = jss::load;