ePOST API

Uses of Interface
rice.Continuation

Packages that use Continuation
rice   
rice.email   
rice.email.log   
rice.email.proxy.smtp.manager   
rice.environment.processing   
rice.environment.processing.sim   
rice.environment.processing.simple   
rice.p2p.aggregation   
rice.p2p.commonapi   
rice.p2p.glacier   
rice.p2p.glacier.v2   
rice.p2p.multiring   
rice.p2p.past   
rice.p2p.past.gc   
rice.p2p.past.gc.messaging   
rice.p2p.past.messaging   
rice.p2p.past.testing   
rice.p2p.replication.manager   
rice.p2p.replication.manager.testing   
rice.pastry   
rice.pastry.commonapi   
rice.pastry.direct   
rice.pastry.dist   
rice.pastry.socket   
rice.persistence   
rice.persistence.testing   
rice.post   
rice.post.delivery   
rice.post.log   
rice.post.security   
rice.post.security.ca   
rice.post.security.pknoi   
rice.post.storage   
 

Uses of Continuation in rice
 

Classes in rice that implement Continuation
static class Continuation.ErrorContinuation
          This class is a Continuation provided for simplicity which passes any results up to the parent Continuation which it is constructed with.
static class Continuation.ExternalContinuation
          This class provides a continuation which is designed to be used from an external thread.
static class Continuation.ListenerContinuation
          This class is a Continuation provided for simplicity which listens for any errors and ignores any success values.
static class Continuation.NamedContinuation
          Continuation class which takes a provided string as it's name, and returns that String when toString() is called.
static class Continuation.SimpleContinuation
          This class is a Continuation provided for simplicity which passes both results and exceptions to the receiveResult() method.
static class Continuation.StandardContinuation
          This class is a Continuation provided for simplicity which passes any errors up to the parent Continuation which it is constructed with.
 

Fields in rice declared as Continuation
protected  Continuation Continuation.StandardContinuation.parent
          The parent continuation
protected  Continuation Continuation.ErrorContinuation.parent
          The parent continuation
protected  Continuation Continuation.MultiContinuation.parent
           
protected  Continuation Continuation.NamedContinuation.parent
           
 

Methods in rice that return Continuation
 Continuation Continuation.MultiContinuation.getSubContinuation(int index)
          Returns the continuation which should be used as the result continuation for the index-th result.
 

Methods in rice with parameters of type Continuation
protected abstract  void Continuation.ExternalContinuationRunnable.execute(Continuation c)
           
protected  void Continuation.ExternalRunnable.execute(Continuation c)
           
 

Constructors in rice with parameters of type Continuation
Continuation.ErrorContinuation(Continuation continuation)
          Constructor which takes in the parent continuation for this continuation.
Continuation.MultiContinuation(Continuation parent, int num)
          Constructor which takes a parent continuation as well as the number of results which to expect.
Continuation.NamedContinuation(java.lang.String name, Continuation command)
          Builds a new NamedContinuation given the name and the wrapped continuation
Continuation.StandardContinuation(Continuation continuation)
          Constructor which takes in the parent continuation for this continuation.
 

Uses of Continuation in rice.email
 

Methods in rice.email with parameters of type Continuation
 void Folder.addChildFolder(Folder folder, Continuation command)
          Adds an existing folder as a child folder of this folder
 void Folder.addMessage(Email email, Continuation command)
          Appends an email to this Folder, with default (no) flags set.
 void Folder.addMessage(Email email, Flags flags, long internaldate, Continuation command)
          Appends an email to this Folder with the specified flags set.
 void Folder.addMessages(Email[] emails, Flags[] flags, long[] internaldates, Continuation command)
          Appends an email to this Folder with the specified flags set.
 void EmailService.addSubscription(java.lang.String sub, Continuation command)
          Adds a subscriptions to the log
 void Folder.addSubscription(java.lang.String sub, Continuation command)
          Adds a subscriptions to the log
 void Folder.createChildFolder(java.lang.String name, Continuation command)
          Creates a new child of the given name.
 void Folder.createSnapShot(Continuation command)
          Creates and inserts a snapshot for the current folder
 void EmailService.expand(PostUserAddress[] list, SmtpManager manager, Continuation command)
          Method which expands the given list of PostUserAddresses by recursively checking for forwarding lists
 void Folder.getChildFolder(java.lang.String name, Continuation command)
          Returns the selected Folder.
protected  void Folder.getChildReferences(java.util.Set set, Continuation command)
           
abstract  void EmailContentPart.getContent(Continuation command)
          Method which retrieves and returns this content's EmailData
 void EmailHeadersPart.getContent(Continuation command)
          Returns the content of this part
 void EmailMultiPart.getContent(Continuation command)
          Method which retrieves and returns this content's EmailData
 void EmailSinglePart.getContent(Continuation command)
          Method which retrieves and returns this content's EmailData
 void EmailService.getContentHashReferences(Continuation command)
          This method is periodically invoked by Post in order to get a list of all handles under which the application has live objects.
 void Folder.getContentHashReferences(java.util.Set set, Continuation command)
          This method returns a list of all the handles stored in the folder or any subfolders.
 void EmailHeadersPart.getHeaders(Continuation command)
          Returns the headers of this EmailPart to the continuation
protected  void Folder.getLogReferences(java.util.Set set, Continuation command)
           
protected  void Folder.getLogReferences(java.util.Set set, SnapShot[] snapshot, Continuation command)
           
 void EmailService.getLogs(Continuation command)
          This method is periodically invoked by Post in order to get a list of all mutable data which the application is interested in.
 void Folder.getLogs(java.util.Set set, Continuation command)
          This method is periodically invoked by Post in order to get a list of all mutable data which the application is interested in.
