| 
Rice Pastry API | ||||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||||
| 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 | 
SocketChannelReader.path
DESCRIBE THE FIELD  | 
protected  SourceRoute | 
SocketChannelWriter.path
DESCRIBE THE FIELD  | 
protected  SourceRoute | 
SocketCollectionManager.MessageRetry.route
DESCRIBE THE FIELD  | 
protected  SourceRoute | 
SocketCollectionManager.DeadChecker.path
DESCRIBE THE FIELD  | 
protected  SourceRoute | 
SocketSourceRouteManager.AddressManager.best
DESCRIBE THE FIELD  | 
protected  SourceRoute | 
SocketSourceRouteManager.AddressManager.SourceRouteManager.route
DESCRIBE THE FIELD  | 
| Methods in rice.pastry.socket that return SourceRoute | |
static SourceRoute | 
PingManager.decodeHeader(byte[] header)
Method which adds a header for the provided path to the given data.  | 
protected  SourceRoute | 
SocketCollectionManager.getSocketToClose()
Internal method which returns the next socket to be closed  | 
 SourceRoute[] | 
SocketPastryNodeFactory.getRoutes(NodeHandle handle)
This method returns the routes a remote node is using  | 
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 | 
SourceRoute.reverse(EpochInetSocketAddress localAddress)
Method which revereses path and cliams the corresponding address  | 
 SourceRoute | 
SourceRoute.reverse()
Method which revereses path  | 
 SourceRoute | 
SourceRoute.removeLastHop()
Method which creates a new source route by removing the last hop of this one  | 
 SourceRoute | 
SourceRoute.append(EpochInetSocketAddress address)
Method which creates a new source route by appending the given address to the end of this one  | 
 SourceRoute | 
SourceRoute.prepend(EpochInetSocketAddress address)
Method which creates a new source route by appending the given address to the end 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  | 
static SourceRoute | 
SourceRoute.build(EpochInetSocketAddress[] path)
Constructor.  | 
static SourceRoute | 
SourceRoute.build(EpochInetSocketAddress address)
Constructor.  | 
| Methods in rice.pastry.socket with parameters of type SourceRoute | |
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.  | 
protected  void | 
PingManager.sendShortPing(SourceRoute route)
Builds the data for a short ping  | 
protected  void | 
PingManager.shortPingReceived(SourceRoute route,
                  byte[] payload)
Builds the data for a short ping response  | 
protected  void | 
PingManager.shortPingResponseReceived(SourceRoute route,
                          byte[] payload)
Processes a short ping response  | 
protected  void | 
PingManager.addPingResponseListener(SourceRoute path,
                        PingResponseListener prl)
Adds a feature to the PingResponseListener attribute of the PingManager object  | 
protected  void | 
PingManager.notifyPingResponseListeners(SourceRoute path,
                            int proximity,
                            long lastTimePinged)
caller must synchronized(pingResponseTimes)  | 
 void | 
PingManager.enqueue(SourceRoute path,
        java.lang.Object msg)
DESCRIBE THE METHOD  | 
static byte[] | 
PingManager.addHeader(SourceRoute path,
          java.lang.Object data,
          EpochInetSocketAddress localAddress)
Method which adds a header for the provided path to the given data.  | 
 void | 
PingResponseListener.pingResponse(SourceRoute path,
             long RTT,
             long timeHeardFrom)
Method which is called once a previously-issued ping is responded to.  | 
protected  void | 
SocketChannelReader.setPath(SourceRoute path)
Sets this reader's path  | 
protected  void | 
SocketChannelReader.record(java.lang.Object obj,
       int size,
       SourceRoute path)
DESCRIBE THE METHOD  | 
protected  void | 
SocketChannelWriter.setPath(SourceRoute path)
Sets this writer's path  | 
protected  void | 
SocketChannelWriter.record(java.lang.String action,
       java.lang.Object obj,
       int size,
       SourceRoute path)
DESCRIBE THE METHOD  | 
 boolean | 
SocketCollectionManager.isOpen(SourceRoute route)
Returns whether or not a socket is currently open to the given route  | 
 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.  | 
 void | 
SocketCollectionManager.send(SourceRoute path,
     Message message)
Method which sends a message across the wire.  | 
 void | 
SocketCollectionManager.ping(SourceRoute route)
Method which suggests a ping to the remote node.  | 
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  boolean | 
SocketCollectionManager.sendInternal(SourceRoute path,
             Message message)
