Class ReadOnlyRequestProcessor
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.zookeeper.server.ZooKeeperThread
-
- org.apache.zookeeper.server.ZooKeeperCriticalThread
-
- org.apache.zookeeper.server.quorum.ReadOnlyRequestProcessor
-
- All Implemented Interfaces:
java.lang.Runnable,RequestProcessor
public class ReadOnlyRequestProcessor extends ZooKeeperCriticalThread implements RequestProcessor
This processor is at the beginning of the ReadOnlyZooKeeperServer's processors chain. All it does is, it passes read-only operations (e.g. OpCode.getData, OpCode.exists) through to the next processor, but drops state-changing operations (e.g. OpCode.create, OpCode.setData).
-
-
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 ReadOnlyRequestProcessor(ZooKeeperServer zks, RequestProcessor nextProcessor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidprocessRequest(Request request)voidrun()voidshutdown()-
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
-
ReadOnlyRequestProcessor
public ReadOnlyRequestProcessor(ZooKeeperServer zks, RequestProcessor nextProcessor)
-
-
Method Detail
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable- Overrides:
runin classjava.lang.Thread
-
processRequest
public void processRequest(Request request)
- Specified by:
processRequestin interfaceRequestProcessor
-
shutdown
public void shutdown()
- Specified by:
shutdownin interfaceRequestProcessor
-
-