protected  void Folder.getMessageReferences(java.util.Set set, Continuation command)
           
 void Folder.getMessages(Continuation command)
          Returns the Emails contained in this Folder.
 void Folder.getMessages(SnapShot[] snapshots, Continuation command)
          Returns the Emails contained in this Folder.
 void EmailService.getRootFolder(Continuation command)
          Returns the Log for ePost's root folder.
 void EmailService.getSubscriptions(Continuation command)
          Returns the list of subscriptions in the log
 void Folder.getSubscriptions(Continuation command)
          Returns the list of subscriptions in the log
 void Folder.moveMessage(StoredEmail email, Folder folder, Continuation command)
          Moves a message from this folder into a another, given folder.
 void EmailService.notificationReceived(NotificationMessage nm, Continuation command)
          This method is how the Post layer informs the EmailService layer that there is an incoming notification of new email.
 void Folder.removeFolder(java.lang.String name, Continuation command)
          Deletes a folder from the user's mailbox.
 void Folder.removeMessage(StoredEmail email, Continuation command)
          Deletes a message from this Folder.
 void Folder.removeMessages(StoredEmail[] email, Continuation command)
          Deletes a list of messages from this Folder.
 void EmailService.removeSubscription(java.lang.String sub, Continuation command)
          Adds a subscriptions to the log
 void Folder.removeSubscription(java.lang.String sub, Continuation command)
          Adds a subscriptions to the log
 void EmailService.sendMessage(Email email, Continuation command)
          Sends the email to the recipient.
 void Folder.setName(java.lang.String name, Continuation command)
          Changes the name of this folder.
protected  void Email.storeData(Continuation command)
          Stores the content of the Email into PAST and saves the references to the content in the email.
abstract  void EmailContentPart.storeData(Continuation command)
          Method which writes this part's content out to disk and retrieves a reference to it.
 void EmailHeadersPart.storeData(Continuation command)
          Method which writes this part's headers out to disk and retrieves a reference to it.
 void EmailMultiPart.storeData(Continuation command)
          Method which writes this part's content out to disk and retrieves a reference to it.
 void EmailSinglePart.storeData(Continuation command)
          Method which writes this part's content out to disk and retrieves a reference to it.
 void Folder.updateMessage(StoredEmail email, Continuation command)
          Updates an Email (flags)
 void Folder.updateMessages(StoredEmail[] emails, Continuation command)
          Updates a list of Emails (flags)
 

Uses of Continuation in rice.email.log
 

Methods in rice.email.log with parameters of type Continuation
 void EmailLog.addSubscription(java.lang.String sub, Continuation command)
          Adds a subscriptions to the log
 void EmailLog.getSnapshot(Continuation command)
          Returns the most recent snapshot reference
 void EmailLog.getSubscriptions(Continuation command)
          Returns the list of subscriptions in the log
 void EmailLog.reconcile(EmailLog otherLog, java.security.KeyPair keyPair, Continuation command)
           
 void EmailLog.removeSubscription(java.lang.String sub, Continuation command)
          Adds a subscriptions to the log
 void EmailLog.setSnapshot(SnapShot[] newsnapshots, Continuation command)
          Sets the newest snapshot
 

Uses of Continuation in rice.email.proxy.smtp.manager
 

Methods in rice.email.proxy.smtp.manager with parameters of type Continuation
 void SimpleManager.isPostAddress(MailAddress addr, Continuation c)
           
 void SimpleManager.isPostAddress(java.lang.String addr, Continuation c)
           
 void SmtpManager.isPostAddress(java.lang.String string, Continuation c)
           
 

Uses of Continuation in rice.environment.processing
 

Methods in rice.environment.processing with parameters of type Continuation
 void Processor.process(Executable task, Continuation command, SelectorManager selector, TimeSource ts, LogManager log)
          Schedules a job for processing on the dedicated processing thread.
 

Constructors in rice.environment.processing with parameters of type Continuation
WorkRequest(Continuation c, SelectorManager sm)
           
 

Uses of Continuation in rice.environment.processing.sim
 

Methods in rice.environment.processing.sim with parameters of type Continuation
 void SimProcessor.process(Executable task, Continuation command, SelectorManager selector, TimeSource ts, LogManager log)
           
 

Uses of Continuation in rice.environment.processing.simple
 

Methods in rice.environment.processing.simple with parameters of type Continuation
 void SimpleProcessor.process(Executable task, Continuation command, SelectorManager selector, TimeSource ts, LogManager log)
          Schedules a job for processing on the dedicated processing thread.
 

Constructors in rice.environment.processing.simple with parameters of type Continuation
ProcessingRequest(Executable r, Continuation c, LogManager logging, TimeSource timeSource, SelectorManager selectorManager)
           
 

Uses of Continuation in rice.p2p.aggregation
 

Fields in rice.p2p.aggregation declared as Continuation
protected  Continuation AggregationImpl.flushWait
           
 

