voldemort.utils
Class ConsistencyFix.BadKeyReader

java.lang.Object
  extended by voldemort.utils.ConsistencyFix.BadKeyReader
All Implemented Interfaces:
java.lang.Runnable
Direct Known Subclasses:
ConsistencyFix.BadKeyOrphanReader
Enclosing class:
ConsistencyFix

public static class ConsistencyFix.BadKeyReader
extends java.lang.Object
implements java.lang.Runnable


Field Summary
protected  java.lang.String badKeyFileIn
           
protected  java.util.concurrent.BlockingQueue<ConsistencyFix.BadKeyStatus> badKeyQOut
           
protected  ConsistencyFix consistencyFix
           
protected  java.util.concurrent.ExecutorService consistencyFixWorkers
           
protected  java.io.BufferedReader fileReader
           
protected  boolean hasException
           
protected  java.util.concurrent.CountDownLatch latch
           
 
Method Summary
 void run()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

latch

protected final java.util.concurrent.CountDownLatch latch

badKeyFileIn

protected final java.lang.String badKeyFileIn

consistencyFix

protected final ConsistencyFix consistencyFix

consistencyFixWorkers

protected final java.util.concurrent.ExecutorService consistencyFixWorkers

badKeyQOut

protected final java.util.concurrent.BlockingQueue<ConsistencyFix.BadKeyStatus> badKeyQOut

fileReader

protected java.io.BufferedReader fileReader

hasException

protected boolean hasException
Method Detail

run

public void run()
Specified by:
run in interface java.lang.Runnable


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