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

A

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

AbstractLogManager - Class in rice.environment.logging

AbstractLogManager(PrintStream, TimeSource, Parameters, String, String) - Constructor for class rice.environment.logging.AbstractLogManager

AbstractSubscribeMessage - Class in rice.p2p.scribe.messaging

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

Constructor which takes a unique integer Id

AbstractSubscribeMessage(InputBuffer, Endpoint) - Constructor for class rice.p2p.scribe.messaging.AbstractSubscribeMessage

Protected because it should only be called from an extending class, to get version numbers correct.

accept(SelectionKey) - Method in class org.mpisws.p2p.transport.wire.TCPLayer

Specified by the SelectionKeyHandler interface.

accept(AppSocketReceiver) - Method in interface rice.p2p.commonapi.Endpoint

Set's the acceptor for this application.

accept(AppSocketReceiver) - Method in class rice.p2p.multiring.MultiringEndpoint

accept(AppSocketReceiver) - Method in class rice.p2p.past.gc.GCEndpoint

accept(AppSocketReceiver) - Method in class rice.pastry.client.PastryAppl

Sets an AppSocketReceiver to be called when the next socket arrives.

accept(SelectionKey) - Method in class rice.pastry.socket.SocketCollectionManager

Specified by the SelectionKeyHandler interface.

accept(SelectionKey) - Method in class rice.selector.SelectionKeyHandler

Method which is called when the key becomes acceptable.

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

acceptAppSocket(SocketAppSocket, int) - Method in class rice.pastry.socket.SocketPastryNode

acceptAppSocket(int) - Method in class rice.pastry.transport.TLPastryNode

acceptConnection(SelectionKey) - Method in class rice.pastry.socket.SocketAppSocket

Accepts a new connection on the given key these methods (createConnection/acceptConnection) could be synchronized, but they are only called in the constructor who does not expose his reference.

acceptConnection(SelectionKey) - Method in class rice.pastry.socket.SocketCollectionManager.SocketAccepter

Accepts a new connection on the given key

acceptConnection(SelectionKey) - Method in class rice.pastry.socket.SocketCollectionManager.SourceRouteManager

Accepts a new connection on the given key

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

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

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

Accept join request.

acceptMessages(boolean) - Method in class org.mpisws.p2p.transport.commonapi.CommonAPITransportLayerImpl

acceptMessages(boolean) - Method in class org.mpisws.p2p.transport.liveness.LivenessTransportLayerImpl

acceptMessages(boolean) - Method in class org.mpisws.p2p.transport.multiaddress.MultiInetAddressTransportLayerImpl

acceptMessages(boolean) - Method in class org.mpisws.p2p.transport.priority.PriorityTransportLayerImpl

acceptMessages(boolean) - Method in class org.mpisws.p2p.transport.sourceroute.manager.SourceRouteManagerImpl

acceptMessages(boolean) - Method in class org.mpisws.p2p.transport.sourceroute.SourceRouteTransportLayerImpl

acceptMessages(boolean) - Method in interface org.mpisws.p2p.transport.TransportLayer

Toggle accepting incoming messages.

acceptMessages(boolean) - Method in class org.mpisws.p2p.transport.wire.magicnumber.MagicNumberTransportLayer

acceptMessages(boolean) - Method in class org.mpisws.p2p.transport.wire.UDPLayer

acceptMessages(boolean) - Method in class org.mpisws.p2p.transport.wire.WireTransportLayerImpl

acceptSockets(boolean) - Method in class org.mpisws.p2p.transport.commonapi.CommonAPITransportLayerImpl

acceptSockets(boolean) - Method in class org.mpisws.p2p.transport.liveness.LivenessTransportLayerImpl

acceptSockets(boolean) - Method in class org.mpisws.p2p.transport.multiaddress.MultiInetAddressTransportLayerImpl

acceptSockets(boolean) - Method in class org.mpisws.p2p.transport.priority.PriorityTransportLayerImpl

acceptSockets(boolean) - Method in class org.mpisws.p2p.transport.sourceroute.manager.SourceRouteManagerImpl

acceptSockets(boolean) - Method in class org.mpisws.p2p.transport.sourceroute.SourceRouteTransportLayerImpl

acceptSockets(boolean) - Method in interface org.mpisws.p2p.transport.TransportLayer

Toggle accepting new sockets.

acceptSockets(boolean) - Method in class org.mpisws.p2p.transport.wire.magicnumber.MagicNumberTransportLayer

acceptSockets(boolean) - Method in class org.mpisws.p2p.transport.wire.TCPLayer

