|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of RawMessage in org.mpisws.p2p.transport.commonapi |
---|
Methods in org.mpisws.p2p.transport.commonapi that return RawMessage | |
---|---|
RawMessage |
RawMessageDeserializer.deserialize(InputBuffer b,
NodeHandle sender)
|
Methods in org.mpisws.p2p.transport.commonapi that return types with arguments of type RawMessage | |
---|---|
MessageRequestHandle<Identifier,RawMessage> |
CommonAPITransportLayerImpl.sendMessage(Identifier i,
RawMessage m,
MessageCallback<Identifier,RawMessage> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
Methods in org.mpisws.p2p.transport.commonapi with parameters of type RawMessage | |
---|---|
java.util.Map<java.lang.String,java.lang.Object> |
OptionsAdder.addOptions(java.util.Map<java.lang.String,java.lang.Object> options,
RawMessage m)
Add any options related to this message |
MessageRequestHandle<Identifier,RawMessage> |
CommonAPITransportLayerImpl.sendMessage(Identifier i,
RawMessage m,
MessageCallback<Identifier,RawMessage> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
void |
RawMessageDeserializer.serialize(RawMessage m,
OutputBuffer b)
|
Method parameters in org.mpisws.p2p.transport.commonapi with type arguments of type RawMessage | |
---|---|
MessageRequestHandle<Identifier,RawMessage> |
CommonAPITransportLayerImpl.sendMessage(Identifier i,
RawMessage m,
MessageCallback<Identifier,RawMessage> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
void |
CommonAPITransportLayerImpl.setCallback(TransportLayerCallback<Identifier,RawMessage> callback)
|
Uses of RawMessage in rice.p2p.commonapi |
---|
Methods in rice.p2p.commonapi with parameters of type RawMessage | |
---|---|
MessageReceipt |
Endpoint.route(Id id,
RawMessage message,
NodeHandle hint)
|
MessageReceipt |
Endpoint.route(Id id,
RawMessage message,
NodeHandle hint,
DeliveryNotification deliverAckToMe)
|
MessageReceipt |
Endpoint.route(Id id,
RawMessage message,
NodeHandle hint,
DeliveryNotification deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
Same as the other call, but uses the Raw serialization rather than java serialization. |
void |
RouteMessage.setMessage(RawMessage message)
Sets the internal message for this message Does the same as setMessage(Message) but with better performance, because it doesn't have to introspect if the message is a RawMessage |
Uses of RawMessage in rice.p2p.glacier.v2.messaging |
---|
Classes in rice.p2p.glacier.v2.messaging that implement RawMessage | |
---|---|
class |
GlacierDataMessage
|
class |
GlacierFetchMessage
|
class |
GlacierMessage
|
class |
GlacierNeighborRequestMessage
|
class |
GlacierNeighborResponseMessage
|
class |
GlacierQueryMessage
DESCRIBE THE CLASS |
class |
GlacierRangeForwardMessage
|
class |
GlacierRangeQueryMessage
|
class |
GlacierRangeResponseMessage
|
class |
GlacierRefreshCompleteMessage
|
class |
GlacierRefreshPatchMessage
|
class |
GlacierRefreshProbeMessage
|
class |
GlacierRefreshResponseMessage
|
class |
GlacierResponseMessage
|
class |
GlacierSyncMessage
|
class |
GlacierTimeoutMessage
|
Uses of RawMessage in rice.p2p.multiring |
---|
Methods in rice.p2p.multiring with parameters of type RawMessage | |
---|---|
MessageReceipt |
MultiringEndpoint.route(Id id,
RawMessage message,
NodeHandle hint)
|
MessageReceipt |
MultiringEndpoint.route(Id id,
RawMessage message,
NodeHandle hint,
DeliveryNotification deliverAckToMe)
|
MessageReceipt |
MultiringEndpoint.route(Id id,
RawMessage message,
NodeHandle hint,
DeliveryNotification deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
protected MessageReceipt |
MultiringNodeCollection.route(RingId id,
RawMessage message,
java.lang.String application,
DeliveryNotification deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
This method returns the best next-hop to a given target, using ring hopping, if one exists. |
void |
MultiringRouteMessage.setMessage(RawMessage message)
Better performance. |
Uses of RawMessage in rice.p2p.multiring.messaging |
---|
Fields in rice.p2p.multiring.messaging declared as RawMessage | |
---|---|
protected RawMessage |
RingMessage.message
The internal message to be sent |
Methods in rice.p2p.multiring.messaging that return RawMessage | |
---|---|
RawMessage |
RingMessage.getRawMessage()
Method which returns this messages' internal message |
Constructors in rice.p2p.multiring.messaging with parameters of type RawMessage | |
---|---|
RingMessage(RingId id,
RawMessage message,
java.lang.String application)
Constructor which takes a unique integer Id |
Uses of RawMessage in rice.p2p.past.gc |
---|
Methods in rice.p2p.past.gc with parameters of type RawMessage | |
---|---|
MessageReceipt |
GCEndpoint.route(Id id,
RawMessage message,
NodeHandle hint)
|
MessageReceipt |
GCEndpoint.route(Id id,
RawMessage message,
NodeHandle hint,
DeliveryNotification deliverAckToMe)
|
MessageReceipt |
GCEndpoint.route(Id id,
RawMessage message,
NodeHandle hint,
DeliveryNotification deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
Uses of RawMessage in rice.p2p.past.gc.messaging |
---|
Classes in rice.p2p.past.gc.messaging that implement RawMessage | |
---|---|
class |
GCCollectMessage
|
class |
GCInsertMessage
|
class |
GCLookupHandlesMessage
|
class |
GCRefreshMessage
|
Uses of RawMessage in rice.p2p.past.messaging |
---|
Classes in rice.p2p.past.messaging that implement RawMessage | |
---|---|
class |
CacheMessage
|
class |
ContinuationMessage
|
class |
FetchHandleMessage
|
class |
FetchMessage
|
class |
InsertMessage
|
class |
LookupHandlesMessage
|
class |
LookupMessage
|
class |
MessageLostMessage
|
class |
PastMessage
|
Uses of RawMessage in rice.p2p.past.testing |
---|
Methods in rice.p2p.past.testing with parameters of type RawMessage | |
---|---|
void |
PastRegrTest.TestRouteMessage.setMessage(RawMessage message)
|
void |
RawPastRegrTest.TestRouteMessage.setMessage(RawMessage message)
|
Uses of RawMessage in rice.p2p.replication.messaging |
---|
Classes in rice.p2p.replication.messaging that implement RawMessage | |
---|---|
class |
ReminderMessage
|
class |
ReplicationMessage
|
class |
RequestMessage
|
class |
ResponseMessage
|
Uses of RawMessage in rice.p2p.scribe.messaging |
---|
Classes in rice.p2p.scribe.messaging that implement RawMessage | |
---|---|
class |
AbstractSubscribeMessage
|
class |
AnycastFailureMessage
|
class |
AnycastMessage
|
class |
DropMessage
|
class |
PublishMessage
|
class |
PublishRequestMessage
|
class |
ScribeMessage
|
class |
SubscribeAckMessage
|
class |
SubscribeFailedMessage
|
class |
SubscribeMessage
|
class |
UnsubscribeMessage
|
Uses of RawMessage in rice.p2p.scribe.testing |
---|
Methods in rice.p2p.scribe.testing with parameters of type RawMessage | |
---|---|
void |
ScribeRegrTest.TestRouteMessage.setMessage(RawMessage message)
|
Uses of RawMessage in rice.p2p.util |
---|
Method parameters in rice.p2p.util with type arguments of type RawMessage | |
---|---|
void |
MCAdapter.ack(MessageRequestHandle<NodeHandle,RawMessage> msg)
|
void |
MCAdapter.sendFailed(MessageRequestHandle<NodeHandle,RawMessage> msg,
java.lang.Exception reason)
|
void |
MRHAdapter.setInternal(MessageRequestHandle<NodeHandle,RawMessage> name)
|
Uses of RawMessage in rice.p2p.util.rawserialization |
---|
Classes in rice.p2p.util.rawserialization that implement RawMessage | |
---|---|
class |
JavaSerializedMessage
Wrapper that converts rice.pastry.messaging.Message to rice.pastry.messageing.PRawMessage |
Uses of RawMessage in rice.pastry |
---|
Fields in rice.pastry with type parameters of type RawMessage | |
---|---|
protected TransportLayer<NodeHandle,RawMessage> |
PastryNode.tl
The top level transport layer. |
Methods in rice.pastry that return types with arguments of type RawMessage | |
---|---|
TransportLayer<NodeHandle,RawMessage> |
PastryNode.getTL()
|
Methods in rice.pastry with parameters of type RawMessage | |
---|---|
void |
PastryNode.messageReceived(NodeHandle i,
RawMessage m,
java.util.Map<java.lang.String,java.lang.Object> options)
|
Method parameters in rice.pastry with type arguments of type RawMessage | |
---|---|
void |
PastryNode.setSocketElements(int lsmf,
int rsmf,
TransportLayer<NodeHandle,RawMessage> tl,
LivenessProvider<NodeHandle> livenessProvider,
ProximityProvider<NodeHandle> proxProvider,
NodeHandleFactory handleFactory)
|
Uses of RawMessage in rice.pastry.commonapi |
---|
Classes in rice.pastry.commonapi that implement RawMessage | |
---|---|
class |
PastryEndpointMessage
This class is an internal message to the commonapi gluecode. |
Fields in rice.pastry.commonapi declared as RawMessage | |
---|---|
protected RawMessage |
PastryEndpointMessage.message
|
Methods in rice.pastry.commonapi with parameters of type RawMessage | |
---|---|
static void |
PastryEndpointMessage.checkRawType(RawMessage message)
|
MessageReceipt |
PastryEndpoint.route(Id key,
RawMessage msg,
NodeHandle hint)
This duplication of the above code is to make a fast path for the RawMessage. |
MessageReceipt |
PastryEndpoint.route(Id key,
RawMessage msg,
NodeHandle hint,
DeliveryNotification deliverAckToMe)
|
MessageReceipt |
PastryEndpoint.route(Id key,
RawMessage msg,
NodeHandle hint,
DeliveryNotification deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
void |
PastryEndpointMessage.setMessage(RawMessage message)
Returns the internal message |
Constructors in rice.pastry.commonapi with parameters of type RawMessage | |
---|---|
PastryEndpointMessage(int address,
RawMessage message,
NodeHandle sender)
|
Uses of RawMessage in rice.pastry.direct |
---|
Methods in rice.pastry.direct that return types with arguments of type RawMessage | |
---|---|
protected TransportLayer<NodeHandle,RawMessage> |
DirectPastryNodeFactory.getDirectTransportLayer(PastryNode pn,
NodeRecord nr)
Override me |
NetworkSimulator<DirectNodeHandle,RawMessage> |
DirectPastryNodeFactory.getNetworkSimulator()
Getter for the NetworkSimulator. |
Constructor parameters in rice.pastry.direct with type arguments of type RawMessage | |
---|---|
DirectPastryNodeFactory(NodeIdFactory nf,
NetworkSimulator<DirectNodeHandle,RawMessage> sim,
Environment env)
Main constructor. |
Uses of RawMessage in rice.pastry.join |
---|
Classes in rice.pastry.join that implement RawMessage | |
---|---|
class |
JoinRequest
Request to join this network. |
Uses of RawMessage in rice.pastry.leafset |
---|
Classes in rice.pastry.leafset that implement RawMessage | |
---|---|
class |
BroadcastLeafSet
Broadcast a leaf set to another node. |
class |
RequestLeafSet
Request a leaf set from another node. |
Uses of RawMessage in rice.pastry.messaging |
---|
Classes in rice.pastry.messaging that implement RawMessage | |
---|---|
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 |
Uses of RawMessage in rice.pastry.peerreview |
---|
Classes in rice.pastry.peerreview that implement RawMessage | |
---|---|
class |
FetchLeafsetRequest
|
class |
FetchLeafsetResponse
|
Uses of RawMessage in rice.pastry.pns.messages |
---|
Classes in rice.pastry.pns.messages that implement RawMessage | |
---|---|
class |
LeafSetRequest
|
class |
LeafSetResponse
|
class |
RouteRowRequest
|
class |
RouteRowResponse
|
Uses of RawMessage in rice.pastry.routing |
---|
Classes in rice.pastry.routing that implement RawMessage | |
---|---|
class |
BroadcastRouteRow
Broadcast message for a row from a routing table. |
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 with parameters of type RawMessage | |
---|---|
void |
RouteMessage.setMessage(RawMessage message)
|
Uses of RawMessage in rice.pastry.socket |
---|
Fields in rice.pastry.socket with type parameters of type RawMessage | |
---|---|
protected TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,RawMessage> |
SocketPastryNodeFactory.TLBootstrapper.tl
|
Methods in rice.pastry.socket that return types with arguments of type RawMessage | |
---|---|
protected TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,RawMessage> |
SocketPastryNodeFactory.getCommonAPITransportLayer(TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,java.nio.ByteBuffer> upperIdentity,
PastryNode pn,
TLDeserializer deserializer)
|
Constructor parameters in rice.pastry.socket with type arguments of type RawMessage | |
---|---|
SocketPastryNodeFactory.TLBootstrapper(PastryNode pn,
TransportLayer<TransportLayerNodeHandle<MultiInetSocketAddress>,RawMessage> tl,
SocketNodeHandleFactory handleFactory,
ProximityNeighborSelector pns)
|
Uses of RawMessage in rice.pastry.socket.nat.probe |
---|
Classes in rice.pastry.socket.nat.probe that implement RawMessage | |
---|---|
class |
ProbeRequestMessage
|
Uses of RawMessage in rice.pastry.socket.nat.rendezvous |
---|
Classes in rice.pastry.socket.nat.rendezvous that implement RawMessage | |
---|---|
class |
ByteBufferMsg
Used to hold a UDP message (usually liveness) when delivering to a firewalled node via Routing. |
class |
OpenChannelMsg
|
class |
PilotForwardMsg
|
class |
RendezvousJoinRequest
Includes the bootstrap (or some other node who will have a pilot from the joiner.) |
Uses of RawMessage in rice.pastry.standard |
---|
Classes in rice.pastry.standard that implement RawMessage | |
---|---|
class |
ConsistentJoinMsg
|
Uses of RawMessage in rice.pastry.transport |
---|
Methods in rice.pastry.transport that return RawMessage | |
---|---|
RawMessage |
TLDeserializer.deserialize(InputBuffer buf,
NodeHandle sender)
|
Methods in rice.pastry.transport that return types with arguments of type RawMessage | |
---|---|
MessageRequestHandle<NodeHandle,RawMessage> |
PMessageReceiptImpl.getInternal()
|
MessageRequestHandle<NodeHandle,RawMessage> |
NodeHandleAdapter.sendMessage(NodeHandle i,
RawMessage m,
MessageCallback<NodeHandle,RawMessage> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
Methods in rice.pastry.transport with parameters of type RawMessage | |
---|---|
MessageRequestHandle<NodeHandle,RawMessage> |
NodeHandleAdapter.sendMessage(NodeHandle i,
RawMessage m,
MessageCallback<NodeHandle,RawMessage> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
void |
TLDeserializer.serialize(RawMessage m,
OutputBuffer o)
|
Method parameters in rice.pastry.transport with type arguments of type RawMessage | |
---|---|
MessageRequestHandle<NodeHandle,RawMessage> |
NodeHandleAdapter.sendMessage(NodeHandle i,
RawMessage m,
MessageCallback<NodeHandle,RawMessage> deliverAckToMe,
java.util.Map<java.lang.String,java.lang.Object> options)
|
void |
NodeHandleAdapter.setCallback(TransportLayerCallback<NodeHandle,RawMessage> callback)
|
void |
PMessageReceiptImpl.setInternal(MessageRequestHandle<NodeHandle,RawMessage> name)
See synchronization note on cancel() |
Uses of RawMessage in rice.tutorial.rawserialization |
---|
Classes in rice.tutorial.rawserialization that implement RawMessage | |
---|---|
class |
MyMsg
An example message. |
|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |