Rice Pastry API

Uses of Class
rice.pastry.messaging.Message

Packages that use Message
rice.pastry   
rice.pastry.client   
rice.pastry.commonapi   
rice.pastry.direct   
rice.pastry.dist   
rice.pastry.join   
rice.pastry.leafset   
rice.pastry.leafset.testing   
rice.pastry.messaging   
rice.pastry.routing   
rice.pastry.socket   
rice.pastry.socket.messaging   
rice.pastry.standard   
rice.pastry.testing   
 

Uses of Message in rice.pastry
 

Fields in rice.pastry declared as Message
protected  Message ScheduledMessage.msg
           
 

Methods in rice.pastry that return Message
 Message ScheduledMessage.getMessage()
          Returns the message
 

Methods in rice.pastry with parameters of type Message
 void NodeHandle.bootstrap(Message msg)
          Method which is used by Pastry to start the bootstrapping process on the local node using this handle as the bootstrap handle.
abstract  void NodeHandle.receiveMessage(Message msg)
          Deprecated. use PastryNode.send() or Endpoint.send()
 void PastryNode.receiveMessage(Message msg)
          message receiver interface.
abstract  ScheduledMessage PastryNode.scheduleMsg(Message msg, long delay)
          Schedule the specified message to be sent to the local node after a specified delay.
abstract  ScheduledMessage PastryNode.scheduleMsg(Message msg, long delay, long period)
          Schedule the specified message for repeated fixed-delay delivery to the local node, beginning after the specified delay.
abstract  ScheduledMessage PastryNode.scheduleMsgAtFixedRate(Message msg, long delay, long period)
          Schedule the specified message for repeated fixed-rate delivery to the local node, beginning after the specified delay.
abstract  void PastryNode.send(NodeHandle handle, Message message)
          Deliver message to the NodeHandle.
 

Constructors in rice.pastry with parameters of type Message
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 Message in rice.pastry.client
 

Methods in rice.pastry.client with parameters of type Message
abstract  void CommonAPIAppl.deliver(Id key, Message msg)
          Called by pastry when a message arrives for this application.
 boolean PastryAppl.enrouteMessage(Message msg, Id key, NodeHandle nextHop, SendOptions opt)
          Called by pastry when a message is enroute and is passing through this node.
 void CommonAPIAppl.messageForAppl(Message msg)
           
abstract  void PastryAppl.messageForAppl(Message msg)
          Called by pastry when a message arrives for this application.
 void CommonAPIAppl.receiveMessage(Message msg)
          Called by pastry to deliver a message to this client.
 void PastryAppl.receiveMessage(Message msg)
          Called by pastry to deliver a message to this client.
 void CommonAPIAppl.route(Id key, Message msg, NodeHandle hint)
          This operation forwards a message towards the root of key.
 void PastryAppl.routeMsg(Id key, Message msg, SendOptions opt)
          Routes a message to the live node D with nodeId numerically closest to key (at the time of delivery).
 boolean PastryAppl.routeMsgDirect(NodeHandle dest, Message msg, SendOptions opt)
          Sends a message to the Pastry node identified by dest.
 

Uses of Message in rice.pastry.commonapi
 

Subclasses of Message in rice.pastry.commonapi
 class PastryEndpointMessage
          This class is an internal message to the commonapi gluecode.
 

Methods in rice.pastry.commonapi with parameters of type Message
 boolean PastryEndpoint.enrouteMessage(Message msg, Id key, NodeHandle nextHop, SendOptions opt)
           
 void PastryEndpoint.messageForAppl(Message msg)
           
 void PastryEndpoint.receiveMessage(Message msg)
          Called by pastry to deliver a message to this client.
 

Uses of Message in rice.pastry.direct
 

