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 void
pRequest(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 void
pRequest2Txn(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.void
processRequest(Request request)
void
run()
static void
setFailCreate(boolean b)
method for tests to set failCreatevoid
shutdown()
-
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:
run
in interfacejava.lang.Runnable
- Overrides:
run
in 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.RequestProcessorException
This 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:
KeeperException
java.io.IOException
RequestProcessor.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:
processRequest
in interfaceRequestProcessor
-
shutdown
public void shutdown()
- Specified by:
shutdown
in interfaceRequestProcessor
-
-