Uses of Interface
rice.p2p.commonapi.Cancellable

Packages that use Cancellable

org.mpisws.p2p.filetransfer
org.mpisws.p2p.transport
org.mpisws.p2p.transport.direct
org.mpisws.p2p.transport.liveness
org.mpisws.p2p.transport.networkinfo
org.mpisws.p2p.transport.peerreview
org.mpisws.p2p.transport.peerreview.identity
org.mpisws.p2p.transport.peerreview.message
org.mpisws.p2p.transport.peerreview.replay
org.mpisws.p2p.transport.rendezvous
org.mpisws.p2p.transport.table
org.mpisws.p2p.transport.util
org.mpisws.p2p.transport.wire
org.mpisws.p2p.transport.wire.magicnumber
rice.environment.processing
rice.environment.processing.sim
rice.environment.processing.simple
rice.p2p.commonapi
rice.p2p.util
rice.pastry
rice.pastry.direct
rice.pastry.pns
rice.pastry.routing
rice.pastry.socket.appsocket
rice.pastry.socket.nat.connectivityverifiier
rice.pastry.socket.nat.probe
rice.pastry.socket.nat.rendezvous
rice.pastry.standard
rice.pastry.transport
rice.selector

Uses of Cancellable in org.mpisws.p2p.filetransfer

Subinterfaces of Cancellable in org.mpisws.p2p.filetransfer

interface	BBReceipt
interface	FileReceipt
interface	Receipt

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

Methods in org.mpisws.p2p.transport.networkinfo that return Cancellable

Cancellable	InetSocketAddressLookup.getExternalNodes(java.net.InetSocketAddress bootstrap, Continuation<java.util.Collection<java.net.InetSocketAddress>,java.io.IOException> c, java.util.Map<java.lang.String,java.lang.Object> options) find nodes outside of our firewall so I can boot
Cancellable	NetworkInfoTransportLayer.getExternalNodes(java.net.InetSocketAddress bootstrap, Continuation<java.util.Collection<java.net.InetSocketAddress>,java.io.IOException> c, java.util.Map<java.lang.String,java.lang.Object> options)
Cancellable	NetworkInfoTransportLayer.getId(java.net.InetSocketAddress bootstrap, byte index, Continuation<byte[],java.io.IOException> c, java.util.Map<java.lang.String,java.lang.Object> options)
Cancellable	InetSocketAddressLookup.getMyInetAddress(java.net.InetSocketAddress bootstrap, Continuation<java.net.InetSocketAddress,java.io.IOException> c, java.util.Map<java.lang.String,java.lang.Object> options) Returns the local node's InetSocketAddress
Cancellable	NetworkInfoTransportLayer.getMyInetAddress(java.net.InetSocketAddress bootstrap, Continuation<java.net.InetSocketAddress,java.io.IOException> c, java.util.Map<java.lang.String,java.lang.Object> options)
Cancellable	NetworkInfoTransportLayer.probe(java.net.InetSocketAddress addr, long uid, Continuation<java.lang.Long,java.lang.Exception> deliverResponseToMe, java.util.Map<java.lang.String,java.lang.Object> options)
Cancellable	Prober.probe(java.net.InetSocketAddress addr, long uid, Continuation<java.lang.Long,java.lang.Exception> deliverResponseToMe, java.util.Map<java.lang.String,java.lang.Object> options)
Cancellable	ProbeStrategy.requestProbe(MultiInetSocketAddress addr, long uid, Continuation<java.lang.Boolean,java.lang.Exception> deliverResultToMe) Finds another node in the network and asks them to probe the addr with the uid calls Prober.probe() on another node
Cancellable	InetSocketAddressLookup.verifyConnectivity(MultiInetSocketAddress local, java.net.InetSocketAddress probeAddresses, ConnectivityResult deliverResultToMe, java.util.Map<java.lang.String,java.lang.Object> options) Verify that I have connectivity by using a third party.
Cancellable	NetworkInfoTransportLayer.verifyConnectivity(MultiInetSocketAddress local, java.net.InetSocketAddress probeAddress, ConnectivityResult deliverResultToMe, java.util.Map<java.lang.String,java.lang.Object> options) ask probeAddress to call probeStrategy.requestProbe()

Uses of Cancellable in org.mpisws.p2p.transport.peerreview

Methods in org.mpisws.p2p.transport.peerreview that return Cancellable

Cancellable	PeerReview.requestCertificate(Handle source, Identifier certHolder)
Cancellable	PeerReviewImpl.requestCertificate(Handle source, Identifier certHolder)
Cancellable	PeerReviewImpl.requestCertificate(Handle source, Identifier certHolder, Continuation<java.security.cert.X509Certificate,java.lang.Exception> c, java.util.Map<java.lang.String,java.lang.Object> options)

Uses of Cancellable in org.mpisws.p2p.transport.peerreview.identity

