Keep unused inbound session tags around for up to 12 minutes (2 minutes longer than
session tags are used on the outbound side so that no reasonable network lag
can cause failed decrypts)
The receiveStreamId will be set to this when the packet doesn't know
what ID will be assigned by the remote peer (aka this is the initial
synchronize packet)
STR_CRIT -
Static variable in class net.i2p.util.Log
STR_DEBUG -
Static variable in class net.i2p.util.Log
STR_ERROR -
Static variable in class net.i2p.util.Log
STR_INFO -
Static variable in class net.i2p.util.Log
STR_WARN -
Static variable in class net.i2p.util.Log
STYLE -
Static variable in class net.i2p.router.transport.tcp.TCPTransport
Scheduler used for after both SYNs have been ACKed and both sides
have closed the stream, but either we haven't ACKed their close or
they haven't ACKed ours.
session key management unit tests:
Run tagsIncluded useTag rekey
// no sessions
1 no no no
2 no no no
// session
3 yes (2) no no
4 no yes no
5 yes (2) yes no
6 no yes no
7 no yes no
// rekeying
8 yes (2) no no
9 no yes no
10 yes (2) yes yes
11 no yes no
12 no yes no
// long session
13-1000 20 tags every 10 messages, rekey every 50
Simple CLI to splot the stat logs into per-stat files containing
#seconds since beginning and the value (ready for loading into your
favorite plotting tool)
Coordinate the management of various frequencies and rates within I2P components,
both allowing central update and retrieval, as well as distributed creation and
use.
Job that, if its allowed to, will submit the data gathered by the MessageHistory
component to some URL so that the network can be debugged more easily.
Begin a kademlia style search for the key specified, which can take up to timeoutMs and
will fire the appropriate jobs on success or timeout (or if the kademlia search completes
without any match)
Asynchronously send the message as requested in the message and, if the
send is successful, queue up any msg.getOnSendJob job, and register it
with the OutboundMessageRegistry (if it has a reply selector).
Asynchronously send the message as requested in the message and, if the
send is successful, queue up any msg.getOnSendJob job, and register it
with the OutboundMessageRegistry (if it has a reply selector).
we're (probably) searching for a LeaseSet, so to be (overly) cautious, we're sending
the request out through a tunnel w/ reply back through another tunnel.
Send a new message to the given destination, containing the specified
payload, returning true if the router feels confident that the message
was delivered.
Router to receive and process this clove - the router that will open the
delivery instructions and decide what to do process it locally as an I2NPMessage,
forward it as an I2NPMessage to a router, forward it as an I2NPMessage to a Destination,
or forward it as an I2NPMessage to a tunnel.
If true, the recipient of this clove is requested to send a DeliveryStatusMessage
back via the replyThroughRouter using the getId() value for the status' message Id.
This value indicates the stratum level of the local clock, with values
defined as follows:
Stratum Meaning
----------------------------------------------
0 unspecified or unavailable
1 primary reference (e.g., radio clock)
2-15 secondary reference (via NTP or SNTP)
16-255 reserved