Methods in rice.pastry.direct with parameters of type Message
 ScheduledMessage BasicNetworkSimulator.deliverMessage(Message msg, DirectPastryNode node)
          node should always be a local node, because this will be delivered instantly
 ScheduledMessage NetworkSimulator.deliverMessage(Message msg, DirectPastryNode node)
          Deliver message ASAP.
 ScheduledMessage BasicNetworkSimulator.deliverMessage(Message msg, DirectPastryNode node, int delay)
           
 ScheduledMessage NetworkSimulator.deliverMessage(Message msg, DirectPastryNode node, int delay)
          Deliver message.
 ScheduledMessage BasicNetworkSimulator.deliverMessage(Message msg, DirectPastryNode node, int delay, int period)
           
 ScheduledMessage NetworkSimulator.deliverMessage(Message msg, DirectPastryNode node, int delay, int period)
          Deliver message.
 ScheduledMessage BasicNetworkSimulator.deliverMessageFixedRate(Message msg, DirectPastryNode node, int delay, int period)
           
 ScheduledMessage NetworkSimulator.deliverMessageFixedRate(Message msg, DirectPastryNode node, int delay, int period)
          Deliver message.
 void BasicNetworkSimulator.notifySimulatorListeners(Message m, NodeHandle from, NodeHandle to, int delay)
           
 void NetworkSimulator.notifySimulatorListeners(Message m, NodeHandle from, NodeHandle to, int delay)
          Call this when a message is sent.
 void DirectNodeHandle.receiveMessage(Message msg)
          Deprecated. use PastryNode.send()
 void DirectPastryNode.receiveMessage(Message msg)
           
 ScheduledMessage DirectPastryNode.scheduleMsg(Message msg, long delay)
          Schedule the specified message to be sent to the local node after a specified delay.
 ScheduledMessage DirectPastryNode.scheduleMsg(Message msg, long delay, long period)
          Schedule the specified message for repeated fixed-delay delivery to the local node, beginning after the specified delay.
 ScheduledMessage DirectPastryNode.scheduleMsgAtFixedRate(Message msg, long delay, long period)
          Schedule the specified message for repeated fixed-rate delivery to the local node, beginning after the specified delay.
 void DirectPastryNode.send(NodeHandle nh, Message m)
           
 

Uses of Message in rice.pastry.dist
 

Methods in rice.pastry.dist with parameters of type Message
 ScheduledMessage DistPastryNode.scheduleMsg(Message msg, long delay)
          Schedule the specified message to be sent to the local node after a specified delay.
 ScheduledMessage DistPastryNode.scheduleMsg(Message msg, long delay, long period)
          Schedule the specified message for repeated fixed-delay delivery to the local node, beginning after the specified delay.
 ScheduledMessage DistPastryNode.scheduleMsgAtFixedRate(Message msg, long delay, long period)
          Schedule the specified message for repeated fixed-rate delivery to the local node, beginning after the specified delay.
 ExponentialBackoffScheduledMessage DistPastryNode.scheduleMsgExpBackoff(Message msg, long delay, long initialPeriod, double expBase)
           
 

Uses of Message in rice.pastry.join
 

Subclasses of Message in rice.pastry.join
 class InitiateJoin
          Request for the join protocols on the local node to join the overlay.
 class JoinRequest
          Request to join this network.
 

Uses of Message in rice.pastry.leafset
 

Subclasses of Message in rice.pastry.leafset
 class BroadcastLeafSet
          Broadcast a leaf set to another node.
 class InitiateLeafSetMaintenance
          Initiate leaf set maintenance on the local node.
 class RequestLeafSet
          Request a leaf set from another node.
 

Uses of Message in rice.pastry.leafset.testing
 

Methods in rice.pastry.leafset.testing with parameters of type Message
 void MergeTest.TestNodeHandle.receiveMessage(Message m)
          Deprecated.  
 

Uses of Message in rice.pastry.messaging
 

Subclasses of Message in rice.pastry.messaging
 class PJavaSerializedMessage
          Wrapper that converts rice.pastry.messaging.Message to rice.pastry.messageing.PRawMessage
 class PRawMessage
          Adapts Message to a RawMessage Adds the "sender" to the RawMessage
 

