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_USER
PORT_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, startVerifyUsage
addSubsession, 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, waitForDate
public I2PSessionMuxedImpl(I2PAppContext ctx, InputStream destKeyStream, Properties options) throws I2PSessionException
I2PSessionException
protected I2PSessionMuxedImpl(I2PSessionImpl primary, InputStream destKeyStream, Properties options) throws I2PSessionException
I2PSessionException
public void setSessionListener(I2PSessionListener lsnr)
setSessionListener
in interface I2PSession
setSessionListener
in class I2PSessionImpl
lsnr
- listener to retrieve eventspublic void addSessionListener(I2PSessionListener lsnr, int proto, int port)
addSessionListener
in interface I2PSession
addSessionListener
in class I2PSessionImpl2
proto
- 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 I2PSession
addMuxedSessionListener
in class I2PSessionImpl2
proto
- 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 I2PSession
removeListener
in class I2PSessionImpl2
public boolean sendMessage(Destination dest, byte[] payload) throws I2PSessionException
I2PSessionImpl2
sendMessage
in interface I2PSession
sendMessage
in class I2PSessionImpl2
dest
- location to send the messagepayload
- body of the message to be sent (unencrypted)I2PSessionException
public boolean sendMessage(Destination dest, byte[] payload, int proto, int fromport, int toport) throws I2PSessionException
I2PSession
sendMessage
in interface I2PSession
sendMessage
in class I2PSessionImpl2
I2PSessionException
public boolean sendMessage(Destination dest, byte[] payload, int offset, int size, SessionKey keyUsed, Set<SessionTag> tagsSent, long expires) throws I2PSessionException
I2PSessionImpl2
sendMessage
in interface I2PSession
sendMessage
in class I2PSessionImpl2
keyUsed
- unused - no end-to-end cryptotagsSent
- unused - no end-to-end cryptoexpires
- absolute expiration timestamp, NOT interval from nowI2PSessionException
public boolean sendMessage(Destination dest, byte[] payload, int offset, int size, SessionKey keyUsed, Set<SessionTag> tagsSent, int proto, int fromport, int toport) throws I2PSessionException
I2PSession
sendMessage
in interface I2PSession
sendMessage
in class I2PSessionImpl2
keyUsed
- 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 unsetI2PSessionException
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
I2PSession
sendMessage
in interface I2PSession
sendMessage
in class I2PSessionImpl2
keyUsed
- 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 nowI2PSessionException
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
I2PSession
sendMessage
in interface I2PSession
sendMessage
in class I2PSessionImpl2
keyUsed
- 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 nowI2PSessionException
public boolean sendMessage(Destination dest, byte[] payload, int offset, int size, int proto, int fromPort, int toPort, SendMessageOptions options) throws I2PSessionException
sendMessage
in interface I2PSession
sendMessage
in class I2PSessionImpl2
proto
- 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
public 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 I2PSession
sendMessage
in class I2PSessionImpl2
proto
- 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