Overview | Package | Class | Use | Tree | Deprecated | Index | Help
| Rice Pastry API
PREV NEXT | FRAMES NO FRAMES

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

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
| Rice Pastry API
PREV NEXT | FRAMES NO FRAMES

Copyright © 2001-2005 - Rice Pastry.