I2PSessionMuxedImpl

net.i2p.client.impl.I2PSessionMuxedImpl

All Implemented Interfaces:: I2PSession, I2CPMessageReader.I2CPMessageEventListener

Direct Known Subclasses:: SubSession

class I2PSessionMuxedImplextends I2PSessionImpl2

I2PSession with protocol and ports

Streaming lib has been modified to send I2PSession.PROTO_STREAMING but still receives all. It sends with fromPort and toPort = 0, and receives on all ports.

No datagram apps have been modified yet.

Therefore the compatibility situation is as follows:

Compatibility: old streaming -> new streaming: sends proto anything, rcvs proto anything new streaming -> old streaming: sends PROTO_STREAMING, ignores rcvd proto old datagram -> new datagram: sends proto anything, rcvs proto anything new datagram -> old datagram: sends PROTO_DATAGRAM, ignores rcvd proto In all the above cases, streaming and datagram receive traffic for the other protocol, same as before.

old datagram -> new muxed: doesn't work because the old sends proto 0 but the udp side of the mux registers with PROTO_DATAGRAM, so the datagrams go to the streaming side, same as before. old streaming -> new muxed: works

Typical Usage: Streaming + datagrams: I2PSocketManager sockMgr = getSocketManager(); I2PSession session = sockMgr.getSession(); session.addMuxedSessionListener(myI2PSessionMuxedListener, I2PSession.PROTO_DATAGRAM, I2PSession.PORT_ANY); or session.addSessionListener(myI2PSessionListener, I2PSession.PROTO_DATAGRAM, I2PSession.PORT_ANY); session.sendMessage(dest, payload, I2PSession.PROTO_DATAGRAM, fromPort, toPort);

Datagrams only, with multiple ports: I2PClient client = I2PClientFactory.createClient(I2PAppContext); ... I2PSession session = client.createSession(...); session.addMuxedSessionListener(myI2PSessionMuxedListener, I2PSession.PROTO_DATAGRAM, I2PSession.PORT_ANY); or session.addSessionListener(myI2PSessionListener, I2PSession.PROTO_DATAGRAM, I2PSession.PORT_ANY); session.sendMessage(dest, payload, I2PSession.PROTO_DATAGRAM, fromPort, toPort);

Multiple streaming ports: Needs some streaming lib hacking.

Nested Class Summary
Nested Classes
Modifier and Type
Class
Description
private static class
I2PSessionMuxedImpl.MsgData
Keep this simple.
protected class
I2PSessionMuxedImpl.MuxedAvailabilityNotifier
MuxedAvailabilityNotifier Extends AvailabilityNotifier.
Nested classes/interfaces inherited from class I2PSessionImpl
I2PSessionImpl.AvailabilityNotifier, I2PSessionImpl.State
Modifier and Type
Class
Description
protected class
I2PSessionImpl.AvailabilityNotifier
This notifies the client of payload messages.
protected static enum
I2PSessionImpl.State
Session state enumeration.
Nested classes/interfaces inherited from interface I2PSession
I2PSession.TunnelPair
Modifier and Type
Interface
Description
static class
I2PSession.TunnelPair
Simple holder for tunnel pair information.
Field Summary
Fields
Modifier and Type
Field
Description
private final I2PSessionDemultiplexer
_demultiplexer
The demultiplexer delivering the messages.
private static final int
FROMPORT_BYTES
Upper two bytes of MTIME in gzip header.
private static final int
PROTO_BYTE
OS byte in gzip header.
private static final int
TOPORT_BYTES
Lower two bytes of MTIME in gzip header.
Fields inherited from class I2PSessionImpl2
_noEffort, _sendingStates, _sendMessageNonce
Modifier and Type
Field
Description
protected boolean
_noEffort
Don't expect any MSMs from the router for outbound traffic.
protected final Map<Long, MessageState>
_sendingStates
One MessageState object per message in the process of being sent.
protected final AtomicLong
_sendMessageNonce
Source of the per-message replay nonces sent to the router.
Fields inherited from class I2PSessionImpl
_availabilityNotifier, _availableMessages, _bwLimits, _bwReceivedLock, _context, _handlerMap, _hostname, _leaseSet, _leaseSetWait, _log, _pendingLookups, _portNum, _producer, _queue, _reader, _sessionListener, _socket, _state, _stateLock, _transientSigningPublicKey, _tunnelStatusListeners, _writer, CACHE_MAX_SIZE, DUMMY_SESSION, LISTEN_PORT, PROP_DOMAIN_SOCKET
Modifier and Type
Field
Description
protected I2PSessionImpl.AvailabilityNotifier
_availabilityNotifier
Thread that we tell when new messages are available, who then tells us to fetch them.
protected Map<Long, MessagePayloadMessage>
_availableMessages
Map of Long--> MessagePayloadMessage.
protected int[]
_bwLimits
Current bandwidth limits.
protected final Object
_bwReceivedLock
Lock for bandwidth limit updates.
protected final I2PAppContext
_context
App context, kept separate so we can get rid of singletons.
protected final I2PClientMessageHandlerMap
_handlerMap
Handler map for I2CP message types.
protected final String
_hostname
Hostname of router - will be null if in RouterContext.
protected LeaseSet
_leaseSet
Currently granted lease set, or null.
protected final Object
_leaseSetWait
Monitor for waiting until a lease set has been granted.
protected final Log
_log
Logger for this session.
protected final LinkedBlockingQueue<I2PSessionImpl.LookupWaiter>
_pendingLookups
Hashes of lookups we are waiting for.
protected final int
_portNum
Port number of router - will be 0 if in RouterContext.
protected final I2CPMessageProducer
_producer
Class that generates new messages.
protected I2CPMessageQueue
_queue
Used for internal connections to the router.
protected I2CPMessageReader
_reader
Reader that always searches for messages.
protected I2PSessionListener
_sessionListener
Where session events are sent.
protected Socket
_socket
Socket for communication.
protected I2PSessionImpl.State
_state
Current session state.
protected final Object
_stateLock
Lock for state transitions.
protected SigningPublicKey
_transientSigningPublicKey
Transient signing public key for offline signatures.
protected final Set<TunnelStatusListener>
_tunnelStatusListeners
Listeners for tunnel status changes (tunnel failures and removals).
protected ClientWriterRunner
_writer
Writer message queue.
protected static final int
CACHE_MAX_SIZE
Maximum size of the lookup cache.
(package private) static final SessionId
DUMMY_SESSION
Dummy session ID for messages before a real session is established.
static final int
LISTEN_PORT
Default I2CP listen port.
protected static final String
PROP_DOMAIN_SOCKET
Use Unix domain socket (or similar) to connect to a router.
Fields inherited from interface I2PSession
PORT_ANY, PORT_UNSPECIFIED, PROTO_ANY, PROTO_DATAGRAM, PROTO_DATAGRAM_RAW, PROTO_DATAGRAM2, PROTO_DATAGRAM3, PROTO_STREAMING, PROTO_UNSPECIFIED
Modifier and Type
Field
Description
static final int
PORT_ANY
Any port.
static final int
PORT_UNSPECIFIED
Unspecified port.
static final int
PROTO_ANY
Any protocol.
static final int
PROTO_DATAGRAM
A repliable and signed datagram.
static final int
PROTO_DATAGRAM_RAW
A raw (unsigned, unrepliable) datagram.
static final int
PROTO_DATAGRAM2
A repliable and signed datagram.
static final int
PROTO_DATAGRAM3
A repliable but unsigned datagram.
static final int
PROTO_STREAMING
Streaming protocol.
static final int
PROTO_UNSPECIFIED
Unspecified protocol.
Constructor Summary
Constructors
Modifier
Constructor
Description
protected
I2PSessionMuxedImpl(I2PSessionImpl primary, InputStream destKeyStream, Properties options)
For extension by SubSession.
I2PSessionMuxedImpl(I2PAppContext ctx, InputStream destKeyStream, Properties options)
Create a new muxed session.
Method Summary
Modifier and Type
Method
Description
void
addMuxedSessionListener(I2PSessionMuxedListener l, int proto, int port)
Listen on specified protocol and port, and receive notification of proto, fromPort, and toPort for every message.
void
addNewMessage(MessagePayloadMessage msg)
Store a received payload message and notify the client that it is available, including the protocol and ports it arrived on.
void
addSessionListener(I2PSessionListener lsnr, int proto, int port)
Listen on specified protocol and port.
private static int
getByte(MessagePayloadMessage msg, int i)
Reads one payload byte of the message.
private static int
getFromPort(MessagePayloadMessage msg)
Non-muxed sets the MTIME bytes to 0.
private static int
getProto(MessagePayloadMessage msg)
Non-muxed sets the OS byte to 0xff.
private static int
getToPort(MessagePayloadMessage msg)
Non-muxed sets the MTIME bytes to 0.
private byte[]
prepPayload(byte[] payload, int offset, int size, int proto, int fromPort, int toPort, SendMessageOptions.GzipOption gzo)
Prepare the payload for sending.
void
removeListener(int proto, int port)
Remove the specified listener (only).
boolean
sendMessage(Destination dest, byte[] payload)
Send an I2CP message, with the protocol and ports unset.
boolean
sendMessage(Destination dest, byte[] payload, int proto, int fromport, int toport)
Send an I2CP message.
boolean
sendMessage(Destination dest, byte[] payload, int offset, int size, int proto, int fromPort, int toPort, SendMessageOptions options)
See SendMessageOptions for option details.
long
sendMessage(Destination dest, byte[] payload, int offset, int size, int proto, int fromPort, int toPort, SendMessageOptions options, SendMessageStatusListener listener)
Send a message and request an asynchronous notification of delivery status.
boolean
sendMessage(Destination dest, byte[] payload, int offset, int size, SessionKey keyUsed, Set<SessionTag> tagsSent, int proto, int fromport, int toport)
Send a message with session key and tags.
boolean
sendMessage(Destination dest, byte[] payload, int offset, int size, SessionKey keyUsed, Set<SessionTag> tagsSent, long expires)
Send a message with session key and tags.
boolean
sendMessage(Destination dest, byte[] payload, int offset, int size, SessionKey keyUsed, Set<SessionTag> tagsSent, long expires, int proto, int fromPort, int toPort)
Send a message with protocol and port information.
boolean
sendMessage(Destination dest, byte[] payload, int offset, int size, SessionKey keyUsed, Set<SessionTag> tagsSent, long expires, int proto, int fromPort, int toPort, int flags)
Send a message with protocol, port, and flags.
private void
sendNoEffort(Destination dest, byte[] payload, SendMessageOptions options)
Send a message without expecting a response.
private static void
setFromPort(byte[] payload, int p)
Sets the from port of the payload.
private static void
setProto(byte[] payload, int p)
Sets the protocol byte of the payload.
void
setSessionListener(I2PSessionListener lsnr)
Listen on all protocols and ports.
private static void
setToPort(byte[] payload, int p)
Sets the to port of the payload.
Methods inherited from class I2PSessionImpl2
addTunnelStatusListener, destroySession, getCurrentTunnelPair, getTimeout, notifyPoolShuttingDown, notifyTunnelFailed, notifyTunnelRemoved, rebuildTunnels, receiveMessage, receiveStatus, reconnect, removeTunnelStatusListener, sendBestEffort, sendBestEffort, sendMessage, sendMessage, sendMessage, sendNoEffort, setCurrentTunnelPair, shouldCompress, startVerifyUsage, switchToNewTunnel
Modifier and Type
Method
Description
void
addTunnelStatusListener(TunnelStatusListener lsnr)
Register a tunnel status listener.
void
destroySession(boolean sendDisconnect)
Destroy the I2P session, after clearing the message send states.
I2PSession.TunnelPair
getCurrentTunnelPair()
Return the current tunnel pair.
protected long
getTimeout()
Wait this long for the router to accept a sent message, in ms.
protected void
notifyPoolShuttingDown(String poolName, boolean isInbound)
Notify all tunnel status listeners of pool shutdown.
protected void
notifyTunnelFailed(String poolName, boolean isInbound)
Notify all tunnel status listeners of a tunnel failure.
protected void
notifyTunnelRemoved(TunnelRemovalEvent event)
Notify all tunnel status listeners of a tunnel removal.
void
rebuildTunnels()
Rebuild the tunnel set.
byte[]
receiveMessage(int msgId)
Receive a message from the router, decompressing it unless it was sent uncompressed.
void
receiveStatus(int msgId, long nonce, int status)
Only call this with nonzero status, i.e.
protected boolean
reconnect()
Reconnect the I2CP session.
void
removeTunnelStatusListener(TunnelStatusListener lsnr)
Remove a tunnel status listener.
protected boolean
sendBestEffort(Destination dest, byte[] payload, long expires, int flags)
Send a best-effort message with the given flags.
protected boolean
sendBestEffort(Destination dest, byte[] payload, SessionKey keyUsed, Set<SessionTag> tagsSent, long expires)
Send a message with best effort delivery.
boolean
sendMessage(Destination dest, byte[] payload, int offset, int size)
Send an I2CP message.
boolean
sendMessage(Destination dest, byte[] payload, int offset, int size, SessionKey keyUsed, Set<SessionTag> tagsSent)
Send a message with session key and tags.
boolean
sendMessage(Destination dest, byte[] payload, SessionKey keyUsed, Set<SessionTag> tagsSent)
Send a message with session key and tags.
protected boolean
sendNoEffort(Destination dest, byte[] payload, long expires, int flags)
Same as I2PSessionImpl2.sendBestEffort(Destination, byte[], SessionKey, Set, long), except we do not expect any MessageStatusMessage responses - not for accepted, or success, or failure.
void
setCurrentTunnelPair(I2PSession.TunnelPair pair)
Current tunnel pair in use.
protected boolean
shouldCompress(int size)
Return whether compression should be used.
protected void
startVerifyUsage()
Fire up a periodic task to check for unclaimed messages.
boolean
switchToNewTunnel()
Switch to the new tunnel set.
Methods inherited from class I2PSessionImpl
addSubsession, bandwidthLimits, bwReceived, changeState, clearCache, connect, dateUpdated, destLookupFailed, destLookupFailed, destReceived, destReceived, destroySession, discardMessage, disconnect, disconnected, getContext, getFastReceive, getHandlerMap, getLastLS2SignTime, getLeaseSet, getMyDestination, getName, getOfflineExpiration, getOfflineSignature, getOptions, getPrefix, getPrivateKey, getProducer, getRouterVersion, getSessionId, getSubsessions, getTransientSigningPublicKey, getTunnelBuildTimeout, isClosed, isOffline, lastActivity, lookupDest, lookupDest, lookupDest, lookupDest, lookupDest, lookupDest, lookupDest2, messageReceived, propagateError, readError, removeSubsession, reportAbuse, sendBlindingInfo, sendMessage, sendMessage_unchecked, setLastLS2SignTime, setLeaseSet, setReduced, setSessionId, shouldReconnect, supportsLS2, toString, updateActivity, updateOptions, verifyOpen, waitForDate
Modifier and Type
Method
Description
I2PSession
addSubsession(InputStream privateKeyStream, Properties opts)
Router must be connected or was connected...
int[]
bandwidthLimits()
Blocking.
(package private) void
bwReceived(int[] limits)
Called by the message handler.
protected void
changeState(I2PSessionImpl.State state)
Change the session state.
static void
clearCache()
Clear the lookup cache.
void
connect()
Connect to the router and establish a session.
(package private) void
dateUpdated(String routerVersion)
Update the router version and related feature support flags.
(package private) void
destLookupFailed(long nonce, int code)
Called by the message handler on reception of HostReplyMessage.
(package private) void
destLookupFailed(Hash h)
Called by the message handler on reception of DestReplyMessage.
(package private) void
destReceived(long nonce, Destination d)
Called by the message handler on reception of HostReplyMessage.
(package private) void
destReceived(Destination d)
Called by the message handler on reception of DestReplyMessage.
void
destroySession()
Tear down the session, and do NOT reconnect.
void
discardMessage(int msgId)
Throw away the received message, we don't want it.
protected void
disconnect()
Will interrupt a connect in progress.
void
disconnected(I2CPMessageReader reader)
The I2CPMessageEventListener callback.
(package private) I2PAppContext
getContext()
For Subsessions.
boolean
getFastReceive()
Does this session support fast receive?
(package private) I2PClientMessageHandlerMap
getHandlerMap()
For Subsessions.
(package private) long
getLastLS2SignTime()
The published timestamp of the last LS2 we signed.
LeaseSet
getLeaseSet()
Current lease set published by this session.
Destination
getMyDestination()
Retrieve the destination of the session.
protected String
getName()
Session name for logging.
long
getOfflineExpiration()
Java time (ms) or 0 if not initialized or does not have offline keys.
Signature
getOfflineSignature()
Null on error or if not initialized or does not have offline keys.
Properties
getOptions()
Retrieve the configuration options, filtered.
protected final String
getPrefix()
Try hard to make a decent identifier as this will appear in error logs.
SigningPrivateKey
getPrivateKey()
Retrieve the signing SigningPrivateKey.
(package private) I2CPMessageProducer
getProducer()
Retrieve the helper that generates I2CP messages.
String
getRouterVersion()
Always valid in RouterContext.
(package private) SessionId
getSessionId()
Retrieve the session's ID.
List<I2PSession>
getSubsessions()
List of subsessions, non-null, does not include the primary session.
SigningPublicKey
getTransientSigningPublicKey()
Null on error or if not initialized or does not have offline keys.
(package private) static int
getTunnelBuildTimeout(String sessionValue, String contextValue)
Parse the tunnel build timeout, shared with the instance method and tests.
boolean
isClosed()
Has the session been closed (or not yet connected)? False when open and during transitions.
boolean
isOffline()
Does this session have offline and transient keys?
long
lastActivity()
Time of last session activity in milliseconds.
Destination
lookupDest(String name)
Ask the router to lookup a Destination by host name.
Destination
lookupDest(String name, long maxWait)
Ask the router to lookup a Destination by host name.
LookupResult
lookupDest(String name, long maxWait, LookupCallback callback)
Lookup a Destination by hash.
Destination
lookupDest(Hash h)
Blocking.
Destination
lookupDest(Hash h, long maxWait)
Blocking.
LookupResult
lookupDest(Hash h, long maxWait, LookupCallback callback)
Lookup a Destination by hostname.
LookupResult
lookupDest2(String name, long maxWait)
Ask the router to lookup a Destination by host name.
void
messageReceived(I2CPMessageReader reader, I2CPMessage message)
The I2CPMessageEventListener callback.
(package private) void
propagateError(String msg, Throwable error)
Pass off the error to the listener Misspelled, oh well.
void
readError(I2CPMessageReader reader, Exception error)
The I2CPMessageEventListener callback.
void
removeSubsession(I2PSession session)
No-op, this session has no subsessions.
void
reportAbuse(int msgId, int severity)
Report abuse with regards to the given messageId.
void
sendBlindingInfo(BlindData bd)
Send blinding info to a peer.
(package private) void
sendMessage(I2CPMessage message)
Deliver an I2CP message to the router As of 0.9.3, may block for several seconds if the write queue to the router is full.
(package private) void
sendMessage_unchecked(I2CPMessage message)
Deliver an I2CP message to the router.
(package private) void
setLastLS2SignTime(long now)
The published timestamp of the last LS2 we signed.
(package private) void
setLeaseSet(LeaseSet ls)
Lease set published by this session.
void
setReduced()
Mark the session as reduced.
(package private) void
setSessionId(SessionId id)
Session ID assigned by the router.
protected boolean
shouldReconnect()
Whether the session should attempt reconnection on disconnect.
boolean
supportsLS2()
Does this session support LS2?
String
toString()

