Rice Pastry API

Uses of Class
rice.pastry.NodeHandle

Packages that use NodeHandle
rice.p2p.commonapi.testing   
rice.p2p.multiring.testing   
rice.pastry   
rice.pastry.client   
rice.pastry.commonapi   
rice.pastry.direct   
rice.pastry.dist   
rice.pastry.join   
rice.pastry.leafset   
rice.pastry.leafset.testing   
rice.pastry.messaging   
rice.pastry.pns   
rice.pastry.pns.messages   
rice.pastry.routing   
rice.pastry.socket   
rice.pastry.standard   
rice.pastry.testing   
rice.pastry.transport   
 

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)
           
 

Method parameters in rice.pastry.transport with type arguments of type NodeHandle
 void NodeHandleAdapter.addLivenessListener(LivenessListener<NodeHandle> name)
           
 void TLPastryNode.addLivenessListener(LivenessListener<NodeHandle> name)
           
 void NodeHandleAdapter.addProximityListener(ProximityListener<NodeHandle> listener)
           
 void TLPastryNode.addProximityListener(ProximityListener<NodeHandle> listener)
           
 void TLPastryNode.doneNode(java.util.Collection<NodeHandle> bootstrap)
          Called after the node is initialized.
 void TLPastryNode.incomingSocket(P2PSocket<NodeHandle> s)
           
 SocketRequestHandle<NodeHandle> NodeHandleAdapter.openSocket(NodeHandle i, SocketCallback<NodeHandle> deliverSocketToMe, java.util.Map<java.lang.String,java.lang.Integer> options)
           
 void AppSocketReceiverWrapper.receiveException(P2PSocket<NodeHandle> s, java.io.IOException ioe)
           
 void AppSocketReceiverWrapper.receiveSelectResult(P2PSocket<NodeHandle> s, boolean canRead, boolean canWrite)
           
 boolean NodeHandleAdapter.removeLivenessListener(LivenessListener<NodeHandle> name)
           
 boolean TLPastryNode.removeLivenessListener(LivenessListener<NodeHandle> name)
           
 boolean NodeHandleAdapter.removeProximityListener(ProximityListener<NodeHandle> listener)
           
 boolean TLPastryNode.removeProximityListener(ProximityListener<NodeHandle> listener)
           
 MessageRequestHandle<NodeHandle,RawMessage> NodeHandleAdapter.sendMessage(NodeHandle i, RawMessage m, MessageCallback<NodeHandle,RawMessage> deliverAckToMe, java.util.Map<java.lang.String,java.lang.Integer> options)
           
 void NodeHandleAdapter.setCallback(TransportLayerCallback<NodeHandle,RawMessage> callback)
           
 void NodeHandleAdapter.setErrorHandler(ErrorHandler<NodeHandle> handler)
           
 void PMessageReceiptImpl.setInternal(MessageRequestHandle<NodeHandle,RawMessage> name)
           
 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)
           
 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)
           
 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

Copyright © 2001-2005 - Rice Pastry.


Imprint-Dataprotection