acceptSockets(boolean) - Method in class org.mpisws.p2p.transport.wire.WireTransportLayerImpl

ack(MessageRequestHandle<Identifier, MessageType>) - Method in interface org.mpisws.p2p.transport.MessageCallback

Layer specific callback.

ack(MessageRequestHandle<NodeHandle, RawMessage>) - Method in class rice.p2p.util.MCAdapter

ackMessageReceived(SubscribeAckMessage) - Method in class rice.p2p.scribe.ScribeImpl

Internal method which processes an ack message

activeFetches - Variable in class rice.p2p.glacier.v2.GlacierStatistics

add(byte[]) - Method in class rice.p2p.glacier.v2.BloomFilter

add(Object) - Method in class rice.p2p.multiring.MultiringIdFactory.MultiringEntrySet

add(Object) - Method in class rice.p2p.multiring.MultiringIdFactory.MultiringKeySet

add(Object) - Method in class rice.p2p.past.gc.GCIdFactory.GCEntrySet

add(byte[]) - Method in class rice.p2p.util.BloomFilter

Method which adds an element to this bloom filter.

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

Returns an Id corresponding to this Id plus a given distance

addAggregateDescriptor(AggregateDescriptor) - Method in class rice.p2p.aggregation.AggregateList

addAll(Collection) - Method in class rice.p2p.multiring.MultiringIdFactory.MultiringEntrySet

addAll(Collection) - Method in class rice.p2p.multiring.MultiringIdFactory.MultiringKeySet

addAll(Collection) - Method in class rice.p2p.past.gc.GCIdFactory.GCEntrySet

addAttribute(String, String) - Method in class rice.p2p.util.XMLParser

Internal method which adds an attributes

addBinding(UpperIdentifier, LowerIdentifier) - Method in class org.mpisws.p2p.transport.identity.IdentityImpl

addChangeListener(ParameterChangeListener) - Method in interface rice.environment.params.Parameters

addChangeListener(ParameterChangeListener) - Method in class rice.environment.params.simple.SimpleParameters

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

Adds a child to the given topic

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

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 Need to be holding lock: topicManagers

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

Adds a child to the given topic, using the specified sequence number in the ack message sent to the child.

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

Adds a feature to the Client attribute of the TopicManager object

addDestructable(Destructable) - Method in class rice.environment.Environment

addDestructable(Destructable) - Method in class rice.pastry.PastryNode

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

addHardLink(SourceRouteManagerImpl<Identifier>.AddressManager) - Method in class org.mpisws.p2p.transport.sourceroute.manager.SourceRouteManagerImpl

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.

addHop(NodeHandle) - Method in class rice.tutorial.forwarding.MyMsg

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.p2p.glacier.FragmentKeySet

add a member

addId(Id) - Method in class rice.p2p.glacier.VersionKeySet

add a member

addId(Id) - Method in class rice.p2p.multiring.MultiringIdSet

add a member

addId(Id) - Method in class rice.p2p.past.gc.GCIdSet

add a member

addId(Id) - Method in class rice.p2p.util.IdBloomFilter

Method which adds an Id to the underlying bloom filter

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

add a member

addIntendedDest(UpperIdentifier) - Method in class org.mpisws.p2p.transport.identity.IdentityImpl

Returns the identifier.

addInterestOp(SelectableChannel, int) - Method in class rice.pastry.socket.SocketCollectionManager.SourceRouteManager

Internal method which adds an interest op to the given channel's interest set.

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

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

addLeafSetListener(NodeSetListener) - Method in class rice.pastry.PastryNode

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

Deprecated. use addLeafSetListener

addLivenessListener(LivenessListener<TransportLayerNodeHandle<Identifier>>) - Method in class org.mpisws.p2p.transport.commonapi.CommonAPITransportLayerImpl

addLivenessListener(LivenessListener<Identifier>) - Method in interface org.mpisws.p2p.transport.liveness.LivenessProvider

addLivenessListener(LivenessListener<Identifier>) - Method in class org.mpisws.p2p.transport.liveness.LivenessTransportLayerImpl

addLivenessListener(LivenessListener<Identifier>) - Method in class org.mpisws.p2p.transport.sourceroute.manager.SourceRouteManagerImpl

addLivenessListener(LivenessListener<NodeHandle>) - Method in class rice.pastry.direct.DirectPastryNode

addLivenessListener(LivenessListener<NodeHandle>) - Method in class rice.pastry.socket.SocketPastryNode

addLivenessListener(LivenessListener<NodeHandle>) - Method in class rice.pastry.transport.TLPastryNode

addLoopObserver(LoopObserver) - Method in class rice.selector.SelectorManager

addMember(Id) - Method in class rice.p2p.glacier.FragmentKeySet

add a member

addMember(Id) - Method in class rice.p2p.glacier.VersionKeySet

add a member

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

add a member

addNetworkListener(NetworkListener) - Method in class rice.pastry.dist.DistPastryNode

addNode(MultiringNode) - Method in class rice.p2p.multiring.MultiringNodeCollection

This method allows other nodes to be dynamically added to the node collection.

addNodeSetListener(NodeSetListener) - Method in class rice.pastry.leafset.LeafSet

Add observer method.

addNodeSetListener(NodeSetListener) - Method in class rice.pastry.leafset.SimilarSet

addNodeSetListener(NodeSetListener) - Method in interface rice.pastry.NodeSetEventSource

addNodeSetListener(NodeSetListener) - Method in class rice.pastry.routing.RoutingTable

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

Deprecated. use addNodeSetListener

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

Deprecated. use addNodeSetListener

addObserver(Observer) - Method in class rice.pastry.NodeHandle

addObserver(Observer, int) - Method in class rice.pastry.NodeHandle

addObserver(Observer) - Method in class rice.pastry.routing.RoutingTable

Deprecated. use addNodeSetListener

addPendingMessage(UpperIdentifier, IdentityImpl<UpperIdentifier, UpperMsgType, LowerIdentifier>.IdentityMessageHandle) - Method in class org.mpisws.p2p.transport.identity.IdentityImpl

addPingListener(PingListener<Identifier>) - Method in class org.mpisws.p2p.transport.liveness.LivenessTransportLayerImpl

addPingListener(PingListener<Identifier>) - Method in interface org.mpisws.p2p.transport.liveness.Pinger

addPingResponseListener(SourceRoute, PingResponseListener) - Method in class rice.pastry.socket.PingManager

Adds a feature to the PingResponseListener attribute of the PingManager object

addProximityListener(ProximityListener<TransportLayerNodeHandle<Identifier>>) - Method in class org.mpisws.p2p.transport.commonapi.CommonAPITransportLayerImpl

addProximityListener(ProximityListener<Identifier>) - Method in class org.mpisws.p2p.transport.proximity.MinRTTProximityProvider

addProximityListener(ProximityListener<Identifier>) - Method in interface org.mpisws.p2p.transport.proximity.ProximityProvider

addProximityListener(ProximityListener<Identifier>) - Method in class org.mpisws.p2p.transport.sourceroute.manager.SourceRouteManagerImpl

addr - Variable in exception org.mpisws.p2p.transport.wire.exception.StalledSocketException

addReplica(NodeHandle, GCId) - Method in class rice.p2p.past.gc.GCPastImpl.ReplicaMap

address - Variable in class org.mpisws.p2p.transport.multiaddress.MultiInetSocketAddress

address - Variable in class org.mpisws.p2p.transport.sourceroute.manager.SourceRouteManagerImpl.AddressManager

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

address - Variable in class rice.pastry.socket.EpochInetSocketAddress

address - Variable in class rice.pastry.socket.messaging.IPAddressResponseMessage

address - Variable in class rice.pastry.socket.SocketSourceRouteManager.AddressManager

addressEquals(MultiInetSocketAddress) - Method in class org.mpisws.p2p.transport.multiaddress.MultiInetSocketAddress

addressEquals(EpochInetSocketAddress) - Method in class rice.pastry.socket.EpochInetSocketAddress

addresses - Variable in class rice.pastry.transport.BogusNodeHandle

AddressStrategy - Interface in org.mpisws.p2p.transport.multiaddress

Return the InetSocketAddress to use for this EpochInetSocketAddress

addRouteSetListener(NodeSetListener) - Method in class rice.pastry.PastryNode

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

Deprecated. use addRouteSetListener

addSimulatorListener(SimulatorListener) - Method in class rice.pastry.direct.BasicNetworkSimulator

addSimulatorListener(SimulatorListener) - Method in interface rice.pastry.direct.NetworkSimulator

addSourceRouteTap(SourceRouteTap) - Method in interface org.mpisws.p2p.transport.sourceroute.SourceRouteTransportLayer

addSourceRouteTap(SourceRouteTap) - Method in class org.mpisws.p2p.transport.sourceroute.SourceRouteTransportLayerImpl

addStat(String, long) - Method in class rice.selector.ProfileSelector

