Package org.apache.zookeeper.server
Class PrepRequestProcessor
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.zookeeper.server.ZooKeeperThread
-
- org.apache.zookeeper.server.ZooKeeperCriticalThread
-
- org.apache.zookeeper.server.PrepRequestProcessor
-
- All Implemented Interfaces:
java.lang.Runnable,RequestProcessor
public class PrepRequestProcessor extends ZooKeeperCriticalThread implements RequestProcessor
This request processor is generally at the start of a RequestProcessor change. It sets up any transactions associated with requests that change the state of the system. It counts on ZooKeeperServer to update outstandingRequests, so that it can take into account transactions that are in the queue to be applied when generating a transaction.
-
-
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
-
-
Constructor Summary
Constructors Constructor Description PrepRequestProcessor(ZooKeeperServer zks, RequestProcessor nextProcessor)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidpRequest(Request request)This method will be called inside the ProcessRequestThread, which is a singleton, so there will be a single thread calling this code.protected voidpRequest2Txn(int type, long zxid, Request request, org.apache.jute.Record record, boolean deserialize)This method will be called inside the ProcessRequestThread, which is a singleton, so there will be a single thread calling this code.voidprocessRequest(Request request)voidrun()static voidsetFailCreate(boolean b)method for tests to set failCreatevoidshutdown()-
Methods inherited from class org.apache.zookeeper.server.ZooKeeperCriticalThread
handleException
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Constructor Detail
-
PrepRequestProcessor
public PrepRequestProcessor(ZooKeeperServer zks, RequestProcessor nextProcessor)
-
-
Method Detail
-
setFailCreate
public static void setFailCreate(boolean b)
method for tests to set failCreate- Parameters:
b-
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable- Overrides:
runin classjava.lang.Thread
-
pRequest2Txn
protected void pRequest2Txn(int type, long zxid, Request request, org.apache.jute.Record record, boolean deserialize) throws KeeperException, java.io.IOException, RequestProcessor.RequestProcessorExceptionThis method will be called inside the ProcessRequestThread, which is a singleton, so there will be a single thread calling this code.- Parameters:
type-zxid-request-record-- Throws:
KeeperExceptionjava.io.IOExceptionRequestProcessor.RequestProcessorException
-
pRequest
protected void pRequest(Request request) throws RequestProcessor.RequestProcessorException
This method will be called inside the ProcessRequestThread, which is a singleton, so there will be a single thread calling this code.- Parameters:
request-- Throws:
RequestProcessor.RequestProcessorException
-
processRequest
public void processRequest(Request request)
- Specified by:
processRequestin interfaceRequestProcessor
-
shutdown
public void shutdown()
- Specified by:
shutdownin interfaceRequestProcessor
-
-