Uses of Class
net.i2p.client.streaming.impl.Connection
Package
Description
Implementation of a TCP-like (reliable, authenticated, in order) set of sockets for
communicating over the IP-like (unreliable, unauthenticated, unordered) I2P
messages.
-
Uses of Connection in net.i2p.client.streaming.impl
Modifier and TypeMethodDescriptionConnectionHandler.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.ConnectionManager.connect
(Destination peer, ConnectionOptions opts, I2PSession session) Build a new connection to the given peer.(package private) Connection
I2PSocketFull.getConnection()
PacketLocal.getConnection()
(package private) Connection
ConnectionManager.getConnectionByInboundId
(long id) (package private) Connection
ConnectionManager.getConnectionByOutboundId
(long id) not guaranteed to be unique, but in case we receive more than one packet on an inbound connection that we havent ack'ed yet...ConnectionManager.receiveConnection
(Packet synPacket) Create a new connection based on the SYN packet we received.Modifier and TypeMethodDescriptionConnectionManager.listConnections()
return a set of Connection objectsModifier and TypeMethodDescriptionboolean
SchedulerClosed.accept
(Connection con) boolean
SchedulerClosing.accept
(Connection con) boolean
SchedulerConnectedBulk.accept
(Connection con) boolean
SchedulerConnecting.accept
(Connection con) boolean
SchedulerDead.accept
(Connection con) boolean
SchedulerHardDisconnected.accept
(Connection con) boolean
SchedulerPreconnect.accept
(Connection con) boolean
SchedulerReceived.accept
(Connection con) boolean
TaskScheduler.accept
(Connection con) Determine whether this scheduler is fit to operate against the given connectionvoid
SchedulerClosed.eventOccurred
(Connection con) void
SchedulerClosing.eventOccurred
(Connection con) void
SchedulerConnectedBulk.eventOccurred
(Connection con) void
SchedulerConnecting.eventOccurred
(Connection con) void
SchedulerDead.eventOccurred
(Connection con) void
SchedulerHardDisconnected.eventOccurred
(Connection con) void
SchedulerPreconnect.eventOccurred
(Connection con) void
SchedulerReceived.eventOccurred
(Connection con) 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.SchedulerChooser.getScheduler
(Connection con) 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) distribute a packet to the connection specifiedboolean
ConnectionManager.receivePing
(Connection con, Packet ping) Process a ping by checking for throttling, etc., then sending a pong.void
ConnectionManager.removeConnection
(Connection con) Drop the (already closed) connection on the floor.protected void
SchedulerImpl.reschedule
(long msToWait, Connection con) void
ConnectionManager.updateOptsFromShare
(Connection con) void
TCBShare.updateOptsFromShare
(Connection con) retrieve from cachevoid
ConnectionManager.updateShareOpts
(Connection con) void
TCBShare.updateShareOpts
(Connection con) store to cachevoid
PcapWriter.write
(Packet pkt, Connection con) For inbound packetsModifierConstructorDescriptionConnectionDataReceiver
(I2PAppContext ctx, Connection con) I2PSocketFull
(Connection con, I2PAppContext context) PacketLocal
(I2PAppContext ctx, Destination to, Connection con) bound to a connection