net.i2p.router.transport.udp
class EstablishmentManager extends Object
Modifier and Type | Field and Description |
---|---|
static long |
MAX_TAG_VALUE |
static String |
PROP_MAX_CONCURRENT_ESTABLISH |
Constructor and Description |
---|
EstablishmentManager(RouterContext ctx,
UDPTransport transport) |
Modifier and Type | Method and Description |
---|---|
void |
establish(OutNetMessage msg)
Send the message to its specified recipient by establishing a connection
with them and sending it off.
|
(package private) InboundEstablishState |
getInboundState(RemoteHostId from)
Grab the active establishing state
|
(package private) OutboundEstablishState |
getOutboundState(RemoteHostId from) |
(package private) PeerState |
receiveData(OutboundEstablishState state)
A data packet arrived on an outbound connection being established, which
means its complete (yay!).
|
(package private) void |
receiveRelayResponse(RemoteHostId bob,
UDPPacketReader reader) |
(package private) void |
receiveSessionConfirmed(RemoteHostId from,
UDPPacketReader reader)
got a SessionConfirmed (should only happen as part of an inbound
establishment)
|
(package private) void |
receiveSessionCreated(RemoteHostId from,
UDPPacketReader reader)
Got a SessionCreated (in response to our outbound SessionRequest)
|
(package private) void |
receiveSessionDestroy(RemoteHostId from)
Got a SessionDestroy - maybe after an inbound establish
|
(package private) void |
receiveSessionDestroy(RemoteHostId from,
OutboundEstablishState state)
Got a SessionDestroy during outbound establish
|
(package private) void |
receiveSessionDestroy(RemoteHostId from,
PeerState state)
Got a SessionDestroy on an established conn
|
(package private) void |
receiveSessionRequest(RemoteHostId from,
UDPPacketReader reader)
Got a SessionRequest (initiates an inbound establishment)
|
void |
shutdown() |
void |
startup() |
public static final String PROP_MAX_CONCURRENT_ESTABLISH
public static final long MAX_TAG_VALUE
public EstablishmentManager(RouterContext ctx, UDPTransport transport)
public void startup()
public void shutdown()
InboundEstablishState getInboundState(RemoteHostId from)
OutboundEstablishState getOutboundState(RemoteHostId from)
public void establish(OutNetMessage msg)
void receiveSessionRequest(RemoteHostId from, UDPPacketReader reader)
void receiveSessionConfirmed(RemoteHostId from, UDPPacketReader reader)
void receiveSessionCreated(RemoteHostId from, UDPPacketReader reader)
void receiveSessionDestroy(RemoteHostId from, PeerState state)
void receiveSessionDestroy(RemoteHostId from, OutboundEstablishState state)
void receiveSessionDestroy(RemoteHostId from)
PeerState receiveData(OutboundEstablishState state)
void receiveRelayResponse(RemoteHostId bob, UDPPacketReader reader)