InboundEstablishState2 (Javadocs [I2P+ 2.13.0+]

java.lang.Object
- net.i2p.router.transport.udp.InboundEstablishState
- - net.i2p.router.transport.udp.InboundEstablishState2

All Implemented Interfaces:
SSU2Payload.PayloadCallback
```
class InboundEstablishState2
extends InboundEstablishState
implements SSU2Payload.PayloadCallback
```
Data for a new connection being established, where the remote peer has initiated the connection with us. In other words, they are Alice and we are Bob. SSU2 only.

Nested Class Summary
- Nested classes/interfaces inherited from class net.i2p.router.transport.udp.InboundEstablishState
  InboundEstablishState.InboundState

Field Summary
- Fields inherited from class net.i2p.router.transport.udp.InboundEstablishState
  _aliceIP, _alicePort, _bobIP, _bobPort, _context, _createdSentCount, _currentState, _establishBegin, _introductionRequested, _lastSend, _log, _nextSend, _receivedConfirmedIdentity, _receivedUnconfirmedIdentity, _remoteHostId, _rtt, _sentRelayTag, RETRANSMIT_DELAY

Constructor Summary

Constructors
Constructor and Description
`InboundEstablishState2(RouterContext ctx, UDPTransport transport, UDPPacket packet)` Start a new handshake with the given incoming packet, which must be a Session Request or Token Request.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`createdPacketSent()` createdPacketSent.
`void`	`createdPacketSent(DatagramPacket pkt)` note that we just sent the SessionCreated packet and save it for retransmission
`void`	`fail()` Overridden to destroy the handshake state
`HandshakeState`	`getHandshakeState()`
`EstablishmentManager.Token`	`getNextToken()`
`PeerState2`	`getPeerState()`
`long`	`getRcvConnID()`
`byte[]`	`getRcvHeaderEncryptKey1()`
`byte[]`	`getRcvHeaderEncryptKey2()`
`UDPPacket`	`getRetransmitSessionCreatedPacket()`
`long`	`getSendConnID()`
`byte[]`	`getSendHeaderEncryptKey1()`
`byte[]`	`getSendHeaderEncryptKey2()`
`InetSocketAddress`	`getSentAddress()`
`long`	`getToken()`
`int`	`getVersion()` Return the SSU protocol version for this state (always 1 for SSU1).
`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)` For most errors here we throw a RIException with a reason code, which is caught in processPayload() to create a PeerStateDestroyed and send a termination with that reason.
`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.
`void`	`queuePossibleDataPacket(UDPPacket packet)`
`PeerState2`	`receiveSessionConfirmed(UDPPacket packet)` Receive the last messages in the handshake, and create the PeerState.
`void`	`receiveSessionOrTokenRequestAfterRetry(UDPPacket packet)` All exceptions thrown from here will be fatal.
`void`	`retryPacketSent()` note that we just sent a Retry packet
`String`	`toString()` toString.

Methods inherited from class net.i2p.router.transport.udp.InboundEstablishState
addMessage, complete, confirmedFullyReceived, getConfirmedIdentity, getEstablishBeginTime, getLifetime, getLifetime, getMaxDelay, getNextQueuedMessage, getNextSendTime, getReceivedOurIP, getReceivedX, getRemoteHostId, getRTT, getSentIP, getSentPort, getSentRelayTag, getSentSignedOnTime, getState, isComplete, isIntroductionRequested, packetReceived, sessionRequestReceived, setSentRelayTag

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

- Constructor Detail
  - InboundEstablishState2
```
public InboundEstablishState2(RouterContext ctx,
                              UDPTransport transport,
                              UDPPacket packet)
                       throws GeneralSecurityException
```
    Start a new handshake with the given incoming packet, which must be a Session Request or Token Request. Caller must then check getState() and build a Retry or Session Created in response.
    Parameters:
    packet - with all header encryption removed, either a SessionRequest OR a TokenRequest.
    Throws:
    GeneralSecurityException
- Method Detail
  - createdPacketSent
```
public void createdPacketSent()
```
    createdPacketSent.
    Overrides:
    createdPacketSent in class InboundEstablishState
  - createdPacketSent
```
public void createdPacketSent(DatagramPacket pkt)
```
    note that we just sent the SessionCreated packet and save it for retransmission
  - fail
```
public void fail()
```
    Overridden to destroy the handshake state
    Overrides:
    fail in class InboundEstablishState
  - getHandshakeState
```
public HandshakeState getHandshakeState()
```
    Returns:
    the handshake state
  - getNextToken
```
public EstablishmentManager.Token getNextToken()
```
    Returns:
    may be null
  - getPeerState
```
public PeerState2 getPeerState()
```
    Returns:
    null if we have not received the session confirmed
  - getRcvConnID
```
public long getRcvConnID()
```
    Returns:
    the rcv conn i d
  - getRcvHeaderEncryptKey1
```
public byte[] getRcvHeaderEncryptKey1()
```
    Returns:
    the rcv header encrypt key1
  - getRcvHeaderEncryptKey2
```
public byte[] getRcvHeaderEncryptKey2()
```
    Returns:
    the rcv header encrypt key2
  - getRetransmitSessionCreatedPacket
```
public UDPPacket getRetransmitSessionCreatedPacket()
```
    Returns:
    null if not sent or already got the session confirmed
  - getSendConnID
```
public long getSendConnID()
```
    Returns:
    the send conn i d
  - getSendHeaderEncryptKey1
```
public byte[] getSendHeaderEncryptKey1()
```
    Returns:
    the send header encrypt key1
  - getSendHeaderEncryptKey2
```
public byte[] getSendHeaderEncryptKey2()
```
    Returns:
    the send header encrypt key2
  - getSentAddress
```
public InetSocketAddress getSentAddress()
```
    Returns:
    the sent address
  - getToken
```
public long getToken()
```
    Returns:
    the token
  - getVersion
```
public int getVersion()
```
    Description copied from class: InboundEstablishState
    Return the SSU protocol version for this state (always 1 for SSU1).
    Overrides:
    getVersion in class InboundEstablishState
    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
```
    For most errors here we throw a RIException with a reason code, which is caught in processPayload() to create a PeerStateDestroyed and send a termination with that reason. Plain DataFormatExceptions indicate you may not respond in-session.
    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
  - queuePossibleDataPacket
```
public void queuePossibleDataPacket(UDPPacket packet)
```
    Parameters:
    packet - with header still encrypted
  - receiveSessionConfirmed
```
public PeerState2 receiveSessionConfirmed(UDPPacket packet)
```
    Receive the last messages in the handshake, and create the PeerState. If the message is fragmented, store the data for reassembly and return, unless this was the last one. Exceptions thrown from here are fatal.
    Returns:
    the new PeerState2 if are done, may also be retrieved from getPeerState(), or null if more fragments to go
  - receiveSessionOrTokenRequestAfterRetry
```
public void receiveSessionOrTokenRequestAfterRetry(UDPPacket packet)
                                            throws GeneralSecurityException
```
    All exceptions thrown from here will be fatal. fail() will be called before throwing.
    Throws:
    GeneralSecurityException
  - retryPacketSent
```
public void retryPacketSent()
```
    note that we just sent a Retry packet
  - toString
```
public String toString()
```
    toString.
    Overrides:
    toString in class InboundEstablishState
    Returns:
    debug string with peer address, lifetime, relay tag, and state

Class InboundEstablishState2

Nested Class Summary

Nested classes/interfaces inherited from class net.i2p.router.transport.udp.InboundEstablishState

Field Summary

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

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Constructor Detail

InboundEstablishState2

Method Detail

createdPacketSent

createdPacketSent

fail

getHandshakeState

getNextToken

getPeerState

getRcvConnID

getRcvHeaderEncryptKey1

getRcvHeaderEncryptKey2

getRetransmitSessionCreatedPacket

getSendConnID

getSendHeaderEncryptKey1

getSendHeaderEncryptKey2

getSentAddress

getToken

getVersion

gotACK

gotAddress

gotDateTime

gotFragment

gotI2NP

gotOptions

gotPathChallenge

gotPathResponse

gotPeerTest

gotRelayIntro

gotRelayRequest

gotRelayResponse

gotRelayTag

gotRelayTagRequest

gotRI

gotRIFragment

gotTermination

gotToken

queuePossibleDataPacket

receiveSessionConfirmed

receiveSessionOrTokenRequestAfterRetry

retryPacketSent

toString