|
Rice Pastry API | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of NodeHandle in rice.p2p.commonapi.testing |
|---|
| Methods in rice.p2p.commonapi.testing that return NodeHandle | |
|---|---|
protected NodeHandle |
CommonAPITest.getBootstrap()
Gets a handle to a bootstrap node. |
| Uses of NodeHandle in rice.p2p.multiring.testing |
|---|
| Methods in rice.p2p.multiring.testing that return NodeHandle | |
|---|---|
protected NodeHandle |
MultiringRegrTest.getBootstrap(Node bootstrap)
Gets a handle to a bootstrap node. |
| Uses of NodeHandle in rice.pastry |
|---|
| Fields in rice.pastry declared as NodeHandle | |
|---|---|
protected NodeHandle |
PastryNode.localhandle
|
| Fields in rice.pastry with type parameters of type NodeHandle | |
|---|---|
protected java.util.Hashtable<NodeHandle,java.util.Hashtable<NodeHandle,java.lang.Integer>> |
PastryNodeFactory.pingCache
Hashtable which keeps track of temporary ping values, which are only used during the getNearest() method |
protected java.util.Hashtable<NodeHandle,java.util.Hashtable<NodeHandle,java.lang.Integer>> |
PastryNodeFactory.pingCache
Hashtable which keeps track of temporary ping values, which are only used during the getNearest() method |
| Methods in rice.pastry that return NodeHandle | |
|---|---|
abstract NodeHandle |
PastryNode.coalesce(NodeHandle newHandle)
|
NodeHandle |
NodeSet.get(Id nid)
Finds the NodeHandle associated with a NodeId. |
NodeHandle |
NodeSetI.get(Id nid)
Finds the NodeHandle associated with the NodeId. |
NodeHandle |
NodeSet.get(int i)
Gets the ith element in the set. |
NodeHandle |
NodeSetI.get(int i)
Gets the ith element in the set. |
NodeHandle |
PastryNode.getLocalHandle()
|
NodeHandle[] |
PastryNodeFactory.getNearest(NodeHandle local,
NodeHandle seed)
This method implements the algorithm in the Pastry locality paper for finding a close node the the current node through iterative leafset and route row requests. |
NodeHandle |
NodeSetUpdate.handle()
The handle that changed. |
NodeHandle |
NodeHandleFactory.readNodeHandle(InputBuffer buf)
|
NodeHandle |
NodeSet.remove(Id nid)
Removes a node id and its handle from the set. |
NodeHandle |
NodeSet.remove(NodeHandle handle)
remove a member |
NodeHandle |
NodeSetI.remove(NodeHandle nh)
Removes a node id and its handle from the set. |
NodeHandle[] |
PastryNodeFactory.sortedProximityCache(NodeHandle local)
|
| Methods in rice.pastry with parameters of type NodeHandle | |
|---|---|
abstract NodeHandle |
PastryNode.coalesce(NodeHandle newHandle)
|
abstract void |
PastryNode.connect(NodeHandle handle,
AppSocketReceiver receiver,
PastryAppl appl,
int timeout)
Called by PastryAppl to ask the transport layer to open a Socket to its counterpart on another node. |
int |
NodeSet.getIndex(NodeHandle nh)
|
int |
NodeSetI.getIndex(NodeHandle nh)
|
abstract LeafSet |
PastryNodeFactory.getLeafSet(NodeHandle handle)
This method returns the remote leafset of the provided handle to the caller, in a protocol-dependent fashion. |
abstract CancellableTask |
PastryNodeFactory.getLeafSet(NodeHandle handle,
Continuation c)
Non-blocking version. |
NodeHandle[] |
PastryNodeFactory.getNearest(NodeHandle local,
NodeHandle seed)
This method implements the algorithm in the Pastry locality paper for finding a close node the the current node through iterative leafset and route row requests. |
abstract int |
PastryNodeFactory.getProximity(NodeHandle local,
NodeHandle handle)
This method determines and returns the proximity of the current local node the provided NodeHandle. |
abstract RouteSet[] |
PastryNodeFactory.getRouteRow(NodeHandle handle,
int row)
This method returns the remote route row of the provided handle to the caller, in a protocol-dependent fashion. |
abstract CancellableTask |
PastryNodeFactory.getRouteRow(NodeHandle handle,
int row,
Continuation c)
Non-blocking version. |
int |
NodeSet.indexOf(NodeHandle handle)
determine rank of a member |
abstract void |
PastryNode.initiateJoin(NodeHandle[] bootstrap)
Overridden by derived classes to initiate the join process |
boolean |
NodeSet.insert(int index,
NodeHandle handle)
insert a member at the given index |
boolean |
NodeSet.member(NodeHandle handle)
test membership |
boolean |
NodeSetI.member(NodeHandle nh)
Verifies if the set contains this particular id. |
abstract PastryNode |
PastryNodeFactory.newNode(NodeHandle bootstrap)
Call this to construct a new node of the type chosen by the factory. |
abstract PastryNode |
PastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId)
Call this to construct a new node of the type chosen by the factory, with the given nodeId. |
void |
NodeSetListener.nodeSetUpdate(NodeSetEventSource nodeSetEventSource,
NodeHandle handle,
boolean added)
|
abstract int |
PastryNode.proximity(NodeHandle nh)
The proximity of the node handle. |
protected int |
PastryNodeFactory.proximity(NodeHandle local,
NodeHandle handle)
Method which checks to see if we have a cached value of the remote ping, and if not, initiates a ping and then caches the value |
boolean |
NodeSet.put(NodeHandle handle)
Appends a member to the ordered set. |
boolean |
NodeSetI.put(NodeHandle handle)
Puts a NodeHandle into the set. |
NodeHandle |
NodeSet.remove(NodeHandle handle)
remove a member |
NodeHandle |
NodeSetI.remove(NodeHandle nh)
Removes a node id and its handle from the set. |
abstract void |
PastryNode.send(NodeHandle handle,
Message message)
Deliver message to the NodeHandle. |
void |
PastryNode.setElements(NodeHandle lh,
MessageDispatch md,
LeafSet ls,
RoutingTable rt)
Combined accessor method for various members of PastryNode. |
NodeHandle[] |
PastryNodeFactory.sortedProximityCache(NodeHandle local)
|
| Constructors in rice.pastry with parameters of type NodeHandle | |
|---|---|
NodeSetUpdate(NodeHandle which,
boolean how)
Constructor. |
|
| Constructor parameters in rice.pastry with type arguments of type NodeHandle | |
|---|---|
NodeSet(java.util.Vector<NodeHandle> s)
Constructor. |
|
| Uses of NodeHandle in rice.pastry.client |
|---|
| Methods in rice.pastry.client that return NodeHandle | |
|---|---|
NodeHandle |
PastryAppl.getNodeHandle()
Gets the handle of the Pastry node associated with this client |
| Methods in rice.pastry.client with parameters of type NodeHandle | |
|---|---|
boolean |
PastryAppl.enrouteMessage(Message msg,
Id key,
NodeHandle nextHop,
SendOptions opt)
Called by pastry when a message is enroute and is passing through this node. |
void |
CommonAPIAppl.leafSetChange(NodeHandle nh,
boolean wasAdded)
Called by pastry when the leaf set changes. |
void |
PastryAppl.leafSetChange(NodeHandle nh,
boolean wasAdded)
Called by pastry when the leaf set changes. |
IdRange |
CommonAPIAppl.range(NodeHandle n,
int r,
Id key)
This method provides information about ranges of keys for which the node n is currently a r-root. |
IdRange |
CommonAPIAppl.range(NodeHandle n,
int r,
Id key,
boolean cumulative)
This method provides information about ranges of keys for which the node n is currently a r-root. |
void |
CommonAPIAppl.route(Id key,
Message msg,
NodeHandle hint)
This operation forwards a message towards the root of key. |
boolean |
PastryAppl.routeMsgDirect(NodeHandle dest,
Message msg,
SendOptions opt)
Sends a message to the Pastry node identified by dest. |
void |
PastryAppl.routeSetChange(NodeHandle nh,
boolean wasAdded)
Called by pastry when the route set changes. |
void |
CommonAPIAppl.update(NodeHandle nh,
boolean joined)
Called by pastry when the neighbor set changes. |
| Uses of NodeHandle in rice.pastry.commonapi |
|---|
| Methods in rice.pastry.commonapi with parameters of type NodeHandle | |
|---|---|
boolean |
PastryEndpoint.enrouteMessage(Message msg,
Id key,
NodeHandle nextHop,
SendOptions opt)
|
void |
PastryEndpoint.leafSetChange(NodeHandle nh,
boolean wasAdded)
|
| Constructors in rice.pastry.commonapi with parameters of type NodeHandle | |
|---|---|
PastryEndpointMessage(int address,
InputBuffer buf,
MessageDeserializer md,
NodeHandle sender)
|
|
PastryEndpointMessage(int address,
Message message,
NodeHandle sender)
Constructor. |
|
PastryEndpointMessage(int address,
RawMessage message,
NodeHandle sender)
|
|
| Uses of NodeHandle in rice.pastry.direct |
|---|
| Subclasses of NodeHandle in rice.pastry.direct | |
|---|---|
class |
DirectNodeHandle
the node handle used with the direct network |
| Methods in rice.pastry.direct that return NodeHandle | |
|---|---|
NodeHandle |
DirectPastryNode.coalesce(NodeHandle newHandle)
|
NodeHandle |
DirectPastryNode.readNodeHandle(InputBuffer buf)
|
| Methods in rice.pastry.direct with parameters of type NodeHandle | |
|---|---|
NodeHandle |
DirectPastryNode.coalesce(NodeHandle newHandle)
|
void |
DirectPastryNode.connect(NodeHandle remoteNode,
AppSocketReceiver receiver,
PastryAppl appl,
int timeout)
|
void |
DirectPastryNode.doneNode(NodeHandle[] bootstrap)
|
LeafSet |
DirectPastryNodeFactory.getLeafSet(NodeHandle handle)
This method returns the remote leafset of the provided handle to the caller, in a protocol-dependent fashion. |
CancellableTask |
DirectPastryNodeFactory.getLeafSet(NodeHandle handle,
Continuation c)
|
int |
DirectPastryNodeFactory.getProximity(NodeHandle local,
NodeHandle remote)
This method determines and returns the proximity of the current local node the provided NodeHandle. |
RouteSet[] |
DirectPastryNodeFactory.getRouteRow(NodeHandle handle,
int row)
This method returns the remote route row of the provided handle to the caller, in a protocol-dependent fashion. |
CancellableTask |
DirectPastryNodeFactory.getRouteRow(NodeHandle handle,
int row,
Continuation c)
|
void |
DirectPastryNode.initiateJoin(NodeHandle[] bootstrap)
|
PastryNode |
DirectPastryNodeFactory.newNode(NodeHandle bootstrap)
Manufacture a new Pastry node. |
PastryNode |
DirectPastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId)
Manufacture a new Pastry node. |
void |
BasicNetworkSimulator.notifySimulatorListeners(Message m,
NodeHandle from,
NodeHandle to,
int delay)
|
void |
NetworkSimulator.notifySimulatorListeners(Message m,
NodeHandle from,
NodeHandle to,
int delay)
Call this when a message is sent. |
int |
DirectPastryNode.proximity(NodeHandle that)
|
void |
DirectPastryNode.send(NodeHandle nh,
Message m)
|
| Uses of NodeHandle in rice.pastry.dist |
|---|
| Subclasses of NodeHandle in rice.pastry.dist | |
|---|---|
class |
DistNodeHandle
Abstract class for handles to "real" remote nodes. |
| Methods in rice.pastry.dist that return NodeHandle | |
|---|---|
abstract NodeHandle |
DistPastryNodeFactory.generateNodeHandle(java.net.InetSocketAddress address,
int timeout)
Method which all subclasses should implement allowing the client to generate a node handle given the address of a node. |
NodeHandle |
DistPastryNodeFactory.getNodeHandle(java.net.InetSocketAddress address)
Method which a client should use in order to get a bootstrap node from the factory. |
NodeHandle |
DistPastryNodeFactory.getNodeHandle(java.net.InetSocketAddress[] addresses)
Method which a client should use in order to get a bootstrap node from the factory. |
NodeHandle |
DistPastryNodeFactory.getNodeHandle(java.net.InetSocketAddress[] addresses,
int timeoutMillis)
|
NodeHandle |
DistPastryNodeFactory.getNodeHandle(java.net.InetSocketAddress address,
int timeout)
|
| Methods in rice.pastry.dist with parameters of type NodeHandle | |
|---|---|
void |
DistPastryNode.doneNode(NodeHandle[] bootstrap)
Called after the node is initialized. |
void |
DistPastryNode.initiateJoin(NodeHandle[] bootstrap)
Sends an InitiateJoin message to itself. |
abstract PastryNode |
DistPastryNodeFactory.newNode(NodeHandle bootstrap)
Generates a new pastry node with a random NodeId using the bootstrap bootstrap. |
abstract PastryNode |
DistPastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId)
Generates a new pastry node with the specified NodeId using the bootstrap bootstrap. |
abstract PastryNode |
DistPastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId,
java.net.InetSocketAddress proxy)
Generates a new pastry node with the specified NodeId using the bootstrap bootstrap. |
abstract PastryNode |
DistPastryNodeFactory.newNode(NodeHandle bootstrap,
java.net.InetSocketAddress proxy)
Generates a new pastry node with the specified NodeId using the bootstrap bootstrap. |
| Uses of NodeHandle in rice.pastry.join |
|---|
| Methods in rice.pastry.join that return NodeHandle | |
|---|---|
NodeHandle |
InitiateJoin.getHandle()
Gets the handle for the join. |
NodeHandle |
JoinRequest.getHandle()
Gets the handle of the node trying to join. |
NodeHandle |
JoinRequest.getJoinHandle()
Gets the handle of the node that accepted the join request; |
| Methods in rice.pastry.join with parameters of type NodeHandle | |
|---|---|
void |
JoinRequest.acceptJoin(NodeHandle nh,
LeafSet ls)
Accept join request. |
| Constructors in rice.pastry.join with parameters of type NodeHandle | |
|---|---|
InitiateJoin(java.util.Date stamp,
NodeHandle[] nh)
Constructor. |
|
InitiateJoin(NodeHandle[] nh)
Constructor. |
|
JoinRequest(InputBuffer buf,
NodeHandleFactory nhf,
NodeHandle sender,
PastryNode localNode)
|
|
JoinRequest(NodeHandle nh,
byte rtBaseBitLength)
Constructor. |
|
JoinRequest(NodeHandle nh,
java.util.Date stamp,
byte rtBaseBitLength)
Constructor. |
|
| Uses of NodeHandle in rice.pastry.leafset |
|---|
| Methods in rice.pastry.leafset that return NodeHandle | |
|---|---|
NodeHandle |
BroadcastLeafSet.from()
Returns the node id of the node that broadcast its leaf set. |
NodeHandle |
SimilarSet.get(Id nid)
Finds the NodeHandle associated with the Id. |
NodeHandle |
LeafSet.get(int index)
Finds the NodeHandle at a given index. |
NodeHandle |
SimilarSet.get(int i)
Gets the ith element in the set. |
NodeHandle |
SimilarSet.get(NodeHandle nh)
|
NodeHandle |
SimilarSet.remove(Id nid)
Removes a node id and its handle from the set. |
protected NodeHandle |
SimilarSet.remove(int i)
Removes a node id and its handle from the set. |
NodeHandle |
SimilarSet.remove(NodeHandle nh)
|
NodeHandle |
RequestLeafSet.returnHandle()
The return handle for the message |
| Methods in rice.pastry.leafset with parameters of type NodeHandle | |
|---|---|
boolean |
LeafSet.directTest(NodeHandle handle)
|
NodeHandle |
SimilarSet.get(NodeHandle nh)
|
int |
LeafSet.getIndex(NodeHandle nh)
|
int |
SimilarSet.getIndex(NodeHandle nh)
|
protected boolean |
LeafSet.isProperlyRemoved(NodeHandle handle)
|
boolean |
LeafSet.member(NodeHandle nid)
Verifies if the set contains this particular handle. |
boolean |
SimilarSet.member(NodeHandle nid)
Verifies if the set contains this particular id. |
boolean |
LeafSet.merge(LeafSet remotels,
NodeHandle from,
RoutingTable routeTable,
boolean testOnly,
java.util.Set insertedHandles)
Merge a remote leafset into this |
protected void |
SimilarSet.notifyListeners(NodeHandle handle,
boolean added)
|
boolean |
LeafSet.put(NodeHandle handle)
Puts a NodeHandle into the set. |
boolean |
SimilarSet.put(NodeHandle handle)
Puts a NodeHandle into the set. |
boolean |
LeafSet.put(NodeHandle handle,
boolean suppressNotification)
|
boolean |
SimilarSet.put(NodeHandle handle,
boolean suppressNotify)
|
IdRange |
LeafSet.range(NodeHandle n,
int r)
range computes the range of keys for which node n is a i-root, 0<=i<=r a node is the r-root for a key of the node becomes the numerically closest node to the key when i-roots for the key fail, O<=i |
IdRange |
LeafSet.range(NodeHandle n,
int r,
boolean cw)
range computes the ranges of keys for which node n is a r-root a node is the r-root for a key of the node becomes the numerically closest node to the key when i-roots for the key fail, O<=i |
void |
LeafSet.remove(NodeHandle nh)
Removes a node id and its handle from the set. |
NodeHandle |
SimilarSet.remove(NodeHandle nh)
|
boolean |
LeafSet.test(NodeHandle handle)
Test if a put of the given NodeHandle would succeed. |
boolean |
SimilarSet.test(NodeHandle handle)
Test if a NodeHandle belongs into the set. |
protected boolean |
LeafSet.testOtherSet(SimilarSet set,
NodeHandle handle)
|
| Constructors in rice.pastry.leafset with parameters of type NodeHandle | |
|---|---|
BroadcastLeafSet(java.util.Date stamp,
NodeHandle from,
LeafSet leafSet,
int type,
long requestTimeStamp)
Constructor. |
|
BroadcastLeafSet(NodeHandle from,
LeafSet leafSet,
int type,
long requestTimeStamp)
Constructor. |
|
LeafSet(NodeHandle localNode,
int size,
boolean observe)
|
|
LeafSet(NodeHandle localNode,
int size,
boolean observe,
NodeHandle[] cwTable,
NodeHandle[] ccwTable)
|
|
LeafSet(NodeHandle localNode,
int size,
boolean observe,
NodeHandle[] cwTable,
NodeHandle[] ccwTable)
|
|
LeafSet(NodeHandle localNode,
int size,
boolean observe,
NodeHandle[] cwTable,
NodeHandle[] ccwTable)
|
|
LeafSet(NodeHandle localNode,
int size,
RoutingTable rt)
Constructor. |
|
RequestLeafSet(java.util.Date stamp,
NodeHandle nh,
long timeStamp)
Constructor. |
|
RequestLeafSet(NodeHandle sender,
InputBuffer buf)
|
|
RequestLeafSet(NodeHandle nh,
long timeStamp)
Constructor. |
|
SimilarSet(LeafSet leafSet,
NodeHandle localNode,
int size,
boolean cw)
Constructor. |
|
SimilarSet(LeafSet leafSet,
NodeHandle localNode,
int size,
boolean cw,
NodeHandle[] handles)
|
|
SimilarSet(LeafSet leafSet,
NodeHandle localNode,
int size,
boolean cw,
NodeHandle[] handles)
|
|
| Uses of NodeHandle in rice.pastry.leafset.testing |
|---|
| Subclasses of NodeHandle in rice.pastry.leafset.testing | |
|---|---|
static class |
MergeTest.TestNodeHandle
|
| Methods in rice.pastry.leafset.testing that return NodeHandle | |
|---|---|
static NodeHandle[] |
MergeTest.getHandles(java.lang.String str)
Input of the form: <0xD74D4F..><0xD7B075..><0xD98A9D..><0xDAC7F0..><0xDB39A6..> |
| Methods in rice.pastry.leafset.testing with parameters of type NodeHandle | |
|---|---|
static void |
MergeTest.flip(NodeHandle[] nds)
|
| Uses of NodeHandle in rice.pastry.messaging |
|---|
| Methods in rice.pastry.messaging that return NodeHandle | |
|---|---|
NodeHandle |
Message.getSender()
Get sender. |
| Methods in rice.pastry.messaging with parameters of type NodeHandle | |
|---|---|
abstract Message |
PJavaSerializedDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
void |
Message.setSender(NodeHandle nh)
Set sender Id. |
| Uses of NodeHandle in rice.pastry.routing |
|---|
| Fields in rice.pastry.routing declared as NodeHandle | |
|---|---|
NodeHandle |
RoutingTable.myNodeHandle
|
NodeHandle |
RouteMessage.nextHop
|
| Methods in rice.pastry.routing that return NodeHandle | |
|---|---|
NodeHandle |
RoutingTable.bestAlternateRoute(Id key)
Determines an alternate hop numerically closer to the key than the one we are at. |
NodeHandle |
RoutingTable.bestAlternateRoute(int minLiveness,
Id key)
Determines an alternate hop numerically closer to the key than the one we are at. |
NodeHandle |
RouteSet.closestNode()
Return the closest live node in the set. |
NodeHandle |
RouteSet.closestNode(int minLiveness)
Return the closest live node in the set. |
NodeHandle |
BroadcastRouteRow.from()
Gets the from node. |
NodeHandle |
RouteSet.get(Id nid)
Returns the node handle with the matching node id or null if none exists. |
NodeHandle |
RoutingTable.get(Id nid)
Gets the node handle associated with a given id. |
NodeHandle |
RouteSet.get(int i)
Returns the node in the ith position in the set. |
NodeHandle |
RouteMessage.getNextHop()
|
NodeHandle |
RouteMessage.getPrevNode()
|
NodeHandle |
RouteSet.remove(Id nid)
Removes a node from a set. |
NodeHandle |
RouteSet.remove(NodeHandle nh)
Removes a node from a set. |
NodeHandle |
RoutingTable.remove(NodeHandle nh)
Removes a node id from the table. |
NodeHandle |
RequestRouteRow.returnHandle()
The return handle for the message |
| Methods in rice.pastry.routing with parameters of type NodeHandle | |
|---|---|
int |
RouteSet.getIndex(NodeHandle nh)
Get the index of the node id. |
boolean |
RouteSet.member(NodeHandle nh)
Membership test. |
void |
RoutingTable.nodeSetUpdate(java.lang.Object o,
NodeHandle handle,
boolean added)
Is called by the Observer pattern whenever a RouteSet in this table has changed. |
boolean |
RouteSet.put(NodeHandle handle)
Puts a node into the set. |
boolean |
RoutingTable.put(NodeHandle handle)
Puts a handle into the routing table. |
NodeHandle |
RouteSet.remove(NodeHandle nh)
Removes a node from a set. |
NodeHandle |
RoutingTable.remove(NodeHandle nh)
Removes a node id from the table. |
boolean |
RouteMessage.routeMessage(NodeHandle localHandle)
Routes the messages if the next hop has been set up. |
void |
RouteMessage.setNextHop(NodeHandle nh)
|
void |
RouteMessage.setPrevNode(NodeHandle n)
|
int |
RoutingTable.test(NodeHandle handle)
|
| Constructors in rice.pastry.routing with parameters of type NodeHandle | |
|---|---|
BroadcastRouteRow(java.util.Date stamp,
NodeHandle from,
RouteSet[] r)
Constructor. |
|
BroadcastRouteRow(NodeHandle from,
RouteSet[] r)
Constructor. |
|
RequestRouteRow(java.util.Date stamp,
NodeHandle nh,
short r)
Constructor. |
|
RequestRouteRow(NodeHandle sender,
InputBuffer buf)
|
|
RequestRouteRow(NodeHandle nh,
short r)
Constructor. |
|
RouteMessage(Id target,
int auxAddress,
NodeHandle prev,
InputBuffer buf,
NodeHandleFactory nhf,
PastryNode pn)
|
|
RouteMessage(Id target,
Message msg,
NodeHandle firstHop)
Constructor. |
|
RouteMessage(Id target,
Message msg,
NodeHandle firstHop,
SendOptions opts)
Constructor. |
|
RouteMessage(Id target,
PRawMessage msg,
NodeHandle firstHop,
SendOptions opts)
|
|
RouteMessage(NodeHandle dest,
Message msg,
SendOptions opts)
Constructor. |
|
RoutingTable(NodeHandle me,
int max,
byte base,
PastryNode pn)
Constructor. |
|
| Uses of NodeHandle in rice.pastry.socket |
|---|
| Subclasses of NodeHandle in rice.pastry.socket | |
|---|---|
class |
SocketNodeHandle
Class which represents the address and nodeId of a remote node. |
| Methods in rice.pastry.socket that return NodeHandle | |
|---|---|
NodeHandle |
SocketPastryNode.coalesce(NodeHandle newHandle)
|
NodeHandle |
SocketPastryNodeFactory.generateNodeHandle(java.net.InetSocketAddress address)
Method which contructs a node handle (using the socket protocol) for the node at address NodeHandle. |
NodeHandle |
SocketPastryNodeFactory.generateNodeHandle(java.net.InetSocketAddress address,
int timeout)
Way to generate a NodeHandle with a maximum timeout to receive the result. |
NodeHandle |
SocketPastryNode.readNodeHandle(InputBuffer buf)
|
| Methods in rice.pastry.socket with parameters of type NodeHandle | |
|---|---|
NodeHandle |
SocketPastryNode.coalesce(NodeHandle newHandle)
|
void |
SocketPastryNode.connect(NodeHandle handle,
AppSocketReceiver receiver,
PastryAppl appl,
int timeout)
|
void |
SocketPastryNode.doneNode(NodeHandle[] bootstrap)
Called after the node is initialized. |
LeafSet |
SocketPastryNodeFactory.getLeafSet(NodeHandle handle)
This method returns the remote leafset of the provided handle to the caller, in a protocol-dependent fashion. |
CancellableTask |
SocketPastryNodeFactory.getLeafSet(NodeHandle handle,
Continuation c)
|
int |
SocketPastryNodeFactory.getProximity(NodeHandle local,
NodeHandle handle)
This method determines and returns the proximity of the current local node to the provided NodeHandle. |
RouteSet[] |
SocketPastryNodeFactory.getRouteRow(NodeHandle handle,
int row)
This method returns the remote route row of the provided handle to the caller, in a protocol-dependent fashion. |
CancellableTask |
SocketPastryNodeFactory.getRouteRow(NodeHandle handle,
int row,
Continuation c)
|
SourceRoute[] |
SocketPastryNodeFactory.getRoutes(NodeHandle handle,
NodeHandle local)
This method returns the routes a remote node is using |
PastryNode |
SocketPastryNodeFactory.newNode(NodeHandle bootstrap)
Method which creates a Pastry node from the next port with a randomly generated NodeId. |
PastryNode |
SocketPastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId)
Method which creates a Pastry node from the next port with a randomly generated NodeId. |
PastryNode |
SocketPastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId,
java.net.InetSocketAddress pAddress)
Method which creates a Pastry node from the next port with a randomly generated NodeId. |
PastryNode |
SocketPastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId,
java.net.InetSocketAddress pAddress,
boolean throwException)
|
PastryNode |
SocketPastryNodeFactory.newNode(NodeHandle bootstrap,
java.net.InetSocketAddress proxy)
Method which creates a Pastry node from the next port with a randomly generated NodeId. |
int |
SocketPastryNode.proximity(NodeHandle nh)
|
void |
SocketPastryNode.send(NodeHandle handle,
Message message)
|
void |
SocketPastryNode.testFireWall(NodeHandle bootstrap,
Continuation c,
int timeout)
|
void |
SocketPastryNode.testFireWall(NodeHandle bootstrap,
Continuation c,
int timeout,
int tries)
Try multiple times... |
| Uses of NodeHandle in rice.pastry.standard |
|---|
| Fields in rice.pastry.standard declared as NodeHandle | |
|---|---|
protected NodeHandle |
PeriodicLeafSetProtocol.localHandle
|
protected NodeHandle |
StandardJoinProtocol.localHandle
|
| Methods in rice.pastry.standard with parameters of type NodeHandle | |
|---|---|
void |
ConsistentJoinProtocol.addToLeafSet(NodeHandle nh)
Observes all NodeHandles added to LeafSet |
protected void |
StandardLeafSetProtocol.broadcast(LeafSet ls,
NodeHandle from)
Broadcast the local leaf set to all members of the given leaf set, plus the node from which the leaf set was received. |
protected boolean |
StandardLeafSetProtocol.checkLeafSet(LeafSet remotels,
NodeHandle from,
boolean notifyMissing)
Checks a received leafset advertisement for missing nodes |
Message |
PeriodicLeafSetProtocol.PLSPMessageDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
boolean |
PeriodicLeafSetProtocol.hasLease(NodeHandle nh)
Do we have a lease from this node? Returns true if nh is null. |
void |
PeriodicLeafSetProtocol.leafSetChange(NodeHandle nh,
boolean wasAdded)
|
void |
StandardLeafSetProtocol.leafSetChange(NodeHandle nh,
boolean wasAdded)
We manage the leafset now. |
protected boolean |
StandardLeafSetProtocol.mergeLeafSet(LeafSet remotels,
NodeHandle from)
Merge a remote leafset into our own |
void |
ConsistentJoinProtocol.nodeSetUpdate(NodeSetEventSource set,
NodeHandle handle,
boolean added)
|
void |
PartitionHandler.nodeSetUpdate(NodeSetEventSource nodeSetEventSource,
NodeHandle handle,
boolean added)
|
void |
PeriodicLeafSetProtocol.nodeSetUpdate(NodeSetEventSource nodeSetEventSource,
NodeHandle handle,
boolean added)
|
void |
PeriodicLeafSetProtocol.removeFromLeafsetIfPossible(NodeHandle nh)
|
void |
ConsistentJoinProtocol.sendTheMessage(NodeHandle nh,
boolean reply)
Sends a consistent join protocol message. |
| Constructors in rice.pastry.standard with parameters of type NodeHandle | |
|---|---|
ConsistentJoinMsg(InputBuffer buf,
NodeHandleFactory nhf,
NodeHandle sender)
|
|
ConsistentJoinProtocol(PastryNode ln,
NodeHandle lh,
RoutingTable rt,
LeafSet ls,
ReadyStrategy nextReadyStrategy)
|
|
ConsistentJoinProtocol(PastryNode ln,
NodeHandle lh,
RoutingTable rt,
LeafSet ls,
ReadyStrategy nextReadyStrategy,
MessageDeserializer md)
Constructor takes in the usual suspects. |
|
PeriodicLeafSetProtocol(PastryNode ln,
NodeHandle local,
LeafSet ls,
RoutingTable rt)
Builds a periodic leafset protocol |
|
StandardJoinProtocol(PastryNode ln,
NodeHandle lh,
RoutingTable rt,
LeafSet ls)
Constructor. |
|
StandardJoinProtocol(PastryNode ln,
NodeHandle lh,
RoutingTable rt,
LeafSet ls,
MessageDeserializer md)
|
|
StandardLeafSetProtocol(PastryNode ln,
NodeHandle local,
LeafSet ls,
RoutingTable rt)
|
|
| Uses of NodeHandle in rice.pastry.testing |
|---|
| Subclasses of NodeHandle in rice.pastry.testing | |
|---|---|
static class |
LeafSetTest.TestNodeHandle
|
| Methods in rice.pastry.testing that return NodeHandle | |
|---|---|
protected NodeHandle |
ClosestRegrTest.getBootstrap()
Get pastryNodes.last() to bootstrap with, or return null. |
protected NodeHandle |
DirectPastryRegrTest.getBootstrap(boolean firstNode)
Get pastryNodes.last() to bootstrap with, or return null. |
protected NodeHandle |
DistHelloWorld.getBootstrap(boolean firstNode)
Gets a handle to a bootstrap node. |
protected NodeHandle |
DistPastryRegrTest.getBootstrap(boolean firstNode)
Gets a handle to a bootstrap node. |
protected abstract NodeHandle |
PastryRegrTest.getBootstrap(boolean firstNode)
get a node handle to bootstrap from. |
| Methods in rice.pastry.testing with parameters of type NodeHandle | |
|---|---|
boolean |
HelloWorldApp.enrouteMessage(Message msg,
Id key,
NodeHandle nextHop,
SendOptions opt)
Invoked on intermediate nodes in routing path. |
boolean |
Ping.enrouteMessage(Message msg,
Id from,
NodeHandle nextHop,
SendOptions opt)
|
boolean |
PingClient.enrouteMessage(Message msg,
Id from,
NodeHandle nextHop,
SendOptions opt)
|
protected PastryNode |
PastryRegrTest.generateNode(NodeHandle bootstrap)
|
protected boolean |
DirectPastryRegrTest.isReallyAlive(NodeHandle nh)
get authoritative information about liveness of node. |
boolean |
DistPastryRegrTest.isReallyAlive(NodeHandle nh)
|
protected abstract boolean |
PastryRegrTest.isReallyAlive(NodeHandle nh)
determine whether this node is really alive. |
void |
HelloWorldApp.leafSetChange(NodeHandle nh,
boolean wasAdded)
Invoked upon change to leafset. |
void |
Ping.leafSetChange(NodeHandle nh,
boolean wasAdded)
|
void |
PingClient.leafSetChange(NodeHandle nh,
boolean wasAdded)
|
void |
RoutingTableTest.MyApp.routeMyMsgDirect(NodeHandle nh)
Called to directly send a message to the nh |
void |
HelloWorldApp.routeSetChange(NodeHandle nh,
boolean wasAdded)
Invoked upon change to routing table. |
void |
Ping.routeSetChange(NodeHandle nh,
boolean wasAdded)
|
void |
PingClient.routeSetChange(NodeHandle nh,
boolean wasAdded)
|
void |
RegrTestApp.routeSetChange(NodeHandle nh,
boolean wasAdded)
|
void |
RegrTestApp.update(NodeHandle nh,
boolean wasAdded)
|
| Constructors in rice.pastry.testing with parameters of type NodeHandle | |
|---|---|
HelloMsg(int addr,
NodeHandle src,
Id tgt,
int mid)
|
|
PingMessageNew(int pingAddress,
NodeHandle src,
Id tgt)
|
|
|
Rice Pastry API | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||