Class SchedulerConnecting

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

class SchedulerConnecting extends SchedulerImpl

Scheduler used once we've sent our SYN but it hasn't been ACKed yet. This connection may or may not be locally created.

Entry conditions:

  • Packets sent but none ACKed

Events:

  • Packets received (which may or may not ACK the ones sent)
  • Message flush (explicitly, through a full buffer, or stream closure)
  • Connection establishment timeout
  • RESET received

Next states:

  • connected - after receiving an ACK
  • closing - after both sending and receiving a CLOSE
  • closed - after both sending and receiving ACKs on the CLOSE
  • dead - after sending or receiving a RESET
  • Constructor Details

    • SchedulerConnecting

      public SchedulerConnecting(I2PAppContext ctx)
  • Method Details

    • accept

      public boolean accept(Connection con)
      Description copied from interface: TaskScheduler
      Determine whether this scheduler is fit to operate against the given connection
    • eventOccurred

      public void eventOccurred(Connection con)
      Description copied from interface: TaskScheduler
      An event has occurred (timeout, message sent, or message received), so schedule what to do next based on our current state.