net.i2p.router.dummy.VMCommSystem

All Implemented Interfaces:: Service

public class VMCommSystem
extends CommSystemFacade

Hacked up in-VM comm system for talking between contexts. It doesn't even generate any routerAddresses, but instead tracks the peers through a singleton. Currently, the comm system doesn't even inject any lag, though it could (later). It does honor the standard transport stats though, but not the TCP specific ones. FOR DEBUGGING AND LOCAL TESTING ONLY.

Nested Class Summary

Nested classes/interfaces inherited from class net.i2p.router.CommSystemFacade
CommSystemFacade.Status
Field Summary

Fields inherited from class net.i2p.router.CommSystemFacade
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 Summary

Constructors

Constructor Description

VMCommSystem(RouterContext context)

Method Summary

Modifier and Type	Method	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.
`Set<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.

Methods inherited from class net.i2p.router.CommSystemFacade

createAddresses, forceDisconnect, getCountry, getCountryName, getDHFactory, getFramedAveragePeerClockSkew, getIP, getLocalizedStatusString, getMedianPeerClockSkew, getMostRecentErrorMessages, getOurCountry, getReachabilityStatus, getStatus, getTransports, haveHighOutboundCapacity, haveInboundCapacity, haveOutboundCapacity, initGeoIP, isBacklogged, isDummy, isInStrictCountry, isInStrictCountry, isInStrictCountry, mayDisconnect, notifyRemoveAddress, notifyRemoveAddress, notifyReplaceAddress, queueLookup, recheckReachability, registerTransport, renderPeerHTML, renderStatusHTML, unregisterTransport, wasUnreachable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- VMCommSystem
  
  public VMCommSystem(RouterContext context)
Method Details
- getXDHFactory
  
  public X25519KeyFactory getXDHFactory()
  
  Factory for making X25519 key pairs.
  
  Overrides:
  
  getXDHFactory in class CommSystemFacade
  
  Since:
  
  0.9.49 so some tests don't NPE
- countActivePeers
  
  public int countActivePeers()
  
  Description copied from class: CommSystemFacade
  
  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.
  
  Specified by:
  
  countActivePeers in class CommSystemFacade
- countActiveSendPeers
  
  public int countActiveSendPeers()
  
  Description copied from class: CommSystemFacade
  
  How many peers are we currently connected to, that we have sent a message to in the last minute. Unused for anything, to be removed.
  
  Specified by:
  
  countActiveSendPeers in class CommSystemFacade
- isEstablished
  
  public boolean isEstablished(Hash peer)
  
  Specified by:
  
  isEstablished in class CommSystemFacade
- getEstablished
  
  public Set<Hash> getEstablished()
  
  Description copied from class: CommSystemFacade
  
  Get all the peers we are connected to. This should be more efficient than repeated calls to isEstablished() if you have to check a lot.
  
  Specified by:
  
  getEstablished in class CommSystemFacade
  
  Returns:
  
  the hashes of all the routers we are connected to, non-null
- processMessage
  
  public void processMessage(OutNetMessage msg)
  
  The router wants us to send the given message to the peer. Do so, or fire off the failing job.
  
  Specified by:
  
  processMessage in class CommSystemFacade
- receive
  
  public void receive(byte[] message, Hash fromPeer)
  
  We send messages between comms as bytes so that we strip any router-local info. For example, a router tags the # attempts to send through a leaseSet, what type of tunnel a tunnelId is bound to, etc.
- shutdown
  
  public void shutdown()
  
  Description copied from interface: Service
  
  Instruct the service that the router is shutting down and that it should do whatever is necessary to go down gracefully. It should not depend on other components at this point. This call DOES block.
- startup
  
  public void startup()
  
  Description copied from interface: Service
  
  Instruct the service that it should start normal operation. This call DOES block until the service is ready.
- restart
  
  public void restart()
  
  Description copied from interface: Service
  
  Perform a soft restart.
- renderStatusHTML
  
  public void renderStatusHTML(Writer out, String urlBase, int sortFlags) throws IOException
  
  Overrides:
  
  renderStatusHTML in class CommSystemFacade
  
  Throws:
  
  IOException

Class VMCommSystem

Nested Class Summary

Nested classes/interfaces inherited from class net.i2p.router.CommSystemFacade

Field Summary

Fields inherited from class net.i2p.router.CommSystemFacade

Constructor Summary

Method Summary

Methods inherited from class net.i2p.router.CommSystemFacade

Methods inherited from class java.lang.Object

Constructor Details

Method Details