protected void
updateActivity()
Update the last activity timestamp.
void
updateOptions(Properties options)
Update the tunnel and bandwidth settings.
protected void
verifyOpen()
Throws I2PSessionException if uninitialized, closed or closing.
protected void
waitForDate()
Wait for a SetDate response from the router.
Methods inherited from class Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface I2PSession
getDecryptionKey
Modifier and Type
Method
Description
PrivateKey
getDecryptionKey()
Retrieve the decryption PrivateKey associated with the Destination.

Field Details
- _demultiplexer
  private final I2PSessionDemultiplexer _demultiplexer
  The demultiplexer delivering the messages.
- PROTO_BYTE
  private static final int PROTO_BYTE
  OS byte in gzip header.
  See Also:
  Constant Field Values
- FROMPORT_BYTES
  private static final int FROMPORT_BYTES
  Upper two bytes of MTIME in gzip header.
  See Also:
  Constant Field Values
- TOPORT_BYTES
  private static final int TOPORT_BYTES
  Lower two bytes of MTIME in gzip header.
  See Also:
  Constant Field Values
Constructor Details
- I2PSessionMuxedImpl
  public I2PSessionMuxedImpl(I2PAppContext ctx, InputStream destKeyStream, Properties options) throws I2PSessionException
  Create a new muxed session.
  Parameters:
  ctx - the application context whose router is to be used
  destKeyStream - stream containing the private key data, format is specified in PrivateKeyFile
  options - set of options to configure the router with, if null will use System properties
  Throws:
  I2PSessionException - if there is a problem loading the private keys