Methods in rice.p2p.aggregation with parameters of type Continuation
 void AggregationImpl.fetch(PastContentHandle handle, Continuation command)
           
 void Aggregation.flush(Continuation command)
          Creates aggregates from all objects in the local object cache.
 void AggregationImpl.flush(Continuation command)
           
 void Aggregation.flush(Id id, Continuation command)
          Creates an aggregate that includes the most current object with the specified key.
 void AggregationImpl.flush(Id id, Continuation command)
           
 void AggregationImpl.insert(PastContent obj, Continuation command)
           
 void AggregationImpl.insert(PastContent obj, long lifetime, Continuation command)
           
 void AggregationImpl.lookup(Id id, boolean cache, Continuation command)
           
 void AggregationImpl.lookup(Id id, Continuation command)
           
 void AggregationImpl.lookup(Id id, long version, Continuation command)
           
 void AggregationImpl.lookupHandle(Id id, NodeHandle handle, Continuation command)
           
 void AggregationImpl.lookupHandles(Id id, int max, Continuation command)
           
 void AggregationImpl.lookupHandles(Id id, long version, int max, Continuation command)
           
 void AggregationImpl.refresh(Id[] ids, long[] expirations, Continuation command)
           
 void AggregationImpl.refresh(Id[] ids, long[] versions, long[] expirations, Continuation command)
           
 void AggregationImpl.refresh(Id[] ids, long expiration, Continuation command)
           
 void Aggregation.reset(Continuation command)
          Deletes all local state, including the aggregate list and all objects waiting in the local buffer.
 void AggregationImpl.reset(Continuation command)
           
 void Aggregation.rollback(Id id, Continuation command)
          Attempts to retrieve the most recent object that has been inserted by the local node under the specified key.
 void AggregationImpl.rollback(Id id, Continuation command)
           
 void Aggregation.setHandle(java.io.Serializable handle, Continuation command)
          Restores the handle object.
 void AggregationImpl.setHandle(java.io.Serializable handle, Continuation command)
           
 

Uses of Continuation in rice.p2p.commonapi
 

Methods in rice.p2p.commonapi with parameters of type Continuation
 void Endpoint.process(Executable task, Continuation command)
          Schedules a job for processing on the dedicated processing thread.
 

Uses of Continuation in rice.p2p.glacier
 

Methods in rice.p2p.glacier with parameters of type Continuation
 void VersioningPast.lookup(Id id, long version, Continuation command)
          Retrieves the object stored in this instance of Past with the given ID and the specified version.
 void VersioningPast.lookupHandles(Id id, long version, int num, Continuation command)
          Retrieves the handles of up to max replicas of the object stored in this instance of Past with the given ID.
 void VersioningPast.refresh(Id[] ids, long[] versions, long[] expirations, Continuation command)
          Updates the objects stored under the provided keys id to expire no earlier than the provided expiration time.
 

Uses of Continuation in rice.p2p.glacier.v2
 

Methods in rice.p2p.glacier.v2 with parameters of type Continuation
 void GlacierImpl.emptyTrash(Continuation c)
           
 void GlacierImpl.fetch(PastContentHandle handle, Continuation command)
           
 void GlacierImpl.insert(PastContent obj, Continuation command)
           
 void GlacierImpl.insert(PastContent obj, long expiration, Continuation command)
           
 void GlacierImpl.lookup(Id id, boolean cache, Continuation command)
           
 void GlacierImpl.lookup(Id id, Continuation command)
           
 void GlacierImpl.lookup(Id id, long version, Continuation command)
           
 void GlacierImpl.lookupHandle(Id id, NodeHandle handle, Continuation command)
           
 void GlacierImpl.lookupHandles(Id id, int num, Continuation command)
           
 void GlacierImpl.lookupHandles(Id id, long version, int num, Continuation command)
           
 void GlacierDefaultPolicy.prefetchLocalObject(VersionKey key, Continuation command)
           
 void GlacierPolicy.prefetchLocalObject(VersionKey key, Continuation command)
           
 void GlacierImpl.refresh(Id[] ids, long[] expirations, Continuation command)
           
 void GlacierImpl.refresh(Id[] ids, long[] versions, long[] expirations, Continuation command)
           
 void GlacierImpl.refresh(Id[] ids, long expiration, Continuation command)
           
 void GlacierImpl.retrieveManifest(VersionKey key, char tag, Continuation command)
           
 void GlacierImpl.retrieveObject(VersionKey key, Manifest manifest, boolean beStrict, char tag, Continuation c)
           
 

Uses of Continuation in rice.p2p.multiring
 

Methods in rice.p2p.multiring with parameters of type Continuation
 void MultiringEndpoint.process(Executable task, Continuation command)
          Schedules a job for processing on the dedicated processing thread.
 

Uses of Continuation in rice.p2p.past
 

Methods in rice.p2p.past that return Continuation
 Continuation[] PastImpl.getOutstandingMessages()
          Returns of the outstanding messages.
protected  Continuation PastImpl.getResponseContinuation(PastMessage msg)
          Returns a continuation which will respond to the given message.
 

Methods in rice.p2p.past with parameters of type Continuation
 void PastImpl.cache(PastContent content, Continuation command)
          Method which inserts the given object into the cache
protected  void PastImpl.doInsert(Id id, PastImpl.MessageBuilder builder, Continuation command)
          Internal method which actually performs an insert for a given object.
 void PastImpl.existsInOverlay(Id id, Continuation command)
           
 void PastPolicy.fetch(Id id, NodeHandle hint, Cache backup, Past past, Continuation command)
          This method is called when Past is told to fetch a key.
 void PastPolicy.DefaultPastPolicy.fetch(Id id, NodeHandle hint, Cache backup, Past past, Continuation command)
          This method fetches the object via a lookup() call.
 void PastImpl.fetch(Id id, NodeHandle hint, Continuation command)
          This upcall is invoked to tell the client to fetch the given id, and to call the given command with the boolean result once the fetch is completed.
 void Past.fetch(PastContentHandle handle, Continuation command)
          Retrieves the object associated with a given content handle.
 void PastImpl.fetch(PastContentHandle handle, Continuation command)
          Retrieves the object associated with a given content handle.
protected  void PastImpl.getHandles(Id id, int max, Continuation command)
          Internal method which returns the handles to an object.
 void Past.insert(PastContent obj, Continuation command)
          Inserts an object with the given ID into this instance of Past.
 void PastImpl.insert(PastContent obj, Continuation command)
          Inserts an object with the given ID into this instance of Past.
 void Past.lookup(Id id, boolean cache, Continuation command)
          Retrieves the object stored in this instance of Past with the given ID.
 void PastImpl.lookup(Id id, boolean cache, Continuation command)
          Method which performs the same as lookup(), but allows the callee to specify if the data should be cached.
 void Past.lookup(Id id, Continuation command)
          Retrieves the object stored in this instance of Past with the given ID.
 void PastImpl.lookup(Id id, Continuation command)
          Retrieves the object stored in this instance of Past with the given ID.
 void Past.lookupHandle(Id id, NodeHandle handle, Continuation command)
          Retrieves the handle for the given object stored on the requested node.
 void PastImpl.lookupHandle(Id id, NodeHandle handle, Continuation command)
          Retrieves the handle for the given object stored on the requested node.
 void Past.lookupHandles(Id id, int max, Continuation command)
          Retrieves the handles of up to max replicas of the object stored in this instance of Past with the given ID.
 void PastImpl.lookupHandles(Id id, int max, Continuation command)
          Retrieves the handles of up to max replicas of the object stored in this instance of Past with the given ID.
 void PastImpl.reInsert(Id id, Continuation command)
           
 void PastImpl.remove(Id id, Continuation command)
          This upcall is to notify the client that the given id can be safely removed from the storage.
protected  void PastImpl.sendRequest(Id id, PastMessage message, Continuation command)
          Sends a request message across the wire, and stores the appropriate continuation.
protected  void PastImpl.sendRequest(Id id, PastMessage message, NodeHandle hint, Continuation command)
          Sends a request message across the wire, and stores the appropriate continuation.
protected  void PastImpl.sendRequest(NodeHandle handle, PastMessage message, Continuation command)
          Sends a request message across the wire, and stores the appropriate continuation.
 

Uses of Continuation in rice.p2p.past.gc
 

Methods in rice.p2p.past.gc with parameters of type Continuation
protected  void GCPastImpl.collect(java.util.SortedMap map, Continuation command)
          Internal method which collects all of the objects in the given set
 void GCPastImpl.existsInOverlay(Id id, Continuation command)
           
 void GCPastImpl.fetch(Id id, NodeHandle hint, Continuation command)
          This upcall is invoked to tell the client to fetch the given id, and to call the given command with the boolean result once the fetch is completed.
 void GCPast.insert(PastContent obj, Continuation command)
          Inserts an object with the given ID into this instance of Past.
 void GCPastImpl.insert(PastContent obj, Continuation command)
          Inserts an object with the given ID into this instance of Past.
 void GCPast.insert(PastContent obj, long expiration, Continuation command)
          Inserts an object with the given ID into this instance of Past.
 void GCPastImpl.insert(PastContent obj, long expiration, Continuation command)
          Inserts an object with the given ID into this instance of Past.
 void GCEndpoint.process(Executable task, Continuation command)
          Schedules a job for processing on the dedicated processing thread.
protected  void GCPastImpl.refresh(GCIdSet ids, Continuation command)
          Internal method which actually does the refreshing.
 void GCPast.refresh(Id[] ids, long[] expiration, Continuation command)
          Updates the objects stored under the provided keys id to expire no earlier than the provided expiration time.
 void GCPastImpl.refresh(Id[] array, long[] expirations, Continuation command)
          Updates the objects stored under the provided keys id to expire no earlier than the provided expiration time.
 void GCPast.refresh(Id[] ids, long expiration, Continuation command)
          Updates the objects stored under the provided keys id to expire no earlier than the provided expiration time.
 void GCPastImpl.refresh(Id[] array, long expiration, Continuation command)
          Updates the objects stored under the provided keys id to expire no earlier than the provided expiration time.
 void GCPastImpl.reInsert(Id id, Continuation command)
           
 void GCPastImpl.remove(Id id, Continuation command)
          This upcall is to notify the client that the given id can be safely removed from the storage.
 

Uses of Continuation in rice.p2p.past.gc.messaging
 

Classes in rice.p2p.past.gc.messaging that implement Continuation
 class GCInsertMessage
           
 class GCLookupHandlesMessage
           
 class GCRefreshMessage
           
 

Methods in rice.p2p.past.gc.messaging with parameters of type Continuation
 void GCCollectMessage.returnResponse(Continuation c, Environment env, java.lang.String instance)
          Method by which this message is supposed to return it's response - in this case, it lets the continuation know that a the message was lost via the receiveException method.
 

Uses of Continuation in rice.p2p.past.messaging
 

Classes in rice.p2p.past.messaging that implement Continuation
 class ContinuationMessage
           
 class FetchHandleMessage
           
 class FetchMessage
           
 class InsertMessage
           
 class LookupHandlesMessage
           
 class LookupMessage
           
 

Methods in rice.p2p.past.messaging with parameters of type Continuation
 void CacheMessage.returnResponse(Continuation c, Environment env, java.lang.String instance)
          Method by which this message is supposed to return it's response.
 void ContinuationMessage.returnResponse(Continuation c, Environment env, java.lang.String instance)
          Method by which this message is supposed to return it's response.
 void MessageLostMessage.returnResponse(Continuation c, Environment env, java.lang.String instance)
          Method by which this message is supposed to return it's response - in this case, it lets the continuation know that a the message was lost via the receiveException method.
abstract  void PastMessage.returnResponse(Continuation c, Environment env, java.lang.String instance)
          Method by which this message is supposed to return it's response.
 

Uses of Continuation in rice.p2p.past.testing
 

Classes in rice.p2p.past.testing that implement Continuation
protected  class PastRegrTest.TestCommand
          Common superclass for test commands.
protected  class PastRegrTest.TestExceptionCommand
          Common superclass for test commands which should throw an exception
 

Uses of Continuation in rice.p2p.replication.manager
 

Classes in rice.p2p.replication.manager that implement Continuation
protected  class ReplicationManagerImpl.ReplicationManagerDeleter
          Inner class which keeps track of the keys which we are currently deleting
 

Methods in rice.p2p.replication.manager with parameters of type Continuation
 void ReplicationManagerClient.existsInOverlay(Id id, Continuation command)
          This upcall should return whether or not the given id is currently stored somewhere in the overlay by the client.
 void ReplicationManagerClient.fetch(Id id, NodeHandle hint, Continuation command)
          This upcall is invoked to tell the client to fetch the given id, and to call the given command with the boolean result once the fetch is completed.
 void ReplicationManagerClient.reInsert(Id id, Continuation command)
          Asks a client to reinsert an object it already holds into the overlay
 void ReplicationManagerClient.remove(Id id, Continuation command)
          This upcall is to notify the client that the given id can be safely removed from the storage.
 

Uses of Continuation in rice.p2p.replication.manager.testing
 

Methods in rice.p2p.replication.manager.testing with parameters of type Continuation
 void ReplicationManagerRegrTest.TestReplicationManagerClient.existsInOverlay(Id id, Continuation command)
           
 void ReplicationManagerRegrTest.TestReplicationManagerClient.fetch(Id id, NodeHandle hint, Continuation command)
           
 void ReplicationManagerRegrTest.TestReplicationManagerClient.reInsert(Id id, Continuation command)
           
 void ReplicationManagerRegrTest.TestReplicationManagerClient.remove(Id id, Continuation command)
           
 

Uses of Continuation in rice.pastry
 

Methods in rice.pastry with parameters of type Continuation
abstract  CancellableTask PastryNodeFactory.getLeafSet(NodeHandle handle, Continuation c)
          Non-blocking version.
abstract  CancellableTask PastryNodeFactory.getRouteRow(NodeHandle handle, int row, Continuation c)
          Non-blocking version.
 void PastryNode.process(Executable task, Continuation command)
          Schedules a job for processing on the dedicated processing thread, should one exist.
 

Uses of Continuation in rice.pastry.commonapi
 

Methods in rice.pastry.commonapi with parameters of type Continuation
 void PastryEndpoint.process(Executable task, Continuation command)
          Schedules a job for processing on the dedicated processing thread.
 

Uses of Continuation in rice.pastry.direct
 

Methods in rice.pastry.direct with parameters of type Continuation
 CancellableTask DirectPastryNodeFactory.getLeafSet(NodeHandle handle, Continuation c)
           
 CancellableTask DirectPastryNodeFactory.getRouteRow(NodeHandle handle, int row, Continuation c)
           
 

Uses of Continuation in rice.pastry.dist
 

Methods in rice.pastry.dist with parameters of type Continuation
abstract  CancellableTask DistPastryNodeFactory.generateNodeHandle(java.net.InetSocketAddress address, Continuation c)
           
 CancellableTask DistPastryNodeFactory.getNodeHandle(java.net.InetSocketAddress[] addresses, Continuation c)
           
 CancellableTask DistPastryNodeFactory.getNodeHandle(java.net.InetSocketAddress address, Continuation c)
           
 void DistPastryNode.process(Executable task, Continuation command)
          Schedules a job for processing on the dedicated processing thread.
 

Uses of Continuation in rice.pastry.socket
 

Methods in rice.pastry.socket with parameters of type Continuation
 CancellableTask SocketPastryNodeFactory.generateNodeHandle(java.net.InetSocketAddress address, Continuation c)
           
 CancellableTask SocketPastryNodeFactory.getLeafSet(NodeHandle handle, Continuation c)
           
protected  CancellableTask SocketPastryNodeFactory.getResponse(java.net.InetSocketAddress address, Message message, Continuation c)
           
 CancellableTask SocketPastryNodeFactory.getRouteRow(NodeHandle handle, int row, Continuation c)
           
 void SocketPastryNode.testFireWall(NodeHandle bootstrap, Continuation c, int timeout)
           
 

Uses of Continuation in rice.persistence
 

