Packages that use PacketLocal
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 PacketLocal in net.i2p.client.streaming.impl
Fields in net.i2p.client.streaming.impl declared as PacketLocalModifier and TypeFieldDescriptionprivate PacketLocalConnection.ResendPacketEvent._packetThe packet to retransmit.Fields in net.i2p.client.streaming.impl with type parameters of type PacketLocalModifier and TypeFieldDescriptionprivate final List<PacketLocal> Connection._ackedListAcked list, reusable for ackPackets() — avoids per-call allocation.private TreeMap<Long, PacketLocal> Connection._outboundPacketsPacket ID (Long) to PacketLocal for sent but unacked packets.private LinkedList<PacketLocal> Connection._pacedQueuePaced-send queue, lazy likeConnection._outboundPackets: null until the first paced packet, so connections that never pace allocate nothing.Methods in net.i2p.client.streaming.impl that return PacketLocalModifier and TypeMethodDescriptionprivate PacketLocalConnectionDataReceiver.buildPacket(byte[] buf, int off, int size, boolean forceIncrement) Compose a packet.ConnectionDataReceiver.send(byte[] buf, int off, int size) Send some data through the connection, attaching any appropriate flags onto the packet.ConnectionDataReceiver.send(byte[] buf, int off, int size, boolean forceIncrement) Called externally from Connection with args (null, 0, 0, true) to send an empty data packet.Methods in net.i2p.client.streaming.impl that return types with arguments of type PacketLocalModifier and TypeMethodDescriptionConnection.ackPackets(long ackThrough, long[] nacks) Process the acks and nacks received in a packet.private TreeMap<Long, PacketLocal> Connection.outboundPackets()Lazily allocate the sender-side unacked-window map.private LinkedList<PacketLocal> Connection.pacedQueue()Lazily allocate the paced-send queue.Methods in net.i2p.client.streaming.impl with parameters of type PacketLocalModifier and TypeMethodDescriptionbooleanPacketQueue.enqueue(PacketLocal packet) Add a new packet to be sent out ASAP.(package private) Connection.ResendPacketEventConnection.newResendPacketEvent(PacketLocal packet) A new ResendPacketEvent from the pool or a fresh instance.(package private) voidConnection.sendPacket(PacketLocal packet) This sends all 'normal' packets (acks and data) for the first time.voidMessageInputStream.updateAcks(PacketLocal packet) Updates the ACK and NACK fields of a packet based on current stream state.voidPcapWriter.write(PacketLocal pkt) Write an outbound packet to the pcap file.Constructors in net.i2p.client.streaming.impl with parameters of type PacketLocalModifierConstructorDescriptionResendPacketEvent(PacketLocal packet) Bind the event to a packet and the router's shared timer.