- I2PSessionMuxedImpl
  protected I2PSessionMuxedImpl(I2PSessionImpl primary, InputStream destKeyStream, Properties options) throws I2PSessionException
  For extension by SubSession.
  Parameters:
  primary - the SubSession this one multiplexes alongside, or null
  destKeyStream - stream containing the private key data, format is specified in PrivateKeyFile
  options - set of options to configure the router with, if null will use System properties
  Throws:
  I2PSessionException - if there is a problem loading the private keys
Method Details
- setSessionListener
  public void setSessionListener(I2PSessionListener lsnr)
  Listen on all protocols and ports.
  Specified by:
  setSessionListener in interface I2PSession
  Overrides:
  setSessionListener in class I2PSessionImpl
  Parameters:
  lsnr - listener to retrieve events
- addSessionListener
  public void addSessionListener(I2PSessionListener lsnr, int proto, int port)
  Listen on specified protocol and port.
  An existing listener with the same proto and port is replaced. Only the listener with the best match is called back for each message.
  Specified by:
  addSessionListener in interface I2PSession
  Overrides:
  addSessionListener in class I2PSessionImpl2
  Parameters:
  lsnr - the listener to add
  proto - 1-254 or PROTO_ANY (0) for all; recommended: I2PSession.PROTO_STREAMING I2PSession.PROTO_DATAGRAM 255 disallowed
  port - 1-65535 or PORT_ANY (0) for all
- addMuxedSessionListener
  public void addMuxedSessionListener(I2PSessionMuxedListener l, int proto, int port)
  Listen on specified protocol and port, and receive notification of proto, fromPort, and toPort for every message.
  Specified by:
  addMuxedSessionListener in interface I2PSession
  Overrides:
  addMuxedSessionListener in class I2PSessionImpl2
  Parameters:
  l - the listener to add
  proto - 1-254 or PROTO_ANY (0) for all; 255 disallowed
  port - 1-65535 or PORT_ANY (0) for all
- removeListener
  public void removeListener(int proto, int port)
  Remove the specified listener (only).
  Specified by:
  removeListener in interface I2PSession
  Overrides:
  removeListener in class I2PSessionImpl2
  Parameters:
  proto - the protocol the listener was added for
  port - the port the listener was added for
- sendMessage
  public boolean sendMessage(Destination dest, byte[] payload) throws I2PSessionException
  Send an I2CP message, with the protocol and ports unset.
  Specified by:
  sendMessage in interface I2PSession
  Overrides:
  sendMessage in class I2PSessionImpl2
  Parameters:
  dest - location to send the message
  payload - body of the message to be sent (unencrypted)
  Returns:
  true if the router accepted the message, false if it was refused
  Throws:
  I2PSessionException - if the session is not open or closed, or the write queue stays full
- sendMessage
  public boolean sendMessage(Destination dest, byte[] payload, int proto, int fromport, int toport) throws I2PSessionException
  Send an I2CP message.
  Specified by:
  sendMessage in interface I2PSession
  Overrides:
  sendMessage in class I2PSessionImpl2
  Parameters:
  dest - location to send the message
  payload - body of the message to be sent (unencrypted)
  proto - 1-254, or 0 for unset; 255 disallowed
  fromport - source port, 1-65535 or 0 for unset
  toport - destination port, 1-65535 or 0 for unset
  Returns:
  true if the router accepted the message, false if it was refused
  Throws:
  I2PSessionException - if the session is not open or closed, or the write queue stays full
- sendMessage
  public boolean sendMessage(Destination dest, byte[] payload, int offset, int size, SessionKey keyUsed, Set<SessionTag> tagsSent, long expires) throws I2PSessionException
  Send a message with session key and tags.
  Specified by:
  sendMessage in interface I2PSession
  Overrides:
  sendMessage in class I2PSessionImpl2
  Parameters:
  dest - location to send the message
  payload - body of the message to be sent (unencrypted)
  offset - offset into the payload
  size - number of bytes to send
  keyUsed - unused - no end-to-end crypto
  tagsSent - unused - no end-to-end crypto
  expires - absolute expiration timestamp, NOT interval from now
  Returns:
  true unless the router reported a failed send status
  Throws:
  I2PSessionException - if the session is not open or closed, or the write queue stays full
- sendMessage
  public boolean sendMessage(Destination dest, byte[] payload, int offset, int size, SessionKey keyUsed, Set<SessionTag> tagsSent, int proto, int fromport, int toport) throws I2PSessionException
  Send a message with session key and tags.
  Specified by:
  sendMessage in interface I2PSession
  Overrides:
  sendMessage in class I2PSessionImpl2
  Parameters:
  dest - location to send the message
  payload - body of the message to be sent (unencrypted)
  offset - offset into the payload
  size - number of bytes to send
  keyUsed - unused - no end-to-end crypto
  tagsSent - unused - no end-to-end crypto
  proto - 1-254 or 0 for unset; recommended: I2PSession.PROTO_UNSPECIFIED I2PSession.PROTO_STREAMING I2PSession.PROTO_DATAGRAM 255 disallowed
  fromport - 1-65535 or 0 for unset
  toport - 1-65535 or 0 for unset
  Returns:
  true unless the router reported a failed send status
  Throws:
  I2PSessionException - if the session is not open or closed, or the write queue stays full
