Lines Matching refs:prep_seq
113 inline bool IsInSnapshot(uint64_t prep_seq, uint64_t snapshot_seq,
119 prep_seq, snapshot_seq, min_uncommitted);
127 if (prep_seq == 0) {
132 prep_seq, snapshot_seq, 1);
135 if (snapshot_seq < prep_seq) {
139 prep_seq, snapshot_seq, 0);
142 if (prep_seq < min_uncommitted) {
147 prep_seq, snapshot_seq, 1, min_uncommitted);
161 auto indexed_seq = prep_seq % COMMIT_CACHE_SIZE;
185 if (exist && prep_seq == cached.prep_seq) {
190 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq);
203 if (max_evicted_seq_ub < prep_seq) {
209 prep_seq, snapshot_seq, 0);
221 static_cast<uint64_t>(delayed_prepared_.size()), prep_seq);
222 if (delayed_prepared_.find(prep_seq) != delayed_prepared_.end()) {
226 auto it = delayed_prepared_commits_.find(prep_seq);
232 prep_seq, snapshot_seq, 0);
238 prep_seq, snapshot_seq, it->second,
245 if (exist && prep_seq == cached.prep_seq) {
249 prep_seq, snapshot_seq, cached.commit_seq <= snapshot_seq);
268 prep_seq, snapshot_seq, 1);
278 prep_seq, snapshot_seq, 0);
296 found = std::binary_search(vec.begin(), vec.end(), prep_seq);
302 prep_seq, snapshot_seq, 0);
315 prep_seq, snapshot_seq, 1);
322 prep_seq, snapshot_seq, 0);
342 uint64_t prep_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()
421 entry->prep_seq = prep_up | prep_low; in Parse()
423 entry->commit_seq = entry->prep_seq + delta - 1; in Parse()
707 bool MaybeUpdateOldCommitMap(const uint64_t& prep_seq,
907 WritePreparedTxnDB* db, DBImpl* db_impl, SequenceNumber prep_seq,
912 prep_seq_(prep_seq), in db_()
919 assert((prep_batch_cnt_ > 0) != (prep_seq == kMaxSequenceNumber)); // xor in db_()
1003 SequenceNumber prep_seq, in WritePreparedRollbackPreReleaseCallback() argument
1008 prep_seq_(prep_seq), in WritePreparedRollbackPreReleaseCallback()
1011 assert(prep_seq != kMaxSequenceNumber); in WritePreparedRollbackPreReleaseCallback()