org.apache.zookeeper.server.quorum.ObserverRequestProcessor

All Implemented Interfaces:: Runnable, RequestProcessor

public class ObserverRequestProcessor 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 Thread
Thread.State, Thread.UncaughtExceptionHandler

Nested classes/interfaces inherited from interface RequestProcessor
RequestProcessor.RequestProcessorException
Field Summary

Fields inherited from class Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor Summary

Constructors

Constructor

Description

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

Modifier and Type

Method

Description

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 ZooKeeperCriticalThread
handleException

Methods inherited from class 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 Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- 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 Details
- run
  
  public void run()
  
  Specified by:
  
  run in interface Runnable
  
  Overrides:
  
  run in class 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

Class ObserverRequestProcessor

Nested Class Summary

Nested classes/interfaces inherited from class Thread

Nested classes/interfaces inherited from interface RequestProcessor

Field Summary

Fields inherited from class Thread

Constructor Summary

Method Summary

Methods inherited from class ZooKeeperCriticalThread

Methods inherited from class Thread

Methods inherited from class Object

Constructor Details

ObserverRequestProcessor

Method Details

run

processRequest

shutdown