- sendMessage
  public boolean sendMessage(Destination dest, byte[] payload, int offset, int size, SessionKey keyUsed, Set<SessionTag> tagsSent, long expires, int proto, int fromPort, int toPort) throws I2PSessionException
  Send a message with protocol and port information.
  Specified by:
  sendMessage in interface I2PSession
  Overrides:
  sendMessage in class I2PSessionImpl2
  Parameters:
  dest - location to send the message
  payload - body of the message to be sent (unencrypted)
  offset - offset into the payload
  size - number of bytes to send
  keyUsed - unused - no end-to-end crypto
  tagsSent - unused - no end-to-end crypto
  expires - absolute expiration timestamp, NOT interval from now
  proto - 1-254 or 0 for unset; recommended: I2PSession.PROTO_UNSPECIFIED I2PSession.PROTO_STREAMING I2PSession.PROTO_DATAGRAM 255 disallowed
  fromPort - 1-65535 or 0 for unset
  toPort - 1-65535 or 0 for unset
  Returns:
  true unless the router reported a failed send status
  Throws:
  I2PSessionException - if the session is not open or closed, or the write queue stays full
- sendMessage
  public boolean sendMessage(Destination dest, byte[] payload, int offset, int size, SessionKey keyUsed, Set<SessionTag> tagsSent, long expires, int proto, int fromPort, int toPort, int flags) throws I2PSessionException
  Send a message with protocol, port, and flags.
  Specified by:
  sendMessage in interface I2PSession
  Overrides:
  sendMessage in class I2PSessionImpl2
  Parameters:
  dest - location to send the message
  payload - body of the message to be sent (unencrypted)
  offset - offset into the payload
  size - number of bytes to send
  keyUsed - unused - no end-to-end crypto
  tagsSent - unused - no end-to-end crypto
  expires - absolute expiration timestamp, NOT interval from now
  proto - 1-254 or 0 for unset; recommended: I2PSession.PROTO_UNSPECIFIED I2PSession.PROTO_STREAMING I2PSession.PROTO_DATAGRAM 255 disallowed
  fromPort - 1-65535 or 0 for unset
  toPort - 1-65535 or 0 for unset
  flags - to be passed to the router
  Returns:
  true unless the router reported a failed send status
  Throws:
  I2PSessionException - if the session is not open or closed, or the write queue stays full
- sendMessage
  public boolean sendMessage(Destination dest, byte[] payload, int offset, int size, int proto, int fromPort, int toPort, SendMessageOptions options) throws I2PSessionException
  See SendMessageOptions for option details.
  Always uses sendNoEffort for now.
  Specified by:
  sendMessage in interface I2PSession
  Overrides:
  sendMessage in class I2PSessionImpl2
  Parameters:
  dest - location to send the message
  payload - body of the message to be sent (unencrypted)
  offset - offset into the payload
  size - number of bytes to send
  proto - 1-254 or 0 for unset; recommended: I2PSession.PROTO_UNSPECIFIED I2PSession.PROTO_STREAMING I2PSession.PROTO_DATAGRAM 255 disallowed
  fromPort - 1-65535 or 0 for unset
  toPort - 1-65535 or 0 for unset
  options - to be passed to the router
  Returns:
  true always
  Throws:
  I2PSessionException - if the session is not open or closed, or the write queue stays full
- sendMessage
  public long sendMessage(Destination dest, byte[] payload, int offset, int size, int proto, int fromPort, int toPort, SendMessageOptions options, SendMessageStatusListener listener) throws I2PSessionException
  Send a message and request an asynchronous notification of delivery status.
  See I2PSessionMuxedImpl for proto/port details. See SendMessageOptions for option details.
  Specified by:
  sendMessage in interface I2PSession
  Overrides:
  sendMessage in class I2PSessionImpl2
  Parameters:
  dest - location to send the message
  payload - body of the message to be sent (unencrypted)
  offset - offset into the payload
  size - number of bytes to send
  proto - 1-254 or 0 for unset; recommended: I2PSession.PROTO_UNSPECIFIED I2PSession.PROTO_STREAMING I2PSession.PROTO_DATAGRAM 255 disallowed
  fromPort - 1-65535 or 0 for unset
  toPort - 1-65535 or 0 for unset
  options - to be passed to the router
  listener - for delivery status notification
  Returns:
  the message ID to be used for later notification to the listener
  Throws:
  I2PSessionException - on all errors
- prepPayload
  private byte[] prepPayload(byte[] payload, int offset, int size, int proto, int fromPort, int toPort, SendMessageOptions.GzipOption gzo) throws I2PSessionException
  Prepare the payload for sending.
  Parameters:
  payload - the message data to wrap
  offset - start of the message data within payload
  size - number of message bytes to take from offset
  proto - protocol written to the gzip OS byte, 1-254 or 0 for unset
  fromPort - source port written to the MTIME field, 1-65535 or 0 for unset
  toPort - destination port written to the MTIME field, 1-65535 or 0 for unset
  gzo - gzip selection; DEFAULT compresses by size heuristic, GZIP_ON forces compression
  Returns:
  gzip compressed payload, ready to send
  Throws:
  I2PSessionException - if the session is not open
- sendNoEffort
  private void sendNoEffort(Destination dest, byte[] payload, SendMessageOptions options) throws I2PSessionException
  Send a message without expecting a response.
  Parameters:
  dest - the destination to deliver the message to
  payload - the already-prepared message data
  options - delivery options, expiration and flags applied to the message
  Throws:
  I2PSessionException - if the message cannot be queued to the router, e.g. the write queue is full or the session closed
- addNewMessage
  public void addNewMessage(MessagePayloadMessage msg)
  Store a received payload message and notify the client that it is available, including the protocol and ports it arrived on.
  Overrides:
  addNewMessage in class I2PSessionImpl
  Parameters:
  msg - the received payload, whose data must be at least 10 bytes for the gzip header
- getProto
  private static int getProto(MessagePayloadMessage msg)
  Non-muxed sets the OS byte to 0xff.
  Parameters:
  msg - the received payload message to read the header from
  Returns:
  the protocol 0-254, or PROTO_UNSPECIFIED when the OS byte is 0xff
- getFromPort
  private static int getFromPort(MessagePayloadMessage msg)
  Non-muxed sets the MTIME bytes to 0.
  Parameters:
  msg - the received payload message to read the header from
  Returns:
  the source port 0-65535 from the upper two MTIME bytes, 0 if unset
- getToPort
  private static int getToPort(MessagePayloadMessage msg)
  Non-muxed sets the MTIME bytes to 0.
  Parameters:
  msg - the received payload message to read the header from
  Returns:
  the destination port 0-65535 from the lower two MTIME bytes, 0 if unset
- getByte
  private static int getByte(MessagePayloadMessage msg, int i)
  Reads one payload byte of the message.
  Parameters:
  msg - the message to read
  i - the index of the byte
  Returns:
  the payload byte
- setProto
  private static void setProto(byte[] payload, int p)
  Sets the protocol byte of the payload.
  Parameters:
  payload - the payload to change
  p - the protocol to set
- setFromPort
  private static void setFromPort(byte[] payload, int p)
  Sets the from port of the payload.
  Parameters:
  payload - the payload to change
  p - the port to set
- setToPort
  private static void setToPort(byte[] payload, int p)
  Sets the to port of the payload.
  Parameters:
  payload - the payload to change
  p - the port to set

Nested Class Summary

Nested classes/interfaces inherited from class I2PSessionImpl

Nested classes/interfaces inherited from interface I2PSession

Field Summary

Fields inherited from class I2PSessionImpl2

Fields inherited from class I2PSessionImpl

Fields inherited from interface I2PSession

Constructor Summary

Method Summary

Methods inherited from class I2PSessionImpl2

Methods inherited from class I2PSessionImpl

Methods inherited from class Object

Methods inherited from interface I2PSession

Field Details

_demultiplexer

PROTO_BYTE

FROMPORT_BYTES

TOPORT_BYTES

Constructor Details

I2PSessionMuxedImpl

Method Details

setSessionListener

addSessionListener

addMuxedSessionListener

removeListener

sendMessage

sendMessage

sendMessage

sendMessage

sendMessage

sendMessage

sendMessage

sendMessage

prepPayload

sendNoEffort

addNewMessage

getProto

getFromPort

getToPort

getByte

setProto

setFromPort

setToPort