org.apache.zookeeper.server.quorum
Class CommitProcessor
java.lang.Object
java.lang.Thread
org.apache.zookeeper.server.quorum.CommitProcessor
- All Implemented Interfaces:
- Runnable, RequestProcessor
public class CommitProcessor
- extends Thread
- implements RequestProcessor
This RequestProcessor matches the incoming committed requests with the
locally submitted requests. The trick is that locally submitted requests that
change the state of the system will come back as incoming committed requests,
so we need to match them up.
Methods inherited from class java.lang.Thread |
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield |
CommitProcessor
public CommitProcessor(RequestProcessor nextProcessor,
String id,
boolean matchSyncs)
run
public void run()
- Specified by:
run
in interface Runnable
- Overrides:
run
in class Thread
commit
public void commit(Request request)
processRequest
public void processRequest(Request request)
- Specified by:
processRequest
in interface RequestProcessor
shutdown
public void shutdown()
- Specified by:
shutdown
in interface RequestProcessor