addStatisticsListener(GlacierStatisticsListener) - Method in class rice.p2p.glacier.v2.GlacierImpl

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

This method should be invoked after the state change in the Topic Manager has been made.

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

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.p2p.glacier.FragmentKey

Adds a feature to the ToId attribute of the FragmentKey object

addToId(Id.Distance) - Method in class rice.p2p.glacier.VersionKey

addToId(Id.Distance) - Method in class rice.p2p.multiring.RingId

Returns an Id corresponding to this Id plus a given distance

addToId(Id.Distance) - Method in class rice.p2p.past.gc.GCId

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

addToId(Id.Distance) - Method in class rice.persistence.testing.MemoryStorageTest.VariableId

addToLeafSet(NodeHandle) - Method in class rice.pastry.standard.ConsistentJoinProtocol

Observes all NodeHandles added to LeafSet

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

Adds a node to the visited list

Aggregate - Class in rice.p2p.aggregation

Aggregate(GCPastContent[], Id[]) - Constructor for class rice.p2p.aggregation.Aggregate

AggregateFactory - Interface in rice.p2p.aggregation

aggregateFactory - Variable in class rice.p2p.aggregation.AggregationImpl

AggregateHandle - Class in rice.p2p.aggregation

AggregateHandle(NodeHandle, Id, long, long) - Constructor for class rice.p2p.aggregation.AggregateHandle

AggregateHandle(InputBuffer, Endpoint) - Constructor for class rice.p2p.aggregation.AggregateHandle

aggregateLifetimeHisto - Variable in class rice.p2p.aggregation.AggregationStatistics

AggregateList - Class in rice.p2p.aggregation

AggregateList(String, String, IdFactory, boolean, String, Environment) - Constructor for class rice.p2p.aggregation.AggregateList

aggregateList - Variable in class rice.p2p.aggregation.AggregateList

aggregateList - Variable in class rice.p2p.aggregation.AggregationImpl

aggregateStore - Variable in class rice.p2p.aggregation.AggregationImpl

Aggregation - Interface in rice.p2p.aggregation

AggregationDefaultPolicy - Class in rice.p2p.aggregation

AggregationDefaultPolicy() - Constructor for class rice.p2p.aggregation.AggregationDefaultPolicy

AggregationException - Exception in rice.p2p.aggregation

AggregationException(String) - Constructor for exception rice.p2p.aggregation.AggregationException

AggregationImpl - Class in rice.p2p.aggregation

AggregationImpl(Node, Past, Past, StorageManager, String, IdFactory, String) - Constructor for class rice.p2p.aggregation.AggregationImpl

AggregationImpl(Node, Past, Past, StorageManager, String, IdFactory, String, AggregationPolicy, AggregateFactory) - Constructor for class rice.p2p.aggregation.AggregationImpl

AggregationMessage - Class in rice.p2p.aggregation.messaging

AggregationMessage(int, NodeHandle, Id) - Constructor for class rice.p2p.aggregation.messaging.AggregationMessage

Constructor which takes a unique integer Id

AggregationPolicy - Interface in rice.p2p.aggregation

AggregationStatistics - Class in rice.p2p.aggregation

AggregationStatistics(int, long, Environment) - Constructor for class rice.p2p.aggregation.AggregationStatistics

AggregationTimeoutMessage - Class in rice.p2p.aggregation.messaging

AggregationTimeoutMessage(int, NodeHandle) - Constructor for class rice.p2p.aggregation.messaging.AggregationTimeoutMessage

ALL - Static variable in class rice.environment.logging.Logger

ALL indicates that all messages should be logged.

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

This contains a mapping of child - > all topics for which the local node has this node(hashtable key) as a child

ALLOW_SOURCE_ROUTE - Static variable in interface org.mpisws.p2p.transport.sourceroute.SourceRouteTransportLayer

allowInsert(PastContent) - Method in interface rice.p2p.past.PastPolicy

This method is call before an insert() is processed on the local node.

allowInsert(PastContent) - Method in class rice.p2p.past.PastPolicy.DefaultPastPolicy

This method always return true;

allowSubscribe(Scribe, NodeHandle, List<Topic>, ScribeContent) - 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(Scribe, NodeHandle, List<Topic>, ScribeContent) - Method in class rice.p2p.scribe.ScribePolicy.DefaultScribePolicy

If you don't override the deprecated allowSubscribe(), This method always return true;

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

This method should be deprecated, but is here for reverse compatibility.

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

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

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.

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

