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