Package | Description |
---|---|
dcps | |
ethernet | |
test |
Modifier and Type | Field and Description |
---|---|
private java.util.HashSet<Destination> |
Topic.knownDestinations |
Modifier and Type | Method and Description |
---|---|
private Destination[] |
Topic.getDestinations() |
Modifier and Type | Method and Description |
---|---|
void |
Topic.addDestination(Destination obj) |
void |
TopicsScope.onNewConnection(Destination dest) |
void |
Topic.removeDestination(Destination obj) |
Modifier and Type | Field and Description |
---|---|
(package private) Destination |
PeersNode.nodeLeader |
Modifier and Type | Field and Description |
---|---|
(package private) java.util.HashMap<java.lang.Integer,Destination> |
PeersNode.nodeEndPoints |
Modifier and Type | Method and Description |
---|---|
Destination |
PeersSet.getDestinationByIPPort(IPPort ipp)
Gets a "Destination" reference from the IPPort identity.
|
Destination |
MultiPeer.getDestinationByIPPort(IPPort ipp) |
Destination |
PeersSet.getGeneralLeader()
Gets the leader among leaders.
|
Destination[] |
PeersSet.getIPDestinations(long ip)
Gets an array containing the "Destinations" running in a specific IP address.
|
Destination[] |
PeersSet.getLocalDestinations()
Gets an array containing the "Destinations" running in the local IP address.
|
Destination |
MultiPeer.getLocalLeader() |
Destination |
MultiPeer.getNetworkLeader()
From the peers in the party, get "local" and "global" (network) leader attending to the IPPort ordering criteria.
|
Destination |
PeersSet.getNodeLeader(long nodeIP)
Gets the "Destination" node leader in node specified by IP (as long).
|
Destination[] |
MultiPeer.send(Destination[] destArray,
Message m)
Send a Message to a subset of peers in the party.
|
private Destination[] |
MultiPeer.sendByProxyPeersSet(Message m,
PeersSet pSet)
Auxiliary method to send a message to an arbitrary "PeersSet"
using the "ProxyManager" service.
|
private Destination[] |
MultiPeer.sendDirectPeersSet(Message m,
PeersSet pSet)
Auxiliary method to send a message to an arbitrary "PeersSet" directly.
|
Modifier and Type | Method and Description |
---|---|
boolean |
PeersSet.addDestination(Destination dest)
Adds a destination into the data structure.
|
(package private) boolean |
PeersNode.addDestination(Destination dest)
Adds a destination to the data structure.
|
void |
SyncClock.onNewConnection(Destination dest)
MultiPeerListener callback.
|
void |
ProxyManager.onNewConnection(Destination dest) |
void |
MultiPeerListener.onNewConnection(Destination dest) |
private void |
MultiPeer.propagateNewConection(Destination dest)
Propagate the new connection to listeners (callback)
|
boolean |
PeersSet.removeDestination(Destination dest)
Remove a destination from the data structure.
|
(package private) boolean |
PeersNode.removeDestination(Destination dest)
Removes a destination from the data structure.
|
void |
MultiPeer.removeDestination(Destination dest)
Remove a destination from the party.
|
Destination[] |
MultiPeer.send(Destination[] destArray,
Message m)
Send a Message to a subset of peers in the party.
|
Modifier and Type | Method and Description |
---|---|
void |
MultiPeerTest.onNewConnection(Destination dest) |