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

A

AbstractSubscribeMessage - class rice.p2p.scribe.messaging.AbstractSubscribeMessage.

AbstractSubscribeMessage(NodeHandle, Topic, int) - Constructor for class rice.p2p.scribe.messaging.AbstractSubscribeMessage

Constructor which takes a unique integer Id

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.

Address - interface rice.pastry.messaging.Address.

The address interface.

AnycastMessage - class rice.p2p.scribe.messaging.AnycastMessage.

AnycastMessage(NodeHandle, Topic, ScribeContent) - Constructor for class rice.p2p.scribe.messaging.AnycastMessage

Constructor which takes a unique integer Id

Application - interface rice.p2p.commonapi.Application.

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

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

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

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.SocketManager

Specified by the SelectionKeyHandler interface.

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

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

Requeired by the SelectionKeyHandler interface.

accept(File) - Method in class rice.pastry.wire.testing.WireFileFilter

acceptAnycast - Variable in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

Whether or not this client should accept anycasts

acceptAnycast(boolean) - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

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

Accept join request.

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

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

acquireFileDescriptor() - Static method in class rice.pastry.wire.Wire

acquireFileDescriptors(int) - Static method in class rice.pastry.wire.Wire

actualReceiver - Variable in class rice.pastry.testing.HelloMsg

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.

add(MessageDigest) - Method in class rice.pastry.wire.testing.WireFileProcessor.ObjPair

add(WireFileProcessor.Pair) - Method in class rice.pastry.wire.testing.WireFileProcessor.Pair

addChild(Topic, NodeHandle) - Method in interface rice.p2p.scribe.Scribe

Adds a child to the given topic

addChild(NodeHandle) - Method in class rice.p2p.scribe.ScribeImpl.TopicManager

Adds a feature to the Child attribute of the TopicManager object

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

Adds a child to the given 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) - Method in class rice.scribe.Scribe

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.

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.

addClient(ScribeClient) - Method in class rice.p2p.scribe.ScribeImpl.TopicManager

Adds a feature to the Client attribute of the TopicManager object

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

addFirst(NodeHandle) - Method in class rice.p2p.scribe.messaging.AnycastMessage

Adds a node the the front of the to-visit list

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.

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.

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

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

add a member

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

add a member

addLast(NodeHandle) - Method in class rice.p2p.scribe.messaging.AnycastMessage

Adds a node the the end of the to-visit list

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

Add a leaf set observer to the Pastry node.

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

add a member

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

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

Add observer method.

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

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

Add a route set observer to the Pastry node.

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

Returns an Id corresponding to this Id plus a given distance

addToId(Id.Distance) - Method in class rice.pastry.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.

addToTable(int, MessageDigest) - Method in class rice.pastry.wire.testing.WireFileProcessor

addVisited(NodeHandle) - Method in class rice.p2p.scribe.messaging.AnycastMessage

Adds a node to the visited list

addWireLimitationListener(WireLimitatioinListener) - Static method in class rice.pastry.wire.Wire

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

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

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

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

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

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

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

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

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

allNodesCreated() - Method in class rice.pastry.testing.DistHelloWorldMultiThread

allowSubscribe(SubscribeMessage, ScribeClient[], NodeHandle[]) - Method in class rice.p2p.scribe.ScribePolicy.DefaultScribePolicy

This method always return true;

allowSubscribe(SubscribeMessage, ScribeClient[], NodeHandle[]) - Method in class rice.p2p.scribe.ScribePolicy.LimitedScribePolicy

This method returns (children.length < maxChildren-1);

allowSubscribe(SubscribeMessage, ScribeClient[], NodeHandle[]) - Method in interface rice.p2p.scribe.ScribePolicy

This method is called when the newChild is about to become our child, and the policy should return whether or not the child should be allowed to become our child.

allowSubscribe - Variable in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribePolicy

allowSubscribe(boolean) - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribePolicy

allowSubscribe(SubscribeMessage, ScribeClient[], NodeHandle[]) - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribePolicy

allowSubscribe(SubscribeMessage, ScribeClient[], NodeHandle[]) - Method in class rice.p2p.splitstream.SplitStreamScribePolicy

This method implements the "locating parent" algorithm of SplitStream.

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(Topic, ScribeContent) - Method in interface rice.p2p.scribe.Scribe

Anycasts the given content to a member of the given topic

anycast(Topic, ScribeContent) - Method in interface rice.p2p.scribe.ScribeClient

This method is invoked when an anycast is received for a topic which this client is interested in.

anycast(Topic, ScribeContent) - Method in class rice.p2p.scribe.ScribeImpl

Anycasts the given content to a member of the given topic

anycast(Topic, ScribeContent) - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

DESCRIBE THE METHOD

anycast(Topic, ScribeContent) - Method in class rice.p2p.splitstream.Stripe

This method is invoked when an anycast is received for a topic which this client is interested in.

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

Anycast to a group/topic.

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, Credentials) - Method in class rice.scribe.Scribe

Anycast to a group/topic.

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) - Method in class rice.scribe.testing.BasicScribeRegrTestApp

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

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

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

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

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

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.BasicScribeRegrTestApp

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.DistScribeRegrTestApp

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

anycastMessages - Variable in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

The publish messages received so far

app - Variable in class rice.rm.RMImpl

Application that uses this Replica Manager.

application - Variable in class rice.pastry.commonapi.PastryEndpoint

apps - Variable in class rice.pastry.PastryNode

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

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.LocalNode

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.NodeHandle

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.p2p.commonapi.testing.CommonAPITest

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.

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

Throws an exception if the test condition is not met.

attachChannel(ChannelId) - Method in interface rice.p2p.splitstream.SplitStream

A SplitStream application calls this method to join a channel.

attachChannel(ChannelId) - Method in class rice.p2p.splitstream.SplitStreamImpl

This method is used by peers who wish to listen to content distributed by some other peer using SplitStream.

B

BEGIN_ACK_NUM - Static variable in class rice.pastry.wire.DatagramTransmissionManager

the first 'ack' number to use

BFS(NodeId) - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

This does the Breadth First Traversal of the multicast tree for a topic.

BOOTSTRAP_HOST - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

BOOTSTRAP_PORT - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

BUFFER_SIZE - Static variable in class rice.pastry.messaging.MessageDispatch

BasicScribeRegrTest - class rice.scribe.testing.BasicScribeRegrTest.

BasicScribeRegrTest() - Constructor for class rice.scribe.testing.BasicScribeRegrTest

BasicScribeRegrTestApp - class rice.scribe.testing.BasicScribeRegrTestApp.

BasicScribeRegrTestApp(PastryNode, Scribe, int, Credentials) - Constructor for class rice.scribe.testing.BasicScribeRegrTestApp

BroadcastLeafSet - class rice.pastry.leafset.BroadcastLeafSet.

Broadcast a leaf set to another node.

BroadcastLeafSet(NodeHandle, LeafSet, int) - Constructor for class rice.pastry.leafset.BroadcastLeafSet

Constructor.

BroadcastLeafSet(Credentials, NodeHandle, LeafSet, int) - Constructor for class rice.pastry.leafset.BroadcastLeafSet

Constructor.

BroadcastLeafSet(Date, NodeHandle, LeafSet, int) - Constructor for class rice.pastry.leafset.BroadcastLeafSet

Constructor.

BroadcastLeafSet(Credentials, Date, NodeHandle, LeafSet, int) - Constructor for class rice.pastry.leafset.BroadcastLeafSet

Constructor.

BroadcastRouteRow - class rice.pastry.routing.BroadcastRouteRow.

Broadcast message for a row from a routing table.

BroadcastRouteRow(Credentials, Date, NodeHandle, RouteSet[]) - Constructor for class rice.pastry.routing.BroadcastRouteRow

Constructor.

BroadcastRouteRow(Date, NodeHandle, RouteSet[]) - Constructor for class rice.pastry.routing.BroadcastRouteRow

Constructor.

BroadcastRouteRow(Credentials, NodeHandle, RouteSet[]) - Constructor for class rice.pastry.routing.BroadcastRouteRow

Constructor.

BroadcastRouteRow(NodeHandle, RouteSet[]) - Constructor for class rice.pastry.routing.BroadcastRouteRow

Constructor.

baseBitLength() - Static method in class rice.pastry.routing.RoutingTable

return the bit length of the base

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

bestAlternateRoute(Id) - Method in class rice.pastry.routing.RoutingTable

Determines an alternate hop numerically closer to the key than the one we are at.

blit(byte[]) - Method in class rice.pastry.Id.Distance

Blits the distance into a target array.

blit(byte[]) - Method in class rice.pastry.Id

Blits the Id into a target array.

broadcast() - Method in class rice.pastry.standard.StandardLeafSetProtocol

Broadcast the leaf set to all members of the local leaf set.

broadcast(int) - Method in class rice.pastry.standard.StandardLeafSetProtocol

Broadcast the leaf set to all members of the local leaf set.

broadcast(LeafSet, NodeHandle) - Method in class rice.pastry.standard.StandardLeafSetProtocol

Broadcast the local leaf set to all members of the given leaf set, plus the node from which the leaf set was received.

broadcastRows(JoinRequest) - Method in class rice.pastry.standard.StandardJoinProtocol

Broadcasts the route table rows.

buildId(byte[]) - Method in interface rice.p2p.commonapi.IdFactory

Builds a protocol-specific Id given the source data.

buildId(int[]) - Method in interface rice.p2p.commonapi.IdFactory

Builds a protocol-specific Id given the source data.

buildId(String) - Method in interface rice.p2p.commonapi.IdFactory

Builds a protocol-specific Id by using the hash of the given string as source data.

buildId(byte[]) - Method in class rice.pastry.commonapi.PastryIdFactory

Builds a protocol-specific Id given the source data.

buildId(int[]) - Method in class rice.pastry.commonapi.PastryIdFactory

Builds a protocol-specific Id given the source data.

buildId(String) - Method in class rice.pastry.commonapi.PastryIdFactory

Builds a protocol-specific Id by using the hash of the given string as source data.

buildIdDistance(byte[]) - Method in interface rice.p2p.commonapi.IdFactory

Builds a protocol-specific Id.Distance given the source data.

buildIdDistance(byte[]) - Method in class rice.pastry.commonapi.PastryIdFactory

Builds a protocol-specific Id.Distance given the source data.

buildIdRange(Id, Id) - Method in interface rice.p2p.commonapi.IdFactory

Creates an IdRange given the CW and CCW ids.

buildIdRange(Id, Id) - Method in class rice.pastry.commonapi.PastryIdFactory

Creates an IdRange given the CW and CCW ids.

buildIdSet() - Method in interface rice.p2p.commonapi.IdFactory

Creates an empty IdSet.

buildIdSet() - Method in class rice.pastry.commonapi.PastryIdFactory

Creates an empty IdSet.

C

CACHE_SIZE - Static variable in class rice.persistence.testing.LRUCacheTest

CREATED - Static variable in class rice.scribe.Topic

The two states in which Topic can be.

Cache - interface rice.persistence.Cache.

This interface is the abstraction of something which provides a caching service.

CacheMessage - class rice.p2p.past.messaging.CacheMessage.

CacheMessage(int, PastContent, NodeHandle, Id) - Constructor for class rice.p2p.past.messaging.CacheMessage

Constructor which takes a unique integer Id and the local id

Catalog - interface rice.persistence.Catalog.

This interface is the abstraction of something which holds objects which are available for lookup.

Channel - class rice.p2p.splitstream.Channel.

The channel controls all the meta data associated with a group of stripes.

Channel(ChannelId, Scribe, IdFactory, Id) - Constructor for class rice.p2p.splitstream.Channel

Constructor to create a new channel from scratch

ChannelId - class rice.p2p.splitstream.ChannelId.

This class wraps the nodeId object so we can use type checking and allow more readable and understandable code.

ChannelId(Id) - Constructor for class rice.p2p.splitstream.ChannelId

Constructor that takes in an Id and makes a ChannelId

ChannelId(String) - Constructor for class rice.p2p.splitstream.ChannelId

Constructor that takes in a String and makes a ChannelId

ClosestRegrTest - class rice.pastry.testing.ClosestRegrTest.

ClosestRegrTest A test suite for the getClosest algorithm

CommonAPIAppl - class rice.pastry.client.CommonAPIAppl.

CommonAPIAppl is an abstract class that all new applications should extend.

CommonAPIAppl(PastryNode) - Constructor for class rice.pastry.client.CommonAPIAppl

Constructor.

CommonAPIAppl(PastryNode, String) - Constructor for class rice.pastry.client.CommonAPIAppl

Constructor.

CommonAPITest - class rice.p2p.commonapi.testing.CommonAPITest.

Provides regression testing setup for applications written on top of the commonapi.

CommonAPITest() - Constructor for class rice.p2p.commonapi.testing.CommonAPITest

Constructor, which takes no arguments and sets up the factories in preparation for node creation.

ContentHashPastContent - class rice.p2p.past.ContentHashPastContent.

ContentHashPastContent() - Constructor for class rice.p2p.past.ContentHashPastContent

ContentHashPastContentHandle - class rice.p2p.past.ContentHashPastContentHandle.

ContentHashPastContentHandle(NodeHandle, Id) - Constructor for class rice.p2p.past.ContentHashPastContentHandle

Constructor

Continuation - interface rice.Continuation.

Asynchronously receives the result to a given method call, using the command pattern.

Continuation.ExternalContinuation - class rice.Continuation.ExternalContinuation.

This class provides a continuation which is designed to be used from an external thread.

Continuation.ExternalContinuation() - Constructor for class rice.Continuation.ExternalContinuation

Continuation.ListenerContinuation - class rice.Continuation.ListenerContinuation.

This class is a Continuation provided for simplicity which listens for any errors and ignores any success values.

Continuation.ListenerContinuation(String) - Constructor for class rice.Continuation.ListenerContinuation

Constructor which takes in a name

Continuation.StandardContinuation - class rice.Continuation.StandardContinuation.

This class is a Continuation provided for simplicity which passes any errors up to the parent Continuation which it is constructed with.

Continuation.StandardContinuation(Continuation) - Constructor for class rice.Continuation.StandardContinuation

Constructor which takes in the parent continuation for this continuation.

ContinuationMessage - class rice.p2p.past.messaging.ContinuationMessage.

ContinuationMessage(int, NodeHandle, Id) - Constructor for class rice.p2p.past.messaging.ContinuationMessage

Constructor which takes a unique integer Id, as well as the data to be stored

Correction - Static variable in class rice.pastry.leafset.BroadcastLeafSet

Credentials - interface rice.pastry.security.Credentials.

This is the interface for a Pastry Credentials object.

cache(Id, Serializable, Continuation) - Method in interface rice.persistence.Cache

Caches an object in this storage.

cache(Id, Serializable, Continuation) - Method in class rice.persistence.LRUCache

Caches an object in this storage.

cache(Id, Serializable, Continuation) - Method in class rice.persistence.StorageManager

Caches an object in this storage.

canRandom() - Method in class rice.pastry.routing.SendOptions

Returns whether randomizations on the route are allowed.

ccwHalf() - Method in class rice.pastry.IdRange

get counterclockwise half of the range

ccwSize() - Method in class rice.pastry.leafset.LeafSet

Gets the current counterclockwise size.

channel - Variable in class rice.p2p.splitstream.Stripe

This stripe's channel

channelId - Variable in class rice.p2p.splitstream.Channel

ChannelId for this channel

channels - Variable in class rice.p2p.splitstream.SplitStreamImpl

Hashtable of all the channels currently created on this node implicitly or explicitly.

checkAnycastDFS(NodeId) - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

Checks the DFS implemented by MessageAnycast class.

checkBit(int) - Method in class rice.pastry.Id

Checks if the ith bit is flipped.

checkFreq - Static variable in class rice.rm.testing.DistRMRegrTestApp

checkInsert(Id, PastContent) - Method in class rice.p2p.past.ContentHashPastContent

Checks if a insert operation should be allowed.

checkInsert(Id, PastContent) - Method in interface rice.p2p.past.PastContent

Checks if a insert operation should be allowed.

checkInsert(Id, PastContent) - Method in class rice.p2p.past.testing.PastRegrTest.NonOverwritingTestPastContent

checkInsert(Id, PastContent) - Method in class rice.p2p.past.testing.PastRegrTest.TestPastContent

checkLeafSet(LeafSet, NodeHandle, boolean) - Method in class rice.pastry.standard.StandardLeafSetProtocol

Checks a received leafset advertisement for missing nodes

checkNewJoin(NodeId) - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

A test for checking if data was correctly propogated along subscribe messages if new join method was used, which takes data as a parameter.

checkParentPointerForAllTopics(int) - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

Check if parent pointer is set for all topics on the specified node.

checkPassed() - Method in class rice.rm.testing.RMRegrTestApp

checkRemoveChild(NodeId) - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

Tests the removeChild interface method.

checkRoutingTable() - Method in class rice.pastry.testing.SinglePingTest

checkStart - Static variable in class rice.rm.testing.DistRMRegrTestApp

checkTree(int, int) - Method in class rice.p2p.splitstream.testing.SplitStreamRegrTest

childAdded(Topic, NodeHandle) - Method in interface rice.p2p.scribe.ScribeClient

Informs this client that a child was added to a topic in which it was interested in.

childAdded(Topic, NodeHandle) - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

DESCRIBE THE METHOD

childAdded(Topic, NodeHandle) - Method in class rice.p2p.splitstream.Stripe

Informs this client that a child was added to a topic in which it was interested in.

childObserver(NodeHandle, NodeId, boolean, ScribeMessage, Serializable) - Method in class rice.scribe.Scribe

Whenever the children table for a topic is changed, ( a child is added or removed), this method is invoked to do some handling.

childParentViewConsistencyTest(int) - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

Here we are trying to check that the parent-child relationship is consistent from the view of the CHILD as well as the PARENT, on given node.

childRemoved(Topic, NodeHandle) - Method in interface rice.p2p.scribe.ScribeClient

Informs this client that a child was removed from a topic in which it was interested in.

childRemoved(Topic, NodeHandle) - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

DESCRIBE THE METHOD

childRemoved(Topic, NodeHandle) - Method in class rice.p2p.splitstream.Stripe

Informs this client that a child was removed from a topic in which it was interested in.

children - Variable in class rice.p2p.scribe.ScribeImpl.TopicManager

DESCRIBE THE FIELD

clearAlreadySentHBNodes() - Method in class rice.scribe.Scribe

The set is cleared so that the set contains only those nodes to which Publish message was sent in last HeartBeat period.

clearChanged() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

clearRefreshedKeys() - Method in class rice.rm.testing.RMRegrTestApp

client - Variable in class rice.p2p.replication.ReplicationImpl

This replication's client

client - Variable in class rice.p2p.replication.manager.ReplicationManagerImpl

The client of this manager

clients - Variable in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

The clients

clients - Variable in class rice.p2p.replication.testing.ReplicationRegrTest

The clients

clients - Variable in class rice.p2p.scribe.ScribeImpl.TopicManager

DESCRIBE THE FIELD

clients - Variable in class rice.p2p.splitstream.Stripe

The list of SplitStreamClients interested in data from this client

clockwise(Id) - Method in interface rice.p2p.commonapi.Id

Checks to see if the Id nid is clockwise or counterclockwise from this, on the ring.

clockwise(Id) - Method in class rice.pastry.Id

Checks to see if the Id nid is clockwise or counterclockwise from this, on the ring.

clockwise(Id) - Method in class rice.pastry.Id

Checks to see if the Id nid is clockwise or counterclockwise from this, on the ring.

clone(IdSet) - Method in class rice.p2p.replication.manager.ReplicationManagerImpl

Internal method which clones an IdSet, so that iterators work as expected

closeSocket(WireNodeHandle) - Method in class rice.pastry.wire.SocketManager

