Rice Pastry API

Uses of Class
rice.pastry.PastryNode

Packages that use PastryNode
rice.p2p.splitstream.testing   
rice.pastry   
rice.pastry.client   
rice.pastry.commonapi   
rice.pastry.direct   
rice.pastry.join   
rice.pastry.messaging   
rice.pastry.peerreview   
rice.pastry.pns   
rice.pastry.pns.messages   
rice.pastry.routing   
rice.pastry.socket   
rice.pastry.socket.appsocket   
rice.pastry.socket.internet   
rice.pastry.socket.nat.probe   
rice.pastry.socket.nat.rendezvous   
rice.pastry.standard   
rice.pastry.testing   
rice.pastry.transport   
 

Uses of PastryNode in rice.p2p.splitstream.testing
 

Constructors in rice.p2p.splitstream.testing with parameters of type PastryNode
MySplitStreamClient(PastryNode n, java.lang.String instance)
           
 

Uses of PastryNode in rice.pastry
 

Fields in rice.pastry declared as PastryNode
protected  PastryNode NodeHandle.localnode
           
protected  PastryNode ScheduledMessage.localNode
           
 

Methods in rice.pastry that return PastryNode
 PastryNode NodeHandle.getLocalNode()
          Accessor method.
 PastryNode ScheduledMessage.getLocalNode()
           
abstract  PastryNode PastryNodeFactory.newNode()
           
abstract  PastryNode PastryNodeFactory.newNode(Id nodeId)
           
abstract  PastryNode PastryNodeFactory.newNode(NodeHandle bootstrap)
          Deprecated. use newNode() then call PastryNode.boot(address);
abstract  PastryNode PastryNodeFactory.newNode(NodeHandle bootstrap, Id nodeId)
          Deprecated. use newNode(nodeId) then call PastryNode.boot(address);
 

Constructors in rice.pastry with parameters of type PastryNode
ExponentialBackoffScheduledMessage(PastryNode node, Message msg, Timer timer, long initialDelay, double expBase)
           
ExponentialBackoffScheduledMessage(PastryNode node, Message msg, Timer timer, long initialDelay, long initialPeriod, double expBase, long maxPeriod)
           
ScheduledMessage(PastryNode pn, Message msg)
          Constructor
 

Uses of PastryNode in rice.pastry.client
 

Fields in rice.pastry.client declared as PastryNode
protected  PastryNode PastryAppl.thePastryNode
           
 

Constructors in rice.pastry.client with parameters of type PastryNode
CommonAPIAppl(PastryNode pn)
          Constructor.
CommonAPIAppl(PastryNode pn, java.lang.String instance)
          Constructor.
PastryAppl(PastryNode pn)
          Constructor.
PastryAppl(PastryNode pn, int port)
          Constructor.
PastryAppl(PastryNode pn, java.lang.String instance)
          Constructor.
PastryAppl(PastryNode pn, java.lang.String instance, int address, MessageDeserializer md)
           
PastryAppl(PastryNode pn, java.lang.String instance, int address, MessageDeserializer md, Logger logger)
           
 

Uses of PastryNode in rice.pastry.commonapi
 

Constructors in rice.pastry.commonapi with parameters of type PastryNode
PastryEndpoint(PastryNode pn, Application application, java.lang.String instance, boolean register)
          Constructor.
PastryEndpoint(PastryNode pn, Application application, java.lang.String instance, int address, boolean register)
          Constructor.
 

Uses of PastryNode in rice.pastry.direct
 

Methods in rice.pastry.direct that return PastryNode
static PastryNode DirectPastryNode.getCurrentNode()
           
 PastryNode DirectNodeHandle.getRemote()
          Gets the Remote attribute of the DirectNodeHandle object
 PastryNode DirectPastryNodeFactory.newNode()
           
 PastryNode DirectPastryNodeFactory.newNode(Id nodeId)
          Manufacture a new Pastry node.
 PastryNode DirectPastryNodeFactory.newNode(NodeHandle bootstrap)
          Manufacture a new Pastry node.
 PastryNode DirectPastryNodeFactory.newNode(NodeHandle bootstrap, Id nodeId)
           
static PastryNode DirectPastryNode.setCurrentNode(PastryNode dpn)
          Returns the previous one.
 

