From 75eda7e1b140d181bc35856071593536af759e17 Mon Sep 17 00:00:00 2001
From: zzz <zzz@mail.i2p>
Date: Thu, 1 Mar 2012 23:52:56 +0000
Subject: [PATCH] log tweak
---
.../src/net/i2p/client/streaming/ConnectionManager.java | 9 +++------
1 file changed, 3 insertions(+), 6 deletions(-)
diff --git a/apps/streaming/java/src/net/i2p/client/streaming/ConnectionManager.java b/apps/streaming/java/src/net/i2p/client/streaming/ConnectionManager.java
index f50a4b5cc8..6e8811a2fe 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/ConnectionManager.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/ConnectionManager.java
@@ -161,8 +161,7 @@ class ConnectionManager {
// active++;
//}
if (locked_tooManyStreams()) {
- if (_log.shouldLog(Log.WARN))
- _log.warn("Refusing connection since we have exceeded our max of "
+ _log.logAlways(Log.WARN, "Refusing connection since we have exceeded our max of "
+ _maxConcurrentStreams + " connections");
reject = true;
} else {
@@ -233,8 +232,7 @@ class ConnectionManager {
while (true) {
long remaining = expiration - _context.clock().now();
if (remaining <= 0) {
- if (_log.shouldLog(Log.WARN))
- _log.warn("Refusing to connect since we have exceeded our max of "
+ _log.logAlways(Log.WARN, "Refusing to connect since we have exceeded our max of "
+ _maxConcurrentStreams + " connections");
_numWaiting--;
return null;
@@ -243,8 +241,7 @@ class ConnectionManager {
if (locked_tooManyStreams()) {
// allow a full buffer of pending/waiting streams
if (_numWaiting > _maxConcurrentStreams) {
- if (_log.shouldLog(Log.WARN))
- _log.warn("Refusing connection since we have exceeded our max of "
+ _log.logAlways(Log.WARN, "Refusing connection since we have exceeded our max of "
+ _maxConcurrentStreams + " and there are " + _numWaiting
+ " waiting already");
_numWaiting--;
--
GitLab