修飾子とタイプ | フィールド | 説明 |
---|---|---|
static int |
MAX_FRAGMENTS |
|
static int |
MAX_PARTIAL_BITFIELD_BYTES |
10
|
コンストラクタ | 説明 |
---|---|
InboundMessageState(RouterContext ctx,
long messageId,
Hash from) |
|
InboundMessageState(RouterContext ctx,
long messageId,
Hash from,
UDPPacketReader.DataReader data,
int dataFragment) |
Create a new IMS and read in the data from the fragment.
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
ACKBitfield |
createACKBitfield() |
FIXME synch here or PeerState.fetchPartialACKs()
|
void |
drop() |
For CDQ
|
int |
getCompleteSize() |
|
long |
getEnqueueTime() |
For CDQ
|
int |
getFragmentCount() |
|
ByteArray[] |
getFragments() |
|
Hash |
getFrom() |
|
long |
getLifetime() |
|
long |
getMessageId() |
|
boolean |
isComplete() |
May not be valid after released.
|
boolean |
isExpired() |
|
boolean |
receiveFragment(UDPPacketReader.DataReader data,
int dataFragment) |
Read in the data from the fragment.
|
void |
releaseResources() |
|
void |
setEnqueueTime(long now) |
For CDQ
|
java.lang.String |
toString() |
May not be valid if released, or may NPE on race with release, use with care in exception text
|
public static final int MAX_FRAGMENTS
public static final int MAX_PARTIAL_BITFIELD_BYTES
public InboundMessageState(RouterContext ctx, long messageId, Hash from)
public InboundMessageState(RouterContext ctx, long messageId, Hash from, UDPPacketReader.DataReader data, int dataFragment) throws DataFormatException
DataFormatException
- if the fragment was corruptpublic boolean receiveFragment(UDPPacketReader.DataReader data, int dataFragment) throws DataFormatException
DataFormatException
public boolean isComplete()
public boolean isExpired()
public long getLifetime()
public void setEnqueueTime(long now)
setEnqueueTime
インタフェース内 CDQEntry
public long getEnqueueTime()
getEnqueueTime
インタフェース内 CDQEntry
public Hash getFrom()
public long getMessageId()
public int getCompleteSize()
java.lang.IllegalStateException
- if released or not isComplete()public ACKBitfield createACKBitfield()
public void releaseResources()
public ByteArray[] getFragments()
java.lang.IllegalStateException
- if releasedpublic int getFragmentCount()
public java.lang.String toString()
toString
クラス内 java.lang.Object