Class CommitProcessor
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.zookeeper.server.ZooKeeperThread
-
- org.apache.zookeeper.server.ZooKeeperCriticalThread
-
- org.apache.zookeeper.server.quorum.CommitProcessor
-
- All Implemented Interfaces:
java.lang.Runnable
,RequestProcessor
public class CommitProcessor extends ZooKeeperCriticalThread 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.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class java.lang.Thread
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
-
Nested classes/interfaces inherited from interface org.apache.zookeeper.server.RequestProcessor
RequestProcessor.RequestProcessorException
-
-
Constructor Summary
Constructors Constructor Description CommitProcessor(RequestProcessor nextProcessor, java.lang.String id, boolean matchSyncs, ZooKeeperServerListener listener)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
commit(Request request)
void
processRequest(Request request)
void
run()
void
shutdown()
-
Methods inherited from class org.apache.zookeeper.server.ZooKeeperCriticalThread
handleException
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Constructor Detail
-
CommitProcessor
public CommitProcessor(RequestProcessor nextProcessor, java.lang.String id, boolean matchSyncs, ZooKeeperServerListener listener)
-
-
Method Detail
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
commit
public void commit(Request request)
-
processRequest
public void processRequest(Request request)
- Specified by:
processRequest
in interfaceRequestProcessor
-
shutdown
public void shutdown()
- Specified by:
shutdown
in interfaceRequestProcessor
-
-