Searched refs:ordered_commit_set_ (Results 1 – 3 of 3) sorted by relevance
41 ordered_commit_set_->GetAllCommitIds(); in ExecuteImpl()46 status->set_commit_set(*ordered_commit_set_.get()); in ExecuteImpl()61 if (ordered_commit_set_->HaveCommitItem(handle) || in AddUncommittedParentsAndTheirPredecessors()73 ordered_commit_set_->AppendReverse(item_dependencies); in AddUncommittedParentsAndTheirPredecessors()80 ordered_commit_set_->HaveCommitItem(item_handle)) { in AddItem()120 ordered_commit_set_->AppendReverse(item_dependencies); in AddPredecessorsThenItem()124 return ordered_commit_set_->Size() >= requested_commit_batch_size_; in IsCommitBatchFull()133 ordered_commit_set_.get()); in AddCreatesAndMoves()151 ordered_commit_set_->Truncate(requested_commit_batch_size_); in AddCreatesAndMoves()159 ordered_commit_set_.get()); in AddDeletes()[all …]
137 scoped_ptr<sessions::OrderedCommitSet> ordered_commit_set_; variable
358 command.ordered_commit_set_->GetAllCommitIds(); in DoTruncationTest()366 proj = command.ordered_commit_set_->GetCommitIdProjection(GROUP_PASSIVE); in DoTruncationTest()371 command.ordered_commit_set_->GetCommitIdAt(proj[i]); in DoTruncationTest()