diff --git a/apps/streaming/java/src/net/i2p/client/streaming/PacketLocal.java b/apps/streaming/java/src/net/i2p/client/streaming/PacketLocal.java index 5dcc4e5120ffd37ecb723ff48f109f437d9d0657..31c008c48b98964c84710987fd15c91d76ab1e01 100644 --- a/apps/streaming/java/src/net/i2p/client/streaming/PacketLocal.java +++ b/apps/streaming/java/src/net/i2p/client/streaming/PacketLocal.java @@ -157,10 +157,10 @@ class PacketLocal extends Packet implements MessageOutputStream.WriteStatus { final int cnt = _nackCount.incrementAndGet(); SimpleTimer2.TimedEvent evt = _resendEvent; if (cnt >= Connection.FAST_RETRANSMIT_THRESHOLD && evt != null && (!_retransmitted) && - (_numSends == 1 || _lastSend < _context.clock().now() + 4*1000)) { // Don't fast retx if we recently resent it + (_numSends == 1 || _lastSend < _context.clock().now() - 4*1000)) { // Don't fast retx if we recently resent it _retransmitted = true; evt.reschedule(0); - // shouldn't ^^^ be clock.now() - 4000 ??? --zab + // the predicate used to be '+', changing to '-' --zab if (_log.shouldLog(Log.DEBUG)) { final String log = String.format("%s nacks and retransmits. Criteria: nacks=%d, retransmitted=%b,"+