From bbfdeeaff5d1d73e4700991027f3e8b0c12aa9fc Mon Sep 17 00:00:00 2001 From: sech1 Date: Sun, 14 Sep 2025 00:04:25 +0200 Subject: [PATCH] Log submit_block RPC performance --- src/p2p_server.cpp | 9 +++++++-- src/p2pool.cpp | 7 ++++++- 2 files changed, 13 insertions(+), 3 deletions(-) diff --git a/src/p2p_server.cpp b/src/p2p_server.cpp index 43256a5..420fc86 100644 --- a/src/p2p_server.cpp +++ b/src/p2p_server.cpp @@ -1645,6 +1645,8 @@ void P2PServer::submit_monero_blocks() const Params::Host& host = m_pool->current_host(); + const uint64_t t1 = microseconds_since_epoch(); + JSONRPCRequest::call( host.m_address, host.m_rpcPort, @@ -1654,10 +1656,13 @@ void P2PServer::submit_monero_blocks() host.m_rpcSSL, host.m_rpcSSL_Fingerprint, JSONRPCRequest::dummy_callback, - [this](const char* data, size_t size, double) + [this, t1](const char* data, size_t size, double) { if (size > 0) { - LOGERR(3, "on_monero_block_broadcast: submit_block RPC request failed, error " << log::const_buf(data, size)); + LOGERR(3, "submit_monero_blocks: submit_block RPC request failed, error " << log::const_buf(data, size)); + } + else { + LOGINFO(4, "submit_monero_blocks: submit_block RPC completed in " << static_cast(microseconds_since_epoch() - t1) / 1e3 << " ms"); } if (!m_MoneroBlocksToSubmit.empty()) { diff --git a/src/p2pool.cpp b/src/p2pool.cpp index 5e64639..597912c 100644 --- a/src/p2pool.cpp +++ b/src/p2pool.cpp @@ -1121,6 +1121,8 @@ void p2pool::submit_block() const const Params::Host& host = current_host(); + const uint64_t t1 = microseconds_since_epoch(); + JSONRPCRequest::call(host.m_address, host.m_rpcPort, request, host.m_rpcLogin, m_params->m_socks5Proxy, host.m_rpcSSL, host.m_rpcSSL_Fingerprint, [height, diff, template_id, nonce, extra_nonce, merge_mining_root, is_external](const char* data, size_t size, double) { @@ -1166,7 +1168,7 @@ void p2pool::submit_block() const LOGWARN(0, "submit_block: daemon sent unrecognizable reply: " << log::const_buf(data, size)); }, - [is_external](const char* data, size_t size, double) + [is_external, t1](const char* data, size_t size, double) { if (size > 0) { if (is_external) { @@ -1176,6 +1178,9 @@ void p2pool::submit_block() const LOGERR(0, "submit_block: RPC request failed, error " << log::const_buf(data, size)); } } + else { + LOGINFO(4, "submit_block RPC completed in " << static_cast(microseconds_since_epoch() - t1) / 1e3 << " ms"); + } }); }