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

SSU: Minor cleanup of congestion checkin

Browse Source
This commit is contained in:
zzz
2020-10-23 16:05:39 +00:00
parent 9b3ff9e615
commit 15da2f85ad
2 changed files with 3 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
router/java/src/net/i2p/router/transport/udp/PeerState.java
View File

@ -1712,16 +1712,8 @@ public class PeerState {
if (should) { if (should) {
if (_log.shouldLog(Log.DEBUG)) if (_log.shouldLog(Log.DEBUG))
_log.debug("Allocate sending (OLD) to " + _remotePeer + ": " + state.getMessageId()); _log.debug("Allocate sending (OLD) to " + _remotePeer + ": " + state.getMessageId());
/*
while (iter.hasNext()) {
OutboundMessageState later = (OutboundMessageState)iter.next();
OutNetMessage msg = later.getMessage();
if (msg != null)
msg.timestamp("not reached for allocation " + msgs.size() + " other peers");
}
*/
if (rv == null) if (rv == null)
rv = new ArrayList<OutboundMessageState>(_outboundMessages.size()); rv = new ArrayList<OutboundMessageState>((1 + _outboundMessages.size()) / 2);
rv.add(state); rv.add(state);
if (rv.size() >= _outboundMessages.size() / 2) if (rv.size() >= _outboundMessages.size() / 2)
return rv; return rv;
@ -1740,7 +1732,7 @@ public class PeerState {
return rv; return rv;
} }
} }
return null; return rv;
} }
// Peek at head of _outboundQueue and see if we can send it. // Peek at head of _outboundQueue and see if we can send it.
// If so, pull it off, put it in _outbundMessages, test // If so, pull it off, put it in _outbundMessages, test

2
router/java/src/net/i2p/router/transport/udp/UDPTransport.java
View File

@ -347,7 +347,7 @@ public class UDPTransport extends TransportImpl implements TimedWeightedPriority
} }
/** /**
* @returns the instance of OutboundMessageFragments * @return the instance of OutboundMessageFragments
* @since 0.9.48 * @since 0.9.48
*/ */
OutboundMessageFragments getOMF() { OutboundMessageFragments getOMF() {