Methods in org.mpisws.p2p.transport.peerreview.identity that return Cancellable

Cancellable	CertificateManager.requestCertificate(Handle source, Identifier certHolder, Continuation<java.security.cert.X509Certificate,java.lang.Exception> c, java.util.Map<java.lang.String,java.lang.Object> options)
Cancellable	IdentityTransportLayerImpl.requestCertificate(Identifier source, I principal, Continuation<java.security.cert.X509Certificate,java.lang.Exception> c, java.util.Map<java.lang.String,java.lang.Object> options) CERT_REQUEST, int requestId, Identifier

Uses of Cancellable in org.mpisws.p2p.transport.peerreview.message

Classes in org.mpisws.p2p.transport.peerreview.message that implement Cancellable

class

OutgoingUserDataMessage<Handle extends RawSerializable>

Uses of Cancellable in org.mpisws.p2p.transport.peerreview.replay

Classes in org.mpisws.p2p.transport.peerreview.replay that implement Cancellable

class	ReplaySocket<Identifier extends RawSerializable>
class	VerifierMRH<Handle>

Uses of Cancellable in org.mpisws.p2p.transport.rendezvous

Methods in org.mpisws.p2p.transport.rendezvous that return Cancellable

Cancellable

RendezvousStrategy.openChannel(Identifier target, Identifier rendezvous, Identifier source, int uid, Continuation<java.lang.Integer,java.lang.Exception> deliverResultToMe, java.util.Map<java.lang.String,java.lang.Object> options) Calls ChannelOpener.openChannel(dest, credentials) on target Possible exceptions to deliverResultToMe: NodeIsFaultyException if target is faulty UnableToConnectException if dest is faulty Called by: 1) Rendezvous if the target and source are NATted 2) Source if target is NATted, but source isn't Not called if the pilotFinder found a pilot for the target (in FreePastry this means that this will not be called if the target is in the leafSet).

Uses of Cancellable in org.mpisws.p2p.transport.table

Methods in org.mpisws.p2p.transport.table that return Cancellable

Cancellable	TableTransportLayer.requestValue(Identifier source, Key key, Continuation<Value,java.lang.Exception> c, java.util.Map<java.lang.String,java.lang.Object> options) Get a Value of the source.
Cancellable	TableTransprotLayerImpl.requestValue(Identifier source, Key principal, Continuation<Value,java.lang.Exception> c, java.util.Map<java.lang.String,java.lang.Object> options) REQUEST, int requestId, Key

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	UDPLayerImpl.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.environment.processing

Classes in rice.environment.processing that implement Cancellable

class

WorkRequest<R> Extend this class and implement doWork() if you need to do blocking disk IO.

Methods in rice.environment.processing that return Cancellable

<R,E extends java.lang.Exception> Cancellable	Processor.process(Executable<R,E> task, Continuation<R,E> command, int priority, SelectorManager selector, TimeSource ts, LogManager log) Schedules a job for processing on the dedicated processing thread.
<R,E extends java.lang.Exception> Cancellable	Processor.process(Executable<R,E> task, Continuation<R,E> command, SelectorManager selector, TimeSource ts, LogManager log) Schedules a job for processing on the dedicated processing thread.
Cancellable	Processor.processBlockingIO(WorkRequest request) Schedules a different type of task.

Uses of Cancellable in rice.environment.processing.sim

Methods in rice.environment.processing.sim that return Cancellable

<R,E extends java.lang.Exception> Cancellable	SimProcessor.process(Executable<R,E> task, Continuation<R,E> command, int priority, SelectorManager selector, TimeSource ts, LogManager log)
<R,E extends java.lang.Exception> Cancellable	SimProcessor.process(Executable<R,E> task, Continuation<R,E> command, SelectorManager selector, TimeSource ts, LogManager log)
Cancellable	SimProcessor.processBlockingIO(WorkRequest request)

Uses of Cancellable in rice.environment.processing.simple

Classes in rice.environment.processing.simple that implement Cancellable

class

ProcessingRequest Scheduling with a lower priority number will be executed first (is higher Priority)

Methods in rice.environment.processing.simple that return Cancellable

<R,E extends java.lang.Exception> Cancellable	SimpleProcessor.process(Executable<R,E> task, Continuation<R,E> command, int priority, SelectorManager selector, TimeSource ts, LogManager log)
<R,E extends java.lang.Exception> Cancellable	SimpleProcessor.process(Executable<R,E> task, Continuation<R,E> command, SelectorManager selector, TimeSource ts, LogManager log) Schedules a job for processing on the dedicated processing thread.
Cancellable	SimpleProcessor.processBlockingIO(WorkRequest workRequest)
Cancellable	UnifiedProcessor.processBlockingIO(WorkRequest workRequest)

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

Methods in rice.pastry that return Cancellable

Cancellable

