|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.i2p.client.streaming.ConnectionManager
class ConnectionManager
Coordinate all of the connections for a single local destination.
Nested Class Summary | |
---|---|
static interface |
ConnectionManager.PingNotifier
|
Field Summary | |
---|---|
static String |
PROP_BLACKLIST
|
Constructor Summary | |
---|---|
ConnectionManager(I2PAppContext context,
I2PSession session,
ConnectionOptions defaultOptions)
Manage all conns for this session |
Method Summary | |
---|---|
boolean |
answerPings()
do we respond to pings that aren't on an existing connection? |
Connection |
connect(Destination peer,
ConnectionOptions opts)
Build a new connection to the given peer. |
void |
disconnectAllHard()
Something b0rked hard, so kill all of our connections without mercy. |
boolean |
getAllowIncomingConnections()
|
(package private) Connection |
getConnectionByInboundId(long id)
|
(package private) Connection |
getConnectionByOutboundId(long id)
not guaranteed to be unique, but in case we receive more than one packet on an inbound connection that we havent ack'ed yet... |
ConnectionHandler |
getConnectionHandler()
|
MessageHandler |
getMessageHandler()
|
PacketHandler |
getPacketHandler()
|
PacketQueue |
getPacketQueue()
|
I2PSession |
getSession()
|
long |
getSoTimeout()
Get the socket accept() timeout. |
Set<Connection> |
listConnections()
return a set of Connection objects |
boolean |
ping(Destination peer,
long timeoutMs)
blocking |
boolean |
ping(Destination peer,
long timeoutMs,
boolean blocking)
|
boolean |
ping(Destination peer,
long timeoutMs,
boolean blocking,
ConnectionManager.PingNotifier notifier)
|
boolean |
ping(Destination peer,
long timeoutMs,
boolean blocking,
SessionKey keyToUse,
Set tagsToSend,
ConnectionManager.PingNotifier notifier)
Deprecated. I2PSession ignores tags, use non-tag variant |
Connection |
receiveConnection(Packet synPacket)
Create a new connection based on the SYN packet we received. |
(package private) void |
receivePong(long pingId)
|
void |
removeConnection(Connection con)
Drop the (already closed) connection on the floor. |
void |
setAllowIncomingConnections(boolean allow)
|
void |
setSoTimeout(long x)
Set the socket accept() timeout. |
void |
updateOptions()
|
void |
updateOptsFromShare(Connection con)
|
void |
updateShareOpts(Connection con)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String PROP_BLACKLIST
Constructor Detail |
---|
public ConnectionManager(I2PAppContext context, I2PSession session, ConnectionOptions defaultOptions)
Method Detail |
---|
Connection getConnectionByInboundId(long id)
Connection getConnectionByOutboundId(long id)
public void setSoTimeout(long x)
x
- public long getSoTimeout()
public void setAllowIncomingConnections(boolean allow)
public void updateOptions()
public boolean getAllowIncomingConnections()
public Connection receiveConnection(Packet synPacket)
synPacket
- SYN packet to process
public Connection connect(Destination peer, ConnectionOptions opts)
peer
- Destination to contactopts
- Connection's options
public MessageHandler getMessageHandler()
public PacketHandler getPacketHandler()
public I2PSession getSession()
public void updateOptsFromShare(Connection con)
public void updateShareOpts(Connection con)
public ConnectionHandler getConnectionHandler()
public PacketQueue getPacketQueue()
public boolean answerPings()
public void disconnectAllHard()
public void removeConnection(Connection con)
con
- Connection to drop.public Set<Connection> listConnections()
public boolean ping(Destination peer, long timeoutMs)
public boolean ping(Destination peer, long timeoutMs, boolean blocking)
public boolean ping(Destination peer, long timeoutMs, boolean blocking, SessionKey keyToUse, Set tagsToSend, ConnectionManager.PingNotifier notifier)
keyToUse
- ignoredtagsToSend
- ignoredpublic boolean ping(Destination peer, long timeoutMs, boolean blocking, ConnectionManager.PingNotifier notifier)
void receivePong(long pingId)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |