A B C D E F G H I J K L M N O P R S T U V W X _

A

abs(int) - Method in class rice.pastry.testing.LeafSetTest

accept(SelectionKey) - Method in class rice.pastry.wire.WireNodeHandle

Requeired by the SelectionKeyHandler interface.

accept(SelectionKey) - Method in class rice.pastry.wire.SocketManager

Specified by the SelectionKeyHandler interface.

accept(SelectionKey) - Method in interface rice.pastry.wire.SelectionKeyHandler

Method which is called when the key becomes acceptable.

accept(SelectionKey) - Method in class rice.pastry.wire.DatagramManager

Specified by the SelectionKeyHandler - should NEVER be called (since datagrams are never accepted).

accepted() - Method in class rice.pastry.join.JoinRequest

Returns true if the request was accepted, false if it hasn't yet.

acceptJoin(NodeHandle, LeafSet) - Method in class rice.pastry.join.JoinRequest

Accept join request.

AcknowledgementMessage - class rice.pastry.wire.messaging.datagram.AcknowledgementMessage.

Class which represents an "ack" packet in the UDP version of the pastry wire protocol.

AcknowledgementMessage(NodeId, NodeId, int, InetSocketAddress) - Constructor for class rice.pastry.wire.messaging.datagram.AcknowledgementMessage

Constructor.

activate(NodeId) - Method in class rice.pastry.rmi.RMINodeHandlePool

If given NodeId has a NodeHandle in the pool, then the latter is marked alive.

add(Id.Distance) - Method in class rice.pastry.Id

Returns an Id corresponding to this Id plus a given distance

add(PendingWrite) - Method in class rice.pastry.wire.DatagramTransmissionManager

Adds a pending write to the queue.

addChild(NodeHandle, NodeId) - Method in class rice.scribe.Scribe

Add a node as a child in the children table for a topic.

addChild(NodeHandle, NodeId) - Method in interface rice.scribe.IScribe

Add a node as a child in the children table for a topic.

addChild(NodeHandle, NodeId, Serializable) - Method in class rice.scribe.Scribe

Add a node as a child in the children table for a topic.

addChild(NodeHandle, ScribeMessage) - Method in class rice.scribe.Topic

Adds a node to the Set of children in this topic's multicast subtree rooted at this node

addChild(NodeHandle, ScribeMessage, Serializable) - Method in class rice.scribe.Topic

Adds a node to the Set of children in this topic's multicast subtree rooted at this node.

addChildForTopic(NodeHandle, NodeId) - Method in class rice.scribe.Scribe

Adds a child for a topic into the distinctChildrenTable.

addChildPastryNode(MultiRingPastryNode) - Method in class rice.pastry.multiring.MultiRingPastryNode

addChildToAlreadySentHBNodes(NodeId) - Method in class rice.scribe.Scribe

Adds a child to the list of nodes to which this node has already send a implicit HeartBeat message in the form of Publish message in this Heartbeat period.

addDistance(double) - Method in class rice.pastry.testing.PingTestRecord

addHop(NodeHandle) - Method in class rice.p2p.past.messaging.PastMessage

Method which is designed to be overridden by subclasses if they need to keep track of where they've been.

addHop(NodeHandle) - Method in class rice.p2p.past.messaging.LookupMessage

Method which is designed to be overridden by subclasses if they need to keep track of where they've been.

addHops(int) - Method in class rice.pastry.testing.PingTestRecord

addId(Id) - Method in class rice.pastry.IdSet

add a member

addId(Id) - Method in interface rice.p2p.commonapi.IdSet

add a member

addLeafSetObserver(Observer) - Method in class rice.pastry.PastryNode

Add a leaf set observer to the Pastry node.

addLeafSetObserver(Observer) - Method in class rice.pastry.multiring.MultiRingPastryNode

addMember(Id) - Method in class rice.pastry.IdSet

add a member

addObserver(Observer) - Method in class rice.pastry.leafset.LeafSet

Add observer method.

addObserver(Observer) - Method in class rice.pastry.dist.DistNodeHandle

addParentForTopic(NodeHandle, NodeId) - Method in class rice.scribe.Scribe

Adds a parent for a topic into the distinctParentTable.

addPending(ObjectInputStream, LocalNodeI) - Method in class rice.pastry.PendingLocalNodesList

Adds a pending LocalNode to the list of pending LocalNodes.

addPendingEvent(NodeId, int) - Method in class rice.rm.RMImpl

Used to insert entries to the m_pendingEvents hashtable

addPendingRange(NodeId, IdRange) - Method in class rice.rm.RMImpl

Used to insert a pending range to the m_pendingRanges hashtable

address - Variable in class rice.pastry.client.PastryAppl

address - Variable in class rice.pastry.dist.DistNodeHandle

Address - interface rice.pastry.messaging.Address.

The address interface.

addRing(RingId) - Method in class rice.pastry.multiring.MultiRingAppl

