class I2PSessionMuxedImpl extends I2PSessionImpl2
| Modifier and Type | Class and Description |
|---|---|
protected class |
I2PSessionMuxedImpl.MuxedAvailabilityNotifier |
I2PSessionImpl.AvailabilityNotifier, I2PSessionImpl.State_noEffort, _sendingStates, _sendMessageNonce_availabilityNotifier, _availableMessages, _bwLimits, _bwReceivedLock, _context, _handlerMap, _hostname, _leaseSet, _leaseSetWait, _log, _pendingLookups, _portNum, _producer, _queue, _reader, _sessionListener, _socket, _state, _stateLock, _transientSigningPublicKey, _writer, CACHE_MAX_SIZE, LISTEN_PORT, PROP_DOMAIN_SOCKET, PROP_ENABLE_SSL, PROP_PW, PROP_USERPORT_ANY, PORT_UNSPECIFIED, PROTO_ANY, PROTO_DATAGRAM, PROTO_DATAGRAM_RAW, PROTO_STREAMING, PROTO_UNSPECIFIED| Modifier | Constructor and Description |
|---|---|
|
I2PSessionMuxedImpl(I2PAppContext ctx,
InputStream destKeyStream,
Properties options) |
protected |
I2PSessionMuxedImpl(I2PSessionImpl primary,
InputStream destKeyStream,
Properties options) |
| Modifier and Type | Method and 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)
Receive a payload message and let the app know its available
|
void |
addSessionListener(I2PSessionListener lsnr,
int proto,
int port)
Listen on specified protocol and port.
|
void |
removeListener(int proto,
int port)
removes the specified listener (only)
|
boolean |
sendMessage(Destination dest,
byte[] payload)
unused, see MuxedImpl override
|
boolean |
sendMessage(Destination dest,
byte[] payload,
int proto,
int fromport,
int toport)
See I2PSessionMuxedImpl for proto/port details.
|
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)
See I2PSessionMuxedImpl for proto/port details.
|
boolean |
sendMessage(Destination dest,
byte[] payload,
int offset,
int size,
SessionKey keyUsed,
Set<SessionTag> tagsSent,
long expires)
Unused? see MuxedImpl override
|
boolean |
sendMessage(Destination dest,
byte[] payload,
int offset,
int size,
SessionKey keyUsed,
Set<SessionTag> tagsSent,
long expires,
int proto,
int fromPort,
int toPort)
See I2PSessionMuxedImpl for proto/port details.
|
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)
See I2PSessionMuxedImpl for proto/port details.
|
void |
setSessionListener(I2PSessionListener lsnr)
listen on all protocols and ports
|
destroySession, getTimeout, receiveMessage, receiveStatus, reconnect, sendBestEffort, sendBestEffort, sendMessage, sendMessage, sendMessage, sendNoEffort, shouldCompress, startVerifyUsageaddSubsession, bandwidthLimits, bwReceived, changeState, clearCache, connect, dateUpdated, destLookupFailed, destLookupFailed, destReceived, destReceived, destroySession, disconnect, disconnected, getContext, getDecryptionKey, getFastReceive, getHandlerMap, getLeaseSet, getMyDestination, getOfflineExpiration, getOfflineSignature, getOptions, getPrefix, getPrivateKey, getProducer, getSessionId, getSubsessions, getTransientSigningPublicKey, isClosed, isOffline, lastActivity, lookupDest, lookupDest, lookupDest, lookupDest, messageReceived, propogateError, readError, removeSubsession, reportAbuse, sendMessage_unchecked, sendMessage, setLeaseSet, setReduced, setSessionId, shouldReconnect, supportsLS2, toString, updateActivity, updateOptions, verifyOpen, waitForDatepublic I2PSessionMuxedImpl(I2PAppContext ctx, InputStream destKeyStream, Properties options) throws I2PSessionException
I2PSessionExceptionprotected I2PSessionMuxedImpl(I2PSessionImpl primary, InputStream destKeyStream, Properties options) throws I2PSessionException
I2PSessionExceptionpublic void setSessionListener(I2PSessionListener lsnr)
setSessionListener in interface I2PSessionsetSessionListener in class I2PSessionImpllsnr - listener to retrieve eventspublic void addSessionListener(I2PSessionListener lsnr, int proto, int port)
addSessionListener in interface I2PSessionaddSessionListener in class I2PSessionImpl2proto - 1-254 or PROTO_ANY (0) for all; recommended:
I2PSession.PROTO_STREAMING
I2PSession.PROTO_DATAGRAM
255 disallowedport - 1-65535 or PORT_ANY (0) for allpublic void addMuxedSessionListener(I2PSessionMuxedListener l, int proto, int port)
addMuxedSessionListener in interface I2PSessionaddMuxedSessionListener in class I2PSessionImpl2proto - 1-254 or PROTO_ANY (0) for all; 255 disallowedport - 1-65535 or PORT_ANY (0) for allpublic void removeListener(int proto,
int port)
removeListener in interface I2PSessionremoveListener in class I2PSessionImpl2public boolean sendMessage(Destination dest, byte[] payload) throws I2PSessionException
I2PSessionImpl2sendMessage in interface I2PSessionsendMessage in class I2PSessionImpl2dest - location to send the messagepayload - body of the message to be sent (unencrypted)I2PSessionExceptionpublic boolean sendMessage(Destination dest, byte[] payload, int proto, int fromport, int toport) throws I2PSessionException
I2PSessionsendMessage in interface I2PSessionsendMessage in class I2PSessionImpl2I2PSessionExceptionpublic boolean sendMessage(Destination dest, byte[] payload, int offset, int size, SessionKey keyUsed, Set<SessionTag> tagsSent, long expires) throws I2PSessionException
I2PSessionImpl2sendMessage in interface I2PSessionsendMessage in class I2PSessionImpl2keyUsed - unused - no end-to-end cryptotagsSent - unused - no end-to-end cryptoexpires - absolute expiration timestamp, NOT interval from nowI2PSessionExceptionpublic boolean sendMessage(Destination dest, byte[] payload, int offset, int size, SessionKey keyUsed, Set<SessionTag> tagsSent, int proto, int fromport, int toport) throws I2PSessionException
I2PSessionsendMessage in interface I2PSessionsendMessage in class I2PSessionImpl2keyUsed - unused - no end-to-end cryptotagsSent - unused - no end-to-end cryptoproto - 1-254 or 0 for unset; recommended:
I2PSession.PROTO_UNSPECIFIED
I2PSession.PROTO_STREAMING
I2PSession.PROTO_DATAGRAM
255 disallowedfromport - 1-65535 or 0 for unsettoport - 1-65535 or 0 for unsetI2PSessionExceptionpublic 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
I2PSessionsendMessage in interface I2PSessionsendMessage in class I2PSessionImpl2keyUsed - unused - no end-to-end cryptotagsSent - unused - no end-to-end cryptoproto - 1-254 or 0 for unset; recommended:
I2PSession.PROTO_UNSPECIFIED
I2PSession.PROTO_STREAMING
I2PSession.PROTO_DATAGRAM
255 disallowedfromPort - 1-65535 or 0 for unsettoPort - 1-65535 or 0 for unsetexpires - absolute expiration timestamp, NOT interval from nowI2PSessionExceptionpublic 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
I2PSessionsendMessage in interface I2PSessionsendMessage in class I2PSessionImpl2keyUsed - unused - no end-to-end cryptotagsSent - unused - no end-to-end cryptoproto - 1-254 or 0 for unset; recommended:
I2PSession.PROTO_UNSPECIFIED
I2PSession.PROTO_STREAMING
I2PSession.PROTO_DATAGRAM
255 disallowedfromPort - 1-65535 or 0 for unsettoPort - 1-65535 or 0 for unsetflags - to be passed to the routerexpires - absolute expiration timestamp, NOT interval from nowI2PSessionExceptionpublic boolean sendMessage(Destination dest, byte[] payload, int offset, int size, int proto, int fromPort, int toPort, SendMessageOptions options) throws I2PSessionException
sendMessage in interface I2PSessionsendMessage in class I2PSessionImpl2proto - 1-254 or 0 for unset; recommended:
I2PSession.PROTO_UNSPECIFIED
I2PSession.PROTO_STREAMING
I2PSession.PROTO_DATAGRAM
255 disallowedfromPort - 1-65535 or 0 for unsettoPort - 1-65535 or 0 for unsetoptions - to be passed to the routerI2PSessionExceptionpublic long sendMessage(Destination dest, byte[] payload, int offset, int size, int proto, int fromPort, int toPort, SendMessageOptions options, SendMessageStatusListener listener) throws I2PSessionException
sendMessage in interface I2PSessionsendMessage in class I2PSessionImpl2proto - 1-254 or 0 for unset; recommended:
I2PSession.PROTO_UNSPECIFIED
I2PSession.PROTO_STREAMING
I2PSession.PROTO_DATAGRAM
255 disallowedfromPort - 1-65535 or 0 for unsettoPort - 1-65535 or 0 for unsetoptions - to be passed to the routerI2PSessionException - on all errorspublic void addNewMessage(MessagePayloadMessage msg)
addNewMessage in class I2PSessionImpl