Methods in rice.pastry.messaging that return Message
abstract  Message PJavaSerializedDeserializer.deserialize(InputBuffer buf, short type, int priority, NodeHandle sender)
           
 Message RawMessageDelivery.deserialize(MessageDeserializer md)
           
 Message PJavaSerializedMessage.getMessage()
           
 

Methods in rice.pastry.messaging with parameters of type Message
 boolean MessageDispatch.dispatchMessage(Message msg)
          Dispatches a message to the appropriate receiver.
 PastryAppl MessageDispatch.getDestination(Message msg)
           
 

Constructors in rice.pastry.messaging with parameters of type Message
PJavaSerializedMessage(Message msg)
           
 

Uses of Message in rice.pastry.routing
 

Subclasses of Message in rice.pastry.routing
 class BroadcastRouteRow
          Broadcast message for a row from a routing table.
 class InitiateRouteSetMaintenance
          Initiate routing table maintenance on the local node
 class RequestRouteRow
          Request a row from the routing table from another node.
 class RouteMessage
          A route message contains a pastry message that has been wrapped to be sent to another pastry node.
 

Methods in rice.pastry.routing that return Message
 Message RouteMessage.unwrap()
          Deprecated. use unwrap(MessageDeserializer)
 Message RouteMessage.unwrap(MessageDeserializer md)
           
 

Constructors in rice.pastry.routing with parameters of type Message
RouteMessage(Id target, Message msg)
          Constructor.
RouteMessage(Id target, Message msg, NodeHandle firstHop)
          Constructor.
RouteMessage(Id target, Message msg, NodeHandle firstHop, SendOptions opts)
          Constructor.
RouteMessage(Id target, Message msg, SendOptions opts)
          Constructor.
RouteMessage(NodeHandle dest, Message msg, SendOptions opts)
          Constructor.
 

Uses of Message in rice.pastry.socket
 

Subclasses of Message in rice.pastry.socket
 class SourceRoute
          Class which represets a source route to a remote IP address.
 

Methods in rice.pastry.socket that return Message
 Message SocketBuffer.deserialize(MessageDeserializer md)
           
protected  Message SocketPastryNodeFactory.getResponse(java.net.InetSocketAddress address, Message message)
          This method anonymously sends the given message to the remote address, blocks until a response is received, and then closes the socket and returns the response.
 

Methods in rice.pastry.socket with parameters of type Message
 void SocketSourceRouteManager.bootstrap(EpochInetSocketAddress address, Message msg)
          Method which sends a bootstrap message across the wire.
 void SocketNodeHandle.bootstrap(Message msg)
          Method which is used by Pastry to start the bootstrapping process on the local node using this handle as the bootstrap handle.
 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.
 boolean SocketChannelWriter.enqueue(Message msg)
           
protected  Message SocketPastryNodeFactory.getResponse(java.net.InetSocketAddress address, Message message)
          This method anonymously sends the given message to the remote address, blocks until a response is received, and then closes the socket and returns the response.
protected  CancellableTask SocketPastryNodeFactory.getResponse(java.net.InetSocketAddress address, Message message, Continuation c)
           
 void SocketNodeHandle.receiveMessage(Message msg)
          Deprecated. use PastryNode.send(msg, nh)
 void SocketSourceRouteManager.send(EpochInetSocketAddress address, Message msg)
           
 void SocketPastryNode.send(NodeHandle handle, Message message)
           
 

Uses of Message in rice.pastry.socket.messaging
 

