|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
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(NodeHandle bootstrap)
Call this to construct a new node of the type chosen by the factory. |
abstract PastryNode |
PastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId)
Call this to construct a new node of the type chosen by the factory, with the given nodeId. |
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 delay,
long initialPeriod,
double expBase)
|
|
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 |
---|
Subclasses of PastryNode in rice.pastry.direct | |
---|---|
class |
DirectPastryNode
Direct pastry node. |
Methods in rice.pastry.direct that return PastryNode | |
---|---|
PastryNode |
DirectPastryNodeFactory.newNode(NodeHandle bootstrap)
Manufacture a new Pastry node. |
PastryNode |
DirectPastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId)
Manufacture a new Pastry node. |
Uses of PastryNode in rice.pastry.dist |
---|
Subclasses of PastryNode in rice.pastry.dist | |
---|---|
class |
DistPastryNode
Class which represents the abstraction of a "real" pastry node. |
Methods in rice.pastry.dist that return PastryNode | |
---|---|
abstract PastryNode |
DistPastryNodeFactory.newNode(NodeHandle bootstrap)
Generates a new pastry node with a random NodeId using the bootstrap bootstrap. |
abstract PastryNode |
DistPastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId)
Generates a new pastry node with the specified NodeId using the bootstrap bootstrap. |
abstract PastryNode |
DistPastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId,
java.net.InetSocketAddress proxy)
Generates a new pastry node with the specified NodeId using the bootstrap bootstrap. |
abstract PastryNode |
DistPastryNodeFactory.newNode(NodeHandle bootstrap,
java.net.InetSocketAddress proxy)
Generates a new pastry node with the specified NodeId using the bootstrap bootstrap. |
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)
Constructor. |
|
PastryObjectInputStream(java.io.InputStream stream,
PastryNode node)
|
|
PJavaSerializedDeserializer(PastryNode pn)
|
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,
NodeHandleFactory nhf,
PastryNode pn)
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + int auxAddress + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + Id target + + + + + + + + + +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ + NodeHandle prev + + (used to repair routing table during routing) + + + ... |
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,
NodeHandleFactory nhf,
PastryNode pn)
|
|
RouteSet(InputBuffer buf,
NodeHandleFactory nhf,
PastryNode local)
|
|
RouteSet(int maxSize,
int row,
int col,
PastryNode local)
Constructor. |
|
RoutingTable(NodeHandle me,
int max,
byte base,
PastryNode pn)
Constructor. |
Uses of PastryNode in rice.pastry.socket |
---|
Subclasses of PastryNode in rice.pastry.socket | |
---|---|
class |
SocketPastryNode
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. |
Methods in rice.pastry.socket that return PastryNode | |
---|---|
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 a randomly generated NodeId. |
PastryNode |
SocketPastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId,
java.net.InetSocketAddress pAddress)
Method which creates a Pastry node from the next port with a randomly generated NodeId. |
PastryNode |
SocketPastryNodeFactory.newNode(NodeHandle bootstrap,
Id nodeId,
java.net.InetSocketAddress pAddress,
boolean throwException)
|
PastryNode |
SocketPastryNodeFactory.newNode(NodeHandle bootstrap,
java.net.InetSocketAddress proxy)
Method which creates a Pastry node from the next port with a randomly generated NodeId. |
Uses of PastryNode in rice.pastry.socket.messaging |
---|
Constructors in rice.pastry.socket.messaging with parameters of type PastryNode | |
---|---|
RouteRowResponseMessage(InputBuffer buf,
NodeHandleFactory nhf,
PastryNode localNode)
|
Uses of PastryNode in rice.pastry.standard |
---|
Fields in rice.pastry.standard declared as PastryNode | |
---|---|
protected PastryNode |
PeriodicLeafSetProtocol.localNode
|
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 |
Constructors in rice.pastry.testing with parameters of type PastryNode | |
---|---|
HelloWorldApp(PastryNode pn)
|
|
Ping(PastryNode pn)
|
|
PingClient(PastryNode pn)
|
|
RegrTestApp(PastryNode pn,
PastryRegrTest prg)
|
|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |