I2PSessionMuxedImpl.MuxedAvailabilityNotifier

java.lang.Object

net.i2p.client.impl.I2PSessionImpl.AvailabilityNotifier

net.i2p.client.impl.I2PSessionMuxedImpl.MuxedAvailabilityNotifier

All Implemented Interfaces:: Runnable

Enclosing class:: I2PSessionMuxedImpl

protected class I2PSessionMuxedImpl.MuxedAvailabilityNotifierextends I2PSessionImpl.AvailabilityNotifier

MuxedAvailabilityNotifier Extends AvailabilityNotifier.

Field Summary
Fields
Modifier and Type
Field
Description
private boolean
_alive
True while the queue runs.
private final LinkedBlockingQueue<I2PSessionMuxedImpl.MsgData>
_msgs
The messages waiting to be delivered.
private static final int
POISON_SIZE
The poison size that ends the queue.
private final AtomicBoolean
stopping
True once stopping was asked.
Constructor Summary
Constructors
Constructor
Description
MuxedAvailabilityNotifier()
Create a notifier with an empty pending queue.
Method Summary
All Methods
Modifier and Type
Method
Description
void
available(long msgId, int size)
Notify that a message is available.
void
available(long msgId, int size, int proto, int fromPort, int toPort)
Notify that data is available.
void
run()
Notify the client thread of available messages, until stopNotifying() is called.
void
stopNotifying()
Stop availability notifications.
Methods inherited from class Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- _msgs
  private final LinkedBlockingQueue<I2PSessionMuxedImpl.MsgData> _msgs
  The messages waiting to be delivered.
- _alive
  private volatile boolean _alive
  True while the queue runs.
- POISON_SIZE
  private static final int POISON_SIZE
  The poison size that ends the queue.
  See Also:
  Constant Field Values
- stopping
  private final AtomicBoolean stopping
  True once stopping was asked.
Constructor Details
- MuxedAvailabilityNotifier
  public MuxedAvailabilityNotifier()
  Create a notifier with an empty pending queue.
Method Details
- stopNotifying
  public void stopNotifying()
  Stop availability notifications.
  Overrides:
  stopNotifying in class I2PSessionImpl.AvailabilityNotifier
- available
  public void available(long msgId, int size)
  Description copied from class: I2PSessionImpl.AvailabilityNotifier
  Notify that a message is available.
  Overrides:
  available in class I2PSessionImpl.AvailabilityNotifier
  Parameters:
  msgId - the message ID
  size - the unencrypted payload length in bytes
- available
  public void available(long msgId, int size, int proto, int fromPort, int toPort)
  Notify that data is available.
  Parameters:
  msgId - the message id the data arrived for
  size - the size of the message in bytes
  proto - the I2CP protocol number the message was received on
  fromPort - the origin port at the remote router that sent it
  toPort - the destination port at this router it was sent to
- run
  public void run()
  Notify the client thread of available messages, until stopNotifying() is called.
  Specified by:
  run in interface Runnable
  Overrides:
  run in class I2PSessionImpl.AvailabilityNotifier

Field Summary

Constructor Summary

Method Summary

Methods inherited from class Object

Field Details

_msgs

_alive

POISON_SIZE

stopping

Constructor Details

MuxedAvailabilityNotifier

Method Details

stopNotifying

available

available

run