Class FollowerRequestProcessor
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.zookeeper.server.ZooKeeperThread
-
- org.apache.zookeeper.server.ZooKeeperCriticalThread
-
- org.apache.zookeeper.server.quorum.FollowerRequestProcessor
-
- All Implemented Interfaces:
java.lang.Runnable
,RequestProcessor
public class FollowerRequestProcessor extends ZooKeeperCriticalThread implements 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
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
-
Nested classes/interfaces inherited from interface org.apache.zookeeper.server.RequestProcessor
RequestProcessor.RequestProcessorException
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
SKIP_LEARNER_REQUEST_TO_NEXT_PROCESSOR
-
Constructor Summary
Constructors Constructor Description FollowerRequestProcessor(FollowerZooKeeperServer zks, RequestProcessor nextProcessor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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
-
-
-
-
Field Detail
-
SKIP_LEARNER_REQUEST_TO_NEXT_PROCESSOR
public static final java.lang.String SKIP_LEARNER_REQUEST_TO_NEXT_PROCESSOR
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
FollowerRequestProcessor
public FollowerRequestProcessor(FollowerZooKeeperServer zks, RequestProcessor nextProcessor)
-
-
Method Detail
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
processRequest
public void processRequest(Request request)
- Specified by:
processRequest
in interfaceRequestProcessor
-
shutdown
public void shutdown()
- Specified by:
shutdown
in interfaceRequestProcessor
-
-