SAMStreamSink.SinkEventHandler2

net.i2p.sam.client.SAMStreamSink.SinkEventHandler2

All Implemented Interfaces:: SAMReader.SAMClientEventListener

Enclosing class:: SAMStreamSink

private class SAMStreamSink.SinkEventHandler2extends SAMStreamSink.SinkEventHandler

Handler for the second master session stream.

Field Summary
Fields
Modifier and Type
Field
Description
private final InputStream
_in
Stream the second session's messages arrive on.
Fields inherited from class SAMStreamSink.SinkEventHandler
_out
Modifier and Type
Field
Description
protected final OutputStream
_out
Stream to the SAM bridge, used to answer keepalives.
Fields inherited from interface SAMReader.SAMClientEventListener
NAMING_REPLY_INVALID_KEY, NAMING_REPLY_KEY_NOT_FOUND, NAMING_REPLY_OK, SESSION_STATUS_DUPLICATE_DEST, SESSION_STATUS_I2P_ERROR, SESSION_STATUS_INVALID_KEY, SESSION_STATUS_OK, STREAM_CLOSED_CANT_REACH_PEER, STREAM_CLOSED_I2P_ERROR, STREAM_CLOSED_OK, STREAM_CLOSED_PEER_NOT_FOUND, STREAM_CLOSED_TIMEOUT, STREAM_STATUS_CANT_REACH_PEER, STREAM_STATUS_I2P_ERROR, STREAM_STATUS_INVALID_KEY, STREAM_STATUS_OK, STREAM_STATUS_TIMEOUT
Modifier and Type
Field
Description
static final String
NAMING_REPLY_INVALID_KEY
Naming lookup failed because the private key is invalid.
static final String
NAMING_REPLY_KEY_NOT_FOUND
Naming lookup failed because no key matches the requested name.
static final String
NAMING_REPLY_OK
Naming lookup succeeded.
static final String
SESSION_STATUS_DUPLICATE_DEST
Session creation failed because the destination is already in use.
static final String
SESSION_STATUS_I2P_ERROR
SESSION_STATUS_I2P_ERROR.
static final String
SESSION_STATUS_INVALID_KEY
Session creation failed because the supplied private key is invalid.
static final String
SESSION_STATUS_OK
Session creation succeeded.
static final String
STREAM_CLOSED_CANT_REACH_PEER
Stream closed because the peer became unreachable.
static final String
STREAM_CLOSED_I2P_ERROR
STREAM_CLOSED_I2P_ERROR.
static final String
STREAM_CLOSED_OK
Stream closed normally.
static final String
STREAM_CLOSED_PEER_NOT_FOUND
Stream closed because the destination was no longer known to the router.
static final String
STREAM_CLOSED_TIMEOUT
Stream closed because the lease expired.
static final String
STREAM_STATUS_CANT_REACH_PEER
Stream connect failed because the peer could not be reached.
static final String
STREAM_STATUS_I2P_ERROR
STREAM_STATUS_I2P_ERROR.
static final String
STREAM_STATUS_INVALID_KEY
Stream connect failed because the private key is invalid.
static final String
STREAM_STATUS_OK
Stream connect succeeded.
static final String
STREAM_STATUS_TIMEOUT
Stream connect failed because the lease expired before it was established.
Constructor Summary
Constructors
Constructor
Description
SinkEventHandler2(I2PAppContext ctx, InputStream in, OutputStream out)
SinkEventHandler2.
Method Summary
All Methods
Modifier and Type
Method
Description
void
streamStatusReceived(String result, String id, String message)
Opens the sink once the bridge confirms the stream connection.
Methods inherited from class SAMStreamSink.SinkEventHandler
datagramReceived, pingReceived, rawReceived, streamClosedReceived, streamConnectedReceived, streamDataReceived
Modifier and Type
Method
Description
void
datagramReceived(String dest, byte[] data, int offset, int length, int fromPort, int toPort)
Appends the received datagram to the first open sink.
void
pingReceived(String data)
Answers a bridge keepalive with a matching PONG.
void
rawReceived(byte[] data, int offset, int length, int fromPort, int toPort, int protocol)
Appends the received raw datagram to the first open sink.
void
streamClosedReceived(String result, String id, String message)
Closes the sink file and records the connection lifetime.
void
streamConnectedReceived(String dest, String id)
Opens a sink file for a newly connected stream.
void
streamDataReceived(String id, byte[] data, int offset, int length)
Appends the received stream data to the sink file.
Methods inherited from class SAMEventHandler
helloReplyReceived, namingReplyReceived, sessionStatusReceived, unknownMessageReceived, waitForHelloReply, waitForNamingReply, waitForSessionAddReply, waitForSessionCreateReply, waitForStreamStatusReply
Modifier and Type
Method
Description
void
helloReplyReceived(boolean ok, String version)
Records the HELLO outcome and version, then wakes any waiter.
void
namingReplyReceived(String name, String result, String value, String msg)
Files a naming reply under its name, value on success and result otherwise.
void
sessionStatusReceived(String result, String destination, String msg)
May be called twice, first for CREATE and second for ADD.
void
unknownMessageReceived(String major, String minor, Properties params)
Logs a message this handler has no handling for.
String
waitForHelloReply()
Wait for the connection to be established, returning the server version if everything went ok.
String
waitForNamingReply(String name)
Return the destination found matching the name, or null if the key was not able to be retrieved.
boolean
waitForSessionAddReply()
Wait for the session to be added, returning true if everything went ok.
boolean
waitForSessionCreateReply()
Wait for the session to be created, returning true if everything went ok.
boolean
waitForStreamStatusReply()
Wait for the stream to be created, returning true if everything went ok.
Methods inherited from class SAMClientEventListenerImpl
destReplyReceived, pongReceived
Modifier and Type
Method
Description
void
destReplyReceived(String publicKey, String privateKey)
Called when a DEST reply arrives.
void
pongReceived(String data)
Called when a PONG reply arrives.
Methods inherited from class Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- _in
  private final InputStream _in
  Stream the second session's messages arrive on.
Constructor Details
- SinkEventHandler2
  public SinkEventHandler2(I2PAppContext ctx, InputStream in, OutputStream out)
  SinkEventHandler2.
  Parameters:
  ctx - the application context for the event handler
  in - the forwarded connection's input stream, read for the destination line and the streamed data
  out - the bridge output stream, used to answer keepalives
Method Details
- streamStatusReceived
  public void streamStatusReceived(String result, String id, String message)
  Opens the sink once the bridge confirms the stream connection.
  Specified by:
  streamStatusReceived in interface SAMReader.SAMClientEventListener
  Overrides:
  streamStatusReceived in class SAMEventHandler
  Parameters:
  result - the stream status, one of the STREAM_STATUS_* constants
  id - the stream ID from the reply, null under SAM v3
  message - the human-readable explanation supplied by the bridge

Field Summary

Fields inherited from class SAMStreamSink.SinkEventHandler

Fields inherited from interface SAMReader.SAMClientEventListener

Constructor Summary

Method Summary

Methods inherited from class SAMStreamSink.SinkEventHandler

Methods inherited from class SAMEventHandler

Methods inherited from class SAMClientEventListenerImpl

Methods inherited from class Object

Field Details

_in

Constructor Details

SinkEventHandler2

Method Details

streamStatusReceived