addRouteSetObserver(Observer) - Method in class rice.pastry.PastryNode

Add a route set observer to the Pastry node.

addRouteSetObserver(Observer) - Method in class rice.pastry.multiring.MultiRingPastryNode

addToId(Id.Distance) - Method in class rice.pastry.Id

Returns an Id corresponding to this Id plus a given distance

addToId(Id.Distance) - Method in interface rice.p2p.commonapi.Id

Returns an Id corresponding to this Id plus a given distance

addToScribe() - Method in class rice.scribe.Topic

Creates a topic reference on the current Scribe node.

afterSetLocalNode() - Method in class rice.pastry.NodeHandle

Method that can be overridden by handle to set isLocal, etc.

afterSetLocalNode() - Method in class rice.pastry.LocalNode

Method that can be overridden by handle to set isLocal, etc.

afterSetLocalNode() - Method in class rice.pastry.dist.DistNodeHandle

Method called from LocalNode after localnode is set to non-null.

alive - Variable in class rice.pastry.dist.DistNodeHandle

already_seen - Variable in class rice.scribe.messaging.MessageAnycast

Holds the list of NodeHandles already examined (used for DFS)

alreadySeenSize() - Method in class rice.scribe.messaging.MessageAnycast

Method returns the number of nodes visited during the DFS.

alternateRoutes(Id, int) - Method in class rice.pastry.routing.RoutingTable

Determines a set of alternate hops towards a given key.

alternateTest() - Method in class rice.pastry.testing.NodeIdUnit

anycast(NodeId) - Method in class rice.scribe.testing.DirectScribeMaintenanceTestApp

direct call to scribe for anycasting to a topic from the current node

anycast(NodeId) - Method in class rice.scribe.testing.BasicScribeRegrTestApp

direct call to scribe for anycasting to a topic from the current node.

anycast(NodeId, MessageAnycast, Credentials) - Method in class rice.scribe.Scribe

An application can create sub-classes of MessageAnycast type of messages and write their own handling functions so as to do some application-specific predicate searching.

anycast(NodeId, MessageAnycast, Credentials) - Method in interface rice.scribe.IScribe

An application can create sub-classes of MessageAnycast type of messages and write their own handling functions so as to take care of routing of these messages and also to handle cases where the anycast message reaches an intermediate node where there is no application running to take care of it.

anycast(NodeId, Serializable) - Method in class rice.scribe.testing.DistScribeRegrTestApp

direct call to scribe for anycasting to a topic from the current node.

anycast(NodeId, Serializable, Credentials) - Method in class rice.scribe.Scribe

Anycast to a group/topic.

anycast(NodeId, Serializable, Credentials) - Method in interface rice.scribe.IScribe

Anycast to a group/topic.

anycastHandler(ScribeMessage) - Method in class rice.pastry.multiring.MultiRingAppl

anycastHandler(ScribeMessage) - Method in interface rice.scribe.IScribeApp

Invoked by underlying scribe when it receives a anycast Message, to check if there is a local application which can take care of this anycast message.

anycastHandler(ScribeMessage) - Method in class rice.scribe.testing.DistScribeRegrTestApp

up-call invoked by Scribe when an anycast message is being handled.

anycastHandler(ScribeMessage) - Method in class rice.scribe.testing.DirectScribeMaintenanceTestApp

up-call invoked by Scribe when an anycast message is being handled.

anycastHandler(ScribeMessage) - Method in class rice.scribe.testing.BasicScribeRegrTestApp

up-call invoked by Scribe when an anycast message is being handled.

app - Variable in class rice.rm.RMImpl

Application that uses this Replica Manager.

Application - interface rice.p2p.commonapi.Application.

apps - Variable in class rice.pastry.PastryNode

assertEquals(String, Object, Object) - Method in class rice.p2p.commonapi.testing.DistCommonAPITest

Thows an exception if expected is not equal to actual.

assertEquals(String, String, Object, Object) - Method in class rice.past.testing.DistPASTRegrTest

Deprecated. Thows an exception if expected is not equal to actual.

assertLocalNode() - Method in class rice.pastry.NodeHandle

May be called from handle etc methods to ensure that local node has been set, either on construction or on deserialization/receivemsg.

assertLocalNode() - Method in interface rice.pastry.LocalNodeI

May be called from handle etc methods to ensure that local node has been set, either on construction or on deserialization/receivemsg.

assertLocalNode() - Method in class rice.pastry.LocalNode

May be called from handle etc methods to ensure that local node has been set, either on construction or on deserialization/receivemsg.

assertTrue(String, boolean) - Method in class rice.pastry.testing.LeafSetTest

Throws an exception if the test condition is not met.

assertTrue(String, boolean) - Method in class rice.p2p.commonapi.testing.DistCommonAPITest

Throws an exception if the test condition is not met.

assertTrue(String, String, boolean) - Method in class rice.past.testing.DistPASTRegrTest

Deprecated. Throws an exception if the test condition is not met.