Uses of Class
net.i2p.client.streaming.impl.Connection
Packages that use 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
Methods in net.i2p.client.streaming.impl that return ConnectionModifier 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) ConnectionI2PSocketFull.getConnection()PacketLocal.getConnection()(package private) ConnectionConnectionManager.getConnectionByInboundId(long id) (package private) ConnectionConnectionManager.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.Methods in net.i2p.client.streaming.impl that return types with arguments of type ConnectionModifier and TypeMethodDescriptionConnectionManager.listConnections()return a set of Connection objectsMethods in net.i2p.client.streaming.impl with parameters of type ConnectionModifier and TypeMethodDescriptionbooleanSchedulerClosed.accept(Connection con) booleanSchedulerClosing.accept(Connection con) booleanSchedulerConnectedBulk.accept(Connection con) booleanSchedulerConnecting.accept(Connection con) booleanSchedulerDead.accept(Connection con) booleanSchedulerHardDisconnected.accept(Connection con) booleanSchedulerPreconnect.accept(Connection con) booleanSchedulerReceived.accept(Connection con) booleanTaskScheduler.accept(Connection con) Determine whether this scheduler is fit to operate against the given connectionvoidSchedulerClosed.eventOccurred(Connection con) voidSchedulerClosing.eventOccurred(Connection con) voidSchedulerConnectedBulk.eventOccurred(Connection con) voidSchedulerConnecting.eventOccurred(Connection con) voidSchedulerDead.eventOccurred(Connection con) voidSchedulerHardDisconnected.eventOccurred(Connection con) voidSchedulerPreconnect.eventOccurred(Connection con) voidSchedulerReceived.eventOccurred(Connection con) voidTaskScheduler.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) voidPacket.logTCPDump(Connection con) Generate a pcap/tcpdump-compatible format, so we can use standard debugging tools.(package private) voidConnectionPacketHandler.receivePacket(Packet packet, Connection con) distribute a packet to the connection specifiedbooleanConnectionManager.receivePing(Connection con, Packet ping) Process a ping by checking for throttling, etc., then sending a pong.voidConnectionManager.removeConnection(Connection con) Drop the (already closed) connection on the floor.protected voidSchedulerImpl.reschedule(long msToWait, Connection con) voidConnectionManager.updateOptsFromShare(Connection con) voidTCBShare.updateOptsFromShare(Connection con) retrieve from cachevoidConnectionManager.updateShareOpts(Connection con) voidTCBShare.updateShareOpts(Connection con) store to cachevoidPcapWriter.write(Packet pkt, Connection con) For inbound packetsConstructors in net.i2p.client.streaming.impl with parameters of type ConnectionModifierConstructorDescriptionConnectionDataReceiver(I2PAppContext ctx, Connection con) I2PSocketFull(Connection con, I2PAppContext context) PacketLocal(I2PAppContext ctx, Destination to, Connection con) bound to a connection