diff --git a/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java b/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java index 4ad84d2592bb6a2d170b263d5aae9d02ccdc44c7..33f4eb15d12bd9c80d4eb81f2a5cabcb69aebe4e 100644 --- a/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java +++ b/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java @@ -119,7 +119,7 @@ class NTCPConnection implements FIFOBandwidthLimiter.CompleteListener { private final byte _meta[] = new byte[META_SIZE]; private boolean _sendingMeta; /** how many consecutive sends were failed due to (estimated) send queue time */ - private int _consecutiveBacklog; + //private int _consecutiveBacklog; private long _nextInfoTime; /* @@ -253,8 +253,6 @@ class NTCPConnection implements FIFOBandwidthLimiter.CompleteListener { /** @return milliseconds */ public long getTimeSinceCreated() { return System.currentTimeMillis()-_created; } - public int getConsecutiveBacklog() { return _consecutiveBacklog; } - /** * workaround for EventPumper * @since 0.8.12 @@ -367,6 +365,8 @@ class NTCPConnection implements FIFOBandwidthLimiter.CompleteListener { } ****/ + public boolean isBacklogged() { return _outbound.isBacklogged(); } + public boolean tooBacklogged() { //long queueTime = queueTime(); //if (queueTime <= 0) return false; diff --git a/router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java b/router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java index d49642ad748506c95b944466dc24ff0b27a2ff3a..fde13148cf853e10b8c810f47dd5c92796cf96b2 100644 --- a/router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java +++ b/router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java @@ -807,7 +807,7 @@ public class NTCPTransport extends TransportImpl { long outQueue = con.getOutboundQueueSize(); buf.append("</td><td class=\"cells\" align=\"center\">").append(outQueue); buf.append("</td><td class=\"cells\" align=\"center\">"); - if (con.getConsecutiveBacklog() > 0) + if (con.isBacklogged()) buf.append("✓"); else buf.append(" ");