Searched refs:commit_data_req_ (Results 1 – 2 of 2) sorted by relevance
136 commit_data_req_ && bytes_pending_commit_ >= shmem_abi_.size() / 2; in GetNewChunk()265 if (!commit_data_req_) { in UpdateCommitDataRequest()266 commit_data_req_.reset(new CommitDataRequest()); in UpdateCommitDataRequest()286 ctm = commit_data_req_->add_chunks_to_move(); in UpdateCommitDataRequest()340 last_patch_req = commit_data_req_->add_chunks_to_patch(); in UpdateCommitDataRequest()406 auto& chunks_to_move = commit_data_req_->chunks_to_move(); in TryDirectPatchLocked()525 if (commit_data_req_) { in FlushPendingCommitDataRequests()539 for (auto& ctm : *commit_data_req_->mutable_chunks_to_move()) { in FlushPendingCommitDataRequests()566 req = std::move(commit_data_req_); in FlushPendingCommitDataRequests()813 if (!commit_data_req_) { in NotifyFlushComplete()[all …]
285 std::unique_ptr<CommitDataRequest> commit_data_req_; variable