void |
IntroductionManager.add(PeerState peer) |
|
void |
OutboundMessageFragments.add(List<OutboundMessageState> states,
PeerState peer) |
Short circuit the OutNetMessage, letting us send multiple messages
reliably and efficiently.
|
void |
OutboundMessageFragments.add(OutboundMessageState state,
PeerState peer) |
Short circuit the OutNetMessage, letting us send the establish
complete message reliably.
|
void |
OutboundMessageFragments.add(PeerState peer,
int size) |
Add the peer to the list of peers wanting to transmit something.
|
(package private) boolean |
UDPTransport.addRemotePeerState(PeerState peer) |
add the peer info, returning true if it went in properly, false if
it was rejected (causes include peer ident already connected, or no
remote host info known
|
UDPPacket |
PacketBuilder.buildACK(PeerState peer,
List<ACKBitfield> ackBitfields) |
Build the ack packet.
|
UDPPacket |
PacketBuilder.buildPacket(List<PacketBuilder.Fragment> fragments,
PeerState peer,
Collection<Long> ackIdsRemaining,
int newAckCount,
List<ACKBitfield> partialACKsRemaining) |
|
UDPPacket |
PacketBuilder.buildPacket(OutboundMessageState state,
int fragment,
PeerState peer,
Collection<Long> ackIdsRemaining,
int newAckCount,
List<ACKBitfield> partialACKsRemaining) |
This builds a data packet (PAYLOAD_TYPE_DATA).
|
UDPPacket |
PacketBuilder.buildPing(PeerState peer) |
An ACK packet with no acks.
|
(package private) UDPPacket |
PacketBuilder.buildRelayIntro(RemoteHostId alice,
PeerState charlie,
UDPPacketReader.RelayRequestReader request) |
|
(package private) UDPPacket |
PacketBuilder.buildRelayResponse(RemoteHostId alice,
PeerState charlie,
long nonce,
SessionKey cipherKey,
SessionKey macKey) |
|
UDPPacket |
PacketBuilder.buildSessionDestroyPacket(PeerState peer) |
Build a destroy packet, which contains a header but no body.
|
(package private) void |
UDPTransport.changePeerPort(PeerState peer,
int newPort) |
Remove and add to peersByRemoteHost map
|
(package private) void |
OutboundMessageFragments.dropPeer(PeerState peer) |
|
(package private) void |
UDPTransport.dropPeer(PeerState peer,
boolean shouldBanlist,
String why) |
This does not send a session destroy, caller must do that if desired.
|
static int |
PacketBuilder.getMaxAdditionalFragmentSize(PeerState peer,
int numFragments,
int curDataSize) |
Will a packet to 'peer' that already has 'numFragments' fragments
totalling 'curDataSize' bytes fit another fragment of size 'newFragSize' ??
This doesn't leave anything for acks.
|
static int |
PacketBuilder2.getMaxAdditionalFragmentSize(PeerState peer,
int numFragments,
int curDataSize) |
Will a packet to 'peer' that already has 'numFragments' fragments
totalling 'curDataSize' bytes fit another fragment?
This includes the 3 byte block overhead, but NOT the 5 byte followon fragment overhead.
|
(package private) void |
PeerState.loadFrom(PeerState oldPeer) |
Transfer the basic activity/state from the old peer to the current peer
SSU 1 or 2.
|
void |
InboundMessageFragments.receiveData(PeerState from,
UDPPacketReader.DataReader data) |
Pull the fragments and ACKs out of the authenticated data packet
SSU 1 only.
|
(package private) void |
EstablishmentManager.receiveSessionDestroy(RemoteHostId from,
PeerState state) |
Got a SessionDestroy on an established conn
SSU 1 or 2
|
void |
PeerTestManager.receiveTest(RemoteHostId from,
PeerState fromPeer,
boolean inSession,
UDPPacketReader reader) |
Entry point for all incoming packets.
|
void |
IntroductionManager.remove(PeerState peer) |
|
boolean |
PeerTestManager.runTest(PeerState bob) |
The next few methods are for when we are Alice
|
(package private) void |
UDPTransport.send(List<I2NPMessage> msgs,
PeerState peer) |
"injected" messages from the EstablishmentManager.
|
(package private) void |
UDPTransport.send(I2NPMessage msg,
List<OutNetMessage> msgs,
PeerState peer) |
"injected" message from the EstablishmentManager,
plus pending messages to send,
so the messages may be bundled efficiently.
|
(package private) void |
UDPTransport.send(I2NPMessage msg,
PeerState peer) |
"injected" message from the EstablishmentManager.
|
(package private) void |
UDPTransport.sendDestroy(PeerState peer,
int reasonCode) |
Send a session destroy message, bypassing OMF and PacketPusher.
|