Uses of Class
rice.pastry.socket.SourceRoute

Packages that use SourceRoute

rice.pastry.socket
rice.pastry.socket.messaging

Uses of SourceRoute in rice.pastry.socket

Fields in rice.pastry.socket declared as SourceRoute

protected SourceRoute	SocketSourceRouteManager.AddressManager.best 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
protected SourceRoute	SocketChannelReader.path
protected SourceRoute	SocketChannelWriter.path
protected SourceRoute	SocketCollectionManager.DeadChecker.path
protected SourceRoute	SocketCollectionManager.MessageRetry.route
protected SourceRoute	SocketSourceRouteManager.AddressManager.SourceRouteManager.route

Methods in rice.pastry.socket that return SourceRoute

SourceRoute	SourceRoute.append(EpochInetSocketAddress address) Method which creates a new source route by appending the given address to the end of this one
static SourceRoute	SourceRoute.build(EpochInetSocketAddress address) Constructor.
static SourceRoute	SourceRoute.build(EpochInetSocketAddress[] path) Constructor.
static SourceRoute	SourceRoute.build(InputBuffer buf)
SourceRoute	PingManager.decodeHeader(byte[] header, int numAddresses) Method which adds a header for the provided path to the given data.
protected SourceRoute[]	SocketSourceRouteManager.getAllRoutes(EpochInetSocketAddress destination) Internal method which returns a list of all possible routes to a given address.
protected SourceRoute	SocketSourceRouteManager.getBestRoute(EpochInetSocketAddress address) Internal method which returns the best known route to the given destination
SourceRoute[]	SocketPastryNodeFactory.getRoutes(NodeHandle handle, NodeHandle local) This method returns the routes a remote node is using
protected SourceRoute	SocketCollectionManager.getSocketToClose() Internal method which returns the next socket to be closed
SourceRoute	SourceRoute.prepend(EpochInetSocketAddress address) Method which creates a new source route by appending the given address to the end of this one
SourceRoute	SourceRoute.removeLastHop() Method which creates a new source route by removing the last hop of this one
protected static SourceRoute	SourceRoute.resolve(java.util.WeakHashMap map, SourceRoute route) Method which performs the coalescing and interaction with the weak hash map
SourceRoute	SourceRoute.reverse() Method which revereses path
SourceRoute	SourceRoute.reverse(EpochInetSocketAddress localAddress) Method which revereses path and cliams the corresponding address

Methods in rice.pastry.socket with parameters of type SourceRoute

