public interface BasePeerNode extends PeerContext
Modifier and Type | Method and Description |
---|---|
double |
averagePingTime() |
double |
averagePingTimeCorrected()
Average ping time incorporating variance, calculated like TCP SRTT, as with RFC 2988.
|
void |
backoffOnResend()
Double the RTT when we resend a packet.
|
SessionKey |
getCurrentKeyTracker() |
int |
getMaxPacketSize() |
PeerMessageQueue |
getMessageQueue() |
SessionKey |
getPreviousKeyTracker() |
SessionKey |
getUnverifiedKeyTracker() |
boolean |
grabSendLoadStatsASAP(boolean realtime) |
void |
handleMessage(Message msg) |
MessageItem |
makeLoadStats(boolean realtime,
boolean highPriority,
boolean noRemember)
Make a load stats message.
|
void |
maybeRekey() |
void |
onNotificationOnlyPacketSent(int length) |
java.util.Random |
paddingGen() |
void |
receivedAck(long currentTimeMillis)
Report when a packet was acked.
|
void |
receivedPacket(boolean dontLog,
boolean dataPacket) |
void |
reportIncomingBytes(int length) |
void |
reportOutgoingBytes(int length) |
void |
reportPing(long rt) |
void |
resentBytes(int bytesToResend) |
void |
sendEncryptedPacket(byte[] data) |
void |
sentPacket() |
void |
sentThrottledBytes(int length) |
void |
setSendLoadStatsASAP(boolean realtime)
Set the load stats to be sent asap.
|
boolean |
shouldPadDataPackets() |
boolean |
shouldThrottle() |
DecodingMessageGroup |
startProcessingDecryptedMessages(int count) |
void |
startRekeying() |
void |
verified(SessionKey s) |
void |
wakeUpSender() |
forceDisconnect, getBootID, getOutgoingMangler, getPeer, getSocketHandler, getThrottle, getThrottleWindowSize, getVersionNumber, getWeakRef, isConnected, isRoutable, reportThrottledPacketSendTime, sendAsync, shortToString, transferFailed, unqueueMessage
SessionKey getCurrentKeyTracker()
SessionKey getPreviousKeyTracker()
SessionKey getUnverifiedKeyTracker()
void receivedPacket(boolean dontLog, boolean dataPacket)
void verified(SessionKey s)
void startRekeying()
void maybeRekey()
void reportIncomingBytes(int length)
void reportOutgoingBytes(int length)
DecodingMessageGroup startProcessingDecryptedMessages(int count)
void reportPing(long rt)
double averagePingTime()
void wakeUpSender()
int getMaxPacketSize()
PeerMessageQueue getMessageQueue()
boolean shouldPadDataPackets()
void sendEncryptedPacket(byte[] data) throws Peer.LocalAddressException
Peer.LocalAddressException
void sentPacket()
boolean shouldThrottle()
void sentThrottledBytes(int length)
void onNotificationOnlyPacketSent(int length)
void resentBytes(int bytesToResend)
java.util.Random paddingGen()
void handleMessage(Message msg)
MessageItem makeLoadStats(boolean realtime, boolean highPriority, boolean noRemember)
realtime
- True for the realtime load stats, false for the bulk load stats.highPriority
- If true, boost the priority so it gets sent fast.noRemember
- If true, generating it for a lossy message in a packet; don't
remember that we sent it, since it might be lost, and generate it even if the last
one was the same, since the last one might be delayed.boolean grabSendLoadStatsASAP(boolean realtime)
void setSendLoadStatsASAP(boolean realtime)
double averagePingTimeCorrected()
void backoffOnResend()
void receivedAck(long currentTimeMillis)