Rice Pastry API

rice.p2p.replication.manager
Class ReplicationManagerImpl.ReplicationManagerDeleter

java.lang.Object
  extended by rice.p2p.replication.manager.ReplicationManagerImpl.ReplicationManagerDeleter
All Implemented Interfaces:
Continuation
Enclosing class:
ReplicationManagerImpl

protected class ReplicationManagerImpl.ReplicationManagerDeleter
extends java.lang.Object
implements Continuation

Inner class which keeps track of the keys which we are currently deleting


Nested Class Summary
 
Nested classes/interfaces inherited from interface rice.Continuation
Continuation.ErrorContinuation, Continuation.ExternalContinuation, Continuation.ExternalContinuationRunnable, Continuation.ExternalRunnable, Continuation.ListenerContinuation, Continuation.MultiContinuation, Continuation.NamedContinuation, Continuation.SimpleContinuation, Continuation.StandardContinuation
 
Field Summary
protected  Id id
          Whether or not we are waiting for a response
protected  IdSet set
          The set of ids we are responsible for deleting
 
Constructor Summary
ReplicationManagerImpl.ReplicationManagerDeleter()
          Bulds a new one
 
Method Summary
protected  void go()
          Internal method which starts the deleting, if it's not already started
 void receiveException(java.lang.Exception e)
          Implementation of continuation
 void receiveResult(java.lang.Object o)
          Implementation of continuation
 void setRange(IdRange range)
          Adds a set of ids to the to-delete list
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

set

protected IdSet set
The set of ids we are responsible for deleting


id

protected Id id
Whether or not we are waiting for a response

Constructor Detail

ReplicationManagerImpl.ReplicationManagerDeleter

public ReplicationManagerImpl.ReplicationManagerDeleter()
Bulds a new one

Method Detail

setRange

public void setRange(IdRange range)
Adds a set of ids to the to-delete list

Parameters:
range - The current responsible range

go

protected void go()
Internal method which starts the deleting, if it's not already started


receiveResult

public void receiveResult(java.lang.Object o)
Implementation of continuation

Specified by:
receiveResult in interface Continuation
Parameters:
o - The result

receiveException

public void receiveException(java.lang.Exception e)
Implementation of continuation

Specified by:
receiveException in interface Continuation
Parameters:
o - The result

Rice Pastry API

Copyright © 2001-2005 - Rice Pastry.


Imprint-Dataprotection