|
Rice Pastry API | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of Cancellable in org.mpisws.p2p.transport |
|---|
| Subinterfaces of Cancellable in org.mpisws.p2p.transport | |
|---|---|
interface |
MessageRequestHandle<Identifier,MessageType>
Can cancel the request to send the message. |
interface |
SocketRequestHandle<Identifier>
Can cancel the request to open the socket. |
| Uses of Cancellable in org.mpisws.p2p.transport.direct |
|---|
| Methods in org.mpisws.p2p.transport.direct that return Cancellable | |
|---|---|
Cancellable |
GenericNetworkSimulator.deliverMessage(MessageType msg,
Identifier to,
Identifier from,
int delay)
Deliver message. |
| Uses of Cancellable in org.mpisws.p2p.transport.liveness |
|---|
| Classes in org.mpisws.p2p.transport.liveness that implement Cancellable | |
|---|---|
protected class |
LivenessTransportLayerImpl.DeadChecker
DESCRIBE THE CLASS |
| Uses of Cancellable in org.mpisws.p2p.transport.peerreview.replay.playback |
|---|
| Classes in org.mpisws.p2p.transport.peerreview.replay.playback that implement Cancellable | |
|---|---|
class |
ReplaySocket<Identifier>
|
| Uses of Cancellable in org.mpisws.p2p.transport.rendezvous |
|---|
| Methods in org.mpisws.p2p.transport.rendezvous that return Cancellable | |
|---|---|
Cancellable |
ChannelOpener.openChannel(Identifier dest,
byte cnnectionType,
byte[] credentials,
Continuation<java.lang.Integer,java.lang.Exception> deliverResultToMe)
Open a socket to the dest, then after writing credentials, call notify the higher layer: incomingSocket() |
Cancellable |
RendezvousStrategy.openChannel(Identifier target,
Identifier rendezvous,
byte[] credentials,
Continuation<java.lang.Integer,java.lang.Exception> deliverResultToMe)
Calls ChannelOpener.openChannel(dest, credentials) on target Possible exceptions to deliverResultToMe: NodeIsFaultyException if target is faulty UnableToConnectException if dest is faulty |
| Uses of Cancellable in org.mpisws.p2p.transport.util |
|---|
| Classes in org.mpisws.p2p.transport.util that implement Cancellable | |
|---|---|
class |
MessageRequestHandleImpl<Identifier,MessageType>
|
class |
SocketRequestHandleImpl<Identifier>
|
| Methods in org.mpisws.p2p.transport.util that return Cancellable | |
|---|---|
Cancellable |
MessageRequestHandleImpl.getSubCancellable()
|
Cancellable |
SocketRequestHandleImpl.getSubCancellable()
|
| Methods in org.mpisws.p2p.transport.util with parameters of type Cancellable | |
|---|---|
void |
MessageRequestHandleImpl.setSubCancellable(Cancellable cancellable)
|
void |
SocketRequestHandleImpl.setSubCancellable(Cancellable sub)
|
| Uses of Cancellable in org.mpisws.p2p.transport.wire |
|---|
| Classes in org.mpisws.p2p.transport.wire that implement Cancellable | |
|---|---|
class |
SocketManager
|
class |
UDPLayer.Envelope
Internal class which holds a pending datagram |
| Uses of Cancellable in org.mpisws.p2p.transport.wire.magicnumber |
|---|
| Classes in org.mpisws.p2p.transport.wire.magicnumber that implement Cancellable | |
|---|---|
protected class |
MagicNumberTransportLayer.VerifyHeaderReceiver
|
| Uses of Cancellable in rice.p2p.commonapi |
|---|
| Subinterfaces of Cancellable in rice.p2p.commonapi | |
|---|---|
interface |
CancellableTask
This class represents a task which can be cancelled by the caller. |
interface |
MessageReceipt
Returned by a call to endpoint.route(). |
| Uses of Cancellable in rice.p2p.util |
|---|
| Classes in rice.p2p.util that implement Cancellable | |
|---|---|
class |
AttachableCancellable
Allows you to cancel a group of things. |
class |
MRHAdapter
Addapts a RawMessage to a normal Message |
static class |
TimerWeakHashMap.HardLinkTimerTask
|
| Methods in rice.p2p.util with parameters of type Cancellable | |
|---|---|
void |
AttachableCancellable.attach(Cancellable c)
|
void |
AttachableCancellable.detach(Cancellable c)
|
| Uses of Cancellable in rice.pastry |
|---|
| Classes in rice.pastry that implement Cancellable | |
|---|---|
class |
ExponentialBackoffScheduledMessage
|
class |
ScheduledMessage
A class that represents scheduled message events |
| Uses of Cancellable in rice.pastry.direct |
|---|
| Classes in rice.pastry.direct that implement Cancellable | |
|---|---|
class |
DeliveryTimerTask
|
class |
DirectTimerTask
|
| Methods in rice.pastry.direct that return Cancellable | |
|---|---|
Cancellable |
BasicNetworkSimulator.deliverMessage(MessageType msg,
Identifier node,
Identifier from)
node should always be a local node, because this will be delivered instantly |
Cancellable |
BasicNetworkSimulator.deliverMessage(MessageType msg,
Identifier node,
Identifier from,
int delay)
|
Cancellable |
BasicNetworkSimulator.deliverMessage(MessageType msg,
Identifier node,
Identifier from,
int delay,
int period)
|
Cancellable |
BasicNetworkSimulator.deliverMessageFixedRate(MessageType msg,
Identifier node,
Identifier from,
int delay,
int period)
|
| Uses of Cancellable in rice.pastry.pns |
|---|
| Methods in rice.pastry.pns that return Cancellable | |
|---|---|
Cancellable |
PNSApplication.getLeafSet(NodeHandle handle,
Continuation<LeafSet,java.lang.Exception> c)
Non-blocking version. |
Cancellable |
PNSApplication.getNearest(NodeHandle seed,
Continuation<java.util.Collection<NodeHandle>,java.lang.Exception> retToMe)
This method implements the algorithm in the Pastry locality paper for finding a close node the the current node through iterative leafset and route row requests. |
Cancellable |
PNSApplication.getNearHandles(java.util.Collection<NodeHandle> bootHandles,
Continuation<java.util.Collection<NodeHandle>,java.lang.Exception> deliverResultToMe)
|
Cancellable |
PNSApplication.getProximity(NodeHandle handle,
Continuation<java.lang.Integer,java.io.IOException> c,
int timeout)
Non-blocking version, no timeout. |
Cancellable |
PNSApplication.getRouteRow(NodeHandle handle,
short row,
Continuation<RouteSet[],java.lang.Exception> c)
Non-blocking version. |
| Methods in rice.pastry.pns with parameters of type Cancellable | |
|---|---|
protected void |
PNSApplication.addToWaitingForLeafSet(NodeHandle handle,
Continuation<LeafSet,java.lang.Exception> c,
Cancellable cancelMeWhenSuccess)
|
protected void |
PNSApplication.addToWaitingForRouteRow(NodeHandle handle,
int row,
Continuation<RouteSet[],java.lang.Exception> c,
Cancellable cancelMeWhenSuccess)
|
| Uses of Cancellable in rice.pastry.routing |
|---|
| Methods in rice.pastry.routing with parameters of type Cancellable | |
|---|---|
void |
RouteMessage.setTLCancellable(Cancellable c)
|
| Uses of Cancellable in rice.pastry.socket.nat.rendezvous |
|---|
| Methods in rice.pastry.socket.nat.rendezvous that return Cancellable | |
|---|---|
Cancellable |
RendezvousApp.openChannel(RendezvousSocketNodeHandle target,
RendezvousSocketNodeHandle rendezvous,
byte[] credentials,
Continuation<java.lang.Integer,java.lang.Exception> deliverResultToMe)
|
| Uses of Cancellable in rice.pastry.standard |
|---|
| Classes in rice.pastry.standard that implement Cancellable | |
|---|---|
class |
PartitionHandler
|
| Methods in rice.pastry.standard that return Cancellable | |
|---|---|
Cancellable |
ProximityNeighborSelector.getNearHandles(java.util.Collection<NodeHandle> bootHandles,
Continuation<java.util.Collection<NodeHandle>,java.lang.Exception> deliverResultToMe)
|
| Uses of Cancellable in rice.pastry.transport |
|---|
| Subinterfaces of Cancellable in rice.pastry.transport | |
|---|---|
interface |
PMessageReceipt
|
| Classes in rice.pastry.transport that implement Cancellable | |
|---|---|
class |
PMessageReceiptImpl
|
| Uses of Cancellable in rice.selector |
|---|
| Classes in rice.selector that implement Cancellable | |
|---|---|
class |
TimerTask
|
|
Rice Pastry API | |||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||