|
ePOST API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
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 | |||||||||
PREV NEXT | FRAMES NO FRAMES |