|
Rice Pastry API | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object java.util.Observable rice.pastry.PastryNode rice.pastry.dist.DistPastryNode rice.pastry.socket.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.
Field Summary |
Fields inherited from class rice.pastry.dist.DistPastryNode |
leafSetMaintFreq, leafSetRoutineMaintenance, routeSetMaintFreq, routeSetRoutineMaintenance, timer |
Fields inherited from class rice.pastry.PastryNode |
apps, localhandle, myNodeId, nodeHandleSet |
Constructor Summary | |
SocketPastryNode(NodeId id,
Environment e)
Constructor |
Method Summary | |
void |
destroy()
Makes this node resign from the network. |
void |
doneNode(NodeHandle bootstrap)
Called after the node is initialized. |
DistNodeHandlePool |
getNodeHandlePool()
Returns the WireNodeHandlePool for this pastry node. |
SocketSourceRouteManager |
getSocketSourceRouteManager()
Returns the SocketSourceRouteManager for this pastry node. |
void |
setSocketElements(EpochInetSocketAddress address,
SocketSourceRouteManager srManager,
SocketNodeHandlePool pool,
int lsmf,
int rsmf)
Helper method which allows the WirePastryNodeFactory to initialize a number of the pastry node's elements. |
java.lang.String |
toString()
Prints out a String representation of this node |
Methods inherited from class rice.pastry.dist.DistPastryNode |
addNetworkListener, broadcastReceivedListeners, broadcastSentListeners, getNetworkListeners, getTimer, initiateJoin, nodeIsReady, process, scheduleMsg, scheduleMsg, scheduleMsgAtFixedRate, scheduleMsgExpBackoff |
Methods inherited from class java.util.Observable |
addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
public SocketPastryNode(NodeId id, Environment e)
id
- The NodeId of this Pastry node.e
- DESCRIBE THE PARAMETERMethod Detail |
public SocketSourceRouteManager getSocketSourceRouteManager()
public DistNodeHandlePool getNodeHandlePool()
getNodeHandlePool
in class DistPastryNode
public void setSocketElements(EpochInetSocketAddress address, SocketSourceRouteManager srManager, SocketNodeHandlePool pool, int lsmf, int rsmf)
address
- The address of this pastry node.lsmf
- Leaf set maintenance frequency. 0 means never.rsmf
- Route set maintenance frequency. 0 means never.pool
- The new SocketElements valuesrManager
- The new SocketElements valuepublic void doneNode(NodeHandle bootstrap)
doneNode
in class DistPastryNode
bootstrap
- The node which this node should boot off of.public java.lang.String toString()
toString
in class PastryNode
public void destroy()
destroy
in class DistPastryNode
|
Rice Pastry API | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |