public class VMCommSystem extends CommSystemFacade
CommSystemFacade.Status
ROUTER_BUNDLE_NAME, STATUS_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
Constructor and Description |
---|
VMCommSystem(RouterContext context) |
Modifier and Type | Method and Description |
---|---|
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.
|
List<Hash> |
getEstablished()
Get all the peers we are connected to.
|
X25519KeyFactory |
getXDHFactory()
Factory for making X25519 key pairs.
|
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(Writer out,
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, exemptIncoming, forceDisconnect, getCountries, getCountry, getCountryName, getDHFactory, getFramedAveragePeerClockSkew, getIP, getLocalizedStatusString, getMedianPeerClockSkew, getMostRecentErrorMessages, getOurCountry, getReachabilityStatus, getStatus, getTransports, haveHighOutboundCapacity, haveInboundCapacity, haveOutboundCapacity, initGeoIP, isBacklogged, isDummy, isExemptIncoming, isInStrictCountry, isInStrictCountry, isInStrictCountry, isRunning, mayDisconnect, notifyRemoveAddress, notifyRemoveAddress, notifyReplaceAddress, queueLookup, recheckReachability, registerTransport, removeExemption, renderPeerHTML, renderStatusHTML, unregisterTransport, wasUnreachable
public VMCommSystem(RouterContext context)
public X25519KeyFactory getXDHFactory()
getXDHFactory
in class CommSystemFacade
public int countActivePeers()
CommSystemFacade
countActivePeers
in class CommSystemFacade
public int countActiveSendPeers()
CommSystemFacade
countActiveSendPeers
in class CommSystemFacade
public boolean isEstablished(Hash peer)
isEstablished
in class CommSystemFacade
public List<Hash> getEstablished()
CommSystemFacade
getEstablished
in class CommSystemFacade
public void processMessage(OutNetMessage msg)
processMessage
in class CommSystemFacade
public void receive(byte[] message, Hash fromPeer)
public void shutdown()
Service
public void startup()
Service
public void restart()
Service
public void renderStatusHTML(Writer out, String urlBase, int sortFlags) throws IOException
renderStatusHTML
in class CommSystemFacade
IOException