I2PSession, I2CPMessageReader.I2CPMessageEventListenerSubSessionclass I2PSessionMuxedImpl extends I2PSessionImpl2
| Modifier and Type | Class | Description |
|---|---|---|
protected class |
I2PSessionMuxedImpl.MuxedAvailabilityNotifier |
I2PSessionImpl.AvailabilityNotifier, I2PSessionImpl.StatePORT_ANY, PORT_UNSPECIFIED, PROTO_ANY, PROTO_DATAGRAM, PROTO_DATAGRAM_RAW, PROTO_STREAMING, PROTO_UNSPECIFIED_availabilityNotifier, _availableMessages, _bwLimits, _bwReceivedLock, _context, _handlerMap, _hostname, _leaseSet, _leaseSetWait, _log, _pendingLookups, _portNum, _producer, _queue, _reader, _sessionListener, _socket, _state, _stateLock, _writer, CACHE_MAX_SIZE, LISTEN_PORT, PROP_DOMAIN_SOCKET, PROP_ENABLE_SSL, PROP_PW, PROP_USER_noEffort, _sendingStates, _sendMessageNonce| Modifier | Constructor | Description |
|---|---|---|
protected |
I2PSessionMuxedImpl(I2PSessionImpl primary,
InputStream destKeyStream,
Properties options) |
|
|
I2PSessionMuxedImpl(I2PAppContext ctx,
InputStream destKeyStream,
Properties options) |
| 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) |
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
|
addSubsession, bandwidthLimits, bwReceived, changeState, clearCache, connect, dateUpdated, destLookupFailed, destLookupFailed, destReceived, destReceived, destroySession, disconnect, disconnected, getContext, getDecryptionKey, getFastReceive, getHandlerMap, getLeaseSet, getMyDestination, getOptions, getPrefix, getPrivateKey, getProducer, getSessionId, getSubsessions, isClosed, lastActivity, lookupDest, lookupDest, lookupDest, lookupDest, messageReceived, propogateError, readError, removeSubsession, reportAbuse, sendMessage, sendMessage_unchecked, setLeaseSet, setReduced, setSessionId, shouldReconnect, toString, updateActivity, updateOptions, verifyOpen, waitForDatedestroySession, getTimeout, receiveMessage, receiveStatus, reconnect, sendBestEffort, sendBestEffort, sendMessage, sendMessage, sendMessage, sendNoEffort, shouldCompress, startVerifyUsagepublic 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