Methods in rice.persistence with parameters of type Continuation
 void Cache.cache(Id id, java.io.Serializable metadata, java.io.Serializable obj, Continuation c)
          Caches an object in this storage.
 void EmptyCache.cache(Id id, java.io.Serializable metadata, java.io.Serializable obj, Continuation c)
          Caches an object in this storage.
 void LRUCache.cache(Id id, java.io.Serializable metadata, java.io.Serializable obj, Continuation c)
          Caches an object in this storage.
 void StorageManagerImpl.cache(Id id, java.io.Serializable metadata, java.io.Serializable obj, Continuation c)
          Caches an object in this storage.
 void Catalog.flush(Continuation c)
          Method which is used to erase all data stored in the Catalog.
 void EmptyCache.flush(Continuation c)
          Method which is used to erase all data stored in the Catalog.
 void LRUCache.flush(Continuation c)
          Method which is used to erase all data stored in the Cache.
 void MemoryStorage.flush(Continuation c)
          Method which is used to erase all data stored in the Storage.
 void PersistentStorage.flush(Continuation c)
          Method which is used to erase all data stored in the Catalog.
 void StorageManagerImpl.flush(Continuation c)
          Method which is used to erase all data stored in the Catalog.
 void Catalog.getObject(Id id, Continuation c)
          Returns the object identified by the given id, or null if there is no cooresponding object (through receiveResult on c).
 void EmptyCache.getObject(Id id, Continuation c)
          Returns the object identified by the given id.
 void LRUCache.getObject(Id id, Continuation c)
          Returns the object identified by the given id.
 void MemoryStorage.getObject(Id id, Continuation c)
          Returns the object identified by the given id, or null if there is no cooresponding object (through receiveResult on c).
 void PersistentStorage.getObject(Id id, Continuation c)
          Returns the object identified by the given id.
 void StorageManagerImpl.getObject(Id id, Continuation c)
          Returns the object identified by the given id, or null if there is no cooresponding object (through receiveResult on c).
 void Catalog.rename(Id oldId, Id newId, Continuation c)
          Renames the given object to the new id.
 void EmptyCache.rename(Id oldId, Id newId, Continuation c)
          Renames the given object to the new id.
 void LRUCache.rename(Id oldId, Id newId, Continuation c)
          Renames the given object to the new id.
 void MemoryStorage.rename(Id oldId, Id newId, Continuation c)
          Renames the given object to the new id.
 void PersistentStorage.rename(Id oldId, Id newId, Continuation c)
          Renames the given object to the new id.
 void StorageManagerImpl.rename(Id oldId, Id newId, Continuation c)
          Renames the given object to the new id.
 void Cache.setMaximumSize(int size, Continuation c)
          Sets the maximum size of the cache, in bytes.
 void EmptyCache.setMaximumSize(int size, Continuation c)
          Sets the maximum size of the cache, in bytes.
 void LRUCache.setMaximumSize(int size, Continuation c)
          Sets the maximum size of the cache, in bytes.
 void StorageManagerImpl.setMaximumSize(int size, Continuation c)
          Sets the maximum size of the cache, in bytes.
 void Catalog.setMetadata(Id id, java.io.Serializable metadata, Continuation command)
          Updates the metadata stored under the given key to be the provided value.
 void EmptyCache.setMetadata(Id id, java.io.Serializable metadata, Continuation c)
          Updates the metadata stored under the given key to be the provided value.
 void LRUCache.setMetadata(Id id, java.io.Serializable metadata, Continuation command)
          Updates the metadata stored under the given key to be the provided value.
 void MemoryStorage.setMetadata(Id id, java.io.Serializable metadata, Continuation command)
          Updates the metadata stored under the given key to be the provided value.
 void PersistentStorage.setMetadata(Id id, java.io.Serializable metadata, Continuation c)
          Updates the metadata stored under the given key to be the provided value.
 void StorageManagerImpl.setMetadata(Id id, java.io.Serializable metadata, Continuation command)
          Updates the metadata stored under the given key to be the provided value.
 void MemoryStorage.store(Id id, java.io.Serializable metadata, java.io.Serializable obj, Continuation c)
          Stores the object under the key id.
 void PersistentStorage.store(Id id, java.io.Serializable metadata, java.io.Serializable obj, Continuation c)
          Makes the object persistent to disk and stored permanantly If the object is already persistent, this method will simply update the object's serialized image.
 void Storage.store(Id id, java.io.Serializable metadata, java.io.Serializable obj, Continuation c)
          Stores an object in this storage.
 void StorageManagerImpl.store(Id id, java.io.Serializable metadata, java.io.Serializable obj, Continuation c)
          Stores an object in this storage.
 void Cache.uncache(Id id, Continuation c)
          Removes the object from the list of cached objects.
 void EmptyCache.uncache(Id id, Continuation c)
          Removes the object from the list of cached objects.
 void LRUCache.uncache(Id id, Continuation c)
          Removes the object from the list of cached objects.
 void StorageManagerImpl.uncache(Id id, Continuation c)
          Removes the object from the list of cached objects.
 void MemoryStorage.unstore(Id id, Continuation c)
          Removes the object from the list of stored objects.
 void PersistentStorage.unstore(Id id, Continuation c)
          Request to remove the object from the list of persistend objects.
 void Storage.unstore(Id id, Continuation c)
          Removes the object from the list of stored objects.
 void StorageManagerImpl.unstore(Id id, Continuation c)
          Removes the object from the list of stored objects.
 

Uses of Continuation in rice.persistence.testing
 

Methods in rice.persistence.testing with parameters of type Continuation
 void LRUCacheTest.setUp(Continuation c)
           
 void MemoryStorageTest.setUp(Continuation c)
           
 void MemoryStorageTest.testExists(Continuation c)
           
 void MemoryStorageTest.testRetreival(Continuation c)
           
 

Uses of Continuation in rice.post
 

Methods in rice.post with parameters of type Continuation
 void PostImpl.createPostLog(Continuation command)
          Internal method which builds a new PostLog for the log user.
 void Post.getAndVerifyPostLog(Continuation command)
          Shortcut which returns the PostLog of the local user.
 void PostImpl.getAndVerifyPostLog(Continuation command)
           
abstract  void PostClient.getContentHashReferences(Continuation command)
          This method is periodically invoked by Post in order to get a list of all handles under which the application has live objects.
abstract  void PostClient.getLogs(Continuation command)
          This method is periodically invoked by Post in order to get a list of all mutable data which the application is interested in.
 void Post.getPostLog(Continuation command)
          Shortcut which returns the PostLog of the local user.
 void PostImpl.getPostLog(Continuation command)
           
 void Post.getPostLog(PostEntityAddress entity, Continuation command)
          Returns and verifies the PostLog of the named entity
 void PostImpl.getPostLog(PostEntityAddress entity, Continuation command)
           
