|
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
|
Methods in rice.pastry that return NodeHandle | |
---|---|
NodeHandle |
NodeHandleFactory.coalesce(NodeHandle handle)
Needed for legacy java deserialization of NodeHanlde because we aren't given any other way to do this properly such as a protected constructor. |
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 |
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. |
Methods in rice.pastry that return types with arguments of type NodeHandle | |
---|---|
java.util.Iterator<NodeHandle> |
NodeSet.iterator()
|
Methods in rice.pastry with parameters of type NodeHandle | |
---|---|
NodeHandle |
NodeHandleFactory.coalesce(NodeHandle handle)
Needed for legacy java deserialization of NodeHanlde because we aren't given any other way to do this properly such as a protected constructor. |
abstract NodeHandle |
PastryNode.coalesce(NodeHandle newHandle)
|
abstract SocketRequestHandle |
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)
|
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. |
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 PMessageReceipt |
PastryNode.send(NodeHandle handle,
Message message,
PMessageNotification deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Integer> options)
Deliver message to the NodeHandle. |
void |
PastryNode.setElements(NodeHandle lh,
MessageDispatch md,
LeafSet ls,
RoutingTable rt,
Router router)
Combined accessor method for various members of PastryNode. |
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. |
Constructors in rice.pastry.client with parameters of type NodeHandle | |
---|---|
NodeIsNotReadyException(NodeHandle handle)
|
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 |
Fields in rice.pastry.direct with type parameters of type NodeHandle | |
---|---|
protected LivenessProvider<NodeHandle> |
NetworkSimulatorImpl.livenessProvider
|
protected BasicNetworkSimulator<NodeHandle,RawMessage> |
NetworkSimulatorImpl.simulator
|
Methods in rice.pastry.direct that return NodeHandle | |
---|---|
protected NodeHandle |
DirectPastryNodeFactory.getLocalHandle(TLPastryNode pn,
NodeHandleFactory handleFactory,
java.lang.Object localNodeData)
|
Methods in rice.pastry.direct that return types with arguments of type NodeHandle | |
---|---|
GenericNetworkSimulator<NodeHandle,RawMessage> |
NetworkSimulator.getGenericSimulator()
|
GenericNetworkSimulator<NodeHandle,RawMessage> |
NetworkSimulatorImpl.getGenericSimulator()
|
LivenessProvider<NodeHandle> |
NetworkSimulator.getLivenessProvider()
|
LivenessProvider<NodeHandle> |
NetworkSimulatorImpl.getLivenessProvider()
|
Methods in rice.pastry.direct with parameters of type NodeHandle | |
---|---|
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)
|
PastryNode |
DirectPastryNodeFactory.newNode(NodeHandle bootstrap)
Manufacture a new Pastry node. |
PastryNode |
DirectPastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId)
Manufacture a new Pastry node. |
void |
NetworkSimulator.notifySimulatorListenersReceived(Message m,
NodeHandle from,
NodeHandle to)
Call this when a message is received. |
void |
NetworkSimulatorImpl.notifySimulatorListenersReceived(Message m,
NodeHandle from,
NodeHandle to)
|
void |
NetworkSimulator.notifySimulatorListenersSent(Message m,
NodeHandle from,
NodeHandle to,
int delay)
Call this when a message is sent. |
void |
NetworkSimulatorImpl.notifySimulatorListenersSent(Message m,
NodeHandle from,
NodeHandle to,
int delay)
|
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 | |
---|---|
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 that return types with arguments of type NodeHandle | |
---|---|
java.util.List<NodeHandle> |
LeafSet.asList()
If overlaps() a NodeHandle may show up twice. |
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.pns |
---|
Fields in rice.pastry.pns with type parameters of type NodeHandle | |
---|---|
protected java.util.Hashtable<NodeHandle,java.lang.Integer> |
PNSApplication.pingCache
Hashtable which keeps track of temporary ping values, which are only used during the getNearest() method |
Methods in rice.pastry.pns that return NodeHandle | |
---|---|
NodeHandle[] |
PNSApplication.getNearest(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[] |
PNSApplication.sortedProximityCache()
|
Methods in rice.pastry.pns with parameters of type NodeHandle | |
---|---|
protected void |
PNSApplication.addToWaitingForLeafSet(NodeHandle handle,
Continuation<LeafSet,java.lang.Exception> c)
|
protected void |
PNSApplication.addToWaitingForRouteRow(NodeHandle handle,
int row,
Continuation<RouteSet[],java.lang.Exception> c)
|
LeafSet |
PNSApplication.getLeafSet(NodeHandle handle)
This method returns the remote leafset of the provided handle to the caller, in a protocol-dependent fashion. |
Cancellable |
PNSApplication.getLeafSet(NodeHandle handle,
Continuation<LeafSet,java.lang.Exception> c)
Non-blocking version. |
NodeHandle[] |
PNSApplication.getNearest(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. |
int |
PNSApplication.getProximity(NodeHandle handle)
This method determines and returns the proximity of the current local node the provided NodeHandle. |
void |
PNSApplication.getProximity(NodeHandle handle,
Continuation<java.lang.Integer,java.io.IOException> c)
Non-blocking version, no timeout. |
RouteSet[] |
PNSApplication.getRouteRow(NodeHandle handle,
short row)
This method returns the remote route row of the provided handle to the caller, in a protocol-dependent fashion. |
Cancellable |
PNSApplication.getRouteRow(NodeHandle handle,
short row,
Continuation<RouteSet[],java.lang.Exception> c)
Non-blocking version. |
protected int |
PNSApplication.proximity(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 |
void |
PNSApplication.proximityChanged(NodeHandle i,
int newProximity,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
protected boolean |
PNSApplication.removeFromWaitingForLeafSet(NodeHandle handle,
Continuation<LeafSet,java.lang.Exception> c)
|
protected boolean |
PNSApplication.removeFromWaitingForRouteRow(NodeHandle handle,
int row,
Continuation<RouteSet[],java.lang.Exception> c)
|
Method parameters in rice.pastry.pns with type arguments of type NodeHandle | |
---|---|
void |
PNSApplication.getNearHandles(java.util.Collection<NodeHandle> bootHandles,
Continuation<java.util.Collection<NodeHandle>,java.lang.Exception> deliverResultToMe)
|
void |
PNSApplication.getNearHandles(java.util.Collection<NodeHandle> bootHandles,
Continuation<java.util.Collection<NodeHandle>,java.lang.Exception> deliverResultToMe)
|
Uses of NodeHandle in rice.pastry.pns.messages |
---|
Methods in rice.pastry.pns.messages with parameters of type NodeHandle | |
---|---|
static LeafSetRequest |
LeafSetRequest.build(InputBuffer buf,
NodeHandle sender,
int dest)
|
static Message |
RouteRowRequest.build(InputBuffer buf,
NodeHandle sender,
int dest)
|
Constructors in rice.pastry.pns.messages with parameters of type NodeHandle | |
---|---|
LeafSetRequest(NodeHandle nodeHandle,
int dest)
|
|
RouteRowRequest(NodeHandle nodeHandle,
short index,
int dest)
|
|
RouteRowResponse(InputBuffer buf,
PastryNode localNode,
NodeHandle sender,
int dest)
|
|
RouteRowResponse(NodeHandle sender,
short index,
RouteSet[] row,
int address)
|
Uses of NodeHandle in rice.pastry.routing |
---|
Fields in rice.pastry.routing declared as NodeHandle | |
---|---|
NodeHandle |
RoutingTable.myNodeHandle
|
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.getDestinationHandle()
|
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. |
void |
RouteMessage.setDestinationHandle(NodeHandle handle)
|
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,
PastryNode pn,
NodeHandle destinationHandle,
byte serializeVersion)
|
|
RouteMessage(Id target,
Message msg,
NodeHandle firstHop,
byte serializeVersion)
Constructor. |
|
RouteMessage(Id target,
Message msg,
NodeHandle firstHop,
SendOptions opts,
byte serializeVersion)
Constructor. |
|
RouteMessage(Id target,
PRawMessage msg,
NodeHandle firstHop,
SendOptions opts,
byte serializeVersion)
|
|
RouteMessage(NodeHandle dest,
Message msg,
SendOptions opts,
byte serializeVersion)
Constructor. |
|
RouteSet(int maxSize,
int row,
int col,
PastryNode local,
NodeHandle initialVal)
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
|
Methods in rice.pastry.socket that return NodeHandle | |
---|---|
NodeHandle |
SocketNodeHandleFactory.coalesce(NodeHandle h)
|
NodeHandle |
SocketPastryNodeFactory.getLocalHandle(TLPastryNode pn,
NodeHandleFactory nhf,
java.lang.Object localNodeInfo)
|
NodeHandle |
SocketPastryNodeFactory.getNodeHandle(java.net.InetSocketAddress bootstrap)
|
NodeHandle |
SocketPastryNodeFactory.getNodeHandle(java.net.InetSocketAddress[] bootstraps,
int int1)
|
NodeHandle |
SocketPastryNodeFactory.getNodeHandle(java.net.InetSocketAddress bootstrap,
int i)
|
NodeHandle |
SocketNodeHandleFactory.readNodeHandle(InputBuffer buf)
|
Methods in rice.pastry.socket with parameters of type NodeHandle | |
---|---|
NodeHandle |
SocketNodeHandleFactory.coalesce(NodeHandle h)
|
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 the specified nodeId (or one generated from the NodeIdFactory if not specified) |
PastryNode |
SocketPastryNodeFactory.newNode(NodeHandle nodeHandle,
Id id,
java.net.InetSocketAddress proxyAddress)
Method which creates a Pastry node from the next port with the specified nodeId (or one generated from the NodeIdFactory if not specified) |
PastryNode |
SocketPastryNodeFactory.newNode(NodeHandle bootstrap,
java.net.InetSocketAddress proxy)
Method which creates a Pastry node from the next port with the specified nodeId (or one generated from the NodeIdFactory if not specified) |
Uses of NodeHandle in rice.pastry.standard |
---|
Fields in rice.pastry.standard declared as NodeHandle | |
---|---|
protected NodeHandle |
PeriodicLeafSetProtocol.localHandle
|
protected NodeHandle |
StandardJoinProtocol.localHandle
|
Fields in rice.pastry.standard with type parameters of type NodeHandle | |
---|---|
protected java.util.Map<NodeHandle,java.lang.Long> |
StandardRouter.lastTimeSentRouteTablePatch
We can end up causing a nasty feeback if we blast too many BRRs, so we're going to throttle. |
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. |
void |
RapidRerouter.livenessChanged(NodeHandle i,
int val,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
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)
|
protected void |
RapidRerouter.rerouteMe(RouteMessage rm,
NodeHandle oldDest,
java.lang.Exception ioe)
|
void |
ConsistentJoinProtocol.sendTheMessage(NodeHandle nh,
boolean reply)
Sends a consistent join protocol message. |
protected void |
RapidRerouter.sendTheMessage(RouteMessage rm,
NodeHandle handle)
|
protected void |
StandardRouter.sendTheMessage(RouteMessage rm,
NodeHandle handle)
|
Method parameters in rice.pastry.standard with type arguments of type NodeHandle | |
---|---|
void |
ProximityNeighborSelector.getNearHandles(java.util.Collection<NodeHandle> bootHandles,
Continuation<java.util.Collection<NodeHandle>,java.lang.Exception> deliverResultToMe)
|
void |
ProximityNeighborSelector.getNearHandles(java.util.Collection<NodeHandle> bootHandles,
Continuation<java.util.Collection<NodeHandle>,java.lang.Exception> deliverResultToMe)
|
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 LeafSet |
PartitionChecker.getLeafSet(NodeHandle nh)
|
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)
|
Uses of NodeHandle in rice.pastry.transport |
---|
Subclasses of NodeHandle in rice.pastry.transport | |
---|---|
class |
BogusNodeHandle
|
Fields in rice.pastry.transport with type parameters of type NodeHandle | |
---|---|
protected LivenessProvider<NodeHandle> |
TLPastryNode.livenessProvider
|
Methods in rice.pastry.transport that return NodeHandle | |
---|---|
NodeHandle |
TLPastryNode.coalesce(NodeHandle newHandle)
|
NodeHandle |
PMessageReceipt.getIdentifier()
|
NodeHandle |
PMessageReceiptImpl.getIdentifier()
|
protected abstract NodeHandle |
TransportPastryNodeFactory.getLocalHandle(TLPastryNode pn,
NodeHandleFactory handleFactory,
java.lang.Object localNodeData)
|
NodeHandle |
NodeHandleAdapter.getLocalIdentifier()
|
NodeHandle |
TLPastryNode.readNodeHandle(InputBuffer buf)
|
Methods in rice.pastry.transport that return types with arguments of type NodeHandle | |
---|---|
LivenessProvider<NodeHandle> |
TLPastryNode.getLivenessProvider()
|
ProximityProvider<NodeHandle> |
TLPastryNode.getProxProvider()
|
TransportLayer<NodeHandle,RawMessage> |
TLPastryNode.getTL()
|
SocketRequestHandle<NodeHandle> |
NodeHandleAdapter.openSocket(NodeHandle i,
SocketCallback<NodeHandle> deliverSocketToMe,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
MessageRequestHandle<NodeHandle,RawMessage> |
NodeHandleAdapter.sendMessage(NodeHandle i,
RawMessage m,
MessageCallback<NodeHandle,RawMessage> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
Methods in rice.pastry.transport with parameters of type NodeHandle | |
---|---|
boolean |
NodeHandleAdapter.checkLiveness(NodeHandle i,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
boolean |
TLPastryNode.checkLiveness(NodeHandle i,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
void |
NodeHandleAdapter.clearState(NodeHandle i)
|
void |
TLPastryNode.clearState(NodeHandle i)
|
NodeHandle |
TLPastryNode.coalesce(NodeHandle newHandle)
|
SocketRequestHandle |
TLPastryNode.connect(NodeHandle i2,
AppSocketReceiver deliverSocketToMe,
PastryAppl appl,
int timeout)
|
void |
TLPastryNode.doneNode(NodeHandle[] bootstrap)
|
int |
NodeHandleAdapter.getLiveness(NodeHandle i,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
int |
TLPastryNode.getLiveness(NodeHandle i,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
void |
TLPastryNode.initiateJoin(NodeHandle[] bootstrap)
|
void |
TLPastryNode.livenessChanged(NodeHandle i,
int val,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
void |
TLPastryNode.messageReceived(NodeHandle i,
RawMessage m,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
protected void |
TLPastryNode.notifyLivenessListeners(NodeHandle i,
int val,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
SocketRequestHandle<NodeHandle> |
NodeHandleAdapter.openSocket(NodeHandle i,
SocketCallback<NodeHandle> deliverSocketToMe,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
int |
NodeHandleAdapter.proximity(NodeHandle i)
|
int |
TLPastryNode.proximity(NodeHandle nh)
|
void |
TLPastryNode.proximityChanged(NodeHandle i,
int val,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
PMessageReceipt |
TLPastryNode.send(NodeHandle handle,
Message msg,
PMessageNotification deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Integer> tempOptions)
|
MessageRequestHandle<NodeHandle,RawMessage> |
NodeHandleAdapter.sendMessage(NodeHandle i,
RawMessage m,
MessageCallback<NodeHandle,RawMessage> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Integer> options)
|
void |
TLPastryNode.setSocketElements(NodeHandle localhandle,
int lsmf,
int rsmf,
TransportLayer<NodeHandle,RawMessage> tl,
LivenessProvider<NodeHandle> livenessProvider,
ProximityProvider<NodeHandle> proxProvider,
Deserializer deserializer,
NodeHandleFactory handleFactory,
Bootstrapper boot)
|
Constructor parameters in rice.pastry.transport with type arguments of type NodeHandle | |
---|---|
SocketAdapter(P2PSocket<NodeHandle> socket,
Environment env)
|
|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |