| Package | Description |
|---|---|
| net.i2p.router.transport.ntcp | The NTCP (New TCP) transport for I2P, allowing I2P messages to be passed
over TCP connections. |
| Modifier and Type | Field and Description |
|---|---|
protected NTCPConnection | EstablishBase._con_con. |
| Modifier and Type | Method and Description |
|---|---|
(package private) NTCPConnection | NTCPTransport.inboundEstablished(NTCPConnection con)Registers a newly established inbound connection, replacing any existing connection
for the same peer. |
(package private) NTCPConnection | NTCPTransport.removeCon(NTCPConnection con) |
| Modifier and Type | Method and Description |
|---|---|
Collection<NTCPConnection> | NTCPTransport.getPeers()For /peers UI only. |
| Modifier and Type | Method and Description |
|---|---|
void | Reader.connectionClosed(NTCPConnection con)Description. |
void | Writer.connectionClosed(NTCPConnection con)connectionClosed. |
(package private) void | NTCPTransport.establishing(NTCPConnection con)add us to the establishment timeout process |
(package private) NTCPConnection | NTCPTransport.inboundEstablished(NTCPConnection con)Registers a newly established inbound connection, replacing any existing connection
for the same peer. |
boolean | EventPumper.processWrite(NTCPConnection con,
SelectionKey key)processWrite. |
void | EventPumper.registerConnect(NTCPConnection con)Outbound connection registration with optional retry backoff. |
(package private) NTCPConnection | NTCPTransport.removeCon(NTCPConnection con) |
void | Reader.wantsRead(NTCPConnection con)Description. |
void | EventPumper.wantsRead(NTCPConnection con)This is only called from NTCPConnection.complete()
if there is more data, which is rare (never?)
so we don't need to check for dups or make _wantsRead a Set. |
void | EventPumper.wantsWrite(NTCPConnection con)Called by the connection when it has data ready to write (after bw allocation). |
void | Writer.wantsWrite(NTCPConnection con,
String source)wantsWrite. |
| Constructor and Description |
|---|
EstablishBase(RouterContext ctx,
NTCPTransport transport,
NTCPConnection con)EstablishBase. |
InboundEstablishState(RouterContext ctx,
NTCPTransport transport,
NTCPConnection con)Creates a new InboundEstablishState for the given context, transport, and connection |
OutboundNTCP2State(RouterContext ctx,
NTCPTransport transport,
NTCPConnection con)Create a new outbound NTCP2 state. |