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.replay.playback |
org.mpisws.p2p.transport.rendezvous |
org.mpisws.p2p.transport.util |
org.mpisws.p2p.transport.wire |
org.mpisws.p2p.transport.wire.magicnumber |
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` | `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.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` | `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.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.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)` 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.