Class ObserverRequestProcessor
java.lang.Object
java.lang.Thread
org.apache.zookeeper.server.ZooKeeperThread
org.apache.zookeeper.server.ZooKeeperCriticalThread
org.apache.zookeeper.server.quorum.ObserverRequestProcessor
- All Implemented Interfaces:
Runnable
,RequestProcessor
This RequestProcessor forwards any requests that modify the state of the
system to the Leader.
-
Nested Class Summary
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
Nested classes/interfaces inherited from interface org.apache.zookeeper.server.RequestProcessor
RequestProcessor.RequestProcessorException
-
Field Summary
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
Constructor Summary
ConstructorsConstructorDescriptionObserverRequestProcessor
(ObserverZooKeeperServer zks, RequestProcessor nextProcessor) Constructor - takes an ObserverZooKeeperServer to associate with and the next processor to pass requests to after we're finished. -
Method Summary
Modifier and TypeMethodDescriptionvoid
processRequest
(Request request) Simply queue the request, which will be processed in FIFO order.void
run()
void
shutdown()
Shutdown the processor.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 Details
-
ObserverRequestProcessor
Constructor - takes an ObserverZooKeeperServer to associate with and the next processor to pass requests to after we're finished.- Parameters:
zks
-nextProcessor
-
-
-
Method Details
-
run
public void run() -
processRequest
Simply queue the request, which will be processed in FIFO order.- Specified by:
processRequest
in interfaceRequestProcessor
-
shutdown
public void shutdown()Shutdown the processor.- Specified by:
shutdown
in interfaceRequestProcessor
-