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

Direct Known Subclasses:

InboundEstablishState2
```
class InboundEstablishState
extends Object
```
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. TODO do all these methods need to be synchronized?

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class InboundEstablishState.InboundState

Field Summary

Fields
Modifier and Type	Field	Description
`protected byte[]`	`_aliceIP`
`protected int`	`_alicePort`
`protected byte[]`	`_bobIP`
`protected int`	`_bobPort`
`protected RouterContext`	`_context`
`protected int`	`_createdSentCount`
`protected InboundEstablishState.InboundState`	`_currentState`
`protected long`	`_establishBegin`
`protected boolean`	`_introductionRequested`
`protected long`	`_lastSend`
`protected Log`	`_log`
`protected long`	`_nextSend`
`protected RouterIdentity`	`_receivedConfirmedIdentity`
`protected RouterIdentity`	`_receivedUnconfirmedIdentity`
`protected RemoteHostId`	`_remoteHostId`
`protected int`	`_rtt`
`protected long`	`_sentRelayTag`
`protected static long`	`MAX_DELAY`	max delay including backoff This should be a little shorter than for outbound.
`protected static long`	`RETRANSMIT_DELAY`	basic delay before backoff Transmissions at 0, 1, 3, 7 sec This should be a little shorter than for outbound.

Constructor Summary

Constructors
Modifier	Constructor	Description
	`InboundEstablishState(RouterContext ctx, byte[] remoteIP, int remotePort, int localPort, DHSessionKeyBuilder dh, UDPPacketReader.SessionRequestReader req)`
`protected`	`InboundEstablishState(RouterContext ctx, InetSocketAddress addr)`	For SSU2

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addMessage(OutNetMessage msg)`	Queue a message to be sent after the session is established.
`void`	`complete()`	Notify successful completion
`protected boolean`	`confirmedFullyReceived()`	Have we fully received the SessionConfirmed messages from Alice? Caller must synch on this.
`void`	`createdPacketSent()`	note that we just sent a SessionCreated packet
`void`	`fail()`
`void`	`generateSessionKey()`	Generates session key and mac key.
`SessionKey`	`getCipherKey()`
`RouterIdentity`	`getConfirmedIdentity()`	Who is Alice (null if forged/unknown) Note that this isn't really confirmed - see below.
`long`	`getEstablishBeginTime()`
`long`	`getLifetime()`	how long have we been trying to establish this session?
`long`	`getLifetime(long now)`	how long have we been trying to establish this session?
`SessionKey`	`getMACKey()`
`OutNetMessage`	`getNextQueuedMessage()`	Pull from the message queue
`long`	`getNextSendTime()`
`byte[]`	`getReceivedOurIP()`
`byte[]`	`getReceivedX()`
`(package private) RemoteHostId`	`getRemoteHostId()`	RemoteHostId, uniquely identifies an attempt
`(package private) int`	`getRTT()`
`byte[]`	`getSentIP()`	what IP do they appear to be on?
`int`	`getSentPort()`	what port number do they appear to be coming from?
`long`	`getSentRelayTag()`
`Signature`	`getSentSignature()`
`long`	`getSentSignedOnTime()`
`byte[]`	`getSentY()`
`InboundEstablishState.InboundState`	`getState()`
`int`	`getVersion()`
`boolean`	`isComplete()`
`boolean`	`isIntroductionRequested()`	True (default) if no extended options in session request, or value of flag bit in the extended options.
`protected void`	`packetReceived()`	Call from synchronized method only
`void`	`prepareSessionCreated()`
`void`	`receiveSessionConfirmed(UDPPacketReader.SessionConfirmedReader conf)`	Note that while a SessionConfirmed could in theory be fragmented, in practice a RouterIdentity is 387 bytes and a single fragment is 512 bytes max, so it will never be fragmented.
`void`	`receiveSessionRequest(UDPPacketReader.SessionRequestReader req)`
`boolean`	`sessionRequestReceived()`
`void`	`setSentRelayTag(long tag)`
`String`	`toString()`

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

Field Detail

_context
```
protected final RouterContext _context
```

_log
```
protected final Log _log
```

_bobIP
```
protected byte[] _bobIP
```

_bobPort
```
protected final int _bobPort
```

_aliceIP
```
protected final byte[] _aliceIP
```

_alicePort
```
protected final int _alicePort
```

_sentRelayTag
```
protected long _sentRelayTag
```

_receivedUnconfirmedIdentity

protected RouterIdentity _receivedUnconfirmedIdentity

_receivedConfirmedIdentity

protected RouterIdentity _receivedConfirmedIdentity

_establishBegin
```
protected final long _establishBegin
```

_lastSend
```
protected long _lastSend
```

_nextSend
```
protected long _nextSend
```

_remoteHostId

protected final RemoteHostId _remoteHostId

_currentState

protected InboundEstablishState.InboundState _currentState

_createdSentCount
```
protected int _createdSentCount
```

_introductionRequested

protected boolean _introductionRequested

_rtt
```
protected int _rtt
```

RETRANSMIT_DELAY
```
protected static final long RETRANSMIT_DELAY
```
basic delay before backoff Transmissions at 0, 1, 3, 7 sec This should be a little shorter than for outbound.

See Also:

Constant Field Values

MAX_DELAY
```
protected static final long MAX_DELAY
```
max delay including backoff This should be a little shorter than for outbound.

See Also:

Constant Field Values

Constructor Detail

InboundEstablishState

public InboundEstablishState(RouterContext ctx,
                             byte[] remoteIP,
                             int remotePort,
                             int localPort,
                             DHSessionKeyBuilder dh,
                             UDPPacketReader.SessionRequestReader req)

Parameters:: localPort - Must be our external port, otherwise the signature of the SessionCreated message will be bad if the external port != the internal port.

InboundEstablishState

protected InboundEstablishState(RouterContext ctx,
                                InetSocketAddress addr)

For SSU2

Since:: 0.9.54

Method Detail
- getVersion
```
public int getVersion()
```
  Since:
  
  0.9.54
- getState
```
public InboundEstablishState.InboundState getState()
```
- isComplete
```
public boolean isComplete()
```
  Returns:
  
  if previously complete
- complete
```
public void complete()
```
  Notify successful completion
- addMessage
```
public void addMessage(OutNetMessage msg)
```
  Queue a message to be sent after the session is established. This will only happen if we decide to send something during establishment
  
  Since:
  
  0.9.2
- getNextQueuedMessage
```
public OutNetMessage getNextQueuedMessage()
```
  Pull from the message queue
  
  Returns:
  
  null if none
  
  Since:
  
  0.9.2
- receiveSessionRequest
```
public void receiveSessionRequest(UDPPacketReader.SessionRequestReader req)
```
- sessionRequestReceived
```
public boolean sessionRequestReceived()
```
- getReceivedX
```
public byte[] getReceivedX()
```
- getReceivedOurIP
```
public byte[] getReceivedOurIP()
```
- isIntroductionRequested
```
public boolean isIntroductionRequested()
```
  True (default) if no extended options in session request, or value of flag bit in the extended options.
  
  Since:
  
  0.9.24
- generateSessionKey
```
public void generateSessionKey()
                        throws DHSessionKeyBuilder.InvalidPublicParameterException
