Searched refs:seq_used (Results 1 – 7 of 7) sorted by relevance
| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_txn.cc | 118 uint64_t seq_used = kMaxSequenceNumber; in PrepareInternal() local
123 assert(!s.ok() || seq_used != kMaxSequenceNumber); in PrepareInternal()
124 auto prepare_seq = seq_used; in PrepareInternal()
185 uint64_t seq_used = kMaxSequenceNumber; in CommitInternal() local
194 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitInternal()
195 const SequenceNumber commit_batch_seq = seq_used; in CommitInternal()
229 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitInternal()
359 uint64_t seq_used = kMaxSequenceNumber; in RollbackInternal() local
387 assert(!s.ok() || seq_used != kMaxSequenceNumber); in RollbackInternal()
396 uint64_t rollback_seq = seq_used; in RollbackInternal()
[all …]
|
| D | pessimistic_transaction.cc | 348 uint64_t seq_used = kMaxSequenceNumber; in CommitWithoutPrepareInternal() local
353 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitWithoutPrepareInternal()
355 SetId(seq_used); in CommitWithoutPrepareInternal()
361 uint64_t seq_used = kMaxSequenceNumber; in CommitBatchInternal() local
364 /*disable_memtable*/ false, &seq_used); in CommitBatchInternal()
365 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitBatchInternal()
367 SetId(seq_used); in CommitBatchInternal()
386 uint64_t seq_used = kMaxSequenceNumber; in CommitInternal() local
390 /*disable_memtable*/ false, &seq_used); in CommitInternal()
391 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitInternal()
[all …]
|
| D | write_unprepared_txn.cc | 369 uint64_t seq_used = kMaxSequenceNumber; in FlushWriteBatchToDBInternal() local
381 assert(!s.ok() || seq_used != kMaxSequenceNumber); in FlushWriteBatchToDBInternal()
382 auto prepare_seq = seq_used; in FlushWriteBatchToDBInternal()
578 uint64_t seq_used = kMaxSequenceNumber; in CommitInternal() local
587 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitInternal()
588 const SequenceNumber commit_batch_seq = seq_used; in CommitInternal()
629 assert(!s.ok() || seq_used != kMaxSequenceNumber); in CommitInternal()
719 uint64_t seq_used = kMaxSequenceNumber; in RollbackInternal() local
744 assert(!s.ok() || seq_used != kMaxSequenceNumber); in RollbackInternal()
758 uint64_t& prepare_seq = seq_used; in RollbackInternal()
[all …]
|
| D | write_prepared_txn_db.cc | 174 uint64_t seq_used = kMaxSequenceNumber; in WriteInternal() local
193 no_log_ref, !DISABLE_MEMTABLE, &seq_used, in WriteInternal()
195 assert(!s.ok() || seq_used != kMaxSequenceNumber); in WriteInternal()
196 uint64_t prepare_seq = seq_used; in WriteInternal()
219 no_log_ref, DISABLE_MEMTABLE, &seq_used, ONE_BATCH, in WriteInternal()
221 assert(!s.ok() || seq_used != kMaxSequenceNumber); in WriteInternal()
|
| D | write_unprepared_txn_db.cc | 175 uint64_t seq_used = kMaxSequenceNumber; in RollbackRecoveredTransaction() local
177 kNoLogRef, !kDisableMemtable, &seq_used, kOneBatch); in RollbackRecoveredTransaction()
185 db_impl_->SetLastPublishedSequence(seq_used); in RollbackRecoveredTransaction()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_write.cc | 139 if (seq_used) { in WriteImpl()
140 *seq_used = seq; in WriteImpl()
202 if (seq_used != nullptr) { in WriteImpl()
203 *seq_used = w.sequence; in WriteImpl()
409 *seq_used = w.sequence; in WriteImpl()
591 if (seq_used != nullptr) { in PipelinedWriteImpl()
592 *seq_used = w.sequence; in PipelinedWriteImpl()
670 if (seq_used != nullptr) { in WriteImplWALOnly()
671 *seq_used = w.sequence; in WriteImplWALOnly()
826 if (seq_used != nullptr) { in WriteImplWALOnly()
[all …]
|
| D | db_impl.h | 1086 bool disable_memtable = false, uint64_t* seq_used = nullptr,
1094 uint64_t* seq_used = nullptr);
1119 const uint64_t log_ref, uint64_t* seq_used, const size_t sub_batch_cnt,
|