| Package | Description |
|---|---|
| net.i2p.client.streaming.impl | Implementation of a TCP-like (reliable, authenticated, in order) set of sockets for communicating over the IP-like (unreliable, unauthenticated, unordered) I2P messages. |
| Modifier and Type | Method and Description |
|---|---|
Connection | ConnectionHandler.accept(long timeoutMs)Receive an incoming connection (built from a received SYN)
Non-SYN packets with a zero SendStreamID may also be queued here so
that they don't get thrown away while the SYN packet before it is queued. |
Connection | ConnectionManager.connect(Destination peer,
ConnectionOptions opts,
I2PSession session)Build a new connection to the given peer. |
Connection | PacketLocal.getConnection() |
(package private) Connection | I2PSocketFull.getConnection() |
(package private) Connection | ConnectionManager.getConnectionByInboundId(long id)Look up a connection by its inbound stream ID. |
(package private) Connection | ConnectionManager.getConnectionByOutboundId(long id)Look up a connection by its outbound stream ID. |
Connection | ConnectionManager.receiveConnection(Packet synPacket)Create a new connection based on the SYN packet we received. |
| Modifier and Type | Method and Description |
|---|---|
Set<Connection> | ConnectionManager.listConnections()return a set of Connection objects |
| Modifier and Type | Method and Description |
|---|---|
boolean | SchedulerConnectedBulk.accept(Connection con)Accept connections that are established, using the bulk profile,
and not yet closing. |
boolean | SchedulerClosing.accept(Connection con)Accept connections where both sides have closed but at least one
direction hasn't ACKed the close. |
boolean | SchedulerConnecting.accept(Connection con)Accept connections where the SYN has been sent but not yet ACKed. |
boolean | SchedulerHardDisconnected.accept(Connection con)Accept connections that have been locally hard disconnected or
sent a RESET, and the final timeout hasn't passed. |
boolean | SchedulerClosed.accept(Connection con)Accept connections where both sides have closed and ACKed, and the
final timeout hasn't passed. |
boolean | TaskScheduler.accept(Connection con)Determine whether this scheduler is fit to operate against the
given connection. |
boolean | SchedulerDead.accept(Connection con)Accept connections where the final timeout has passed or a RESET
was received. |
boolean | SchedulerPreconnect.accept(Connection con)Accept locally created connections that haven't sent any packets yet. |
boolean | SchedulerReceived.accept(Connection con)Accept connections that have received a SYN but haven't sent one. |
void | SchedulerConnectedBulk.eventOccurred(Connection con)Handle an event on a connected bulk connection. |
void | SchedulerClosing.eventOccurred(Connection con)Handle an event on a closing connection. |
void | SchedulerConnecting.eventOccurred(Connection con)Handle an event on a connecting connection. |
void | SchedulerHardDisconnected.eventOccurred(Connection con)Handle an event on a hard-disconnected connection. |
void | SchedulerClosed.eventOccurred(Connection con)eventOccurred. |
void | TaskScheduler.eventOccurred(Connection con)An event has occurred (timeout, message sent, or message received),
so schedule what to do next based on our current state. |
void | SchedulerDead.eventOccurred(Connection con)Handle an event on a dead connection. |
void | SchedulerPreconnect.eventOccurred(Connection con)Handle an event on a preconnect connection. |
void | SchedulerReceived.eventOccurred(Connection con)Handle an event on a received connection. |
TaskScheduler | SchedulerChooser.getScheduler(Connection con)Return the appropriate scheduler for the given connection. |
void | Packet.logTCPDump(Connection con)Generate a pcap/tcpdump-compatible format,
so we can use standard debugging tools. |
(package private) void | ConnectionPacketHandler.receivePacket(Packet packet,
Connection con)Takes ownership of the packet and calls packet.releasePayload() unless
it is passed to the MessageInputStream. |
boolean | ConnectionManager.receivePing(Connection con,
Packet ping)Process a ping by checking for throttling, etc., then sending a pong. |
(package private) void | ConnectionManager.registerOutboundId(Connection con)Register outbound id. |
void | ConnectionManager.removeConnection(Connection con)Remove a connection from the manager. |
protected void | SchedulerImpl.reschedule(long msToWait,
Connection con)Schedule a connection event to occur after the specified delay. |
void | TCBShare.updateOptsFromShare(Connection con)Retrieve cached TCB parameters and apply them to the connection's options. |
void | ConnectionManager.updateOptsFromShare(Connection con)Update opts from share. |
void | TCBShare.updateShareOpts(Connection con)Store the connection's current TCB parameters into the cache. |
void | ConnectionManager.updateShareOpts(Connection con)Update share opts. |
void | PcapWriter.write(Packet pkt,
Connection con)Write an inbound packet to the pcap file. |
| Constructor and Description |
|---|
ConnectionDataReceiver(I2PAppContext ctx,
Connection con) |
I2PSocketFull(Connection con,
I2PAppContext context) |
PacketLocal(I2PAppContext ctx,
Destination to,
Connection con)bound to a connection |