Package | Description |
---|---|
net.i2p.client.streaming.impl |
Implementation of a TCP-like (reliable, authenticated, in order) set of sockets for
communicating over the IP-like (unreliable, unauthenticated, unordered) I2P
messages.
|
Class and Description |
---|
Connection
Maintain the state controlling a streaming connection between two
destinations.
|
ConnectionHandler
Receive new connection attempts
Use a bounded queue to limit the damage from SYN floods,
router overload, or a slow client
|
ConnectionManager
Coordinate all of the connections for a single local destination.
|
ConnectionManager.PingNotifier
The callback interface for a pong.
|
ConnectionOptions
Define the current options for the con (and allow custom tweaking midstream)
TODO many of these are not per-connection options, and should be migrated
somewhere so they aren't copied for every connection
|
ConnectionPacketHandler
Receive a packet for a particular connection - placing the data onto the
queue, marking packets as acked, updating various fields, etc.
|
I2PServerSocketFull
Bridge to allow accepting new connections
|
I2PSocketFull
Bridge between the full streaming lib and the I2PSocket API
|
I2PSocketManagerFull
Centralize the coordination and multiplexing of the local client's streaming.
|
I2PSocketOptionsImpl
Define the configuration for streaming and verifying data on the socket.
|
MessageHandler
Receive raw information from the I2PSession and turn it into
Packets, if we can.
|
MessageInputStream
Stream that can be given messages out of order
yet present them in order.
|
MessageOutputStream
A stream that we can shove data into that fires off those bytes
on flush or when the buffer is full.
|
MessageOutputStream.DataReceiver
Define a component to receive data flushed from this stream
|
MessageOutputStream.WriteStatus
Define a way to detect the status of a write
|
Packet
This contains solely the data that goes out on the wire,
including the local and remote port which is embedded in
the I2CP overhead, not in the packet itself.
|
PacketHandler
receive a packet and dispatch it correctly to the connection specified,
the server socket, or queue a reply RST packet.
|
PacketLocal
This is the class used for outbound packets.
|
PacketQueue
Queue out packets to be sent through the session.
|
PcapWriter
Write a standard pcap file with a "TCP" packet that can be analyzed with
standard tools such as wireshark.
|
RetransmissionTimer
Per-destination timer
|
SchedulerChooser
Examine a connection's state and pick the right scheduler for it.
|
SchedulerImpl
Base scheduler
|
TaskScheduler
Coordinates what we do 'next'.
|