AGentooCat/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix NTCP backlogged indication

Browse Source
This commit is contained in:
zzz
2012-09-18 12:37:30 +00:00
parent 2c4910e9e7
commit bd57463d42
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java
View File

@@ -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;

2
router/java/src/net/i2p/router/transport/ntcp/NTCPTransport.java
View File

@@ -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("&#x2713;");
else
buf.append("&nbsp;");