org.apache.zookeeper.server.quorum

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:

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

Thread.State, Thread.UncaughtExceptionHandler

Nested classes/interfaces inherited from interface org.apache.zookeeper.server.RequestProcessor

RequestProcessor.RequestProcessorException

Field Summary

Fields

Modifier and Type	Field and Description
static String	SKIP_LEARNER_REQUEST_TO_NEXT_PROCESSOR

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
FollowerRequestProcessor(FollowerZooKeeperServer zks, RequestProcessor nextProcessor)

Method Summary

Modifier and Type	Method and 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, 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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

SKIP_LEARNER_REQUEST_TO_NEXT_PROCESSOR

public static final 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 interface Runnable

Overrides:

run in class Thread

processRequest

public void processRequest(Request request)

Specified by:

processRequest in interface RequestProcessor

shutdown

public void shutdown()

Specified by:

shutdown in interface RequestProcessor