ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2026-06-03 00:36:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

reduce log verbosity

Browse Source
This commit is contained in:
Vito
2025-09-04 12:40:33 +02:00
parent a5bdb3cef5
commit c487b41d1f
2 changed files with 21 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/xrpld/overlay/detail/ConnectAttempt.cpp
View File

@@ -160,8 +160,14 @@ ConnectAttempt::onShutdown(error_code ec)
// - stream_truncated: the tcp connection closed (no handshake) it could
// occur if a peer does not perform a graceful disconnect
// - broken_pipe: the peer is gone
if (ec != boost::asio::error::eof &&
ec != boost::asio::error::operation_aborted)
// - application data after close notify: benign SSL shutdown condition
bool shouldLog =
(ec != boost::asio::error::eof &&
ec != boost::asio::error::operation_aborted &&
ec.message().find("application data after close notify") ==
std::string::npos);
if (shouldLog)
{
JLOG(journal_.debug()) << "onShutdown: " << ec.message();
}

17
src/xrpld/overlay/detail/PeerImp.cpp
View File

@@ -669,8 +669,13 @@ PeerImp::onShutdown(error_code ec)
// - stream_truncated: the tcp connection closed (no handshake) it could
// occur if a peer does not perform a graceful disconnect
// - broken_pipe: the peer is gone
if (ec != boost::asio::error::eof &&
ec != boost::asio::error::operation_aborted)
bool shouldLog =
(ec != boost::asio::error::eof &&
ec != boost::asio::error::operation_aborted &&
ec.message().find("application data after close notify") ==
std::string::npos);
if (shouldLog)
{
JLOG(journal_.debug()) << "onShutdown: " << ec.message();
}
@@ -715,8 +720,8 @@ PeerImp::setTimer(std::chrono::seconds interval)
catch (std::exception const& ex)
{
JLOG(journal_.error()) << "setTimer: " << ex.what();
return close();
};
return shutdown();
}
timer_.async_wait(bind_executor(
strand_,
@@ -965,6 +970,9 @@ PeerImp::onReadMessage(error_code ec, std::size_t bytes_transferred)
return fail("onReadMessage", ec);
}
// we started shutdown, no reason to process further data
if (shutdown_)
return tryAsyncShutdown();
if (auto stream = journal_.trace())
{
@@ -1007,6 +1015,7 @@ PeerImp::onReadMessage(error_code ec, std::size_t bytes_transferred)
read_buffer_.consume(bytes_consumed);
}
// check if a shutdown was initiated while processing messages
if (shutdown_)
return tryAsyncShutdown();