voldemort.server.storage
Class ScanPermitWrapper

java.lang.Object
  extended by voldemort.server.storage.ScanPermitWrapper

public class ScanPermitWrapper
extends java.lang.Object


Constructor Summary
ScanPermitWrapper(int numPermits)
           
 
Method Summary
 void acquire(java.util.concurrent.atomic.AtomicLong scanProgress, java.util.concurrent.atomic.AtomicLong deleteProgress, java.lang.String ownerName)
           
 void acquire(java.util.concurrent.atomic.AtomicLong progress, java.lang.String ownerName)
           
 int availablePermits()
           
 long getEntriesDeleted()
           
 long getEntriesScanned()
           
 int getGrantedPermits()
           
 java.util.List<java.lang.String> getPermitOwners()
           
 void release(java.lang.String ownerName)
           
 boolean tryAcquire(java.util.concurrent.atomic.AtomicLong scanProgress, java.util.concurrent.atomic.AtomicLong deleteProgress, java.lang.String ownerName)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ScanPermitWrapper

public ScanPermitWrapper(int numPermits)
Method Detail

acquire

public void acquire(java.util.concurrent.atomic.AtomicLong progress,
                    java.lang.String ownerName)
             throws java.lang.InterruptedException
Throws:
java.lang.InterruptedException

acquire

public void acquire(java.util.concurrent.atomic.AtomicLong scanProgress,
                    java.util.concurrent.atomic.AtomicLong deleteProgress,
                    java.lang.String ownerName)
             throws java.lang.InterruptedException
Throws:
java.lang.InterruptedException

release

public void release(java.lang.String ownerName)

getPermitOwners

public java.util.List<java.lang.String> getPermitOwners()

tryAcquire

public boolean tryAcquire(java.util.concurrent.atomic.AtomicLong scanProgress,
                          java.util.concurrent.atomic.AtomicLong deleteProgress,
                          java.lang.String ownerName)

availablePermits

public int availablePermits()

getGrantedPermits

public int getGrantedPermits()

getEntriesScanned

public long getEntriesScanned()

getEntriesDeleted

public long getEntriesDeleted()


Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu