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.UncaughtExceptionHandlerNested 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 TypeMethodDescriptionvoidprocessRequest(Request request) Simply queue the request, which will be processed in FIFO order.voidrun()voidshutdown()Shutdown the processor.Methods inherited from class org.apache.zookeeper.server.ZooKeeperCriticalThread
handleExceptionMethods inherited from class java.lang.Thread
activeCount, checkAccess, clone, 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
-
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:
processRequestin interfaceRequestProcessor
-
shutdown
public void shutdown()Shutdown the processor.- Specified by:
shutdownin interfaceRequestProcessor
-