This contains a mapping of parent - > all topics for which the local node has this node(hashtable key) as a parent

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

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

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

ALWAYS - Static variable in class rice.pastry.socket.CopyOfSocketPastryNodeFactory

am - Variable in class rice.pastry.socket.SocketCollectionManager.MessageRetry

anycast(Topic, ScribeContent) - Method in class rice.p2p.multiring.MultiringNode

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

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

Anycasts the given content to a member of the given topic

anycast(Topic, ScribeContent, NodeHandle) - Method in interface rice.p2p.scribe.javaserialized.JavaScribe

Anycasts the given content to a member of the given topic The hint helps us to implement centralized algorithms where the hint is the cachedRoot for the topic.

anycast(Topic, RawScribeContent) - Method in interface rice.p2p.scribe.rawserialization.RawScribe

Anycasts the given content to a member of the given topic

anycast(Topic, RawScribeContent, NodeHandle) - Method in interface rice.p2p.scribe.rawserialization.RawScribe

Anycasts the given content to a member of the given topic The hint helps us to implement centralized algorithms where the hint is the cachedRoot for the topic.

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

Deprecated. 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, NodeHandle) - Method in class rice.p2p.scribe.ScribeImpl

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

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

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

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

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.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(Topic, ScribeContent) - Method in class rice.tutorial.scribe.MyScribeClient

Called when we receive an anycast.

AnycastFailureMessage - Class in rice.p2p.scribe.messaging

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

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

AnycastMessage - Class in rice.p2p.scribe.messaging

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

Constructor which takes a unique integer Id

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

AnycastMessage(InputBuffer, Endpoint, ScribeContentDeserializer) - Constructor for class rice.p2p.scribe.messaging.AnycastMessage

Protected because it should only be called from an extending class, to get version numbers correct.

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

The publish messages received so far

apop(byte[], byte[]) - Static method in class rice.p2p.util.SecurityUtils

Utility method for determining the apop of a challenge and password using a secure hashing algorithm.

APOP_ALGORITHM - Static variable in class rice.p2p.util.SecurityUtils

The name of the apop function.

append(char[], int, int) - Method in class rice.p2p.util.XMLParser.CharArrayBuffer

Appends some more chars!

append(EpochInetSocketAddress) - Method in class rice.pastry.socket.SourceRoute

Method which creates a new source route by appending the given address to the end of this one

Application - Interface in rice.p2p.commonapi

application - Variable in class rice.p2p.multiring.messaging.RingMessage

The name of the application which sent this message

application - Variable in class rice.p2p.multiring.MultiringApplication

The app which this mulitring app is wrapping

application - Variable in class rice.p2p.multiring.MultiringEndpoint

The application this endpoint is for

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

AppNotRegisteredException - Exception in rice.p2p.commonapi.exception

The application has not been registered on that node.

AppNotRegisteredException(int) - Constructor for exception rice.p2p.commonapi.exception.AppNotRegisteredException

apps - Variable in class rice.pastry.PastryNode

AppSocket - Interface in rice.p2p.commonapi.appsocket

Interface for sending bulk data from the application.

appSocketClosed(SocketAppSocket) - Method in class rice.pastry.socket.SocketCollectionManager

Method which is designed to be called *ONCE THE SOCKET HAS BEEN CLOSED*.

AppSocketException - Exception in rice.p2p.commonapi.exception

AppSocketException() - Constructor for exception rice.p2p.commonapi.exception.AppSocketException

AppSocketException(Throwable) - Constructor for exception rice.p2p.commonapi.exception.AppSocketException

AppSocketException(String) - Constructor for exception rice.p2p.commonapi.exception.AppSocketException

appSocketOpened(SocketAppSocket) - Method in class rice.pastry.socket.SocketCollectionManager

AppSocketReceiver - Interface in rice.p2p.commonapi.appsocket

Interface to receive an application level socket.

AppSocketReceiverWrapper - Class in rice.pastry.transport

AppSocketReceiverWrapper(AppSocketReceiver, SocketAdapter, Environment) - Constructor for class rice.pastry.transport.AppSocketReceiverWrapper

appSockets - Variable in class rice.pastry.socket.SocketCollectionManager

array - Variable in class rice.p2p.util.IdBloomFilter

An internal byte[] for managing ids in a memory-efficent manner The deal with this is that we will be creating a ton of arrays in addId/check.

asArray() - Method in interface rice.p2p.commonapi.IdSet

return this set as an array

asArray() - Method in class rice.p2p.glacier.FragmentKeySet

return this set as an array

