Lines Matching refs:commit_seq
190 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq);
191 return cached.commit_seq <= snapshot_seq;
249 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq);
250 return cached.commit_seq <= snapshot_seq;
338 void AddCommitted(uint64_t prepare_seq, uint64_t commit_seq,
343 uint64_t commit_seq; member
344 CommitEntry() : prep_seq(0), commit_seq(0) {} in CommitEntry()
345 CommitEntry(uint64_t ps, uint64_t cs) : prep_seq(ps), commit_seq(cs) {} in CommitEntry()
347 return prep_seq == rhs.prep_seq && commit_seq == rhs.commit_seq;
386 : CommitEntry64b(entry.prep_seq, entry.commit_seq, format) {} in CommitEntry64b()
423 entry->commit_seq = entry->prep_seq + delta - 1; in Parse()
708 const uint64_t& commit_seq,
924 virtual Status Callback(SequenceNumber commit_seq, in Callback() argument
935 ? commit_seq in Callback()
936 : commit_seq + data_batch_cnt_ - 1; in Callback()
954 db_->AddCommitted(commit_seq + i, last_commit_seq); in Callback()
1016 Status Callback(SequenceNumber commit_seq, bool is_mem_disabled, uint64_t, in Callback() argument
1024 const uint64_t last_commit_seq = commit_seq; in Callback()