TransportEventListener
public class TransportManager extends java.lang.Object implements TransportEventListener
修飾子とタイプ | クラス | 説明 |
---|---|---|
(package private) static class |
TransportManager.Port |
修飾子とタイプ | フィールド | 説明 |
---|---|---|
static java.lang.String |
PROP_ENABLE_NTCP |
default true
|
static java.lang.String |
PROP_ENABLE_UDP |
default true
|
static java.lang.String |
PROP_ENABLE_UPNP |
default true
|
コンストラクタ | 説明 |
---|---|
TransportManager(RouterContext context) |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
int |
countActivePeers() |
How many peers are we currently connected to, that we have
sent a message to or received a message from in the last five minutes.
|
int |
countActiveSendPeers() |
How many peers are we currently connected to, that we have
sent a message to in the last minute.
|
void |
externalAddressReceived(Transport.AddressSource source,
byte[] ip,
int port) |
Initialize from interfaces, and callback from UPnP or SSU.
|
void |
externalAddressRemoved(Transport.AddressSource source,
boolean ipv6) |
Remove all ipv4 or ipv6 addresses.
|
void |
forwardPortStatus(java.lang.String style,
byte[] ip,
int port,
int externalPort,
boolean success,
java.lang.String reason) |
callback from UPnP
|
java.util.List<RouterAddress> |
getAddresses() |
This forces a rebuild
|
TransportBid |
getBid(OutNetMessage msg) |
|
java.util.List<TransportBid> |
getBids(OutNetMessage msg) |
|
java.util.Vector<java.lang.Long> |
getClockSkews() |
Return our peer clock skews on all transports.
|
(package private) DHSessionKeyBuilder.Factory |
getDHFactory() |
Hook for pluggable transport creation.
|
byte[] |
getIP(Hash peer) |
IP of the peer from the last connection (in or out, any transport).
|
java.util.List<java.lang.String> |
getMostRecentErrorMessages() |
|
TransportBid |
getNextBid(OutNetMessage msg) |
|
CommSystemFacade.Status |
getReachabilityStatus() |
Previously returned short, now enum as of 0.9.20
|
Transport |
getTransport(java.lang.String style) |
|
(package private) int |
getTransportCount() |
|
java.util.SortedMap<java.lang.String,Transport> |
getTransports() |
|
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 peer) |
|
boolean |
isEstablished(Hash peer) |
|
static boolean |
isNTCPEnabled(RouterContext ctx) |
|
void |
mayDisconnect(Hash peer) |
Tell the transports that we may disconnect from this peer.
|
void |
messageReceived(I2NPMessage message,
RouterIdentity fromRouter,
Hash fromRouterHash) |
Message received
|
void |
recheckReachability() |
推奨されていません。
unused
|
(package private) void |
registerAndStart(Transport t) |
Pluggable transports.
|
void |
renderStatusHTML(java.io.Writer out,
java.lang.String urlBase,
int sortFlags) |
As of 0.9.31, only outputs UPnP status
Warning - blocking, very slow, queries the active UPnP router,
will take many seconds if it has vanished.
|
void |
restart() |
|
void |
shutdown() |
Cannot be restarted.
|
void |
startListening() |
|
(package private) void |
stopAndUnregister(Transport t) |
Pluggable transports.
|
void |
stopListening() |
Can be restarted.
|
void |
transportAddressChanged() |
|
boolean |
wasUnreachable(Hash peer) |
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.
|
public static final java.lang.String PROP_ENABLE_UDP
public static final java.lang.String PROP_ENABLE_NTCP
public static final java.lang.String PROP_ENABLE_UPNP
public TransportManager(RouterContext context)
void registerAndStart(Transport t)
void stopAndUnregister(Transport t)
DHSessionKeyBuilder.Factory getDHFactory()
public static boolean isNTCPEnabled(RouterContext ctx)
public void externalAddressReceived(Transport.AddressSource source, byte[] ip, int port)
public void externalAddressRemoved(Transport.AddressSource source, boolean ipv6)
public void forwardPortStatus(java.lang.String style, byte[] ip, int port, int externalPort, boolean success, java.lang.String reason)
public void startListening()
public void restart()
public void stopListening()
public void shutdown()
public Transport getTransport(java.lang.String style)
int getTransportCount()
public java.util.SortedMap<java.lang.String,Transport> getTransports()
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<java.lang.Long> getClockSkews()
public CommSystemFacade.Status getReachabilityStatus()
@Deprecated public void recheckReachability()
public boolean isBacklogged(Hash peer)
public boolean isEstablished(Hash peer)
public void mayDisconnect(Hash peer)
public boolean wasUnreachable(Hash peer)
public byte[] getIP(Hash peer)
public java.util.List<RouterAddress> getAddresses()
public TransportBid getBid(OutNetMessage msg)
public java.util.List<TransportBid> getBids(OutNetMessage msg)
public TransportBid getNextBid(OutNetMessage msg)
public void messageReceived(I2NPMessage message, RouterIdentity fromRouter, Hash fromRouterHash)
messageReceived
インタフェース内 TransportEventListener
message
- non-nullfromRouter
- may be nullfromRouterHash
- may be null, calculated from fromRouter if nullpublic void transportAddressChanged()
transportAddressChanged
インタフェース内 TransportEventListener
public java.util.List<java.lang.String> getMostRecentErrorMessages()
public void renderStatusHTML(java.io.Writer out, java.lang.String urlBase, int sortFlags) throws java.io.IOException
java.io.IOException