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 progress)
           
 int availablePermits()
           
 long getEntriesScanned()
           
 int getGrantedPermits()
           
static java.lang.String getOwnerName()
           
 java.util.List<java.lang.String> getPermitOwners()
           
 void release()
           
 boolean tryAcquire(java.util.concurrent.atomic.AtomicLong progress)
           
 
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

getOwnerName

public static java.lang.String getOwnerName()

acquire

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

release

public void release()

getPermitOwners

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

tryAcquire

public boolean tryAcquire(java.util.concurrent.atomic.AtomicLong progress)

availablePermits

public int availablePermits()

getGrantedPermits

public int getGrantedPermits()

getEntriesScanned

public long getEntriesScanned()


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