Methods in rice.pastry.direct with parameters of type PastryNode
protected  Bootstrapper DirectPastryNodeFactory.getBootstrapper(PastryNode pn, NodeHandleAdapter tl, NodeHandleFactory handleFactory, ProximityNeighborSelector pns)
           
protected  TransportLayer<NodeHandle,RawMessage> DirectPastryNodeFactory.getDirectTransportLayer(PastryNode pn, NodeRecord nr)
          Override me
protected  LeafSetProtocol DirectPastryNodeFactory.getLeafSetProtocol(PastryNode pn, LeafSet leafSet, RoutingTable routeTable)
           
protected  NodeHandle DirectPastryNodeFactory.getLocalHandle(PastryNode pn, NodeHandleFactory handleFactory)
           
protected  NodeHandleAdapter DirectPastryNodeFactory.getNodeHandleAdapter(PastryNode pn, NodeHandleFactory handleFactory, TLDeserializer deserializer)
           
protected  NodeHandleFactory DirectPastryNodeFactory.getNodeHandleFactory(PastryNode pn)
           
 void NetworkSimulator.removeNode(PastryNode node)
          Registers a node handle with the simulator.
 void NetworkSimulatorImpl.removeNode(PastryNode node)
           
static PastryNode DirectPastryNode.setCurrentNode(PastryNode dpn)
          Returns the previous one.
 

Constructors in rice.pastry.direct with parameters of type PastryNode
DirectNodeHandle(PastryNode ln, NetworkSimulator sim)
          Constructor for DirectNodeHandle.
 

Uses of PastryNode in rice.pastry.join
 

Constructors in rice.pastry.join with parameters of type PastryNode
JoinRequest(InputBuffer buf, NodeHandleFactory nhf, NodeHandle sender, PastryNode localNode)
           
 

Uses of PastryNode in rice.pastry.messaging
 

Fields in rice.pastry.messaging declared as PastryNode
protected  PastryNode MessageDispatch.localNode
           
protected  PastryNode PastryObjectInputStream.node
           
protected  PastryNode JavaSerializedDeserializer.pn
           
 

Constructors in rice.pastry.messaging with parameters of type PastryNode
JavaSerializedDeserializer(PastryNode pn)
           
MessageDispatch(PastryNode pn, Deserializer deserializer)
          Constructor.
PastryObjectInputStream(java.io.InputStream stream, PastryNode node)
           
PJavaSerializedDeserializer(PastryNode pn)
           
 

Uses of PastryNode in rice.pastry.peerreview
 

Fields in rice.pastry.peerreview with type parameters of type PastryNode
 java.util.Map<PastryNode,NodeHandle> CallbackFactory.localHandleTable
           
 

Methods in rice.pastry.peerreview with parameters of type PastryNode
 NodeHandle CallbackFactory.getLocalHandle(PastryNode pn, NodeHandleFactory nhf)
           
 NodeHandleAdapter CallbackFactory.getNodeHandleAdapter(PastryNode pn, NodeHandleFactory handleFactory2, TLDeserializer deserializer)
           
 

Constructors in rice.pastry.peerreview with parameters of type PastryNode
FetchLeafsetApp(PastryNode pn, int numNeighbors)
           
PeerReviewCallbackImpl(PastryNode pn, TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,java.nio.ByteBuffer> tl, CallbackFactory nodeFactory)
           
 

Uses of PastryNode in rice.pastry.pns
 

Constructors in rice.pastry.pns with parameters of type PastryNode
PNSApplication(PastryNode pn)
           
PNSApplication(PastryNode pn, Logger logger)
           
 

Uses of PastryNode in rice.pastry.pns.messages
 

Constructors in rice.pastry.pns.messages with parameters of type PastryNode
RouteRowResponse(InputBuffer buf, PastryNode localNode, NodeHandle sender, int dest)
           
 

Uses of PastryNode in rice.pastry.routing
 

Fields in rice.pastry.routing declared as PastryNode
protected  PastryNode RoutingTable.pn
           
 

Methods in rice.pastry.routing with parameters of type PastryNode
static RouteMessage RouteMessage.build(InputBuffer buf, byte priority, PastryNode pn, NodeHandle prev, byte outputVersion)
          version 1: +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + int auxAddress + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + bool hasHndle + // if it has a destinationHandle instead of an Id +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + Id target + + (only existis if the hasHandle boolean is false + + + + + + + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + NodeHandle destinationHandle + + (used if the RouteMessage is intended for a specific node) + + (only exists if the hasHandle boolean is true) + ...
 

