From 71e1152cdedc972823e672adc9b03092fdff2f36 Mon Sep 17 00:00:00 2001 From: jrandom Date: Wed, 17 Nov 2004 00:57:33 +0000 Subject: [PATCH] if we've already sent our close packet but we still want to send something, send an ack packet --- .../java/src/net/i2p/client/streaming/SchedulerClosing.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/apps/streaming/java/src/net/i2p/client/streaming/SchedulerClosing.java b/apps/streaming/java/src/net/i2p/client/streaming/SchedulerClosing.java index 0c17f7b61..61a399ba3 100644 --- a/apps/streaming/java/src/net/i2p/client/streaming/SchedulerClosing.java +++ b/apps/streaming/java/src/net/i2p/client/streaming/SchedulerClosing.java @@ -45,10 +45,14 @@ class SchedulerClosing extends SchedulerImpl { if (con.getNextSendTime() <= 0) con.setNextSendTime(_context.clock().now() + con.getOptions().getSendAckDelay()); long remaining = con.getNextSendTime() - _context.clock().now(); + if (_log.shouldLog(Log.DEBUG)) + _log.debug("Event occurred w/ remaining: " + remaining + " on " + con); if (remaining <= 0) { if (con.getCloseSentOn() <= 0) { con.sendAvailable(); con.setNextSendTime(_context.clock().now() + con.getOptions().getSendAckDelay()); + } else { + con.ackImmediately(); } } else { //if (remaining < 5*1000)