protected void	PingManager.addPingResponseListener(SourceRoute path, PingResponseListener prl) Adds a feature to the PingResponseListener attribute of the PingManager object
void	SocketCollectionManager.bootstrap(SourceRoute path, Message message) 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.
protected void	SocketCollectionManager.checkLiveness(SourceRoute path) Initiates a liveness test on the given address, if the remote node does not respond, it is declared dead.
protected void	SocketCollectionManager.closeSocket(SourceRoute path) Method which cloeses a socket to a given remote node handle, and updates the bookkeeping to keep track of this closing.
void	SocketCollectionManager.connect(SourceRoute path, int appId, AppSocketReceiver receiver, int timeout) Method which sends a message across the wire.
protected void	SocketAppSocket.createConnection(SourceRoute path) Creates the outgoing socket to the remote handle
void	PingManager.enqueue(SourceRoute path, PRawMessage msg)
void	PingManager.enqueue(SourceRoute path, SocketBuffer msg) DESCRIBE THE METHOD
protected SocketSourceRouteManager.AddressManager.SourceRouteManager	SocketSourceRouteManager.AddressManager.getRouteManager(SourceRoute route) Method which returns the route manager for the given route
boolean	SocketCollectionManager.isOpen(SourceRoute route) Returns whether or not a socket is currently open to the given route
protected void	SocketSourceRouteManager.markAlive(SourceRoute route) This method should be called when a known route is declared alive.
protected void	SocketSourceRouteManager.AddressManager.markAlive(SourceRoute route) This method should be called when a known route is declared alive.
protected void	SocketSourceRouteManager.markDead(SourceRoute route) This method should be called when a known route is declared dead.
protected void	SocketSourceRouteManager.AddressManager.markDead(SourceRoute route) This method should be called when a known route is declared dead.
protected void	SocketSourceRouteManager.markProximity(SourceRoute route, int proximity) This method should be called when a known route has its proximity updated
protected void	SocketSourceRouteManager.AddressManager.markProximity(SourceRoute route, int proximity) This method should be called when a known route has its proximity updated
protected void	SocketSourceRouteManager.markSuspected(SourceRoute route) This method should be called when a known route is declared suspected.
protected void	SocketSourceRouteManager.AddressManager.markSuspected(SourceRoute route) This method should be called when a known route is declared suspected.
protected void	PingManager.notifyPingResponseListeners(SourceRoute path, int proximity, long lastTimePinged) caller must synchronized(pingResponseTimes)
protected void	SocketCollectionManager.openAppSocket(SourceRoute path, int appId, AppSocketReceiver connector, int timeout) Method which opens a socket to a given remote node handle, and updates the bookkeeping to keep track of this socket
protected void	SocketCollectionManager.openSocket(SourceRoute path, boolean bootstrap) Method which opens a socket to a given remote node handle, and updates the bookkeeping to keep track of this socket
void	SocketCollectionManager.ping(SourceRoute route) Method which suggests a ping to the remote node.
protected void	PingManager.ping(SourceRoute path, PingResponseListener prl) Method which actually sends a ping to over the specified path, and returns the result to the specified listener.
void	PingResponseListener.pingResponse(SourceRoute path, long RTT, long timeHeardFrom) Method which is called once a previously-issued ping is responded to.
void	SocketCollectionManager.DeadChecker.pingResponse(SourceRoute path, long RTT, long timeHeardFrom) DESCRIBE THE METHOD
protected int	SocketSourceRouteManager.proximity(SourceRoute route)
void	PingManager.receiveMessage(SourceRoute sr, DatagramMessage dm, int size, SourceRoute fromPath) DESCRIBE THE METHOD
protected void	PingManager.removePingResponseListener(SourceRoute path, PingResponseListener prl) Adds a feature to the PingResponseListener attribute of the PingManager object
protected static SourceRoute	SourceRoute.resolve(java.util.WeakHashMap map, SourceRoute route) Method which performs the coalescing and interaction with the weak hash map
protected int	SocketSourceRouteManager.rto(SourceRoute route)
void	SocketCollectionManager.send(SourceRoute path, SocketBuffer message, SocketSourceRouteManager.AddressManager am) Method which sends a message across the wire.
protected boolean	SocketCollectionManager.sendInternal(SourceRoute path, SocketBuffer message) Method which sends a message across the wire.
protected void	SocketChannelReader.setPath(SourceRoute path) Sets this reader's path
protected void	SocketChannelWriter.setPath(SourceRoute path) Sets this writer's path
protected void	SocketCollectionManager.socketClosed(SourceRoute path, rice.pastry.socket.SocketManager manager) Method which is designed to be called *ONCE THE SOCKET HAS BEEN CLOSED*.
protected void	SocketCollectionManager.socketOpened(SourceRoute path, rice.pastry.socket.SocketManager manager) Method which is designed to be called by node handles when they wish to open a socket to their remote node.
protected void	SocketCollectionManager.socketUpdated(SourceRoute path) Method which is designed to be called whenever a node has network activity.

Constructors in rice.pastry.socket with parameters of type SourceRoute

SocketAppSocket(SocketCollectionManager manager, SourceRoute path, int appId, AppSocketReceiver receiver, int timeout)
Constructor which creates an outgoing connection to the given node handle using the provided address as a source route intermediate node.

SocketBuffer(EpochInetSocketAddress address, SourceRoute path, PRawMessage msg)
This serializes UDP messages with the appropriate source route header.

SocketBuffer(SourceRoute path, int appId)
Used to initialize a TCP stream header.

SocketChannelReader(Environment env, SourceRoute path)

SocketChannelReader(SocketPastryNode spn, SourceRoute path)
Constructor which creates this SocketChannelReader and the WirePastryNode.

SocketChannelWriter(Environment env, SourceRoute path)

SocketChannelWriter(SocketPastryNode spn, SourceRoute path)
Constructor which creates this SocketChannelWriter with a pastry node and an object to write out.

SocketCollectionManager.DeadChecker(SourceRoute path, int numTries, int initialDelay)
Constructor for DeadChecker.

SocketCollectionManager.MessageRetry(SourceRoute route, SocketBuffer message, SocketSourceRouteManager.AddressManager am)
Constructor, taking a message and the route

SocketSourceRouteManager.AddressManager.SourceRouteManager(SourceRoute route)
Constructor - builds a route manager given the route

Uses of SourceRoute in rice.pastry.socket.messaging

Methods in rice.pastry.socket.messaging that return SourceRoute

SourceRoute[]

RoutesResponseMessage.getRoutes() Returns the leafset of the receiver.

Constructors in rice.pastry.socket.messaging with parameters of type SourceRoute

RoutesResponseMessage(SourceRoute[] routes)
Constructor