Constructors in rice.pastry.routing with parameters of type PastryNode
BroadcastRouteRow(InputBuffer buf, NodeHandleFactory nhf, PastryNode localNode)
           
RouteMessage(Id target, int auxAddress, NodeHandle prev, InputBuffer buf, byte priority, PastryNode pn, NodeHandle destinationHandle, byte serializeVersion)
           
RouteSet(InputBuffer buf, NodeHandleFactory nhf, PastryNode local)
           
RouteSet(int maxSize, int row, int col, PastryNode local)
           
RouteSet(int maxSize, int row, int col, PastryNode local, NodeHandle initialVal)
          Constructor.
RoutingTable(NodeHandle me, int max, byte base, PastryNode pn)
          Constructor.
 

Uses of PastryNode in rice.pastry.socket
 

Fields in rice.pastry.socket declared as PastryNode
protected  PastryNode SPNFIdentitySerializer.pn
           
protected  PastryNode SocketNodeHandleFactory.pn
           
protected  PastryNode SocketPastryNodeFactory.TLBootstrapper.pn
           
 

Methods in rice.pastry.socket that return PastryNode
 PastryNode SocketPastryNodeFactory.newNode()
          Need to boot manually.
 PastryNode SocketPastryNodeFactory.newNode(Id id)
           
 PastryNode SocketPastryNodeFactory.newNode(Id nodeId, java.net.InetSocketAddress pAddress)
          This method uses the pAddress as the outer address if it's non-null.
 PastryNode SocketPastryNodeFactory.newNode(Id nodeId, MultiInetSocketAddress pAddress)
          Method which creates a Pastry node from the next port with the specified nodeId (or one generated from the NodeIdFactory if not specified)
 PastryNode SocketPastryNodeFactory.newNode(java.net.InetSocketAddress proxyAddress)
           
 PastryNode SocketPastryNodeFactory.newNode(NodeHandle bootstrap)
          Method which creates a Pastry node from the next port with a randomly generated NodeId.
 PastryNode SocketPastryNodeFactory.newNode(NodeHandle bootstrap, Id nodeId)
          Method which creates a Pastry node from the next port with the specified nodeId (or one generated from the NodeIdFactory if not specified)
 PastryNode SocketPastryNodeFactory.newNode(NodeHandle nodeHandle, Id id, java.net.InetSocketAddress proxyAddress)
          Method which creates a Pastry node from the next port with the specified nodeId (or one generated from the NodeIdFactory if not specified)
 PastryNode SocketPastryNodeFactory.newNode(NodeHandle bootstrap, java.net.InetSocketAddress proxy)
          Method which creates a Pastry node from the next port with the specified nodeId (or one generated from the NodeIdFactory if not specified)
 

Methods in rice.pastry.socket with parameters of type PastryNode
protected  Bootstrapper SocketPastryNodeFactory.getBootstrapper(PastryNode pn, NodeHandleAdapter tl, NodeHandleFactory handleFactory, ProximityNeighborSelector pns)
           
 TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> SocketPastryNodeFactory.getBottomLayers(PastryNode pn, MultiInetSocketAddress proxyAddress)
          This is split off so we can get the IpServiceLayer easily.
protected  TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,RawMessage> SocketPastryNodeFactory.getCommonAPITransportLayer(TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,java.nio.ByteBuffer> upperIdentity, PastryNode pn, TLDeserializer deserializer)
           
protected  IdentityImpl<TransportLayerNodeHandle<MultiInetSocketAddress>,MultiInetSocketAddress,java.nio.ByteBuffer,SourceRoute<MultiInetSocketAddress>> SocketPastryNodeFactory.getIdentityImpl(PastryNode pn, SocketNodeHandleFactory handleFactory)
           
protected  IdentitySerializer<TransportLayerNodeHandle<MultiInetSocketAddress>,MultiInetSocketAddress,SourceRoute<MultiInetSocketAddress>> SocketPastryNodeFactory.getIdentiySerializer(PastryNode pn, SocketNodeHandleFactory handleFactory)
           
protected  TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> SocketPastryNodeFactory.getIpServiceTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> wtl, PastryNode pn)
           
protected  TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> SocketPastryNodeFactory.getLimitSocketsTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> mntl, PastryNode pn)
           
protected  SocketPastryNodeFactory.TransLiveness<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> SocketPastryNodeFactory.getLivenessTransportLayer(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> tl, PastryNode pn)
           
 NodeHandle SocketPastryNodeFactory.getLocalHandle(PastryNode pn, NodeHandleFactory nhf)
           
protected  TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> SocketPastryNodeFactory.getLowerIdentityLayer(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> srl, PastryNode pn, IdentityImpl<TransportLayerNodeHandle<MultiInetSocketAddress>,MultiInetSocketAddress,java.nio.ByteBuffer,SourceRoute<MultiInetSocketAddress>> identity)
           
protected  TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> SocketPastryNodeFactory.getMagicNumberTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> wtl, PastryNode pn)
           
protected  MultiAddressSourceRouteFactory SocketPastryNodeFactory.getMultiAddressSourceRouteFactory(PastryNode pn)
           
protected  TransportLayer<MultiInetSocketAddress,java.nio.ByteBuffer> SocketPastryNodeFactory.getMultiAddressSourceRouteTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> mntl, PastryNode pn, MultiInetSocketAddress localAddress)
           
protected  NextHopStrategy<MultiInetSocketAddress> SocketPastryNodeFactory.getNextHopStrategy(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> ltl, LivenessProvider<SourceRoute<MultiInetSocketAddress>> livenessProvider, Pinger<SourceRoute<MultiInetSocketAddress>> pinger, PastryNode pn, MultiInetSocketAddress proxyAddress, MultiAddressSourceRouteFactory esrFactory)
           
 NodeHandleAdapter SocketPastryNodeFactory.getNodeHandleAdapter(PastryNode pn, NodeHandleFactory handleFactory2, TLDeserializer deserializer)
           
 NodeHandleFactory SocketPastryNodeFactory.getNodeHandleFactory(PastryNode pn)
           
protected  OptionsAdder SocketPastryNodeFactory.getOptionsAdder(PastryNode pn)
           
protected  PriorityTransportLayer<MultiInetSocketAddress> SocketPastryNodeFactory.getPriorityTransportLayer(TransportLayer<MultiInetSocketAddress,java.nio.ByteBuffer> trans, LivenessProvider<MultiInetSocketAddress> liveness, ProximityProvider<MultiInetSocketAddress> prox, PastryNode pn)
           
protected  ProbeStrategy SocketPastryNodeFactory.getProbeStrategy(PastryNode pn)
           
protected  SocketCountListener<java.net.InetSocketAddress> SocketPastryNodeFactory.getSocketCountListener(PastryNode pn)
           
protected  SourceRouteForwardStrategy<MultiInetSocketAddress> SocketPastryNodeFactory.getSourceRouteForwardStrategy(PastryNode pn, MultiAddressSourceRouteFactory esrFactory)
           
protected  SocketPastryNodeFactory.TransLivenessProximity<MultiInetSocketAddress,java.nio.ByteBuffer> SocketPastryNodeFactory.getSourceRouteManagerLayer(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> ltl, LivenessProvider<SourceRoute<MultiInetSocketAddress>> livenessProvider, Pinger<SourceRoute<MultiInetSocketAddress>> pinger, PastryNode pn, MultiInetSocketAddress proxyAddress, MultiAddressSourceRouteFactory esrFactory)
           
protected  SourceRouteStrategy<MultiInetSocketAddress> SocketPastryNodeFactory.getSourceRouteStrategy(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> ltl, LivenessProvider<SourceRoute<MultiInetSocketAddress>> livenessProvider, Pinger<SourceRoute<MultiInetSocketAddress>> pinger, PastryNode pn, MultiInetSocketAddress proxyAddress, MultiAddressSourceRouteFactory esrFactory)
           
protected  TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> SocketPastryNodeFactory.getSourceRouteTransportLayer(TransportLayer<MultiInetSocketAddress,java.nio.ByteBuffer> etl, PastryNode pn, MultiAddressSourceRouteFactory esrFactory)
           
protected  SocketPastryNodeFactory.TransLivenessProximity<TransportLayerNodeHandle<MultiInetSocketAddress>,java.nio.ByteBuffer> SocketPastryNodeFactory.getUpperIdentityLayer(TransportLayer<MultiInetSocketAddress,java.nio.ByteBuffer> priorityTL, PastryNode pn, IdentityImpl<TransportLayerNodeHandle<MultiInetSocketAddress>,MultiInetSocketAddress,java.nio.ByteBuffer,SourceRoute<MultiInetSocketAddress>> identity, LivenessProvider<MultiInetSocketAddress> live, ProximityProvider<MultiInetSocketAddress> prox, OverrideLiveness<SourceRoute<MultiInetSocketAddress>> overrideLiveness)
           
protected  TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> SocketPastryNodeFactory.getWireTransportLayer(java.net.InetSocketAddress innermostAddress, PastryNode pn)
           
protected  void SocketPastryNodeFactory.registerApps(PastryNode pn, LeafSet leafSet, RoutingTable routeTable, NodeHandleAdapter nha, NodeHandleFactory handleFactory)
           
 void SocketNodeHandle.setLocalNode(PastryNode pn)
           
 

Method parameters in rice.pastry.socket with type arguments of type PastryNode
protected  void SocketPastryNodeFactory.newNodeSelector(Id nodeId, MultiInetSocketAddress proxyAddress, Continuation<PastryNode,java.io.IOException> deliverResultToMe, java.util.Map<java.lang.String,java.lang.Object> initialVars)
          Only call this on the selector thread.
 

Constructors in rice.pastry.socket with parameters of type PastryNode
SocketNodeHandle(MultiInetSocketAddress eisa, long epoch, Id id, PastryNode node)
           
SocketNodeHandleFactory(PastryNode pn)
           
SocketPastryNodeFactory.TLBootstrapper(PastryNode pn, TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,RawMessage> tl, SocketNodeHandleFactory handleFactory, ProximityNeighborSelector pns)
           
SPNFIdentitySerializer(PastryNode pn, SocketNodeHandleFactory factory)
           
 

Uses of PastryNode in rice.pastry.socket.appsocket
 

Methods in rice.pastry.socket.appsocket with parameters of type PastryNode
protected  SocketPastryNodeFactory.TransLiveness<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> AppSocketPastryNodeFactory.getLivenessTransportLayer(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> tl, PastryNode pn)
          If it's for a remote node, eliminate the liveness layer, and just return bogus results
protected  TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> AppSocketPastryNodeFactory.getWireTransportLayer(java.net.InetSocketAddress innermostAddress, PastryNode pn)
          This code tells the WireTransportLayerImpl not to create a server-socket if we are using the BogusTLPastryNode
 

Uses of PastryNode in rice.pastry.socket.internet
 

Method parameters in rice.pastry.socket.internet with type arguments of type PastryNode
protected  void InternetPastryNodeFactory.findExternalAddress(Id nodeId, java.net.InetSocketAddress bindAddress, Continuation<PastryNode,java.io.IOException> deliverResultToMe)
          Finds the external address, calls openFirewallPort()
protected  void InternetPastryNodeFactory.findExternalAddressHelper(Id nodeId, java.net.InetSocketAddress bindAddress, Continuation<PastryNode,java.io.IOException> deliverResultToMe, java.util.Collection<java.net.InetSocketAddress> myProbeAddresses)
           
protected  void InternetPastryNodeFactory.findExternalNodes(Id nodeId, java.net.InetSocketAddress bindAddress, java.util.Collection<java.net.InetSocketAddress> nonInternetRoutable, Continuation<PastryNode,java.io.IOException> deliverResultToMe)
          Probe the internalAddresses to get more externalAddresses, then call findExternalAddressHelper
protected  void InternetPastryNodeFactory.newNodeSelector(Id nodeId, MultiInetSocketAddress proxyAddress, Continuation<PastryNode,java.io.IOException> deliverResultToMe, java.util.Map<java.lang.String,java.lang.Object> initialVars)
          This is where the action takes place.
protected  void InternetPastryNodeFactory.openFirewallPort(Id nodeId, java.net.InetSocketAddress bindAddress, Continuation<PastryNode,java.io.IOException> deliverResultToMe, java.net.InetAddress externalAddress, int requestedPort)
          Attempt to open the firewall on the specified port if it doesn't work, uses Rendezvous
protected  void InternetPastryNodeFactory.verifyConnectivityThenMakeNewNode(Id nodeId, MultiInetSocketAddress proxyAddress, Continuation<PastryNode,java.io.IOException> deliverResultToMe)
          Verifies the connectivity (if necessary), then calls super.newNodeSelector() if connectivity fails, then uses Rendezvous
 

Uses of PastryNode in rice.pastry.socket.nat.probe
 

Constructors in rice.pastry.socket.nat.probe with parameters of type PastryNode
ProbeApp(PastryNode pn, Prober prober, AddressStrategy addressStrategy)
           
 

Uses of PastryNode in rice.pastry.socket.nat.rendezvous
 

Fields in rice.pastry.socket.nat.rendezvous declared as PastryNode
protected  PastryNode LeafSetRendezvousStrategy.pn
           
 

Methods in rice.pastry.socket.nat.rendezvous with parameters of type PastryNode
protected  void RendezvousSocketPastryNodeFactory.generatePilotStrategy(PastryNode pn, RendezvousTransportLayerImpl<java.net.InetSocketAddress,RendezvousSocketNodeHandle> rendezvousLayer)
           
protected  Bootstrapper RendezvousSocketPastryNodeFactory.getBootstrapper(PastryNode pn, NodeHandleAdapter tl, NodeHandleFactory handleFactory, ProximityNeighborSelector pns)
          This code opens a pilot to our bootstrap node before proceeding.
protected  ContactDeserializer<java.net.InetSocketAddress,RendezvousSocketNodeHandle> RendezvousSocketPastryNodeFactory.getContactDeserializer(PastryNode pn)
           
protected  ContactDirectStrategy<RendezvousSocketNodeHandle> RendezvousSocketPastryNodeFactory.getContactDirectStrategy(PastryNode pn)
           
protected  IdentitySerializer<TransportLayerNodeHandle<MultiInetSocketAddress>,MultiInetSocketAddress,SourceRoute<MultiInetSocketAddress>> RendezvousSocketPastryNodeFactory.getIdentiySerializer(PastryNode pn, SocketNodeHandleFactory handleFactory)
           
protected  TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> RendezvousSocketPastryNodeFactory.getIpServiceTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> wtl, PastryNode pn)
           
protected  JoinProtocol RendezvousSocketPastryNodeFactory.getJoinProtocol(PastryNode pn, LeafSet leafSet, RoutingTable routeTable, ReadyStrategy lsProtocol)
           
 NodeHandle RendezvousSocketPastryNodeFactory.getLocalHandle(PastryNode pn, NodeHandleFactory nhf)
           
protected  NextHopStrategy<MultiInetSocketAddress> RendezvousSocketPastryNodeFactory.getNextHopStrategy(TransportLayer<SourceRoute<MultiInetSocketAddress>,java.nio.ByteBuffer> ltl, LivenessProvider<SourceRoute<MultiInetSocketAddress>> livenessProvider, Pinger<SourceRoute<MultiInetSocketAddress>> pinger, PastryNode pn, MultiInetSocketAddress proxyAddress, MultiAddressSourceRouteFactory esrFactory)
           
 NodeHandleFactory RendezvousSocketPastryNodeFactory.getNodeHandleFactory(PastryNode pn)
           
protected  PilotFinder<RendezvousSocketNodeHandle> RendezvousSocketPastryNodeFactory.getPilotFinder(PastryNode pn)
           
protected  PriorityTransportLayer<MultiInetSocketAddress> RendezvousSocketPastryNodeFactory.getPriorityTransportLayer(TransportLayer<MultiInetSocketAddress,java.nio.ByteBuffer> trans, LivenessProvider<MultiInetSocketAddress> liveness, ProximityProvider<MultiInetSocketAddress> prox, PastryNode pn)
           
protected  ProximityNeighborSelector RendezvousSocketPastryNodeFactory.getProximityNeighborSelector(PastryNode pn)
           
protected  RendezvousGenerationStrategy<RendezvousSocketNodeHandle> RendezvousSocketPastryNodeFactory.getRendezvousGenerator(PastryNode pn)
           
protected  RendezvousStrategy<RendezvousSocketNodeHandle> RendezvousSocketPastryNodeFactory.getRendezvousStrategy(PastryNode pn)
           
protected  RendezvousStrategy<RendezvousSocketNodeHandle> RendezvousSocketPastryNodeFactory.getRendezvousStrategyHelper(PastryNode pn)
          This is an annoying hack.
protected  TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> RendezvousSocketPastryNodeFactory.getRendezvousTransportLayer(TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> mtl, PastryNode pn)
           
protected  ResponseStrategy<java.net.InetSocketAddress> RendezvousSocketPastryNodeFactory.getResponseStrategy(PastryNode pn)
           
protected  TransportLayer<java.net.InetSocketAddress,java.nio.ByteBuffer> RendezvousSocketPastryNodeFactory.getWireTransportLayer(java.net.InetSocketAddress innermostAddress, PastryNode pn)
          For testing, may return a FirewallTL impl for testing.
protected  void RendezvousSocketPastryNodeFactory.registerApps(PastryNode pn, LeafSet leafSet, RoutingTable routeTable, NodeHandleAdapter nha, NodeHandleFactory handleFactory)
           
 

Method parameters in rice.pastry.socket.nat.rendezvous with type arguments of type PastryNode
protected  void RendezvousSocketPastryNodeFactory.newNodeSelector(Id nodeId, MultiInetSocketAddress proxyAddress, Continuation<PastryNode,java.io.IOException> deliverResultToMe, java.util.Map<java.lang.String,java.lang.Object> initialVars, boolean firewalled)
          Can override the contactState on a per-node basis
protected  void RendezvousSocketPastryNodeFactory.newNodeSelector(Id nodeId, MultiInetSocketAddress proxyAddress, Continuation<PastryNode,java.io.IOException> deliverResultToMe, java.util.Map<java.lang.String,java.lang.Object> initialVars, byte contactState)
          Can override the contactState on a per-node basis
 

Constructors in rice.pastry.socket.nat.rendezvous with parameters of type PastryNode
LeafSetPilotFinder(PastryNode pn)
           
LeafSetRendezvousStrategy(PastryNode pn, RandomSource r)
           
RendezvousApp(PastryNode pn)
           
RendezvousJoinProtocol(PastryNode ln, NodeHandle lh, RoutingTable rt, LeafSet ls, ReadyStrategy nextReadyStrategy, PilotManager<RendezvousSocketNodeHandle> pilotManager)
           
RendezvousJoinRequest(InputBuffer buf, NodeHandleFactory nhf, NodeHandle sender, PastryNode localNode)
           
RendezvousPNSApplication(PastryNode pn, ContactDirectStrategy<RendezvousSocketNodeHandle> contactDirectStrategy)
           
RendezvousSNHFactory(PastryNode pn)
           
RendezvousSPNFIdentitySerializer(PastryNode pn, SocketNodeHandleFactory factory)
           
 

Uses of PastryNode in rice.pastry.standard
 

Fields in rice.pastry.standard declared as PastryNode
protected  PastryNode PeriodicLeafSetProtocol.localNode
           
protected  PastryNode PartitionHandler.pastryNode
           
 

Constructors in rice.pastry.standard with parameters of type PastryNode
ConsistentJoinProtocol.CJPDeserializer(PastryNode pn)
           
ConsistentJoinProtocol(PastryNode ln, NodeHandle lh, RoutingTable rt, LeafSet ls, ReadyStrategy nextReadyStrategy)
           
ConsistentJoinProtocol(PastryNode ln, NodeHandle lh, RoutingTable rt, LeafSet ls, ReadyStrategy nextReadyStrategy, MessageDeserializer md)
          Constructor takes in the usual suspects.
PartitionHandler(PastryNode pn, SocketPastryNodeFactory factory, java.net.InetSocketAddress[] bootstraps)
          Constructs a PartitionHandler.
PeriodicLeafSetProtocol.PLSPMessageDeserializer(PastryNode pn)
           
PeriodicLeafSetProtocol(PastryNode ln, NodeHandle local, LeafSet ls, RoutingTable rt)
          Builds a periodic leafset protocol
RapidRerouter(PastryNode thePastryNode, MessageDispatch dispatch, RouterStrategy strategy)
           
StandardJoinProtocol.SJPDeserializer(PastryNode pn)
           
StandardJoinProtocol(PastryNode ln, NodeHandle lh, RoutingTable rt, LeafSet ls)
          Constructor.
StandardJoinProtocol(PastryNode ln, NodeHandle lh, RoutingTable rt, LeafSet ls, MessageDeserializer md)
           
StandardLeafSetProtocol(PastryNode ln, NodeHandle local, LeafSet ls, RoutingTable rt)
           
StandardRouter(PastryNode thePastryNode, MessageDispatch dispatch)
          Constructor.
StandardRouter(PastryNode thePastryNode, MessageDispatch dispatch, RouterStrategy strategy)
           
StandardRouteSetProtocol(PastryNode ln, RoutingTable rt)
          Constructor.
StandardRouteSetProtocol(PastryNode ln, RoutingTable rt, MessageDeserializer md)
           
 

Uses of PastryNode in rice.pastry.testing
 

Methods in rice.pastry.testing that return PastryNode
 PastryNode RoutingTableTest.createNode()
           
protected  PastryNode PastryRegrTest.generateNode(NodeHandle bootstrap)
           
 PastryNode RegrTestApp.getPastryNode()
           
 PastryNode SinglePingTest.makePastryNode()
           
 PastryNode DistHelloWorld.makePastryNode(boolean firstNode)
          Create a Pastry node and add it to pastryNodes.
 

Methods in rice.pastry.testing with parameters of type PastryNode
 void RoutingTableTest.finishNode(PastryNode node)
           
protected  void DirectPastryRegrTest.killNode(PastryNode pn)
          murder the node.
protected  void DistPastryRegrTest.killNode(PastryNode pn)
           
protected abstract  void PastryRegrTest.killNode(PastryNode pn)
          kill a given node.
protected  void DirectPastryRegrTest.registerapp(PastryNode pn, RegrTestApp app)
          wire protocol specific handling of the application object e.g., RMI may launch a new thread
protected  void DistPastryRegrTest.registerapp(PastryNode pn, RegrTestApp app)
          wire protocol specific handling of the application object e.g., RMI may launch a new thread
protected abstract  void PastryRegrTest.registerapp(PastryNode pn, RegrTestApp app)
          wire protocol specific handling of the application object e.g., RMI may launch a new thread
 

Method parameters in rice.pastry.testing with type arguments of type PastryNode
protected  double ClosestRegrTest.getAvgNumEntries(java.util.Collection<PastryNode> nds)
           
 

Constructors in rice.pastry.testing with parameters of type PastryNode
HelloWorldApp(PastryNode pn)
           
Ping(PastryNode pn)
           
PingClient(PastryNode pn)
           
RegrTestApp(PastryNode pn, PastryRegrTest prg)
           
 

Uses of PastryNode in rice.pastry.transport
 

Methods in rice.pastry.transport that return PastryNode
 PastryNode TransportPastryNodeFactory.nodeHandleHelper(PastryNode pn)
           
 

Methods in rice.pastry.transport with parameters of type PastryNode
protected abstract  Bootstrapper TransportPastryNodeFactory.getBootstrapper(PastryNode pn, NodeHandleAdapter tl, NodeHandleFactory handleFactory, ProximityNeighborSelector pns)
           
protected  JoinProtocol TransportPastryNodeFactory.getJoinProtocol(PastryNode pn, LeafSet leafSet, RoutingTable routeTable, ReadyStrategy lsProtocol)
           
protected  LeafSetProtocol TransportPastryNodeFactory.getLeafSetProtocol(PastryNode pn, LeafSet leafSet, RoutingTable routeTable)
           
protected abstract  NodeHandle TransportPastryNodeFactory.getLocalHandle(PastryNode pn, NodeHandleFactory handleFactory)
           
protected abstract  NodeHandleAdapter TransportPastryNodeFactory.getNodeHandleAdapter(PastryNode pn, NodeHandleFactory handleFactory, TLDeserializer deserializer)
           
protected abstract  NodeHandleFactory TransportPastryNodeFactory.getNodeHandleFactory(PastryNode pn)
           
protected  ProximityNeighborSelector TransportPastryNodeFactory.getProximityNeighborSelector(PastryNode pn)
          Can be overridden.
protected  RouterStrategy TransportPastryNodeFactory.getRouterStrategy(PastryNode pn)
           
protected  RouteSetProtocol TransportPastryNodeFactory.getRouteSetProtocol(PastryNode pn, LeafSet leafSet, RoutingTable routeTable)
           
protected  TLDeserializer TransportPastryNodeFactory.getTLDeserializer(NodeHandleFactory handleFactory, PastryNode pn)
           
 PastryNode TransportPastryNodeFactory.nodeHandleHelper(PastryNode pn)
           
protected  void TransportPastryNodeFactory.registerApps(PastryNode pn, LeafSet leafSet, RoutingTable routeTable, NodeHandleAdapter nha, NodeHandleFactory handleFactory)
           
 


Rice Pastry API

Copyright © 2001-2005 - Rice Pastry.


Imprint-Dataprotection