mirror of
https://github.com/i2p/i2p.i2p.git
synced 2026-06-08 15:11:51 +00:00
jrandom
aef33548b3
* Reworded the SSU introductions config section (thanks duck!)
* Force identity content encoding for I2PTunnel httpserver requests
(thanks redzara!)
* Further x-i2p-gzip bugfixes for the end of streams
* Reduce the minimum bandwidth limits to 3KBps steady and burst (though
I2P's performance at 3KBps is another issue)
* Cleaned up some streaming lib structures
49 lines
1.6 KiB
Java
49 lines
1.6 KiB
Java
package net.i2p.client.streaming;
|
|
|
|
import net.i2p.I2PAppContext;
|
|
import net.i2p.util.Log;
|
|
|
|
/**
|
|
* Scheduler used after receiving an inbound connection but before
|
|
* we have sent our own SYN.
|
|
*
|
|
*/
|
|
class SchedulerReceived extends SchedulerImpl {
|
|
private Log _log;
|
|
|
|
public SchedulerReceived(I2PAppContext ctx) {
|
|
super(ctx);
|
|
_log = ctx.logManager().getLog(SchedulerReceived.class);
|
|
}
|
|
|
|
public boolean accept(Connection con) {
|
|
return (con != null) &&
|
|
(con.getLastSendId() < 0) &&
|
|
(con.getSendStreamId() > 0);
|
|
}
|
|
|
|
public void eventOccurred(Connection con) {
|
|
if (con.getUnackedPacketsReceived() <= 0) {
|
|
if (_log.shouldLog(Log.WARN))
|
|
_log.warn("hmm, state is received, but no unacked packets received?");
|
|
return;
|
|
}
|
|
|
|
long timeTillSend = con.getNextSendTime() - _context.clock().now();
|
|
if (timeTillSend <= 0) {
|
|
if (con.getNextSendTime() > 0) {
|
|
if (_log.shouldLog(Log.DEBUG))
|
|
_log.debug("received con... send a packet");
|
|
con.sendAvailable();
|
|
con.setNextSendTime(-1);
|
|
} else {
|
|
con.setNextSendTime(_context.clock().now() + con.getOptions().getSendAckDelay());
|
|
reschedule(con.getOptions().getSendAckDelay(), con);
|
|
}
|
|
} else {
|
|
if (_log.shouldLog(Log.DEBUG))
|
|
_log.debug("received con... time till next send: " + timeTillSend);
|
|
reschedule(timeTillSend, con);
|
|
}
|
|
}
|
|
} |