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 Modifier and Type Class Description static class
PrepRequestProcessor.DigestOpCode
-
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
addChangeRecord(org.apache.zookeeper.server.ZooKeeperServer.ChangeRecord c)
static java.util.List<ACL>
fixupACL(java.lang.String path, java.util.List<Id> authInfo, java.util.List<ACL> acls)
This method checks out the acl making sure it isn't null or empty, it has valid schemes and ids, and expanding any relative ids that depend on the requestor's authentication information.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, 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
-
addChangeRecord
protected void addChangeRecord(org.apache.zookeeper.server.ZooKeeperServer.ChangeRecord c)
-
pRequest2Txn
protected void pRequest2Txn(int type, long zxid, Request request, 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
-
fixupACL
public static java.util.List<ACL> fixupACL(java.lang.String path, java.util.List<Id> authInfo, java.util.List<ACL> acls) throws KeeperException.InvalidACLException
This method checks out the acl making sure it isn't null or empty, it has valid schemes and ids, and expanding any relative ids that depend on the requestor's authentication information.- Parameters:
authInfo
- list of ACL IDs associated with the client connectionacls
- list of ACLs being assigned to the node (create or setACL operation)- Returns:
- verified and expanded ACLs
- Throws:
KeeperException.InvalidACLException
-
processRequest
public void processRequest(Request request)
- Specified by:
processRequest
in interfaceRequestProcessor
-
shutdown
public void shutdown()
- Specified by:
shutdown
in interfaceRequestProcessor
-
-