Uses of Class
org.apache.zookeeper.server.Request
Packages that use Request
Package
Description
ZooKeeper server theory of operation
-
Uses of Request in org.apache.zookeeper.audit
Methods in org.apache.zookeeper.audit with parameters of type RequestModifier and TypeMethodDescriptionstatic void
AuditHelper.addAuditLog
(Request request, DataTree.ProcessTxnResult rc) static void
AuditHelper.addAuditLog
(Request request, DataTree.ProcessTxnResult txnResult, boolean failedTxn) Add audit log if audit log is enabled and operation is of type which to be audit logged. -
Uses of Request in org.apache.zookeeper.server
Fields in org.apache.zookeeper.server declared as RequestMethods in org.apache.zookeeper.server with parameters of type RequestModifier and TypeMethodDescriptionvoid
ZKDatabase.addCommittedProposal
(Request request) maintains a list of last committedLog or so committed requests.boolean
append to the underlying transaction logboolean
ZooKeeperServer.authWriteRequest
(Request request) Check Write Requests for Potential Access Restrictionsvoid
ZooKeeperServer.enqueueRequest
(Request si) static void
ZooTrace.logRequest
(org.slf4j.Logger log, long mask, char rp, Request request, String header) protected void
ContainerManager.postDeleteRequest
(Request request) protected void
This method will be called inside the ProcessRequestThread, which is a singleton, so there will be a single thread calling this code.protected void
PrepRequestProcessor.pRequest2Txn
(int type, long zxid, Request request, Record record) This method will be called inside the ProcessRequestThread, which is a singleton, so there will be a single thread calling this code.void
FinalRequestProcessor.processRequest
(Request request) void
PrepRequestProcessor.processRequest
(Request request) void
RequestProcessor.processRequest
(Request request) void
SyncRequestProcessor.processRequest
(Request request) void
UnimplementedRequestProcessor.processRequest
(Request request) ZooKeeperServer.processTxn
(Request request) void
ZooKeeperServer.requestFinished
(Request request) protected void
ZooKeeperServer.setLocalSessionFlag
(Request si) If the underlying Zookeeper server support local session, this method will set a isLocalSession to true if a request is associated with a local session.protected boolean
RequestThrottler.shouldThrottleOp
(Request request, long elapsedTime) void
RequestThrottler.submitRequest
(Request request) void
ZooKeeperServer.submitRequest
(Request si) void
ZooKeeperServer.submitRequestNow
(Request si) void
ServerStats.updateLatency
(Request request, long currentTime) Update request statistic. -
Uses of Request in org.apache.zookeeper.server.persistence
Methods in org.apache.zookeeper.server.persistence with parameters of type Request -
Uses of Request in org.apache.zookeeper.server.quorum
Subclasses of Request in org.apache.zookeeper.server.quorumFields in org.apache.zookeeper.server.quorum declared as RequestFields in org.apache.zookeeper.server.quorum with type parameters of type RequestModifier and TypeFieldDescriptionprotected final LinkedBlockingQueue
<Request> CommitProcessor.committedRequests
Requests that have been committed.CommitProcessor.pendingRequests
Requests that we are holding until commit comes in.protected LinkedBlockingQueue
<Request> CommitProcessor.queuedRequests
Incoming requests.protected final LinkedBlockingQueue
<Request> CommitProcessor.queuedWriteRequests
Incoming requests that are waiting on a commit, contained in order of arrivalMethods in org.apache.zookeeper.server.quorum that return RequestMethods in org.apache.zookeeper.server.quorum with parameters of type RequestModifier and TypeMethodDescriptionQuorumZooKeeperServer.checkUpgradeSession
(Request request) void
void
ObserverZooKeeperServer.commitRequest
(Request request) Unlike a Follower, which sees a full request only during the PROPOSAL phase, Observers get all the data required with the INFORM packet.protected boolean
CommitProcessor.needCommit
(Request request) void
CommitProcessor.processRequest
(Request request) void
FollowerRequestProcessor.processRequest
(Request request) void
LeaderRequestProcessor.processRequest
(Request request) void
ObserverRequestProcessor.processRequest
(Request request) Simply queue the request, which will be processed in FIFO order.void
ProposalRequestProcessor.processRequest
(Request request) void
ReadOnlyRequestProcessor.processRequest
(Request request) void
SendAckRequestProcessor.processRequest
(Request si) create a proposal and send it out to all the membersprotected void
QuorumZooKeeperServer.setLocalSessionFlag
(Request si) protected void
ReadOnlyZooKeeperServer.setLocalSessionFlag
(Request si) void
Leader.submitLearnerRequest
(Request si) void
LeaderZooKeeperServer.submitLearnerRequest
(Request request) Requests coming from the learner should go directly to PrepRequestProcessorvoid
ObserverMaster.submitLearnerRequest
(Request si)