asArray() - Method in class rice.p2p.glacier.VersionKeySet

return this set as an array

asArray() - Method in class rice.p2p.multiring.MultiringIdSet

return this set as an array

asArray() - Method in class rice.p2p.past.gc.GCIdSet

return this set as an array

asArray() - Method in class rice.pastry.IdSet

return this set as an array

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

If overlaps() a NodeHandle may show up twice.

asList() - Method in class rice.pastry.routing.RoutingTable

Does not return self

assertAttribute(String, String) - Method in class rice.p2p.util.XMLReader

Asserts that the given attribute exists and is equal to the given value.

assertEndTag() - Method in class rice.p2p.util.XMLReader

Asserts that a end tag was just read

assertEndTag(String) - Method in class rice.p2p.util.XMLReader

Asserts that the provided end tag was just read

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

Thows an exception if expected is not equal to actual.

assertEquals(String, Object, Object) - Method in class rice.p2p.multiring.testing.MultiringRegrTest

Thows an exception if expected is not equal to actual.

assertEvent(int) - Method in class rice.p2p.util.XMLReader

Asserts that the given event type just happened.

assertLocalNode() - Method in class rice.pastry.direct.DirectNodeHandle

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.

assertStartTag() - Method in class rice.p2p.util.XMLReader

Asserts that a start tag was just read

assertStartTag(String) - Method in class rice.p2p.util.XMLReader

Asserts that the provided start tag was just read

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

Throws an exception if the test condition is not met.

assertTrue(String, boolean) - Method in class rice.p2p.multiring.testing.MultiringRegrTest

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.

assignedIndices - Variable in class rice.pastry.direct.GenericNetwork

assignReference() - Method in class rice.p2p.util.XMLObjectOutputStream

Method which assigns a new unique reference.

ASYMMETRIC_ALGORITHM - Static variable in class rice.p2p.util.SecurityUtils

The name of the asymmetric cipher to use.

ASYMMETRIC_GENERATOR - Static variable in class rice.p2p.util.SecurityUtils

The name of the asymmetric generator to use.

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.

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

attribute(String, int) - Method in class rice.p2p.util.XMLWriter

Method which writes an attribute to the XML document.

attribute(String, double) - Method in class rice.p2p.util.XMLWriter

Method which writes an attribute to the XML document.

attribute(String, float) - Method in class rice.p2p.util.XMLWriter

Method which writes an attribute to the XML document.

attribute(String, long) - Method in class rice.p2p.util.XMLWriter

Method which writes an attribute to the XML document.

attribute(String, char) - Method in class rice.p2p.util.XMLWriter

Method which writes an attribute to the XML document.

attribute(String, boolean) - Method in class rice.p2p.util.XMLWriter

Method which writes an attribute to the XML document.

attribute(String, Object) - Method in class rice.p2p.util.XMLWriter

Method which writes an attribute to the XML document.

attribute(String, String) - Method in class rice.p2p.util.XMLWriter

Method which writes an attribute to the XML document.

attributeKeys - Variable in class rice.p2p.util.XMLParser

If the tag parsed was a start tag, the list of attribute-> value pairs

attributeValues - Variable in class rice.p2p.util.XMLParser

authoritative - Variable in class rice.p2p.glacier.v2.messaging.GlacierResponseMessage

available() - Method in class rice.p2p.util.EncryptedInputStream

Returns the number of bytes that can be read (or skipped over) from this input stream without blocking by the next caller of a method for this input stream.

B

BACKOFF_INITIAL - Variable in class org.mpisws.p2p.transport.liveness.LivenessTransportLayerImpl

BACKOFF_INITIAL - Variable in class rice.pastry.socket.SocketCollectionManager

BACKOFF_LIMIT - Variable in class org.mpisws.p2p.transport.liveness.LivenessTransportLayerImpl

BACKOFF_LIMIT - Variable in class rice.pastry.socket.SocketCollectionManager

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

BACKUP_DIRECTORY - Static variable in class rice.persistence.PersistentStorage

Static variables which define the location of the storage root

BAD_HDR - Static variable in class org.mpisws.p2p.testing.transportlayer.MagicNumberTest

Goes to Carol

bais - Variable in class rice.p2p.util.testing.XMLObjectStreamUnit

baos - Variable in class rice.p2p.util.testing.XMLObjectStreamUnit

BASE - Variable in class rice.p2p.multiring.MultiringNodeCollection

The routing base for ring ids, in bytes

Base64 - Class in rice.p2p.util

Base64.InputStream - Class in rice.p2p.util

