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 voidAuditHelper.addAuditLog(Request request, DataTree.ProcessTxnResult rc) static voidAuditHelper.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 TypeMethodDescriptionvoidZKDatabase.addCommittedProposal(Request request) maintains a list of last committedLog or so committed requests.booleanappend to the underlying transaction logbooleanZooKeeperServer.authWriteRequest(Request request) Check Write Requests for Potential Access RestrictionsvoidZooKeeperServer.enqueueRequest(Request si) static voidZooTrace.logRequest(org.slf4j.Logger log, long mask, char rp, Request request, String header) protected voidContainerManager.postDeleteRequest(Request request) protected voidThis method will be called inside the ProcessRequestThread, which is a singleton, so there will be a single thread calling this code.protected voidPrepRequestProcessor.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.voidFinalRequestProcessor.processRequest(Request request) voidPrepRequestProcessor.processRequest(Request request) voidRequestProcessor.processRequest(Request request) voidSyncRequestProcessor.processRequest(Request request) voidUnimplementedRequestProcessor.processRequest(Request request) ZooKeeperServer.processTxn(Request request) voidZooKeeperServer.requestFinished(Request request) protected voidZooKeeperServer.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 booleanRequestThrottler.shouldThrottleOp(Request request, long elapsedTime) voidRequestThrottler.submitRequest(Request request) voidZooKeeperServer.submitRequest(Request si) voidZooKeeperServer.submitRequestNow(Request si) voidServerStats.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.committedRequestsRequests that have been committed.CommitProcessor.pendingRequestsRequests that we are holding until commit comes in.protected LinkedBlockingQueue<Request>CommitProcessor.queuedRequestsIncoming requests.protected final LinkedBlockingQueue<Request>CommitProcessor.queuedWriteRequestsIncoming requests that are waiting on a commit, contained in order of arrivalMethods in org.apache.zookeeper.server.quorum that return RequestModifier and TypeMethodDescriptionFollowerZooKeeperServer.appendRequest(TxnHeader hdr, Record txn, TxnDigest digest) Build a request for the txn and append it to the transaction logQuorumZooKeeperServer.checkUpgradeSession(Request request) Leader.Proposal.getRequest()Methods in org.apache.zookeeper.server.quorum with parameters of type RequestModifier and TypeMethodDescriptionQuorumZooKeeperServer.checkUpgradeSession(Request request) voidvoidObserverZooKeeperServer.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 booleanCommitProcessor.needCommit(Request request) voidCommitProcessor.processRequest(Request request) voidFollowerRequestProcessor.processRequest(Request request) voidLeaderRequestProcessor.processRequest(Request request) voidObserverRequestProcessor.processRequest(Request request) Simply queue the request, which will be processed in FIFO order.voidProposalRequestProcessor.processRequest(Request request) voidReadOnlyRequestProcessor.processRequest(Request request) voidSendAckRequestProcessor.processRequest(Request si) create a proposal and send it out to all the membersprotected voidQuorumZooKeeperServer.setLocalSessionFlag(Request si) protected voidReadOnlyZooKeeperServer.setLocalSessionFlag(Request si) voidLeader.submitLearnerRequest(Request si) voidLeaderZooKeeperServer.submitLearnerRequest(Request request) Requests coming from the learner should go directly to PrepRequestProcessorvoidObserverMaster.submitLearnerRequest(Request si) Constructors in org.apache.zookeeper.server.quorum with parameters of type RequestModifierConstructorDescriptionProposal(Request request, QuorumPacket packet) PureRequestProposal(Request request)