voldemort.server.storage
Class ScanPermitWrapper
java.lang.Object
voldemort.server.storage.ScanPermitWrapper
public class ScanPermitWrapper
- extends java.lang.Object
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 |
ScanPermitWrapper
public ScanPermitWrapper(int numPermits)
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