EstablishBase.FailedEstablishState

java.lang.Object

net.i2p.router.transport.ntcp.EstablishBase

net.i2p.router.transport.ntcp.EstablishBase.FailedEstablishState

All Implemented Interfaces:: EstablishState

Enclosing class:: EstablishBase

private static class EstablishBase.FailedEstablishStateextends EstablishBase

Establish state that failed, to retry later.

Nested Class Summary
Nested classes/interfaces inherited from class EstablishBase
EstablishBase.State
Modifier and Type
Class
Description
protected static enum
EstablishBase.State
States for NTCP connection establishment process.
Field Summary
Fields inherited from class EstablishBase
_con, _context, _failReason, _log, _peerSkew, _prevEncrypted, _received, _state, _stateLock, _transport, _X, _Y, AES_SIZE, FAILED, STATES_DONE, VERIFIED
Modifier and Type
Field
Description
protected final NTCPConnection
_con
Connection being established by this handshake.
protected final RouterContext
_context
Router context, supplied to the subclass that constructs this.
protected String
_failReason
Why the handshake failed, or null while it is still viable.
protected final Log
_log
Log scoped to the subclass that constructs this.
protected long
_peerSkew
OUR clock minus HIS clock, in seconds.
protected byte[]
_prevEncrypted
Previously received encrypted block (or the IV).
protected int
_received
Bytes received so far.
protected EstablishBase.State
_state
Current handshake state, replaced under the state lock.
protected final Object
_stateLock
Monitor serialising every handshake state change.
protected final NTCPTransport
_transport
NTCP transport running this handshake.
protected final byte[]
_X
Key block Bob receives and Alice sends, doubled as padding on inbound handshakes.
protected final byte[]
_Y
Key block Alice receives and Bob sends, null on outbound handshakes.
protected static final int
AES_SIZE
AES block and key size in bytes.
static final EstablishBase.FailedEstablishState
FAILED
Shared instance marking a handshake that ended in corruption.
protected static final Set<EstablishBase.State>
STATES_DONE
The two terminal states, VERIFIED and CORRUPT.
static final EstablishBase.VerifiedEstablishState
VERIFIED
Shared instance marking a handshake that completed and verified successfully.
Constructor Summary
Constructors
Constructor
Description
FailedEstablishState()
Starts in the corrupt state, for a handshake that already failed.
Method Summary
All Methods
Modifier and Type
Method
Description
int
getVersion()
The NTCP 2 version.
void
prepareOutbound()
Reject handshake preparation after failure.
void
receive(ByteBuffer src)
Reject any data received after the handshake failed.
String
toString()
String representation of the failed state.
Methods inherited from class EstablishBase
_x, changeState, close, fail, fail, fail, getFailReason, isComplete, isCorrupt, prefix, releaseBufs, storeFailCause
Modifier and Type
Method
Description
protected static final String
_x(String s)
Marker function for i18n, returns the string unchanged.
protected void
changeState(EstablishBase.State state)
Change the handshake state and update completion/corruption flags.
void
close(String reason, Exception e)
Release resources on timeout.
protected void
fail(String reason)
Fail the handshake.
protected void
fail(String reason, Exception e)
Fail the handshake with exception.
protected void
fail(String reason, Exception e, boolean bySkew)
Fail the handshake optionally suppressing skew stat.
String
getFailReason()
Failure reason if the handshake failed, or null if not failed/corrupt.
boolean
isComplete()
If synchronized on this, fails with deadlocks from all over via CSFI.isEstablished().
boolean
isCorrupt()
Did the handshake fail for some reason?
protected String
prefix()
Logging prefix string.
protected void
releaseBufs(boolean isVerified)
Only call once.
(package private) static String
storeFailCause(IllegalArgumentException iae)
The bare cause from a netdb store rejection, stripped of the "Invalid NetDbStore attempt" wrapper, capability flags and router ID.
Methods inherited from class Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- FailedEstablishState
  public FailedEstablishState()
  Starts in the corrupt state, for a handshake that already failed.
Method Details
- getVersion
  public int getVersion()
  The NTCP 2 version.
  Specified by:
  getVersion in interface EstablishState
  Specified by:
  getVersion in class EstablishBase
  Returns:
  1, the NTCP 2 protocol version number
- receive
  public void receive(ByteBuffer src)
  Reject any data received after the handshake failed.
  Specified by:
  receive in interface EstablishState
  Overrides:
  receive in class EstablishBase
  Parameters:
  src - the buffer to parse
  Throws:
  IllegalStateException - always; the state is already corrupt
- prepareOutbound
  public void prepareOutbound()
  Reject handshake preparation after failure.
  Specified by:
  prepareOutbound in interface EstablishState
  Overrides:
  prepareOutbound in class EstablishBase
  Throws:
  IllegalStateException - always; the state is already corrupt
- toString
  public String toString()
  String representation of the failed state.
  Overrides:
  toString in class EstablishBase

Nested Class Summary

Nested classes/interfaces inherited from class EstablishBase

Field Summary

Fields inherited from class EstablishBase

Constructor Summary

Method Summary

Methods inherited from class EstablishBase

Methods inherited from class Object

Constructor Details

FailedEstablishState

Method Details

getVersion

receive

prepareOutbound

toString