Subclasses of Message in rice.pastry.socket.messaging
 class DatagramMessage
          Class which represents a "ping" message sent through the socket pastry system.
 class IPAddressRequestMessage
          Class which represents a request for the external visible IP address
 class IPAddressResponseMessage
          Class which represents a request for the external visible IP address
 class LeafSetRequestMessage
          Message which represents a request to get the leafset from the remote node.
 class LeafSetResponseMessage
          A response message to a LeafSetRequestMessage, containing the remote node's leafset.
 class NodeIdRequestMessage
          Message which represents a request to get a node Id from the remote node.
 class NodeIdResponseMessage
          A response message to a NodeIdRequestMessage, containing the remote node's nodeId.
 class PingMessage
          Class which represents a "ping" message sent through the socket pastry system.
 class PingResponseMessage
          Class which represents a "ping" message sent through the socket pastry system.
 class RouteRowRequestMessage
          Message which represents a request to get the leafset from the remote node.
 class RouteRowResponseMessage
          A response message to a RouteRowRequestMessage, containing the remote node's routerow.
 class RoutesRequestMessage
          Message which represents a request to get the leafset from the remote node.
 class RoutesResponseMessage
          A response message to a RoutesRequestMessage, containing the remote node's routes.
 class SocketMessage
          Class which represents an abstract control message
 class WrongEpochMessage
          Class which represents a "ping" message sent through the socket pastry system.
 

Uses of Message in rice.pastry.standard
 

Subclasses of Message in rice.pastry.standard
 class ConsistentJoinMsg
           
 class InitiatePingNeighbor
          Initiate leaf set maintenance on the local node.
 

Methods in rice.pastry.standard that return Message
 Message PeriodicLeafSetProtocol.PLSPMessageDeserializer.deserialize(InputBuffer buf, short type, int priority, NodeHandle sender)
           
 

Methods in rice.pastry.standard with parameters of type Message
 void PeriodicLeafSetProtocol.messageForAppl(Message msg)
          Should not be called becasue we are overriding the receiveMessage() interface anyway.
 void StandardJoinProtocol.messageForAppl(Message msg)
          Should not be called becasue we are overriding the receiveMessage() interface anyway.
 void StandardLeafSetProtocol.messageForAppl(Message msg)
          Receives messages.
 void StandardRouteSetProtocol.messageForAppl(Message msg)
          Receives a message.
 void StandardRouter.messageForAppl(Message msg)
           
 void ConsistentJoinProtocol.receiveMessage(Message msg)
          Handle the CJM as in the MSR-TR
 void PeriodicLeafSetProtocol.receiveMessage(Message msg)
          Receives messages.
 void StandardJoinProtocol.receiveMessage(Message msg)
          Receives a message from the outside world.
 void StandardRouter.receiveMessage(Message msg)
          Receive a message from a remote node.
 

Uses of Message in rice.pastry.testing
 

Subclasses of Message in rice.pastry.testing
 class HelloMsg
           
 class PingMessageNew
          PingMessageNew A performance test suite for pastry.
 

Fields in rice.pastry.testing declared as Message
 Message PastryRegrTest.lastMsg
           
 

Methods in rice.pastry.testing with parameters of type Message
 void RegrTestApp.deliver(Id key, Message msg)
          Makes sure the message was delivered to the correct node by crossrefrencing the sorted nodes list in the simulator.
 boolean HelloWorldApp.enrouteMessage(Message msg, Id key, NodeHandle nextHop, SendOptions opt)
          Invoked on intermediate nodes in routing path.
 boolean Ping.enrouteMessage(Message msg, Id from, NodeHandle nextHop, SendOptions opt)
           
 boolean PingClient.enrouteMessage(Message msg, Id from, NodeHandle nextHop, SendOptions opt)
           
 void HelloWorldApp.messageForAppl(Message msg)
          Invoked on destination node when a message arrives.
 void Ping.messageForAppl(Message msg)
           
 void PingClient.messageForAppl(Message msg)
           
 void LeafSetTest.TestNodeHandle.receiveMessage(Message m)
          Deprecated.  
 


Rice Pastry API

Copyright © 2001-2005 - Rice Pastry.


Imprint-Dataprotection