abstract  void PostClient.notificationReceived(NotificationMessage nm, Continuation command)
          This method is how the Post object informs the clients that there is an incoming notification.
 void Post.sendGroup(NotificationMessage message, Continuation command)
          This method multicasts the provided notification message to the destination group.
 void PostImpl.sendGroup(NotificationMessage message, Continuation command)
          This method multicasts the provided notification message to the destination group.
 void Post.sendNotification(NotificationMessage message, Continuation command)
          Sends a notification message with destination specified by the members of the NotificationMessage.
 void PostImpl.sendNotification(NotificationMessage message, Continuation command)
          Sends a notification message with destination specified by the members of the NotificationMessage.
 void Post.sendNotificationDirect(NodeHandle handle, NotificationMessage message, Continuation command)
          Sends a notification message with destination specified by the members of the NotificationMessage.
 void PostImpl.sendNotificationDirect(NodeHandle handle, NotificationMessage message, Continuation command)
          Sends a notification message with destination specified by the members of the NotificationMessage.
 void ForwardLog.setAddresses(java.lang.String[] addresses, Continuation command)
          Updates the list of addresses
 

Constructors in rice.post with parameters of type Continuation
ForwardLog(PostLog log, java.lang.String[] addresses, Id location, Post post, Continuation command)
          Constructor for ForwardLog.
 

Uses of Continuation in rice.post.delivery
 

Methods in rice.post.delivery with parameters of type Continuation
 void DeliveryService.check(Id id, Continuation command)
          Determines whether or not the given ENM has been delivered before
 void DeliveryService.deliver(SignedPostMessage message, Continuation command)
          Requests delivery of the given EncryptedNotificationMessage, which internally contains the destination user.
 void DeliveryService.delivered(SignedPostMessage message, Id id, byte[] signature, Continuation command)
          Records delivery of the given message to the user.
 void DeliveryPastImpl.fetch(Id id, NodeHandle hint, Continuation command)
          This upcall is invoked to tell the client to fetch the given id, and to call the given command with the boolean result once the fetch is completed.
 void DeliveryPast.getGroups(Continuation command)
          Returns the list of PostEntityaddress for which we are the primary replica responsible for delivering messages.
 void DeliveryPastImpl.getGroups(Continuation command)
          Returns the list of PostEntityaddress for which we are the primary replica responsible for delivering messages.
 void DeliveryPast.getMessage(PostEntityAddress address, Continuation command)
          Returns the first message which is still pending to the given address.
 void DeliveryPastImpl.getMessage(PostEntityAddress address, Continuation command)
          Returns the first message which is still pending to the given address.
 void DeliveryService.presence(PresenceMessage message, Continuation command)
          Is called when a presence message is received.
protected  void DeliveryPastImpl.setMetadata(Id id, Continuation command)
          Either returns the userid associated with the given id by looking in the cache, or reads it off of disk.
 void DeliveryPast.synchronize(Continuation command)
          Method which periodically checks to see if we've got receipts for any outstanding messages.
 void DeliveryPastImpl.synchronize(Continuation command)
          Method which periodically checks to see if we've got receipts for any outstanding messages.
 void DeliveryService.undeliverable(SignedPostMessage message, Id id, Continuation command)
          Records a message as being undeliverable, which will ensure that delivery won't be attempted again, but does not provide a receipt.
 

Uses of Continuation in rice.post.log
 

Classes in rice.post.log that implement Continuation
protected  class Log.AddLogEntryTask
          This class encapsulates the logic needed to add a log entry to the current log.
 

Fields in rice.post.log declared as Continuation
protected  Continuation CoalescedLog.AddCoalescedLogEntryTask.command
           
 

Methods in rice.post.log with parameters of type Continuation
 void Log.addChildLog(Log log, Continuation command)
          This method adds a child log to this log, essentially forming a tree of logs.
 void CoalescedLog.addLogEntry(LogEntry entry, Continuation command)
          This method appends an entry into the user's log, and updates the pointer to the top of the log to reflect the new object.
 void EncryptedLog.addLogEntry(LogEntry entry, Continuation command)
          This method appends an entry into the user's log, and updates the pointer to the top of the log to reflect the new object.
 void Log.addLogEntry(LogEntry entry, Continuation command)
          This method appends an entry into the user's log, and updates the pointer to the top of the log to reflect the new object.
 void CoalescedLog.getActualTopEntry(Continuation command)
          This method returns the *actual* top entry in the log.
 void Log.getChildLog(java.lang.Object name, Continuation command)
          This method returns a the specific child log of this log, given the child log's name.
 void CoalescedLog.getLogEntryReferences(java.util.Set set, LogEntry entry, Continuation command)
          This method returns a list of all the handles stored in the folder or any subfolders.
 void Log.getLogEntryReferences(java.util.Set set, LogEntry entry, Continuation command)
          This method returns a list of all the handles stored in the folder or any subfolders.
 void CoalescedLog.PhantomLogEntry.getPreviousEntry(Continuation command)
          Method which redirects the getPreviousEntry back to the Coalesed entry
 void LogEntry.getPreviousEntry(Continuation command)
          Returns the reference to the previous entry in the log
protected  void LogEntry.getRealPreviousEntry(Continuation command)
          Returns the reference to the previous entry in the log
protected  void Log.getRealTopEntry(Continuation command)
          Internal method to get the *actual* top entry
 void CoalescedLog.getTopEntry(Continuation command)
          This method returns a reference to the most recent entry in the log, which can then be used to walk down the log.
 void EncryptedLog.getTopEntry(Continuation command)
          This method returns a reference to the most recent entry in the log, which can then be used to walk down the log.
 void Log.getTopEntry(Continuation command)
          This method returns a reference to the most recent entry in the log, which can then be used to walk down the log.
 void Log.removeChildLog(java.lang.Object name, Continuation command)
          This method removes a child log from this log.
 void Log.AddLogEntryTask.setCommand(Continuation command)
           
 void Log.setName(java.lang.Object name, Continuation command)
          Sets the name of this log.
