org.apache.zookeeper.server.quorum
Class CommitProcessor

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

All Implemented Interfaces:

java.lang.Runnable, RequestProcessor

public class CommitProcessor
extends java.lang.Thread
implements RequestProcessor

This RequestProcessor matches the incoming committed requests with the locally submitted requests. The trick is that locally submitted requests that change the state of the system will come back as incoming committed requests, so we need to match them up.

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

CommitProcessor(RequestProcessor nextProcessor, java.lang.String id, boolean matchSyncs)

Method Summary

void	commit(Request request)
void	processRequest(Request request)
void	run()
void	shutdown()

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

CommitProcessor

public CommitProcessor(RequestProcessor nextProcessor,
                       java.lang.String id,
                       boolean matchSyncs)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

commit

public void commit(Request request)

processRequest

public void processRequest(Request request)

Specified by:

processRequest in interface RequestProcessor

shutdown

public void shutdown()

Specified by:

shutdown in interface RequestProcessor