InboundMessageFragments (Javadocs [I2P+ 2.13.0+]

java.lang.Object
- net.i2p.router.transport.udp.InboundMessageFragments

```
class InboundMessageFragments
extends Object
```
Organize the received data message fragments, feeding completed messages to the MessageReceiver and telling the PeerState to ACK. In addition, it drops failed fragments and keeps a minimal list of the most recently completed messages (even though higher up in the router we have full blown replay detection, its nice to have a basic line of defense here).

Nested Class Summary
Nested Classes
Modifier and Type Class and Description
static class InboundMessageFragments.ModifiableLong
Modifiable Long, no locking

Nested Classes
Modifier and Type	Class and Description
`static class`	`InboundMessageFragments.ModifiableLong` Modifiable Long, no locking

Constructor Summary
Constructors
Constructor and Description
InboundMessageFragments(RouterContext ctx, OutboundMessageFragments outbound, UDPTransport transport)
InboundMessageFragments.

Constructors
Constructor and Description
`InboundMessageFragments(RouterContext ctx, OutboundMessageFragments outbound, UDPTransport transport)` InboundMessageFragments.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`(package private) void`	`adjustMessageReceiverThreads()` Dynamically adjust MessageReceiver thread count to match the target.
`(package private) double`	`getMessageReceiverUtilization()` Get message receiver pool utilization as a ratio (0.0-1.0).
`(package private) int`	`getReceiverQueueCapacity()` Returns the maximum capacity of the message receiver queue.
`(package private) int`	`getReceiverQueueSize()` Returns the current queue depth of the message receiver.
`boolean`	`isAlive()`
`boolean`	`messageReceived(long messageID)` This message was received - SSU 2 only.
`void`	`shutdown()` shutdown.
`void`	`startup()` startup.
`boolean`	`wasRecentlyReceived(long messageID)` Was this message recently received? SSU 2 only.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - InboundMessageFragments
```
public InboundMessageFragments(RouterContext ctx,
                               OutboundMessageFragments outbound,
                               UDPTransport transport)
```
    InboundMessageFragments.
- Method Detail
  - adjustMessageReceiverThreads
```
void adjustMessageReceiverThreads()
```
    Dynamically adjust MessageReceiver thread count to match the target.
  - getMessageReceiverUtilization
```
double getMessageReceiverUtilization()
```
    Get message receiver pool utilization as a ratio (0.0-1.0).
  - getReceiverQueueCapacity
```
int getReceiverQueueCapacity()
```
    Returns the maximum capacity of the message receiver queue.
  - getReceiverQueueSize
```
int getReceiverQueueSize()
```
    Returns the current queue depth of the message receiver.
  - isAlive
```
public boolean isAlive()
```
    Returns:
    whether alive
  - messageReceived
```
public boolean messageReceived(long messageID)
```
    This message was received - SSU 2 only. No stats updated here, caller should handle stats.
    Returns:
    true if this message was a duplicate
  - shutdown
```
public void shutdown()
```
    shutdown.
  - startup
```
public void startup()
```
    startup.
  - wasRecentlyReceived
```
public boolean wasRecentlyReceived(long messageID)
```
    Was this message recently received? SSU 2 only. No stats updated here, caller should handle stats.
    Returns:
    true if this message was recently received.

Class InboundMessageFragments

Nested Class Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

InboundMessageFragments

Method Detail

adjustMessageReceiverThreads

getMessageReceiverUtilization

getReceiverQueueCapacity

getReceiverQueueSize

isAlive

messageReceived

shutdown

startup

wasRecentlyReceived