java.lang.Object
net.i2p.client.streaming.impl.SchedulerImpl
net.i2p.client.streaming.impl.SchedulerReceived
All Implemented Interfaces:
TaskScheduler

class SchedulerReceivedextends SchedulerImpl
Scheduler used after receiving an inbound connection but before we have sent our own SYN.
  • Constructor Details

    • SchedulerReceived

      public SchedulerReceived(I2PAppContext ctx)
      Sets up the scheduler for connections awaiting our own SYN.
      Parameters:
      ctx - the application context supplying the clock and log used by the scheduler
  • Method Details

    • accept

      public boolean accept(Connection con)
      Accept connections that have received a SYN but haven't sent one.
      Parameters:
      con - the connection to check
      Returns:
      true if the connection is in the received state
    • eventOccurred

      public void eventOccurred(Connection con)
      Handle an event on a received connection. Sends the SYN when the send delay has elapsed.
      Parameters:
      con - the connection that had an event