boldsuck/haveno
1
0
Fork 0
mirror of https://github.com/boldsuck/haveno.git synced 2025-01-07 00:30:08 +00:00
Code Issues 1 Projects Releases Packages Wiki Activity Actions

log connection read timeouts at info level

Browse source
This commit is contained in:
woodser 2024-12-28 08:31:30 -05:00
parent 6a798312fe
commit 2dc7405f82
1 changed files with 17 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
p2p/src/main/java/haveno/network/p2p/network/Connection.java
View file

@ -178,6 +178,8 @@ public class Connection implements HasCapabilities, Runnable, MessageListener {
private static int numThrottledInvalidRequestReports = 0; private static int numThrottledInvalidRequestReports = 0;
private static long lastLoggedWarningTs = 0; private static long lastLoggedWarningTs = 0;
private static int numThrottledWarnings = 0; private static int numThrottledWarnings = 0;
private static long lastLoggedInfoTs = 0;
private static int numThrottledInfos = 0;
/////////////////////////////////////////////////////////////////////////////////////////// ///////////////////////////////////////////////////////////////////////////////////////////
// Constructor // Constructor
@ -676,7 +678,7 @@ public class Connection implements HasCapabilities, Runnable, MessageListener {
throttleWarn("SocketException (expected if connection lost). closeConnectionReason=" + closeConnectionReason + "; connection=" + this); throttleWarn("SocketException (expected if connection lost). closeConnectionReason=" + closeConnectionReason + "; connection=" + this);
} else if (e instanceof SocketTimeoutException || e instanceof TimeoutException) { } else if (e instanceof SocketTimeoutException || e instanceof TimeoutException) {
closeConnectionReason = CloseConnectionReason.SOCKET_TIMEOUT; closeConnectionReason = CloseConnectionReason.SOCKET_TIMEOUT;
throttleWarn("Shut down caused by exception " + e.getMessage() + " on connection=" + this); throttleInfo("Shut down caused by exception " + e.getMessage() + " on connection=" + this);
} else if (e instanceof EOFException) { } else if (e instanceof EOFException) {
closeConnectionReason = CloseConnectionReason.TERMINATED; closeConnectionReason = CloseConnectionReason.TERMINATED;
throttleWarn("Shut down caused by exception " + e.getMessage() + " on connection=" + this); throttleWarn("Shut down caused by exception " + e.getMessage() + " on connection=" + this);
@ -937,8 +939,8 @@ public class Connection implements HasCapabilities, Runnable, MessageListener {
} }
private synchronized void throttleWarn(String msg) { private synchronized void throttleWarn(String msg) {
boolean logWarning = System.currentTimeMillis() - lastLoggedWarningTs > LOG_THROTTLE_INTERVAL_MS; boolean doLog = System.currentTimeMillis() - lastLoggedWarningTs > LOG_THROTTLE_INTERVAL_MS;
if (logWarning) { if (doLog) {
log.warn(msg); log.warn(msg);
if (numThrottledWarnings > 0) log.warn("{} warnings were throttled since the last log entry", numThrottledWarnings); if (numThrottledWarnings > 0) log.warn("{} warnings were throttled since the last log entry", numThrottledWarnings);
numThrottledWarnings = 0; numThrottledWarnings = 0;
@ -947,4 +949,16 @@ public class Connection implements HasCapabilities, Runnable, MessageListener {
numThrottledWarnings++; numThrottledWarnings++;
} }
} }
private synchronized void throttleInfo(String msg) {
boolean doLog = System.currentTimeMillis() - lastLoggedInfoTs > LOG_THROTTLE_INTERVAL_MS;
if (doLog) {
log.info(msg);
if (numThrottledInfos > 0) log.info("{} info logs were throttled since the last log entry", numThrottledInfos);
numThrottledInfos = 0;
lastLoggedInfoTs = System.currentTimeMillis();
} else {
numThrottledInfos++;
}
}
} }