NodeHandleFetcher.getNodeHandle(java.lang.Object o, Continuation<NodeHandle,java.lang.Exception> c)

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) This method returns the remote leafset of the provided handle to the caller, in a protocol-dependent fashion.
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.appsocket

Methods in rice.pastry.socket.appsocket that return Cancellable

Cancellable	SocketFactory.getAppSocket(java.net.InetSocketAddress addr, int appid, Continuation<AppSocket,java.lang.Exception> c, java.util.Map<java.lang.String,java.lang.Object> options)
Cancellable	SocketFactory.getSocketChannel(java.net.InetSocketAddress addr, int appid, Continuation<java.nio.channels.SocketChannel,java.lang.Exception> c, java.util.Map<java.lang.String,java.lang.Object> options)

Uses of Cancellable in rice.pastry.socket.nat.connectivityverifiier

Methods in rice.pastry.socket.nat.connectivityverifiier that return Cancellable

Cancellable	ConnectivityVerifier.findExternalAddress(java.net.InetSocketAddress local, java.util.Collection<java.net.InetSocketAddress> probeAddresses, Continuation<java.net.InetAddress,java.io.IOException> deliverResultToMe) Finds the external address by contacting a random member of the probeAddresses
Cancellable	ConnectivityVerifierImpl.findExternalAddress(java.net.InetSocketAddress local, java.util.Collection<java.net.InetSocketAddress> probeAddresses, Continuation<java.net.InetAddress,java.io.IOException> deliverResultToMe) Call this to determine your external address.
Cancellable	ConnectivityVerifier.findExternalNodes(java.net.InetSocketAddress local, java.util.Collection<java.net.InetSocketAddress> probeAddresses, Continuation<java.util.Collection<java.net.InetSocketAddress>,java.io.IOException> deliverResultToMe) Finds known external nodes from other bootstrap nodes who are in your firewall
Cancellable	ConnectivityVerifierImpl.findExternalNodes(java.net.InetSocketAddress local, java.util.Collection<java.net.InetSocketAddress> probeAddresses, Continuation<java.util.Collection<java.net.InetSocketAddress>,java.io.IOException> deliverResultToMe) Call this to find some nodes outside your firewall.
protected Cancellable	ConnectivityVerifierImpl.getInetSocketAddressLookup(java.net.InetSocketAddress bindAddress, Continuation<InetSocketAddressLookup,java.io.IOException> deliverResultToMe) Get the address from the transport layer.
Cancellable	ConnectivityVerifier.verifyConnectivity(MultiInetSocketAddress local, java.util.Collection<java.net.InetSocketAddress> probeAddresses, ConnectivityResult deliverResultToMe) Verify my connectivity using a 3rd party
Cancellable	ConnectivityVerifierImpl.verifyConnectivity(MultiInetSocketAddress local, java.util.Collection<java.net.InetSocketAddress> probeAddresses, ConnectivityResult deliverResultToMe) Call this to determine if your connectivity is good.

Uses of Cancellable in rice.pastry.socket.nat.probe

Methods in rice.pastry.socket.nat.probe that return Cancellable

Cancellable

ProbeApp.requestProbe(MultiInetSocketAddress addr, long uid, Continuation<java.lang.Boolean,java.lang.Exception> deliverResultToMe) Send a ProbeRequestMessage to a node in the leafset.

Uses of Cancellable in rice.pastry.socket.nat.rendezvous

Methods in rice.pastry.socket.nat.rendezvous that return Cancellable

Cancellable	RendezvousPNSApplication.getLeafSet(NodeHandle input, Continuation<LeafSet,java.lang.Exception> c)
Cancellable	RendezvousPNSApplication.getNearest(NodeHandle seed, Continuation<java.util.Collection<NodeHandle>,java.lang.Exception> retToMe)
Cancellable	RendezvousPNSApplication.getNearHandles(java.util.Collection<NodeHandle> bootHandles, Continuation<java.util.Collection<NodeHandle>,java.lang.Exception> deliverResultToMe) This is the first step, cull out the bootHandles that we can't use good.
Cancellable	RendezvousPNSApplication.getProximity(NodeHandle handle, Continuation<java.lang.Integer,java.io.IOException> c, int timeout)
Cancellable	RendezvousPNSApplication.getRouteRow(NodeHandle input, short row, Continuation<RouteSet[],java.lang.Exception> c)
Cancellable	RendezvousApp.openChannel(RendezvousSocketNodeHandle target, RendezvousSocketNodeHandle rendezvous, RendezvousSocketNodeHandle source, int uid, Continuation<java.lang.Integer,java.lang.Exception> deliverAckToMe, java.util.Map<java.lang.String,java.lang.Object> options)

Uses of Cancellable in rice.pastry.standard

Classes in rice.pastry.standard that implement Cancellable

class

PartitionHandler The PartitionHandler does two things: it collects a list of candidate nodes that may be in another partition, and it periodically tries to reach these nodes to heal a partition.

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