Package | Description |
---|---|
net.i2p.router.transport.ntcp |
The NTCP transport allows passing I2P messages on top of TCP.
|
Modifier and Type | Method | Description |
---|---|---|
(package private) NTCPConnection |
NTCPTransport.inboundEstablished(NTCPConnection con) |
|
(package private) NTCPConnection |
NTCPTransport.removeCon(NTCPConnection con) |
Modifier and Type | Method | Description |
---|---|---|
Collection<NTCPConnection> |
NTCPTransport.getPeers() |
For /peers UI only.
|
Modifier and Type | Method | Description |
---|---|---|
void |
Reader.connectionClosed(NTCPConnection con) |
|
void |
Writer.connectionClosed(NTCPConnection con) |
|
(package private) void |
NTCPTransport.establishing(NTCPConnection con) |
add us to the establishment timeout process
|
(package private) NTCPConnection |
NTCPTransport.inboundEstablished(NTCPConnection con) |
|
void |
EventPumper.registerConnect(NTCPConnection con) |
Outbound
|
(package private) NTCPConnection |
NTCPTransport.removeCon(NTCPConnection con) |
|
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 |
Reader.wantsRead(NTCPConnection con) |
|
void |
EventPumper.wantsWrite(NTCPConnection con) |
Called by the connection when it has data ready to write (after bw allocation).
|
void |
EventPumper.wantsWrite(NTCPConnection con,
byte[] data) |
Called by the connection when it has data ready to write.
|
void |
Writer.wantsWrite(NTCPConnection con,
String source) |
Constructor | Description |
---|---|
EstablishState(RouterContext ctx,
NTCPTransport transport,
NTCPConnection con) |