Method which is designed to be called by node handles which have been disconnected by the remote node (i.e.

closestNode() - Method in class rice.pastry.routing.RouteSet

Return the closest live node in the set.

coalesce(DistNodeHandle) - Method in class rice.pastry.dist.DistNodeHandlePool

The method verifies a DistNodeHandle.

coalesce(DistNodeHandle) - Method in class rice.pastry.wire.WireNodeHandlePool

The method verifies a WireNodeHandle.

commandTable - Variable in class rice.past.PASTServiceImpl

Deprecated. The table used to store commands waiting for a response.

compareEnqRec() - Method in class rice.pastry.wire.testing.WireFileProcessor

compareEnqSnd() - Method in class rice.pastry.wire.testing.WireFileProcessor

compareSets(Hashtable, Hashtable) - Method in class rice.pastry.wire.testing.WireFileProcessor

compareTables(Hashtable, Hashtable) - Method in class rice.pastry.wire.testing.WireFileProcessor

compareTo(Object) - Method in class rice.pastry.Id.Distance

Comparison operator.

compareTo(Object) - Method in class rice.pastry.Id

Comparison operator for Ids.

compareTo(Object) - Method in class rice.pastry.testing.LeafSetTest.TestNodeHandle

complement() - Method in class rice.pastry.IdRange

get the complement of this range on the ring

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

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

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

Method which is called when the key becomes connectable.

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

Specified by the SelectionKeyHandler interface - should NEVER be called!

connect(SelectionKey) - Method in class rice.pastry.wire.StaleSKH

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

Called by the socket manager whnever this node handle needs to complete it's connection to it's remote node.

connectToRemoteNode(Iterator) - Method in class rice.pastry.wire.WireNodeHandle

Method which initiates a connection to a remote node.

contains(Id) - Method in class rice.pastry.IdRange

test if a given key lies within this range

containsId(Id) - Method in interface rice.p2p.commonapi.IdRange

test if a given key lies within this range

containsId(Id) - Method in class rice.pastry.IdRange

test if a given key lies within this range

content - Variable in class rice.p2p.past.messaging.CacheMessage

content - Variable in class rice.p2p.scribe.messaging.AnycastMessage

the content of this message

content - Variable in class rice.p2p.scribe.messaging.PublishMessage

content - Variable in class rice.p2p.scribe.messaging.PublishRequestMessage

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

Copy the distance into a freshly generated array.

copy() - Method in class rice.pastry.Id

Copy the Id into a freshly generated array.

countItems(Hashtable) - Method in class rice.pastry.wire.testing.WireFileProcessor

countItems2(Hashtable) - Method in class rice.pastry.wire.testing.WireFileProcessor

countObservers() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

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

Creates a group/topic if the credentials are valid.

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

Creates a group/topic if the credentials are valid.

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

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

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

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

create(NodeId) - Method in class rice.scribe.testing.DistScribeRegrTestApp

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

createChannel(ChannelId) - Method in interface rice.p2p.splitstream.SplitStream

A SplitStream application calls this method when it wishes to distribute content, creating a new channel object.

createChannel(ChannelId) - Method in class rice.p2p.splitstream.SplitStreamImpl

This method is used by a peer who wishes to distribute the content using SplitStream.

createEmptyIdRange() - Method in class rice.pastry.testing.IdRangeUnit

createFullIdRange() - Method in class rice.pastry.testing.IdRangeUnit

createIdRangeEndingIn(Id) - Method in class rice.pastry.testing.IdRangeUnit

createIdRangeStartingWith(Id) - Method in class rice.pastry.testing.IdRangeUnit

createIdWithPrefix(byte) - Method in class rice.pastry.testing.IdRangeUnit

createNode(int) - Method in class rice.p2p.commonapi.testing.CommonAPITest

Method which creates a single node, given it's node number

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

createNodes() - Method in class rice.past.testing.DistPASTRegrTest

Deprecated. Creates the nodes used for testing.

createRandomIdRange() - Method in class rice.pastry.testing.IdRangeUnit

credentials - Variable in class rice.pastry.commonapi.PastryEndpoint

cwHalf() - Method in class rice.pastry.IdRange

get clockwise half of the range

cwSize() - Method in class rice.pastry.leafset.LeafSet

Gets the current clockwise size.

D

DATAGRAM_RECEIVE_BUFFER_SIZE - Static variable in class rice.pastry.wire.DatagramManager

the size of the buffer used to read incoming datagrams must be big enough to encompass multiple datagram packets

DATAGRAM_SEND_BUFFER_SIZE - Static variable in class rice.pastry.wire.DatagramManager

the size of the buffer used to send outgoing datagrams this is also the largest message size than can be sent via UDP

DEBUG - Static variable in class rice.past.PASTServiceImpl

Deprecated. Whether to print debugging statements.

DECLARED_DEAD - Static variable in class rice.p2p.commonapi.NodeHandle

DECLARED_LIVE - Static variable in class rice.p2p.commonapi.NodeHandle

DEFAULT_DISTANCE - Static variable in class rice.pastry.dist.DistCoalesedNodeHandle

DEFAULT_MAXIMUM_CHILDREN - Static variable in class rice.p2p.splitstream.SplitStreamScribePolicy

The default maximum number of children per channel

DEFAULT_REGISTRY_PORT - Static variable in class rice.pastry.rmi.RMIPastryNodeFactory

DM_PREFIX - Static variable in class rice.pastry.wire.testing.WireFileProcessor

DatagramManager - class rice.pastry.wire.DatagramManager.

This class is an implementation of a UDP-based Pastry protocol.

DatagramManager(WirePastryNode, SelectorManager, int) - Constructor for class rice.pastry.wire.DatagramManager

Constructor.

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

Class which wraps all messages to be sent through the UDP-based pastry protocol.

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

Builds a DatagramMessage given a packet number

DatagramTransmissionManager - class rice.pastry.wire.DatagramTransmissionManager.

Class which controls which object should be transmitted in the UPD version of the pastry protocol.

DatagramTransmissionManager(WirePastryNode, SelectionKey, DatagramManager) - Constructor for class rice.pastry.wire.DatagramTransmissionManager

Builds a transmission manager for a given pastry node using a given key.

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

Message which is a "transport" message in the datagram protocol.

DatagramTransportMessage(NodeId, NodeId, int, Object) - Constructor for class rice.pastry.wire.messaging.datagram.DatagramTransportMessage

Builds a DatagramMessage given an object to wrap and a packet number

DeserializationException - exception rice.pastry.wire.exception.DeserializationException.

Class which represents an exception occuring during the deserialization of a Pastry message.

DeserializationException(String) - Constructor for class rice.pastry.wire.exception.DeserializationException

Constructs an DeserializationException with a given message

DirectNodeHandle - class rice.pastry.direct.DirectNodeHandle.

the node handle used with the direct network

DirectNodeHandle(PastryNode, PastryNode, NetworkSimulator) - Constructor for class rice.pastry.direct.DirectNodeHandle

Constructor for DirectNodeHandle.

DirectPastryNode - class rice.pastry.direct.DirectPastryNode.

Direct pastry node.

DirectPastryNode(NodeId, NetworkSimulator) - Constructor for class rice.pastry.direct.DirectPastryNode

DirectPastryNodeFactory - class rice.pastry.direct.DirectPastryNodeFactory.

Pastry node factory for direct connections between nodes (local instances).

DirectPastryNodeFactory(NodeIdFactory, NetworkSimulator) - Constructor for class rice.pastry.direct.DirectPastryNodeFactory

DirectPastryPingTest - class rice.pastry.testing.DirectPastryPingTest.

DirectPastryPingTest A performance test suite for pastry.

DirectPastryPingTest() - Constructor for class rice.pastry.testing.DirectPastryPingTest

DirectPastryRegrTest - class rice.pastry.testing.DirectPastryRegrTest.

PastryRegrTest a regression test suite for pastry.

DirectRMRegrTest - class rice.rm.testing.DirectRMRegrTest.

DirectRMRegrTest() - Constructor for class rice.rm.testing.DirectRMRegrTest

DirectRMRegrTestApp - class rice.rm.testing.DirectRMRegrTestApp.

DirectRMRegrTestApp(PastryNode, Credentials, String) - Constructor for class rice.rm.testing.DirectRMRegrTestApp

DirectScribeMaintenanceTest - class rice.scribe.testing.DirectScribeMaintenanceTest.

DirectScribeMaintenanceTest() - Constructor for class rice.scribe.testing.DirectScribeMaintenanceTest

DirectScribeMaintenanceTest.TestAnycastMessage - class rice.scribe.testing.DirectScribeMaintenanceTest.TestAnycastMessage.

A dummy test message used for checking if anycast is doing DFS correctly.

DirectScribeMaintenanceTest.TestAnycastMessage(Address, NodeHandle, NodeId, Credentials) - Constructor for class rice.scribe.testing.DirectScribeMaintenanceTest.TestAnycastMessage

DirectScribeMaintenanceTestApp - class rice.scribe.testing.DirectScribeMaintenanceTestApp.

DirectScribeMaintenanceTestApp(PastryNode, Scribe, Credentials) - Constructor for class rice.scribe.testing.DirectScribeMaintenanceTestApp

Constructor

DirectScribeRegrTest - class rice.scribe.testing.DirectScribeRegrTest.

DirectScribeRegrTest() - Constructor for class rice.scribe.testing.DirectScribeRegrTest

DirectSecurityManager - class rice.pastry.direct.DirectSecurityManager.

Security manager for direct connections between nodes.

DirectSecurityManager(NetworkSimulator) - Constructor for class rice.pastry.direct.DirectSecurityManager

Constructor.

DisconnectMessage - class rice.pastry.wire.messaging.socket.DisconnectMessage.

Class which represents a disconnect notice in the Socket-based pastry wire protocol.

DisconnectMessage() - Constructor for class rice.pastry.wire.messaging.socket.DisconnectMessage

Constructor

DistCoalesedNodeHandle - class rice.pastry.dist.DistCoalesedNodeHandle.

Abstract class for handles to "real" remote nodes.

DistCoalesedNodeHandle(NodeId, InetSocketAddress) - Constructor for class rice.pastry.dist.DistCoalesedNodeHandle

Constructor

DistHelloWorld - class rice.pastry.testing.DistHelloWorld.

A hello world example for pastry.

DistHelloWorld() - Constructor for class rice.pastry.testing.DistHelloWorld

Constructor

DistHelloWorldMultiThread - class rice.pastry.testing.DistHelloWorldMultiThread.

A hello world example for pastry.

DistHelloWorldMultiThread() - Constructor for class rice.pastry.testing.DistHelloWorldMultiThread

Constructor

DistNodeHandle - class rice.pastry.dist.DistNodeHandle.

Abstract class for handles to "real" remote nodes.

DistNodeHandle(NodeId, InetSocketAddress) - Constructor for class rice.pastry.dist.DistNodeHandle

Constructor

DistNodeHandlePool - class rice.pastry.dist.DistNodeHandlePool.

The DistNodeHandlePool controls all of the node handles in use by the DistPastryNode.

DistNodeHandlePool() - Constructor for class rice.pastry.dist.DistNodeHandlePool

Constructor.

DistPASTRegrTest - class rice.past.testing.DistPASTRegrTest.

Deprecated. This version of PAST has been deprecated - please use the version located in the rice.p2p.past package.

DistPASTRegrTest() - Constructor for class rice.past.testing.DistPASTRegrTest

Deprecated.

DistPASTRegrTest.TestCommand - class rice.past.testing.DistPASTRegrTest.TestCommand.

Deprecated. Common superclass for test commands.

DistPASTRegrTest.TestCommand() - Constructor for class rice.past.testing.DistPASTRegrTest.TestCommand

Deprecated.

DistPASTRegrTest.TestFailedException - exception rice.past.testing.DistPASTRegrTest.TestFailedException.

Deprecated. Exception indicating that a regression test failed.

DistPASTRegrTest.TestFailedException(String) - Constructor for class rice.past.testing.DistPASTRegrTest.TestFailedException

Deprecated.

DistPASTRegrTest.TestPASTFunctions - class rice.past.testing.DistPASTRegrTest.TestPASTFunctions.

Deprecated. Commands for running the PAST functions test.

DistPASTRegrTest.TestPASTFunctions() - Constructor for class rice.past.testing.DistPASTRegrTest.TestPASTFunctions

Deprecated. Sets up this test.

DistPastryNode - class rice.pastry.dist.DistPastryNode.

Class which represents the abstraction of a "real" pastry node.

DistPastryNode(NodeId) - Constructor for class rice.pastry.dist.DistPastryNode

Constructor, with NodeId.

DistPastryNodeFactory - class rice.pastry.dist.DistPastryNodeFactory.

An abstraction of the nodeId factory for distributed nodes.

DistPastryNodeFactory() - Constructor for class rice.pastry.dist.DistPastryNodeFactory

Constructor.

DistPastryRegrTest - class rice.pastry.testing.DistPastryRegrTest.

a regression test suite for pastry with "distributed" nodes.

DistPastryRegrTest() - Constructor for class rice.pastry.testing.DistPastryRegrTest

DistRMRegrTest - class rice.rm.testing.DistRMRegrTest.

DistRMRegrTest() - Constructor for class rice.rm.testing.DistRMRegrTest

DistRMRegrTestApp - class rice.rm.testing.DistRMRegrTestApp.

DistRMRegrTestApp(PastryNode, Credentials, boolean, String) - Constructor for class rice.rm.testing.DistRMRegrTestApp

DistRMRegrTestMessage - class rice.rm.testing.DistRMRegrTestMessage.

DistRMRegrTestMessage is used by the dist regression test application on the RM layer to do system invariant checking.

DistRMRegrTestMessage(Address, Credentials) - Constructor for class rice.rm.testing.DistRMRegrTestMessage

Constructor

DistRMRegrTestReplicateMessage - class rice.rm.testing.DistRMRegrTestReplicateMessage.

DistRMRegrTestReplicateMessage is used by the dist regression test application on the RM layer to do the initial replication of a few objects into the system and the periodic refreshing.

DistRMRegrTestReplicateMessage(Address, Credentials) - Constructor for class rice.rm.testing.DistRMRegrTestReplicateMessage

Constructor

DistScribeRegrTest - class rice.scribe.testing.DistScribeRegrTest.

DistScribeRegrTest() - Constructor for class rice.scribe.testing.DistScribeRegrTest

DistScribeRegrTestApp - class rice.scribe.testing.DistScribeRegrTestApp.

DistScribeRegrTestApp(PastryNode, Scribe, Credentials, DistScribeRegrTest) - Constructor for class rice.scribe.testing.DistScribeRegrTestApp

DistScribeRegrTestMessage - class rice.scribe.testing.DistScribeRegrTestMessage.

DistScribeRegrTestMessage is used by the dist regression test application on the Scribe layer to do publishing on some topics, etc.

DistScribeRegrTestMessage(Address, Credentials) - Constructor for class rice.scribe.testing.DistScribeRegrTestMessage

Constructor

DistTopicLog - class rice.scribe.testing.DistTopicLog.

DistTopicLog() - Constructor for class rice.scribe.testing.DistTopicLog

DropMessage - class rice.p2p.scribe.messaging.DropMessage.

DropMessage(NodeHandle, Topic) - Constructor for class rice.p2p.scribe.messaging.DropMessage

Constructor which takes a unique integer Id

data - Variable in class rice.p2p.splitstream.SplitStreamContent

The internal data - just the bytes

debug(String) - Method in class rice.past.PASTServiceImpl

Deprecated. Prints a debugging message to System.out if the DEBUG flag is turned on.

debug(String) - Method in class rice.past.messaging.PASTMessage

Deprecated. Print a debug message if the PASTServiceImpl.DEBUG flag is enabled.

debug(String) - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Prints out nicely formatted debug messages.

defaultAllowMultipleHops - Static variable in class rice.pastry.routing.SendOptions

defaultNoShortCuts - Static variable in class rice.pastry.routing.SendOptions

defaultRandom - Static variable in class rice.pastry.routing.SendOptions

defaultShortestPath - Static variable in class rice.pastry.routing.SendOptions

delete(Id, Continuation) - Method in interface rice.past.PASTService

Deprecated. Reclaims the storage used by the object with the given ID.

delete(Id, Continuation) - Method in class rice.past.PASTServiceImpl

Deprecated. Reclaims the storage used by the object with the given ID.

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

Delete a leaf set observer from the Pastry node.

deleteObserver(Observer) - Method in class rice.pastry.dist.DistCoalesedNodeHandle

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

Delete observer method.

deleteObservers() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

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

Delete a route set observer from the Pastry node.

deliver(Id, Message) - Method in interface rice.p2p.commonapi.Application

This method is called on the application at the destination node for the given id.

deliver(Id, Message) - Method in class rice.p2p.past.PastImpl

This method is called on the application at the destination node for the given id.

deliver(Id, Message) - Method in class rice.p2p.replication.ReplicationImpl

This method is called on the application at the destination node for the given id.

deliver(Id, Message) - Method in class rice.p2p.replication.manager.ReplicationManagerImpl

This method is called on the application at the destination node for the given id.

deliver(Topic, ScribeContent) - Method in interface rice.p2p.scribe.ScribeClient

This method is invoked when a message is delivered for a topic this client is interested in.

deliver(Id, Message) - Method in class rice.p2p.scribe.ScribeImpl

This method is called on the application at the destination node for the given id.

deliver(Topic, ScribeContent) - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

DESCRIBE THE METHOD

deliver(Stripe, byte[]) - Method in interface rice.p2p.splitstream.SplitStreamClient

Is called when data is received on a stripe which this client has registered interest

deliver(Topic, ScribeContent) - Method in class rice.p2p.splitstream.Stripe

This method is invoked when a message is delivered for a topic this client is interested in.

deliver(Id, Message) - Method in class rice.past.PASTServiceImpl

Deprecated. Called by pastry when a message arrives for this application.

deliver(Id, Message) - Method in class rice.pastry.client.CommonAPIAppl

Called by pastry when a message arrives for this application.

deliver(Id, Message) - Method in class rice.pastry.testing.RegrTestApp

deliver(Id, Message) - Method in class rice.rm.RMImpl

Called by pastry when a message arrives for this application.

deliver(Id, Message) - Method in class rice.rm.testing.RMRegrTestApp

deliverBuffered(Address) - Method in class rice.pastry.messaging.MessageDispatch

deliverMessage(Message, PastryNode) - Method in class rice.pastry.direct.EuclideanNetwork

DESCRIBE THE METHOD

deliverMessage(Message, PastryNode) - Method in interface rice.pastry.direct.NetworkSimulator

Deliver message.

deliverMessage(Message, PastryNode) - Method in class rice.pastry.direct.SphereNetwork

DESCRIBE THE METHOD

deserialize(ByteBuffer) - Static method in class rice.pastry.wire.DatagramManager

Method which takes in a ByteBuffer read from a datagram, and deserializes the contained object.

dest - Variable in class rice.p2p.past.messaging.PastMessage

destination - Variable in class rice.pastry.wire.messaging.datagram.DatagramMessage

DESCRIBE THE FIELD

diff(IdRange) - Method in class rice.pastry.IdRange

compute the difference between two ranges (exclusive or of keys in the two ranges) two ranges may differ in two ranges on the circle; this method produces one such range of difference if one exists the other range of difference can be computed by invoking o.diff(this)

diffRange(IdRange) - Method in interface rice.p2p.commonapi.IdRange

diffs the given range with this range

diffRange(IdRange) - Method in class rice.pastry.IdRange

diffs the given range with this range

diffSubtractTest(IdRange, IdRange) - Method in class rice.pastry.testing.IdRangeUnit

directAnycast(AnycastMessage, NodeHandle, NodeHandle[]) - Method in class rice.p2p.scribe.ScribePolicy.DefaultScribePolicy

Simply adds the parent and children in order, which implements a depth-first-search.

directAnycast(AnycastMessage, NodeHandle, NodeHandle[]) - Method in interface rice.p2p.scribe.ScribePolicy

This method is called when an anycast is received which is not satisfied at the local node.

directAnycast(AnycastMessage, NodeHandle, NodeHandle[]) - Method in class rice.p2p.splitstream.SplitStreamScribePolicy

This method adds the parent and child in such a way that the nodes who have this stripe as their primary strpe are examined first.

disconnect() - Method in class rice.pastry.wire.WireNodeHandle

Method that is designed to be called by the SocketManager when it wishes for this node handle to disconnect.

dispatchMessage(Message) - Method in class rice.pastry.messaging.MessageDispatch

Dispatches a message to the appropriate receiver.

distClients - Variable in class rice.rm.testing.DistRMRegrTest

distClients - Variable in class rice.scribe.testing.DistScribeRegrTest

distance(Id) - Method in class rice.pastry.Id

Returns the shorter numerical distance on the ring between a pair of Ids.

distanceFromId(Id) - Method in interface rice.p2p.commonapi.Id

Returns the shorter numerical distance on the ring between a pair of Ids.

distanceFromId(Id) - Method in class rice.pastry.Id

Returns the shorter numerical distance on the ring between a pair of Ids.

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

distinctChildrenTableConsistencyTest(int) - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

Check the consistency between distinctChildrenTable maintained by scribe on a node and the children maintained by each Topic on that node.

distinctChildrenTableConsistencyTest(Scribe) - Method in class rice.scribe.testing.DistScribeRegrTestMessage

Check the consistency between distinctChildrenTable maintained by scribe on a node and the children maintained by each Topic on that node.

distinctParentTableConsistencyTest(int) - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

Check the consistency between distinctParentTable maintained by scribe on a node and the parent maintained by each Topic on that node.

distinctParentTableConsistencyTest(Scribe) - Method in class rice.scribe.testing.DistScribeRegrTestMessage

Check the consistency between distinctParentTable maintained by scribe on a node and the parent maintained by each Topic on that node.

doPing() - Method in class rice.pastry.rmi.RMINodeHandle

Do the (blocking) ping

doSend(Message) - Method in class rice.pastry.rmi.RMINodeHandle

Do the actual (blocking) RMI call to the remote node

doTesting() - Method in class rice.rm.testing.DirectRMRegrTest

The system of nodes is set up and the testing is performed while stepwise failing the desired number of nodes.

doTesting() - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

The system of nodes is set up and the testing is performed while stepwise failing the desired number of nodes.

doTheTesting(int, int) - Method in class rice.scribe.testing.BasicScribeRegrTest

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

doneNode(NodeHandle) - Method in class rice.pastry.direct.DirectPastryNode

doneNode(NodeHandle) - Method in class rice.pastry.dist.DistPastryNode

Called after the node is initialized.

doneNode(NodeHandle) - Method in class rice.pastry.rmi.RMIPastryNode

Called after the node is initialized.

doneNode(NodeHandle) - Method in class rice.pastry.wire.WirePastryNode

Called after the node is initialized.

doneReleaseingFileDescriptor() - Static method in class rice.pastry.wire.Wire

doneTest() - Method in class rice.pastry.direct.TestRecord

doneTest() - Method in class rice.pastry.testing.PingTestRecord

dropPrefix - Static variable in class rice.pastry.wire.testing.WireFileProcessor

dropped - Variable in class rice.pastry.wire.testing.WireFileProcessor

E

Endpoint - interface rice.p2p.commonapi.Endpoint.

EuclideanNetwork - class rice.pastry.direct.EuclideanNetwork.

Euclidean network topology and idealized node life.

EuclideanNetwork() - Constructor for class rice.pastry.direct.EuclideanNetwork

Constructor.

enableWrite(boolean, String) - Method in class rice.pastry.wire.DatagramTransmissionManager

This method controls the key's write interestOp, and has a parallel boolean to improve performance.

endpoint - Variable in class rice.p2p.past.PastImpl

endpoint - Variable in class rice.p2p.replication.ReplicationImpl

this application's endpoint

endpoint - Variable in class rice.p2p.replication.manager.ReplicationManagerImpl

The endpoint used for sending reminder messages

endpoint - Variable in class rice.p2p.scribe.ScribeImpl

this application's endpoint

enquePrefix - Static variable in class rice.pastry.wire.testing.WireFileProcessor

enqueue(Object) - Method in class rice.pastry.wire.SocketChannelWriter

Adds an object to this SocketChannelWriter's queue of pending objects to write.

enqueueSendMsg(Message, RMINodeHandle) - Method in class rice.pastry.rmi.RMIPastryNode

Enqueues a message for asynchronous transmission

enqueued - Variable in class rice.pastry.wire.testing.WireFileProcessor

String nodeid -> HashTable of MessageDigest -> ObjPair

enrouteMessage(Message, Id, NodeId, SendOptions) - Method in class rice.pastry.client.PastryAppl

Called by pastry when a message is enroute and is passing through this node.

enrouteMessage(Message, Id, NodeId, SendOptions) - Method in class rice.pastry.commonapi.PastryEndpoint

enrouteMessage(Message, Id, NodeId, SendOptions) - Method in class rice.pastry.testing.HelloWorldApp

Invoked on intermediate nodes in routing path.

enrouteMessage(Message, NodeId, NodeId, SendOptions) - Method in class rice.pastry.testing.HelloWorldAppMultiThread

Invoked on intermediate nodes in routing path.

enrouteMessage(Message, Id, NodeId, SendOptions) - Method in class rice.pastry.testing.Ping

enrouteMessage(Message, Id, NodeId, SendOptions) - Method in class rice.pastry.testing.PingClient

enrouteMessage(Message, Id, NodeId, SendOptions) - Method in class rice.scribe.Scribe

Called by pastry when a message is enroute and is passing through this node.

equalityTest(IdRange, IdRange) - Method in class rice.pastry.testing.IdRangeUnit

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

equals(Object) - Method in class rice.p2p.past.testing.PastRegrTest.NonMutableTestPastContent

equals(Object) - Method in class rice.p2p.past.testing.PastRegrTest.TestPastContent

equals(Object) - Method in class rice.p2p.past.testing.PastRegrTest.VersionedTestPastContent

equals(Object) - Method in class rice.p2p.scribe.Topic

Returns whether this is equal to o or not

equals(Object) - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeContent

DESCRIBE THE METHOD

equals(Object) - Method in class rice.p2p.splitstream.ChannelId

equals(Object) - Method in class rice.p2p.splitstream.StripeId

equals(Object) - Method in interface rice.past.messaging.PASTMessageID

Deprecated. Indicates whether some other object is equal to this one.

equals(Object) - Method in class rice.past.messaging.PASTMessageIDImpl

Deprecated. Indicates whether some other object is equal to this one.

equals(Object) - Method in class rice.pastry.Id.Distance

Equality operator.

equals(Object) - Method in class rice.pastry.Id

Equality operator for Ids.

equals(Id) - Method in class rice.pastry.Id

Equivalence relation for Ids.

equals(Object) - Method in class rice.pastry.IdRange

equality operator

equals(Object) - Method in class rice.pastry.NodeHandle

Equality operator for nodehandles.

equals(Object) - Method in class rice.pastry.direct.DirectNodeHandle

Equivalence relation for nodehandles.

equals(Object) - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Equivalence relation for nodehandles.

equals(Object) - Method in class rice.pastry.dist.DistNodeHandle

Equivalence relation for nodehandles.

equals(Object) - Method in class rice.pastry.join.JoinAddress

equals(Object) - Method in class rice.pastry.leafset.LeafSetProtocolAddress

equals(Object) - Method in class rice.pastry.routing.RouteProtocolAddress

equals(Object) - Method in class rice.pastry.routing.RouterAddress

equals(Object) - Method in class rice.pastry.standard.StandardAddress

equals(Object) - Method in class rice.pastry.testing.LeafSetTest.TestNodeHandle

equals(Object) - Method in class rice.pastry.testing.PingAddress

equals(Object) - Method in class rice.pastry.wire.testing.HelloMessageDigest

equals(Object) - Method in class rice.pastry.wire.testing.MessageDigest

equals(Object) - Method in class rice.pastry.wire.testing.PublishMessageDigest

equals(Object) - Method in class rice.rm.RMImpl.KEPenEntry

Equality is based only on the reqRange part, does not care about the numKeys argument.

exception - Variable in class rice.Continuation.ExternalContinuation

exception - Variable in class rice.p2p.past.messaging.ContinuationMessage

exceptionThrown() - Method in class rice.Continuation.ExternalContinuation

existing - Variable in class rice.p2p.past.testing.PastRegrTest.TestPastContent

exists(Id) - Method in class rice.p2p.past.PastImpl

This upcall should return whether or not the given id is currently stored by the client.

exists(Id) - Method in interface rice.p2p.replication.manager.ReplicationManagerClient

This upcall should return whether or not the given id is currently stored by the client.

exists(Id) - Method in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest.TestReplicationManagerClient

exists(Id, Continuation) - Method in interface rice.past.PASTService

Deprecated. Determines whether an object is currently stored at the given ID.

exists(Id, Continuation) - Method in class rice.past.PASTServiceImpl

Deprecated. Determines whether an object is currently stored at the given ID.

exists() - Method in class rice.past.messaging.MessageExists

Deprecated. Returns whether the file exists.

exists(Id) - Method in interface rice.persistence.Catalog

Returns whether or not an object is present in the location id.

exists(Id, Continuation) - Method in interface rice.persistence.Catalog

Returns whether or not an object is present in the location id.

exists(Id) - Method in class rice.persistence.LRUCache

Returns whether or not an object is cached in the location id.

exists(Id, Continuation) - Method in class rice.persistence.LRUCache

Returns whether or not an object is cached in the location id.

exists(Id) - Method in class rice.persistence.MemoryStorage

Returns whether or not the provided id exists

exists(Id, Continuation) - Method in class rice.persistence.MemoryStorage

Returns whether or not the provided id exists, by returning a Boolean through receiveResult on c

exists(Id) - Method in class rice.persistence.PersistentStorage

Returns whether or not an object is present in the location id.

exists(Id, Continuation) - Method in class rice.persistence.PersistentStorage

Returns whether or not an object is present in the location id.

exists(Id) - Method in class rice.persistence.StorageManager

Returns whether or not an object is present in the location id.

exists(Id, Continuation) - Method in class rice.persistence.StorageManager

Returns whether or not an object is present in the location id.

F

FACTORY - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

FAILURE - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

FAILURE - Static variable in class rice.persistence.testing.Test

FETCH_DELAY - Static variable in class rice.p2p.replication.manager.ReplicationManagerImpl

The amount of time to wait between fetch calls to the client

FetchHandleMessage - class rice.p2p.past.messaging.FetchHandleMessage.

FetchHandleMessage(int, Id, NodeHandle, Id) - Constructor for class rice.p2p.past.messaging.FetchHandleMessage

Constructor

FetchMessage - class rice.p2p.past.messaging.FetchMessage.

FetchMessage(int, PastContentHandle, NodeHandle, Id) - Constructor for class rice.p2p.past.messaging.FetchMessage

Constructor

factory - Variable in class rice.p2p.commonapi.testing.CommonAPITest

factory - Variable in class rice.p2p.past.PastImpl

factory - Variable in class rice.p2p.replication.ReplicationImpl

The factory for create IdSets and IdRanges

factory - Variable in class rice.p2p.replication.manager.ReplicationManagerImpl

The id factory used for manipulating ids

factory - Variable in class rice.pastry.testing.LeafSetTest

factory - Variable in class rice.pastry.testing.PastryRegrTest

failed - Variable in class rice.p2p.splitstream.Stripe

The count of failed subscribe messages

faultHandler(ScribeMessage, NodeHandle) - Method in interface rice.scribe.IScribeApp

Invoked by Scribe just before the "repair" SUBSCRIBE message is sent when a node suspects its parent is faulty.

faultHandler(Scribe) - Method in class rice.scribe.messaging.MessageAnycast

Method to notify that anycast has failed.

faultHandler(ScribeMessage, NodeHandle) - Method in class rice.scribe.testing.BasicScribeRegrTestApp

up-call invoked by scribe when a node detects a failure from its parent.

faultHandler(Scribe) - Method in class rice.scribe.testing.DirectScribeMaintenanceTest.TestAnycastMessage

faultHandler(ScribeMessage, NodeHandle) - Method in class rice.scribe.testing.DirectScribeMaintenanceTestApp

up-call invoked by scribe when a node detects a failure from its parent.

faultHandler(ScribeMessage, NodeHandle) - Method in class rice.scribe.testing.DistScribeRegrTestApp

up-call invoked by scribe when a node detects a failure from its parent.

fetch(PastContentHandle, Continuation) - Method in interface rice.p2p.past.Past

Retrieves the object associated with a given content handle.

fetch(PastContentHandle, Continuation) - Method in class rice.p2p.past.PastImpl

Retrieves the object associated with a given content handle.

fetch(Id, Continuation) - Method in class rice.p2p.past.PastImpl

This upcall is invoked to tell the client to fetch the given id, and to call the given command with the boolean result once the fetch is completed.

fetch(IdSet) - Method in interface rice.p2p.replication.ReplicationClient

This upcall is invoked to notify the application that is should fetch the cooresponding keys in this set, since the node is now responsible for these keys also.

fetch(Id, Continuation) - Method in interface rice.p2p.replication.manager.ReplicationManagerClient

This upcall is invoked to tell the client to fetch the given id, and to call the given command with the boolean result once the fetch is completed.

fetch(IdSet) - Method in class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

Method by which keys are added to the list of keys to fetch

fetch(IdSet) - Method in class rice.p2p.replication.manager.ReplicationManagerImpl

This upcall is invoked to notify the application that is should fetch the cooresponding keys in this set, since the node is now responsible for these keys also.

fetch(Id, Continuation) - Method in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest.TestReplicationManagerClient

fetch(IdSet) - Method in class rice.p2p.replication.testing.ReplicationRegrTest.TestReplicationClient

This upcall is invoked to notify the application that is should fetch the cooresponding keys in this set, since the node is now responsible for these keys also.

fetch(IdSet) - Method in class rice.past.PASTServiceImpl

Deprecated. This upcall is invoked to notify the application that is should fetch the cooresponding keys in this set, since the node is now responsible for these keys also

fetch(IdSet) - Method in interface rice.rm.RMClient

This upcall is invoked to notify the application that is should fetch the cooresponding keys in this set, since the node is now responsible for these keys also.

fetch(IdSet) - Method in class rice.rm.testing.RMRegrTestApp

forward(RouteMessage) - Method in interface rice.p2p.commonapi.Application

This method is invoked on applications when the underlying node is about to forward the given message with the provided target to the specified next hop.

forward(RouteMessage) - Method in class rice.p2p.past.PastImpl

This method is invoked on applications when the underlying node is about to forward the given message with the provided target to the specified next hop.

forward(RouteMessage) - Method in class rice.p2p.replication.ReplicationImpl

This method is invoked on applications when the underlying node is about to forward the given message with the provided target to the specified next hop.

forward(RouteMessage) - Method in class rice.p2p.replication.manager.ReplicationManagerImpl

This method is invoked on applications when the underlying node is about to forward the given message with the provided target to the specified next hop.

forward(RouteMessage) - Method in class rice.p2p.scribe.ScribeImpl

This method is invoked on applications when the underlying node is about to forward the given message with the provided target to the specified next hop.

forward(RouteMessage) - Method in class rice.past.PASTServiceImpl

Deprecated. This method is invoked on applications when the underlying node is about to forward the given message with the provided target to the specified next hop.

forward(RouteMessage) - Method in class rice.pastry.client.CommonAPIAppl

Called by pastry when a message is enroute and is passing through this node.

forward(RouteMessage) - Method in class rice.pastry.testing.RegrTestApp

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

Called by Scribe before the node forwards a message to its children in the multicast tree.

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

up-call invoked by scribe when a publish message is forwarded through the multicast tree.

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

up-call invoked by scribe when a publish message is forwarded through the multicast tree.

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

up-call invoked by scribe when a publish message is forwarded through the multicast tree.

fractionUnsubscribedAllowed - Static variable in class rice.scribe.testing.DistScribeRegrTest

freeBandwidth(Channel, NodeHandle, Id) - Method in class rice.p2p.splitstream.SplitStreamScribePolicy

This method attempts to free bandwidth from our primary stripe.

freeBandwidthUltimate(Id) - Method in class rice.p2p.splitstream.SplitStreamScribePolicy

This method makes an attempt to free up bandwidth from non-primary, non-root stripes (for which local node is not root).

from() - Method in class rice.pastry.leafset.BroadcastLeafSet

Returns the node id of the node that broadcast its leaf set.

from() - Method in class rice.pastry.routing.BroadcastRouteRow

Gets the from node.

G

GlobalSocketManager - class rice.pastry.wire.GlobalSocketManager.

This is one of the first steps toward a centrally managed wire protocol that can support OS level limitations such as FileDescriptor limits.

GlobalSocketManager(WirePastryNode, int, Selector) - Constructor for class rice.pastry.wire.GlobalSocketManager

Constructs a new GlobalSocketManager.

generateIdRng - Variable in class rice.p2p.scribe.testing.ScribeRegrTest

generateIdRng - Variable in class rice.p2p.splitstream.testing.SplitStreamRegrTest

generateLeafSet(int, int, boolean) - Method in class rice.pastry.testing.LeafSetTest

Returns a leafset of size size out of a network with the specified number of nodes

generateNode(NodeHandle) - Method in class rice.pastry.testing.PastryRegrTest

generateNodeHandle(InetSocketAddress) - Method in class rice.pastry.dist.DistPastryNodeFactory

Method which all subclasses should implement allowing the client to generate a node handle given the address of a node.

generateNodeHandle(InetSocketAddress) - Method in class rice.pastry.rmi.RMIPastryNodeFactory

Specified by the DistPastryNodeFactory class.

generateNodeHandle(InetSocketAddress) - Method in class rice.pastry.wire.WirePastryNodeFactory

Method which contructs a node handle (using the wire protocol) for the node at address NodeHandle.

generateNodeId() - Method in interface rice.pastry.NodeIdFactory

Generates a nodeId.

generateNodeId() - Method in class rice.pastry.standard.IPNodeIdFactory

generate a nodeId multiple invocations result in a deterministic series of randomized NodeIds, seeded by the IP address of the local host.

generateNodeId() - Method in class rice.pastry.standard.RandomNodeIdFactory

generate a nodeId

generateOpenSockets() - Method in class rice.pastry.wire.GlobalSocketManager

Returns the staticlly allocated list.

generateOpenSockets() - Method in class rice.pastry.wire.SocketManager

Can be overloaded.

generateStripeIds(ChannelId, IdFactory) - Static method in class rice.p2p.splitstream.Channel

Creates and returns the Ids associated with the provided channelId

generateTopicId(String) - Method in class rice.rm.testing.DirectRMRegrTest

generateTopicId(String) - Method in class rice.rm.testing.DistRMRegrTestApp

generateTopicId(String) - Method in interface rice.scribe.IScribe

Generate a unique id for the topic, which will determine its rendezvous point.

generateTopicId(String) - Method in class rice.scribe.Scribe

Generate a unique id for the topic, which will determine its rendezvous point.

generateTopicId(String) - Method in class rice.scribe.testing.BasicScribeRegrTest

generateTopicId(String) - Method in class rice.scribe.testing.BasicScribeRegrTestApp

generateTopicId(String) - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

generateTopicId(String) - Static method in class rice.scribe.testing.DistScribeRegrTest

get(NodeId) - Method in class rice.pastry.NodeSet

Finds the NodeHandle associated with a NodeId.

get(int) - Method in class rice.pastry.NodeSet

Gets the ith element in the set.

get(NodeId) - Method in interface rice.pastry.NodeSetI

Finds the NodeHandle associated with the NodeId.

get(int) - Method in interface rice.pastry.NodeSetI

Gets the ith element in the set.

get(NodeId) - Method in class rice.pastry.leafset.LeafSet

Finds the NodeHandle associated with the NodeId.

get(int) - Method in class rice.pastry.leafset.LeafSet

Finds the NodeHandle at a given index.

get(NodeId) - Method in class rice.pastry.leafset.SimilarSet

Finds the NodeHandle associated with the NodeId.

get(int) - Method in class rice.pastry.leafset.SimilarSet

Gets the ith element in the set.

get(int) - Method in class rice.pastry.routing.RouteSet

Returns the node in the ith position in the set.

get(NodeId) - Method in class rice.pastry.routing.RouteSet

Returns the node handle with the matching node id or null if none exists.

get(NodeId) - Method in class rice.pastry.routing.RoutingTable

Gets the node handle associated with a given id.

get(NodeId) - Method in class rice.pastry.wire.WireNodeHandlePool

Looks up the WireNodeHandle given a NodeId

getAck(InetSocketAddress) - Method in class rice.pastry.wire.messaging.datagram.DatagramMessage

Returns the approriate 'ack' message for this datagram transport message.

getAddress() - Method in class rice.pastry.client.PastryAppl

Returns the address of this application.

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

Returns the IP address and port of the remote node.

getAddress() - Method in class rice.pastry.standard.StandardJoinProtocol

Get address.

getAddress() - Method in class rice.pastry.standard.StandardLeafSetProtocol

Gets the address.

getAddress() - Method in class rice.pastry.standard.StandardRouteSetProtocol

Gets the address.

getAddress() - Method in class rice.pastry.standard.StandardRouter

Gets the address of this component.

getAddress() - Method in class rice.pastry.testing.HelloWorldApp

Get address.

getAddress() - Method in class rice.pastry.testing.HelloWorldAppMultiThread

Get address.

getAddress() - Method in class rice.pastry.testing.Ping

getAddress() - Method in class rice.pastry.testing.PingClient

getAddress() - Method in class rice.pastry.testing.RegrTestApp

getAddress() - Method in class rice.pastry.wire.PendingWrite

Returns the destination address of this write

getAddress() - Method in class rice.pastry.wire.messaging.datagram.AcknowledgementMessage

Returns the address of the destination of this ack message.

getAddress() - Method in class rice.pastry.wire.messaging.socket.HelloMessage

Returns the address of the source of this message.

getAddress() - Method in class rice.pastry.wire.messaging.socket.HelloResponseMessage

Returns the address of the source of this message.

getAddress() - Method in class rice.scribe.Scribe

Returns the address of this client.

getAddress() - Method in class rice.scribe.testing.DistScribeRegrTestApp

getAlreadySentHBNodes() - Method in class rice.scribe.Scribe

Gets the vector of nodes to which an implicit HeartBeat in form of Publish message was sent in last HeartBeat period.

getAlternateId(int, int, int) - Method in class rice.pastry.Id

produces a set of ids (keys) that are evenly distributed around the id ring.

getAnycastMessages() - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

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

Gets all the applications that wish to receive events regarding this Topic.

getAttempt() - Method in class rice.rm.messaging.RMRequestKeysMsg

getAveDistance() - Method in class rice.pastry.testing.PingTestRecord

getAveHops() - Method in class rice.pastry.testing.PingTestRecord

getBestEntry(Id) - Method in class rice.pastry.routing.RoutingTable

Gets the set of handles that match at least one more digit of the key than the local nodeId.

getBootstrap() - Method in class rice.p2p.commonapi.testing.CommonAPITest

Gets a handle to a bootstrap node.

getBootstrap() - Method in class rice.past.testing.DistPASTRegrTest

Deprecated. Gets a handle to a bootstrap node.

getBootstrap() - Method in class rice.pastry.testing.ClosestRegrTest

Get pastryNodes.last() to bootstrap with, or return null.

getBootstrap(boolean) - Method in class rice.pastry.testing.DirectPastryRegrTest

Get pastryNodes.last() to bootstrap with, or return null.

getBootstrap(boolean) - Method in class rice.pastry.testing.DistHelloWorld

Gets a handle to a bootstrap node.

getBootstrap(boolean) - Method in class rice.pastry.testing.DistHelloWorldMultiThread

Gets a handle to a bootstrap node.

getBootstrap(boolean) - Method in class rice.pastry.testing.DistPastryRegrTest

Gets a handle to a bootstrap node.

getBootstrap(boolean) - Method in class rice.pastry.testing.PastryRegrTest

get a node handle to bootstrap from.

getCCW() - Method in class rice.pastry.Id

gets the Id just counterclockwise from this

getCCW() - Method in class rice.pastry.IdRange

get counterclockwise edge of range

getCCWId() - Method in interface rice.p2p.commonapi.IdRange

get counterclockwise edge of range

getCCWId() - Method in class rice.pastry.IdRange

get counterclockwise edge of range

getCW() - Method in class rice.pastry.Id

gets the Id just clockwise from this

getCW() - Method in class rice.pastry.IdRange

get clockwise edge of range

getCWId() - Method in interface rice.p2p.commonapi.IdRange

get clockwise edge of range

getCWId() - Method in class rice.pastry.IdRange

get clockwise edge of range

getCache() - Method in class rice.persistence.StorageManager

Returns the cache object used by this StorageManager

getChannelId() - Method in class rice.p2p.splitstream.Channel

Gets the channelId for this channel

getChannels() - Method in interface rice.p2p.splitstream.SplitStream

Returns all of the channels on this local splitstream

getChannels() - Method in class rice.p2p.splitstream.SplitStreamImpl

Returns all of the channels on this local splitstream

getChildren(Topic) - Method in interface rice.p2p.scribe.Scribe

Returns the list of children for a given topic

getChildren() - Method in class rice.p2p.scribe.ScribeImpl.TopicManager

Gets the Children attribute of the TopicManager object

getChildren(Topic) - Method in class rice.p2p.scribe.ScribeImpl

Returns the list of children for a given topic

getChildren() - Method in class rice.p2p.splitstream.Stripe

Utility method.

getChildren(NodeId) - Method in interface rice.scribe.IScribe

This returns the most current view of the children in this topic's multicast subtree rooted at the local node.

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

This returns the most current view of the children in this topic's multicast subtree rooted at the local node.

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

This returns the most current view of the children in this topic's multicast subtree rooted at the local node.

getClients() - Method in class rice.p2p.scribe.ScribeImpl.TopicManager

Gets the Clients attribute of the TopicManager object

getClients(Topic) - Method in class rice.p2p.scribe.ScribeImpl

Returns the list of clients for a given topic

getClosest(NodeId) - Method in class rice.pastry.direct.EuclideanNetwork

find the closest NodeId to an input NodeId out of all NodeIds in the network

getClosest(NodeId) - Method in interface rice.pastry.direct.NetworkSimulator

getClosest(NodeId) - Method in class rice.pastry.direct.SphereNetwork

find the closest NodeId to an input NodeId out of all NodeIds in the network

getComplementRange() - Method in interface rice.p2p.commonapi.IdRange

get the complement of this range

getComplementRange() - Method in class rice.pastry.IdRange

get the complement of this range

getContent() - Method in class rice.p2p.past.messaging.CacheMessage

Method which returns the content

getContent() - Method in class rice.p2p.past.messaging.InsertMessage

Method which returns the content

getContent() - Method in class rice.p2p.scribe.messaging.AnycastMessage

Returns the content

getContent() - Method in class rice.p2p.scribe.messaging.PublishMessage

Returns the content

getContent() - Method in class rice.p2p.scribe.messaging.PublishRequestMessage

Returns the content

getContent() - Method in class rice.past.messaging.MessageFetch

Deprecated. Returns the located storage object.

getContent() - Method in class rice.past.messaging.MessageLookup

Deprecated. Returns the located storage object.

getCount() - Method in class rice.pastry.wire.testing.WireFileProcessor.ObjPair

getCount() - Method in class rice.scribe.testing.DistTopicLog

getCredentials() - Method in class rice.pastry.client.CommonAPIAppl

Returns the credentials of this application.

getCredentials() - Method in class rice.pastry.client.PastryAppl

Returns the credentials of this application.

getCredentials() - Method in class rice.pastry.commonapi.PastryEndpoint

Returns the credentials of this application.

getCredentials() - Method in class rice.pastry.messaging.Message

Gets the credentials of the sender.

getCredentials() - Method in class rice.pastry.testing.HelloWorldApp

Get credentials.

getCredentials() - Method in class rice.pastry.testing.HelloWorldAppMultiThread

Get credentials.

getCredentials() - Method in class rice.pastry.testing.Ping

getCredentials() - Method in class rice.pastry.testing.PingClient

getCredentials() - Method in class rice.pastry.testing.RegrTestApp

getCredentials() - Method in class rice.rm.RMImpl

Returns the credentials for the application

getCredentials() - Method in class rice.rm.messaging.RMMessage

Gets the author's credentials associated with this object

getCredentials() - Method in class rice.rm.testing.RMRegrTestApp

getCredentials() - Method in class rice.rm.testing.TestMessage

getCredentials() - Method in class rice.scribe.Scribe

Returns the credentials of this client.

getCredentials() - Method in class rice.scribe.testing.DistScribeRegrTestApp

getData() - Method in class rice.p2p.splitstream.SplitStreamContent

Returns the data for this content

getData() - Method in class rice.scribe.messaging.ScribeMessage

Gets the data inside of the ScribeMessage object.

getDatagramManager() - Method in class rice.pastry.wire.WirePastryNode

Returns the DatagramManager for this pastry node.

getDate() - Method in class rice.pastry.messaging.Message

Gets the timestamp of the message, if it exists.

getDest() - Method in class rice.rm.messaging.RMRequestKeysMsg.WrappedMsg

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

Method which returns this messages' destination address

getDestination() - Method in class rice.pastry.messaging.Message

Gets the address of message receiver that the message is for.

getDestination() - Method in class rice.pastry.routing.RouteMessage

Get receiver address.

getDestination() - Method in class rice.pastry.wire.PendingWrite

Returns the destination address of this write

getDestination() - Method in class rice.pastry.wire.messaging.datagram.DatagramMessage

Returns the NodeId which is the destination

getDestination() - Method in class rice.pastry.wire.messaging.socket.HelloMessage

Returns the NodeId of the source

getDestination() - Method in class rice.pastry.wire.messaging.socket.HelloResponseMessage

Returns the NodeId of the source

getDestination() - Method in class rice.pastry.wire.messaging.socket.SocketTransportMessage

Returns the destination node id

getDestinationId() - Method in interface rice.p2p.commonapi.RouteMessage

Returns the destination Id for this message

getDestinationId() - Method in class rice.p2p.past.testing.PastRegrTest.TestRouteMessage

getDestinationId() - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestRouteMessage

Gets the DestinationId attribute of the TestRouteMessage object

getDestinationId() - Method in class rice.pastry.routing.RouteMessage

getDigit(int, int) - Method in class rice.pastry.Id

Gets the ith digit in base 2^b.

getDistance() - Method in class rice.pastry.testing.PingMessageNew

getDistinctChildren() - Method in class rice.scribe.Scribe

Gets the Vector of distinct children of this local node in multicast tree of all topics.

getDistinctParents() - Method in class rice.scribe.Scribe

Gets the Vector of distinct parent of this local node in the multicast trees of all topics.

getDomainPrefix(int, int, int, int) - Method in class rice.pastry.Id

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.

getEventId() - Method in class rice.rm.messaging.RMRequestKeysMsg

getEventId() - Method in class rice.rm.messaging.RMResponseKeysMsg

getException() - Method in class rice.Continuation.ExternalContinuation

getFactory(NodeIdFactory, int, int) - Static method in class rice.pastry.dist.DistPastryNodeFactory

Static method which is designed to be used by clients needing a distrubuted pastry node factory.

getFileId() - Method in class rice.past.messaging.PASTMessage

Deprecated. Gets the fileId for this file, which is used as the destination.

getFingerprintForChildTopics(NodeHandle) - Method in class rice.scribe.Scribe

getFingerprintForParentTopics(NodeHandle) - Method in class rice.scribe.Scribe

getHandle(Id) - Method in interface rice.p2p.commonapi.NodeHandleSet

Finds the NodeHandle associated with the NodeId.

getHandle(int) - Method in interface rice.p2p.commonapi.NodeHandleSet

Gets the ith element in the set.

getHandle(Past) - Method in class rice.p2p.past.ContentHashPastContent

Produces a handle for this content object.

getHandle(Past) - Method in interface rice.p2p.past.PastContent

Produces a handle for this content object.

getHandle() - Method in class rice.p2p.past.messaging.FetchMessage

Method which returns the handle

getHandle(Past) - Method in class rice.p2p.past.testing.PastRegrTest.TestPastContent

getHandle(Id) - Method in class rice.pastry.NodeSet

Finds the NodeHandle associated with the NodeId.

getHandle(int) - Method in class rice.pastry.NodeSet

Gets the ith element in the set.

getHandle() - Method in class rice.pastry.join.InitiateJoin

Gets the handle for the join.

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

Gets the handle of the node trying to join.

getHandle(Id) - Method in class rice.pastry.leafset.SimilarSet

Finds the NodeHandle associated with the NodeId.

getHandle(int) - Method in class rice.pastry.leafset.SimilarSet

Gets the ith element in the set.

getHandle(Id) - Method in class rice.pastry.routing.RouteSet

Finds the NodeHandle associated with the NodeId.

getHandle(int) - Method in class rice.pastry.routing.RouteSet

Gets the ith element in the set.

getHash() - Method in class rice.pastry.IdSet

compute a fingerprint of the members in this IdSet

getHash() - Method in class rice.rm.messaging.RMMessage.KEEntry

getHashEnabled() - Method in class rice.rm.messaging.RMMessage.KEEntry

getHashes() - Method in class rice.p2p.replication.messaging.RequestMessage

Method which returns this messages' hashes

getHops() - Method in class rice.pastry.testing.PingMessageNew

getID() - Method in class rice.past.messaging.PASTMessage

Deprecated. Gets this message's identifier.

getIDCode() - Method in class rice.past.messaging.PASTMessageIDImpl

Deprecated. Returns the internal representation of the id.

getId() - Method in interface rice.p2p.commonapi.Endpoint

Returns this node's id, which is its identifier in the namespace.

getId() - Method in interface rice.p2p.commonapi.Node

Returns the Id of this node

getId() - Method in class rice.p2p.commonapi.NodeHandle

Returns this node's id.

getId() - Method in class rice.p2p.past.ContentHashPastContent

Returns the Id under which this object is stored in Past.

getId() - Method in class rice.p2p.past.ContentHashPastContentHandle

Returns the id of the PastContent object associated with this handle

getId() - Method in interface rice.p2p.past.PastContent

Returns the Id under which this object is stored in Past.

getId() - Method in interface rice.p2p.past.PastContentHandle

get the id of the PastContent object associated with this handle

getId() - Method in class rice.p2p.past.messaging.FetchHandleMessage

Method which returns the id

getId() - Method in class rice.p2p.past.messaging.LookupHandlesMessage

Method which returns the id

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

Method which returns the id

getId() - Method in class rice.p2p.past.testing.PastRegrTest.TestPastContent

getId() - Method in class rice.p2p.past.testing.PastRegrTest.TestPastContentHandle

getId() - Method in class rice.p2p.scribe.ScribeImpl

Returns the Id of the local node

getId() - Method in class rice.p2p.scribe.Topic

Returns the Id to which this topic is mapped

getId(IdFactory, String) - Static method in class rice.p2p.scribe.Topic

Returns the Id to which the string is mapped

getId() - Method in class rice.p2p.scribe.messaging.AbstractSubscribeMessage

Returns this subscribe lost message's id

getId() - Method in class rice.p2p.scribe.messaging.SubscribeMessage

Returns this subscribe lost message's id

getId() - Method in class rice.p2p.splitstream.ChannelId

Gets the Id attribute of the ChannelId object

getId() - Method in class rice.p2p.splitstream.StripeId

Gets the Id attribute of the StripeId object

getId() - Method in class rice.past.PASTServiceImpl

Deprecated. Returns the Node

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

getId() - Method in class rice.pastry.PastryNode

Returns the Id of this node

getId() - Method in class rice.pastry.commonapi.PastryEndpoint

Returns this node's id, which is its identifier in the namespace.

getId() - Method in class rice.pastry.testing.HelloMsg

getIdFactory() - Method in interface rice.p2p.commonapi.Node

Returns a factory for Ids specific to this node's protocol.

getIdFactory() - Method in class rice.pastry.PastryNode

Returns a factory for Ids specific to this node's protocol.

getIdSet() - Method in class rice.p2p.replication.messaging.ResponseMessage

Method which returns this messages' ranges

getIndex(NodeId) - Method in class rice.pastry.NodeSet

Gets the index of the element with the given node id.

getIndex(NodeId) - Method in interface rice.pastry.NodeSetI

Gets the index of the element with the given node id.

getIndex(NodeId) - Method in class rice.pastry.leafset.LeafSet

Gets the index of the element with the given node id.

getIndex(NodeId) - Method in class rice.pastry.leafset.SimilarSet

Gets the index of the element with the given node id.

getIndex(NodeId) - Method in class rice.pastry.routing.RouteSet

Get the index of the node id.

getIndexHandle(Id) - Method in interface rice.p2p.commonapi.NodeHandleSet

Gets the index of the element with the given node id.

getIndexHandle(Id) - Method in class rice.pastry.NodeSet

Gets the index of the element with the given node id.

getIndexHandle(Id) - Method in class rice.pastry.leafset.SimilarSet

Gets the index of the element with the given node id.

getIndexHandle(Id) - Method in class rice.pastry.routing.RouteSet

Gets the index of the element with the given node id.

getIsInPool() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Returns whether or not this node handle is the one in the node handle pool.

getIterator() - Method in interface rice.p2p.commonapi.IdSet

return an iterator over the elements of this set

getIterator() - Method in class rice.pastry.IdSet

return an iterator over the elements of this set

getIterator() - Method in class rice.pastry.NodeSet

return an iterator that iterates over the elements of this set

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

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

Gets the handle of the node that accepted the join request;

getKeySet() - Method in class rice.rm.messaging.RMMessage.KEEntry

getLastRecvTime() - Method in class rice.scribe.testing.DistTopicLog

getLastSeqNumRecv() - Method in class rice.scribe.testing.DistTopicLog

getLeafSet() - Method in class rice.pastry.PastryNode

getLeafSet(NodeHandle) - Method in class rice.pastry.PastryNodeFactory

This method returns the remote leafset of the provided handle to the caller, in a protocol-dependent fashion.

getLeafSet() - Method in class rice.pastry.client.PastryAppl

Called by a layered Pastry application to obtain a copy of the leaf set.

getLeafSet(NodeHandle) - Method in class rice.pastry.direct.DirectPastryNodeFactory

This method returns the remote leafset of the provided handle to the caller, in a protocol-dependent fashion.

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

Gets the leafset of the node that accepted the join request;

getLeafSet(NodeHandle) - Method in class rice.pastry.rmi.RMIPastryNodeFactory

This method returns the remote leafset of the provided handle to the caller, in a protocol-dependent fashion.

getLeafSet() - Method in interface rice.pastry.rmi.RMIRemoteNodeI

getLeafSet(NodeHandle) - Method in class rice.pastry.wire.WirePastryNodeFactory

This method returns the remote leafset of the provided handle to the caller, in a protocol-dependent fashion.

getLeafSet() - Method in class rice.pastry.wire.messaging.socket.LeafSetResponseMessage

Returns the leafset of the receiver.

getLocalHandle() - Method in class rice.pastry.PastryNode

getLocalHandle() - Method in class rice.rm.RMImpl

Gets the local NodeHandle associated with this Pastry node.

getLocalHandle() - Method in class rice.rm.testing.RMRegrTestApp

getLocalHandle() - Method in class rice.scribe.Scribe

getLocalHandle() - Method in class rice.scribe.testing.DirectScribeMaintenanceTestApp

getLocalId() - Method in class rice.p2p.splitstream.Channel

Gets the local node id.

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

Accessor method.

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

Accessor method.

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

Accessor method.

getLocalNodeHandle() - Method in interface rice.p2p.commonapi.Endpoint

Returns a handle to the local node below this endpoint.

getLocalNodeHandle() - Method in interface rice.p2p.past.Past

get the nodeHandle of the local Past node

getLocalNodeHandle() - Method in class rice.p2p.past.PastImpl

get the nodeHandle of the local Past node

getLocalNodeHandle() - Method in class rice.pastry.commonapi.PastryEndpoint

Returns a handle to the local node below this endpoint.

getMax() - Method in class rice.p2p.past.messaging.LookupHandlesMessage

Method which returns the number of replicas

getMaxChildren(ChannelId) - Method in class rice.p2p.splitstream.SplitStreamScribePolicy

Gets the max bandwidth for a channel.

getMaximumSize(Continuation) - Method in interface rice.persistence.Cache

Returns the maximum size of the cache, in bytes.

getMaximumSize(Continuation) - Method in class rice.persistence.LRUCache

Returns the maximum size of the cache, in bytes.

getMaximumSize(Continuation) - Method in class rice.persistence.StorageManager

Returns the maximum size of the cache, in bytes.

getMessage() - Method in interface rice.p2p.commonapi.RouteMessage

Returns the enclosed message inside of this message

getMessage() - Method in class rice.p2p.past.testing.PastRegrTest.TestRouteMessage

getMessage() - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestRouteMessage

Gets the Message attribute of the TestRouteMessage object

getMessage() - Method in class rice.pastry.ScheduledMessage

Returns the message

getMessage() - Method in class rice.pastry.commonapi.PastryEndpointMessage

Returns the internal message

getMessage() - Method in class rice.pastry.routing.RouteMessage

getMessageDigest(int, String, String, String, int, boolean) - Method in class rice.pastry.wire.testing.MessageDigestFactory

getMessageDispatch() - Method in class rice.pastry.PastryNode

FOR TESTING ONLY - DO NOT USE!

getMsg() - Method in class rice.rm.messaging.RMRequestKeysMsg.WrappedMsg

getNearest(NodeHandle, NodeHandle) - Method in class rice.pastry.PastryNodeFactory

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.

getNetworkSimulator() - Method in class rice.pastry.direct.DirectPastryNodeFactory

getNext() - Method in class rice.p2p.scribe.messaging.AnycastMessage

Returns the next handle to visit and removes the node from the list.

getNextHop() - Method in class rice.pastry.routing.RouteMessage

getNextHopHandle() - Method in interface rice.p2p.commonapi.RouteMessage

Returns the next hop handle for this message

getNextHopHandle() - Method in class rice.p2p.past.testing.PastRegrTest.TestRouteMessage

getNextHopHandle() - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestRouteMessage

Gets the NextHopHandle attribute of the TestRouteMessage object

getNextHopHandle() - Method in class rice.pastry.routing.RouteMessage

getNextId() - Method in class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

Interal method which safely takes the next id to be fetched from the set of pending keys

getNextUID() - Method in class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

Returns the next unique id for a message

getNodeHandle() - Method in class rice.p2p.past.ContentHashPastContentHandle

Returns the NodeHandle of the Past node on which the object associated with this handle is stored

getNodeHandle() - Method in interface rice.p2p.past.PastContentHandle

get the NodeHandle of the Past node on which the object associated with this handle is stored

getNodeHandle() - Method in class rice.p2p.past.testing.PastRegrTest.TestPastContentHandle

getNodeHandle() - Method in class rice.pastry.client.PastryAppl

Gets the handle of the Pastry node associated with this client

getNodeHandle(InetSocketAddress) - Method in class rice.pastry.dist.DistPastryNodeFactory

Method which a client should use in order to get a bootstrap node from the factory.

getNodeHandle() - Method in class rice.scribe.Scribe

Returns the handle of the local node on which this Scribe application resides.

getNodeHandlePool() - Method in class rice.pastry.dist.DistPastryNode

Method which returns the Dist for this Pastry node.

getNodeHandlePool() - Method in class rice.pastry.rmi.RMIPastryNode

accessor method for RMI handle pool.

getNodeHandlePool() - Method in class rice.pastry.wire.WirePastryNode

Returns the WireNodeHandlePool for this pastry node.

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

Gets the nodeId of this Pastry node.

getNodeId() - Method in class rice.pastry.PastryNode

getNodeId() - Method in class rice.pastry.client.PastryAppl

Gets the node id associated with this client.

getNodeId() - Method in class rice.pastry.direct.DirectNodeHandle

Gets the NodeId attribute of the DirectNodeHandle object

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

Gets the nodeId of this Pastry node.

getNodeId() - Method in interface rice.pastry.rmi.RMIRemoteNodeI

getNodeId() - Method in class rice.pastry.testing.LeafSetTest.TestNodeHandle

getNodeId() - Method in class rice.pastry.wire.messaging.socket.HelloMessage

Returns the NodeId of the source

getNodeId() - Method in class rice.pastry.wire.messaging.socket.HelloResponseMessage

Returns the NodeId of the source

getNodeId() - Method in class rice.pastry.wire.messaging.socket.NodeIdResponseMessage

Returns the nodeId of the receiver.

getNodeId() - Method in class rice.scribe.testing.BasicScribeRegrTestApp

getNodeId() - Method in class rice.scribe.testing.DirectScribeMaintenanceTestApp

getNodeNumber() - Method in class rice.pastry.direct.TestRecord

returns the number of nodes

getNum() - Method in class rice.pastry.wire.messaging.datagram.DatagramMessage

Returns the "packet number" of this transmission

getNumAcks() - Method in class rice.rm.testing.RMRegrTestApp.ReplicateEntry

getNumFDsUsed() - Static method in class rice.pastry.wire.Wire

will throw an error on platforms other than Linux/BSD

getNumKeys() - Method in class rice.rm.RMImpl.KEPenEntry

getNumKeys() - Method in class rice.rm.messaging.RMMessage.KEEntry

getNumUnsubscribed(NodeId) - Static method in class rice.scribe.testing.DistScribeRegrTest

getObject() - Method in class rice.pastry.wire.PendingWrite

Returns the object to be written

getObject() - Method in class rice.pastry.wire.messaging.datagram.DatagramTransportMessage

Returns the iternal wrapped object.

getObject() - Method in class rice.pastry.wire.messaging.socket.SocketTransportMessage

Returns the wrapped message

getObject(Id, Continuation) - Method in interface rice.persistence.Catalog

Returns the object identified by the given id, or null if there is no cooresponding object (through receiveResult on c).

getObject(Id, Continuation) - Method in class rice.persistence.LRUCache

Returns the object identified by the given id.

getObject(Id, Continuation) - Method in class rice.persistence.MemoryStorage

Returns the object identified by the given id, or null if there is no cooresponding object (through receiveResult on c).

getObject(Id, Continuation) - Method in class rice.persistence.PersistentStorage

Returns the object identified by the given id.

getObject(Id, Continuation) - Method in class rice.persistence.StorageManager

Returns the object identified by the given id, or null if there is no cooresponding object (through receiveResult on c).

getObject() - Method in class rice.rm.testing.InsertMsg

Gets the object contained in this message

getObject() - Method in class rice.rm.testing.RMRegrTestApp.ReplicateEntry

getObjectKey() - Method in class rice.rm.testing.HeartbeatMsg

Gets the objectKey of the object.

getObjectKey() - Method in class rice.rm.testing.InsertMsg

Gets the objectKey of the object.

getObjectKey() - Method in class rice.rm.testing.InsertResponseMsg

getObjectKey() - Method in class rice.rm.testing.RefreshMsg

Gets the objectKey of the object.

getObjectKey() - Method in class rice.rm.testing.ReplicateMsg

Gets the objectKey of the object.

getObjectKey() - Method in class rice.rm.testing.ReplicateResponseMsg

getObjectKey() - Method in class rice.rm.testing.ReplicateTimeoutMsg

getOptions() - Method in class rice.pastry.routing.RouteMessage

Get transmission options.

getParent() - Method in class rice.p2p.scribe.ScribeImpl.TopicManager

Gets the Parent attribute of the TopicManager object

getParent(Topic) - Method in class rice.p2p.scribe.ScribeImpl

Returns the parent for a given topic

getParent() - Method in class rice.p2p.splitstream.Stripe

Utility method.

getParent(NodeId) - Method in interface rice.scribe.IScribe

Returns the local node's parent in this topic's multicast tree.

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

Returns the local node's parent in this topic's multicast tree.

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

Returns the local node's parent in this topic's multicast tree.

getPastryNode() - Method in class rice.rm.RMImpl

Gets the underlying local Pastry node.

getPastryNode() - Method in class rice.rm.testing.RMRegrTestApp

getPastryNode() - Method in class rice.scribe.Scribe

Returns the pastryNode for this application.

getPathToRoot() - Method in class rice.p2p.scribe.ScribeImpl.TopicManager

Gets the PathToRoot attribute of the TopicManager object

getPathToRoot() - Method in class rice.p2p.scribe.messaging.SubscribeAckMessage

Returns the path to the root for the node receiving this message

getPendingObject(Id) - Method in class rice.rm.testing.RMRegrTestApp

getPendingRanges(NodeId) - Method in class rice.rm.RMImpl

Gets the list of pending Ranges corresponding to a node that we are communicating to in the Keys Exchange Protocol.

getPolicy() - Method in interface rice.p2p.scribe.Scribe

Returns the current policy for this scribe object

getPolicy() - Method in class rice.p2p.scribe.ScribeImpl

Returns the current policy for this scribe object

getPolicy() - Method in class rice.p2p.splitstream.SplitStreamImpl

Returns the policy used to control Scribe

getPrefixMatch(Id, Id) - Static method in class rice.p2p.splitstream.SplitStreamScribePolicy

Helper method for finding prefix match between two Ids.

getPrevNode() - Method in class rice.pastry.routing.RouteMessage

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

Method which returns the previous hop (where the message was just at)

getPreviousParent() - Method in class rice.p2p.scribe.messaging.SubscribeMessage

Returns the node who is trying to subscribe

getPrimaryStripe() - Method in class rice.p2p.splitstream.Channel

The primary stripe is the stripe that the user must have.

getProbability() - Method in class rice.pastry.testing.PingTestRecord

getProximity(NodeHandle, NodeHandle) - Method in class rice.pastry.PastryNodeFactory

This method determines and returns the proximity of the current local node the provided NodeHandle.

getProximity(NodeHandle, NodeHandle) - Method in class rice.pastry.direct.DirectPastryNodeFactory

This method determines and returns the proximity of the current local node the provided NodeHandle.

getProximity(NodeHandle, NodeHandle) - Method in class rice.pastry.rmi.RMIPastryNodeFactory

This method determines and returns the proximity of the current local node the provided NodeHandle.

getProximity(NodeHandle, NodeHandle) - Method in class rice.pastry.wire.WirePastryNodeFactory

This method determines and returns the proximity of the current local node the provided NodeHandle.

getPublishMessages() - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

getQueue() - Method in class rice.pastry.wire.SocketChannelWriter

Returns the queue of writes for the remote address We are only returning the iterator of the queue because we don't actually want to return the queue, as we need to control the SelectionKey state based on the queue.

getRM() - Method in class rice.past.PASTServiceImpl

Deprecated. Return the RM

getRange() - Method in class rice.rm.messaging.RMMessage.KEEntry

getRanges() - Method in class rice.p2p.replication.messaging.RequestMessage

Method which returns this messages' ranges

getReader(File) - Static method in class rice.pastry.wire.testing.WireFileProcessor

getReady() - Method in class rice.pastry.wire.DatagramTransmissionManager

Returns an iterator over the pending writes ready to be written.

getRemote() - Method in class rice.pastry.direct.DirectNodeHandle

Gets the Remote attribute of the DirectNodeHandle object

getRemote() - Method in class rice.pastry.rmi.RMINodeHandle

Remotenode accessor method.

getReplicaManager() - Method in class rice.p2p.past.PastImpl

Returns the replica manager for this Past instance.

getReplicaSet() - Method in class rice.rm.testing.ReplicateResponseMsg

getReplication() - Method in class rice.p2p.replication.manager.ReplicationManagerImpl

Utility method which returns the underlying replication object.

getReplicationFactor() - Method in interface rice.p2p.past.Past

Returns the number of replicas used in this Past

getReplicationFactor() - Method in class rice.p2p.past.PastImpl

Returns the number of replicas used in this Past

getReqRange() - Method in class rice.rm.RMImpl.KEPenEntry

getReqRange() - Method in class rice.rm.messaging.RMMessage.KEEntry

getResponse() - Method in class rice.p2p.past.messaging.ContinuationMessage

Returns the response

getResponse(InetSocketAddress, SocketCommandMessage) - Method in class rice.pastry.wire.WirePastryNodeFactory

This method anonymously sends the given message to the remote address, blocks until a response is received, and then closes the socket and returns the response.

getResponse(WirePastryNode) - Method in class rice.pastry.wire.messaging.socket.HelloMessage

Returns the appropriate response for this HelloMessage

getResult() - Method in class rice.Continuation.ExternalContinuation

getRoot() - Method in class rice.persistence.PersistentStorage

gets the root directory that the persistence Manager uses

getRouteRow(NodeHandle, int) - Method in class rice.pastry.PastryNodeFactory

This method returns the remote route row of the provided handle to the caller, in a protocol-dependent fashion.

getRouteRow(NodeHandle, int) - Method in class rice.pastry.direct.DirectPastryNodeFactory

This method returns the remote route row of the provided handle to the caller, in a protocol-dependent fashion.

getRouteRow(int) - Method in class rice.pastry.rmi.RMIPastryNode

Returns the given row of the routing table

getRouteRow(NodeHandle, int) - Method in class rice.pastry.rmi.RMIPastryNodeFactory

This method returns the remote route row of the provided handle to the caller, in a protocol-dependent fashion.

getRouteRow(int) - Method in interface rice.pastry.rmi.RMIRemoteNodeI

getRouteRow(NodeHandle, int) - Method in class rice.pastry.wire.WirePastryNodeFactory

This method returns the remote route row of the provided handle to the caller, in a protocol-dependent fashion.

getRouteRow() - Method in class rice.pastry.wire.messaging.socket.RouteRowResponseMessage

Returns the routeset of the receiver.

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

Gets the set of handles at a particular entry in the table.

getRoutingTable() - Method in class rice.pastry.PastryNode

getRoutingTable() - Method in class rice.pastry.client.PastryAppl

Called by a layered Pastry application to obtain a copy of the routing table.

getRow(int) - Method in class rice.pastry.join.JoinRequest

Get row.

getRow() - Method in class rice.pastry.routing.BroadcastRouteRow

Gets the row that was sent in the message.

getRow() - Method in class rice.pastry.routing.RequestRouteRow

Gets the row that made the request.

getRow(int) - Method in class rice.pastry.routing.RoutingTable

Get a row from the routing table.

getRow() - Method in class rice.pastry.wire.messaging.socket.RouteRowRequestMessage

Returns the row which this a request for

getScribe() - Method in class rice.scribe.testing.DirectScribeMaintenanceTestApp

Returns the underlying scribe object.

getScribe() - Method in class rice.scribe.testing.DistScribeRegrTestApp

getSecurityManager() - Method in class rice.scribe.Scribe

Returns the security manager from the Scribe node.

getSeed() - Static method in class rice.pastry.PastrySeed

getSelector() - Method in class rice.pastry.wire.SelectorManager

Returns the selector used by this SelectorManager.

getSelectorManager() - Method in class rice.pastry.wire.WirePastryNode

Returns the SelectorManager for this pastry node.

getSendOptions() - Method in class rice.scribe.Scribe

Returns the send options in the Scribe system.

getSenderId() - Method in class rice.pastry.messaging.Message

Get sender Id.

getSeqNumToPublish() - Method in class rice.scribe.testing.DistTopicLog

getSeqno() - Method in class rice.rm.messaging.RMMessage

getSimulator() - Method in class rice.pastry.direct.DirectNodeHandle

Gets the Simulator attribute of the DirectNodeHandle object

getSocketManager() - Method in class rice.pastry.wire.WirePastryNode

Returns the SocketManager for this pastry node.

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

Method which returns this messages' source address

getSource() - Method in class rice.p2p.replication.messaging.ReplicationMessage

Method which returns this messages' source address

getSource() - Method in class rice.p2p.scribe.messaging.ScribeMessage

Method which returns this messages' source address

getSource() - Method in class rice.past.messaging.PASTMessage

Deprecated. Gets the source Id for this message.

getSource() - Method in class rice.pastry.testing.PingMessageNew

getSource() - Method in class rice.pastry.wire.messaging.datagram.DatagramMessage

Returns the NodeId from which this message came.

getSource() - Method in class rice.rm.messaging.RMMessage

getSource() - Method in class rice.rm.testing.TestMessage

getSource() - Method in class rice.scribe.messaging.ScribeMessage

Returns the nodeId of the node that generated the message.

getStage() - Method in class rice.p2p.splitstream.SplitStreamSubscribeContent

Returns the data for this content

getState() - Method in class rice.pastry.wire.WireNodeHandle

Returns the state of this WireNodeHandle

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

Gets the current state of topic.

getStorage() - Method in class rice.past.PASTServiceImpl

Deprecated. Returns the StorageManager object

getStorage() - Method in class rice.persistence.StorageManager

Returns the permantent storage object used by this StorageManager

getStorageManager() - Method in class rice.p2p.past.PastImpl

Returns this Past's storage manager.

getStorageSize() - Method in class rice.persistence.PersistentStorage

gets the amount of storage that the persistence Manager uses

getStream() - Method in class rice.pastry.messaging.Message

Get stream over which the object was deserialized.

getStripeId() - Method in class rice.p2p.splitstream.Stripe

gets the StripeID for this stripe

getStripes() - Method in class rice.p2p.splitstream.Channel

At any moment a node is subscribed to at least 1 but possibly more stripes.

getSubscribeFailed() - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

getSubscriber() - Method in class rice.p2p.scribe.messaging.SubscribeMessage

Returns the node who is trying to subscribe

getSuccess() - Method in class rice.past.messaging.MessageInsert

Deprecated. Returns whether the insert was successful.

getSuccess() - Method in class rice.past.messaging.MessageReclaim

Deprecated. Returns whether the reclaim command was successful.

getTarget() - Method in class rice.pastry.routing.RouteMessage

Gets the target node id of this message.

getTestNumber() - Method in class rice.pastry.direct.TestRecord

returns the number of tests

getTestRecord() - Method in class rice.pastry.direct.EuclideanNetwork

get TestRecord

getTestRecord() - Method in interface rice.pastry.direct.NetworkSimulator

getTestRecord() - Method in class rice.pastry.direct.SphereNetwork

get TestRecord

getTimestamp() - Method in class rice.pastry.direct.DirectSecurityManager

Gets the current time for a timestamp.

getTimestamp() - Method in class rice.pastry.rmi.RMIPastrySecurityManager

Gets the current time for a timestamp.

getTimestamp() - Method in interface rice.pastry.security.PastrySecurityManager

Gets the current time for a timestamp.

getTimestamp() - Method in class rice.pastry.security.PermissiveSecurityManager

getTimestamp() - Method in class rice.pastry.wire.WirePastrySecurityManager

Gets the current time for a timestamp.

getTopic() - Method in class rice.p2p.scribe.messaging.ScribeMessage

Method which returns this messages' topic

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

Returns the topic object associated with topicId.

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

Returns the topic's id

getTopicId() - Method in class rice.scribe.messaging.ScribeMessage

Returns the topicId associated with the message.

getTopics() - Method in class rice.scribe.Scribe

Method to access the list of topics this scribe is responsible for.

getTopicsForChild(NodeHandle) - Method in class rice.scribe.Scribe

Gets the vector of topicIds for which given node is a child.

getTopicsForParent(NodeHandle) - Method in class rice.scribe.Scribe

Gets the vector of topicIds for which given node is our parent.

getTotalChildren(Channel) - Method in class rice.p2p.splitstream.SplitStreamScribePolicy

Returns the total number of children for the given channel

getTotalRange() - Method in class rice.p2p.replication.ReplicationImpl

Returns the range for which the local node is an i root, where i can range between 0 and replicationFactor

getTotalSize(Continuation) - Method in interface rice.persistence.Catalog

Returns the total size of the stored data in bytes.The result is returned via the receiveResult method on the provided Continuation with a Long representing the total size used.

getTotalSize(Continuation) - Method in class rice.persistence.LRUCache

Returns the total size of the stored data in bytes.

getTotalSize(Continuation) - Method in class rice.persistence.MemoryStorage

Returns the total size of the stored data in bytes.The result is returned via the receiveResult method on the provided Continuation with an Integer representing the size.

getTotalSize(Continuation) - Method in class rice.persistence.PersistentStorage

Returns the total size of the stored data in bytes.The result is returned via the receiveResult method on the provided Continuation with an Integer representing the size.

getTotalSize(Continuation) - Method in class rice.persistence.StorageManager

Returns the total size of the stored data in bytes.The result is returned via the receiveResult method on the provided Continuation with an Integer representing the size.

getTreeRepairThreshold() - Method in class rice.scribe.Scribe

Gets the tree repair threshold value.

getType() - Method in class rice.past.messaging.PASTMessage

Deprecated. Gets this message's type.

getType(String) - Static method in class rice.pastry.wire.testing.WireFileProcessor

getType(int) - Static method in class rice.pastry.wire.testing.WireFileProcessor

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

Method which returns this messages' unique id

getUID() - Method in class rice.p2p.replication.manager.messaging.TimeoutMessage

Returns the unique id of this message

getUnsubscribed() - Method in class rice.scribe.testing.DistTopicLog

getmissingCount() - Method in class rice.rm.testing.ObjectState

getstaleCount() - Method in class rice.rm.testing.ObjectState

greetingReceived() - Method in class rice.pastry.wire.SocketChannelWriter

called when the greeting has been received, setting that the socket is ready to be used to write data over

H

Half - Static variable in class rice.pastry.Id

HeartbeatMsg - class rice.rm.testing.HeartbeatMsg.

HeartbeatMsg(NodeHandle, Address, Id, Credentials) - Constructor for class rice.rm.testing.HeartbeatMsg

Constructor : Builds a new Heartbeat Message

HelloMessage - class rice.pastry.wire.messaging.socket.HelloMessage.

Class which represents a greeting in the socket-based pastry protocol.

HelloMessage(WirePastryNode, NodeId) - Constructor for class rice.pastry.wire.messaging.socket.HelloMessage

Constructor

HelloMessageDigest - class rice.pastry.wire.testing.HelloMessageDigest.

Helper class for interpreting HelloMessages.

HelloMessageDigest(int, String, String, String, int, boolean, int) - Constructor for class rice.pastry.wire.testing.HelloMessageDigest

HelloMsg - class rice.pastry.testing.HelloMsg.

HelloMsg(Address, NodeId, Id, int) - Constructor for class rice.pastry.testing.HelloMsg

HelloResponseMessage - class rice.pastry.wire.messaging.socket.HelloResponseMessage.

Class which represents a greeting response in the socket-based pastry protocol.

HelloResponseMessage(WirePastryNode, NodeId) - Constructor for class rice.pastry.wire.messaging.socket.HelloResponseMessage

Constructor

HelloWorld - class rice.pastry.testing.HelloWorld.

A hello world example for pastry.

HelloWorld() - Constructor for class rice.pastry.testing.HelloWorld

Constructor

HelloWorldApp - class rice.pastry.testing.HelloWorldApp.

A hello world example for pastry.

HelloWorldApp(PastryNode) - Constructor for class rice.pastry.testing.HelloWorldApp

HelloWorldAppMultiThread - class rice.pastry.testing.HelloWorldAppMultiThread.

A hello world example for pastry.

HelloWorldAppMultiThread(PastryNode, DistHelloWorldMultiThread) - Constructor for class rice.pastry.testing.HelloWorldAppMultiThread

handle - Variable in class rice.p2p.past.testing.PastRegrTest.TestPastContentHandle

handle - Variable in class rice.p2p.replication.ReplicationImpl

the local node handle

handle - Variable in class rice.p2p.scribe.ScribeImpl

the local node handle

handle() - Method in class rice.pastry.NodeSetUpdate

The handle that changed.

handle - Variable in class rice.pastry.wire.SocketChannelReader

handle - Variable in class rice.pastry.wire.SocketChannelWriter

handleDeliverMessage(RMImpl) - Method in class rice.rm.messaging.RMMaintenanceMsg

handleDeliverMessage(RMImpl) - Method in class rice.rm.messaging.RMMessage

This method is called whenever the rm node receives a message for itself and wants to process it.

handleDeliverMessage(RMImpl) - Method in class rice.rm.messaging.RMRequestKeysMsg

The handling of the message iterates of the 'rangeSet' as takes the following action on the entries of type RMMessage.KEEntry.

handleDeliverMessage(RMImpl) - Method in class rice.rm.messaging.RMResponseKeysMsg

The handling of the message does the following - 1.

handleDeliverMessage(RMImpl) - Method in class rice.rm.messaging.RMTimeoutMsg

If the RMResponseKeysMsg corresponding to the wrapped RMRequestKeysMsg was received (done by having same 'eventId' field in RMRequestKeysMsg & corresponding RMResponseKeysMsg) then nothing needs to be done.

handleDeliverMessage(DistRMRegrTestApp) - Method in class rice.rm.testing.DistRMRegrTestMessage

This method is called whenever the pastry node receives this message for the DistRMRegrTestApp.

handleDeliverMessage(DistRMRegrTestApp) - Method in class rice.rm.testing.DistRMRegrTestReplicateMessage

This method is called whenever the pastry node receives this message for the DistRMRegrTestApp.

handleDeliverMessage(RMRegrTestApp) - Method in class rice.rm.testing.HeartbeatMsg

This method is called whenever the rm node receives a message for itself and wants to process it.

handleDeliverMessage(RMRegrTestApp) - Method in class rice.rm.testing.InsertMsg

This method is called whenever the rm node receives a message for itself and wants to process it.

handleDeliverMessage(RMRegrTestApp) - Method in class rice.rm.testing.InsertResponseMsg

This method is called whenever the rm node receives a message for itself and wants to process it.

handleDeliverMessage(RMRegrTestApp) - Method in class rice.rm.testing.InvariantCheckMsg

handleDeliverMessage(RMRegrTestApp) - Method in class rice.rm.testing.ObjectInsertionMsg

handleDeliverMessage(RMRegrTestApp) - Method in class rice.rm.testing.ObjectRefreshMsg

handleDeliverMessage(RMRegrTestApp) - Method in class rice.rm.testing.RefreshMsg

handleDeliverMessage(RMRegrTestApp) - Method in class rice.rm.testing.ReplicateMsg

This method is called whenever the rm node receives a message for itself and wants to process it.

handleDeliverMessage(RMRegrTestApp) - Method in class rice.rm.testing.ReplicateResponseMsg

This method is called whenever the rm node receives a message for itself and wants to process it.

handleDeliverMessage(RMRegrTestApp) - Method in class rice.rm.testing.ReplicateTimeoutMsg

handleDeliverMessage(RMRegrTestApp) - Method in class rice.rm.testing.TestMessage

handleDeliverMessage(Scribe, Topic) - Method in class rice.scribe.maintenance.MessageScribeMaintenance

This method is called whenever the scribe node receives a message for itself and wants to process it.

handleDeliverMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageAckOnSubscribe

This method is called whenever the scribe node receives a message for itself and wants to process it.

handleDeliverMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageAnycast

This method is called whenever the scribe node receives a message for itself and wants to process it.

handleDeliverMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageCreate

This method is called whenever the scribe node receives a message for itself and wants to process it.

handleDeliverMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageHeartBeat

This method is called whenever the scribe node receives a message for itself and wants to process it.

handleDeliverMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessagePublish

This method is called whenever the scribe node receives a message for itself and wants to process it.

handleDeliverMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageReplyFromParent

This method is called whenever the scribe node receives a message for itself and wants to process it.

handleDeliverMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageRequestToParent

This method is called whenever the scribe node receives a message for itself and wants to process it.

handleDeliverMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageSubscribe

This method is called whenever the scribe node receives a message for itself and wants to process it.

handleDeliverMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageUnsubscribe

This method is called whenever the scribe node receives a message for itself and wants to process it.

handleDeliverMessage(Scribe, Topic) - Method in class rice.scribe.messaging.ScribeMessage

This method is called whenever the scribe node receives a message for itself and wants to process it.

handleDeliverMessage(DistScribeRegrTestApp) - Method in class rice.scribe.testing.DistScribeRegrTestMessage

This method is called whenever the pastry node receives a message for the DistScribeRegrTestApp.

handleForwardMessage(Scribe, Topic) - Method in class rice.scribe.maintenance.MessageScribeMaintenance

This method is called whenever the scribe node forwards a message in the scribe network.

handleForwardMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageAckOnSubscribe

This method is called whenever the scribe node forwards a message in the scribe network.

handleForwardMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageAnycast

This method is called whenever the scribe node forwards a message in the scribe network.

handleForwardMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageCreate

This method is called whenever the scribe node forwards a message in the scribe network.

handleForwardMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageHeartBeat

This method is called whenever the scribe node forwards a message in the scribe network.

handleForwardMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessagePublish

This method is called whenever the scribe node forwards a message in the scribe network.

handleForwardMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageReplyFromParent

This method is called whenever the scribe node forwards a message in the scribe network.

handleForwardMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageRequestToParent

This method is called whenever the scribe node forwards a message in the scribe network.

handleForwardMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageSubscribe

This method is called whenever the scribe node forwards a message in the scribe network.

handleForwardMessage(Scribe, Topic) - Method in class rice.scribe.messaging.MessageUnsubscribe

This method is called whenever the scribe node forwards a message in the scribe network.

handleForwardMessage(Scribe, Topic) - Method in class rice.scribe.messaging.ScribeMessage

This method is called whenever the scribe node forwards a message in the scribe network.

hasChanged() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

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

Indicates if the local node has children associated with this topic.

hasPriority() - Method in class rice.pastry.messaging.Message

Get priority

hasPriority() - Method in class rice.pastry.routing.RouteMessage

Get priority

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

If this topic has any applications registered as subscribers.

hash() - Method in interface rice.p2p.commonapi.IdSet

return a hash of this set

hash() - Method in class rice.pastry.IdSet

return a hash of this set

hashCode() - Method in class rice.p2p.scribe.Topic

Returns the hashCode for this topic

hashCode() - Method in class rice.p2p.splitstream.ChannelId

hashCode() - Method in class rice.p2p.splitstream.StripeId

hashCode() - Method in interface rice.past.messaging.PASTMessageID

Deprecated. Returns the hashcode value of the object.

hashCode() - Method in class rice.past.messaging.PASTMessageIDImpl

Deprecated. Returns the hashcode value of the object.

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

Hash codes.

hashCode() - Method in class rice.pastry.Id

Hash codes for Ids.

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

Hash codes for nodehandles.

hashCode() - Method in class rice.pastry.direct.DirectNodeHandle

Hash codes for node handles.It is the hashcode of their corresponding NodeId's.

hashCode() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Hash codes for node handles.

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

Hash codes for node handles.

hashCode() - Method in class rice.pastry.join.JoinAddress

hashCode() - Method in class rice.pastry.leafset.LeafSetProtocolAddress

hashCode() - Method in class rice.pastry.routing.RouteProtocolAddress

hashCode() - Method in class rice.pastry.routing.RouterAddress

hashCode() - Method in class rice.pastry.standard.StandardAddress

hashCode() - Method in class rice.pastry.testing.LeafSetTest.TestNodeHandle

hashCode() - Method in class rice.pastry.testing.PingAddress

hashCode() - Method in class rice.pastry.wire.testing.HelloMessageDigest

hashCode() - Method in class rice.pastry.wire.testing.MessageDigest

hashCode() - Method in class rice.pastry.wire.testing.PublishMessageDigest

hashcode - Variable in class rice.pastry.wire.testing.MessageDigest

hashes - Variable in class rice.p2p.replication.messaging.RequestMessage

heartbeat(Id) - Method in class rice.rm.testing.RMRegrTestApp

helper - Variable in class rice.p2p.replication.manager.ReplicationManagerImpl

The helper for the replication manager

I

IDLE_TIME - Static variable in class rice.scribe.testing.DistScribeRegrTest

ID_LENGTH - Static variable in class rice.pastry.wire.testing.WireFileProcessor

INSTANCE - Static variable in class rice.p2p.past.testing.PastRegrTest

INSTANCE - Static variable in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

the instance name to use

INSTANCE - Static variable in class rice.p2p.replication.testing.ReplicationRegrTest

the instance name to use

INSTANCE - Static variable in class rice.p2p.scribe.testing.ScribeRegrTest

DESCRIBE THE FIELD

INSTANCE - Static variable in class rice.p2p.splitstream.testing.SplitStreamRegrTest

DESCRIBE THE FIELD

INSTANCE_NAME - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

IPNodeIdFactory - class rice.pastry.standard.IPNodeIdFactory.

Constructs NodeIds for virtual nodes derived from the IP address and port number of this Java VM.

IPNodeIdFactory(int) - Constructor for class rice.pastry.standard.IPNodeIdFactory

Constructor.

IScribe - interface rice.scribe.IScribe.

IScribeApp - interface rice.scribe.IScribeApp.

IScribeObserver - interface rice.scribe.IScribeObserver.

IScribeSecurityManager - interface rice.scribe.security.IScribeSecurityManager.

The Scribe security manager interface.

Id - interface rice.p2p.commonapi.Id.

Id - class rice.pastry.Id.

Represents a Pastry identifier for a node, object or key.

Id(byte[]) - Constructor for class rice.pastry.Id

Constructor.

Id(int[]) - Constructor for class rice.pastry.Id

Constructor.

Id() - Constructor for class rice.pastry.Id

Constructor.

Id.Distance - interface rice.p2p.commonapi.Id.Distance.

A class for representing and manipulating the distance between two Ids on the circle.

Id.Distance - class rice.pastry.Id.Distance.

A class for representing and manipulating the distance between two Ids on the circle.

Id.Distance() - Constructor for class rice.pastry.Id.Distance

Constructor.

Id.Distance(byte[]) - Constructor for class rice.pastry.Id.Distance

Constructor.

Id.Distance(int[]) - Constructor for class rice.pastry.Id.Distance

Constructor.

IdBitLength - Static variable in class rice.pastry.Id

This is the bit length of the node ids.

IdFactory - interface rice.p2p.commonapi.IdFactory.

IdRange - interface rice.p2p.commonapi.IdRange.

IdRange - class rice.pastry.IdRange.

Represents a contiguous range of Pastry ids.

IdRange(Id, Id) - Constructor for class rice.pastry.IdRange

Constructor.

IdRange() - Constructor for class rice.pastry.IdRange

Constructor, constructs an empty IdRange

IdRange(boolean) - Constructor for class rice.pastry.IdRange

IdRange(IdRange) - Constructor for class rice.pastry.IdRange

Copy constructor.

IdRangeUnit - class rice.pastry.testing.IdRangeUnit.

IdRangeUnit tests the IdRange class.

IdRangeUnit() - Constructor for class rice.pastry.testing.IdRangeUnit

IdSet - interface rice.p2p.commonapi.IdSet.

IdSet - class rice.pastry.IdSet.

Represents a set of Pastry ids.

IdSet() - Constructor for class rice.pastry.IdSet

Constructor.

IdSet(TreeSet) - Constructor for class rice.pastry.IdSet

Constructor.

IdSet(IdSet) - Constructor for class rice.pastry.IdSet

Copy constructor.

ImproperlyFormattedMessageException - exception rice.pastry.wire.exception.ImproperlyFormattedMessageException.

Class which represents an exception occuring during the parsing of a Pastry message sent through the Socket protocol.

ImproperlyFormattedMessageException(String) - Constructor for class rice.pastry.wire.exception.ImproperlyFormattedMessageException

Constructs an ImproperlyFormattedMessageException with a given message

InitiateJoin - class rice.pastry.join.InitiateJoin.

Request for the join protocols on the local node to join the overlay.

InitiateJoin(NodeHandle) - Constructor for class rice.pastry.join.InitiateJoin

Constructor.

InitiateJoin(Date, NodeHandle) - Constructor for class rice.pastry.join.InitiateJoin

Constructor.

InitiateJoin(Credentials, NodeHandle) - Constructor for class rice.pastry.join.InitiateJoin

Constructor.

InitiateJoin(Credentials, Date, NodeHandle) - Constructor for class rice.pastry.join.InitiateJoin

Constructor.

InitiateLeafSetMaintenance - class rice.pastry.leafset.InitiateLeafSetMaintenance.

Initiate leaf set maintenance on the local node.

InitiateLeafSetMaintenance() - Constructor for class rice.pastry.leafset.InitiateLeafSetMaintenance

Constructor.

InitiateRouteSetMaintenance - class rice.pastry.routing.InitiateRouteSetMaintenance.

Initiate routing table maintenance on the local node

InitiateRouteSetMaintenance() - Constructor for class rice.pastry.routing.InitiateRouteSetMaintenance

Constructor.

InsertMessage - class rice.p2p.past.messaging.InsertMessage.

InsertMessage(int, PastContent, NodeHandle, Id) - Constructor for class rice.p2p.past.messaging.InsertMessage

Constructor which takes a unique integer Id, as well as the data to be stored

InsertMsg - class rice.rm.testing.InsertMsg.

InsertMsg(NodeHandle, Address, Id, Object, Credentials) - Constructor for class rice.rm.testing.InsertMsg

InsertResponseMsg - class rice.rm.testing.InsertResponseMsg.

InsertResponseMsg(NodeHandle, Address, Id, Credentials) - Constructor for class rice.rm.testing.InsertResponseMsg

Constructor : Builds a new RM Message

InvariantCheckMsg - class rice.rm.testing.InvariantCheckMsg.

InvariantCheckMsg(NodeHandle, Address, Credentials) - Constructor for class rice.rm.testing.InvariantCheckMsg

Constructor

i - Variable in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

DESCRIBE THE FIELD

id - Variable in class rice.p2p.past.messaging.PastMessage

id - Variable in class rice.p2p.past.testing.PastRegrTest.TestPastContent

id - Variable in class rice.p2p.past.testing.PastRegrTest.TestPastContentHandle

id - Variable in class rice.p2p.scribe.Topic

The Id to which this topic is mapped

id - Variable in class rice.p2p.scribe.messaging.AbstractSubscribeMessage

The id of this subscribe message

id - Variable in class rice.p2p.scribe.messaging.SubscribeMessage

The id of this message

id - Variable in class rice.p2p.splitstream.ChannelId

The underlying id for this channelid

id - Variable in class rice.p2p.splitstream.StripeId

This stripe's Id

id - Variable in class rice.pastry.rmi.RMINodeHandle

idBaseBitLength - Static variable in class rice.pastry.routing.RoutingTable

The routing calculations will occur in base 2 ^{idBaseBitLength}

idFactory - Variable in class rice.p2p.commonapi.testing.CommonAPITest

ids - Variable in class rice.p2p.replication.messaging.ResponseMessage

ifp(int) - Static method in class rice.pastry.Log

Called before every println, to check if verbosity levels are okay.

inConcJoin - Variable in class rice.pastry.testing.PastryRegrTest

inThread() - Method in class rice.pastry.wire.WirePastryNode

Checks whether the current thread is the execution thread.

incNumAcks() - Method in class rice.rm.testing.RMRegrTestApp.ReplicateEntry

incrAttempt() - Method in class rice.rm.messaging.RMRequestKeysMsg

Since this message has a timeout mechanism, the next time we resend the message as a result of Timeout we need to increment the attempt number.

incrDistance(double) - Method in class rice.pastry.testing.PingMessageNew

incrHops() - Method in class rice.pastry.testing.PingMessageNew

incrMissingCount() - Method in class rice.rm.testing.ObjectState

incrStaleCount() - Method in class rice.rm.testing.ObjectState

incrementNumUnsubscribed(NodeId) - Static method in class rice.scribe.testing.DistScribeRegrTest

index - Static variable in class rice.pastry.rmi.RMINodeHandle

indexOf(NodeHandle) - Method in class rice.pastry.NodeSet

determine rank of a member

indexOfMSDB(Id) - Method in class rice.pastry.Id

Returns the index of the most significant differing bit (MSDB).

indexOfMSDD(Id, int) - Method in class rice.pastry.Id

Returns the index of the most significant different digit (MSDD) in a given base.

informClient(Id, int) - Method in class rice.p2p.replication.manager.ReplicationManagerImpl

Internal method which informs the client of the next id to fetch

init(String[]) - Static method in class rice.pastry.Log

Called by Pastry applications to parse for verbosity options.

initialize() - Method in class rice.past.testing.DistPASTRegrTest

Deprecated. Sets up the environment for regression tests.

initialize() - Static method in class rice.pastry.wire.Wire

Automatic determination of ulimit -n

initialize(int) - Static method in class rice.pastry.wire.Wire

initialize(int, float, float) - Static method in class rice.pastry.wire.Wire

initialize(float, float) - Static method in class rice.pastry.wire.Wire

Automatic determination of ulimit -n

initiateJoin(NodeHandle) - Method in class rice.pastry.PastryNode

Overridden by derived classes to initiate the join process

initiateJoin(NodeHandle) - Method in class rice.pastry.direct.DirectPastryNode

Sends an InitiateJoin message to itself.

initiateJoin(NodeHandle) - Method in class rice.pastry.dist.DistPastryNode

Sends an InitiateJoin message to itself.

initiateMaintenance() - Method in class rice.past.testing.DistPASTRegrTest

Deprecated. Initiates replica maintenance on all nodes

insert(Past, Continuation) - Method in class rice.p2p.past.ContentHashPastContent

Inserts this object into its associated Past instance.

insert(PastContent, Continuation) - Method in interface rice.p2p.past.Past

Inserts an object with the given ID into this instance of Past.

insert(PastContent, Continuation) - Method in class rice.p2p.past.PastImpl

Inserts an object with the given ID into this instance of Past.

insert(Id) - Method in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest.TestReplicationManagerClient

insert(Id) - Method in class rice.p2p.replication.testing.ReplicationRegrTest.TestReplicationClient

insert(Id, Serializable, Continuation) - Method in interface rice.past.PASTService

Deprecated. Inserts an object with the given ID into distributed storage.

insert(Id, Serializable, Continuation) - Method in class rice.past.PASTServiceImpl

Deprecated. Inserts an object with the given ID into distributed storage.

insert(int, NodeHandle) - Method in class rice.pastry.NodeSet

insert a member at the given index

insertionFreq - Static variable in class rice.rm.testing.DistRMRegrTestApp

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

intersect(IdRange) - Method in class rice.pastry.IdRange

intersect two ranges returns an empty range if the ranges don't intersect two ranges may intersect in two ranges on the circle; this method produces one such range of intersection if one exists the other range of intersection can be computed by invoking o.intersect(this)

intersectRange(IdRange) - Method in interface rice.p2p.commonapi.IdRange

intersects the given range with this range

intersectRange(IdRange) - Method in class rice.pastry.IdRange

intersects the given range with this range

isAdjacent(IdRange) - Method in class rice.pastry.IdRange

test if this range is adjacent to another range

isAlive() - Method in class rice.p2p.commonapi.NodeHandle

Returns whether or not this node is currently alive

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

Returns the last known liveness information about the Pastry node associated with this handle.

isAlive() - Method in class rice.pastry.direct.DirectNodeHandle

Gets the Alive attribute of the DirectNodeHandle object

isAlive(NodeId) - Method in class rice.pastry.direct.EuclideanNetwork

testing if a NodeId is alive

isAlive(NodeId) - Method in interface rice.pastry.direct.NetworkSimulator

Checks to see if a node id is alive.

isAlive(NodeId) - Method in class rice.pastry.direct.SphereNetwork

testing if a NodeId is alive

isAlive() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Returns the last known liveness information about the Pastry node associated with this handle.

isAlive() - Method in class rice.pastry.testing.LeafSetTest.TestNodeHandle

isAlive() - Method in class rice.pastry.wire.SelectorManager

Gets the Alive attribute of the SelectorManager object

isBetween(Id, Id) - Method in interface rice.p2p.commonapi.Id

Checks if this Id is between two given ids ccw (inclusive) and cw (exclusive) on the circle

isBetween(Id, Id) - Method in class rice.pastry.Id

Checks if this Id is between two given ids ccw (inclusive) and cw (exclusive) on the circle

isBetween(Id, Id) - Method in class rice.pastry.Id

Checks if this Id is between two given ids ccw (inclusive) and cw (exclusive) on the circle

isCached() - Method in class rice.p2p.past.messaging.FetchMessage

Returns whether or not this message has been cached

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

Returns whether or not this message has been cached

isClosest(NodeId) - Method in class rice.pastry.PastryNode

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.

isClosest(NodeId) - Method in class rice.pastry.client.PastryAppl

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.

isEmpty() - Method in interface rice.p2p.commonapi.IdRange

returns whether or not this range is empty

isEmpty() - Method in class rice.pastry.IdRange

test if the range is empty

isEmpty() - Method in class rice.pastry.wire.SocketChannelWriter

Returns whether or not there are objects in the queue on in writing.

isFull() - Method in class rice.pastry.IdRange

test if the range is the full circle

isInPool - Variable in class rice.pastry.dist.DistCoalesedNodeHandle

isInterestedInWriting() - Method in class rice.pastry.wire.SocketChannelWriter

Gets the InterestedInWriting attribute of the SocketChannelWriter object

isLocal - Variable in class rice.pastry.dist.DistCoalesedNodeHandle

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

test membership

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

test membership

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

test membership

isMissing() - Method in class rice.rm.testing.ObjectState

isMutable() - Method in class rice.p2p.past.ContentHashPastContent

States if this content object is mutable.

isMutable() - Method in interface rice.p2p.past.PastContent

States if this content object is mutable.

isMutable() - Method in class rice.p2p.past.testing.PastRegrTest.NonMutableTestPastContent

isMutable() - Method in class rice.p2p.past.testing.PastRegrTest.TestPastContent

isNewRoot(NodeId) - Method in interface rice.scribe.IScribeApp

Upcall made by scribe to registered applications to inform them that local node is now the root for some topic, and hence can take appropriate action.

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

Upcall by scribe to let this application know that it is the new root.

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

Upcall by scribe to let this application know that it is the new root.

isNewRoot(NodeId) - Method in class rice.scribe.testing.DistScribeRegrTestApp

Upcall by scribe to let this application know that it is the new root.

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

Used to check for existence of an entry in the m_pendingEvents hashtable

isPresent() - Method in class rice.rm.testing.ObjectState

isPrimary - Variable in class rice.p2p.splitstream.Stripe

A flag whether or not this stripe is the primary stripe for this node

isPrimary() - Method in class rice.p2p.splitstream.Stripe

Returns whether or not this stripe is the primary stripe for the local node

isReady() - Method in class rice.pastry.PastryNode

isReady() - Method in class rice.rm.RMImpl

Returns true if the RM substrate is ready.

isReady() - Method in class rice.scribe.Scribe

Returns true is the Scribe substrate is ready.

isReallyAlive(NodeId) - Method in class rice.pastry.testing.DirectPastryRegrTest

get authoritative information about liveness of node.

isReallyAlive(NodeId) - Method in class rice.pastry.testing.DistPastryRegrTest

isReallyAlive(NodeId) - Method in class rice.pastry.testing.PastryRegrTest

determine whether this node is really alive.

isResponse - Variable in class rice.p2p.past.messaging.PastMessage

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

Method which returns whether or not this message is a response.

isResponsible(IdRange) - Method in class rice.past.PASTServiceImpl

Deprecated. This upcall is to notify the application of the range of keys for which it is responsible.

isResponsible(IdRange) - Method in interface rice.rm.RMClient

This upcall is to notify the application of the range of keys for which it is responsible.

isResponsible(IdRange) - Method in class rice.rm.testing.RMRegrTestApp

isRoot(Topic) - Method in interface rice.p2p.scribe.Scribe

Returns whether or not this Scribe is the root for the given topic

isRoot(Topic) - Method in class rice.p2p.scribe.ScribeImpl

Returns whether or not this Scribe is the root for the given topic

isRoot() - Method in class rice.p2p.splitstream.Stripe

Utility method.

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

Returns true if the local node is currently the root(the node that is closest to the topicId) of the topic.

isStale() - Method in class rice.rm.testing.ObjectState

isSubscribed() - Method in class rice.p2p.splitstream.Stripe

get the state of the Stripe

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

Return boolean indicating if the node is topic manager for the current topic.

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

Returns true if the local node is waiting to be unsubscribed from this topic.

isWriteEnabled() - Method in class rice.pastry.wire.WireNodeHandle

Gets the WriteEnabled attribute of the WireNodeHandle object

J

JOINING - Static variable in class rice.scribe.Topic

JoinAddress - class rice.pastry.join.JoinAddress.

The address of the join receiver at a pastry node.

JoinAddress() - Constructor for class rice.pastry.join.JoinAddress

Constructor.

JoinAdvertise - Static variable in class rice.pastry.leafset.BroadcastLeafSet

JoinInitial - Static variable in class rice.pastry.leafset.BroadcastLeafSet

JoinRequest - class rice.pastry.join.JoinRequest.

Request to join this network.

JoinRequest(NodeHandle) - Constructor for class rice.pastry.join.JoinRequest

Constructor.

JoinRequest(NodeHandle, Date) - Constructor for class rice.pastry.join.JoinRequest

Constructor.

JoinRequest(NodeHandle, Credentials) - Constructor for class rice.pastry.join.JoinRequest

Constructor.

JoinRequest(NodeHandle, Credentials, Date) - Constructor for class rice.pastry.join.JoinRequest

Constructor.

join(NodeId, IScribeApp, Credentials) - Method in interface rice.scribe.IScribe

Joins a multicast group/topic.

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

Joins a multicast group/topic.

join(NodeId, IScribeApp, Credentials) - Method in class rice.scribe.Scribe

Joins a multicast group/topic.

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

Joins a multicast group/topic.

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

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

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

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

join(NodeId, Serializable) - Method in class rice.scribe.testing.DirectScribeMaintenanceTestApp

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

join(NodeId) - Method in class rice.scribe.testing.DistScribeRegrTestApp

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

joinData - Variable in class rice.scribe.testing.DirectScribeMaintenanceTestApp

joinFailed(Stripe) - Method in interface rice.p2p.splitstream.SplitStreamClient

This is a call back into the application to notify it that one of the stripes was unable to to find a parent, and thus unable to recieve data.

joinNodes(int) - Method in class rice.rm.testing.DirectRMRegrTest

Creates the specified number of new nodes and joins them to the existing Pastry network.

joinNodes(int) - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

Creates the specified number of new nodes and joins them to the existing Pastry network.

K

kill(int) - Method in class rice.p2p.commonapi.testing.CommonAPITest

Method which kills the specified node

kill() - Method in class rice.pastry.dist.DistPastryNode

Method which kills a PastryNode (used only for testing).

kill() - Method in class rice.pastry.rmi.RMIPastryNode

Testing purposes only!

kill() - Method in class rice.pastry.wire.SelectorManager

To be used for testing purposes only - kills the socket client by shutting down all outgoing sockets and stopping the client thread.

kill() - Method in class rice.pastry.wire.WirePastryNode

Method for simulating the death of this node.

killNode(PastryNode) - Method in class rice.pastry.testing.DirectPastryRegrTest

murder the node.

killNode(PastryNode) - Method in class rice.pastry.testing.DistPastryRegrTest

killNode(PastryNode) - Method in class rice.pastry.testing.PastryRegrTest

kill a given node.

killPastryNode() - Method in class rice.pastry.testing.DistHelloWorldMultiThread

Create a Pastry node and add it to pastryNodes.

L

LOCK - Static variable in class rice.scribe.testing.DistScribeRegrTest

LRUCache - class rice.persistence.LRUCache.

This class is an encapsulation of a least-recently-used (LRU) cache.

LRUCache(Storage, int) - Constructor for class rice.persistence.LRUCache

Builds a LRU cache given a storage object to store the cached data in and a maximum cache size.

LRUCacheTest - class rice.persistence.testing.LRUCacheTest.

This class is a class which tests the Cache class in the rice.persistence package.

LRUCacheTest() - Constructor for class rice.persistence.testing.LRUCacheTest

Builds a MemoryStorageTest

LeafSet - class rice.pastry.leafset.LeafSet.

A class for representing and manipulating the leaf set.

LeafSet(NodeHandle, int) - Constructor for class rice.pastry.leafset.LeafSet

Constructor.

LeafSetProtocolAddress - class rice.pastry.leafset.LeafSetProtocolAddress.

The address of the leafset protocol at a pastry node.

LeafSetProtocolAddress() - Constructor for class rice.pastry.leafset.LeafSetProtocolAddress

Constructor.

LeafSetRequestMessage - class rice.pastry.wire.messaging.socket.LeafSetRequestMessage.

Message which represents a request to get the leafset from the remote node.

LeafSetRequestMessage() - Constructor for class rice.pastry.wire.messaging.socket.LeafSetRequestMessage

Constructor

LeafSetResponseMessage - class rice.pastry.wire.messaging.socket.LeafSetResponseMessage.

A response message to a LeafSetRequestMessage, containing the remote node's leafset.

LeafSetResponseMessage(LeafSet) - Constructor for class rice.pastry.wire.messaging.socket.LeafSetResponseMessage

Constructor

LeafSetTest - class rice.pastry.testing.LeafSetTest.

This class tests the correctness of the leafset in Pastry.

LeafSetTest() - Constructor for class rice.pastry.testing.LeafSetTest

LeafSetTest.TestNodeHandle - class rice.pastry.testing.LeafSetTest.TestNodeHandle.

LeafSetTest.TestNodeHandle(NodeId) - Constructor for class rice.pastry.testing.LeafSetTest.TestNodeHandle

LocalNode - class rice.pastry.LocalNode.

Implementation of the LocalNodeI interface that some Serializable classes (such as Certificate) extend, if they want to be kept informed of what node they're on.

LocalNode() - Constructor for class rice.pastry.LocalNode

LocalNodeI - interface rice.pastry.LocalNodeI.

Interface that some Serializable classes (such as NodeHandle and Certificate) implement, if they want to be kept informed of what node they're on.

Log - class rice.pastry.Log.

A fairly rudimentary Log class for the moment.

Log() - Constructor for class rice.pastry.Log

LookupHandlesMessage - class rice.p2p.past.messaging.LookupHandlesMessage.

LookupHandlesMessage(int, Id, int, NodeHandle, Id) - Constructor for class rice.p2p.past.messaging.LookupHandlesMessage

Constructor

LookupMessage - class rice.p2p.past.messaging.LookupMessage.

LookupMessage(int, Id, NodeHandle, Id) - Constructor for class rice.p2p.past.messaging.LookupMessage

Constructor

lastDist - Variable in class rice.pastry.testing.PastryRegrTest

lastMsg - Variable in class rice.pastry.testing.PastryRegrTest

lastNode - Variable in class rice.pastry.testing.PastryRegrTest

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

Returns the number of rows left to determine (in order).

leafSet() - Method in class rice.pastry.leafset.BroadcastLeafSet

Returns the leaf set that was broadcast.

leafSetChange(NodeHandle, boolean) - Method in class rice.pastry.client.CommonAPIAppl

Called by pastry when the leaf set changes.

leafSetChange(NodeHandle, boolean) - Method in class rice.pastry.client.PastryAppl

Called by pastry when the leaf set changes.

leafSetChange(NodeHandle, boolean) - Method in class rice.pastry.commonapi.PastryEndpoint

leafSetChange(NodeHandle, boolean) - Method in class rice.pastry.testing.HelloWorldApp

Invoked upon change to leafset.

leafSetChange(NodeHandle, boolean) - Method in class rice.pastry.testing.HelloWorldAppMultiThread

Invoked upon change to leafset.

leafSetChange(NodeHandle, boolean) - Method in class rice.pastry.testing.Ping

leafSetChange(NodeHandle, boolean) - Method in class rice.pastry.testing.PingClient

leafSetChange(NodeHandle, boolean) - Method in class rice.scribe.Scribe

Called by pastry when the leaf set changes.

leafSetMaintFreq - Variable in class rice.pastry.dist.DistPastryNode

leave(NodeId, IScribeApp, Credentials) - Method in interface rice.scribe.IScribe

Leaving a multicast group/topic.

leave(NodeId, IScribeApp, Credentials) - Method in class rice.scribe.Scribe

Leaving a multicast group/topic.

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

direct call to scribe for unsubscribing a topic from the current node The topic is chosen randomly if null is passed and topics exist.

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

direct call to scribe for unsubscribing a topic from the current node The topic is chosen randomly if null is passed and topics exist.

leave(NodeId) - Method in class rice.scribe.testing.DistScribeRegrTestApp

direct call to scribe for unsubscribing a topic from the current node The topic is chosen randomly if null is passed and topics exist.

lineNumber - Variable in class rice.pastry.wire.testing.MessageDigest

local - Variable in class rice.pastry.wire.testing.MessageDigest

localId - Variable in class rice.p2p.splitstream.Channel

The Id of the local node

localLookup(Id, int, boolean) - Method in interface rice.p2p.commonapi.Endpoint

This call produces a list of nodes that can be used as next hops on a route towards the given id, such that the resulting route satisfies the overlay protocol's bounds on the number of hops taken.

localLookup(Id, int, boolean) - Method in class rice.pastry.client.CommonAPIAppl

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.

localLookup(Id, int, boolean) - Method in class rice.pastry.commonapi.PastryEndpoint

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.

localNodes - Variable in class rice.rm.testing.DistRMRegrTest

localNodes - Variable in class rice.scribe.testing.DistScribeRegrTest

localhandle - Variable in class rice.pastry.PastryNode

localnode - Variable in class rice.pastry.NodeHandle

log - Variable in class rice.p2p.past.PastImpl

log - Variable in class rice.p2p.replication.ReplicationImpl

the logger which we will use

log - Variable in class rice.p2p.replication.manager.ReplicationManagerImpl

the logger which we will use

log - Variable in class rice.p2p.scribe.ScribeImpl

the logger which we will use

longDistance(Id) - Method in class rice.pastry.Id

Returns the longer numerical distance on the ring between a pair of Ids.

longDistanceFromId(Id) - Method in interface rice.p2p.commonapi.Id

Returns the longer numerical distance on the ring between a pair of Ids.

longDistanceFromId(Id) - Method in class rice.pastry.Id

Returns the longer numerical distance on the ring between a pair of Ids.

lookup(Id, Continuation) - Method in interface rice.p2p.past.Past

Retrieves the object stored in this instance of Past with the given ID.

lookup(Id, Continuation) - Method in class rice.p2p.past.PastImpl

Retrieves the object stored in this instance of Past with the given ID.

lookup(Id, Continuation) - Method in interface rice.past.PASTService

Deprecated. Retrieves the object and all associated updates with the given ID.

lookup(Id, Continuation) - Method in class rice.past.PASTServiceImpl

Deprecated. Retrieves the object and all associated updates with the given ID.

lookupForward(RouteMessage) - Method in interface rice.rm.RM

Called by client(RMClient) to enable optimizations to route to the nearest replica.

lookupForward(RouteMessage) - Method in class rice.rm.RMImpl

Called by client(RMClient) to enable optimizations to route to the nearest replica.

lookupHandles(Id, int, Continuation) - Method in interface rice.p2p.past.Past

Retrieves the handles of up to max replicas of the object stored in this instance of Past with the given ID.

lookupHandles(Id, int, Continuation) - Method in class rice.p2p.past.PastImpl

Retrieves the handles of up to max replicas of the object stored in this instance of Past with the given ID.

M

MAGIC_NUMBER - Static variable in class rice.pastry.wire.SocketChannelReader

the magic number array which is written first

MAGIC_NUMBER - Static variable in class rice.pastry.wire.SocketChannelWriter

the magic number array which is written first

MAINTENANCE_INTERVAL - Static variable in class rice.p2p.replication.ReplicationImpl

The amount of time to wait between replications

MAXATTEMPTS - Static variable in class rice.rm.messaging.RMRequestKeysMsg

The maximum number of attempts made in the timeout mechanism after which the message is ignored.

MAXIMUM_QUEUE_LENGTH - Static variable in class rice.pastry.wire.SocketChannelWriter

the maximum length of the queue

MAXKEYSINRANGE - Static variable in class rice.rm.RMImpl

This value represents the maximum size of the keySet corresponding to a requested id range that we would like to fit in a single message.

MAX_FAILED_SUBSCRIPTION - Static variable in class rice.p2p.splitstream.Stripe

The maximum number of failed subscriptions

MAX_OPEN_SOCKETS - Static variable in class rice.pastry.wire.SocketManager

the number of sockets where we start closing other sockets

MAX_UDP_MESSAGE_SIZE - Static variable in class rice.pastry.wire.WireNodeHandle

the largest message size to send over UDP

MESSAGE_TIMEOUT - Static variable in class rice.p2p.past.PastImpl

MESSAGE_TIMEOUT - Static variable in class rice.p2p.scribe.ScribeImpl

the timeout for a subscribe message

MemoryStorage - class rice.persistence.MemoryStorage.

This class is an implementation of Storage which provides in-memory storage.

MemoryStorage(IdFactory) - Constructor for class rice.persistence.MemoryStorage

Builds a MemoryStorage object.

MemoryStorageTest - class rice.persistence.testing.MemoryStorageTest.

This class is a class which tests the Storage class in the rice.persistence package.

MemoryStorageTest(boolean) - Constructor for class rice.persistence.testing.MemoryStorageTest

Builds a MemoryMemoryStorageTest

Message - interface rice.p2p.commonapi.Message.

Message - class rice.pastry.messaging.Message.

This is an abstract implementation of a message object.

Message(Address) - Constructor for class rice.pastry.messaging.Message

Constructor.

Message(Address, Credentials) - Constructor for class rice.pastry.messaging.Message

Constructor.

Message(Address, Credentials, Date) - Constructor for class rice.pastry.messaging.Message

Constructor.

Message(Address, Date) - Constructor for class rice.pastry.messaging.Message

Constructor.

MessageAckOnSubscribe - class rice.scribe.messaging.MessageAckOnSubscribe.

MessageAckOnSubscribe(Address, NodeHandle, NodeId, Credentials, Serializable) - Constructor for class rice.scribe.messaging.MessageAckOnSubscribe

Constructor

MessageAnycast - class rice.scribe.messaging.MessageAnycast.

MessageAnycast is used whenever a Scribe node wishes to anycast to a particular topic.

MessageAnycast(Address, NodeHandle, NodeId, Credentials) - Constructor for class rice.scribe.messaging.MessageAnycast

Constructor

MessageCreate - class rice.scribe.messaging.MessageCreate.

MessageCreate is used whenever a Scribe node wants to create a new topic.

MessageCreate(Address, NodeHandle, NodeId, Credentials) - Constructor for class rice.scribe.messaging.MessageCreate

Constructor.

MessageDigest - class rice.pastry.wire.testing.MessageDigest.

This is the basic message that the WireFileProcessor creates.

MessageDigest(int, String, String, String, int, boolean) - Constructor for class rice.pastry.wire.testing.MessageDigest

MessageDigestFactory - class rice.pastry.wire.testing.MessageDigestFactory.

The purpose of the factory is to generate special message digests for specifically analyzed messages.

MessageDigestFactory() - Constructor for class rice.pastry.wire.testing.MessageDigestFactory

MessageDispatch - class rice.pastry.messaging.MessageDispatch.

An object which remembers the mapping from names to MessageReceivers and dispatches messages by request.

MessageDispatch() - Constructor for class rice.pastry.messaging.MessageDispatch

Constructor.

MessageExists - class rice.past.messaging.MessageExists.

Deprecated. This version of PAST has been deprecated - please use the version located in the rice.p2p.past package.

MessageExists(Id, Id) - Constructor for class rice.past.messaging.MessageExists

Deprecated. Builds a new request to see if a file exists.

MessageFetch - class rice.past.messaging.MessageFetch.

Deprecated. This version of PAST has been deprecated - please use the version located in the rice.p2p.past package.

MessageFetch(Id, Id) - Constructor for class rice.past.messaging.MessageFetch

Deprecated. Builds a new request to lookup an existing file.

MessageHeartBeat - class rice.scribe.messaging.MessageHeartBeat.

HeartBeatMessage is used whenever a Scribe nodes wishes let its children know that it is still alive, so that the children need not do any repairing of the multicast tree.

MessageHeartBeat(Address, NodeHandle, Credentials) - Constructor for class rice.scribe.messaging.MessageHeartBeat

Constructor

MessageInsert - class rice.past.messaging.MessageInsert.

Deprecated. This version of PAST has been deprecated - please use the version located in the rice.p2p.past package.

MessageInsert(Id, Id, Serializable) - Constructor for class rice.past.messaging.MessageInsert

Deprecated. Builds a new request to insert a file.

MessageLookup - class rice.past.messaging.MessageLookup.

Deprecated. This version of PAST has been deprecated - please use the version located in the rice.p2p.past package.

MessageLookup(Id, Id) - Constructor for class rice.past.messaging.MessageLookup

Deprecated. Builds a new request to lookup an existing file.

MessageLostMessage - class rice.p2p.past.messaging.MessageLostMessage.

MessageLostMessage(int, NodeHandle) - Constructor for class rice.p2p.past.messaging.MessageLostMessage

Constructor which takes a unique integer Id and the local id

MessagePublish - class rice.scribe.messaging.MessagePublish.

MessagePublish is used whenever a Scribe nodes wishes to send events to a particular topic.

MessagePublish(Address, NodeHandle, NodeId, Credentials) - Constructor for class rice.scribe.messaging.MessagePublish

Constructor

MessageReceiver - interface rice.pastry.messaging.MessageReceiver.

An interface to an agent which can receive messages.

MessageRecieved(HelloMsg) - Method in class rice.pastry.testing.DistHelloWorldMultiThread

MessageReclaim - class rice.past.messaging.MessageReclaim.

Deprecated. This version of PAST has been deprecated - please use the version located in the rice.p2p.past package.

MessageReclaim(Id, Id) - Constructor for class rice.past.messaging.MessageReclaim

Deprecated. Builds a new request to reclaim space used by an existing file.

MessageReplyFromParent - class rice.scribe.messaging.MessageReplyFromParent.

MessageReplyFromParent is a message sent by the PARENT node to a node as a response to a MessageRequestToParent type of message.

MessageReplyFromParent(Address, NodeHandle, Credentials) - Constructor for class rice.scribe.messaging.MessageReplyFromParent

Constructor

MessageRequestToParent - class rice.scribe.messaging.MessageRequestToParent.

MessageRequestToParent is a message sent by a CHILD node to the PARENT requesting it for the list of topics for which the PARENT node has this node as a CHILD.

MessageRequestToParent(Address, NodeHandle, Credentials) - Constructor for class rice.scribe.messaging.MessageRequestToParent

Constructor

MessageScribeMaintenance - class rice.scribe.maintenance.MessageScribeMaintenance.

MessageScribeMaintenance is used by a Scribe node to initiate tree maintenance activities for the topics residing on the local node.

MessageScribeMaintenance(Address, NodeHandle, Credentials) - Constructor for class rice.scribe.maintenance.MessageScribeMaintenance

Constructor

MessageSent(HelloMsg) - Method in class rice.pastry.testing.DistHelloWorldMultiThread

MessageSubscribe - class rice.scribe.messaging.MessageSubscribe.

MessageSubscribe is used whenever a Scribe node wants to subscribe itself to a topic.

MessageSubscribe(Address, NodeHandle, NodeId, Credentials) - Constructor for class rice.scribe.messaging.MessageSubscribe

Constructor

MessageUnsubscribe - class rice.scribe.messaging.MessageUnsubscribe.

MessageUnsubscribe is used whenever a Scribe node wishes to unsubscribe from a topic.

MessageUnsubscribe(Address, NodeHandle, NodeId, Credentials) - Constructor for class rice.scribe.messaging.MessageUnsubscribe

Contructor

m_ackOnSubscribeSwitch - Variable in class rice.scribe.Scribe

The AckOnSubscribe switch if true activates the immediate sending of ACK by a node when it receives a SUBSCRIBE message from its child for a topic.

m_address - Static variable in class rice.scribe.Scribe

The receiver address for the scribe system.

m_address - Static variable in class rice.scribe.testing.DistScribeRegrTestApp

The receiver address for the DistScribeApp system.

m_alreadySentHBNodes - Variable in class rice.scribe.Scribe

Optimization on number of HeartBeat Messages sent.

m_appCount - Variable in class rice.rm.testing.RMRegrTestApp

m_appCount - Variable in class rice.scribe.testing.DirectScribeMaintenanceTestApp

m_appCount - Static variable in class rice.scribe.testing.DistScribeRegrTestApp

m_appIndex - Variable in class rice.scribe.testing.DistScribeRegrTestApp

m_apps - Variable in class rice.scribe.Scribe

The set of IScribeApp's that have registered to this Scribe substrate.

m_apps - Variable in class rice.scribe.Topic

Set of IScribeApps that have subscribed to this Topic.

m_children - Variable in class rice.scribe.Topic

Set of NodeHandle objects for the local node's children in this topic's multicast subtree rooted at the local node.

m_credentials - Static variable in class rice.scribe.Scribe

The Credentials object to be used for all messaging through Pastry.

m_credentials - Static variable in class rice.scribe.testing.DistScribeRegrTestApp

The Credentials object to be used for all messaging through Pastry

m_distinctChildrenTable - Variable in class rice.scribe.Scribe

Hashtable having mapping from a child -> list of topics for which this child is in local node's children list for that topic.

m_distinctParentTable - Variable in class rice.scribe.Scribe

Hashtable having mapping from a parent node -> list of topics for which the parent node is local node's parent in the corresponding multicast tree for that topic.

m_driver - Variable in class rice.scribe.testing.DistScribeRegrTestApp

m_eId - Variable in class rice.rm.RMImpl

This is to keep track of events with respect to RMRequestKeysMsg only.

m_firstNodeInSystem - Variable in class rice.rm.testing.DistRMRegrTestApp

m_heartBeatsMissed - Variable in class rice.scribe.Topic

This keeps track of the number of heartbeat messages missed corresponding to this topic.

m_keys - Variable in class rice.rm.testing.RMRegrTestApp

m_lastDist - Variable in class rice.scribe.testing.BasicScribeRegrTest

m_lastMsg - Variable in class rice.scribe.testing.BasicScribeRegrTest

m_logTable - Variable in class rice.scribe.testing.DistScribeRegrTestApp

The hashtable maintaining mapping from topicId to log object maintained by this application for that topic.

m_maintainer - Variable in class rice.scribe.Scribe

The ScribeMaintainer object handles all the tree maintenance activities like the sending of heartbeat messages and issuing tree repair events for all the topics residing on the local node.

m_objectInsertionMsg - Variable in class rice.rm.testing.DistRMRegrTestApp

m_parent - Variable in class rice.scribe.Topic

Local node's parent in this topic's multicast tree

m_pastryNode - Variable in class rice.rm.testing.RMRegrTestApp

m_pastryNode - Variable in class rice.scribe.testing.DistScribeRegrTestApp

m_pendingEvents - Variable in class rice.rm.RMImpl

This table will be used by the Timeout mechanism in RMRequestKeysMsg.

m_pendingObjects - Variable in class rice.rm.testing.RMRegrTestApp

m_pendingRanges - Variable in class rice.rm.RMImpl

This hashtable is keyed by the NodeId of the node to whom this local node is requesting for a set of keys in the Keys Exchange protocol.

m_refreshedKeys - Variable in class rice.rm.testing.RMRegrTestApp

m_rm - Variable in class rice.rm.testing.RMRegrTestApp

m_rng - Variable in class rice.scribe.testing.DistScribeRegrTestApp

m_scribe - Variable in class rice.scribe.Topic

The scribe object on which this topic resides.

m_scribe - Variable in class rice.scribe.testing.DirectScribeMaintenanceTestApp

m_scribe - Variable in class rice.scribe.testing.DistScribeRegrTestApp

m_scribeMaintFreq - Static variable in class rice.scribe.Scribe

The time period determining Scribe Tree Maintenance Activity frequency

m_scribeObservers - Variable in class rice.scribe.Scribe

The set of applications which are interested in getting notified whenever the local node becomes an intermediate node for a topic.

m_securityManager - Variable in class rice.scribe.Scribe

Handles all the security verification.

m_sendOptions - Variable in class rice.scribe.Scribe

The SendOptions object to be used for all messaging through Pastry.

m_sendOptions - Variable in class rice.scribe.testing.DistScribeRegrTestApp

The SendOptions object to be used for all messaging through Pastry

m_seqno - Variable in class rice.rm.RMImpl

This will be incremented for every message that this node sends remotely.

m_source - Variable in class rice.scribe.messaging.ScribeMessage

The ID of the source of this message.

m_state - Variable in class rice.scribe.Topic

Current state of Topic.

m_topicId - Variable in class rice.scribe.Topic

This topic's identifier

m_topicId - Variable in class rice.scribe.messaging.ScribeMessage

The ID of the topic that this message refers to.

m_topicManager - Variable in class rice.scribe.Topic

Indicates whether this node is manager of this topic.

m_topics - Variable in class rice.scribe.Scribe

Set of topics on the local scribe node.

m_topics - Variable in class rice.scribe.testing.DistScribeRegrTestApp

m_wantUnsubscribe - Variable in class rice.scribe.Topic

Flag indicating if the local node is waiting to be unsubscribed (because it still does not know parent)

main(String[]) - Static method in class rice.p2p.past.testing.PastRegrTest

Usage: DistPastTest [-port p] [-bootstrap host[:port]] [-nodes n] [-protocol (rmi|wire)] [-help]

main(String[]) - Static method in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

Usage: ReplicationRegrTest [-port p] [-bootstrap host[:port]] [-nodes n] [-protocol (rmi|wire)] [-help]

main(String[]) - Static method in class rice.p2p.replication.testing.ReplicationRegrTest

Usage: ReplicationRegrTest [-port p] [-bootstrap host[:port]] [-nodes n] [-protocol (rmi|wire)] [-help]

main(String[]) - Static method in class rice.p2p.scribe.testing.ScribeRegrTest

Usage: DistScribeRegrTest [-port p] [-bootstrap host[:port]] [-nodes n] [-protocol (rmi|wire)] [-help]

main(String[]) - Static method in class rice.p2p.splitstream.testing.SplitStreamRegrTest

Usage: DistScribeRegrTest [-port p] [-bootstrap host[:port]] [-nodes n] [-protocol (rmi|wire)] [-help]

main(String[]) - Static method in class rice.past.testing.DistPASTRegrTest

Deprecated. Usage: DistPASTTest [-port p] [-bootstrap host[:port]] [-nodes n] [-protocol (rmi|wire)] [-help]

main(String[]) - Static method in class rice.pastry.testing.ClosestRegrTest

main

main(String[]) - Static method in class rice.pastry.testing.DirectPastryPingTest

main(String[]) - Static method in class rice.pastry.testing.DirectPastryRegrTest

main.

main(String[]) - Static method in class rice.pastry.testing.DistHelloWorld

Usage: DistHelloWorld [-msgs m] [-nodes n] [-port p] [-bootstrap bshost[:bsport]] [-verbose|-silent|-verbosity v] [-help].

main(String[]) - Static method in class rice.pastry.testing.DistHelloWorldMultiThread

Usage: DistHelloWorld [-msgs m] [-nodes n] [-port p] [-bootstrap bshost[:bsport]] [-verbose|-silent|-verbosity v] [-help].

main(String[]) - Static method in class rice.pastry.testing.DistPastryRegrTest

Usage: DistRegrPastryTest [-port p] [-protocol (wire|rmi)] [-nodes n] [-bootstrap host[:port]] [-help]

main(String[]) - Static method in class rice.pastry.testing.HelloWorld

Usage: HelloWorld [-msgs m] [-nodes n] [-verbose|-silent|-verbosity v] [-simultaneous_joins] [-simultaneous_msgs] [-help]

main(String[]) - Static method in class rice.pastry.testing.IdRangeUnit

main(String[]) - Static method in class rice.pastry.testing.LeafSetTest

main(String[]) - Static method in class rice.pastry.testing.NodeIdUnit

main(String[]) - Static method in class rice.pastry.testing.PastryTest

main(String[]) - Static method in class rice.pastry.wire.testing.WireFileProcessor

main(String[]) - Static method in class rice.persistence.testing.LRUCacheTest

main(String[]) - Static method in class rice.persistence.testing.MemoryStorageTest

main(String[]) - Static method in class rice.persistence.testing.PersistentStorageTest

main(String[]) - Static method in class rice.rm.testing.DirectRMRegrTest

main(String[]) - Static method in class rice.rm.testing.DistRMRegrTest

Usage: DistRMRegrTest [-nodes n] [-port p] [-bootstrap bshost[:bsport]] [-protocol [wire,rmi]] [-help].

main(String[]) - Static method in class rice.scribe.testing.DirectScribeRegrTest

main(String[]) - Static method in class rice.scribe.testing.DistScribeRegrTest

Usage: DistScribeRegrTest [-nodes n] [-port p] [-bootstrap bshost[:bsport]] [-protocol [wire,rmi]] [-help].

mainfunc(PastryRegrTest, String[], int, int, int, int, int) - Static method in class rice.pastry.testing.PastryRegrTest

main

maintFreq - Static variable in class rice.rm.messaging.RMMaintenanceMsg

The time interval between successive replica manager maintenance activities.

maintStart - Static variable in class rice.rm.messaging.RMMaintenanceMsg

The time offset after the RM substrate on the local node is ready when we first trigger the maintenance protocol.

maintainLeafSet() - Method in class rice.pastry.standard.StandardLeafSetProtocol

Maintain the leaf set.

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

Makes a AckOnSubscribe message using the current Pastry node as the source.

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

Makes a AckOnSubscribe message using the current Pastry node as the source.

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

Makes a anycast message using the current Pastry node as the source.

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

Makes a create message using the current Pastry node as the source.

makeHeartBeatMessage(Credentials) - Method in class rice.scribe.Scribe

Makes a heart-beat message using the current Pastry node as the source.

makeNoShortCuts() - Method in class rice.pastry.routing.SendOptions

Returns whether it is required for each routing step to go to a node whose id matches in exactly one more digit.

makePASTNode() - Method in class rice.past.testing.DistPASTRegrTest

Deprecated. Creates a pastryNode with a PASTService running on it.

makePastryNode(boolean) - Method in class rice.pastry.testing.DistHelloWorld

Create a Pastry node and add it to pastryNodes.

makePastryNode(boolean) - Method in class rice.pastry.testing.DistHelloWorldMultiThread

Create a Pastry node and add it to pastryNodes.

makePastryNode() - Method in class rice.pastry.testing.HelloWorld

Create a Pastry node and add it to pastryNodes.

makePastryNode() - Method in class rice.pastry.testing.PastryTest

makePastryNode() - Method in class rice.pastry.testing.SinglePingTest

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

Makes a publish message using the current Pastry node as the source.

makeRMNode() - Method in class rice.rm.testing.DirectRMRegrTest

makeRMNode() - Method in class rice.rm.testing.DistRMRegrTest

Create a Pastry node and add it to pastryNodes.

makeRandomId(Random) - Static method in class rice.pastry.Id

Creates a random Id.

makeReplyFromParentMessage(Credentials) - Method in class rice.scribe.Scribe

Makes a ReplyFromParent message using the current Pastry node as the source.

makeRequestToParentMessage(Credentials) - Method in class rice.scribe.Scribe

Makes a RequestToParent message using the current Pastry node as the source.

makeScribeMaintenanceMessage(Credentials) - Method in class rice.scribe.Scribe

Makes a ScribeMaintenance message using the current Pastry node as the source.

makeScribeNode(int) - Method in class rice.scribe.testing.BasicScribeRegrTest

makeScribeNode() - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

makeScribeNode() - Method in class rice.scribe.testing.DistScribeRegrTest

Create a Pastry node and add it to pastryNodes.

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

Makes a subscribe message using the current Pastry node as the source.

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

Makes an unsubscribe message using the current Pastry node as the source.

markAlive() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Marks this handle as alive (if dead earlier), and reset distance to infinity.

markDead() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Mark this handle as dead (if alive earlier), and reset distance to infinity.

maxChildren - Variable in class rice.p2p.scribe.ScribePolicy.LimitedScribePolicy

The number of children to allow per topic

maxMember() - Method in class rice.pastry.IdSet

return the largest member id

maxSize() - Method in class rice.pastry.leafset.LeafSet

Gets the maximal size of the leaf set.

member(NodeId) - Method in class rice.pastry.NodeSet

test membership using Id

member(NodeHandle) - Method in class rice.pastry.NodeSet

test membership

member(NodeId) - Method in interface rice.pastry.NodeSetI

Verifies if the set contains this particular id.

member(NodeId) - Method in class rice.pastry.leafset.LeafSet

Verifies if the set contains this particular id.

member(NodeId) - Method in class rice.pastry.leafset.SimilarSet

Verifies if the set contains this particular id.

member(NodeId) - Method in class rice.pastry.routing.RouteSet

Membership test.

memberHandle(Id) - Method in interface rice.p2p.commonapi.NodeHandleSet

Verifies if the set contains this particular id.

memberHandle(Id) - Method in class rice.pastry.NodeSet

Verifies if the set contains this particular id.

memberHandle(Id) - Method in class rice.pastry.leafset.SimilarSet

Verifies if the set contains this particular id.

memberHandle(Id) - Method in class rice.pastry.routing.RouteSet

Verifies if the set contains this particular id.

merge(IdRange) - Method in class rice.pastry.IdRange

merge two ranges if this and other don't overlap, are not adjacent, and this is not empty, then the result is this

merge(LeafSet, NodeHandle, RoutingTable, PastrySecurityManager, boolean, Set) - Method in class rice.pastry.leafset.LeafSet

Merge a remote leafset into this

mergeIntersectTest(IdRange, IdRange) - Method in class rice.pastry.testing.IdRangeUnit

mergeLeafSet(LeafSet, NodeHandle) - Method in class rice.pastry.standard.StandardLeafSetProtocol

Merge a remote leafset into our own

mergeRange(IdRange) - Method in interface rice.p2p.commonapi.IdRange

merges the given range with this range

mergeRange(IdRange) - Method in class rice.pastry.IdRange

merges the given range with this range

mergeTest(IdRange, IdRange) - Method in class rice.pastry.testing.IdRangeUnit

message(int) - Method in class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

message - Variable in class rice.pastry.commonapi.PastryEndpointMessage

messageForAppl(Message) - Method in class rice.pastry.client.CommonAPIAppl

messageForAppl(Message) - Method in class rice.pastry.client.PastryAppl

Called by pastry when a message arrives for this application.

messageForAppl(Message) - Method in class rice.pastry.commonapi.PastryEndpoint

messageForAppl(Message) - Method in class rice.pastry.testing.HelloWorldApp

Invoked on destination node when a message arrives.

messageForAppl(Message) - Method in class rice.pastry.testing.HelloWorldAppMultiThread

Invoked on destination node when a message arrives.

messageForAppl(Message) - Method in class rice.pastry.testing.Ping

messageForAppl(Message) - Method in class rice.pastry.testing.PingClient

messageForAppl(Message) - Method in class rice.scribe.Scribe

Called by pastry when a message arrives for this client.

messageForAppl(Message) - Method in class rice.scribe.testing.DistScribeRegrTestApp

messageLine - Variable in class rice.pastry.wire.testing.MessageDigest

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

minMember() - Method in class rice.pastry.IdSet

return the smallest member id

mostSimilar(Id) - Method in class rice.pastry.leafset.LeafSet

Numerically closests node to a given a node in the leaf set.

mostSimilar(Id) - Method in class rice.pastry.leafset.SimilarSet

Numerically closest node to a given a node.

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

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

Multicast information to a group/topic.

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

Multicast information to a group/topic.

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

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

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

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

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

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

multipleHopsAllowed() - Method in class rice.pastry.routing.SendOptions

Returns whether multiple hops are allowed during the transmission of this message.

myCode - Variable in class rice.pastry.standard.StandardAddress

myId - Variable in class rice.p2p.past.ContentHashPastContent

myNodeHandle - Variable in class rice.pastry.routing.RoutingTable

myNodeId - Variable in class rice.pastry.PastryNode

myRange - Variable in class rice.rm.RMImpl

This represents the range of object identifiers in the Id space for which this node (by virtue of its position in the Id Space relative to the positions of the other Pastry nodes) is an i-root (0<=i<=k).

N

NUM_ATTEMPTS - Static variable in class rice.pastry.rmi.RMIPastryNodeFactory

NUM_NODES - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

NUM_NODES - Static variable in class rice.pastry.testing.ClosestRegrTest

NUM_TABLES - Static variable in class rice.pastry.wire.testing.WireFileProcessor

NUM_TOPICS - Static variable in class rice.scribe.testing.DistScribeRegrTest

NUM_TRIALS - Static variable in class rice.pastry.testing.ClosestRegrTest

NeedsWakeUp - interface rice.pastry.wire.NeedsWakeUp.

This interface was designed to pull wakeUp out of all of the SelectionKeyHandlers.

NegOne - Static variable in class rice.pastry.Id

NetworkSimulator - interface rice.pastry.direct.NetworkSimulator.

Interface to an object which is simulating the network.

Node - interface rice.p2p.commonapi.Node.

NodeHandle - class rice.p2p.commonapi.NodeHandle.

NodeHandle() - Constructor for class rice.p2p.commonapi.NodeHandle

NodeHandle - class rice.pastry.NodeHandle.

Interface for handles to remote nodes.

NodeHandle() - Constructor for class rice.pastry.NodeHandle

NodeHandleSet - interface rice.p2p.commonapi.NodeHandleSet.

NodeId - class rice.pastry.NodeId.

Represents a Pastry identifier for a node.

NodeId(byte[]) - Constructor for class rice.pastry.NodeId

Constructor.

NodeId(int[]) - Constructor for class rice.pastry.NodeId

Constructor.

NodeId() - Constructor for class rice.pastry.NodeId

Constructor.

NodeIdFactory - interface rice.pastry.NodeIdFactory.

An interface to any object capable of generating nodeIds.

NodeIdRequestMessage - class rice.pastry.wire.messaging.socket.NodeIdRequestMessage.

Message which represents a request to get a node Id from the remote node.

NodeIdRequestMessage() - Constructor for class rice.pastry.wire.messaging.socket.NodeIdRequestMessage

Constructor

NodeIdResponseMessage - class rice.pastry.wire.messaging.socket.NodeIdResponseMessage.

A response message to a NodeIdRequestMessage, containing the remote node's nodeId.

NodeIdResponseMessage(NodeId) - Constructor for class rice.pastry.wire.messaging.socket.NodeIdResponseMessage

Constructor

NodeIdUnit - class rice.pastry.testing.NodeIdUnit.

NodeIdUnit tests the NodeId class.

NodeIdUnit() - Constructor for class rice.pastry.testing.NodeIdUnit

NodeIsDeadException - exception rice.pastry.wire.exception.NodeIsDeadException.

Thrown if you try to send a message on a node that has been killed.

NodeIsDeadException(Exception) - Constructor for class rice.pastry.wire.exception.NodeIsDeadException

Constructor for NodeIsDeadException.

NodeSet - class rice.pastry.NodeSet.

Represents an ordered set of NodeHandles.

NodeSet() - Constructor for class rice.pastry.NodeSet

Constructor.

NodeSet(Vector) - Constructor for class rice.pastry.NodeSet

Constructor.

NodeSet(NodeSet) - Constructor for class rice.pastry.NodeSet

Copy constructor.

NodeSetI - interface rice.pastry.NodeSetI.

An interface to a generic set of nodes.

NodeSetUpdate - class rice.pastry.NodeSetUpdate.

A class which stores changes to a node set.

NodeSetUpdate(NodeHandle, boolean) - Constructor for class rice.pastry.NodeSetUpdate

Constructor.

Null - Static variable in class rice.pastry.Id

nNodes - Variable in class rice.pastry.direct.TestRecord

nTests - Variable in class rice.pastry.direct.TestRecord

name - Variable in class rice.Continuation.ListenerContinuation

The name of this continuation

name - Variable in class rice.pastry.standard.StandardAddress

needToDisconnectSockets() - Method in class rice.pastry.wire.GlobalSocketManager

asks the socketmanager wether to call removeOpenSocketsIfNeeded

needToDisconnectSockets() - Method in class rice.pastry.wire.SocketManager

called to determine if a socket should be closed

needToReleaseFDs() - Static method in class rice.pastry.wire.Wire

neighborSet(int) - Method in interface rice.p2p.commonapi.Endpoint

This methods returns an unordered set of nodehandles on which are neighbors of the local node in the id space.

neighborSet(int) - Method in class rice.pastry.client.CommonAPIAppl

This method produces an unordered list of nodehandles that are neighbors of the local node in the ID space.

neighborSet(int) - Method in class rice.pastry.commonapi.PastryEndpoint

This method produces an unordered list of nodehandles that are neighbors of the local node in the ID space.

neighborSet(int) - Method in class rice.pastry.leafset.LeafSet

compute an ordered set of nodes that are neighbors of this local node, in order of numerical closeness to the local node

neverAllowSubscribe - Variable in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribePolicy

neverAllowSubscribe(boolean) - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribePolicy

newNode(NodeHandle) - Method in class rice.pastry.PastryNodeFactory

Call this to construct a new node of the type chosen by the factory.

newNode(NodeHandle, NodeId) - Method in class rice.pastry.PastryNodeFactory

Call this to construct a new node of the type chosen by the factory, with the given nodeId.

newNode(NodeHandle) - Method in class rice.pastry.direct.DirectPastryNodeFactory

Manufacture a new Pastry node.

newNode(NodeHandle, NodeId) - Method in class rice.pastry.direct.DirectPastryNodeFactory

Manufacture a new Pastry node.

newNode(NodeHandle) - Method in class rice.pastry.dist.DistPastryNodeFactory

Generates a new pastry node with a random NodeId using the bootstrap bootstrap.

newNode(NodeHandle, NodeId) - Method in class rice.pastry.dist.DistPastryNodeFactory

Generates a new pastry node with the specified NodeId using the bootstrap bootstrap.

newNode(NodeHandle) - Method in class rice.pastry.rmi.RMIPastryNodeFactory

newNode(NodeHandle, NodeId) - Method in class rice.pastry.rmi.RMIPastryNodeFactory

Makes many policy choices and manufactures a new RMIPastryNode.

newNode(NodeHandle) - Method in class rice.pastry.wire.WirePastryNodeFactory

Method which creates a Pastry node from the next port with a randomly generated NodeId.

newNode(NodeHandle, NodeId) - Method in class rice.pastry.wire.WirePastryNodeFactory

Method which creates a Pastry node from the next port with a randomly generated NodeId.

newParent(NodeId, NodeHandle, Serializable) - Method in interface rice.scribe.IScribeApp

Upcall made by scribe to the registered applications to inform them that a new parent is found for local node in the topic tree.

newParent(NodeId, NodeHandle, Serializable) - Method in class rice.scribe.testing.BasicScribeRegrTestApp

Upcall by scribe to let this application know about local node's new parent in the topic tree

newParent(NodeId, NodeHandle, Serializable) - Method in class rice.scribe.testing.DirectScribeMaintenanceTestApp

Upcall by scribe to let this application know about local node's new parent in the topic tree

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

Upcall by scribe to let this application know about local node's new parent in the topic tree

nextHop - Variable in class rice.pastry.routing.RouteMessage

nextUID - Variable in class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

The next message UID which is available

node - Variable in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest.TestReplicationManagerClient

node - Variable in class rice.p2p.replication.testing.ReplicationRegrTest.TestReplicationClient

node - Variable in class rice.p2p.splitstream.SplitStreamImpl

The node that this application is running on

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

nodeIdBitLength - Static variable in class rice.pastry.NodeId

This is the bit length of the node ids.

nodeIdToApp - Variable in class rice.rm.testing.DirectRMRegrTest

nodeIdToApp - Variable in class rice.scribe.testing.DirectScribeMaintenanceTest

nodeIsReady() - Method in class rice.pastry.PastryNode

Overridden by derived classes, and invoked when the node has joined successfully.

nodeIsReady() - Method in class rice.pastry.direct.DirectPastryNode

Called from PastryNode after the join succeeds.

nodeIsReady() - Method in class rice.pastry.dist.DistPastryNode

Called from PastryNode when the join succeeds.

nodeIsReady() - Method in class rice.pastry.rmi.RMIPastryNode

Called from PastryNode when the join succeeds, whereupon it rebinds the node into the RMI registry.

nodeIsReady() - Method in class rice.pastry.wire.WirePastryNode

called when the node is initialized

node_created() - Method in class rice.pastry.testing.DistHelloWorldMultiThread

nodes - Variable in class rice.p2p.commonapi.testing.CommonAPITest

notifyKilled() - Method in class rice.pastry.wire.DatagramManager

notifyKilled() - Method in class rice.pastry.wire.DatagramTransmissionManager

notifys all of the TransmissionEntries that they have been killed.

notifyKilled() - Method in class rice.pastry.wire.SocketChannelWriter

prints out any messages still in queue

notifyKilled() - Method in class rice.pastry.wire.WireNodeHandle

prints Potentially lost the message for all messages in queue

notifyKilled() - Method in class rice.pastry.wire.WireNodeHandlePool

tells all the WireNodeHandles they have been killed.

notifyObservers(Object) - Method in class rice.pastry.direct.DirectNodeHandle

DESCRIBE THE METHOD

notifyObservers() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

notifyObservers(Object) - Method in class rice.pastry.dist.DistCoalesedNodeHandle

notifyPotentiallyLostMessage(Iterator) - Method in class rice.pastry.wire.WireNodeHandle

prints Potentially lost the message for all messages in the iterator

notifyReady() - Method in class rice.pastry.client.CommonAPIAppl

Invoked when the Pastry node has joined the overlay network and is ready to send and receive messages

notifyReady() - Method in class rice.pastry.client.PastryAppl

Invoked when the Pastry node has joined the overlay network and is ready to send and receive messages

notifyReady() - Method in class rice.pastry.testing.HelloWorldApp

Invoked by {RMI,Direct}PastryNode when the node has something in its leaf set, and has become ready to receive application messages.

notifyReady() - Method in class rice.pastry.testing.HelloWorldAppMultiThread

Invoked by {RMI,Direct}PastryNode when the node has something in its leaf set, and has become ready to receive application messages.

notifyReady() - Method in class rice.pastry.testing.RegrTestApp

Invoked when the Pastry node has joined the overlay network and is ready to send and receive messages

notifyReady() - Method in class rice.rm.RMImpl

This is called when the underlying pastry node is ready.

notifyReady() - Method in class rice.scribe.Scribe

This is called when the underlying pastry node is ready.

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

Notifies the applications on top of scribe who are interested in knowing the events of implicit topic creation.

num - Variable in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeContent

DESCRIBE THE FIELD

num - Variable in class rice.pastry.wire.messaging.datagram.DatagramMessage

DESCRIBE THE FIELD

num - Variable in class rice.scribe.testing.DistScribeRegrTest

numChildren(NodeId) - Method in interface rice.scribe.IScribe

This returns the number of children in this topic's multicast subtree rooted at the local node.

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

This returns the number of children in this topic's multicast subtree rooted at the local node.

numColumns() - Method in class rice.pastry.routing.RoutingTable

return ths number of columns in the routing table

numDigits(int) - Static method in class rice.pastry.Id

return the number of digits in a given base

numElements() - Method in interface rice.p2p.commonapi.IdSet

return the number of elements

numElements() - Method in class rice.pastry.IdSet

return the number of elements

numObjects - Static variable in class rice.rm.testing.DistRMRegrTestApp

numObjectsInPeriod - Static variable in class rice.rm.testing.DistRMRegrTestApp

numRefreshed - Variable in class rice.rm.testing.DistRMRegrTestApp

numReplicated - Variable in class rice.rm.testing.DistRMRegrTestApp

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

Get the number of rows.

numRows() - Method in class rice.pastry.routing.RoutingTable

return the number of rows in the routing table

O

ObjectInsertionMsg - class rice.rm.testing.ObjectInsertionMsg.

ObjectInsertionMsg(NodeHandle, Address, Credentials) - Constructor for class rice.rm.testing.ObjectInsertionMsg

Constructor

ObjectRefreshMsg - class rice.rm.testing.ObjectRefreshMsg.

ObjectRefreshMsg(NodeHandle, Address, Credentials) - Constructor for class rice.rm.testing.ObjectRefreshMsg

Constructor

ObjectState - class rice.rm.testing.ObjectState.

ObjectState(boolean, int, int) - Constructor for class rice.rm.testing.ObjectState

One - Static variable in class rice.pastry.Id

openSocket(WireNodeHandle) - Method in class rice.pastry.wire.SocketManager

Method which is designed to be called by node handles when they wish to open a socket to their remote node.

openSockets - Variable in class rice.pastry.wire.SocketManager

the linked list of open sockets

originalException - Variable in class rice.pastry.wire.exception.NodeIsDeadException

The original reason we found the node to be dead.

overlaps() - Method in class rice.pastry.leafset.LeafSet

Test if the leafset overlaps

P

PAD_SIZE - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

PAD_SIZE - Static variable in class rice.persistence.testing.Test

PASTMessage - class rice.past.messaging.PASTMessage.

Deprecated. This version of PAST has been deprecated - please use the version located in the rice.p2p.past package.

PASTMessage(Id, Id, int) - Constructor for class rice.past.messaging.PASTMessage

Deprecated. Constructor

PASTMessage(Id, Id) - Constructor for class rice.past.messaging.PASTMessage

Deprecated. Constructor

PASTMessageID - interface rice.past.messaging.PASTMessageID.

Deprecated. This version of PAST has been deprecated - please use the version located in the rice.p2p.past package.

PASTMessageIDImpl - class rice.past.messaging.PASTMessageIDImpl.

Deprecated. This version of PAST has been deprecated - please use the version located in the rice.p2p.past package.

PASTService - interface rice.past.PASTService.

Deprecated. This version of PAST has been deprecated - please use the version located in the rice.p2p.past package.

PASTServiceImpl - class rice.past.PASTServiceImpl.

Deprecated. This version of PAST has been deprecated - please use the version located in the rice.p2p.past package.

PASTServiceImpl(Node, StorageManager, String) - Constructor for class rice.past.PASTServiceImpl

Deprecated. Builds a new PASTService to run on the given PastryNode, given a Storage object (to persistedly store objects) and a cache used to cache objects.

PING_THROTTLE - Static variable in class rice.pastry.wire.WireNodeHandle

the throttle (pings only sent this many seconds)

PORT - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

PREFIX_LENGTH - Static variable in class rice.pastry.wire.testing.WireFileProcessor

PROTOCOL - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

PROTOCOL_DIRECT - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

PROTOCOL_RMI - Static variable in class rice.pastry.dist.DistPastryNodeFactory

DESCRIBE THE FIELD

PROTOCOL_SOCKET - Static variable in class rice.pastry.dist.DistPastryNodeFactory

DESCRIBE THE FIELD

PROTOCOL_WIRE - Static variable in class rice.pastry.dist.DistPastryNodeFactory

DESCRIBE THE FIELD

PROXIMITY_CHANGED - Static variable in class rice.p2p.commonapi.NodeHandle

PSecurityManager - class rice.scribe.security.PSecurityManager.

Implementation of a trivial security manager.

PSecurityManager() - Constructor for class rice.scribe.security.PSecurityManager

Past - interface rice.p2p.past.Past.

PastContent - interface rice.p2p.past.PastContent.

PastContentHandle - interface rice.p2p.past.PastContentHandle.

PastException - exception rice.p2p.past.PastException.

PastException(String) - Constructor for class rice.p2p.past.PastException

Constructor.

PastImpl - class rice.p2p.past.PastImpl.

PastImpl(Node, StorageManager, int, String) - Constructor for class rice.p2p.past.PastImpl

Constructor for Past

PastMessage - class rice.p2p.past.messaging.PastMessage.

PastMessage(int, NodeHandle, Id) - Constructor for class rice.p2p.past.messaging.PastMessage

Constructor which takes a unique integer Id

PastRegrTest - class rice.p2p.past.testing.PastRegrTest.

PastRegrTest() - Constructor for class rice.p2p.past.testing.PastRegrTest

Constructor which sets up all local variables

PastRegrTest.NonMutableTestPastContent - class rice.p2p.past.testing.PastRegrTest.NonMutableTestPastContent.

PastRegrTest.NonMutableTestPastContent(Id) - Constructor for class rice.p2p.past.testing.PastRegrTest.NonMutableTestPastContent

PastRegrTest.NonOverwritingTestPastContent - class rice.p2p.past.testing.PastRegrTest.NonOverwritingTestPastContent.

PastRegrTest.NonOverwritingTestPastContent(Id, int) - Constructor for class rice.p2p.past.testing.PastRegrTest.NonOverwritingTestPastContent

PastRegrTest.TestCommand - class rice.p2p.past.testing.PastRegrTest.TestCommand.

Common superclass for test commands.

PastRegrTest.TestCommand() - Constructor for class rice.p2p.past.testing.PastRegrTest.TestCommand

PastRegrTest.TestExceptionCommand - class rice.p2p.past.testing.PastRegrTest.TestExceptionCommand.

Common superclass for test commands which should throw an exception

PastRegrTest.TestExceptionCommand() - Constructor for class rice.p2p.past.testing.PastRegrTest.TestExceptionCommand

PastRegrTest.TestPastContent - class rice.p2p.past.testing.PastRegrTest.TestPastContent.

Utility class for past content objects

PastRegrTest.TestPastContent(Id) - Constructor for class rice.p2p.past.testing.PastRegrTest.TestPastContent

PastRegrTest.TestPastContentHandle - class rice.p2p.past.testing.PastRegrTest.TestPastContentHandle.

Utility class for past content object handles

PastRegrTest.TestPastContentHandle(Past, Id) - Constructor for class rice.p2p.past.testing.PastRegrTest.TestPastContentHandle

PastRegrTest.TestRouteMessage - class rice.p2p.past.testing.PastRegrTest.TestRouteMessage.

Utility class which simulates a route message

PastRegrTest.TestRouteMessage(Id, NodeHandle, Message) - Constructor for class rice.p2p.past.testing.PastRegrTest.TestRouteMessage

PastRegrTest.VersionedTestPastContent - class rice.p2p.past.testing.PastRegrTest.VersionedTestPastContent.

PastRegrTest.VersionedTestPastContent(Id, int) - Constructor for class rice.p2p.past.testing.PastRegrTest.VersionedTestPastContent

PastryAppl - class rice.pastry.client.PastryAppl.

A PastryAppl is an abstract class that every Pastry application extends.

PastryAppl(PastryNode) - Constructor for class rice.pastry.client.PastryAppl

Constructor.

PastryAppl(PastryNode, String) - Constructor for class rice.pastry.client.PastryAppl

Constructor.

PastryEndpoint - class rice.pastry.commonapi.PastryEndpoint.

This class serves as gluecode, which allows applications written for the common API to work with pastry.

PastryEndpoint(PastryNode, Application, String) - Constructor for class rice.pastry.commonapi.PastryEndpoint

Constructor.

PastryEndpointMessage - class rice.pastry.commonapi.PastryEndpointMessage.

This class is an internal message to the commonapi gluecode.

PastryEndpointMessage(Address, Message) - Constructor for class rice.pastry.commonapi.PastryEndpointMessage

Constructor.

PastryIdFactory - class rice.pastry.commonapi.PastryIdFactory.

This class provides applications with a way of genertating pastry Ids.

PastryIdFactory() - Constructor for class rice.pastry.commonapi.PastryIdFactory

Constructor

PastryNode - class rice.pastry.PastryNode.

A Pastry node is single entity in the pastry network.

PastryNode(NodeId) - Constructor for class rice.pastry.PastryNode

Constructor, with NodeId.

PastryNodeFactory - class rice.pastry.PastryNodeFactory.

The interface to an object which can construct PastryNodes.

PastryNodeFactory() - Constructor for class rice.pastry.PastryNodeFactory

PastryRegrTest - class rice.pastry.testing.PastryRegrTest.

PastryRegrTest a regression test suite for pastry.

PastryRegrTest() - Constructor for class rice.pastry.testing.PastryRegrTest

constructor

PastrySecurityManager - interface rice.pastry.security.PastrySecurityManager.

The security manager interface.

PastrySeed - class rice.pastry.PastrySeed.

PastrySeed() - Constructor for class rice.pastry.PastrySeed

PastryTest - class rice.pastry.testing.PastryTest.

Pastry test.

PastryTest() - Constructor for class rice.pastry.testing.PastryTest

PendingLocalNodesList - class rice.pastry.PendingLocalNodesList.

Class which stores a list of LocalNodes waiting to have their local pastry node to be set non-null.

PendingLocalNodesList() - Constructor for class rice.pastry.PendingLocalNodesList

PendingWrite - class rice.pastry.wire.PendingWrite.

Wrapper class which contains an object to write and the address it needs to be written to.

PendingWrite(NodeId, InetSocketAddress, Object) - Constructor for class rice.pastry.wire.PendingWrite

Contructs a PendingWrite from an address and an object

PermissiveCredentials - class rice.pastry.security.PermissiveCredentials.

Trivial credentials.

PermissiveCredentials() - Constructor for class rice.pastry.security.PermissiveCredentials

PermissiveSecurityManager - class rice.pastry.security.PermissiveSecurityManager.

A trivial security manager.

PermissiveSecurityManager() - Constructor for class rice.pastry.security.PermissiveSecurityManager

PersistentStorage - class rice.persistence.PersistentStorage.

This class is an implementation of Storage which provides persistent storage to disk.

PersistentStorage(IdFactory, String, int) - Constructor for class rice.persistence.PersistentStorage

Builds a PersistentStorage given a root directory in which to persist the data.

PersistentStorage(IdFactory, String, String, int) - Constructor for class rice.persistence.PersistentStorage

Builds a PersistentStorage given and an instance name and a root directoy in which to persist the data.

PersistentStorageTest - class rice.persistence.testing.PersistentStorageTest.

This class is a class which tests the PersistentStorage class in the rice.persistence package.

PersistentStorageTest(boolean) - Constructor for class rice.persistence.testing.PersistentStorageTest

Builds a MemoryStorageTest

Ping - class rice.pastry.testing.Ping.

Ping A performance test suite for pastry.

Ping(PastryNode) - Constructor for class rice.pastry.testing.Ping

PingAddress - class rice.pastry.testing.PingAddress.

PingAddress A performance test suite for pastry.

PingAddress() - Constructor for class rice.pastry.testing.PingAddress

PingClient - class rice.pastry.testing.PingClient.

A very simple ping object.

PingClient(PastryNode) - Constructor for class rice.pastry.testing.PingClient

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

Class which represents a "ping" message sent through the udp pastry system.

PingMessage(NodeId, NodeId, int, WireNodeHandle) - Constructor for class rice.pastry.wire.messaging.datagram.PingMessage

Constructor

PingMessageNew - class rice.pastry.testing.PingMessageNew.

PingMessageNew A performance test suite for pastry.

PingMessageNew(Address, NodeId, NodeId) - Constructor for class rice.pastry.testing.PingMessageNew

PingTestRecord - class rice.pastry.testing.PingTestRecord.

PingAddress A performance test suite for pastry.

PingTestRecord(int, int) - Constructor for class rice.pastry.testing.PingTestRecord

PublishMessage - class rice.p2p.scribe.messaging.PublishMessage.

PublishMessage(NodeHandle, Topic, ScribeContent) - Constructor for class rice.p2p.scribe.messaging.PublishMessage

Constructor which takes a unique integer Id

PublishMessageDigest - class rice.pastry.wire.testing.PublishMessageDigest.

A digest specifically designed to analyze Splitstream PublishMessage

PublishMessageDigest(int, String, String, String, int, boolean, int) - Constructor for class rice.pastry.wire.testing.PublishMessageDigest

PublishRequestMessage - class rice.p2p.scribe.messaging.PublishRequestMessage.

PublishRequestMessage(NodeHandle, Topic, ScribeContent) - Constructor for class rice.p2p.scribe.messaging.PublishRequestMessage

Constructor which takes a unique integer Id

parent - Variable in class rice.Continuation.StandardContinuation

The parent continuation

parent - Variable in class rice.p2p.scribe.ScribeImpl.TopicManager

DESCRIBE THE FIELD

parseArgs(String[]) - Static method in class rice.p2p.commonapi.testing.CommonAPITest

process command line args

pastryNodes - Variable in class rice.pastry.testing.PastryRegrTest

pastryNodesLastAdded - Variable in class rice.pastry.testing.PastryRegrTest

pastryNodesSorted - Variable in class rice.pastry.testing.PastryRegrTest

pasts - Variable in class rice.p2p.past.testing.PastRegrTest

pathToRoot - Variable in class rice.p2p.scribe.ScribeImpl.TopicManager

The current path to the root for this node

pathToRoot - Variable in class rice.p2p.scribe.messaging.SubscribeAckMessage

The contained path to the root

pause(int) - Method in class rice.p2p.commonapi.testing.CommonAPITest

Method which pauses for the provided number of milliseconds

pause(int) - Method in class rice.past.testing.DistPASTRegrTest

Deprecated.

pause(int) - Method in class rice.pastry.rmi.RMIPastryNodeFactory

Pauses the current thread for ms milliseconds.

pause(int) - Method in class rice.pastry.testing.DirectPastryRegrTest

pause(int) - Method in class rice.pastry.testing.DistPastryRegrTest

pause(int) - Method in class rice.pastry.testing.PastryRegrTest

peekNext() - Method in class rice.p2p.scribe.messaging.AnycastMessage

Returns the next handle to visit

pending - Static variable in interface rice.pastry.LocalNodeI

Refer to README.handles_localnode.

pendingMsg - Variable in class rice.pastry.wire.SocketChannelWriter

a message that has already been serialized and pulled off of the queue but hasn't been sent

performAction(PASTServiceImpl) - Method in class rice.past.messaging.MessageExists

Deprecated. Looks up the file in the given service's storage.

performAction(PASTServiceImpl) - Method in class rice.past.messaging.MessageFetch

Deprecated. Looks up the file in the given service's storage.

performAction(PASTServiceImpl) - Method in class rice.past.messaging.MessageInsert

Deprecated. Inserts this message's file into the service.

performAction(PASTServiceImpl) - Method in class rice.past.messaging.MessageLookup

Deprecated. Looks up the file in the given service's storage.

performAction(PASTServiceImpl) - Method in class rice.past.messaging.MessageReclaim

Deprecated. Reclaims the space in the service's storage.

performAction(PASTServiceImpl) - Method in class rice.past.messaging.PASTMessage

Deprecated. Performs this message's action after it is delivered.

periodicMaintenance() - Method in class rice.rm.RMImpl

This is the periodic maintenance protocol which removes stale objects as well as checks to see if there is any missing object.

periodicMaintenance() - Method in class rice.rm.testing.RMRegrTestApp

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

Ping the node.

ping() - Method in class rice.pastry.direct.DirectNodeHandle

DESCRIBE THE METHOD

ping() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Ping the node.

ping() - Method in class rice.pastry.testing.LeafSetTest.TestNodeHandle

pingAllNew() - Method in class rice.pastry.routing.RouteSet

Pings all new nodes in the RouteSet.

pingImpl() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Ping the node.

pingImpl() - Method in class rice.pastry.rmi.RMINodeHandle

Ping the remote node now, and update the proximity metric.

pingImpl() - Method in class rice.pastry.wire.WireNodeHandle

Ping the remote node now, and update the proximity metric.

pingResponse() - Method in class rice.pastry.wire.WireNodeHandle

Method which is called by the SocketPingManager when a ping response comes back for this node.

pingStarted() - Method in class rice.pastry.wire.WireNodeHandle

Method which is called by the PingMessage right before it is going to be sent across the wire.

policies - Variable in class rice.p2p.scribe.testing.ScribeRegrTest

The scribe policies

policy - Variable in class rice.p2p.scribe.ScribeImpl

this scribe's policy

policy - Variable in class rice.p2p.splitstream.SplitStreamScribePolicy

A mapping from channelId -> maximum children

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

Resets the number of heartbeat messages corresponding to this topic to zero.

previousParent - Variable in class rice.p2p.scribe.messaging.SubscribeMessage

The previous parent

print() - Method in class rice.pastry.wire.testing.WireFileProcessor.ObjPair

printDiffa(WireFileProcessor.ObjPair) - Method in class rice.pastry.wire.testing.WireFileProcessor.ObjPair

printPendingRanges(NodeId) - Method in class rice.rm.RMImpl

Prints the list of pending Ranges corresponding to a node that we are communicating to in the Keys Exchange Protocol.

printRange() - Method in class rice.rm.testing.RMRegrTestApp

printStatus() - Static method in class rice.pastry.wire.Wire

printTableTotals() - Method in class rice.pastry.wire.testing.WireFileProcessor

processDMFile(File, boolean) - Method in class rice.pastry.wire.testing.WireFileProcessor

processFile(String) - Method in class rice.pastry.wire.testing.WireFileProcessor

processFiles() - Method in class rice.pastry.wire.testing.WireFileProcessor

processFiles(File) - Method in class rice.pastry.wire.testing.WireFileProcessor

processLog(NodeId, int) - Method in class rice.scribe.testing.DistScribeRegrTestApp

processNode(int, Node) - Method in class rice.p2p.commonapi.testing.CommonAPITest

Method which should process the given newly-created node

processNode(int, Node) - Method in class rice.p2p.past.testing.PastRegrTest

Method which should process the given newly-created node

processNode(int, Node) - Method in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

Method which should process the given newly-created node

processNode(int, Node) - Method in class rice.p2p.replication.testing.ReplicationRegrTest

Method which should process the given newly-created node

processNode(int, Node) - Method in class rice.p2p.scribe.testing.ScribeRegrTest

Method which should process the given newly-created node

processNode(int, Node) - Method in class rice.p2p.splitstream.testing.SplitStreamRegrTest

Method which should process the given newly-created node

processWNHFile(File, boolean) - Method in class rice.pastry.wire.testing.WireFileProcessor

protocol - Static variable in class rice.pastry.testing.DistHelloWorld

protocol - Static variable in class rice.pastry.testing.DistHelloWorldMultiThread

protocol - Static variable in class rice.rm.testing.DistRMRegrTest

protocol - Static variable in class rice.scribe.testing.DistScribeRegrTest

proximity() - Method in class rice.p2p.commonapi.NodeHandle

Returns the current proximity value of this node

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

Returns the last known proximity information about the Pastry node associated with this handle.

proximity() - Method in class rice.pastry.direct.DirectNodeHandle

DESCRIBE THE METHOD

proximity(NodeId, NodeId) - Method in class rice.pastry.direct.EuclideanNetwork

computes the proximity between two NodeIds

proximity(NodeId, NodeId) - Method in interface rice.pastry.direct.NetworkSimulator

Determines proximity between two nodes.

proximity(NodeId, NodeId) - Method in class rice.pastry.direct.SphereNetwork

computes the proximity between two NodeIds

proximity() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Returns the last known proximity information about the Pastry node associated with this handle.

proximity() - Method in class rice.pastry.testing.LeafSetTest.TestNodeHandle

publish(Topic, ScribeContent) - Method in interface rice.p2p.scribe.Scribe

Publishes the given message to the topic.

publish(Topic, ScribeContent) - Method in class rice.p2p.scribe.ScribeImpl

Publishes the given message to the topic.

publish(byte[]) - Method in class rice.p2p.splitstream.Stripe

Publishes the given data to this stripe

publishMessages - Variable in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

The publish messages received so far

pushRow(RouteSet[]) - Method in class rice.pastry.join.JoinRequest

Push row.

put(NodeHandle) - Method in class rice.pastry.NodeSet

Appends a member to the ordered set.

put(NodeHandle) - Method in interface rice.pastry.NodeSetI

Puts a NodeHandle into the set.

put(NodeHandle) - Method in class rice.pastry.leafset.LeafSet

Puts a NodeHandle into the set.

put(NodeHandle) - Method in class rice.pastry.leafset.SimilarSet

Puts a NodeHandle into the set.

put(NodeHandle) - Method in class rice.pastry.routing.RouteSet

Puts a node into the set.

put(NodeHandle) - Method in class rice.pastry.routing.RoutingTable

Puts a handle into the routing table.

putHandle(NodeHandle) - Method in interface rice.p2p.commonapi.NodeHandleSet

Puts a NodeHandle into the set.

putHandle(NodeHandle) - Method in class rice.pastry.NodeSet

Puts a NodeHandle into the set.

putHandle(NodeHandle) - Method in class rice.pastry.leafset.SimilarSet

Puts a NodeHandle into the set.

putHandle(NodeHandle) - Method in class rice.pastry.routing.RouteSet

Puts a NodeHandle into the set.

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

Let's the current node know about a topic created in the whole scribe network.

Q

queueSize() - Method in class rice.pastry.wire.SocketChannelWriter

Accessor for the queue size.

R

REPLICATION_FACTOR - Static variable in class rice.p2p.past.testing.PastRegrTest

REPLICATION_FACTOR - Static variable in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

The replication factor to use

REPLICATION_FACTOR - Static variable in class rice.p2p.replication.testing.ReplicationRegrTest

The replication factor to use

REQUEST - Static variable in class rice.past.messaging.PASTMessage

Deprecated.

RESPONSE - Static variable in class rice.past.messaging.PASTMessage

Deprecated.

RM - interface rice.rm.RM.

RMClient - interface rice.rm.RMClient.

RMINodeHandle - class rice.pastry.rmi.RMINodeHandle.

A locally stored node handle that points to a remote RMIRemoteNodeI.

RMINodeHandle(RMIRemoteNodeI, NodeId, InetSocketAddress) - Constructor for class rice.pastry.rmi.RMINodeHandle

Constructor.

RMINodeHandle(RMIRemoteNodeI, NodeId, PastryNode, InetSocketAddress) - Constructor for class rice.pastry.rmi.RMINodeHandle

Alternate constructor with local Pastry node.

RMIPastryNode - class rice.pastry.rmi.RMIPastryNode.

An RMI-exported Pastry node.

RMIPastryNode(NodeId) - Constructor for class rice.pastry.rmi.RMIPastryNode

Constructor

RMIPastryNodeFactory - class rice.pastry.rmi.RMIPastryNodeFactory.

Pastry node factory for RMI-linked nodes.

RMIPastryNodeFactory(NodeIdFactory, int) - Constructor for class rice.pastry.rmi.RMIPastryNodeFactory

Constructor.

RMIPastrySecurityManager - class rice.pastry.rmi.RMIPastrySecurityManager.

Security manager for RMI connections between nodes.

RMIPastrySecurityManager(RMINodeHandle, RMINodeHandlePool) - Constructor for class rice.pastry.rmi.RMIPastrySecurityManager

Constructor.

RMIRemoteNodeI - interface rice.pastry.rmi.RMIRemoteNodeI.

A remote interface exported by Pastry nodes.

RMImpl - class rice.rm.RMImpl.

RMImpl(PastryNode, RMClient, int, String) - Constructor for class rice.rm.RMImpl

Builds a new ReplicaManager(RM) associated with a particular RMclient.

RMImpl.KEPenEntry - class rice.rm.RMImpl.KEPenEntry.

This is the per entry state corresponding to the m_pendingRanges hashtable that we maintain in the Keys Exchange Protocol.

RMImpl.KEPenEntry(IdRange) - Constructor for class rice.rm.RMImpl.KEPenEntry

RMImpl.KEPenEntry(IdRange, int) - Constructor for class rice.rm.RMImpl.KEPenEntry

RMMaintenanceMsg - class rice.rm.messaging.RMMaintenanceMsg.

RMMaintenanceMsg(NodeHandle, Address, Credentials, int) - Constructor for class rice.rm.messaging.RMMaintenanceMsg

Constructor

RMMessage - class rice.rm.messaging.RMMessage.

RMMessage(NodeHandle, Address, Credentials, int) - Constructor for class rice.rm.messaging.RMMessage

Constructor : Builds a new RM Message

RMMessage.KEEntry - class rice.rm.messaging.RMMessage.KEEntry.

This class will be used by the messaging system.

RMMessage.KEEntry(IdRange, boolean) - Constructor for class rice.rm.messaging.RMMessage.KEEntry

RMMessage.KEEntry(IdRange, IdRange, int, boolean, Id, IdSet) - Constructor for class rice.rm.messaging.RMMessage.KEEntry

RMRegrTestApp - class rice.rm.testing.RMRegrTestApp.

RMRegrTestApp(PastryNode, Credentials, String) - Constructor for class rice.rm.testing.RMRegrTestApp

Constructor

RMRegrTestApp.ReplicateEntry - class rice.rm.testing.RMRegrTestApp.ReplicateEntry.

RMRegrTestApp.ReplicateEntry(Object) - Constructor for class rice.rm.testing.RMRegrTestApp.ReplicateEntry

RMRequestKeysMsg - class rice.rm.messaging.RMRequestKeysMsg.

RMRequestKeysMsg(NodeHandle, Address, Credentials, int, Vector, int) - Constructor for class rice.rm.messaging.RMRequestKeysMsg

Constructor : Builds a new RM Message

RMRequestKeysMsg.WrappedMsg - class rice.rm.messaging.RMRequestKeysMsg.WrappedMsg.

Contains the RMRequestKeysMsg and the destination to which it was being sent.

RMRequestKeysMsg.WrappedMsg(RMRequestKeysMsg, NodeHandle) - Constructor for class rice.rm.messaging.RMRequestKeysMsg.WrappedMsg

RMResponseKeysMsg - class rice.rm.messaging.RMResponseKeysMsg.

RMResponseKeysMsg(NodeHandle, Address, Credentials, int, Vector, int) - Constructor for class rice.rm.messaging.RMResponseKeysMsg

Constructor : Builds a new RM Message

RMTimeoutMsg - class rice.rm.messaging.RMTimeoutMsg.

RMTimeoutMsg(NodeHandle, Address, Credentials, int, RMRequestKeysMsg.WrappedMsg) - Constructor for class rice.rm.messaging.RMTimeoutMsg

Constructor

RandomNodeIdFactory - class rice.pastry.standard.RandomNodeIdFactory.

Constructs random node ids by SHA'ing consecutive numbers, with random starting value.

RandomNodeIdFactory() - Constructor for class rice.pastry.standard.RandomNodeIdFactory

Constructor.

RefreshMsg - class rice.rm.testing.RefreshMsg.

RefreshMsg(NodeHandle, Address, Id, Credentials) - Constructor for class rice.rm.testing.RefreshMsg

RegrTestApp - class rice.pastry.testing.RegrTestApp.

RegrTestApp A regression test suite for pastry.

RegrTestApp(PastryNode, PastryRegrTest) - Constructor for class rice.pastry.testing.RegrTestApp

ReminderMessage - class rice.p2p.replication.manager.messaging.ReminderMessage.

ReminderMessage() - Constructor for class rice.p2p.replication.manager.messaging.ReminderMessage

Constructor which takes a unique integer Id

ReminderMessage - class rice.p2p.replication.messaging.ReminderMessage.

ReminderMessage(NodeHandle) - Constructor for class rice.p2p.replication.messaging.ReminderMessage

Constructor which takes a unique integer Id

ReplicateMsg - class rice.rm.testing.ReplicateMsg.

ReplicateMsg(NodeHandle, Address, Id, Credentials) - Constructor for class rice.rm.testing.ReplicateMsg

ReplicateResponseMsg - class rice.rm.testing.ReplicateResponseMsg.

ReplicateResponseMsg(NodeHandle, Address, Id, NodeSet, Credentials) - Constructor for class rice.rm.testing.ReplicateResponseMsg

Constructor : Builds a new RM Message

ReplicateTimeoutMsg - class rice.rm.testing.ReplicateTimeoutMsg.

ReplicateTimeoutMsg(NodeHandle, Address, Id, Credentials) - Constructor for class rice.rm.testing.ReplicateTimeoutMsg

Constructor

Replication - interface rice.p2p.replication.Replication.

ReplicationClient - interface rice.p2p.replication.ReplicationClient.

ReplicationImpl - class rice.p2p.replication.ReplicationImpl.

ReplicationImpl(Node, ReplicationClient, int, String) - Constructor for class rice.p2p.replication.ReplicationImpl

Constructor

ReplicationManager - interface rice.p2p.replication.manager.ReplicationManager.

ReplicationManagerClient - interface rice.p2p.replication.manager.ReplicationManagerClient.

ReplicationManagerImpl - class rice.p2p.replication.manager.ReplicationManagerImpl.

ReplicationManagerImpl(Node, ReplicationManagerClient, int, String) - Constructor for class rice.p2p.replication.manager.ReplicationManagerImpl

Constructor

ReplicationManagerImpl.ReplicationManagerHelper - class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper.

Inner class which keeps track of the state we're in- waiting, sleeping, or with nothing to do.

ReplicationManagerImpl.ReplicationManagerHelper() - Constructor for class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

Constructor

ReplicationManagerRegrTest - class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest.

ReplicationManagerRegrTest() - Constructor for class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

Constructor which sets up all local variables

ReplicationManagerRegrTest.TestReplicationManagerClient - class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest.TestReplicationManagerClient.

DESCRIBE THE CLASS

ReplicationManagerRegrTest.TestReplicationManagerClient(Node) - Constructor for class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest.TestReplicationManagerClient

ReplicationMessage - class rice.p2p.replication.messaging.ReplicationMessage.

ReplicationMessage(NodeHandle) - Constructor for class rice.p2p.replication.messaging.ReplicationMessage

Constructor which takes a unique integer Id

ReplicationRegrTest - class rice.p2p.replication.testing.ReplicationRegrTest.

ReplicationRegrTest() - Constructor for class rice.p2p.replication.testing.ReplicationRegrTest

Constructor which sets up all local variables

ReplicationRegrTest.TestReplicationClient - class rice.p2p.replication.testing.ReplicationRegrTest.TestReplicationClient.

DESCRIBE THE CLASS

ReplicationRegrTest.TestReplicationClient(Node) - Constructor for class rice.p2p.replication.testing.ReplicationRegrTest.TestReplicationClient

RequestLeafSet - class rice.pastry.leafset.RequestLeafSet.

Request a leaf set from another node.

RequestLeafSet(NodeHandle) - Constructor for class rice.pastry.leafset.RequestLeafSet

Constructor.

RequestLeafSet(Credentials, NodeHandle) - Constructor for class rice.pastry.leafset.RequestLeafSet

Constructor.

RequestLeafSet(Date, NodeHandle) - Constructor for class rice.pastry.leafset.RequestLeafSet

Constructor.

RequestLeafSet(Credentials, Date, NodeHandle) - Constructor for class rice.pastry.leafset.RequestLeafSet

Constructor.

RequestMessage - class rice.p2p.replication.messaging.RequestMessage.

RequestMessage(NodeHandle, IdRange[], Id[]) - Constructor for class rice.p2p.replication.messaging.RequestMessage

Constructor which takes a unique integer Id

RequestRouteRow - class rice.pastry.routing.RequestRouteRow.

Request a row from the routing table from another node.

RequestRouteRow(NodeHandle, int) - Constructor for class rice.pastry.routing.RequestRouteRow

Constructor.

RequestRouteRow(Credentials, NodeHandle, int) - Constructor for class rice.pastry.routing.RequestRouteRow

Constructor.

RequestRouteRow(Date, NodeHandle, int) - Constructor for class rice.pastry.routing.RequestRouteRow

Constructor.

RequestRouteRow(Credentials, Date, NodeHandle, int) - Constructor for class rice.pastry.routing.RequestRouteRow

Constructor.

ResponseMessage - class rice.p2p.replication.messaging.ResponseMessage.

ResponseMessage(NodeHandle, IdSet) - Constructor for class rice.p2p.replication.messaging.ResponseMessage

Constructor which takes a unique integer Id

RouteMessage - interface rice.p2p.commonapi.RouteMessage.

RouteMessage - class rice.pastry.routing.RouteMessage.

A route message contains a pastry message that has been wrapped to be sent to another pastry node.

RouteMessage(Id, Message, Credentials) - Constructor for class rice.pastry.routing.RouteMessage

Constructor.

RouteMessage(Id, Message, Credentials, SendOptions) - Constructor for class rice.pastry.routing.RouteMessage

Constructor.

RouteMessage(NodeHandle, Message, Credentials, SendOptions, Address) - Constructor for class rice.pastry.routing.RouteMessage

Constructor.

RouteMessage(Id, Message, Credentials, Address) - Constructor for class rice.pastry.routing.RouteMessage

Constructor.

RouteMessage(Id, Message, Credentials, SendOptions, Address) - Constructor for class rice.pastry.routing.RouteMessage

Constructor.

RouteMessage(Id, Message, NodeHandle, Address) - Constructor for class rice.pastry.routing.RouteMessage

Constructor.

RouteProtocolAddress - class rice.pastry.routing.RouteProtocolAddress.

The address of the route protocol at a pastry node.

RouteProtocolAddress() - Constructor for class rice.pastry.routing.RouteProtocolAddress

Constructor.

RouteRowRequestMessage - class rice.pastry.wire.messaging.socket.RouteRowRequestMessage.

Message which represents a request to get the leafset from the remote node.

RouteRowRequestMessage(int) - Constructor for class rice.pastry.wire.messaging.socket.RouteRowRequestMessage

Constructor

RouteRowResponseMessage - class rice.pastry.wire.messaging.socket.RouteRowResponseMessage.

A response message to a RouteRowRequestMessage, containing the remote node's routerow.

RouteRowResponseMessage(RouteSet[]) - Constructor for class rice.pastry.wire.messaging.socket.RouteRowResponseMessage

Constructor

RouteSet - class rice.pastry.routing.RouteSet.

A set of nodes typically stored in the routing table.

RouteSet(int) - Constructor for class rice.pastry.routing.RouteSet

Constructor.

RouterAddress - class rice.pastry.routing.RouterAddress.

The address of the router at a pastry node.

RouterAddress() - Constructor for class rice.pastry.routing.RouterAddress

Constructor.

RoutingTable - class rice.pastry.routing.RoutingTable.

The Pastry routing table.

RoutingTable(NodeHandle, int) - Constructor for class rice.pastry.routing.RoutingTable

Constructor.

rFactor - Variable in class rice.rm.RMImpl

rFactor stands for the number of additional replicas for an object.

rFactor - Static variable in class rice.rm.testing.RMRegrTestApp

random - Variable in class rice.pastry.testing.LeafSetTest

range(NodeHandle, int, Id) - Method in interface rice.p2p.commonapi.Endpoint

This operation provides information about ranges of keys for which the node is currently a rank-root.

range(NodeHandle, int, Id, boolean) - Method in interface rice.p2p.commonapi.Endpoint

This operation provides information about ranges of keys for which the node is currently a rank-root.

range(NodeHandle, int, Id, boolean) - Method in class rice.pastry.client.CommonAPIAppl

This method provides information about ranges of keys for which the node n is currently a r-root.

range(NodeHandle, int, Id) - Method in class rice.pastry.client.CommonAPIAppl

This method provides information about ranges of keys for which the node n is currently a r-root.

range(NodeHandle, int, Id, boolean) - Method in class rice.pastry.commonapi.PastryEndpoint

This method provides information about ranges of keys for which the node n is currently a r-root.

range(NodeHandle, int, Id) - Method in class rice.pastry.commonapi.PastryEndpoint

This method provides information about ranges of keys for which the node n is currently a r-root.

range(NodeHandle, int) - Method in class rice.pastry.leafset.LeafSet

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<=irange(NodeHandle, int, boolean) - Method in class rice.pastry.leafset.LeafSet

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<=iranges - Variable in class rice.p2p.replication.messaging.RequestMessage

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

Specified by the SelectionKeyHandler interface - is called when there is a datagram ready to be read.

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

Method which is called when the key becomes readable.

read(SocketChannel) - Method in class rice.pastry.wire.SocketChannelReader

Method which is to be called when there is data available on the specified SocketChannel.

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

Specified by the SelectionKeyHandler interface - is called whenever a key has data available.

read(SelectionKey) - Method in class rice.pastry.wire.StaleSKH

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

Called by the socket manager whenever there is data to be read from this node handle's remote node.

receive(Object) - Method in class rice.p2p.past.testing.PastRegrTest.TestCommand

receive(Object) - Method in class rice.p2p.past.testing.PastRegrTest.TestExceptionCommand

receive(Object) - Method in class rice.past.testing.DistPASTRegrTest.TestCommand

Deprecated.

receiveException(Exception) - Method in class rice.Continuation.ExternalContinuation

receiveException(Exception) - Method in class rice.Continuation.ListenerContinuation

Called when an execption occured as a result of the previous command.

receiveException(Exception) - Method in class rice.Continuation.StandardContinuation

Called when an execption occured as a result of the previous command.

receiveException(Exception) - Method in interface rice.Continuation

Called when an execption occured as a result of the previous command.

receiveException(Exception) - Method in class rice.p2p.past.messaging.ContinuationMessage

Method which builds a response for this message, using the provided exception, which was thrown

receiveException(Exception) - Method in class rice.p2p.past.testing.PastRegrTest.TestCommand

receiveException(Exception) - Method in class rice.p2p.past.testing.PastRegrTest.TestExceptionCommand

receiveException(Exception) - Method in class rice.past.testing.DistPASTRegrTest.TestCommand

Deprecated.

receiveMessage(Message) - Method in class rice.pastry.PastryNode

message receiver interface.

receiveMessage(Message) - Method in class rice.pastry.client.CommonAPIAppl

Called by pastry to deliver a message to this client.

receiveMessage(Message) - Method in class rice.pastry.client.PastryAppl

Called by pastry to deliver a message to this client.

receiveMessage(Message) - Method in class rice.pastry.commonapi.PastryEndpoint

Called by pastry to deliver a message to this client.

receiveMessage(Message) - Method in class rice.pastry.direct.DirectNodeHandle

DESCRIBE THE METHOD

receiveMessage(Message) - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Called to send a message to the node corresponding to this handle.

receiveMessage(Message) - Method in interface rice.pastry.messaging.MessageReceiver

Passes a message along to entity which is this message receiver.

receiveMessage(Message) - Method in class rice.pastry.standard.StandardJoinProtocol

Receives a message from the outside world.

receiveMessage(Message) - Method in class rice.pastry.standard.StandardLeafSetProtocol

Receives messages.

receiveMessage(Message) - Method in class rice.pastry.standard.StandardRouteSetProtocol

Receives a message.

receiveMessage(Message) - Method in class rice.pastry.standard.StandardRouter

Receive a message from a remote node.

receiveMessage(Message) - Method in class rice.pastry.testing.LeafSetTest.TestNodeHandle

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

Called by Scribe when a multicast message arrives.

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

up-call invoked by scribe when a publish message is 'delivered'.

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

up-call invoked by scribe when a publish message is 'delivered'.

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

up-call invoked by scribe when a publish message is 'delivered'.

receiveMessageImpl(Message) - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Called to send a message to the node corresponding to this handle.

receiveMessageImpl(Message) - Method in class rice.pastry.rmi.RMINodeHandle

Called to send a message to the node corresponding to this handle.

receiveMessageImpl(Message) - Method in class rice.pastry.wire.WireNodeHandle

Called to send a message to the node corresponding to this handle.

receiveResult(Object) - Method in class rice.Continuation.ExternalContinuation

receiveResult(Object) - Method in class rice.Continuation.ListenerContinuation

Called when a previously requested result is now availble.

receiveResult(Object) - Method in interface rice.Continuation

Called when a previously requested result is now availble.

receiveResult(Object) - Method in class rice.p2p.past.messaging.ContinuationMessage

Method which builds a response for this message, using the provided object as a result.

receiveResult(Object) - Method in class rice.p2p.past.testing.PastRegrTest.TestCommand

receiveResult(Object) - Method in class rice.p2p.past.testing.PastRegrTest.TestExceptionCommand

receiveResult(Object) - Method in class rice.past.testing.DistPASTRegrTest.TestCommand

Deprecated.

receiveRouteMessage(RouteMessage) - Method in class rice.pastry.standard.StandardRouter

Receive and process a route message.

receiveSocketMessage(SocketCommandMessage) - Method in class rice.pastry.wire.WireNodeHandle

Method which is called when a SocketCommandMessage comes across an open socket for this node handle.

received - Variable in class rice.pastry.wire.testing.WireFileProcessor

receivedAck(AcknowledgementMessage) - Method in class rice.pastry.wire.DatagramTransmissionManager

Callback mechanism designed to be called when an ack packet is received.

receivedPrefix - Static variable in class rice.pastry.wire.testing.WireFileProcessor

refresh(Id) - Method in class rice.rm.testing.RMRegrTestApp

refreshFreq - Static variable in class rice.rm.testing.DistRMRegrTestApp

refreshStart - Static variable in class rice.rm.testing.DistRMRegrTestApp

registerApp(PastryAppl) - Method in class rice.pastry.PastryNode

Registers an application with this pastry node.

registerApp(IScribeApp) - Method in interface rice.scribe.IScribe

Registers the IScribeApp to the Scribe substrate.

registerApp(IScribeApp) - Method in class rice.scribe.Scribe

Registers the IScribeApp to the Scribe substrate.

registerApplication(Application, String) - Method in interface rice.p2p.commonapi.Node

This returns a VirtualizedNode specific to the given application and instance name to the application, which the application can then use in order to send an receive messages.

registerApplication(Application, String) - Method in class rice.pastry.PastryNode

This returns a VirtualizedNode specific to the given application and instance name to the application, which the application can then use in order to send an receive messages.

registerForWakeup(NeedsWakeUp) - Method in class rice.pastry.wire.SelectorManager

required to register all objects that need a routine wakeup call on the Selector thread.

registerKey(Id) - Method in interface rice.rm.RM

Called by client(RMClient) to notify the RM substrate of the presence of a key corresponding to a object that was 'recently' inserted at itself.

registerKey(Id) - Method in class rice.rm.RMImpl

Called by client(RMClient) to notify the RM substrate of the presence of a key corresponding to a object that was 'recently' inserted at itself.

registerNodeId(DirectNodeHandle) - Method in class rice.pastry.direct.EuclideanNetwork

register a new node

registerNodeId(DirectNodeHandle) - Method in interface rice.pastry.direct.NetworkSimulator

Registers a node handle with the simulator.

registerNodeId(DirectNodeHandle) - Method in class rice.pastry.direct.SphereNetwork

register a new node

registerReceiver(Credentials, Address, MessageReceiver) - Method in class rice.pastry.PastryNode

Registers a message receiver with this Pastry node.

registerReceiver(Credentials, Address, MessageReceiver) - Method in class rice.pastry.client.PastryAppl

Registers a message receiver with the pastry node.

registerReceiver(Address, MessageReceiver) - Method in class rice.pastry.messaging.MessageDispatch

Registers a receiver with the mail service.

registerScribeObserver(IScribeObserver) - Method in interface rice.scribe.IScribe

Registers the application that implements the IScribeObserver interface.

registerScribeObserver(IScribeObserver) - Method in class rice.scribe.Scribe

Registers the application that implements the IScribeObserver interface.

registerSocketChannel(SocketChannel, String) - Static method in class rice.pastry.wire.Wire

registerapp(PastryNode, RegrTestApp) - Method in class rice.pastry.testing.DirectPastryRegrTest

wire protocol specific handling of the application object e.g., RMI may launch a new thread

registerapp(PastryNode, RegrTestApp) - Method in class rice.pastry.testing.DistPastryRegrTest

wire protocol specific handling of the application object e.g., RMI may launch a new thread

registerapp(PastryNode, RegrTestApp) - Method in class rice.pastry.testing.PastryRegrTest

wire protocol specific handling of the application object e.g., RMI may launch a new thread

releaseFileDescriptor() - Static method in class rice.pastry.wire.Wire

releaseFileDescriptors(int) - Static method in class rice.pastry.wire.Wire

releaseingFileDescriptor() - Static method in class rice.pastry.wire.Wire

remote - Variable in class rice.pastry.wire.testing.MessageDigest

remoteReceiveMessage(Message, NodeId) - Method in class rice.pastry.rmi.RMIPastryNode

Proxies to the local node to accept a message.

remoteReceiveMessage(Message, NodeId) - Method in interface rice.pastry.rmi.RMIRemoteNodeI

remove(Id, Continuation) - Method in class rice.p2p.past.PastImpl

This upcall is to notify the client that the given id can be safely removed from the storage.

remove(Id, Continuation) - Method in interface rice.p2p.replication.manager.ReplicationManagerClient

This upcall is to notify the client that the given id can be safely removed from the storage.

remove(Id, Continuation) - Method in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest.TestReplicationManagerClient

remove(NodeHandle) - Method in class rice.p2p.scribe.messaging.AnycastMessage

Removes the node handle from the to visit and visited lists

remove(NodeId) - Method in class rice.pastry.NodeSet

Removes a node id and its handle from the set.

remove(NodeHandle) - Method in class rice.pastry.NodeSet

remove a member

remove(int) - Method in class rice.pastry.NodeSet

remove a member at a given position

remove(NodeId) - Method in interface rice.pastry.NodeSetI

Removes a node id and its handle from the set.

remove(NodeId) - Method in class rice.pastry.leafset.LeafSet

Removes a node id and its handle from the set.

remove(NodeId) - Method in class rice.pastry.leafset.SimilarSet

Removes a node id and its handle from the set.

remove(int) - Method in class rice.pastry.leafset.SimilarSet

Removes a node id and its handle from the set.

remove(NodeId) - Method in class rice.pastry.routing.RouteSet

Removes a node from a set.

remove(NodeId) - Method in class rice.pastry.routing.RoutingTable

Removes a node id from the table.

remove(Id) - Method in class rice.rm.testing.RMRegrTestApp

removeChild(Topic, NodeHandle) - Method in interface rice.p2p.scribe.Scribe

Removes a child from the given topic

removeChild(NodeHandle) - Method in class rice.p2p.scribe.ScribeImpl.TopicManager

DESCRIBE THE METHOD

removeChild(Topic, NodeHandle) - Method in class rice.p2p.scribe.ScribeImpl

Removes a child from the given topic

removeChild(Topic, NodeHandle, boolean) - Method in class rice.p2p.scribe.ScribeImpl

Removes a child from the given topic

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

Removes a node as a child from the children table for a topic.

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

Removes a node as a child from the children table for a topic.

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

Removes a node from the Set of children in this topic's multicast subtree rooted at this node

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

Removes a child for a topic from the distinctChildrenTable.

removeClient(ScribeClient) - Method in class rice.p2p.scribe.ScribeImpl.TopicManager

DESCRIBE THE METHOD

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

Removes this topic reference on the current Scribe node.

removeHandle(Id) - Method in interface rice.p2p.commonapi.NodeHandleSet

Removes a node id and its handle from the set.

removeHandle(Id) - Method in class rice.pastry.NodeSet

Removes a node id and its handle from the set.

removeHandle(Id) - Method in class rice.pastry.leafset.SimilarSet

Removes a node id and its handle from the set.

removeHandle(Id) - Method in class rice.pastry.routing.RouteSet

Removes a node id and its handle from the set.

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

remove a member

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

remove a member

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

remove a member

removeOpenSocketsIfNeeded() - Method in class rice.pastry.wire.SocketManager

called routinely to recycle sockets that haven't recently been used

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

Removes a parent for a topic fromthe distinctParentTable.

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

Used to remove entries to the m_pendingEvents hashtable

removePendingObject(Id) - Method in class rice.rm.testing.RMRegrTestApp

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

Used to remove a pending range to the m_pendingRanges hashtable

removeWireLimitationListener(WireLimitatioinListener) - Static method in class rice.pastry.wire.Wire

replicaManager - Variable in class rice.p2p.past.PastImpl

replicaSet(Id, int) - Method in interface rice.p2p.commonapi.Endpoint

This methods returns an ordered set of nodehandles on which replicas of an object with a given id can be stored.

replicaSet(Id, int) - Method in class rice.pastry.client.CommonAPIAppl

This method returns an ordered set of nodehandles on which replicas of the object with key can be stored.

replicaSet(Id, int) - Method in class rice.pastry.commonapi.PastryEndpoint

This method returns an ordered set of nodehandles on which replicas of the object with key can be stored.

replicaSet(Id, int) - Method in class rice.pastry.leafset.LeafSet

compute an ordered set of nodes, in order of numerical closeness to a given key

replicate(Id) - Method in class rice.rm.testing.RMRegrTestApp

Called by the application when it needs to replicate an object into k nodes closest to the object key.

replicateSuccess(Id, boolean) - Method in class rice.rm.testing.RMRegrTestApp

replication - Variable in class rice.p2p.replication.manager.ReplicationManagerImpl

The replication used by the manager

replicationFactor - Variable in class rice.p2p.past.PastImpl

replicationFactor - Variable in class rice.p2p.replication.ReplicationImpl

The replication factor for this replication

replications - Variable in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

the replication impls in the ring

replications - Variable in class rice.p2p.replication.testing.ReplicationRegrTest

the replication impls in the ring

requireShortestPath() - Method in class rice.pastry.routing.SendOptions

Returns whether it is required to go to the strictly nearest known node with appropriate node id.

reset() - Method in class rice.pastry.wire.SocketChannelReader

Resets this input stream so that it is ready to read another object off of the queue.

reset(SocketCommandMessage) - Method in class rice.pastry.wire.SocketChannelWriter

Resets the SocketChannelWriter, by clearing both the buffer and the queue.

resetAckNumber(NodeId) - Method in class rice.pastry.wire.DatagramManager

Designed to be called by a node handle when a socket is open in order to reset the seqence number of UDP.

resetAckNumber(NodeId) - Method in class rice.pastry.wire.DatagramTransmissionManager

Resets the sequence number for the specified node

resourcesFine(int, int) - Method in interface rice.pastry.wire.WireLimitatioinListener

resourcesRunningShort(int, int) - Method in interface rice.pastry.wire.WireLimitatioinListener

response - Variable in class rice.p2p.past.messaging.ContinuationMessage

result - Variable in class rice.Continuation.ExternalContinuation

returnHandle() - Method in class rice.pastry.leafset.RequestLeafSet

The return handle for the message

returnHandle() - Method in class rice.pastry.routing.RequestRouteRow

The return handle for the message

returnResponse(Continuation) - Method in class rice.p2p.past.messaging.CacheMessage

Method by which this message is supposed to return it's response.

returnResponse(Continuation) - Method in class rice.p2p.past.messaging.ContinuationMessage

Method by which this message is supposed to return it's response.

returnResponse(Continuation) - Method in class rice.p2p.past.messaging.MessageLostMessage

Method by which this message is supposed to return it's response - in this case, it lets the continuation know that a the message was lost via the receiveException method.

returnResponse(Continuation) - Method in class rice.p2p.past.messaging.PastMessage

Method by which this message is supposed to return it's response.

rice - package rice

rice.p2p.commonapi - package rice.p2p.commonapi

rice.p2p.commonapi.testing - package rice.p2p.commonapi.testing

rice.p2p.past - package rice.p2p.past

rice.p2p.past.messaging - package rice.p2p.past.messaging

rice.p2p.past.testing - package rice.p2p.past.testing

rice.p2p.replication - package rice.p2p.replication

rice.p2p.replication.manager - package rice.p2p.replication.manager

rice.p2p.replication.manager.messaging - package rice.p2p.replication.manager.messaging

rice.p2p.replication.manager.testing - package rice.p2p.replication.manager.testing

rice.p2p.replication.messaging - package rice.p2p.replication.messaging

rice.p2p.replication.testing - package rice.p2p.replication.testing

rice.p2p.scribe - package rice.p2p.scribe

rice.p2p.scribe.messaging - package rice.p2p.scribe.messaging

rice.p2p.scribe.testing - package rice.p2p.scribe.testing

rice.p2p.splitstream - package rice.p2p.splitstream

rice.p2p.splitstream.testing - package rice.p2p.splitstream.testing

rice.past - package rice.past

rice.past.messaging - package rice.past.messaging

rice.past.testing - package rice.past.testing

rice.pastry - package rice.pastry

rice.pastry.client - package rice.pastry.client

rice.pastry.commonapi - package rice.pastry.commonapi

rice.pastry.direct - package rice.pastry.direct

rice.pastry.dist - package rice.pastry.dist

rice.pastry.join - package rice.pastry.join

rice.pastry.leafset - package rice.pastry.leafset

rice.pastry.messaging - package rice.pastry.messaging

rice.pastry.rmi - package rice.pastry.rmi

rice.pastry.routing - package rice.pastry.routing

rice.pastry.security - package rice.pastry.security

rice.pastry.standard - package rice.pastry.standard

rice.pastry.testing - package rice.pastry.testing

rice.pastry.wire - package rice.pastry.wire

rice.pastry.wire.exception - package rice.pastry.wire.exception

rice.pastry.wire.messaging.datagram - package rice.pastry.wire.messaging.datagram

rice.pastry.wire.messaging.socket - package rice.pastry.wire.messaging.socket

rice.pastry.wire.testing - package rice.pastry.wire.testing

rice.persistence - package rice.persistence

rice.persistence.testing - package rice.persistence.testing

rice.rm - package rice.rm

rice.rm.messaging - package rice.rm.messaging

rice.rm.testing - package rice.rm.testing

rice.scribe - package rice.scribe

rice.scribe.maintenance - package rice.scribe.maintenance

rice.scribe.messaging - package rice.scribe.messaging

rice.scribe.security - package rice.scribe.security

rice.scribe.testing - package rice.scribe.testing

rmClients - Variable in class rice.rm.testing.DirectRMRegrTest

rmIsReady(RM) - Method in class rice.past.PASTServiceImpl

Deprecated. This upcall is simply to denote that the underlying replica manager (rm) is ready.

rmIsReady(RM) - Method in interface rice.rm.RMClient

This upcall is simply to denote that the underlying replica manager (rm) is ready.

rmIsReady(RM) - Method in class rice.rm.testing.DistRMRegrTestApp

rmIsReady(RM) - Method in class rice.rm.testing.RMRegrTestApp

rmiRegistry - Static variable in class rice.pastry.rmi.RMIPastryNodeFactory

Instance of RMI registry ever-created when using this factory.

rng - Variable in class rice.p2p.past.testing.PastRegrTest

rng - Variable in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

random number generator

rng - Variable in class rice.p2p.replication.testing.ReplicationRegrTest

random number generator

rng - Variable in class rice.p2p.scribe.testing.ScribeRegrTest

DESCRIBE THE FIELD

rng - Variable in class rice.p2p.splitstream.testing.SplitStreamRegrTest

DESCRIBE THE FIELD

rng - Variable in class rice.pastry.testing.DistHelloWorldMultiThread

rootApp(NodeId) - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

This returns the index of the application that is currently the root for the topic's multicast tree.

route(Id, Message, NodeHandle) - Method in interface rice.p2p.commonapi.Endpoint

This method makes an attempt to route the message to the root of the given id.

route(Id, Message, NodeHandle) - Method in class rice.pastry.client.CommonAPIAppl

This operation forwards a message towards the root of key.

route(Id, Message, NodeHandle) - Method in class rice.pastry.commonapi.PastryEndpoint

This operation forwards a message towards the root of key.

routeMessage(NodeId) - Method in class rice.pastry.routing.RouteMessage

Routes the messages if the next hop has been set up.

routeMsg(Id, Message, Credentials, SendOptions) - Method in class rice.pastry.client.PastryAppl

Routes a message to the live node D with nodeId numerically closest to key (at the time of delivery).

routeMsgDirect(NodeHandle, Message, Credentials, SendOptions) - Method in class rice.pastry.client.PastryAppl

Sends a message to the Pastry node identified by dest.

routeSetChange(NodeHandle, boolean) - Method in class rice.pastry.client.PastryAppl

Called by pastry when the route set changes.

routeSetChange(NodeHandle, boolean) - Method in class rice.pastry.testing.HelloWorldApp

Invoked upon change to routing table.

routeSetChange(NodeHandle, boolean) - Method in class rice.pastry.testing.HelloWorldAppMultiThread

Invoked upon change to routing table.

routeSetChange(NodeHandle, boolean) - Method in class rice.pastry.testing.Ping

routeSetChange(NodeHandle, boolean) - Method in class rice.pastry.testing.PingClient

routeSetChange(NodeHandle, boolean) - Method in class rice.pastry.testing.RegrTestApp

routeSetMaintFreq - Variable in class rice.pastry.dist.DistPastryNode

row - Variable in class rice.pastry.wire.messaging.socket.RouteRowRequestMessage

DESCRIBE THE FIELD

run() - Method in class rice.pastry.ScheduledMessage

deliver the message

run() - Method in class rice.pastry.testing.ClosestRegrTest

initializes the network and prepares for testing

run() - Method in class rice.pastry.wire.SelectorManager

This method starts the datagram manager listening for incoming datagrams.

runInsertChecks() - Method in class rice.past.testing.DistPASTRegrTest.TestPASTFunctions

Deprecated. Checks that a file is stored on the right number of nodes after being inserted.

runInsertTests() - Method in class rice.past.testing.DistPASTRegrTest.TestPASTFunctions

Deprecated. Checks that a file is not available until it is inserted, and that it can only be inserted once.

runMaintenance() - Method in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

runMaintenance() - Method in class rice.p2p.replication.testing.ReplicationRegrTest

runReclaimTests() - Method in class rice.past.testing.DistPASTRegrTest.TestPASTFunctions

Deprecated. Checks that deleting a file works.

runTest() - Method in class rice.p2p.commonapi.testing.CommonAPITest

Method which should run the test - this is called once all of the nodes have been created and are ready.

runTest() - Method in class rice.p2p.past.testing.PastRegrTest

Method which should run the test - this is called once all of the nodes have been created and are ready.

runTest() - Method in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

Method which should run the test - this is called once all of the nodes have been created and are ready.

runTest() - Method in class rice.p2p.replication.testing.ReplicationRegrTest

Method which should run the test - this is called once all of the nodes have been created and are ready.

runTest() - Method in class rice.p2p.scribe.testing.ScribeRegrTest

Method which should run the test - this is called once all of the nodes have been created and are ready.

runTest() - Method in class rice.p2p.splitstream.testing.SplitStreamRegrTest

Method which should run the test - this is called once all of the nodes have been created and are ready.

runTests() - Method in class rice.past.testing.DistPASTRegrTest

Deprecated. Initializes and runs all regression tests.

S

SELECT_WAIT_TIME - Variable in class rice.pastry.wire.SelectorManager

the amount of time to wait during a selection (ms)

SIMULATOR - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

SIMULATOR_EUCLIDEAN - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

SIMULATOR_SPHERE - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

SOCKET_BUFFER_SIZE - Static variable in class rice.pastry.wire.WireNodeHandle

the size of the "receive" buffer for the socket

SPLITFACTOR - Static variable in class rice.rm.RMImpl

This value represents the splitting factor by which a range is split into in the Keys Exchange Protocol.

STAGE_FINAL - Static variable in class rice.p2p.splitstream.SplitStreamSubscribeContent

The final stage of the join process

STAGE_NON_FINAL - Static variable in class rice.p2p.splitstream.SplitStreamSubscribeContent

The first stage of the join process

STATE_NOTHING - Variable in class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

The set of possible states we can be in

STATE_SLEEPING - Variable in class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

STATE_USING_TCP - Static variable in class rice.pastry.wire.WireNodeHandle

using TCP

STATE_USING_UDP - Static variable in class rice.pastry.wire.WireNodeHandle

using UDP

STATE_USING_UDP_WAITING_FOR_TCP_DISCONNECT - Static variable in class rice.pastry.wire.WireNodeHandle

waiting to disconnect from TCP from remote side

STATE_USING_UDP_WAITING_TO_DISCONNECT - Static variable in class rice.pastry.wire.WireNodeHandle

waiting to disconnect

STATE_WAITING - Variable in class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

STRIPE_BASE - Static variable in class rice.p2p.splitstream.Channel

The default number of stripes to create

SUCCESS - Static variable in class rice.p2p.commonapi.testing.CommonAPITest

SUCCESS - Static variable in class rice.persistence.testing.Test

ScheduledMessage - class rice.pastry.ScheduledMessage.

A class that represents scheduled message events

ScheduledMessage(PastryNode, Message) - Constructor for class rice.pastry.ScheduledMessage

Constructor

Scribe - interface rice.p2p.scribe.Scribe.

Scribe - class rice.scribe.Scribe.

Scribe(PastryNode, Credentials) - Constructor for class rice.scribe.Scribe

Constructor.

ScribeClient - interface rice.p2p.scribe.ScribeClient.

ScribeContent - interface rice.p2p.scribe.ScribeContent.

ScribeImpl - class rice.p2p.scribe.ScribeImpl.

ScribeImpl(Node, String) - Constructor for class rice.p2p.scribe.ScribeImpl

Constructor for Scribe, using the default policy.

ScribeImpl(Node, ScribePolicy, String) - Constructor for class rice.p2p.scribe.ScribeImpl

Constructor for Scribe

ScribeImpl.TopicManager - class rice.p2p.scribe.ScribeImpl.TopicManager.

Class which keeps track of a given topic

ScribeImpl.TopicManager(Topic, ScribeClient) - Constructor for class rice.p2p.scribe.ScribeImpl.TopicManager

Constructor for TopicManager.

ScribeImpl.TopicManager(Topic, NodeHandle) - Constructor for class rice.p2p.scribe.ScribeImpl.TopicManager

Constructor for TopicManager.

ScribeImpl.TopicManager(Topic) - Constructor for class rice.p2p.scribe.ScribeImpl.TopicManager

Constructor for TopicManager.

ScribeMaintainer - class rice.scribe.maintenance.ScribeMaintainer.

This is responsible for all the Scribe tree maintainance activities corresponding to all the topics in this local node.

ScribeMaintainer(Scribe) - Constructor for class rice.scribe.maintenance.ScribeMaintainer

ScribeMessage - class rice.p2p.scribe.messaging.ScribeMessage.

ScribeMessage(NodeHandle, Topic) - Constructor for class rice.p2p.scribe.messaging.ScribeMessage

Constructor which takes a unique integer Id

ScribeMessage - class rice.scribe.messaging.ScribeMessage.

This is an abstract implementation of a Scribe message object.

ScribeMessage(Address, NodeHandle, NodeId, Credentials) - Constructor for class rice.scribe.messaging.ScribeMessage

Constructor

ScribePolicy - interface rice.p2p.scribe.ScribePolicy.

ScribePolicy.DefaultScribePolicy - class rice.p2p.scribe.ScribePolicy.DefaultScribePolicy.

The default policy for Scribe, which always allows new children to join and adds children in the order in which they are provided, implicitly providing a depth-first search.

ScribePolicy.DefaultScribePolicy() - Constructor for class rice.p2p.scribe.ScribePolicy.DefaultScribePolicy

ScribePolicy.LimitedScribePolicy - class rice.p2p.scribe.ScribePolicy.LimitedScribePolicy.

An optional policy for Scribe, which allows up to a specified number of children per topic.

ScribePolicy.LimitedScribePolicy(int) - Constructor for class rice.p2p.scribe.ScribePolicy.LimitedScribePolicy

Construtor which takes a maximum number

ScribeRegrTest - class rice.p2p.scribe.testing.ScribeRegrTest.

ScribeRegrTest() - Constructor for class rice.p2p.scribe.testing.ScribeRegrTest

Constructor which sets up all local variables

ScribeRegrTest.TestRouteMessage - class rice.p2p.scribe.testing.ScribeRegrTest.TestRouteMessage.

Utility class which simulates a route message

ScribeRegrTest.TestRouteMessage(Id, NodeHandle, Message) - Constructor for class rice.p2p.scribe.testing.ScribeRegrTest.TestRouteMessage

Constructor for TestRouteMessage.

ScribeRegrTest.TestScribeClient - class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient.

DESCRIBE THE CLASS

ScribeRegrTest.TestScribeClient(ScribeImpl, Topic, int) - Constructor for class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

Constructor for TestScribeClient.

ScribeRegrTest.TestScribeContent - class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeContent.

Utility class for past content objects

ScribeRegrTest.TestScribeContent(Topic, int) - Constructor for class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeContent

Constructor for TestScribeContent.

ScribeRegrTest.TestScribePolicy - class rice.p2p.scribe.testing.ScribeRegrTest.TestScribePolicy.

ScribeRegrTest.TestScribePolicy(Scribe) - Constructor for class rice.p2p.scribe.testing.ScribeRegrTest.TestScribePolicy

SelectionKeyHandler - interface rice.pastry.wire.SelectionKeyHandler.

This interface is designed to be a callback mechanism from the SelectorManager.

SelectorManager - class rice.pastry.wire.SelectorManager.

This class is the class which handles the selector, and listens for activity.

SelectorManager(WirePastryNode) - Constructor for class rice.pastry.wire.SelectorManager

Constructor.

SendOptions - class rice.pastry.routing.SendOptions.

This is the options for a client to send messages.

SendOptions() - Constructor for class rice.pastry.routing.SendOptions

Constructor.

SendOptions(boolean, boolean, boolean, boolean) - Constructor for class rice.pastry.routing.SendOptions

Constructor.

SerializationException - exception rice.pastry.wire.exception.SerializationException.

Class which represents an exception occuring during the serialization of a Pastry message.

SerializationException(String) - Constructor for class rice.pastry.wire.exception.SerializationException

Constructs an SerializationException with a given message

SimilarSet - class rice.pastry.leafset.SimilarSet.

A set of nodes, ordered by numerical distance of their nodeId from the local nodeId

SimilarSet(NodeHandle, int, boolean) - Constructor for class rice.pastry.leafset.SimilarSet

Constructor.

SinglePingTest - class rice.pastry.testing.SinglePingTest.

SinglePingTest A performance test suite for pastry.

SinglePingTest(TestRecord) - Constructor for class rice.pastry.testing.SinglePingTest

SocketChannelReader - class rice.pastry.wire.SocketChannelReader.

Class which serves as an "reader" for messages sent across the wire via the Pastry socket protocol.

SocketChannelReader(WirePastryNode, WireNodeHandle) - Constructor for class rice.pastry.wire.SocketChannelReader

Constructor which creates this SocketChannelReader and the WirePastryNode.

SocketChannelWriter - class rice.pastry.wire.SocketChannelWriter.

Class which serves as an "writer" for all of the messages sent across the wire in Pastry.

SocketChannelWriter(WirePastryNode, SocketCommandMessage, SelectionKey) - Constructor for class rice.pastry.wire.SocketChannelWriter

Constructor which creates this SocketChannelWriter with a pastry node and an object to write out.

SocketChannelWriter(WirePastryNode, SocketCommandMessage, SelectionKey, WireNodeHandle) - Constructor for class rice.pastry.wire.SocketChannelWriter

Constructor which creates this SocketChannelWriter with a pastry node and an object to write out.

SocketCommandMessage - class rice.pastry.wire.messaging.socket.SocketCommandMessage.

Class which represents a "command" message sent across the socket-based pastry protocol.

SocketCommandMessage() - Constructor for class rice.pastry.wire.messaging.socket.SocketCommandMessage

Constructor for SocketCommandMessage.

SocketManager - class rice.pastry.wire.SocketManager.

Class which maintains all outgoing open sockets.

SocketManager(WirePastryNode, int, Selector) - Constructor for class rice.pastry.wire.SocketManager

Constructs a new SocketManager.

SocketMessage - class rice.pastry.wire.messaging.socket.SocketMessage.

Class which abstracts out a message sent across the socket-based pastry protocol.

SocketMessage() - Constructor for class rice.pastry.wire.messaging.socket.SocketMessage

Constructor for SocketMessage.

SocketTransportMessage - class rice.pastry.wire.messaging.socket.SocketTransportMessage.

Class which represents a wrapper message sent across the socket-based protocol - it has another message inside of it.

SocketTransportMessage(Object, NodeId) - Constructor for class rice.pastry.wire.messaging.socket.SocketTransportMessage

Constructs a new message wrapping another object.

SphereNetwork - class rice.pastry.direct.SphereNetwork.

Sphere network topology and idealized node life.

SphereNetwork() - Constructor for class rice.pastry.direct.SphereNetwork

Constructor.

SplitStream - interface rice.p2p.splitstream.SplitStream.

The interface defines the methods that a splitStream object must implement.

SplitStreamClient - interface rice.p2p.splitstream.SplitStreamClient.

This interface allows an application running on top of SplitStream to be notified of events.

SplitStreamContent - class rice.p2p.splitstream.SplitStreamContent.

This represents data sent through scribe for splitstream

SplitStreamContent(byte[]) - Constructor for class rice.p2p.splitstream.SplitStreamContent

Constructor taking in a byte[]

SplitStreamImpl - class rice.p2p.splitstream.SplitStreamImpl.

This is the implementing class of the ISplitStream interface.

SplitStreamImpl(Node, String) - Constructor for class rice.p2p.splitstream.SplitStreamImpl

The constructor for building the splitStream object which internally creates it's own Scribe.

SplitStreamRegrTest - class rice.p2p.splitstream.testing.SplitStreamRegrTest.

SplitStreamRegrTest() - Constructor for class rice.p2p.splitstream.testing.SplitStreamRegrTest

Constructor which sets up all local variables

SplitStreamScribePolicy - class rice.p2p.splitstream.SplitStreamScribePolicy.

This class represents SplitStream's policy for Scribe, which only allows children according to the bandwidth manager and makes anycasts first traverse all nodes who have the stripe in question as their primary stripe, and then the nodes who do not.

SplitStreamScribePolicy(Scribe, SplitStream) - Constructor for class rice.p2p.splitstream.SplitStreamScribePolicy

Constructor which takes a splitStream object

SplitStreamSubscribeContent - class rice.p2p.splitstream.SplitStreamSubscribeContent.

This represents data sent through scribe for splitstream during a subscribe

SplitStreamSubscribeContent(int) - Constructor for class rice.p2p.splitstream.SplitStreamSubscribeContent

Constructor taking in a byte[]

StaleSKH - class rice.pastry.wire.StaleSKH.

The purpose of this class is to be able to have a key in the SelectorManager without an attachment while it is pending being attached.

StaleSKH() - Constructor for class rice.pastry.wire.StaleSKH

Constructor for StaleSKH.

StandardAddress - class rice.pastry.standard.StandardAddress.

Constructs an address for a specific class and instance name.

StandardAddress(Class, String) - Constructor for class rice.pastry.standard.StandardAddress

StandardJoinProtocol - class rice.pastry.standard.StandardJoinProtocol.

An implementation of a simple join protocol.

StandardJoinProtocol(PastryNode, NodeHandle, PastrySecurityManager, RoutingTable, LeafSet) - Constructor for class rice.pastry.standard.StandardJoinProtocol

Constructor.

StandardLeafSetProtocol - class rice.pastry.standard.StandardLeafSetProtocol.

An implementation of a simple leaf set protocol.

StandardLeafSetProtocol(PastryNode, NodeHandle, PastrySecurityManager, LeafSet, RoutingTable) - Constructor for class rice.pastry.standard.StandardLeafSetProtocol

StandardRouteSetProtocol - class rice.pastry.standard.StandardRouteSetProtocol.

An implementation of a simple route set protocol.

StandardRouteSetProtocol(NodeHandle, PastrySecurityManager, RoutingTable) - Constructor for class rice.pastry.standard.StandardRouteSetProtocol

Constructor.

StandardRouter - class rice.pastry.standard.StandardRouter.

An implementation of the standard Pastry routing algorithm.

StandardRouter(NodeHandle, RoutingTable, LeafSet, PastrySecurityManager) - Constructor for class rice.pastry.standard.StandardRouter

Constructor.

Storage - interface rice.persistence.Storage.

This interface is the abstraction of something which provides a local storage service, such as a persistence storage service or an in-memory storage service.

StorageManager - class rice.persistence.StorageManager.

This class provides both persistent and caching services to external applications.

StorageManager(IdFactory, Storage, Cache) - Constructor for class rice.persistence.StorageManager

Builds a StorageManager given a Storage object to provide storage services and a Cache object to provide caching services.

Stripe - class rice.p2p.splitstream.Stripe.

This class encapsulates all data about an individual stripe.

Stripe(StripeId, Scribe, Channel) - Constructor for class rice.p2p.splitstream.Stripe

The constructor used when creating a stripe from scratch.

StripeId - class rice.p2p.splitstream.StripeId.

This class wraps the nodeId object so we can use type checking and allow more readable and understandable code.

StripeId(Id) - Constructor for class rice.p2p.splitstream.StripeId

Constructor that takes in a nodeId and makes a StripeId

SubscribeAckMessage - class rice.p2p.scribe.messaging.SubscribeAckMessage.

SubscribeAckMessage(NodeHandle, Topic, Id[], int) - Constructor for class rice.p2p.scribe.messaging.SubscribeAckMessage

Constructor which takes a unique integer Id

SubscribeFailedMessage - class rice.p2p.scribe.messaging.SubscribeFailedMessage.

SubscribeFailedMessage(NodeHandle, Topic, int) - Constructor for class rice.p2p.scribe.messaging.SubscribeFailedMessage

Constructor which takes a unique integer Id

SubscribeLostMessage - class rice.p2p.scribe.messaging.SubscribeLostMessage.

SubscribeLostMessage(NodeHandle, Topic, int) - Constructor for class rice.p2p.scribe.messaging.SubscribeLostMessage

Constructor which takes a unique integer Id

SubscribeMessage - class rice.p2p.scribe.messaging.SubscribeMessage.

SubscribeMessage(NodeHandle, Topic, int, ScribeContent) - Constructor for class rice.p2p.scribe.messaging.SubscribeMessage

Constructor which takes a unique integer Id

SubscribeMessage(NodeHandle, Topic, Id, int, ScribeContent) - Constructor for class rice.p2p.scribe.messaging.SubscribeMessage

Constructor which takes a unique integer Id

scan(IdRange) - Method in interface rice.p2p.past.Past

Return the ids of objects stored in this instance of Past on the *local* node, with ids in a given range.

scan(IdRange) - Method in class rice.p2p.past.PastImpl

This upcall should return the set of keys that the application currently stores in this range.

scan(IdRange) - Method in interface rice.p2p.replication.ReplicationClient

This upcall should return the set of keys that the application currently stores in this range.

scan(IdRange) - Method in interface rice.p2p.replication.manager.ReplicationManagerClient

This upcall should return the set of keys that the application currently stores in this range.

scan(IdRange) - Method in class rice.p2p.replication.manager.ReplicationManagerImpl

This upcall should return the set of keys that the application currently stores in this range.

scan(IdRange) - Method in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest.TestReplicationManagerClient

scan(IdRange) - Method in class rice.p2p.replication.testing.ReplicationRegrTest.TestReplicationClient

This upcall should return the set of keys that the application currently stores in this range.

scan(IdRange) - Method in class rice.past.PASTServiceImpl

Deprecated. This upcall should return the set of keys that the application currently stores in this range.

scan(IdRange, Continuation) - Method in interface rice.persistence.Catalog

Return the objects identified by the given range of ids.

scan(IdRange) - Method in interface rice.persistence.Catalog

Return the objects identified by the given range of ids.

scan(IdRange, Continuation) - Method in class rice.persistence.LRUCache

Return the objects identified by the given range of ids.

scan(IdRange) - Method in class rice.persistence.LRUCache

Return the objects identified by the given range of ids.

scan(IdRange, Continuation) - Method in class rice.persistence.MemoryStorage

Return the objects identified by the given range of ids.

scan(IdRange) - Method in class rice.persistence.MemoryStorage

Return the objects identified by the given range of ids.

scan(IdRange, Continuation) - Method in class rice.persistence.PersistentStorage

Return the objects identified by the given range of ids.

scan(IdRange) - Method in class rice.persistence.PersistentStorage

Return the objects identified by the given range of ids.

scan(IdRange, Continuation) - Method in class rice.persistence.StorageManager

Return the objects identified by the given range of ids.

scan(IdRange) - Method in class rice.persistence.StorageManager

Return the objects identified by the given range of ids.

scan(IdRange) - Method in interface rice.rm.RMClient

This upcall should return the set of keys that the application currently stores in this range.

scan(IdRange) - Method in class rice.rm.testing.RMRegrTestApp

scheduleHB() - Method in interface rice.scribe.IScribe

Sends heartbeat messages to this local node's children for all the topics on this local scribe node.

scheduleHB() - Method in class rice.scribe.Scribe

Sends heartbeat messages to this local node's children for all the topics on this local scribe node.

scheduleHB() - Method in class rice.scribe.maintenance.ScribeMaintainer

Sends heartbeat messages to this local node's children for all the topics on this local scribe node.

scheduleHBOnAllNodes() - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

Schedule a HeartBeat event on all nodes for all topics.

scheduleMessage(Message, long) - Method in interface rice.p2p.commonapi.Endpoint

Schedules a message to be delivered to this application after the provided number of milliseconds.

scheduleMessage(Message, long, long) - Method in interface rice.p2p.commonapi.Endpoint

Schedules a message to be delivered to this application every period number of milliseconds, after delay number of miliseconds have passed.

scheduleMessage(Message, long) - Method in class rice.pastry.commonapi.PastryEndpoint

Schedules a message to be delivered to this application after the provided number of milliseconds.

scheduleMessage(Message, long, long) - Method in class rice.pastry.commonapi.PastryEndpoint

Schedules a message to be delivered to this application every period number of milliseconds, after delay number of miliseconds have passed.

scheduleMsg(Message, long) - Method in class rice.pastry.PastryNode

Schedule the specified message to be sent to the local node after a specified delay.

scheduleMsg(Message, long, long) - Method in class rice.pastry.PastryNode

Schedule the specified message for repeated fixed-delay delivery to the local node, beginning after the specified delay.

scheduleMsg(Message, long) - Method in class rice.pastry.direct.DirectPastryNode

Schedule the specified message to be sent to the local node after a specified delay.

scheduleMsg(Message, long, long) - Method in class rice.pastry.direct.DirectPastryNode

Schedule the specified message for repeated fixed-delay delivery to the local node, beginning after the specified delay.

scheduleMsg(Message, long) - Method in class rice.pastry.dist.DistPastryNode

Schedule the specified message to be sent to the local node after a specified delay.

scheduleMsg(Message, long, long) - Method in class rice.pastry.dist.DistPastryNode

Schedule the specified message for repeated fixed-delay delivery to the local node, beginning after the specified delay.

scheduleMsgAtFixedRate(Message, long, long) - Method in class rice.pastry.PastryNode

Schedule the specified message for repeated fixed-rate delivery to the local node, beginning after the specified delay.

scheduleMsgAtFixedRate(Message, long, long) - Method in class rice.pastry.direct.DirectPastryNode

Schedule the specified message for repeated fixed-rate delivery to the local node, beginning after the specified delay.

scheduleMsgAtFixedRate(Message, long, long) - Method in class rice.pastry.dist.DistPastryNode

Schedule the specified message for repeated fixed-rate delivery to the local node, beginning after the specified delay.

scheduleNext() - Method in class rice.p2p.replication.manager.ReplicationManagerImpl

Internal method which schedules the next reminder message (if it is necessary), or simply resets the active flag if there's nothing to be fetched.

scheduleTR(Topic) - Method in class rice.scribe.maintenance.ScribeMaintainer

Starts a tree repair for a particular topic in the local node

scheduleTROnAllNodes() - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

Schedule a TreeRepair event on all nodes for all the topics.

scribe - Variable in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

DESCRIBE THE FIELD

scribe - Variable in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribePolicy

scribe - Variable in class rice.p2p.splitstream.SplitStreamImpl

The scribe instance for this SplitStream Object

scribe - Variable in class rice.p2p.splitstream.SplitStreamScribePolicy

A reference to this policy's scribe object

scribe - Variable in class rice.p2p.splitstream.Stripe

The scribe object

scribeClients - Variable in class rice.scribe.testing.DirectScribeMaintenanceTest

scribeIsReady() - Method in interface rice.scribe.IScribeApp

Invoked when the underlying Scribe substrate is ready.

scribeIsReady() - Method in class rice.scribe.testing.BasicScribeRegrTestApp

scribeIsReady() - Method in class rice.scribe.testing.DirectScribeMaintenanceTestApp

scribeIsReady() - Method in class rice.scribe.testing.DistScribeRegrTestApp

scribes - Variable in class rice.p2p.scribe.testing.ScribeRegrTest

DESCRIBE THE FIELD

searchForMe - Variable in class rice.pastry.wire.testing.MessageDigest

Have MessageDigestFactory set this to true if you want to analyze these messages in the future.

sectionDone() - Method in class rice.p2p.commonapi.testing.CommonAPITest

Method which prints the end of a test section.

sectionEnd() - Method in class rice.persistence.testing.Test

sectionStart(String) - Method in class rice.p2p.commonapi.testing.CommonAPITest

Method which prints the beginning of a test section.

sectionStart(String) - Method in class rice.persistence.testing.Test

send() - Method in class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

Method which determines if a message should be sent, and if so, sends it

sendKeyRequestMessages(NodeSet, Vector) - Method in class rice.rm.RMImpl

We send RMRequestKeys messages to the the nodes in the 'set' asking for keys in the ranges specified in the 'rangeSet'.

sendMessage(PASTMessage) - Method in class rice.past.PASTServiceImpl

Deprecated. Sends a message to a remote PAST node (either a request or response).

sendMessage(Message) - Method in class rice.pastry.client.PastryAppl

Sends a message directly to the local pastry node.

sendMsg(NodeId) - Method in class rice.pastry.testing.RegrTestApp

sendPing(NodeId) - Method in class rice.pastry.testing.Ping

sendPing(NodeId) - Method in class rice.pastry.testing.PingClient

sendPings(int) - Method in class rice.pastry.testing.PastryRegrTest

Send messages among random message pairs.

sendPings(int) - Method in class rice.pastry.testing.PastryTest

sendPings(int) - Method in class rice.pastry.testing.SinglePingTest

sendRequests() - Method in class rice.p2p.replication.ReplicationImpl

This internal method sends out the request messages to all of the nodes which hold keys this node may be interested in

sendRndMsg(Random) - Method in class rice.pastry.testing.HelloWorldApp

Sends a message to a randomly chosen node.

sendRndMsg(Random) - Method in class rice.pastry.testing.HelloWorldAppMultiThread

Sends a message to a randomly chosen node.

sendRndMsg(Random, int) - Method in class rice.pastry.testing.HelloWorldAppMultiThread

Sends a message to a randomly chosen node.

sendTrace(NodeId) - Method in class rice.pastry.testing.PingClient

sendTrace(NodeId) - Method in class rice.pastry.testing.RegrTestApp

sent - Variable in class rice.pastry.wire.testing.WireFileProcessor

sentPrefix - Static variable in class rice.pastry.wire.testing.WireFileProcessor

serialize(Object) - Static method in class rice.pastry.wire.DatagramManager

Method which serializes a given object into a ByteBuffer, in order to prepare it for writing.

serialize(Object, ByteBuffer) - Static method in class rice.pastry.wire.SocketChannelWriter

Method which serializes a given object into a ByteBuffer, in order to prepare it for writing.

set - Variable in class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

The set of keys we have yet to fetch

set - Variable in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest.TestReplicationManagerClient

setAlive(NodeId, boolean) - Method in class rice.pastry.direct.EuclideanNetwork

set the liveliness of a NodeId

setAlive(NodeId, boolean) - Method in interface rice.pastry.direct.NetworkSimulator

setAlive(NodeId, boolean) - Method in class rice.pastry.direct.SphereNetwork

set the liveliness of a NodeId

setBit(int, int) - Method in class rice.pastry.Id

Sets the ith bit to a given value i = 0 is the least significant bit.

setCached() - Method in class rice.p2p.past.messaging.FetchMessage

Sets this message as having been cached.

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

Sets this message as having been cached.

setChanged() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

setContent(ScribeContent) - Method in class rice.p2p.scribe.messaging.AnycastMessage

Sets the content

setCount(int) - Method in class rice.scribe.testing.DistTopicLog

setData(Serializable) - Method in class rice.scribe.messaging.ScribeMessage

Sets the data contained in the message.

setDestinationId(Id) - Method in interface rice.p2p.commonapi.RouteMessage

Sets the destination Id for this message

setDestinationId(Id) - Method in class rice.p2p.past.testing.PastRegrTest.TestRouteMessage

setDestinationId(Id) - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestRouteMessage

Sets the DestinationId attribute of the TestRouteMessage object

setDestinationId(Id) - Method in class rice.pastry.routing.RouteMessage

setDigit(int, int, int) - Method in class rice.pastry.Id

Sets the ith digit in base 2^b.

setDirectElements() - Method in class rice.pastry.direct.DirectPastryNode

setElements(NodeHandle, PastrySecurityManager, MessageDispatch, LeafSet, RoutingTable) - Method in class rice.pastry.PastryNode

Combined accessor method for various members of PastryNode.

setID(PASTMessageID) - Method in class rice.past.messaging.PASTMessage

Deprecated. Sets this message's identifier.

setIsInPool(boolean) - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Sets whether or not this node handle is in the node handle pool.

setKey(SelectionKey) - Method in class rice.pastry.wire.SocketChannelWriter

method to re-assign the key if it changes

setKey(SelectionKey, SocketCommandMessage) - Method in class rice.pastry.wire.WireNodeHandle

Method which sets the SelectionKey of this node handle.

setLastRecvTime(long) - Method in class rice.scribe.testing.DistTopicLog

setLastSeqNumRecv(int) - Method in class rice.scribe.testing.DistTopicLog

setLocalNode(PastryNode) - Method in class rice.pastry.LocalNode

Accessor method.

setLocalNode(PastryNode) - Method in interface rice.pastry.LocalNodeI

Accessor method.

setLocalNode(PastryNode) - Method in class rice.pastry.NodeHandle

Set the local PastryNode.

setLocalPastryNode(PastryNode) - Method in class rice.pastry.direct.DirectSecurityManager

Sets the local pastry node.

setLocalPastryNode(PastryNode) - Method in class rice.pastry.rmi.RMIPastrySecurityManager

Sets the local Pastry node after it is fully constructed.

setLocalPastryNode(PastryNode) - Method in class rice.pastry.wire.WirePastrySecurityManager

Sets the local Pastry node after it is fully constructed.

setMaxChildren(ChannelId, int) - Method in class rice.p2p.splitstream.SplitStreamScribePolicy

Adjust the max bandwidth for this channel.

setMaximumSize(int, Continuation) - Method in interface rice.persistence.Cache

Sets the maximum size of the cache, in bytes.

setMaximumSize(int, Continuation) - Method in class rice.persistence.LRUCache

Sets the maximum size of the cache, in bytes.

setMaximumSize(int, Continuation) - Method in class rice.persistence.StorageManager

Sets the maximum size of the cache, in bytes.

setMessage(Message) - Method in interface rice.p2p.commonapi.RouteMessage

Sets the internal message for this message

setMessage(Message) - Method in class rice.p2p.past.testing.PastRegrTest.TestRouteMessage

setMessage(Message) - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestRouteMessage

Sets the Message attribute of the TestRouteMessage object

setMessage(Message) - Method in class rice.pastry.commonapi.PastryEndpointMessage

Returns the internal message

setMessage(Message) - Method in class rice.pastry.routing.RouteMessage

setMessageDispatch(MessageDispatch) - Method in class rice.pastry.PastryNode

setNextHop(NodeHandle) - Method in class rice.pastry.routing.RouteMessage

setNextHopHandle(NodeHandle) - Method in interface rice.p2p.commonapi.RouteMessage

Sets the next hop handle for this message

setNextHopHandle(NodeHandle) - Method in class rice.p2p.past.testing.PastRegrTest.TestRouteMessage

setNextHopHandle(NodeHandle) - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestRouteMessage

Sets the NextHopHandle attribute of the TestRouteMessage object

setNextHopHandle(NodeHandle) - Method in class rice.pastry.routing.RouteMessage

setNum(int) - Method in class rice.pastry.wire.messaging.datagram.DatagramMessage

Sets the "packet number" of this transmission

setParent(NodeHandle) - Method in class rice.p2p.scribe.ScribeImpl.TopicManager

Sets the Parent attribute of the TopicManager object

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

Sets the parent for the topic specified by topicId.

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

Sets the parent for the topic specified by topicId.

setParent(NodeHandle) - Method in class rice.scribe.Topic

Sets the local node's parent in this topic's multicast tree.

setParentAndaddChildTest() - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

Checks whether setParent and addChild works correctly.

setPathToRoot(Id[]) - Method in class rice.p2p.scribe.ScribeImpl.TopicManager

Sets the PathToRoot attribute of the TopicManager object

setPending(ObjectInputStream, PastryNode) - Method in class rice.pastry.PendingLocalNodesList

Sets all of the pending local nodes read in by the given input stream.

setPolicy(ScribePolicy) - Method in interface rice.p2p.scribe.Scribe

Sets the current policy for this scribe object

setPolicy(ScribePolicy) - Method in class rice.p2p.scribe.ScribeImpl

Sets the current policy for this scribe object

setPresent(boolean) - Method in class rice.rm.testing.ObjectState

setPrevNode(NodeHandle) - Method in class rice.pastry.routing.RouteMessage

setPriority(boolean) - Method in class rice.pastry.messaging.Message

Set priority.

setProximity(int) - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Method which is designed to be called by subclassses whenever there is a change in the distance metric.

setRMIElements(RMINodeHandlePool, int, int, int) - Method in class rice.pastry.rmi.RMIPastryNode

accessor method for elements in RMIPastryNode, called by RMIPastryNodeFactory.

setRange(IdRange) - Method in interface rice.p2p.replication.ReplicationClient

This upcall is to notify the application of the range of keys for which it is responsible.

setRange(IdRange) - Method in class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

Method by which the range is set, which will delete any keys from the to fetch list not in the range

setRange(IdRange) - Method in class rice.p2p.replication.manager.ReplicationManagerImpl

This upcall is to notify the application of the range of keys for which it is responsible.

setRange(IdRange) - Method in class rice.p2p.replication.testing.ReplicationRegrTest.TestReplicationClient

This upcall is to notify the application of the range of keys for which it is responsible.

setReady() - Method in class rice.pastry.PastryNode

setRemoteNode(RMIRemoteNodeI) - Method in class rice.pastry.rmi.RMINodeHandle

Remotenode accessor method.

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

Method which builds a response for this message, using the provided object as a result.

setRoot(String) - Method in class rice.persistence.PersistentStorage

Sets the root directory that the persistence Manager uses

setSeed(int) - Static method in class rice.pastry.PastrySeed

setSenderId(NodeId) - Method in class rice.pastry.messaging.Message

Set sender Id.

setSeqNo(int) - Method in class rice.rm.messaging.RMRequestKeysMsg

Since this message has a timeout mechanism, the next time we resend the message as a result of Timeout we need to reflect the current seqNo used by the application in the message.

setSeqNumToPublish(int) - Method in class rice.scribe.testing.DistTopicLog

setSocketElements(InetSocketAddress, SelectorManager, DatagramManager, SocketManager, WireNodeHandlePool, int, int) - Method in class rice.pastry.wire.WirePastryNode

Helper method which allows the WirePastryNodeFactory to initialize a number of the pastry node's elements.

setSource(NodeHandle) - Method in class rice.p2p.scribe.messaging.ScribeMessage

Method which set this messages' source address

setState(int) - Method in class rice.scribe.Topic

Set the state of topic to state

setStorageSize(int) - Method in class rice.persistence.PersistentStorage

Sets the amount of storage that the persistence Manager uses

setTestRecord(TestRecord) - Method in class rice.pastry.direct.EuclideanNetwork

set TestRecord

setTestRecord(TestRecord) - Method in interface rice.pastry.direct.NetworkSimulator

setTestRecord(TestRecord) - Method in class rice.pastry.direct.SphereNetwork

set TestRecord

setThread(Thread) - Method in class rice.pastry.wire.WirePastryNode

Sets the thread which the pastry node is running in.

setTreeRepairThreshold(int) - Method in interface rice.scribe.IScribe

The tree repair event for a particular topic in Scribe is triggered when a node misses a certain treeRepairThreshold number of heartbeat messages from its parent for the topic.

setTreeRepairThreshold(int) - Method in class rice.scribe.Scribe

The tree repair event for a particular topic in Scribe is triggered when a node misses a certain threshold number of heartbeat messages from its parent for the topic.

setType(int) - Method in class rice.past.messaging.PASTMessage

Deprecated. Sets this message's type.

setUnsubscribed(boolean) - Method in class rice.scribe.testing.DistTopicLog

setUp(Continuation) - Method in class rice.persistence.testing.LRUCacheTest

setUp(Continuation) - Method in class rice.persistence.testing.MemoryStorageTest

setmissingCount(int) - Method in class rice.rm.testing.ObjectState

setstaleCount(int) - Method in class rice.rm.testing.ObjectState

setupDone - Static variable in class rice.rm.testing.DirectRMRegrTest

shift(int, int) - Method in class rice.pastry.Id.Distance

Shift operator.

shift(int, int, boolean) - Method in class rice.pastry.Id.Distance

Shift operator.

shiftDistance(int, int) - Method in interface rice.p2p.commonapi.Id.Distance

Shift operator.

shiftDistance(int, int) - Method in class rice.pastry.Id.Distance

Shift operator.

simulate() - Method in class rice.p2p.commonapi.testing.CommonAPITest

In case we're using the direct simulator, this method simulates the message passing.

simulate() - Method in class rice.pastry.direct.EuclideanNetwork

DESCRIBE THE METHOD

simulate() - Method in interface rice.pastry.direct.NetworkSimulator

Simulate one message delivery.

simulate() - Method in class rice.pastry.direct.SphereNetwork

DESCRIBE THE METHOD

simulate() - Method in class rice.pastry.testing.DirectPastryRegrTest

send one simulated message

simulate() - Method in class rice.pastry.testing.DistPastryRegrTest

simulate() - Method in class rice.pastry.testing.PastryRegrTest

send one simulated message, or return false for a real wire protocol.

simulate() - Method in class rice.pastry.testing.PastryTest

simulate() - Method in class rice.pastry.testing.SinglePingTest

simulate() - Method in class rice.rm.testing.DirectRMRegrTest

simulate() - Method in class rice.scribe.testing.BasicScribeRegrTest

simulate() - Method in class rice.scribe.testing.DirectScribeMaintenanceTest

simulator - Variable in class rice.p2p.commonapi.testing.CommonAPITest

simulator - Static variable in class rice.rm.testing.DirectRMRegrTest

size() - Method in interface rice.p2p.commonapi.NodeHandleSet

Gets the size of the set.

size() - Method in class rice.pastry.NodeSet

Gets the number of elements.

size() - Method in interface rice.pastry.NodeSetI

Gets the size of the set.

size() - Method in class rice.pastry.leafset.LeafSet

Gets the current size of the leaf set.

size() - Method in class rice.pastry.leafset.SimilarSet

Gets the current size of this set.

size() - Method in class rice.pastry.routing.RouteSet

Return the current size of the set.

sleep() - Method in class rice.Continuation.ExternalContinuation

source - Variable in class rice.p2p.past.messaging.PastMessage

source - Variable in class rice.p2p.replication.messaging.ReplicationMessage

source - Variable in class rice.p2p.scribe.messaging.ScribeMessage

source - Variable in class rice.pastry.testing.HelloMsg

source - Variable in class rice.pastry.wire.messaging.datagram.DatagramMessage

DESCRIBE THE FIELD

splitPendingRanges(NodeId) - Method in class rice.rm.RMImpl

Iterates over the list of pending Ranges and splits the ranges if the expected number of keys in a range is greater than MAXKEYSINRANGE.

splitStream - Variable in class rice.p2p.splitstream.SplitStreamScribePolicy

A reference to this policy's splitstream object

splitstreams - Variable in class rice.p2p.splitstream.testing.SplitStreamRegrTest

DESCRIBE THE FIELD

ssclients - Variable in class rice.p2p.splitstream.testing.SplitStreamRegrTest

stage - Variable in class rice.p2p.splitstream.SplitStreamSubscribeContent

The stage that the client attempting to join is in

stamp(Date) - Method in class rice.pastry.messaging.Message

If the message has no timestamp, this will stamp the message.

start() - Method in class rice.p2p.commonapi.testing.CommonAPITest

Method which starts the creation of nodes

start() - Method in class rice.past.testing.DistPASTRegrTest.TestPASTFunctions

Deprecated. Starts running this test.

start() - Method in class rice.pastry.testing.LeafSetTest

start() - Method in class rice.persistence.testing.LRUCacheTest

start() - Method in class rice.persistence.testing.MemoryStorageTest

start() - Method in class rice.persistence.testing.Test

start() - Static method in class rice.scribe.testing.BasicScribeRegrTest

Main entry point for the basic scribe regression test suite.

start() - Static method in class rice.scribe.testing.DirectScribeMaintenanceTest

Main entry point for the test suite.

state - Variable in class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

The current state that we are in

stepDone() - Method in class rice.p2p.commonapi.testing.CommonAPITest

Method which prints the end of a test section step, with an assumed success.

stepDone(String) - Method in class rice.p2p.commonapi.testing.CommonAPITest

Method which prints the end of a test section step.

stepDone(String, String) - Method in class rice.p2p.commonapi.testing.CommonAPITest

Method which prints the end of a test section step, as well as a message.

stepDone(String) - Method in class rice.persistence.testing.Test

stepDone(String, String) - Method in class rice.persistence.testing.Test

stepException(Exception) - Method in class rice.p2p.commonapi.testing.CommonAPITest

Method which prints an exception which occured during testing.

stepException(Exception) - Method in class rice.persistence.testing.Test

stepStart(String) - Method in class rice.p2p.commonapi.testing.CommonAPITest

Method which prints the beginning of a test section step.

stepStart(String) - Method in class rice.persistence.testing.Test

storage - Variable in class rice.p2p.past.PastImpl

storage - Variable in class rice.p2p.replication.testing.ReplicationRegrTest.TestReplicationClient

storage - Variable in class rice.persistence.testing.MemoryStorageTest

storages - Variable in class rice.p2p.past.testing.PastRegrTest

store(Id, Serializable, Continuation) - Method in class rice.persistence.MemoryStorage

Stores the object under the key id.

store(Id, Serializable, Continuation) - Method in class rice.persistence.PersistentStorage

Makes the object persistent to disk and stored permanantly If the object is already persistent, this method will simply update the object's serialized image.

store(Id, Serializable, Continuation) - Method in interface rice.persistence.Storage

Stores an object in this storage.

store(Id, Serializable, Continuation) - Method in class rice.persistence.StorageManager

Stores an object in this storage.

store - Variable in class rice.persistence.testing.MemoryStorageTest

store(Id, Object) - Method in class rice.rm.testing.RMRegrTestApp

stripeId - Variable in class rice.p2p.splitstream.Stripe

The stripeId for this stripe

stripes - Variable in class rice.p2p.splitstream.Channel

The list of stripeIds for this channel

subSet(IdRange) - Method in interface rice.p2p.commonapi.IdSet

return a subset of this set, consisting of the member ids in a given range

subSet(Id, Id) - Method in class rice.pastry.IdSet

return a subset of this set, consisting of the member ids in a given range

subSet(IdRange) - Method in class rice.pastry.IdSet

return a subset of this set, consisting of the member ids in a given range

subSet(IdRange) - Method in class rice.pastry.IdSet

return a subset of this set, consisting of the member ids in a given range

subscribe(Topic, ScribeClient) - Method in interface rice.p2p.scribe.Scribe

Subscribes the given client to the provided topic.

subscribe(Topic, ScribeClient, ScribeContent) - Method in interface rice.p2p.scribe.Scribe

Subscribes the given client to the provided topic.

subscribe(Topic, ScribeClient) - Method in class rice.p2p.scribe.ScribeImpl

Subscribes the given client to the provided topic.

subscribe(Topic, ScribeClient, ScribeContent) - Method in class rice.p2p.scribe.ScribeImpl

Subscribes the given client to the provided topic.

subscribe(SplitStreamClient) - Method in class rice.p2p.splitstream.Stripe

Adds a client to this stripe - the client will be informed whenever data arrives for this stripe

subscribe(IScribeApp) - Method in class rice.scribe.Topic

Register an application as a subscriber to this Topic, so that the application receives events related to the Topic.

subscribeFailed(Topic) - Method in interface rice.p2p.scribe.ScribeClient

Informs the client that a subscribe on the given topic failed - the client should retry the subscribe or take appropriate action.

subscribeFailed - Variable in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

Whether this client has had a subscribe fail

subscribeFailed(Topic) - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

subscribeFailed(Topic) - Method in class rice.p2p.splitstream.Stripe

Informs this client that a subscription failed

subscribeHandler(NodeId, NodeHandle, boolean, Serializable) - Method in interface rice.scribe.IScribeApp

Invoked by Scribe after a child is added to or removed from one of the node's children tables.

subscribeHandler(NodeId, NodeHandle, boolean, Serializable) - Method in class rice.scribe.testing.BasicScribeRegrTestApp

up-call invoked by scribe when a node is added/removed to the multicast tree.

subscribeHandler(NodeId, NodeHandle, boolean, Serializable) - Method in class rice.scribe.testing.DirectScribeMaintenanceTestApp

up-call invoked by scribe when a node is added/removed to the multicast tree.

subscribeHandler(NodeId, NodeHandle, boolean, Serializable) - Method in class rice.scribe.testing.DistScribeRegrTestApp

up-call invoked by scribe when a node is added/removed to the multicast tree.

subscriber - Variable in class rice.p2p.scribe.messaging.SubscribeMessage

The original subscriber

subtract(IdRange, boolean) - Method in class rice.pastry.IdRange

subtract the other range from this computes the ranges of keys that are in this but not in o subtracting a range may produce two ranges on the circle; this method produces one such ranges under control of the cwPart parameter

swap(int, int) - Method in class rice.pastry.leafset.SimilarSet

swap two elements

T

TIMEOUT - Static variable in class rice.rm.messaging.RMRequestKeysMsg

The timeout period within which if the response to this message is not received, then the same message is resent.

TIMEOUT_DELAY - Static variable in class rice.p2p.replication.manager.ReplicationManagerImpl

The amount of time to wait before giving up on a client fetch

TYPE_DRP - Static variable in class rice.pastry.wire.testing.WireFileProcessor

TYPE_ENQ - Static variable in class rice.pastry.wire.testing.WireFileProcessor

TYPE_REC - Static variable in class rice.pastry.wire.testing.WireFileProcessor

TYPE_SEN - Static variable in class rice.pastry.wire.testing.WireFileProcessor

Test - class rice.persistence.testing.Test.

This class is a class which tests the Storage class in the rice.persistence package.

Test() - Constructor for class rice.persistence.testing.Test

TestMessage - class rice.rm.testing.TestMessage.

TestMessage(NodeHandle, Address, Credentials) - Constructor for class rice.rm.testing.TestMessage

TestRecord - class rice.pastry.direct.TestRecord.

TestRecord(int, int) - Constructor for class rice.pastry.direct.TestRecord

Constructor.

TimeoutMessage - class rice.p2p.replication.manager.messaging.TimeoutMessage.

TimeoutMessage(int) - Constructor for class rice.p2p.replication.manager.messaging.TimeoutMessage

Constructor which takes a unique integer Id

Topic - class rice.p2p.scribe.Topic.

Topic(Id) - Constructor for class rice.p2p.scribe.Topic

Constructor which takes an Id for this topic

Topic(IdFactory, String) - Constructor for class rice.p2p.scribe.Topic

Constructor which takes a name for this topic

Topic - class rice.scribe.Topic.

Topic(NodeId, Scribe) - Constructor for class rice.scribe.Topic

Constructs an empty Topic

tables - Variable in class rice.pastry.wire.testing.WireFileProcessor

target - Variable in class rice.pastry.testing.HelloMsg

tcp - Variable in class rice.pastry.wire.testing.WireFileProcessor.ObjPair

tcp - Variable in class rice.pastry.wire.testing.WireFileProcessor.Pair

test(NodeHandle) - Method in class rice.pastry.leafset.LeafSet

Test if a put of the given NodeHandle would succeed.

test(NodeHandle) - Method in class rice.pastry.leafset.SimilarSet

Test if a NodeHandle belongs into the set.

test(int, NodeHandle) - Method in class rice.pastry.testing.ClosestRegrTest

starts the testing process

test() - Method in class rice.pastry.testing.SinglePingTest

testAPI() - Method in class rice.p2p.scribe.testing.ScribeRegrTest

Tests basic publish functionality

testBandwidthUsage() - Method in class rice.p2p.splitstream.testing.SplitStreamRegrTest

testBasic() - Method in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

Tests basic functionality

testBasic() - Method in class rice.p2p.replication.testing.ReplicationRegrTest

Tests basic functionality

testBasic(int, String) - Method in class rice.p2p.scribe.testing.ScribeRegrTest

Tests basic functionality

testBasic() - Method in class rice.p2p.splitstream.testing.SplitStreamRegrTest

Tests routing a Past request to a particular node.

testCaching() - Method in class rice.p2p.past.testing.PastRegrTest

Tests the dynamic caching function in Past.

testCumulativeRange() - Method in class rice.pastry.testing.LeafSetTest

testExists(Continuation) - Method in class rice.persistence.testing.MemoryStorageTest

testFailure(int) - Method in class rice.p2p.splitstream.testing.SplitStreamRegrTest

testFailureNotification() - Method in class rice.p2p.scribe.testing.ScribeRegrTest

Tests failure notification

testFetch() - Method in class rice.p2p.past.testing.PastRegrTest

Tests the fetch function in Past.

testIndependence() - Method in class rice.p2p.splitstream.testing.SplitStreamRegrTest

testLookupHandles() - Method in class rice.p2p.past.testing.PastRegrTest

Tests the lookup handles function in Past.

testMaintenance() - Method in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

Tests maintenance functionality

testMaintenance() - Method in class rice.p2p.replication.testing.ReplicationRegrTest

Tests maintenance functionality

testMaintenance() - Method in class rice.p2p.scribe.testing.ScribeRegrTest

Tests basic publish functionality

testMaintenance(int) - Method in class rice.p2p.splitstream.testing.SplitStreamRegrTest

testNonCumulativeRange() - Method in class rice.pastry.testing.LeafSetTest

testOverload() - Method in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

Tests basic functionality

testParameterChecks() - Method in class rice.p2p.past.testing.PastRegrTest

Tests the parameter checking in Past.

testRetreival(Continuation) - Method in class rice.persistence.testing.MemoryStorageTest

testRouteRequest() - Method in class rice.p2p.past.testing.PastRegrTest

Tests routing a Past request to a particular node.

testRouteRequest() - Method in class rice.past.testing.DistPASTRegrTest

Deprecated. Tests routing a PAST request to a particular node.

testSingleRoot(String) - Method in class rice.p2p.scribe.testing.ScribeRegrTest

testStress() - Method in class rice.p2p.replication.manager.testing.ReplicationManagerRegrTest

Tests basic functionality

testVersionControl() - Method in class rice.p2p.past.testing.PastRegrTest

Tests overwriting an exiting object with a new one

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

toByteArray() - Method in interface rice.p2p.commonapi.Id

Returns a (mutable) byte array representing this Id

toByteArray() - Method in class rice.pastry.Id

Returns the byte array representation of this Id

toString() - Method in class rice.p2p.past.messaging.CacheMessage

Returns a string representation of this message

toString() - Method in class rice.p2p.past.messaging.FetchHandleMessage

Returns a string representation of this message

toString() - Method in class rice.p2p.past.messaging.FetchMessage

Returns a string representation of this message

toString() - Method in class rice.p2p.past.messaging.InsertMessage

Returns a string representation of this message

toString() - Method in class rice.p2p.past.messaging.LookupHandlesMessage

Returns a string representation of this message

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

Returns a string representation of this message

toString() - Method in class rice.p2p.past.messaging.MessageLostMessage

Returns a string representation of this message

toString() - Method in class rice.p2p.past.testing.PastRegrTest.TestPastContent

toString() - Method in class rice.p2p.past.testing.PastRegrTest.VersionedTestPastContent

toString() - Method in class rice.p2p.scribe.Topic

Returns a String representation of this topic

toString() - Method in class rice.p2p.scribe.messaging.PublishMessage

toString() - Method in class rice.p2p.scribe.messaging.SubscribeMessage

Returns a String represneting this message

toString() - Method in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeContent

DESCRIBE THE METHOD

toString() - Method in class rice.p2p.splitstream.ChannelId

toString() - Method in class rice.p2p.splitstream.SplitStreamContent

toString() - Method in class rice.p2p.splitstream.Stripe

Returns a String representation of this Stripe

toString() - Method in class rice.p2p.splitstream.StripeId

toString() - Method in class rice.past.messaging.MessageExists

Deprecated. Display this message.

toString() - Method in class rice.past.messaging.MessageFetch

Deprecated. Display this message.

toString() - Method in class rice.past.messaging.MessageInsert

Deprecated. Display this message.

toString() - Method in class rice.past.messaging.MessageLookup

Deprecated. Display this message.

toString() - Method in class rice.past.messaging.MessageReclaim

Deprecated. Display this message.

toString() - Method in class rice.past.messaging.PASTMessage

Deprecated. Force subclasses to implement toString.

toString() - Method in interface rice.past.messaging.PASTMessageID

Deprecated. Returns the string representation of the node.

toString() - Method in class rice.past.messaging.PASTMessageIDImpl

Deprecated. Returns the string representation of the node.

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

Returns a string representation of the distance The string is a byte string from most to least significant.

toString() - Method in class rice.pastry.Id

Returns a string representation of the Id in base 16.

toString() - Method in class rice.pastry.IdRange

Returns a string representation of the range.

toString() - Method in class rice.pastry.IdSet

Returns a string representation of the IdSet.

toString() - Method in class rice.pastry.NodeSet

Returns a string representation of the NodeSet

toString() - Method in class rice.pastry.PastryNode

toString() - Method in class rice.pastry.commonapi.PastryEndpointMessage

Returns the String representation of this message

toString() - Method in class rice.pastry.direct.DirectNodeHandle

DESCRIBE THE METHOD

toString() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Returns a String representation of this DistNodeHandle.

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

Returns a String representation of this DistNodeHandle.

toString() - Method in class rice.pastry.join.JoinAddress

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

toString() - Method in class rice.pastry.leafset.BroadcastLeafSet

toString() - Method in class rice.pastry.leafset.LeafSet

Returns a string representation of the leaf set

toString() - Method in class rice.pastry.leafset.LeafSetProtocolAddress

toString() - Method in class rice.pastry.leafset.RequestLeafSet

toString() - Method in class rice.pastry.routing.BroadcastRouteRow

toString() - Method in class rice.pastry.routing.RequestRouteRow

toString() - Method in class rice.pastry.routing.RouteMessage

toString() - Method in class rice.pastry.routing.RouteProtocolAddress

toString() - Method in class rice.pastry.routing.RouterAddress

toString() - Method in class rice.pastry.routing.RoutingTable

produces a String representation of the routing table, showing the number of node handles in each entry

toString() - Method in class rice.pastry.standard.StandardAddress

toString() - Method in class rice.pastry.testing.HelloMsg

toString() - Method in class rice.pastry.testing.HelloWorldAppMultiThread

toString() - Method in class rice.pastry.testing.LeafSetTest.TestNodeHandle

toString() - Method in class rice.pastry.testing.PingAddress

toString() - Method in class rice.pastry.testing.PingMessageNew

toString() - Method in class rice.pastry.wire.WireNodeHandlePool

toString() - Method in class rice.pastry.wire.messaging.datagram.AcknowledgementMessage

DESCRIBE THE METHOD

toString() - Method in class rice.pastry.wire.messaging.datagram.DatagramMessage

DESCRIBE THE METHOD

toString() - Method in class rice.pastry.wire.messaging.datagram.DatagramTransportMessage

DESCRIBE THE METHOD

toString() - Method in class rice.pastry.wire.messaging.datagram.PingMessage

DESCRIBE THE METHOD

toString() - Method in class rice.pastry.wire.messaging.socket.DisconnectMessage

DESCRIBE THE METHOD

toString() - Method in class rice.pastry.wire.messaging.socket.HelloMessage

DESCRIBE THE METHOD

toString() - Method in class rice.pastry.wire.messaging.socket.HelloResponseMessage

DESCRIBE THE METHOD

toString() - Method in class rice.pastry.wire.messaging.socket.SocketTransportMessage

DESCRIBE THE METHOD

toString() - Method in class rice.pastry.wire.testing.HelloMessageDigest

toString() - Method in class rice.pastry.wire.testing.MessageDigest

toString() - Method in class rice.pastry.wire.testing.PublishMessageDigest

toString() - Method in class rice.pastry.wire.testing.WireFileProcessor.Pair

toString() - Method in class rice.rm.RMImpl.KEPenEntry

toString() - Method in class rice.rm.messaging.RMMaintenanceMsg

toString() - Method in class rice.rm.messaging.RMMessage.KEEntry

toString() - Method in class rice.rm.messaging.RMTimeoutMsg

toString() - Method in class rice.rm.testing.DistRMRegrTestMessage

toString() - Method in class rice.rm.testing.DistRMRegrTestReplicateMessage

toString() - Method in class rice.rm.testing.InvariantCheckMsg

toString() - Method in class rice.rm.testing.ObjectInsertionMsg

toString() - Method in class rice.rm.testing.ObjectRefreshMsg

toString() - Method in class rice.rm.testing.ReplicateTimeoutMsg

toString() - Method in class rice.scribe.maintenance.MessageScribeMaintenance

toString() - Method in class rice.scribe.messaging.MessageAckOnSubscribe

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

toString() - Method in class rice.scribe.messaging.MessageCreate

toString() - Method in class rice.scribe.messaging.MessageHeartBeat

toString() - Method in class rice.scribe.messaging.MessagePublish

toString() - Method in class rice.scribe.messaging.MessageReplyFromParent

toString() - Method in class rice.scribe.messaging.MessageRequestToParent

toString() - Method in class rice.scribe.messaging.MessageSubscribe

toString() - Method in class rice.scribe.messaging.MessageUnsubscribe

toString() - Method in class rice.scribe.messaging.ScribeMessage

toString() - Method in class rice.scribe.testing.DistScribeRegrTestMessage

toStringFull() - Method in interface rice.p2p.commonapi.Id

Returns a string representing the full length of this Id.

toStringFull() - Method in class rice.pastry.Id

Returns the complete represntation of this Id, in hex.

toStringImpl() - Method in class rice.pastry.dist.DistCoalesedNodeHandle

Returns a String representation of this DistNodeHandle.

toStringImpl() - Method in class rice.pastry.rmi.RMINodeHandle

toStringImpl() - Method in class rice.pastry.wire.WireNodeHandle

implementation for toString()

toVisit - Variable in class rice.p2p.scribe.messaging.AnycastMessage

the list of nodes which we are going to visit

topic - Variable in class rice.p2p.scribe.ScribeImpl.TopicManager

DESCRIBE THE FIELD

topic - Variable in class rice.p2p.scribe.messaging.ScribeMessage

topic - Variable in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeClient

The topic this client is listening for

topic - Variable in class rice.p2p.scribe.testing.ScribeRegrTest.TestScribeContent

DESCRIBE THE FIELD

topic - Variable in class rice.p2p.splitstream.Stripe

The topic corresponding to this stripeId

topicManager(boolean) - Method in class rice.scribe.Topic

Sets the flag indicating whether the current node is topic manager for this topic

topics - Variable in class rice.p2p.scribe.ScribeImpl

the hashtable of topic -> TopicManager

type() - Method in class rice.pastry.leafset.BroadcastLeafSet

Returns the type of leaf set.

type - Variable in class rice.pastry.wire.testing.MessageDigest

U

UNSUBSCRIBE_LIMIT - Static variable in class rice.scribe.testing.DistScribeRegrTest

UNSUBSCRIBE_PROBABILITY - Static variable in class rice.scribe.testing.DistScribeRegrTest

UnsubscribeMessage - class rice.p2p.scribe.messaging.UnsubscribeMessage.

UnsubscribeMessage(NodeHandle, Topic) - Constructor for class rice.p2p.scribe.messaging.UnsubscribeMessage

Constructor which takes a unique integer Id

Update - Static variable in class rice.pastry.leafset.BroadcastLeafSet

udp - Variable in class rice.pastry.wire.testing.MessageDigest

udp - Variable in class rice.pastry.wire.testing.WireFileProcessor.ObjPair

udp - Variable in class rice.pastry.wire.testing.WireFileProcessor.Pair

uid - Variable in class rice.p2p.replication.manager.messaging.TimeoutMessage

THe unique id of this message

uncache(Id, Continuation) - Method in interface rice.persistence.Cache

Removes the object from the list of cached objects.

uncache(Id, Continuation) - Method in class rice.persistence.LRUCache

Removes the object from the list of cached objects.

uncache(Id, Continuation) - Method in class rice.persistence.StorageManager

Removes the object from the list of cached objects.

unregisterForWakeup(NeedsWakeUp) - Method in class rice.pastry.wire.SelectorManager

used to unregister an object for wakeup on the Selector thread.

unstore(Id, Continuation) - Method in class rice.persistence.MemoryStorage

Removes the object from the list of stored objects.

unstore(Id, Continuation) - Method in class rice.persistence.PersistentStorage

Request to remove the object from the list of persistend objects.

unstore(Id, Continuation) - Method in interface rice.persistence.Storage

Removes the object from the list of stored objects.

unstore(Id, Continuation) - Method in class rice.persistence.StorageManager

Removes the object from the list of stored objects.

unsubscribe(Topic, ScribeClient) - Method in interface rice.p2p.scribe.Scribe

Unsubscribes the given client from the provided topic.

unsubscribe(Topic, ScribeClient) - Method in class rice.p2p.scribe.ScribeImpl

Unsubscribes the given client from the provided topic.

unsubscribe(SplitStreamClient) - Method in class rice.p2p.splitstream.Stripe

Removes a client from this stripe - the client will no longer be informed whenever data arrives for this stripe

unsubscribe(IScribeApp) - Method in class rice.scribe.Topic

Unregister an application as a Subscriber to this Topic, so that the application no longer receives events regarding this Topic.

unwrap() - Method in class rice.pastry.routing.RouteMessage

The wrapped message.

update(NodeHandle, boolean) - Method in interface rice.p2p.commonapi.Application

This method is invoked to inform the application that the given node has either joined or left the neighbor set of the local node, as the set would be returned by the neighborSet call.

update(NodeHandle, boolean) - Method in class rice.p2p.past.PastImpl

This method is invoked to inform the application that the given node has either joined or left the neighbor set of the local node, as the set would be returned by the neighborSet call.

update(NodeHandle, boolean) - Method in class rice.p2p.replication.ReplicationImpl

This method is invoked to inform the application that the given node has either joined or left the neighbor set of the local node, as the set would be returned by the neighborSet call.

update(NodeHandle, boolean) - Method in class rice.p2p.replication.manager.ReplicationManagerImpl

This method is invoked to inform the application that the given node has either joined or left the neighbor set of the local node, as the set would be returned by the neighborSet call.

update(Observable, Object) - Method in class rice.p2p.scribe.ScribeImpl.TopicManager

DESCRIBE THE METHOD

update(NodeHandle, boolean) - Method in class rice.p2p.scribe.ScribeImpl

This method is invoked to inform the application that the given node has either joined or left the neighbor set of the local node, as the set would be returned by the neighborSet call.

update(NodeHandle, boolean) - Method in class rice.past.PASTServiceImpl

Deprecated. This method is invoked to inform the application that the given node has either joined or left the neighbor set of the local node, as the set would be returned by the neighborSet call.

update(NodeHandle, boolean) - Method in class rice.pastry.client.CommonAPIAppl

Called by pastry when the neighbor set changes.

update(Observable, Object) - Method in class rice.pastry.dist.DistCoalesedNodeHandle

update(Observable, Object) - Method in class rice.pastry.leafset.SimilarSet

Is called by the Observer pattern whenever the liveness or proximity of a registered node handle is changed.

update(Observable, Object) - Method in class rice.pastry.routing.RouteSet

Is called by the Observer pattern whenever the liveness or proximity of a registered node handle is changed.

update(Observable, Object) - Method in class rice.pastry.routing.RoutingTable

Is called by the Observer pattern whenever a RouteSet in this table has changed.

update(Observable, Object) - Method in class rice.pastry.standard.StandardRouteSetProtocol

Observer update.

update(NodeHandle, boolean) - Method in class rice.pastry.testing.RegrTestApp

update(WireNodeHandle) - Method in class rice.pastry.wire.SocketManager

Method which is designed to be called whenever a node has network activity.

update(NodeHandle, boolean) - Method in class rice.rm.RMImpl

Implements the main algorithm for keeping the invariant that an object would be stored in k closest nodes to the objectKey while the nodes are coming up or going down.

update(Object) - Method in interface rice.scribe.IScribeObserver

Method called by underlying scribe layer whenever a topic data structure is created implicitly.

update(Object) - Method in class rice.scribe.testing.DirectScribeMaintenanceTestApp

Method called by underlying scribe whenever a topic object is created impliclity.

updateNumKeys(int) - Method in class rice.rm.RMImpl.KEPenEntry

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

Used to update the state of a pending range to the m_pendingRanges hashtable.

V

verifyAddressBinding(Credentials, Address) - Method in class rice.pastry.direct.DirectSecurityManager

Checks to see if these credentials can be associated with the address.

verifyAddressBinding(Credentials, Address) - Method in class rice.pastry.rmi.RMIPastrySecurityManager

Checks to see if these credentials can be associated with the address.

verifyAddressBinding(Credentials, Address) - Method in interface rice.pastry.security.PastrySecurityManager

Checks to see if these credentials can be associated with the address.

verifyAddressBinding(Credentials, Address) - Method in class rice.pastry.security.PermissiveSecurityManager

verifyAddressBinding(Credentials, Address) - Method in class rice.pastry.wire.WirePastrySecurityManager

Checks to see if these credentials can be associated with the address.

verifyApplication(List, MRTracker, MRTracker) - Method in class rice.scribe.testing.BasicScribeRegrTestApp

This makes sure that if the current app was subscribed to a topic, it received all the messages published to it.

verifyCanCreate(NodeHandle, NodeId) - Method in interface rice.scribe.security.IScribeSecurityManager

Verify that the node handle has permission to create a topic.

verifyCanCreate(NodeHandle, NodeId) - Method in class rice.scribe.security.PSecurityManager

Verify that the node handle has permission to create a topic.

verifyCanPublish(NodeHandle, NodeId) - Method in interface rice.scribe.security.IScribeSecurityManager

Verify that the node handle has permission to publish to a topic.

verifyCanPublish(NodeHandle, NodeId) - Method in class rice.scribe.security.PSecurityManager

Verify that the node handle has permission to publish to a topic.

verifyCanSubscribe(NodeHandle, NodeId) - Method in interface rice.scribe.security.IScribeSecurityManager

Verify that the node handle has permission to subscribe to a topic.

verifyCanSubscribe(NodeHandle, NodeId) - Method in class rice.scribe.security.PSecurityManager

Verify that the node handle has permission to subscribe to a topic.

verifyMessage(Message) - Method in class rice.pastry.direct.DirectSecurityManager

This method takes a message and returns true if the message is safe and false otherwise.

verifyMessage(Message) - Method in class rice.pastry.rmi.RMIPastrySecurityManager

This method takes a message and returns true if the message is safe and false otherwise.

verifyMessage(Message) - Method in interface rice.pastry.security.PastrySecurityManager

This method takes a message and returns true if the message is safe and false otherwise.

verifyMessage(Message) - Method in class rice.pastry.security.PermissiveSecurityManager

verifyMessage(Message) - Method in class rice.pastry.wire.WirePastrySecurityManager

This method takes a message and returns true if the message is safe and false otherwise.

verifyNodeHandle(NodeHandle) - Method in class rice.pastry.direct.DirectSecurityManager

Verify node handle safety.

verifyNodeHandle(NodeHandle) - Method in class rice.pastry.rmi.RMIPastrySecurityManager

Verify node handle safety.

verifyNodeHandle(NodeHandle) - Method in interface rice.pastry.security.PastrySecurityManager

Verify node handle safety.

verifyNodeHandle(NodeHandle) - Method in class rice.pastry.security.PermissiveSecurityManager

verifyNodeHandle(NodeHandle) - Method in class rice.pastry.wire.WirePastrySecurityManager

Verify node handle safety.

version - Variable in class rice.p2p.past.testing.PastRegrTest.VersionedTestPastContent

visited - Variable in class rice.p2p.scribe.messaging.AnycastMessage

the list of nodes which we have visited

W

WNH_PREFIX - Static variable in class rice.pastry.wire.testing.WireFileProcessor

Wire - class rice.pastry.wire.Wire.

This is the beginning of a process wide authority for Wire.

Wire() - Constructor for class rice.pastry.wire.Wire

WireFileFilter - class rice.pastry.wire.testing.WireFileFilter.

Helper for WireFileProcessor to search for specific files.

WireFileFilter(String) - Constructor for class rice.pastry.wire.testing.WireFileFilter

WireFileProcessor - class rice.pastry.wire.testing.WireFileProcessor.

This file interprets all of the files generated by wireDebug() calls throughout the wire package.

WireFileProcessor() - Constructor for class rice.pastry.wire.testing.WireFileProcessor

WireFileProcessor.ObjPair - class rice.pastry.wire.testing.WireFileProcessor.ObjPair.

WireFileProcessor.ObjPair(MessageDigest) - Constructor for class rice.pastry.wire.testing.WireFileProcessor.ObjPair

WireFileProcessor.Pair - class rice.pastry.wire.testing.WireFileProcessor.Pair.

WireFileProcessor.Pair(int, int) - Constructor for class rice.pastry.wire.testing.WireFileProcessor.Pair

WireLimitatioinListener - interface rice.pastry.wire.WireLimitatioinListener.

This is an interface to notify user code that the FileDescriptors for the system are being saturated.

WireNodeHandle - class rice.pastry.wire.WireNodeHandle.

Class which represents a node handle in the socket-based pastry protocol.

WireNodeHandle(InetSocketAddress, NodeId) - Constructor for class rice.pastry.wire.WireNodeHandle

Constructor.

WireNodeHandle(InetSocketAddress, NodeId, PastryNode) - Constructor for class rice.pastry.wire.WireNodeHandle

Alternate constructor with local Pastry node.

WireNodeHandlePool - class rice.pastry.wire.WireNodeHandlePool.

The WireNodeHandlePool controls all of the node handles in use by the WirePastryNode.

WireNodeHandlePool(WirePastryNode) - Constructor for class rice.pastry.wire.WireNodeHandlePool

Constructor.

WirePastryNode - class rice.pastry.wire.WirePastryNode.

An Socket-based Pastry node, which has two threads - one thread for performing route set and leaf set maintainance, and another thread for listening on the sockets and performing all non-blocking I/O.

WirePastryNode(NodeId) - Constructor for class rice.pastry.wire.WirePastryNode

Constructor

WirePastryNodeFactory - class rice.pastry.wire.WirePastryNodeFactory.

Pastry node factory for Wire-linked nodes.

WirePastryNodeFactory(NodeIdFactory, int) - Constructor for class rice.pastry.wire.WirePastryNodeFactory

Constructor.

WirePastrySecurityManager - class rice.pastry.wire.WirePastrySecurityManager.

Security manager for wire connections between nodes.

WirePastrySecurityManager(WireNodeHandle, WireNodeHandlePool) - Constructor for class rice.pastry.wire.WirePastrySecurityManager

Constructor.

waitUnsubscribe(boolean) - Method in class rice.scribe.Topic

Sets flag indicating if the local node is waiting to be unsubscribed from this topic (because it does not yet know its parent)

wakeup() - Method in class rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerHelper

wakeup() - Method in class rice.pastry.wire.DatagramManager

Called by the SelectorManager whenever it is awoken.

wakeup() - Method in class rice.pastry.wire.DatagramTransmissionManager

Designed to be called periodically in order for the Transmission Manager to decide if a packet has been lost.

wakeup() - Method in interface rice.pastry.wire.NeedsWakeUp

this method is routinely called on the SelectorManager's thread.

wakeup() - Method in class rice.pastry.wire.SocketManager

Specified by the SelectionKeyHandler interface - does nothing.

wasAdded() - Method in class rice.pastry.NodeSetUpdate

Returns true if the handle was added to the set.

write(NodeId, InetSocketAddress, Object) - Method in class rice.pastry.wire.DatagramManager

Method designed for node handles to use when they wish to write to their remote node.

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

Specified by the SelectionKeyHandler interface - is called when there is space in the DatagramChannel's buffer to write some data.

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

Method which is called when the key becomes writable.

write(SocketChannel) - Method in class rice.pastry.wire.SocketChannelWriter

Method which is designed to be called when this writer should write out its data.

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

Specified by the SelectionKeyHandler interface - should NEVER be called!

write(SelectionKey) - Method in class rice.pastry.wire.StaleSKH

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

X

xor(Id) - Method in class rice.pastry.Id

Xor operator for Ids.

_

_content - Variable in class rice.past.messaging.MessageFetch

Deprecated. Content to be returned

_content - Variable in class rice.past.messaging.MessageLookup

Deprecated. Content to be returned

_exists - Variable in class rice.past.messaging.MessageExists

Deprecated. Content to be returned

_file - Variable in class rice.past.messaging.MessageInsert

Deprecated. The file to insert.

_fileId - Variable in class rice.past.messaging.PASTMessage

Deprecated. The fileId of the file, to be used as destination.

_handleResponseMessage(PASTMessage) - Method in class rice.past.PASTServiceImpl

Deprecated. Receives a response message after a request has been sent and gives it to the appropriate command.

_messageID - Variable in class rice.past.messaging.PASTMessage

Deprecated. A key for uniquely identifying the message.

_messageType - Variable in class rice.past.messaging.PASTMessage

Deprecated. Whether this is a request or a response.

_sendOptions - Variable in class rice.rm.RMImpl

The SendOptions object to be used for all messaging through Pastry.

_sendOptions - Variable in class rice.rm.testing.RMRegrTestApp

_sendRequestMessage(PASTMessage, Continuation) - Method in class rice.past.PASTServiceImpl

Deprecated. Sends a request message and stores the given command to be executed when the response is received.

_senderId - Variable in class rice.past.messaging.PASTMessage

Deprecated. The id of the sender

_seqno - Variable in class rice.rm.messaging.RMMessage

for debugging purposes only

_source - Variable in class rice.rm.messaging.RMMessage

The ID of the source of this message.

_source - Variable in class rice.rm.testing.TestMessage

The ID of the source of this message.

_success - Variable in class rice.past.messaging.MessageInsert

Deprecated. Whether the insert was successful (on a response).

_success - Variable in class rice.past.messaging.MessageReclaim

Deprecated. Whether the reclaim request was successful

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