PeerState2 (Javadocs [I2P+ 2.13.0+]

java.lang.Object
- net.i2p.router.transport.udp.PeerState
- - net.i2p.router.transport.udp.PeerState2

All Implemented Interfaces:
SSU2Bitfield.Callback, SSU2Payload.PayloadCallback, SSU2Sender
```
public class PeerState2
extends PeerState
implements SSU2Payload.PayloadCallback, SSU2Bitfield.Callback, SSU2Sender
```
Contain all of the state about a UDP connection to a peer. This is instantiated only after a connection is fully established. Public only for UI peers page. Not a public API, not for external use. SSU2 only.

Field Summary

Fields
Modifier and Type	Field and Description
`static int`	`DEFAULT_MTU` DEFAULT_MTU.
`static int`	`DEFAULT_SSU_IPV4_MTU` DEFAULT_SSU_IPV4_MTU.
`static int`	`DEFAULT_SSU_IPV6_MTU` DEFAULT_SSU_IPV6_MTU.
`static int`	`MAX_MTU` MAX_MTU.
`static int`	`MAX_SSU_IPV4_MTU` MAX_SSU_IPV4_MTU.
`static int`	`MAX_SSU_IPV6_MTU` MAX_SSU_IPV6_MTU.
`static int`	`MIN_MLKEM768_IPV4_MTU` MIN_MLKEM768_IPV4_MTU.
`static int`	`MIN_MLKEM768_IPV6_MTU` MIN_MLKEM768_IPV6_MTU.
`static int`	`MIN_MTU` MIN_MTU.
`static int`	`MIN_SSU_IPV4_MTU` MIN_SSU_IPV4_MTU.
`static int`	`MIN_SSU_IPV6_MTU` MIN_SSU_IPV6_MTU.

Fields inherited from class net.i2p.router.transport.udp.PeerState
_context, _dead, _inboundLock, _inboundMessages, _isInbound, _keyEstablishedTime, _lastACKSend, _log, _mtu, _packetsReceivedDuplicate, _remoteHostId, _remoteIP, _remoteIPAddress, _remotePeer, _remotePort, _rtt, _transport, _wantACKSendSince, LARGE_MTU, MAX_IPV6_MTU, MIN_IPV6_MTU, RETRANSMISSION_PERIOD_WIDTH

Constructor Summary

Constructors
Constructor and Description
`PeerState2(RouterContext ctx, UDPTransport transport, InetSocketAddress remoteAddress, Hash remotePeer, boolean isInbound, int rtt, CipherState sendCha, CipherState rcvCha, long sendID, long rcvID, byte[] sendHdrKey1, byte[] sendHdrKey2, byte[] rcvHdrKey2)` If inbound, caller MUST immediately call setWeRelayToThemAs() (if nonzero) and sendAck0().

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`bitSet(long pktNum)` Callback from SSU2Bitfield.forEachAndNot().
`(package private) void`	`changeAddress(RemoteHostId id)` Caller should sync; UDPTransport must remove and add to peersByRemoteHost map
`(package private) void`	`clearWantedACKSendSince()` All acks have been sent.
`(package private) void`	`confirmedPacketsSent(byte[][] data)` Note that we just sent the SessionConfirmed packets and save them for retransmission.
`(package private) void`	`dropOutbound()` Overridden to also clear sent-but-unacked fragments and cancel ACKTimer.
`(package private) List<OutboundMessageState>`	`finishAndAllocate(long now)` Single-pass combined cleanup + send allocation, overriding the base class to incorporate SSU2-specific _sentMessages cleanup and SessionConfirmed retransmit logic.
`(package private) int`	`fragmentOverhead()` Packet overhead This is 5 bytes too high for first or only fragment, because the 9 byte I2NP header is included in that fragment.
`(package private) int`	`fragmentSize()` how much payload data can we shove in there? This is 5 bytes too low for first or only fragment, because the 9 byte I2NP header is included in that fragment.
`void`	`fragmentsSent(long pktNum, int length, List<PacketBuilder.Fragment> fragments)` Record the mapping of packet number to what fragments were in it, so we can process acks.
`SSU2Bitfield`	`getAckedMessages()`
`(package private) int`	`getDestroyReason()`
`byte`	`getFlags()` Flag byte to be sent in header
`long`	`getNextPacketNumber()` Next outbound packet number, starts at 1 for Alice (0 is Session Confirmed) and 0 for Bob
`protected long`	`getNextPacketNumberNoThrow()` For PeerStateDestroyed only, after we are dead
`(package private) byte[]`	`getOurIP()` As received in the Address Block in the handshake, or subsequently in the data phase.
`(package private) int`	`getOurPort()` As received in the Address Block in the handshake, or subsequently in the data phase.
`(package private) CipherState`	`getRcvCipher()`
`(package private) long`	`getRcvConnID()` The connection ID we expect to receive packets with.
`(package private) byte[]`	`getRcvHeaderEncryptKey1()` The first header encryption key for received packets.
`(package private) byte[]`	`getRcvHeaderEncryptKey2()` The second header encryption key for received packets.
`SSU2Bitfield`	`getReceivedMessages()`
`CipherState`	`getSendCipher()` Caller must sync on returned object when encrypting
`long`	`getSendConnID()`
`byte[]`	`getSendHeaderEncryptKey1()`
`byte[]`	`getSendHeaderEncryptKey2()`
`static long`	`getSentMessagesCleanTime()`
`int`	`getVersion()` peer SSU version.
`void`	`gotACK(long ackThru, int acks, byte[] ranges)` gotACK.
`void`	`gotAddress(byte[] ip, int port)` gotAddress.
`void`	`gotDateTime(long time)` gotDateTime.
`void`	`gotFragment(byte[] data, int off, int len, long messageId, int frag, boolean isLast)` gotFragment.
`void`	`gotI2NP(I2NPMessage msg)` gotI2NP.
`void`	`gotOptions(byte[] options, boolean isHandshake)` gotOptions.
`void`	`gotPathChallenge(RemoteHostId from, byte[] data)` gotPathChallenge.
`void`	`gotPathResponse(RemoteHostId from, byte[] data)` gotPathResponse.
`void`	`gotPeerTest(int msg, int status, Hash h, byte[] data)` gotPeerTest.
`void`	`gotRelayIntro(Hash aliceHash, byte[] data)` gotRelayIntro.
`void`	`gotRelayRequest(byte[] data)` gotRelayRequest.
`void`	`gotRelayResponse(int status, byte[] data)` gotRelayResponse.
`void`	`gotRelayTag(long tag)` gotRelayTag.
`void`	`gotRelayTagRequest()` gotRelayTagRequest.
`void`	`gotRI(RouterInfo ri, boolean isHandshake, boolean flood)` gotRI.
`void`	`gotRIFragment(byte[] data, boolean isHandshake, boolean flood, boolean isGzipped, int frag, int totalFrags)` gotRIFragment.
`void`	`gotTermination(int reason, long count)` gotTermination.
`void`	`gotToken(long token, long expires)` gotToken.
`(package private) boolean`	`isDead()`
`protected void`	`messagePartiallyReceived(long now)` Overridden to use our version of ACKTimer
`(package private) void`	`receivePacket(RemoteHostId from, UDPPacket packet)` From different than expected source IP/port
`(package private) void`	`receivePacket(UDPPacket packet)`
`(package private) void`	`sendAck0()` Send immediate ACK 0 of Session Confirmed.
`int`	`sentMessagesSize()`
`void`	`setDestroyReason(int reason)`
`(package private) void`	`setOurAddress(byte[] ip, int port)` For initialization by IES2/OES2 only.
`static void`	`setSentMessagesCleanTime(long ms)` Set sent-messages cleanup interval.

Methods inherited from class net.i2p.router.transport.udp.PeerState
acked, add, adjustClockSkew, changePort, dataReceived, ECNReceived, expireInboundMessages, getAckFrequency, getAggregateStats, getClockSkew, getClockSkewFudge, getConcurrentSends, getConcurrentSendWindow, getConsecutiveFailedSends, getConsecutiveSendRejections, getInactivityTime, getInboundMessages, getInitConcurrentMsgs, getInitRTO, getIntroducerTime, getKeyEstablishedTime, getLastACKSend, getLastReceiveTime, getLastSendFullyTime, getLastSendOrPingTime, getLastSendTime, getMaxConcurrentMessages, getMaxRTO, getMaxSendWindow, getMayDisconnect, getMessagesReceived, getMessagesSent, getMinConcurrentMsgs, getMinRTO, getMTU, getNextDelay, getOutboundMessageCount, getOutboundMsgExpiration, getPacketsReceived, getPacketsReceivedDuplicate, getPacketsRetransmitted, getPacketsTransmitted, getPostRTOWindowMTUs, getReceiveBps, getReceiveMTU, getRemoteHostId, getRemoteIP, getRemoteIPAddress, getRemotePeer, getRemotePort, getRTO, getRTT, getRTTDeviation, getSendBps, getSendWindowBytes, getSendWindowBytesRemaining, getSlowStartThreshold, getTheyRelayToUsAs, getTransport, getWeRelayToThemAs, hasOutbound, highestSeqNumAcked, incrementConsecutiveFailedSends, isBacklogged, isInbound, isIPv6, loadConfig, loadFrom, messageFullyReceived, messagePartiallyReceived, messageRetransmitted, packetReceived, packetsTransmitted, setAckFrequency, setHisMTU, setInitConcurrentMsgs, setInitRTO, setIntroducerTime, setLastPingTime, setLastReceiveTime, setLastSendTime, setMaxConcurrentMessages, setMaxRTO, setMaxSendWindow, setMayDisconnect, setMinConcurrentMsgs, setMinRTO, setOutboundMsgExpiration, setPostRTOWindowMTUs, setTheyRelayToUsAs, setWeRelayToThemAs, shouldRequestImmediateAck, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface net.i2p.router.transport.udp.SSU2Sender
getMTU, getRemoteHostId, getRemoteIPAddress, getRemotePort, isIPv6

- Field Detail
  - DEFAULT_MTU
```
public static final int DEFAULT_MTU
```
    DEFAULT_MTU.
    See Also:
    Constant Field Values
  - DEFAULT_SSU_IPV4_MTU
```
public static final int DEFAULT_SSU_IPV4_MTU
```
    DEFAULT_SSU_IPV4_MTU.
    See Also:
    Constant Field Values
  - DEFAULT_SSU_IPV6_MTU
```
public static final int DEFAULT_SSU_IPV6_MTU
```
    DEFAULT_SSU_IPV6_MTU.
    See Also:
    Constant Field Values
  - MAX_MTU
```
public static final int MAX_MTU
```
    MAX_MTU.
    See Also:
    Constant Field Values
  - MAX_SSU_IPV4_MTU
```
public static final int MAX_SSU_IPV4_MTU
```
    MAX_SSU_IPV4_MTU.
    See Also:
    Constant Field Values
  - MAX_SSU_IPV6_MTU
```
public static final int MAX_SSU_IPV6_MTU
```
    MAX_SSU_IPV6_MTU.
    See Also:
    Constant Field Values
  - MIN_MLKEM768_IPV4_MTU
```
public static final int MIN_MLKEM768_IPV4_MTU
```
    MIN_MLKEM768_IPV4_MTU.
    See Also:
    Constant Field Values
  - MIN_MLKEM768_IPV6_MTU
```
public static final int MIN_MLKEM768_IPV6_MTU
```
    MIN_MLKEM768_IPV6_MTU.
    See Also:
    Constant Field Values
  - MIN_MTU
```
public static final int MIN_MTU
```
    MIN_MTU.
    See Also:
    Constant Field Values
  - MIN_SSU_IPV4_MTU
```
public static final int MIN_SSU_IPV4_MTU
```
    MIN_SSU_IPV4_MTU.
    See Also:
    Constant Field Values
  - MIN_SSU_IPV6_MTU
```
public static final int MIN_SSU_IPV6_MTU
```
    MIN_SSU_IPV6_MTU.
    See Also:
    Constant Field Values
- Constructor Detail
  - PeerState2
```
public PeerState2(RouterContext ctx,
                  UDPTransport transport,
                  InetSocketAddress remoteAddress,
                  Hash remotePeer,
                  boolean isInbound,
                  int rtt,
                  CipherState sendCha,
                  CipherState rcvCha,
                  long sendID,
                  long rcvID,
                  byte[] sendHdrKey1,
                  byte[] sendHdrKey2,
                  byte[] rcvHdrKey2)
```
    If inbound, caller MUST immediately call setWeRelayToThemAs() (if nonzero) and sendAck0().
    Parameters:
    rtt - from the EstablishState, or 0 if not available
- Method Detail
  - bitSet
```
public void bitSet(long pktNum)
```
    Callback from SSU2Bitfield.forEachAndNot(). A new ack was received.
    Specified by:
    bitSet in interface SSU2Bitfield.Callback
  - changeAddress
```
void changeAddress(RemoteHostId id)
```
    Caller should sync; UDPTransport must remove and add to peersByRemoteHost map
  - clearWantedACKSendSince
```
void clearWantedACKSendSince()
```
    All acks have been sent.
    Overrides:
    clearWantedACKSendSince in class PeerState
  - confirmedPacketsSent
```
void confirmedPacketsSent(byte[][] data)
```
    Note that we just sent the SessionConfirmed packets and save them for retransmission. This is only called the first time. For retransmit see allocateSend() above.
  - dropOutbound
```
void dropOutbound()
```
    Overridden to also clear sent-but-unacked fragments and cancel ACKTimer. Prevents lingering references from keeping orphaned PeerState2 alive.
    Overrides:
    dropOutbound in class PeerState
  - finishAndAllocate
```
List<OutboundMessageState> finishAndAllocate(long now)
```
    Single-pass combined cleanup + send allocation, overriding the base class to incorporate SSU2-specific _sentMessages cleanup and SessionConfirmed retransmit logic.
    Overrides:
    finishAndAllocate in class PeerState
    Parameters:
    now - current time
    Returns:
    messages to send, or null if none ready
  - fragmentOverhead
```
int fragmentOverhead()
```
    Packet overhead This is 5 bytes too high for first or only fragment, because the 9 byte I2NP header is included in that fragment. Does NOT leave any room for acks with a full-size fragment.
    Overrides:
    fragmentOverhead in class PeerState
    Returns:
    68 (IPv4), 88 (IPv6)
  - fragmentSize
```
int fragmentSize()
```
    how much payload data can we shove in there? This is 5 bytes too low for first or only fragment, because the 9 byte I2NP header is included in that fragment. Does NOT leave any room for acks with a full-size fragment.
    Overrides:
    fragmentSize in class PeerState
    Returns:
    MTU - 68 (IPv4), MTU - 88 (IPv6)
  - fragmentsSent
```
public void fragmentsSent(long pktNum,
                          int length,
                          List<PacketBuilder.Fragment> fragments)
```
    Record the mapping of packet number to what fragments were in it, so we can process acks.
    Specified by:
    fragmentsSent in interface SSU2Sender
    Parameters:
    length - including ip/udp header, for logging only
    pktNum - packet number, @param length fragment length, @param fragments fragment list
  - getAckedMessages
```
public SSU2Bitfield getAckedMessages()
```
    Specified by:
    getAckedMessages in interface SSU2Sender
    Returns:
    the acked messages
  - getDestroyReason
```
int getDestroyReason()
```
    Returns:
    0 (REASON_UNSPEC) if unset
  - getFlags
```
public byte getFlags()
```
    Flag byte to be sent in header
    Specified by:
    getFlags in interface SSU2Sender
    Returns:
    the flags
  - getNextPacketNumber
```
public long getNextPacketNumber()
                         throws IOException
```
    Next outbound packet number, starts at 1 for Alice (0 is Session Confirmed) and 0 for Bob
    Specified by:
    getNextPacketNumber in interface SSU2Sender
    Returns:
    the next packet number
    Throws:
    IOException
  - getNextPacketNumberNoThrow
```
protected long getNextPacketNumberNoThrow()
```
    For PeerStateDestroyed only, after we are dead
    Returns:
    the next packet number no throw
  - getOurIP
```
byte[] getOurIP()
```
    As received in the Address Block in the handshake, or subsequently in the data phase. Unvalidated. Also, if a transient IPv6 address, may be deprecated and not match our current non-deprecated IPv6 address.
  - getOurPort
```
int getOurPort()
```
    As received in the Address Block in the handshake, or subsequently in the data phase. Unvalidated.
  - getRcvCipher
```
CipherState getRcvCipher()
```
  - getRcvConnID
```
long getRcvConnID()
```
    The connection ID we expect to receive packets with.
    Returns:
    the receive connection ID
  - getRcvHeaderEncryptKey1
```
byte[] getRcvHeaderEncryptKey1()
```
    The first header encryption key for received packets.
    Returns:
    the receive header key 1
  - getRcvHeaderEncryptKey2
```
byte[] getRcvHeaderEncryptKey2()
```
    The second header encryption key for received packets.
    Returns:
    the receive header key 2
  - getReceivedMessages
```
public SSU2Bitfield getReceivedMessages()
```
    Specified by:
    getReceivedMessages in interface SSU2Sender
    Returns:
    the received messages
  - getSendCipher
```
public CipherState getSendCipher()
```
    Caller must sync on returned object when encrypting
    Specified by:
    getSendCipher in interface SSU2Sender
    Returns:
    the send cipher
  - getSendConnID
```
public long getSendConnID()
```
    Specified by:
    getSendConnID in interface SSU2Sender
    Returns:
    the send conn i d
  - getSendHeaderEncryptKey1
```
public byte[] getSendHeaderEncryptKey1()
```
    Specified by:
    getSendHeaderEncryptKey1 in interface SSU2Sender
    Returns:
    the send header encrypt key1
  - getSendHeaderEncryptKey2
```
public byte[] getSendHeaderEncryptKey2()
```
    Specified by:
    getSendHeaderEncryptKey2 in interface SSU2Sender
    Returns:
    the send header encrypt key2
  - getSentMessagesCleanTime
```
public static long getSentMessagesCleanTime()
```
    Returns:
    current sent-messages cleanup interval in ms
  - getVersion
```
public int getVersion()
```
    Description copied from class: PeerState
    peer SSU version.
    Overrides:
    getVersion in class PeerState
    Returns:
    the version
  - gotACK
```
public void gotACK(long ackThru,
                   int acks,
                   byte[] ranges)
```
    gotACK.
    Specified by:
    gotACK in interface SSU2Payload.PayloadCallback
    Parameters:
    ackThru - highest contiguous sequence number acknowledged
    acks - number of additional acknowledgments beyond ackThru
    ranges - null if none
  - gotAddress
```
public void gotAddress(byte[] ip,
                       int port)
```
    gotAddress.
    Specified by:
    gotAddress in interface SSU2Payload.PayloadCallback
    Parameters:
    ip - IP address bytes
    port - port number
  - gotDateTime
```
public void gotDateTime(long time)
```
    gotDateTime.
    Specified by:
    gotDateTime in interface SSU2Payload.PayloadCallback
    Parameters:
    time - time in milliseconds since epoch
  - gotFragment
```
public void gotFragment(byte[] data,
                        int off,
                        int len,
                        long messageId,
                        int frag,
                        boolean isLast)
                 throws DataFormatException
```
    gotFragment.
    Specified by:
    gotFragment in interface SSU2Payload.PayloadCallback
    Parameters:
    data - buffer containing fragment data
    off - offset in data
    len - length of data to copy
    messageId - unique message identifier
    frag - fragment number (0-based)
    isLast - whether this is the last fragment
    Throws:
    DataFormatException
  - gotI2NP
```
public void gotI2NP(I2NPMessage msg)
```
    gotI2NP.
    Specified by:
    gotI2NP in interface SSU2Payload.PayloadCallback
    Parameters:
    msg - the parsed I2NP message
  - gotOptions
```
public void gotOptions(byte[] options,
                       boolean isHandshake)
```
    gotOptions.
    Specified by:
    gotOptions in interface SSU2Payload.PayloadCallback
    Parameters:
    options - the option data
    isHandshake - true only for message 3 part 2
  - gotPathChallenge
```
public void gotPathChallenge(RemoteHostId from,
                             byte[] data)
```
    gotPathChallenge.
    Specified by:
    gotPathChallenge in interface SSU2Payload.PayloadCallback
    Parameters:
    from - null if unknown
  - gotPathResponse
```
public void gotPathResponse(RemoteHostId from,
                            byte[] data)
```
    gotPathResponse.
    Specified by:
    gotPathResponse in interface SSU2Payload.PayloadCallback
    Parameters:
    from - null if unknown
  - gotPeerTest
```
public void gotPeerTest(int msg,
                        int status,
                        Hash h,
                        byte[] data)
```
    gotPeerTest.
    Specified by:
    gotPeerTest in interface SSU2Payload.PayloadCallback
    Parameters:
    msg - 1-7
    status - 0 = accept, 1-255 = reject
    h - Alice or Charlie hash for msg 2 and 4, null for msg 1, 3, 5-7
    data - excludes flag, includes signature
  - gotRelayIntro
```
public void gotRelayIntro(Hash aliceHash,
                          byte[] data)
```
    gotRelayIntro.
    Specified by:
    gotRelayIntro in interface SSU2Payload.PayloadCallback
    Parameters:
    aliceHash - hash of the introducer
    data - excludes flag, includes signature
  - gotRelayRequest
```
public void gotRelayRequest(byte[] data)
```
    gotRelayRequest.
    Specified by:
    gotRelayRequest in interface SSU2Payload.PayloadCallback
    Parameters:
    data - excludes flag, includes signature
  - gotRelayResponse
```
public void gotRelayResponse(int status,
                             byte[] data)
```
    gotRelayResponse.
    Specified by:
    gotRelayResponse in interface SSU2Payload.PayloadCallback
    Parameters:
    status - 0 = accept, 1-255 = reject
    data - excludes flag, includes signature
  - gotRelayTag
```
public void gotRelayTag(long tag)
```
    gotRelayTag.
    Specified by:
    gotRelayTag in interface SSU2Payload.PayloadCallback
    Parameters:
    tag - the relay tag
  - gotRelayTagRequest
```
public void gotRelayTagRequest()
```
    gotRelayTagRequest.
    Specified by:
    gotRelayTagRequest in interface SSU2Payload.PayloadCallback
  - gotRI
```
public void gotRI(RouterInfo ri,
                  boolean isHandshake,
                  boolean flood)
           throws DataFormatException
```
    gotRI.
    Specified by:
    gotRI in interface SSU2Payload.PayloadCallback
    Parameters:
    ri - will already be validated
    isHandshake - true only for message 3 part 2
    flood - true if this is a floodfill router
    Throws:
    DataFormatException
  - gotRIFragment
```
public void gotRIFragment(byte[] data,
                          boolean isHandshake,
                          boolean flood,
                          boolean isGzipped,
                          int frag,
                          int totalFrags)
```
    gotRIFragment.
    Specified by:
    gotRIFragment in interface SSU2Payload.PayloadCallback
    Parameters:
    data - is first gzipped and then fragmented
    isHandshake - true only for message 3 part 2
    flood - true if this is a floodfill router
    isGzipped - true if the data is gzipped
    frag - fragment number (0-based)
    totalFrags - total number of fragments
  - gotTermination
```
public void gotTermination(int reason,
                           long count)
```
    gotTermination.
    Specified by:
    gotTermination in interface SSU2Payload.PayloadCallback
    Parameters:
    reason - termination reason code
    count - in theory could wrap around to negative, but very unlikely
  - gotToken
```
public void gotToken(long token,
                     long expires)
```
    gotToken.
    Specified by:
    gotToken in interface SSU2Payload.PayloadCallback
    Parameters:
    token - the token value
    expires - token expiration time in milliseconds
  - isDead
```
boolean isDead()
```
  - messagePartiallyReceived
```
protected void messagePartiallyReceived(long now)
```
    Overridden to use our version of ACKTimer
    Overrides:
    messagePartiallyReceived in class PeerState
    Parameters:
    now - the current time
  - receivePacket
```
void receivePacket(RemoteHostId from,
                   UDPPacket packet)
```
    From different than expected source IP/port
    Parameters:
    from - source address
    packet - fully encrypted, header and body decryption will be done here
  - receivePacket
```
void receivePacket(UDPPacket packet)
```
    Parameters:
    packet - fully encrypted, header and body decryption will be done here
  - sendAck0
```
void sendAck0()
```
    Send immediate ACK 0 of Session Confirmed. Inbound only. Bundle relay tag if requested, see InboundEstablishState2.
  - sentMessagesSize
```
public int sentMessagesSize()
```
    Returns:
    number of pending sent-but-unacked packet entries
  - setDestroyReason
```
public void setDestroyReason(int reason)
```
    Specified by:
    setDestroyReason in interface SSU2Sender
    Parameters:
    reason - destroy reason
  - setOurAddress
```
void setOurAddress(byte[] ip,
                   int port)
```
    For initialization by IES2/OES2 only.
  - setSentMessagesCleanTime
```
public static void setSentMessagesCleanTime(long ms)
```
    Set sent-messages cleanup interval. Called by Tuner.
    Parameters:
    ms - cleanup interval in ms, clamped to [2000, 300000]

Class PeerState2

Field Summary

Fields inherited from class net.i2p.router.transport.udp.PeerState

Constructor Summary

Method Summary

Methods inherited from class net.i2p.router.transport.udp.PeerState

Methods inherited from class java.lang.Object

Methods inherited from interface net.i2p.router.transport.udp.SSU2Sender

Field Detail

DEFAULT_MTU

DEFAULT_SSU_IPV4_MTU

DEFAULT_SSU_IPV6_MTU

MAX_MTU

MAX_SSU_IPV4_MTU

MAX_SSU_IPV6_MTU

MIN_MLKEM768_IPV4_MTU

MIN_MLKEM768_IPV6_MTU

MIN_MTU

MIN_SSU_IPV4_MTU

MIN_SSU_IPV6_MTU

Constructor Detail

PeerState2

Method Detail

bitSet

changeAddress

clearWantedACKSendSince

confirmedPacketsSent

dropOutbound

finishAndAllocate

fragmentOverhead

fragmentSize

fragmentsSent

getAckedMessages

getDestroyReason

getFlags

getNextPacketNumber

getNextPacketNumberNoThrow

getOurIP

getOurPort

getRcvCipher

getRcvConnID

getRcvHeaderEncryptKey1

getRcvHeaderEncryptKey2

getReceivedMessages

getSendCipher

getSendConnID

getSendHeaderEncryptKey1

getSendHeaderEncryptKey2

getSentMessagesCleanTime

getVersion

gotACK

gotAddress

gotDateTime

gotFragment

gotI2NP

gotOptions

gotPathChallenge

gotPathResponse

gotPeerTest

gotRelayIntro

gotRelayRequest

gotRelayResponse

gotRelayTag

gotRelayTagRequest

gotRI

gotRIFragment

gotTermination

gotToken

isDead

messagePartiallyReceived

receivePacket

receivePacket

sendAck0

sentMessagesSize

setDestroyReason

setOurAddress

setSentMessagesCleanTime