A Base64#InputStream will read data from another InputStream, given in the constructor, and encode/decode to/from Base64 notation on the fly.

Base64.InputStream(InputStream) - Constructor for class rice.p2p.util.Base64.InputStream

Constructs a Base64#InputStream in DECODE mode.

Base64.InputStream(InputStream, int) - Constructor for class rice.p2p.util.Base64.InputStream

Constructs a Base64#InputStream in either ENCODE or DECODE mode.

Base64.OutputStream - Class in rice.p2p.util

A Base64#OutputStream will write data to another OutputStream, given in the constructor, and encode/decode to/from Base64 notation on the fly.

Base64.OutputStream(OutputStream) - Constructor for class rice.p2p.util.Base64.OutputStream

Constructs a Base64#OutputStream in ENCODE mode.

Base64.OutputStream(OutputStream, int) - Constructor for class rice.p2p.util.Base64.OutputStream

Constructs a Base64#OutputStream in either ENCODE or DECODE mode.

baseBitLength() - Method in class rice.pastry.routing.RoutingTable

return the bit length of the base

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

BaseScribe - Interface in rice.p2p.scribe

Scribe functions not specific to serialization type.

BasicNetworkSimulator - Class in rice.pastry.direct

BasicNetworkSimulator(Environment) - Constructor for class rice.pastry.direct.BasicNetworkSimulator

best - Variable in class org.mpisws.p2p.transport.sourceroute.manager.SourceRouteManagerImpl.AddressManager

the current best route to this remote address if best == null, we are already in a CheckDead, which means we are searching for a path

best - Variable in class rice.pastry.socket.SocketSourceRouteManager.AddressManager

the current best route to this remote address if best == null, we are already in a CheckDead, which means we are searching for a path

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

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

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

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

bindAddress - Variable in class org.mpisws.p2p.transport.wire.WireTransportLayerImpl

bindings - Variable in class org.mpisws.p2p.transport.identity.IdentityImpl

Multiple UpperIdentifiers claim the same binding to the LowerIdentifier.

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

Blits the Id into a target array.

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

Blits the distance into a target array, starting at the given offset.

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

Blits the distance into a target array.

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

Blits the distance into a target array, starting at the given offset.

BlockingAppSocketFactory - Class in rice.pastry.socket.appsocket

BlockingAppSocketFactory() - Constructor for class rice.pastry.socket.appsocket.BlockingAppSocketFactory

BlockingIOThread - Class in rice.environment.processing.simple

BlockingIOThread(WorkQueue) - Constructor for class rice.environment.processing.simple.BlockingIOThread

BloomFilter - Class in rice.p2p.glacier.v2

BloomFilter(int, int[]) - Constructor for class rice.p2p.glacier.v2.BloomFilter

BloomFilter(int, int, RandomSource) - Constructor for class rice.p2p.glacier.v2.BloomFilter

BloomFilter(InputBuffer) - Constructor for class rice.p2p.glacier.v2.BloomFilter

BloomFilter - Variable in class rice.p2p.glacier.v2.messaging.GlacierSyncMessage

BloomFilter - Class in rice.p2p.util

BloomFilter(int, int) - Constructor for class rice.p2p.util.BloomFilter

Constructor which takes the number of hash functions to use and the length of the set to use.

BloomFilter(InputBuffer) - Constructor for class rice.p2p.util.BloomFilter

BloomFilterUnit - Class in rice.p2p.util.testing

BloomFilterUnit() - Constructor for class rice.p2p.util.testing.BloomFilterUnit

BLS_THROTTLE - Variable in class rice.pastry.standard.PeriodicLeafSetProtocol

bogus() - Method in class org.mpisws.p2p.testing.transportlayer.EpochTest

To fool eclips's testing harness.

bogus() - Method in class org.mpisws.p2p.testing.transportlayer.PriorityTest

bogus() - Method in class org.mpisws.p2p.testing.transportlayer.WireTest

BogusNodeHandle - Class in rice.pastry.transport

BogusNodeHandle(InetSocketAddress) - Constructor for class rice.pastry.transport.BogusNodeHandle

BogusNodeHandle(InetSocketAddress[]) - Constructor for class rice.pastry.transport.BogusNodeHandle

boot(Collection) - Method in class rice.pastry.boot.BootstrapApp

boot(Collection<Identifier>) - Method in interface rice.pastry.boot.Bootstrapper

BOOTNODE - Static variable in class rice.p2p.splitstream.testing.SplitStreamDistTest

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

bootstrap(Message) - Method in class rice.pastry.NodeHandle

