TaskSchedulerclass SchedulerConnectedBulk extends SchedulerImpl
Scheduler used for after our SYN has been sent and ACKed but one (or more) sides haven't closed the stream yet. In addition, the stream must be using the BULK profile, rather than the INTERACTIVE profile.
_context, _log| Constructor | Description |
|---|---|
SchedulerConnectedBulk(I2PAppContext ctx) |
| Modifier and Type | Method | Description |
|---|---|---|
boolean |
accept(Connection con) |
Determine whether this scheduler is fit to operate against the
given connection
|
void |
eventOccurred(Connection con) |
An event has occurred (timeout, message sent, or message received),
so schedule what to do next based on our current state.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitreschedule, toStringpublic SchedulerConnectedBulk(I2PAppContext ctx)
public boolean accept(Connection con)
TaskSchedulerpublic void eventOccurred(Connection con)
TaskScheduler