SchedulerClosed | Javadocs [I2P+]

java.lang.Object

net.i2p.client.streaming.impl.SchedulerImpl

net.i2p.client.streaming.impl.SchedulerClosed

All Implemented Interfaces:: TaskScheduler

class SchedulerClosedextends SchedulerImpl

Scheduler used for after both sides have had their close packets ACKed, but the final timeout hasn't passed.

Entry conditions:

Both sides have closed and ACKed.
Less than the final timeout period has passed since the last ACK.

Events:

Packets received
RESET received
Message sending fails (error talking to the session)

Next states:

dead - after the final timeout passes

Field Summary
Fields inherited from class SchedulerImpl
_context, _log
Modifier and Type
Field
Description
protected final I2PAppContext
_context
Application context the scheduled connections live in.
protected final Log
_log
Logger scoped to this scheduler class.
Constructor Summary
Constructors
Constructor
Description
SchedulerClosed(I2PAppContext ctx)
Creates the closed-connection scheduler for the given application context.
Method Summary
All Methods
Modifier and Type
Method
Description
boolean
accept(Connection con)
Accept connections where both sides have closed and ACKed, and the final timeout hasn't passed.
void
eventOccurred(Connection con)
Handles the scheduler event; a no-op as the timeout is handled by the timer.
Methods inherited from class SchedulerImpl
reschedule, toString
Modifier and Type
Method
Description
protected void
reschedule(long msToWait, Connection con)
Schedule a connection event to occur after the specified delay.
String
toString()
Name of the scheduler class.
Methods inherited from class Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- SchedulerClosed
  public SchedulerClosed(I2PAppContext ctx)
  Creates the closed-connection scheduler for the given application context.
  Parameters:
  ctx - the context supplying the router, client and clock services
Method Details
- accept
  public boolean accept(Connection con)
  Accept connections where both sides have closed and ACKed, and the final timeout hasn't passed.
  Parameters:
  con - the connection to check
  Returns:
  true if the connection is in the closed state
- eventOccurred
  public void eventOccurred(Connection con)
  Handles the scheduler event; a no-op as the timeout is handled by the timer.
  Parameters:
  con - the connection on which the event occurred