```
  Generates session key and mac key.
  
  Throws:
  
  DHSessionKeyBuilder.InvalidPublicParameterException
- getCipherKey
```
public SessionKey getCipherKey()
```
- getMACKey
```
public SessionKey getMACKey()
```
- getSentIP
```
public byte[] getSentIP()
```
  what IP do they appear to be on?
- getSentPort
```
public int getSentPort()
```
  what port number do they appear to be coming from?
- getSentY
```
public byte[] getSentY()
```
- fail
```
public void fail()
```
- getSentRelayTag
```
public long getSentRelayTag()
```
- setSentRelayTag
```
public void setSentRelayTag(long tag)
```
- getSentSignedOnTime
```
public long getSentSignedOnTime()
```
- prepareSessionCreated
```
public void prepareSessionCreated()
```
- getSentSignature
```
public Signature getSentSignature()
```
- createdPacketSent
```
public void createdPacketSent()
```
  note that we just sent a SessionCreated packet
- getLifetime
```
public long getLifetime()
```
  how long have we been trying to establish this session?
- getLifetime
```
public long getLifetime(long now)
```
  how long have we been trying to establish this session?
  
  Since:
  
  0.9.57
- getEstablishBeginTime
```
public long getEstablishBeginTime()
```
- getNextSendTime
```
public long getNextSendTime()
```
  Returns:
  
  rcv time after receiving a packet (including after constructor), send time + delay after sending a packet
- getRTT
```
int getRTT()
```
- getRemoteHostId
```
RemoteHostId getRemoteHostId()
```
  RemoteHostId, uniquely identifies an attempt
- receiveSessionConfirmed
```
public void receiveSessionConfirmed(UDPPacketReader.SessionConfirmedReader conf)
```
  Note that while a SessionConfirmed could in theory be fragmented, in practice a RouterIdentity is 387 bytes and a single fragment is 512 bytes max, so it will never be fragmented.
- confirmedFullyReceived
```
protected boolean confirmedFullyReceived()
```
  Have we fully received the SessionConfirmed messages from Alice? Caller must synch on this.
- getConfirmedIdentity
```
public RouterIdentity getConfirmedIdentity()
```
  Who is Alice (null if forged/unknown) Note that this isn't really confirmed - see below.
- packetReceived
```
protected void packetReceived()
```
  Call from synchronized method only
- toString
```
public String toString()
```
  Overrides:
  
  toString in class Object

Class InboundEstablishState

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

_context

_log

_bobIP

_bobPort

_aliceIP

_alicePort

_sentRelayTag

_receivedUnconfirmedIdentity

_receivedConfirmedIdentity

_establishBegin

_lastSend

_nextSend

_remoteHostId

_currentState

_createdSentCount

_introductionRequested

_rtt

RETRANSMIT_DELAY

MAX_DELAY

Constructor Detail

InboundEstablishState

InboundEstablishState

Method Detail

getVersion

getState

isComplete

complete

addMessage

getNextQueuedMessage

receiveSessionRequest

sessionRequestReceived

getReceivedX

getReceivedOurIP

isIntroductionRequested

generateSessionKey

getCipherKey

getMACKey

getSentIP

getSentPort

getSentY

fail

getSentRelayTag

setSentRelayTag

getSentSignedOnTime

prepareSessionCreated

getSentSignature

createdPacketSent

getLifetime

getLifetime

getEstablishBeginTime

getNextSendTime

getRTT

getRemoteHostId

receiveSessionConfirmed

confirmedFullyReceived

getConfirmedIdentity

packetReceived

toString