|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.i2p.router.transport.TransportManager
public class TransportManager
Field Summary | |
---|---|
static java.lang.String |
DEFAULT_ENABLE_NTCP
|
static java.lang.String |
DEFAULT_ENABLE_UDP
|
static java.lang.String |
PROP_ENABLE_NTCP
|
static java.lang.String |
PROP_ENABLE_UDP
|
static java.lang.String |
PROP_ENABLE_UPNP
default true |
Constructor Summary | |
---|---|
TransportManager(RouterContext context)
|
Method Summary | |
---|---|
void |
addTransport(Transport transport)
|
int |
countActivePeers()
|
int |
countActiveSendPeers()
|
static boolean |
enableNTCP(RouterContext ctx)
|
void |
externalAddressReceived(java.lang.String source,
byte[] ip,
int port)
callback from UPnP Only tell SSU, it will tell NTCP |
void |
forwardPortStatus(java.lang.String style,
int port,
boolean success,
java.lang.String reason)
callback from UPnP |
java.util.Map<java.lang.String,RouterAddress> |
getAddresses()
|
TransportBid |
getBid(OutNetMessage msg)
|
java.util.List |
getBids(OutNetMessage msg)
|
java.util.Vector |
getClockSkews()
Return our peer clock skews on all transports. |
byte[] |
getIP(Hash dest)
IP of the peer from the last connection (in or out, any transport). |
java.util.List |
getMostRecentErrorMessages()
|
TransportBid |
getNextBid(OutNetMessage msg)
|
short |
getReachabilityStatus()
|
Transport |
getTransport(java.lang.String style)
|
(package private) int |
getTransportCount()
|
boolean |
haveHighOutboundCapacity()
Are all transports well below their outbound connection limit Use for throttling in the router. |
boolean |
haveInboundCapacity(int pct)
Is at least one transport below its inbound connection limit + some margin Use for throttling in the router. |
boolean |
haveOutboundCapacity(int pct)
Is at least one transport below its outbound connection limit + some margin Use for throttling in the router. |
boolean |
isBacklogged(Hash dest)
|
boolean |
isEstablished(Hash dest)
|
void |
messageReceived(I2NPMessage message,
RouterIdentity fromRouter,
Hash fromRouterHash)
|
void |
recheckReachability()
|
void |
removeTransport(Transport transport)
|
void |
renderStatusHTML(java.io.Writer out,
java.lang.String urlBase,
int sortFlags)
|
void |
restart()
|
void |
startListening()
|
void |
stopListening()
|
void |
transportAddressChanged()
|
boolean |
wasUnreachable(Hash dest)
Was the peer UNreachable (outbound only) on any transport, based on the last time we tried it for each transport? This is NOT reset if the peer contacts us. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final java.lang.String PROP_ENABLE_UDP
public static final java.lang.String PROP_ENABLE_NTCP
public static final java.lang.String DEFAULT_ENABLE_NTCP
public static final java.lang.String DEFAULT_ENABLE_UDP
public static final java.lang.String PROP_ENABLE_UPNP
Constructor Detail |
---|
public TransportManager(RouterContext context)
Method Detail |
---|
public void addTransport(Transport transport)
public void removeTransport(Transport transport)
public static boolean enableNTCP(RouterContext ctx)
public void externalAddressReceived(java.lang.String source, byte[] ip, int port)
public void forwardPortStatus(java.lang.String style, int port, boolean success, java.lang.String reason)
public void startListening()
public void restart()
public void stopListening()
public Transport getTransport(java.lang.String style)
int getTransportCount()
public int countActivePeers()
public int countActiveSendPeers()
public boolean haveOutboundCapacity(int pct)
pct
- percent of limit 0-100public boolean haveHighOutboundCapacity()
public boolean haveInboundCapacity(int pct)
pct
- percent of limit 0-100public java.util.Vector getClockSkews()
public short getReachabilityStatus()
public void recheckReachability()
public boolean isBacklogged(Hash dest)
public boolean isEstablished(Hash dest)
public boolean wasUnreachable(Hash dest)
public byte[] getIP(Hash dest)
public java.util.Map<java.lang.String,RouterAddress> getAddresses()
public TransportBid getBid(OutNetMessage msg)
public java.util.List getBids(OutNetMessage msg)
public TransportBid getNextBid(OutNetMessage msg)
public void messageReceived(I2NPMessage message, RouterIdentity fromRouter, Hash fromRouterHash)
messageReceived
in interface TransportEventListener
public void transportAddressChanged()
transportAddressChanged
in interface TransportEventListener
public java.util.List getMostRecentErrorMessages()
public void renderStatusHTML(java.io.Writer out, java.lang.String urlBase, int sortFlags) throws java.io.IOException
java.io.IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |