コンストラクタの詳細

• MessageInputStream

  public MessageInputStream​(I2PAppContext ctx,
                            int maxMessageSize,
                            int maxWindowSize,
                            int maxBufferSize)

メソッドの詳細

• getHighestReadyBlockId

  public long getHighestReadyBlockId​()

  What is the highest block ID we've completely received through?

  戻り値:

  highest data block ID completely received or -1 for none

• getHighestBlockId

  public long getHighestBlockId​()

  戻り値:

  highest data block ID received or -1 for none

• isLocallyClosed

  public boolean isLocallyClosed​()

  戻り値:

  true if this has been closed on the read side with close()

• canAccept

  public boolean canAccept​(long messageId,
                           int payloadSize)

  Determine if this packet will fit in our buffering limits. Always returns true for zero payloadSize and dups, even if locally closed. Returns false if there is no room, OR it's not a dup and the stream has been closed on the read side with close(). If this returns false, you probably want to call isLocallyClosed() to find out why.

  戻り値:

  true if we have room. If false, do not call messageReceived()

  導入されたバージョン:

  0.9.20 moved from ConnectionPacketHandler.receivePacket() so it can all be under one lock, and we can efficiently do several checks

• getNacks

  public long[] getNacks​()

  Retrieve the message IDs that are holes in our sequence - ones past the highest ready ID and below the highest received message ID. This may return null if there are no such IDs.

  戻り値:

  array of message ID holes, or null if none

• updateAcks

  public void updateAcks​(PacketLocal packet)

  Adds the ack-through and nack fields to a packet we are building for transmission

• getReadTimeout

  public int getReadTimeout​()

  how long a read() call should block (if less than 0, block indefinitely, but if it is 0, do not block at all)

  戻り値:

  how long read calls should block, 0 for nonblocking, negative to indefinitely block

• setReadTimeout

  public void setReadTimeout​(int timeout)

  how long a read() call should block (if less than 0, block indefinitely, but if it is 0, do not block at all)

  パラメータ:

  timeout - how long read calls should block, 0 for nonblocking, negative to indefinitely block

• closeReceived

  public void closeReceived​()

  There is no more data coming from the I2P side. Does NOT clear pending data. messageReceived() MUST have been called previously with the messageId of the CLOSE packet.

• notifyActivity

  public void notifyActivity​()

• messageReceived

  public boolean messageReceived​(long messageId,
                                 ByteArray payload)

  A new message has arrived - toss it on the appropriate queue (moving previously pending messages to the ready queue if it fills the gap, etc). This does no limiting of pending data - see canAccept() for limiting. Warning - returns true if locally closed.

  パラメータ:

  messageId - ID of the message

  payload - message payload, may be null or have null or zero-length data

  戻り値:

  true if this is a new packet, false if it is a dup

• read

  public int read​()
           throws java.io.IOException

  On a read timeout, this returns -1 (doesn't throw SocketTimeoutException like Socket) (doesn't throw InterruptedIOException like our javadocs say)

  定義:

  read クラス内 java.io.InputStream

  例外:

  java.io.IOException

• read

  public int read​(byte[] target)
           throws java.io.IOException

  On a read timeout, this returns 0 (doesn't throw SocketTimeoutException like Socket) (doesn't throw InterruptedIOException like our javadocs say)

  オーバーライド:

  read クラス内 java.io.InputStream

  例外:

  java.io.IOException

• read

  public int read​(byte[] target,
                  int offset,
                  int length)
           throws java.io.IOException

  On a read timeout, this returns 0 (doesn't throw SocketTimeoutException like Socket) (doesn't throw InterruptedIOException like our javadocs say)

  オーバーライド:

  read クラス内 java.io.InputStream

  例外:

  java.io.IOException

• available

  public int available​()
                throws java.io.IOException

  オーバーライド:

  available クラス内 java.io.InputStream

  例外:

  java.io.IOException

• getTotalReadySize

  public int getTotalReadySize​()

  Same as available() but doesn't throw IOE

• close

  public void close​()

  オーバーライド:

  close クラス内 java.io.InputStream

• streamErrorOccurred

  void streamErrorOccurred​(java.io.IOException ioe)

  Stream b0rked, die with the given error