|
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
public 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.
Field Summary |
---|
Fields inherited from class rice.pastry.dist.DistPastryNode |
---|
leafSetMaintFreq, leafSetRoutineMaintenance, routeSetMaintFreq, routeSetRoutineMaintenance, timer |
Fields inherited from class rice.pastry.PastryNode |
---|
apps, joinFailed, joinFailedReason, leafSet, localhandle, logger, myNodeId, routeSet |
Constructor Summary | |
---|---|
SocketPastryNode(Id id,
Environment e)
Constructor |
Method Summary | |
---|---|
void |
acceptAppSocket(SocketAppSocket socket,
int appId)
|
NodeHandle |
coalesce(NodeHandle newHandle)
|
void |
connect(NodeHandle handle,
AppSocketReceiver receiver,
PastryAppl appl,
int timeout)
Called by PastryAppl to ask the transport layer to open a Socket to its counterpart on another node. |
void |
destroy()
Makes this node resign from the network. |
void |
doneNode(NodeHandle[] bootstrap)
Called after the node is initialized. |
SocketSourceRouteManager |
getSocketSourceRouteManager()
Returns the SocketSourceRouteManager for this pastry node. |
int |
proximity(NodeHandle nh)
The proximity of the node handle. |
NodeHandle |
readNodeHandle(InputBuffer buf)
|
void |
send(NodeHandle handle,
Message message)
Deliver message to the NodeHandle. |
void |
setSocketElements(EpochInetSocketAddress address,
int lsmf,
int rsmf)
Helper method which allows the WirePastryNodeFactory to initialize a number of the pastry node's elements. |
void |
setSocketSourceRouteManager(SocketSourceRouteManager srManager)
|
void |
testFireWall(NodeHandle bootstrap,
Continuation c,
int timeout)
|
void |
testFireWall(NodeHandle bootstrap,
Continuation c,
int timeout,
int tries)
Try multiple times... |
java.lang.String |
toString()
Prints out a String representation of this node |
Methods inherited from class rice.pastry.dist.DistPastryNode |
---|
addNetworkListener, broadcastChannelClosed, broadcastChannelOpened, 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(Id id, Environment e)
id
- The NodeId of this Pastry node.Method Detail |
---|
public SocketSourceRouteManager getSocketSourceRouteManager()
public void setSocketElements(EpochInetSocketAddress address, int lsmf, int rsmf)
address
- The address of this pastry node.manager
- The socket manager for this pastry node.lsmf
- Leaf set maintenance frequency. 0 means never.rsmf
- Route set maintenance frequency. 0 means never.sManager
- The new SocketElements valuepingManager
- The new SocketElements valuepool
- 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 interface Destructable
destroy
in class DistPastryNode
public NodeHandle coalesce(NodeHandle newHandle)
coalesce
in class PastryNode
public void setSocketSourceRouteManager(SocketSourceRouteManager srManager)
public void send(NodeHandle handle, Message message)
PastryNode
send
in class PastryNode
public void testFireWall(NodeHandle bootstrap, Continuation c, int timeout, int tries)
bootstrap
- c
- timeout
- tries
- public void testFireWall(NodeHandle bootstrap, Continuation c, int timeout)
public void connect(NodeHandle handle, AppSocketReceiver receiver, PastryAppl appl, int timeout)
PastryNode
connect
in class PastryNode
public void acceptAppSocket(SocketAppSocket socket, int appId) throws AppSocketException
AppSocketException
public NodeHandle readNodeHandle(InputBuffer buf) throws java.io.IOException
java.io.IOException
public int proximity(NodeHandle nh)
PastryNode
proximity
in class PastryNode
|
Rice Pastry API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |