Packages that use Packet
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 Packet in net.i2p.client.streaming.impl
Subclasses of Packet in net.i2p.client.streaming.implModifier and TypeClassDescriptionprivate static classSimple end-of-queue marker.(package private) classThis is the class used for outbound packets.Fields in net.i2p.client.streaming.impl declared as PacketModifier and TypeFieldDescription(package private) final PacketPacketDispatcher.Entry.packetThe packet to process, payload still held until it is drained.Fields in net.i2p.client.streaming.impl with type parameters of type PacketModifier and TypeFieldDescriptionprivate final ConcurrentHashMap<Packet, ConnectionHandler.SynEntry> ConnectionHandler._synEnqueueTimesEnqueue records for packets currently in (or just polled from) the accept queue, keyed by packet identity.private final LinkedBlockingDeque<Packet> ConnectionHandler._synQueuePackets waiting to be sent.Methods in net.i2p.client.streaming.impl with parameters of type PacketModifier and TypeMethodDescriptionprivate ConnectionEverything about a new inbound connection up to the point where its payload is handed over: the SYN burst gates, the admission reservation, the options and MTU negotiation, and the connection's construction.private booleanConnectionPacketHandler.ack(Connection con, long ackThrough, long[] nacks, Packet packet, boolean isNew, boolean choke) Process the acks in a received packet, and adjust our window and RTT.(package private) voidPacketDispatcher.dispatch(long sendStreamId, Connection con, Packet packet) Route (con, packet) to the shard owning the connection and return promptly.private voidPacketHandler.dispatchKnownConnection(Connection con, Packet packet, long sendId) Offload (con, packet) to the shard owning the connection.(package private) voidPacketHandler.displayPacket(Packet packet, String prefix, String suffix) Logs the provided packet at debug level with a timestamp.private static longPcapWriter.getLowestAckedThrough(Packet pkt) Calculate the lowest sequence number that has been acked through.private voidPacketHandler.handleEchoOnUnknown(Packet packet) Handles an echo packet received on an unknown connection.private voidPacketHandler.handleEchoPacket(Connection con, Packet packet) Handles echo packets on known connections.private voidPacketHandler.handleMisroutedPacket(Connection con, Packet packet) Handles a packet that appears on a known connection, but with stream ID mismatches or other anomalies.voidPacketDispatcher.PacketProcessor.process(Connection con, Packet packet) Process the packet.ConnectionManager.receiveConnection(Packet synPacket) Create a new connection based on the SYN packet we received.private voidPacketHandler.receiveKnownConnection(Connection con, Packet packet) Process a packet that matches a known connection.voidConnectionHandler.receiveNewSyn(Packet packet) Receive new connection attempts(package private) voidConnectionPacketHandler.receivePacket(Packet packet, Connection con) Takes ownership of the packet and calls packet.releasePayload() unless it is passed to the MessageInputStream.(package private) voidPacketHandler.receivePacket(Packet packet) Receives a packet and dispatches it to the appropriate handler.(package private) voidPacketHandler.receivePacketDirect(Packet packet, boolean queueIfNoConn) Processes the packet immediately, optionally queuing if no connection is found.booleanConnectionManager.receivePing(Connection con, Packet ping) Process a ping by checking for throttling, etc., then sending a pong.private voidPacketHandler.receivePing(Connection con, Packet packet) Verifies and processes an incoming ping packet.private voidPacketHandler.receivePong(Packet packet) Processes an incoming pong packet.private voidPacketHandler.receiveUnknownConnection(Packet packet, long sendId, boolean queueIfNoConn) Processes a packet that does not match any known connection.private voidConnectionHandler.reReceivePacket(Packet packet) We found a non-SYN packet that was queued in the syn queue, check to see if it has a home now, else drop it ...private voidConnectionHandler.resendSynAck(Connection con, Packet syn) Re-send a SYN-ACK in response to a retransmitted SYN for an existing connection.private voidConnectionHandler.sampleSynResidence(Packet syn) Record how long a freshly accepted SYN spent in the accept queue.private voidConnectionManager.sendRejectResponse(Packet synPacket, Destination from, Hash fromHash, int retryAfter) Send the configured response for a rejected SYN (RESET, HTTP-style Retry-After payload, or custom payload), subject to the peer's throttler status.private voidSend a reset in response to this packet, but only if it contains a FROM field and Signature that can be verified.private voidSends a reset packet back to the sender if the incoming packet is verified.voidPacketHandler.sendResetUnverified(Packet packet) Sends a reset packet back to the sender without verifying the packet signature.private ConnectionManager.ReasonConnectionManager.shouldRejectConnection(Packet syn) Check if a connection should be rejected based on blacklists, access lists, throttling, and the connection filter.(package private) static StringConnectionHandler.synExpiryMessage(Packet syn, int queueDepth, int maxQueueSize, int timeoutMs) Full single-line DEBUG detail for a timed-out SYN, folding in both the packet detail and the queue/timeout pressure that caused the expiry.(package private) static voidConnectionHandler.synExpirySummary(Packet syn, StringBuilder out) Build a diagnostic message for a SYN that expired on the accept queue without being accepted.private booleanConnectionPacketHandler.verifyPacket(Packet packet, Connection con) Make sure this packet is ok and that we can continue processing its data.private voidConnectionPacketHandler.verifyReset(Packet packet, Connection con) Make sure this RST packet is valid, and if it is, act on it.private voidConnectionPacketHandler.verifySignature(Packet packet, Connection con) Verify the signature if necessary.voidPcapWriter.write(Packet pkt, Connection con) Write an inbound packet to the pcap file.private voidPcapWriter.wrt(Packet pkt, Connection con, boolean isInbound) Write a packet to the pcap file in the proper format.Constructors in net.i2p.client.streaming.impl with parameters of type PacketModifierConstructorDescription(package private)Entry(Connection con, Packet packet) Pairs the two so a retired shard can free the payload on its own.