org.apache.zookeeper.server
Class SyncRequestProcessor

java.lang.Object
  extended by java.lang.Thread
      extended by org.apache.zookeeper.server.SyncRequestProcessor
All Implemented Interfaces:
Runnable, RequestProcessor

public class SyncRequestProcessor
extends Thread
implements RequestProcessor

This RequestProcessor logs requests to disk. It batches the requests to do the io efficiently. The request is not passed to the next RequestProcessor until its log has been synced to disk.


Nested Class Summary
 
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
 
Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
SyncRequestProcessor(ZooKeeperServer zks, RequestProcessor nextProcessor)
           
 
Method Summary
static int getSnapCount()
          used by tests to get the snapcount
 void processRequest(Request request)
           
 void run()
           
static void setSnapCount(int count)
          used by tests to check for changing snapcounts
 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

SyncRequestProcessor

public SyncRequestProcessor(ZooKeeperServer zks,
                            RequestProcessor nextProcessor)
Method Detail

setSnapCount

public static void setSnapCount(int count)
used by tests to check for changing snapcounts

Parameters:
count -

getSnapCount

public static int getSnapCount()
used by tests to get the snapcount

Returns:
the snapcount

run

public void run()
Specified by:
run in interface Runnable
Overrides:
run in class Thread

shutdown

public void shutdown()
Specified by:
shutdown in interface RequestProcessor

processRequest

public void processRequest(Request request)
Specified by:
processRequest in interface RequestProcessor


Copyright © 2011 The Apache Software Foundation