|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Id in org.mpisws.p2p.testing.transportlayer.replay |
---|
Methods in org.mpisws.p2p.testing.transportlayer.replay with parameters of type Id | |
---|---|
static void |
Replayer.replayNode(Id id,
java.net.InetSocketAddress addr,
java.net.InetSocketAddress bootaddress,
long startTime,
long randSeed)
|
Constructors in org.mpisws.p2p.testing.transportlayer.replay with parameters of type Id | |
---|---|
Replayer(Id id,
java.net.InetSocketAddress addr,
java.net.InetSocketAddress bootaddress,
long startTime,
long randSeed)
|
Uses of Id in rice.pastry |
---|
Fields in rice.pastry declared as Id | |
---|---|
protected Id |
PastryNode.myNodeId
|
Methods in rice.pastry that return Id | |
---|---|
Id |
Id.add(Id.Distance offset)
Returns an Id corresponding to this Id plus a given distance |
static Id |
Id.build()
Constructor. |
static Id |
Id.build(byte[] material)
Constructor. |
static Id |
Id.build(char[] chars,
int offset,
int length)
Constructor, which takes the output of a toStringFull() and converts it back into an Id. |
static Id |
Id.build(InputBuffer buf)
Id (Version 0) +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + 160 Bit + + + + + + + + + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ |
static Id |
Id.build(int[] material)
Constructor. |
static Id |
Id.build(java.lang.String hex)
Constructor, which takes the output of a toStringFull() and converts it back into an Id. |
Id |
NodeIdFactory.generateNodeId()
Generates a nodeId. |
Id |
Id.getAlternateId(int num,
int b,
int i)
produces a set of ids (keys) that are evenly distributed around the id ring. |
Id |
Id.getCCW()
gets the Id just counterclockwise from this |
Id |
IdRange.getCCW()
get counterclockwise edge of range |
Id |
Id.getCW()
gets the Id just clockwise from this |
Id |
IdRange.getCW()
get clockwise edge of range |
Id |
Id.getDomainPrefix(int row,
int column,
int suffixDigit,
int b)
produces a Id whose prefix up to row is identical to this, followed by a digit with value column, followed by a suffix of digits with value suffixDigits. |
abstract Id |
NodeHandle.getNodeId()
Gets the nodeId of this Pastry node. |
Id |
PastryNode.getNodeId()
|
static Id |
Id.makeRandomId(java.util.Random rng)
Creates a random Id. |
static Id |
Id.makeRandomId(RandomSource rng)
|
Id |
IdSet.maxMember()
return the largest member id |
Id |
IdSet.minMember()
return the smallest member id |
protected static Id |
Id.resolve(java.util.WeakHashMap map,
Id id)
Method which performs the coalescing and interaction with the weak hash map |
Methods in rice.pastry with parameters of type Id | |
---|---|
void |
IdSet.addMember(Id id)
add a member |
boolean |
Id.clockwise(Id nid)
Checks to see if the Id nid is clockwise or counterclockwise from this, on the ring. |
boolean |
IdRange.contains(Id key)
test if a given key lies within this range |
Id.Distance |
Id.distance(Id nid)
Returns the shorter numerical distance on the ring between a pair of Ids. |
Id.Distance |
Id.distance(Id nid,
Id.Distance d)
|
boolean |
Id.equals(Id nid)
Equivalence relation for Ids. |
NodeHandle |
NodeSet.get(Id nid)
Finds the NodeHandle associated with a NodeId. |
NodeHandle |
NodeSetI.get(Id nid)
Finds the NodeHandle associated with the NodeId. |
int |
NodeSet.getIndex(Id nid)
Gets the index of the element with the given node id. |
int |
NodeSetI.getIndex(Id nid)
Gets the index of the element with the given node id. |
int |
Id.indexOfMSDB(Id nid)
Returns the index of the most significant differing bit (MSDB). |
int |
Id.indexOfMSDD(Id nid,
int base)
Returns the index of the most significant different digit (MSDD) in a given base. |
boolean |
Id.isBetween(Id ccw,
Id cw)
Checks if this Id is between two given ids ccw (inclusive) and cw (exclusive) on the circle |
boolean |
PastryNode.isClosest(Id key)
Called by the layered Pastry application to check if the local pastry node is the one that is currently closest to the object key id. |
boolean |
IdSet.isMember(Id id)
test membership |
Id.Distance |
Id.longDistance(Id nid)
Returns the longer numerical distance on the ring between a pair of Ids. |
abstract PastryNode |
PastryNodeFactory.newNode(Id nodeId)
|
abstract PastryNode |
PastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId)
Deprecated. use newNode(nodeId) then call PastryNode.boot(address); |
NodeHandle |
NodeSet.remove(Id nid)
Removes a node id and its handle from the set. |
void |
IdSet.removeMember(Id id)
remove a member |
protected static Id |
Id.resolve(java.util.WeakHashMap map,
Id id)
Method which performs the coalescing and interaction with the weak hash map |
IdSet |
IdSet.subSet(Id from,
Id to)
return a subset of this set, consisting of the member ids in a given range |
Constructors in rice.pastry with parameters of type Id | |
---|---|
IdRange(Id ccw,
Id cw)
Constructor. |
|
PastryNode(Id id,
Environment e)
Constructor, with NodeId. |
Uses of Id in rice.pastry.client |
---|
Methods in rice.pastry.client that return Id | |
---|---|
Id |
PastryAppl.getNodeId()
Gets the node id associated with this client. |
Methods in rice.pastry.client with parameters of type Id | |
---|---|
abstract void |
CommonAPIAppl.deliver(Id key,
Message msg)
Called by pastry when a message arrives for this application. |
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. |
boolean |
PastryAppl.isClosest(Id key)
Called by the layered Pastry application to check if the local pastry node is the one that is currently closest to the object key id. |
NodeSet |
CommonAPIAppl.localLookup(Id key,
int num,
boolean safe)
This method produces a list of nodes that can be used as next hops on a route towards key, such that the resulting route satisfies the overlay protocol's bounds on the number of hops taken. |
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. |
NodeSet |
CommonAPIAppl.replicaSet(Id key,
int max_rank)
This method returns an ordered set of nodehandles on which replicas of the object with key can be stored. |
void |
CommonAPIAppl.route(Id key,
Message msg,
NodeHandle hint)
This operation forwards a message towards the root of key. |
void |
PastryAppl.routeMsg(Id key,
Message msg,
SendOptions opt)
Routes a message to the live node D with nodeId numerically closest to key (at the time of delivery). |
MessageReceipt |
PastryAppl.routeMsg(Id key,
Message msg,
SendOptions opt,
DeliveryNotification deliverAckToMe)
|
Uses of Id in rice.pastry.commonapi |
---|
Methods in rice.pastry.commonapi with parameters of type Id | |
---|---|
boolean |
PastryEndpoint.enrouteMessage(Message msg,
Id key,
NodeHandle nextHop,
SendOptions opt)
|
Uses of Id in rice.pastry.direct |
---|
Methods in rice.pastry.direct that return Id | |
---|---|
Id |
DirectNodeHandle.getNodeId()
Gets the NodeId attribute of the DirectNodeHandle object |
Methods in rice.pastry.direct with parameters of type Id | |
---|---|
PastryNode |
DirectPastryNodeFactory.newNode(Id nodeId)
Manufacture a new Pastry node. |
PastryNode |
DirectPastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId)
|
Uses of Id in rice.pastry.dist |
---|
Fields in rice.pastry.dist declared as Id | |
---|---|
protected Id |
DistNodeHandle.nodeId
|
Methods in rice.pastry.dist that return Id | |
---|---|
Id |
DistNodeHandle.getNodeId()
Gets the nodeId of this Pastry node. |
Constructors in rice.pastry.dist with parameters of type Id | |
---|---|
DistNodeHandle(Id nodeId)
Constructor |
Uses of Id in rice.pastry.leafset |
---|
Methods in rice.pastry.leafset with parameters of type Id | |
---|---|
NodeHandle |
SimilarSet.get(Id nid)
Finds the NodeHandle associated with the Id. |
int |
SimilarSet.getIndex(Id nid)
Gets the index of the element with the given node id. |
boolean |
LeafSet.member(Id nid)
Verifies if the set contains this particular id. |
boolean |
SimilarSet.member(Id nid)
|
int |
LeafSet.mostSimilar(Id nid)
Numerically closests node to a given a node in the leaf set. |
int |
SimilarSet.mostSimilar(Id nid)
Impl that doesn't produce garbage Numerically closest node to a given a node. |
NodeHandle |
SimilarSet.remove(Id nid)
Removes a node id and its handle from the set. |
NodeSet |
LeafSet.replicaSet(Id key,
int max)
compute an ordered set of nodes, in order of numerical closeness to a given key |
Uses of Id in rice.pastry.leafset.testing |
---|
Methods in rice.pastry.leafset.testing that return Id | |
---|---|
Id |
MergeTest.TestNodeHandle.getNodeId()
|
Constructors in rice.pastry.leafset.testing with parameters of type Id | |
---|---|
MergeTest.TestNodeHandle(Id id)
|
Uses of Id in rice.pastry.messaging |
---|
Methods in rice.pastry.messaging that return Id | |
---|---|
Id |
Message.getSenderId()
Get sender Id. |
Uses of Id in rice.pastry.peerreview |
---|
Fields in rice.pastry.peerreview declared as Id | |
---|---|
Id |
FetchLeafsetRequest.subject
Stored in the RouteMessage |
Id |
FetchLeafsetResponse.subject
|
Fields in rice.pastry.peerreview with type parameters of type Id | |
---|---|
protected java.util.Map<Id,Tuple<TimerTask,java.util.Collection<Continuation<java.util.Collection<NodeHandle>,java.lang.Exception>>>> |
FetchLeafsetApp.pendingLookups
|
Methods in rice.pastry.peerreview that return types with arguments of type Id | |
---|---|
PeerReviewCallback<TransportLayerNodeHandle<MultiInetSocketAddress>,Id> |
PeerReviewCallbackImpl.getReplayInstance(Verifier<TransportLayerNodeHandle<MultiInetSocketAddress>> v)
Construct a PastryNode down to my layer (figure out how to borrow the code from the PastryNodeFactory) Construct a PeerReviewCallbackImpl with the PastryNode/Verifier Construct the layers above self, attach them appropriately. |
Methods in rice.pastry.peerreview with parameters of type Id | |
---|---|
void |
FetchLeafsetApp.getNeighbors(Id subject,
Continuation<java.util.Collection<NodeHandle>,java.lang.Exception> continuation)
Add to the pendingLookups. |
void |
PeerReviewCallbackImpl.getWitnesses(Id subject,
WitnessListener<TransportLayerNodeHandle<MultiInetSocketAddress>,Id> callback)
|
void |
PeerReviewCallbackImpl.notifyCertificateAvailable(Id id)
|
void |
PeerReviewCallbackImpl.notifyStatusChange(Id id,
int newStatus)
|
Method parameters in rice.pastry.peerreview with type arguments of type Id | |
---|---|
void |
PeerReviewCallbackImpl.getWitnesses(Id subject,
WitnessListener<TransportLayerNodeHandle<MultiInetSocketAddress>,Id> callback)
|
Constructors in rice.pastry.peerreview with parameters of type Id | |
---|---|
FetchLeafsetRequest(NodeHandle sender,
Id subject)
|
|
FetchLeafsetResponse(Id subject,
LeafSet leafSet)
|
Uses of Id in rice.pastry.routing |
---|
Fields in rice.pastry.routing declared as Id | |
---|---|
protected Id |
NoLegalRouteToMakeProgressException.target
|
Methods in rice.pastry.routing that return Id | |
---|---|
Id |
NoLegalRouteToMakeProgressException.getTarget()
|
Id |
RouteMessage.getTarget()
Gets the target node id of this message. |
Methods in rice.pastry.routing with parameters of type Id | |
---|---|
NodeSet |
RoutingTable.alternateRoutes(Id key,
int max)
Determines a set of alternate hops towards a given key. |
java.util.Iterator<NodeHandle> |
RoutingTable.alternateRoutesIterator(Id key)
More efficient implementation, but less accurate, doesn't include lower levels of rt. |
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.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. |
RouteSet |
RoutingTable.getBestEntry(Id key)
Gets the set of handles that match at least one more digit of the key than the local Id. |
java.util.Iterator<NodeHandle> |
Router.getBestRoutingCandidates(Id key)
Returns an ordered list of the best candidates for the next to the key. |
int |
RouteSet.getIndex(Id nid)
Get the index of the node id. |
boolean |
RouteSet.member(Id nid)
Membership test. |
NodeHandle |
RouteSet.remove(Id nid)
Removes a node from a set. |
Constructors in rice.pastry.routing with parameters of type Id | |
---|---|
NoLegalRouteToMakeProgressException(Id target)
|
|
RouteMessage(Id target,
int auxAddress,
NodeHandle prev,
InputBuffer buf,
byte priority,
PastryNode pn,
NodeHandle destinationHandle,
byte serializeVersion)
|
|
RouteMessage(Id target,
Message msg,
byte serializeVersion)
Constructor. |
|
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,
Message msg,
SendOptions opts,
byte serializeVersion)
Constructor. |
|
RouteMessage(Id target,
PRawMessage msg,
NodeHandle firstHop,
SendOptions opts,
byte serializeVersion)
|
Uses of Id in rice.pastry.socket |
---|
Methods in rice.pastry.socket with parameters of type Id | |
---|---|
protected SocketNodeHandle |
SPNFIdentitySerializer.buildSNH(InputBuffer buf,
MultiInetSocketAddress i,
long epoch,
Id nid)
|
protected Environment |
SocketPastryNodeFactory.cloneEnvironment(Environment rootEnvironment,
Id nodeId)
|
protected LogManager |
SocketPastryNodeFactory.cloneLogManager(Environment rootEnvironment,
Id nodeId)
|
protected Processor |
SocketPastryNodeFactory.cloneProcessor(Environment rootEnvironment,
Id nodeId,
LogManager lman)
|
protected RandomSource |
SocketPastryNodeFactory.cloneRandomSource(Environment rootEnvironment,
Id nodeId,
LogManager lman)
|
protected SelectorManager |
SocketPastryNodeFactory.cloneSelectorManager(Environment rootEnvironment,
Id nodeId,
LogManager lman)
|
SocketNodeHandle |
SocketNodeHandleFactory.getNodeHandle(MultiInetSocketAddress i,
long epoch,
Id id)
This is kind of weird, may need to rethink this. |
PastryNode |
SocketPastryNodeFactory.newNode(Id id)
|
PastryNode |
SocketPastryNodeFactory.newNode(Id nodeId,
java.net.InetSocketAddress pAddress)
This method uses the pAddress as the outer address if it's non-null. |
PastryNode |
SocketPastryNodeFactory.newNode(Id nodeId,
MultiInetSocketAddress pAddress)
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,
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) |
protected void |
SocketPastryNodeFactory.newNodeSelector(Id nodeId,
MultiInetSocketAddress proxyAddress,
Continuation<PastryNode,java.io.IOException> deliverResultToMe,
java.util.Map<java.lang.String,java.lang.Object> initialVars)
Only call this on the selector thread. |
Constructors in rice.pastry.socket with parameters of type Id | |
---|---|
SocketNodeHandle(MultiInetSocketAddress eisa,
long epoch,
Id id,
PastryNode node)
|
Uses of Id in rice.pastry.socket.internet |
---|
Methods in rice.pastry.socket.internet with parameters of type Id | |
---|---|
protected void |
InternetPastryNodeFactory.findExternalAddress(Id nodeId,
java.net.InetSocketAddress bindAddress,
Continuation<PastryNode,java.io.IOException> deliverResultToMe)
Finds the external address, calls openFirewallPort() |
protected void |
InternetPastryNodeFactory.findExternalAddressHelper(Id nodeId,
java.net.InetSocketAddress bindAddress,
Continuation<PastryNode,java.io.IOException> deliverResultToMe,
java.util.Collection<java.net.InetSocketAddress> myProbeAddresses)
|
protected void |
InternetPastryNodeFactory.findExternalNodes(Id nodeId,
java.net.InetSocketAddress bindAddress,
java.util.Collection<java.net.InetSocketAddress> nonInternetRoutable,
Continuation<PastryNode,java.io.IOException> deliverResultToMe)
Probe the internalAddresses to get more externalAddresses, then call findExternalAddressHelper |
protected void |
InternetPastryNodeFactory.newNodeSelector(Id nodeId,
MultiInetSocketAddress proxyAddress,
Continuation<PastryNode,java.io.IOException> deliverResultToMe,
java.util.Map<java.lang.String,java.lang.Object> initialVars)
This is where the action takes place. |
protected void |
InternetPastryNodeFactory.openFirewallPort(Id nodeId,
java.net.InetSocketAddress bindAddress,
Continuation<PastryNode,java.io.IOException> deliverResultToMe,
java.net.InetAddress externalAddress,
int requestedPort)
Attempt to open the firewall on the specified port if it doesn't work, uses Rendezvous |
protected void |
InternetPastryNodeFactory.verifyConnectivityThenMakeNewNode(Id nodeId,
MultiInetSocketAddress proxyAddress,
Continuation<PastryNode,java.io.IOException> deliverResultToMe)
Verifies the connectivity (if necessary), then calls super.newNodeSelector() if connectivity fails, then uses Rendezvous |
Uses of Id in rice.pastry.socket.nat.rendezvous |
---|
Methods in rice.pastry.socket.nat.rendezvous with parameters of type Id | |
---|---|
protected SocketNodeHandle |
RendezvousSPNFIdentitySerializer.buildSNH(InputBuffer buf,
MultiInetSocketAddress i,
long epoch,
Id nid)
|
SocketNodeHandle |
RendezvousSNHFactory.getNodeHandle(MultiInetSocketAddress i,
long epoch,
Id id)
|
SocketNodeHandle |
RendezvousSNHFactory.getNodeHandle(MultiInetSocketAddress i,
long epoch,
Id id,
byte contactState)
|
protected void |
RendezvousSocketPastryNodeFactory.newNodeSelector(Id nodeId,
MultiInetSocketAddress proxyAddress,
Continuation<PastryNode,java.io.IOException> deliverResultToMe,
java.util.Map<java.lang.String,java.lang.Object> initialVars,
boolean firewalled)
Can override the contactState on a per-node basis |
protected void |
RendezvousSocketPastryNodeFactory.newNodeSelector(Id nodeId,
MultiInetSocketAddress proxyAddress,
Continuation<PastryNode,java.io.IOException> deliverResultToMe,
java.util.Map<java.lang.String,java.lang.Object> initialVars,
byte contactState)
Can override the contactState on a per-node basis |
Uses of Id in rice.pastry.standard |
---|
Methods in rice.pastry.standard that return Id | |
---|---|
Id |
CertifiedNodeIdFactory.generateNodeId()
generate a nodeId |
Id |
IPNodeIdFactory.generateNodeId()
generate a nodeId multiple invocations result in a deterministic series of randomized NodeIds, seeded by the IP address of the local host. |
Id |
RandomNodeIdFactory.generateNodeId()
generate a nodeId |
Methods in rice.pastry.standard with parameters of type Id | |
---|---|
static void |
CertifiedNodeIdFactory.generateCertificate(Id id,
java.io.OutputStream os,
java.security.PrivateKey key)
Method which generates a certificate given the nodeid, location, and private key |
java.util.Iterator<NodeHandle> |
StandardRouter.getBestRoutingCandidates(Id target)
|
protected java.util.Iterator<NodeHandle> |
StandardRouter.getBestRoutingCandidates(Id target,
int lsPos,
boolean leafSetOnly)
|
Uses of Id in rice.pastry.testing |
---|
Fields in rice.pastry.testing declared as Id | |
---|---|
Id |
PastryRegrTest.lastNode
|
Methods in rice.pastry.testing that return Id | |
---|---|
Id |
IdRangeUnit.createIdWithPrefix(byte b)
|
Id |
NodeIdUnit.createNodeId()
|
Id |
LeafSetTest.TestNodeHandle.getNodeId()
|
Id |
PingMessageNew.getSource()
|
Methods in rice.pastry.testing with parameters of type Id | |
---|---|
IdRange |
IdRangeUnit.createIdRangeEndingIn(Id cw)
|
IdRange |
IdRangeUnit.createIdRangeStartingWith(Id ccw)
|
void |
RegrTestApp.deliver(Id key,
Message msg)
Makes sure the message was delivered to the correct node by crossrefrencing the sorted nodes list in the simulator. |
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)
|
void |
RegrTestApp.sendMsg(Id nid)
|
void |
Ping.sendPing(Id nid)
|
void |
PingClient.sendPing(Id nid)
|
void |
PingClient.sendTrace(Id nid)
|
void |
RegrTestApp.sendTrace(Id nid)
|
Constructors in rice.pastry.testing with parameters of type Id | |
---|---|
LeafSetTest.TestNodeHandle(Id id)
|
|
PingMessageNew(int pingAddress,
NodeHandle src,
Id tgt)
|
Uses of Id in rice.pastry.transport |
---|
Methods in rice.pastry.transport that return Id | |
---|---|
Id |
BogusNodeHandle.getNodeId()
|
|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |