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.ConnectionManager.connect(Destination peer, ConnectionOptions opts, I2PSession session) Build a new connection to the given peer.(package private) ConnectionI2PSocketFull.getConnection()Underlying connection.PacketLocal.getConnection()Read the connection this packet is bound to.(package private) ConnectionConnectionManager.getConnectionByInboundId(long id) Look up a connection by its inbound stream ID.(package private) ConnectionConnectionManager.getConnectionByOutboundId(long id) Look up a connection by its outbound stream ID.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 ConnectionMethods in net.i2p.client.streaming.impl with parameters of type ConnectionModifier and TypeMethodDescriptionbooleanSchedulerClosed.accept(Connection con) Accept connections where both sides have closed and ACKed, and the final timeout hasn't passed.booleanSchedulerClosing.accept(Connection con) Accept connections where both sides have closed but at least one direction hasn't ACKed the close.booleanSchedulerConnectedBulk.accept(Connection con) Accept connections that are established, using the bulk profile, and not yet closing.booleanSchedulerConnecting.accept(Connection con) Accept connections where the SYN has been sent but not yet ACKed.booleanSchedulerDead.accept(Connection con) Accept connections where the final timeout has passed or a RESET was received.booleanSchedulerHardDisconnected.accept(Connection con) Accept connections that have been locally hard disconnected or sent a RESET, and the final timeout hasn't passed.booleanSchedulerPreconnect.accept(Connection con) Accept locally created connections that haven't sent any packets yet.booleanSchedulerReceived.accept(Connection con) Accept connections that have received a SYN but haven't sent one.booleanTaskScheduler.accept(Connection con) Determine whether this scheduler is fit to operate against the given connection.(package private) voidPacketDispatcher.dispatch(long sendStreamId, Connection con, Packet packet) Route (con, packet) to the shard owning the connection and return promptly.voidSchedulerClosed.eventOccurred(Connection con) Handles the scheduler event; a no-op as the timeout is handled by the timer.voidSchedulerClosing.eventOccurred(Connection con) Handle an event on a closing connection.voidSchedulerConnectedBulk.eventOccurred(Connection con) Handle an event on a connected bulk connection.voidSchedulerConnecting.eventOccurred(Connection con) Handle an event on a connecting connection.voidSchedulerDead.eventOccurred(Connection con) Handle an event on a dead connection.voidSchedulerHardDisconnected.eventOccurred(Connection con) Handle an event on a hard-disconnected connection.voidSchedulerPreconnect.eventOccurred(Connection con) Handle an event on a preconnect connection.voidSchedulerReceived.eventOccurred(Connection con) Handle an event on a received connection.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) Return the appropriate scheduler for the given connection.voidPacket.logTCPDump(Connection con) Generate a pcap/tcpdump-compatible format, so we can use standard debugging tools.voidPacketDispatcher.PacketProcessor.process(Connection con, Packet packet) Process the packet.(package private) voidConnectionManager.publishLifetimeStats(Connection con) Publish a closing connection's lifetime counters.(package private) voidConnectionPacketHandler.receivePacket(Packet packet, Connection con) Takes ownership of the packet and calls packet.releasePayload() unless it is passed to the MessageInputStream.booleanConnectionManager.receivePing(Connection con, Packet ping) Process a ping by checking for throttling, etc., then sending a pong.(package private) voidConnectionManager.registerOutboundId(Connection con) Register outbound id.voidConnectionManager.removeConnection(Connection con) Remove a connection from the manager.protected voidSchedulerImpl.reschedule(long msToWait, Connection con) Schedule a connection event to occur after the specified delay.(package private) static booleanConnectionPacketHandler.shouldRemainChoked(Connection con, long seqNum, int payloadSize) Determine if a packet should keep the connection choked.voidConnectionManager.updateOptsFromShare(Connection con) Update opts from share.voidTCBShare.updateOptsFromShare(Connection con) Retrieve cached TCB parameters and apply them to the connection's options.voidConnectionManager.updateShareOpts(Connection con) Update share opts.voidTCBShare.updateShareOpts(Connection con) Store the connection's current TCB parameters into the cache.voidPcapWriter.write(Packet pkt, Connection con) Write an inbound packet to the pcap file.Constructors in net.i2p.client.streaming.impl with parameters of type ConnectionModifierConstructorDescriptionConnectionDataReceiver(I2PAppContext ctx, Connection con) Create a data receiver for the given connection.I2PSocketFull(Connection con, I2PAppContext context) Bridge between a connection and the I2PSocket API.PacketLocal(I2PAppContext ctx, Destination to, Connection con) Constructor for a packet bound to a connection.