Method which is used by Pastry to start the bootstrapping process on the local node using this handle as the bootstrap handle.

bootstrap(SourceRoute, Message) - Method in class rice.pastry.socket.SocketCollectionManager

Method which sends bootstraps a node by sending message across the wire, using a fake IP address in the header so that the local node is not marked alive, and then closes the connection.

bootstrap(Message) - Method in class rice.pastry.socket.SocketNodeHandle

Method which is used by Pastry to start the bootstrapping process on the local node using this handle as the bootstrap handle.

bootstrap(EpochInetSocketAddress, Message) - Method in class rice.pastry.socket.SocketSourceRouteManager

Method which sends a bootstrap message across the wire.

bootstrap - Variable in class rice.pastry.testing.PastryNetworkTest

BOOTSTRAP_HOST - Static variable in class rice.p2p.multiring.testing.MultiringRegrTest

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

BOOTSTRAP_PORT - Static variable in class rice.p2p.multiring.testing.MultiringRegrTest

BootstrapApp - Class in rice.pastry.boot

Simple bootstrapper.

BootstrapApp(PastryNode, LivenessProvider<NodeHandle>) - Constructor for class rice.pastry.boot.BootstrapApp

Bootstrapper<Identifier> - Interface in rice.pastry.boot

bootstraps - Variable in class rice.p2p.multiring.RingCertificate

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.

broadcastAll() - Method in class rice.pastry.standard.PeriodicLeafSetProtocol

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

broadcastChannelClosed(InetSocketAddress) - Method in class rice.pastry.dist.DistPastryNode

broadcastChannelOpened(InetSocketAddress, int) - Method in class rice.pastry.dist.DistPastryNode

BroadcastLeafSet - Class in rice.pastry.leafset

Broadcast a leaf set to another node.

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

Constructor.

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

Constructor.

BroadcastLeafSet(InputBuffer, NodeHandleFactory) - Constructor for class rice.pastry.leafset.BroadcastLeafSet

broadcastNewNode(MultiringNode) - Method in class rice.p2p.multiring.MultiringNodeCollection

This method informs all of the existing nodes of the newly added node, and informs the newly added node of all of the existing nodes.

broadcastReceivedListeners(int, short, InetSocketAddress, int, int) - Method in class rice.pastry.dist.DistPastryNode

BroadcastRouteRow - Class in rice.pastry.routing

Broadcast message for a row from a routing table.

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

Constructor.

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

Constructor.

BroadcastRouteRow(InputBuffer, NodeHandleFactory, PastryNode) - Constructor for class rice.pastry.routing.BroadcastRouteRow

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

Broadcasts the route table rows.

broadcastSentListeners(int, short, InetSocketAddress, int, int) - Method in class rice.pastry.dist.DistPastryNode

bucketConsumed - Variable in class rice.p2p.glacier.v2.GlacierImpl

bucketConsumed - Variable in class rice.p2p.glacier.v2.GlacierStatistics

bucketLastUpdated - Variable in class rice.p2p.glacier.v2.GlacierImpl

bucketMax - Variable in class rice.p2p.glacier.v2.GlacierImpl

bucketMax - Variable in class rice.p2p.glacier.v2.GlacierStatistics

bucketMaxBurstSize - Variable in class rice.p2p.glacier.v2.GlacierStatistics

bucketMin - Variable in class rice.p2p.glacier.v2.GlacierImpl

bucketMin - Variable in class rice.p2p.glacier.v2.GlacierStatistics

bucketTokensPerSecond - Variable in class rice.p2p.glacier.v2.GlacierStatistics

buf() - Method in class org.mpisws.p2p.transport.util.ExposedByteArrayOutputStream

buffer - Variable in class rice.environment.logging.LogOutputStream

buffer - Variable in class rice.p2p.util.EncryptedInputStream

buffer - Variable in class rice.p2p.util.EncryptedOutputStream

buffer - Variable in class rice.p2p.util.XMLParser

The internal buffer used to process data

buffer - Variable in class rice.p2p.util.XMLParser.CharArrayBuffer

The internal buffer

BUFFER_SIZE - Static variable in class rice.environment.logging.LogOutputStream

BUFFER_SIZE - Variable in class rice.p2p.util.EncryptedOutputStream

BUFFER_SIZE - Static variable in class rice.p2p.util.XMLParser

The size of the internal buffer to allocate

bufferLength - Variable in class rice.p2p.util.EncryptedInputStream

bufferLength - Variable in class rice.p2p.util.