freenet.node

Class NewPacketFormatKeyContext

java.lang.Object

freenet.node.NewPacketFormatKeyContext

public class NewPacketFormatKeyContext
extends java.lang.Object

NewPacketFormat's context for each SessionKey. Specifically, packet numbers are unique to a SessionKey, because the packet number is used in encrypting the packet. Hence this class has everything to do with packet numbers - which to use next, which we've sent packets on and are waiting for acks, which we've received and should ack etc.

Field Summary

Fields

Modifier and Type	Field and Description
int	firstSeqNumUsed
int	highestReceivedSeqNum
int	nextSeqNum
byte[][]	seqNumWatchList
int	watchListOffset
int	watchListPointer Index of the packet with the lowest sequence number

Method Summary

Modifier and Type	Method and Description
void	ack(int ack, BasePeerNode pn, SessionKey key) One of our outgoing packets has been acknowledged.
freenet.node.NewPacketFormatKeyContext.AddedAcks	addAcks(freenet.node.NPFPacket packet, int maxPacketSize, long now) Add as many acks as possible to the packet.
void	checkForLostPackets(double averageRTT, long curTime, BasePeerNode pn)
int	countSentPackets()
void	disconnected()
int	queueAck(int seqno) Queue an ack.
void	sent(int sequenceNumber, int length)
void	sent(freenet.node.NewPacketFormat.SentPacket sentPacket, int seqNum, int length)
long	timeCheckForAcks()
long	timeCheckForLostPackets(double averageRTT)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

firstSeqNumUsed

public int firstSeqNumUsed

nextSeqNum

public int nextSeqNum

highestReceivedSeqNum

public int highestReceivedSeqNum

seqNumWatchList

public byte[][] seqNumWatchList

watchListPointer

public int watchListPointer

Index of the packet with the lowest sequence number

watchListOffset

public int watchListOffset

Method Detail

ack

public void ack(int ack,
                BasePeerNode pn,
                SessionKey key)

One of our outgoing packets has been acknowledged.

queueAck

public int queueAck(int seqno)

Queue an ack.

Returns:

-1 If the ack was already queued, or the total number queued.

sent

public void sent(int sequenceNumber,
                 int length)

addAcks

public freenet.node.NewPacketFormatKeyContext.AddedAcks addAcks(freenet.node.NPFPacket packet,
                                                                int maxPacketSize,
                                                                long now)

Add as many acks as possible to the packet.

Returns:

True if there are any old acks i.e. acks that will force us to send a packet even if there isn't anything else in it.

countSentPackets

public int countSentPackets()

sent

public void sent(freenet.node.NewPacketFormat.SentPacket sentPacket,
                 int seqNum,
                 int length)

timeCheckForLostPackets

public long timeCheckForLostPackets(double averageRTT)

checkForLostPackets

public void checkForLostPackets(double averageRTT,
                                long curTime,
                                BasePeerNode pn)

timeCheckForAcks

public long timeCheckForAcks()

disconnected

public void disconnected()