protected  void Log.sync(Continuation command)
          Helper method to sync this log object on the network.
 

Constructors in rice.post.log with parameters of type Continuation
CoalescedLog.AddCoalescedLogEntryTask(LogEntry entry, Continuation command)
          This construct will build an object which will call the given command once processing has been completed, and will provide a result.
Log.AddLogEntryTask(LogEntry entry, Continuation command)
          This construct will build an object which will call the given command once processing has been completed, and will provide a result.
 

Uses of Continuation in rice.post.security
 

Methods in rice.post.security with parameters of type Continuation
 void SecurityModule.verify(PostCertificate certificate, Continuation command)
          This method verifies the provided ceritifcate, and returns the result to the continuation (either True or False).
 void SecurityService.verify(PostCertificate certificate, Continuation command)
          Verifies the given certificate, and passes the result, either True or False, to the given command.
 

Uses of Continuation in rice.post.security.ca
 

Methods in rice.post.security.ca with parameters of type Continuation
 void CASecurityModule.verify(PostCertificate certificate, Continuation command)
          This method verifies the provided ceritifcate, and returns the result to the continuation (either True or False).
 

Uses of Continuation in rice.post.security.pknoi
 

Methods in rice.post.security.pknoi with parameters of type Continuation
 void PKnoISecurityModule.addPrivate(PKnoIPostCertificate cert, Continuation command)
          This method should be called when this user wishes to record a non-verified certificate for later use.
 void PKnoISecurityModule.addPublic(PKnoIPostCertificate cert, Continuation command)
          This method should be called when this user wishes to "vouch" for the user with the provided certificate.
 void PKnoISecurityModule.findChains(PKnoIPostCertificate source, PKnoIPostCertificate destination, int len, Continuation command)
          This method will attempt to find all chains of length up to len, and return a PKnoIChain[] to the continuation once all chains have been completed.
 void PKnoISecurityModule.getContentHashReferences(Continuation command)
          This method is periodically invoked by Post in order to get a list of all handles under which the application has live objects.
 void PKnoISecurityModule.getLogs(Continuation command)
          This method is periodically invoked by Post in order to get a list of all mutable data which the application is interested in.
 void PKnoISecurityModule.notificationReceived(NotificationMessage nm, Continuation command)
          This method is how the Post object informs the clients that there is an incoming notification.
 void PKnoISecurityModule.verify(PostCertificate certificate, Continuation command)
          This method verifies the provided ceritifcate, and returns the result to the continuation (either True or False).
 

Uses of Continuation in rice.post.storage
 

Methods in rice.post.storage with parameters of type Continuation
 void StorageService.backupLogs(PostLog log, Log[] logs, Continuation command)
          This method backs up all of the provided logs by inserting them into the immutable store with appropriate version numbers.
 void PostPastPolicy.fetch(Id id, NodeHandle hint, Cache backup, Past past, Continuation command)
          This method fetches the object via a lookup() call.
static void StorageService.recoverLogs(Id location, long timestamp, java.security.KeyPair keyPair, Past immutablePast, Past mutablePast, Continuation command, Environment env, Logger logger)
          This method performs an emergency recovery of the logs by reinserting them into the provided PAST store.
 void StorageService.refreshContentHash(ContentHashReference[] references, Continuation command)
          This method "refreshes" a list of ContentHashReferences, which ensures that all of the referenced objects are not collected by the underlying store.
 void StorageService.refreshSecure(SecureReference[] references, Continuation command)
          This method "refreshes" a list of SecureReferences, which ensures that all of the referenced objects are not collected by the underlying store.
 void StorageService.retrieveAllSigned(SignedReference reference, Continuation command)
          This method retrieves a previously-stored block from PAST which was signed using the private key.
 void StorageService.retrieveAndVerifySigned(SignedReference reference, Continuation command)
          This method retrieves a previously-stored private-key signed block from PAST.
 void StorageService.retrieveAndVerifySigned(SignedReference reference, java.security.PublicKey publicKey, Continuation command)
          This method retrieves a previously-stored block from PAST which was signed using the private key matching the given public key.
 void StorageService.retrieveContentHash(ContentHashReference reference, Continuation command)
          This method retrieves a given PostDataReference object from the network.
 void StorageService.retrieveContentHashEntry(Id location, byte[] key, Continuation command)
          This method retrieves a single content hash entry and verifies it.
 void StorageService.retrieveSecure(SecureReference reference, Continuation command)
          This method retrieves a given SecureReference object from the network.
 void StorageService.retrieveSigned(SignedReference reference, Continuation command)
          This method retrieves a previously-stored block from PAST which was signed using the private key.
 void StorageService.setAggregate(PostLog log, Continuation command)
          Method which sets the aggregate head, if we are using a Aggregation as the immutable past store.
 void StorageService.storeContentHash(PostData data, Continuation command)
          Stores a PostData in the PAST storage system, in encrypted state, and returns a pointer and key to the data object.
 void StorageService.storeContentHashEntry(byte[] plainText, Continuation command)
          Performs the actual content hashing and insertion of a single content has block.
 void StorageService.storeSecure(PostData data, Continuation command)
          Stores a PostData in the PAST storage system, in encrypted state, and returns a pointer and key to the data object.
 void StorageService.storeSigned(PostData data, Id location, Continuation command)
          Stores a PostData in the PAST store by signing the content and storing it at a well-known location.
protected static void StorageService.storeSigned(PostData data, Id location, long time, long expiration, java.security.KeyPair keyPair, Past past, Continuation command)
          Stores a PostData in the PAST store by signing the content and storing it at a well-known location.
 


ePOST API

Copyright © 2001-2005 - Rice Pastry.