Rice Pastry API

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
           
 


Rice Pastry API

Copyright © 2001-2005 - Rice Pastry.


Imprint-Dataprotection