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

SSU: Remove unneeded old queue latency check in UDPSender

Browse Source 
as the queue is CoDel already
reported by drzed
This commit is contained in:
zzz
2022-11-23 09:53:09 -05:00
parent 0d571a5565
commit 98477eef9f
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
router/java/src/net/i2p/router/transport/udp/UDPSender.java
View File

@@ -183,9 +183,7 @@ class UDPSender {
********/
add(packet);
}
private static final int MAX_HEAD_LIFETIME = 3*1000;
/**
* Put it on the queue.
* BLOCKING if queue is full (backs up PacketPusher thread)
@@ -311,11 +309,11 @@ class UDPSender {
_log.warn("Stop sending on " + _endpoint);
_outboundQueue.clear();
}
/** @return next packet in queue. Will discard any packet older than MAX_HEAD_LIFETIME */
/** @return next packet in queue */
private UDPPacket getNextPacket() {
UDPPacket packet = null;
while ( (_keepRunning) && (packet == null || packet.getLifetime() > MAX_HEAD_LIFETIME) ) {
while (_keepRunning && packet == null) {
if (packet != null) {
_context.statManager().addRateData("udp.sendQueueTrimmed", 1);
packet.release();