Method which sends a message across the wire.  | 
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  | 
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.  | 
protected  void | 
SocketCollectionManager.socketOpened(SourceRoute path,
             rice.pastry.socket.SocketCollectionManager.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.socketClosed(SourceRoute path,
             rice.pastry.socket.SocketCollectionManager.SocketManager manager)
Method which is designed to be called *ONCE THE SOCKET HAS BEEN CLOSED*.  | 
protected  void | 
SocketCollectionManager.socketUpdated(SourceRoute path)
Method which is designed to be called whenever a node has network activity.  | 
 void | 
SocketCollectionManager.DeadChecker.pingResponse(SourceRoute path,
             long RTT,
             long timeHeardFrom)
DESCRIBE THE METHOD  | 
protected  void | 
SocketSourceRouteManager.markDead(SourceRoute route)
This method should be called when a known route is declared dead.  | 
protected  void | 
SocketSourceRouteManager.markAlive(SourceRoute route)
This method should be called when a known route is declared alive.  | 
protected  void | 
SocketSourceRouteManager.markSuspected(SourceRoute route)
This method should be called when a known route is declared suspected.  | 
protected  void | 
SocketSourceRouteManager.markProximity(SourceRoute route,
              int proximity)
This method should be called when a known route has its proximity updated  | 
protected  SocketSourceRouteManager.AddressManager.SourceRouteManager | 
SocketSourceRouteManager.AddressManager.getRouteManager(SourceRoute route)
Method which returns the route manager for the given route  | 
protected  void | 
SocketSourceRouteManager.AddressManager.markAlive(SourceRoute route)
This method should be called when a known route is declared alive.  | 
protected  void | 
SocketSourceRouteManager.AddressManager.markSuspected(SourceRoute route)
This method should be called when a known route is declared suspected.  | 
protected  void | 
SocketSourceRouteManager.AddressManager.markDead(SourceRoute route)
This method should be called when a known route is declared dead.  | 
protected  void | 
SocketSourceRouteManager.AddressManager.markProximity(SourceRoute route,
              int proximity)
This method should be called when a known route has its proximity updated  | 
protected static SourceRoute | 
SourceRoute.resolve(java.util.WeakHashMap map,
        SourceRoute route)
Method which performs the coalescing and interaction with the weak hash map  | 
| Constructors in rice.pastry.socket with parameters of type SourceRoute | |
SocketChannelReader(PastryNode spn,
                    SourceRoute path)
Constructor which creates this SocketChannelReader and the WirePastryNode.  | 
|
SocketChannelWriter(PastryNode spn,
                    SourceRoute path)
Constructor which creates this SocketChannelWriter with a pastry node and an object to write out.  | 
|
SocketCollectionManager.MessageRetry(SourceRoute route,
                                     Message message)
Constructor, taking a message and the route  | 
|
SocketCollectionManager.DeadChecker(SourceRoute path,
                                    int numTries)
Constructor for DeadChecker.  | 
|
SocketSourceRouteManager.AddressManager.SourceRouteManager(SourceRoute route)
Constructor - builds a route manager given the route  | 
|
| Uses of SourceRoute in rice.pastry.socket.messaging | 
| Fields in rice.pastry.socket.messaging declared as SourceRoute | |
protected  SourceRoute | 
DatagramMessage.outbound
DESCRIBE THE FIELD  | 
protected  SourceRoute | 
DatagramMessage.inbound
DESCRIBE THE FIELD  | 
| Methods in rice.pastry.socket.messaging that return SourceRoute | |
 SourceRoute | 
DatagramMessage.getOutboundPath()
Gets the OutboundPath attribute of the DatagramMessage object  | 
 SourceRoute | 
DatagramMessage.getInboundPath()
Gets the InboundPath attribute of the DatagramMessage object  | 
 SourceRoute[] | 
RoutesResponseMessage.getRoutes()
Returns the leafset of the receiver.  | 
| Constructors in rice.pastry.socket.messaging with parameters of type SourceRoute | |
DatagramMessage(SourceRoute outbound,
                SourceRoute inbound)
Constructor  | 
|
PingMessage(SourceRoute outbound,
            SourceRoute inbound)
Constructor  | 
|
PingResponseMessage(SourceRoute outbound,
                    SourceRoute inbound,
                    long start)
Constructor  | 
|
RoutesResponseMessage(SourceRoute[] routes)
Constructor  | 
|
WrongEpochMessage(SourceRoute outbound,
                  SourceRoute inbound,
                  EpochInetSocketAddress incorrect,
                  EpochInetSocketAddress correct)
Constructor  | 
|
  | 
Rice Pastry API | ||||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||||