|
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 | |||||||||