java.lang.Object
net.i2p.sam.SAMStreamSession.StreamSender
net.i2p.sam.SAMStreamSession.V1StreamSender
All Implemented Interfaces:
Runnable
Enclosing class:
SAMStreamSession
private class SAMStreamSession.V1StreamSenderextends SAMStreamSession.StreamSender
SAM V1 stream session sender.

  • Field Details

    • _data

      private final List<ByteArray> _data
      Pending outbound data buffers.

    • _cache

      private final ByteCache _cache
      Byte cache for packet buffers.

    • _out

      private final OutputStream _out
      Output stream for the I2P socket.

    • _stillRunning

      private volatile boolean _stillRunning
      Still running.

    • _shuttingDownGracefully

      private volatile boolean _shuttingDownGracefully
      Shutting down gracefully.

    • runningLock

      private final Object runningLock
      Lock for sender running state.

  • Constructor Details

    • V1StreamSender

      public V1StreamSender(I2PSocket s, int id) throws IOException
      V1StreamSender.
      Parameters:
      s - the socket to send stream data over
      id - the connection's handler id
      Throws:
      IOException - if the socket's output stream cannot be opened

  • Method Details