org.apache.zookeeper.server.quorum
Class ObserverRequestProcessor

java.lang.Object
  java.lang.Thread
      org.apache.zookeeper.server.quorum.ObserverRequestProcessor

All Implemented Interfaces:

java.lang.Runnable, RequestProcessor

public class ObserverRequestProcessor
extends java.lang.Thread
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 inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

ObserverRequestProcessor(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

void	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 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

Constructor Detail

ObserverRequestProcessor

public ObserverRequestProcessor(ObserverZooKeeperServer zks,
                                RequestProcessor nextProcessor)

Constructor - takes an ObserverZooKeeperServer to associate with and the next processor to pass requests to after we're finished.

Parameters:

zks -

nextProcessor -

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

processRequest

public void processRequest(Request request)

Simply queue the request, which will be processed in FIFO order.

Specified by:

processRequest in interface RequestProcessor

shutdown

public void shutdown()

Shutdown the processor.

Specified by:

shutdown in interface RequestProcessor