voldemort.server.storage
Class ScanPermitWrapper

java.lang.Object
  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()