Servicepublic class VMCommSystem extends CommSystemFacade
CommSystemFacade.StatusSTATUS_DIFFERENT, STATUS_DISCONNECTED, STATUS_HOSED, STATUS_IPV4_DISABLED_IPV6_FIREWALLED, STATUS_IPV4_DISABLED_IPV6_OK, STATUS_IPV4_DISABLED_IPV6_UNKNOWN, STATUS_IPV4_FIREWALLED_IPV6_OK, STATUS_IPV4_FIREWALLED_IPV6_UNKNOWN, STATUS_IPV4_OK_IPV6_FIREWALLED, STATUS_IPV4_OK_IPV6_UNKNOWN, STATUS_IPV4_SNAT_IPV6_OK, STATUS_IPV4_SNAT_IPV6_UNKNOWN, STATUS_IPV4_UNKNOWN_IPV6_FIREWALLED, STATUS_IPV4_UNKNOWN_IPV6_OK, STATUS_OK, STATUS_REJECT_UNSOLICITED, STATUS_UNKNOWN| コンストラクタ | 説明 |
|---|---|
VMCommSystem(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.
|
java.util.Set<Hash> |
getEstablished() |
Get all the peers we are connected to.
|
boolean |
isEstablished(Hash peer) |
|
void |
processMessage(OutNetMessage msg) |
The router wants us to send the given message to the peer.
|
void |
receive(byte[] message,
Hash fromPeer) |
We send messages between comms as bytes so that we strip any router-local
info.
|
void |
renderStatusHTML(java.io.Writer out,
java.lang.String urlBase,
int sortFlags) |
|
void |
restart() |
Perform a soft restart.
|
void |
shutdown() |
Instruct the service that the router is shutting down and that it should do
whatever is necessary to go down gracefully.
|
void |
startup() |
Instruct the service that it should start normal operation.
|
createAddresses, getCountry, getCountryName, getDHFactory, getFramedAveragePeerClockSkew, getIP, getMedianPeerClockSkew, getMostRecentErrorMessages, getOurCountry, getReachabilityStatus, getStatus, getTransports, haveHighOutboundCapacity, haveInboundCapacity, haveOutboundCapacity, isBacklogged, isDummy, isInBadCountry, isInBadCountry, isInBadCountry, mayDisconnect, notifyRemoveAddress, notifyRemoveAddress, notifyReplaceAddress, queueLookup, recheckReachability, registerTransport, renderPeerHTML, renderStatusHTML, unregisterTransport, wasUnreachablepublic VMCommSystem(RouterContext context)
public int countActivePeers()
CommSystemFacadecountActivePeers クラス内 CommSystemFacadepublic int countActiveSendPeers()
CommSystemFacadecountActiveSendPeers クラス内 CommSystemFacadepublic boolean isEstablished(Hash peer)
isEstablished クラス内 CommSystemFacadepublic java.util.Set<Hash> getEstablished()
CommSystemFacadegetEstablished クラス内 CommSystemFacadepublic void processMessage(OutNetMessage msg)
processMessage クラス内 CommSystemFacadepublic void receive(byte[] message,
Hash fromPeer)
public void shutdown()
Servicepublic void startup()
Servicepublic void restart()
Servicepublic void renderStatusHTML(java.io.Writer out,
java.lang.String urlBase,
int sortFlags)
throws java.io.IOException
renderStatusHTML クラス内 CommSystemFacadejava.io.IOException