|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.i2p.router.transport.udp.EstablishmentManager
public class EstablishmentManager
Coordinate the establishment of new sessions - both inbound and outbound. This has its own thread to add packets to the packet queue when necessary, as well as to drop any failed establishment attempts.
Field Summary | |
---|---|
static long |
MAX_TAG_VALUE
|
static java.lang.String |
PROP_MAX_CONCURRENT_ESTABLISH
|
Constructor Summary | |
---|---|
EstablishmentManager(RouterContext ctx,
UDPTransport transport)
|
Method Summary | |
---|---|
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!). |
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 |
receiveSessionRequest(RemoteHostId from,
UDPPacketReader reader)
Got a SessionRequest (initiates an inbound establishment) |
void |
shutdown()
|
void |
startup()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final java.lang.String PROP_MAX_CONCURRENT_ESTABLISH
public static final long MAX_TAG_VALUE
Constructor Detail |
---|
public EstablishmentManager(RouterContext ctx, UDPTransport transport)
Method Detail |
---|
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)
PeerState receiveData(OutboundEstablishState state)
public void receiveRelayResponse(RemoteHostId bob, UDPPacketReader reader)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |