| Package | Description |
|---|---|
| ds.funnel.overlay | |
| ds.funnel.overlay.routing | |
| ds.funnel.peer | |
| ds.funnel.peer.event | |
| ds.funnel.topic |
| Modifier and Type | Class and Description |
|---|---|
class |
OverlayPathImpl |
| Modifier and Type | Field and Description |
|---|---|
static OverlayPath |
OverlayPath.EMPTY_PATH |
static OverlayPath |
OverlayPath.UNMARSHALL |
| Modifier and Type | Field and Description |
|---|---|
static java.util.Comparator<OverlayPath> |
OverlayPathImpl.COMP_DIST |
static java.util.Comparator<OverlayPath> |
OverlayPathImpl.COMP_FLAT |
| Modifier and Type | Method and Description |
|---|---|
OverlayPath |
OverlayPath.branchPath(int inMemberId)
Return a near copy of this path, adding an additional node.
|
OverlayPath |
OverlayPathImpl.branchPath(int inMemberId) |
OverlayPath |
OverlayPath.branchPath(long inVersion,
int inMemberId)
Return a near copy of this path, adding an additional node, and changing
the overlay version.
|
OverlayPath |
OverlayPathImpl.branchPath(long inVersion,
int inMemberId) |
OverlayPath |
OverlayManagerImpl.getCurrentPath(NodeDetails inNode) |
OverlayPath |
OverlayManager.getCurrentPath(NodeDetails inNode)
Get the most recent known path to the node, up to the current version.
|
OverlayPath |
OverlayLinkImpl.getLinkedLoc() |
OverlayPath |
OverlayLink.getLinkedLoc() |
OverlayPath |
OverlayVersion.getLocation() |
OverlayPath |
OverlayVersionImpl.getLocation() |
OverlayPath |
OverlayManagerImpl.getPath(NodeDetails inNode,
long inVersion) |
OverlayPath |
OverlayManager.getPath(NodeDetails inNode,
long inVersion)
Get the known path to a given node for a specific overlay version.
|
OverlayPath |
OverlayPath.returnPath()
Reverse this path, creating a return routing path.
|
OverlayPath |
OverlayPathImpl.returnPath() |
OverlayPath |
OverlayPathImpl.unmarshall(FormatReader mFormat) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<OverlayPath> |
OverlayManagerImpl.getPaths(NodeDetails inNode) |
java.util.List<OverlayPath> |
OverlayManager.getPaths(NodeDetails inNode)
Get the known paths to a given node.
|
| Modifier and Type | Method and Description |
|---|---|
static int[] |
OverlayPathImpl.between(OverlayPath treeLocA,
OverlayPath treeLocB) |
int |
OverlayPath.distanceTo(OverlayPath inDestPath)
The number of hops to reach the given destination using primary links.
|
int |
OverlayPathImpl.distanceTo(OverlayPath inDestPath) |
static int[] |
OverlayPathImpl.longestPrefix(OverlayPath treeLocA,
OverlayPath treeLocB) |
boolean |
OverlayPath.onPathOf(OverlayPath inDestPath)
True is this location is on the path of the given destination.
|
boolean |
OverlayPathImpl.onPathOf(OverlayPath inDestPath) |
boolean |
OverlayManagerImpl.updatePath(NodeDetails inNode,
OverlayPath inPath) |
boolean |
OverlayManager.updatePath(NodeDetails inNode,
OverlayPath inPath)
Update the known path to a node for a given version of the overlay.
|
| Modifier and Type | Method and Description |
|---|---|
void |
OverlayLinkImpl.sendMessage(TopicEvent inMessage,
java.util.List<OverlayPath> inDests) |
void |
OverlayLink.sendMessage(TopicEvent inMessage,
java.util.List<OverlayPath> inDests)
Send a message to the connected destination.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Map<OverlayLink,java.util.List<OverlayPath>> |
RoutePolicyImpl.getRoutingLinks(MessageEvent inEvent) |
java.util.Map<OverlayLink,java.util.List<OverlayPath>> |
RoutePolicy.getRoutingLinks(MessageEvent inEvent)
Determine the links that should be used to route a message.
|
| Modifier and Type | Method and Description |
|---|---|
OverlayPath |
PeerDetails.getOverlayPath() |
OverlayPath |
PeerDetailsImpl.getOverlayPath() |
| Modifier and Type | Method and Description |
|---|---|
PeerDetails |
PeerGroup.updatePeerDetails(NodeDetails inDetails,
OverlayPath inPath,
int inCoordOrder)
Update overlay information for a given node.
|
PeerDetails |
PeerGroupImpl.updatePeerDetails(NodeDetails inDetails,
OverlayPath inPath,
int inCoordOrder) |
| Constructor and Description |
|---|
PeerDetailsImpl(PeerGroupImpl inGroup,
NodeDetails inDetails,
OverlayPath inPath,
int inCoordOrder) |
| Modifier and Type | Field and Description |
|---|---|
OverlayPath |
MsgTopicAdvert.coordPath |
OverlayPath |
MsgTopicRepair.curLoc |
OverlayPath |
MsgTopicRepair.failedLoc |
OverlayPath |
MsgTopicOverlay.location |
OverlayPath |
MsgTopicNeighbor.nodePath |
OverlayPath |
MsgTopicLookup.peerPath |
| Modifier and Type | Field and Description |
|---|---|
java.util.List<OverlayPath> |
MessageBaseTE.dests |
java.util.List<OverlayPath> |
MsgTopicOverlay.priPath |
| Modifier and Type | Method and Description |
|---|---|
OverlayPath |
MessageBaseTE.getHops() |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<OverlayPath> |
MessageBaseTE.getDestinations() |
| Modifier and Type | Method and Description |
|---|---|
void |
MessageBaseTE.updateDests(OverlayPath inDest) |
void |
MessageBaseTE.updateHops(long inVersion,
int inMemberId,
OverlayPath inSrcLoc) |
| Modifier and Type | Method and Description |
|---|---|
void |
MessageBaseTE.updateDests(java.util.List<OverlayPath> inDests) |
| Constructor and Description |
|---|
MsgTopicAdvert(Topic inTopic,
NodeDetails inCoord,
OverlayPath inPath,
int inExpire) |
MsgTopicLookup(Topic inTopic,
int inSearch,
NodeDetails inMember,
OverlayPath inPath,
java.lang.String inTracker) |
MsgTopicNeighbor(NodeDetails inNode,
OverlayPath inPath,
boolean inCoord) |
MsgTopicOverlay(OverlayPath inOverlayLoc,
java.util.List<NodeDetails> inPrimaryLinks,
java.util.List<OverlayPath> inPrimaryPaths,
java.util.List<NodeDetails> inBackupLinks) |
MsgTopicRepair(NodeDetails inNode,
OverlayPath inCurLoc,
OverlayPath inFailedLoc) |
| Constructor and Description |
|---|
MsgTopicData(java.util.Properties inProps,
byte[] inData,
int inSize,
int inOffset,
java.util.List<OverlayPath> inDests) |
MsgTopicOverlay(OverlayPath inOverlayLoc,
java.util.List<NodeDetails> inPrimaryLinks,
java.util.List<OverlayPath> inPrimaryPaths,
java.util.List<NodeDetails> inBackupLinks) |
| Modifier and Type | Method and Description |
|---|---|
OverlayPath |
TopicEvent.getHops() |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<OverlayPath> |
TopicEvent.getDestinations() |
| Modifier and Type | Method and Description |
|---|---|
void |
TopicPublisherImpl.sendEvent(TopicDataEvent inEvent,
OverlayPath... inDests) |
void |
TopicPublisher.sendEvent(TopicDataEvent inEvent,
OverlayPath... inDests) |
void |
TopicPublisherImpl.sendEventData(byte[] inData,
OverlayPath... inDests) |
void |
TopicPublisher.sendEventData(byte[] inData,
OverlayPath... inDests) |
void |
TopicPublisherImpl.sendEventData(byte[] inData,
java.util.Properties inProps,
OverlayPath... inDests) |
void |
TopicPublisher.sendEventData(byte[] inData,
java.util.Properties inProps,
OverlayPath... inDests) |
void |
TopicEvent.updateDests(OverlayPath inDest) |
| Modifier and Type | Method and Description |
|---|---|
void |
TopicEvent.updateDests(java.util.List<OverlayPath> inDests) |