I2P_Developers/i2p.itoopie
3
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

if we've already sent our close packet but we still want to send something, send an ack packet

Browse Source
This commit is contained in:
jrandom
2004-11-17 00:57:33 +00:00
committed by zzz
parent d01ab7fd23
commit 71e1152cde
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
apps/streaming/java/src/net/i2p/client/streaming/SchedulerClosing.java
View File

@ -45,10 +45,14 @@ class SchedulerClosing extends SchedulerImpl {
if (con.getNextSendTime() <= 0) if (con.getNextSendTime() <= 0)
con.setNextSendTime(_context.clock().now() + con.getOptions().getSendAckDelay()); con.setNextSendTime(_context.clock().now() + con.getOptions().getSendAckDelay());
long remaining = con.getNextSendTime() - _context.clock().now(); 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 (remaining <= 0) {
if (con.getCloseSentOn() <= 0) { if (con.getCloseSentOn() <= 0) {
con.sendAvailable(); con.sendAvailable();
con.setNextSendTime(_context.clock().now() + con.getOptions().getSendAckDelay()); con.setNextSendTime(_context.clock().now() + con.getOptions().getSendAckDelay());
} else {
con.ackImmediately();
} }
} else { } else {
//if (remaining < 5*1000) //if (remaining < 5*1000)