I2P Address: [http://git.idk.i2p]

Skip to content
Snippets Groups Projects
Commit a5b68d4f authored by zzz's avatar zzz
Browse files

* I2CP: Reduce log level when outbound queue is full (ticket #758)

parent 8a7d1199
No related branches found
No related tags found
No related merge requests found
...@@ -56,7 +56,7 @@ import net.i2p.util.SimpleTimer; ...@@ -56,7 +56,7 @@ import net.i2p.util.SimpleTimer;
* @author jrandom * @author jrandom
*/ */
class ClientConnectionRunner { class ClientConnectionRunner {
private final Log _log; protected final Log _log;
protected final RouterContext _context; protected final RouterContext _context;
private final ClientManager _manager; private final ClientManager _manager;
/** socket for this particular peer connection */ /** socket for this particular peer connection */
......
...@@ -5,6 +5,7 @@ import net.i2p.data.i2cp.I2CPMessageException; ...@@ -5,6 +5,7 @@ import net.i2p.data.i2cp.I2CPMessageException;
import net.i2p.internal.I2CPMessageQueue; import net.i2p.internal.I2CPMessageQueue;
import net.i2p.internal.QueuedI2CPMessageReader; import net.i2p.internal.QueuedI2CPMessageReader;
import net.i2p.router.RouterContext; import net.i2p.router.RouterContext;
import net.i2p.util.Log;
/** /**
* Zero-copy in-JVM. * Zero-copy in-JVM.
...@@ -67,8 +68,8 @@ class QueuedClientConnectionRunner extends ClientConnectionRunner { ...@@ -67,8 +68,8 @@ class QueuedClientConnectionRunner extends ClientConnectionRunner {
// with non-blocking writes for the router // with non-blocking writes for the router
// and blocking writes for the client? // and blocking writes for the client?
boolean success = queue.offer(msg); boolean success = queue.offer(msg);
if (!success) if (!success && _log.shouldLog(Log.WARN))
throw new I2CPMessageException("I2CP write to queue failed"); _log.warn("I2CP write to queue failed: " + msg);
} }
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment