SchedulerImpl | Javadocs [I2P+]

java.lang.Object

net.i2p.client.streaming.impl.SchedulerImpl

All Implemented Interfaces:: TaskScheduler

Direct Known Subclasses:: SchedulerClosed, SchedulerClosing, SchedulerConnectedBulk, SchedulerConnecting, SchedulerDead, SchedulerHardDisconnected, SchedulerPreconnect, SchedulerReceived

abstract class SchedulerImplextends Object implements TaskScheduler

Base class for connection state schedulers. Provides common utilities for rescheduling events and logging.

Field Summary
Fields
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
SchedulerImpl(I2PAppContext ctx)
Create a new scheduler with the given context.
Method Summary
Public Methods
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
Methods inherited from interface TaskScheduler
accept, eventOccurred
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.

Field Details
- _context
  protected final I2PAppContext _context
  Application context the scheduled connections live in.
- _log
  protected final Log _log
  Logger scoped to this scheduler class.
Constructor Details
- SchedulerImpl
  public SchedulerImpl(I2PAppContext ctx)
  Create a new scheduler with the given context.
  Parameters:
  ctx - the application context
Method Details
- reschedule
  protected void reschedule(long msToWait, Connection con)
  Schedule a connection event to occur after the specified delay.
  Parameters:
  msToWait - the delay in milliseconds
  con - the connection to reschedule
- toString
  public String toString()
  Name of the scheduler class.
  Overrides:
  toString in class Object