| /rocksdb-6.9/utilities/transactions/ |
| D | pessimistic_transaction.cc | 201 assert(log_number_ == 0 || in Prepare()
258 &log_number_, kRefNoLog, kDisableMemtable, KIgnoreSeqUsed, kNoBatchCount, in PrepareInternal()
300 if (log_number_ > 0) { in Commit()
302 log_number_); in Commit()
327 assert(log_number_ > 0); in Commit()
329 log_number_); in Commit()
389 /*log_used*/ nullptr, /*log_ref*/ log_number_, in CommitInternal()
407 assert(log_number_ > 0); in Rollback()
409 log_number_); in Rollback()
414 if (log_number_ > 0) { in Rollback()
[all …]
|
| D | write_unprepared_txn.cc | 54 assert(log_number_ > 0); in ~WriteUnpreparedTxn()
71 log_number_); in ~WriteUnpreparedTxn()
353 const bool first_prepare_batch = log_number_ == 0; in FlushWriteBatchToDBInternal()
378 if (log_number_ == 0) { in FlushWriteBatchToDBInternal()
379 log_number_ = last_log_number_; in FlushWriteBatchToDBInternal()
521 assert(log_number_ == 0); in CommitWithoutPrepareInternal()
|
| D | write_unprepared_txn_db.cc | 264 auto first_log_number = recovered_trx->batches_.begin()->second.log_number_; in Initialize()
287 assert(batch_info.log_number_); in Initialize()
|
| D | pessimistic_transaction_db.cc | 126 assert(batch_info.log_number_); in Initialize()
143 real_trx->SetLogNumber(batch_info.log_number_); in Initialize()
|
| D | transaction_base.cc | 32 log_number_ = 0; in TransactionBaseImpl()
64 log_number_ = 0; in Reinitialize()
|
| D | write_prepared_txn.cc | 121 /*callback*/ nullptr, &log_number_, /*log ref*/ 0, !DISABLE_MEMTABLE, in PrepareInternal()
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | transaction.h | 471 virtual void SetLogNumber(uint64_t log) { log_number_ = log; } in SetLogNumber()
473 virtual uint64_t GetLogNumber() const { return log_number_; } in GetLogNumber()
514 Transaction() : log_number_(0), txn_state_(STARTED) {} in Transaction()
518 uint64_t log_number_; variable
530 virtual uint64_t GetLastLogNumber() const { return log_number_; } in GetLastLogNumber()
|
| /rocksdb-6.9/db/ |
| D | log_writer.h | 88 uint64_t get_log_number() const { return log_number_; } in get_log_number()
99 uint64_t log_number_; variable
|
| D | log_reader.h | 94 uint64_t GetLogNumber() const { return log_number_; } in GetLogNumber()
122 uint64_t const log_number_; variable
|
| D | version_edit.cc | 139 log_number_ = 0; in Clear()
175 PutVarint32Varint64(dst, kLogNumber, log_number_); in EncodeTo()
455 if (GetVarint64(&input, &log_number_)) { in DecodeFrom()
691 AppendNumberTo(&r, log_number_); in DebugString()
784 jw << "LogNumber" << log_number_; in DebugJSON()
|
| D | log_writer.cc | 25 log_number_(log_number), in Writer()
143 EncodeFixed32(buf + 7, static_cast<uint32_t>(log_number_)); in EmitPhysicalRecord()
|
| D | version_edit_handler.cc | 286 version_set_->MarkFileNumberUsed(version_edit_params_.log_number_); in CheckIterationResult()
429 if (cfd->GetLogNumber() > edit.log_number_) { in ExtractInfoFromVersionEdit()
435 cfd->SetLogNumber(edit.log_number_); in ExtractInfoFromVersionEdit()
436 version_edit_params_.SetLogNumber(edit.log_number_); in ExtractInfoFromVersionEdit()
|
| D | version_edit.h | 271 log_number_ = num; in SetLogNumber()
274 uint64_t GetLogNumber() const { return log_number_; } in GetLogNumber()
441 uint64_t log_number_ = 0; variable
|
| D | column_family.h | 319 void SetLogNumber(uint64_t log_number) { log_number_ = log_number; } in SetLogNumber()
320 uint64_t GetLogNumber() const { return log_number_; } in GetLogNumber()
570 uint64_t log_number_; variable
|
| D | log_reader.cc | 40 log_number_(log_num), in Reader()
348 if (log_num != log_number_) { in ReadPhysicalRecord()
582 if (log_num != log_number_) { in TryReadFragment()
|
| D | version_set.cc | 4173 assert(edit->log_number_ >= cfd->GetLogNumber()); in LogAndApplyHelper()
4174 assert(edit->log_number_ < next_file_number_.load()); in LogAndApplyHelper()
4296 if (cfd->GetLogNumber() > from_edit.log_number_) { in ExtractInfoFromVersionEdit()
4302 cfd->SetLogNumber(from_edit.log_number_); in ExtractInfoFromVersionEdit()
4303 version_edit_params->SetLogNumber(from_edit.log_number_); in ExtractInfoFromVersionEdit()
4526 MarkFileNumberUsed(version_edit_params.log_number_); in Recover()
4607 last_sequence_.load(), version_edit_params.log_number_, in Recover()
5079 cfd->SetLogNumber(edit.log_number_); in DumpManifest()
5732 new_cfd->SetLogNumber(edit->log_number_); in CreateColumnFamily()
5888 MarkFileNumberUsed(version_edit.log_number_); in Recover()
[all …]
|
| D | column_family.cc | 514 log_number_(0), in ColumnFamilyData()
|
| D | db_test2.cc | 901 unsigned long long log_number_; in TEST_F() member in ROCKSDB_NAMESPACE::TEST_F::TestWalFilterWithColumnFamilies::LogRecordFound::LogRecordBatchHandler
908 log_number_(current_log_number){} in TEST_F()
918 if (log_number_ >= log_number_for_cf) { in TEST_F()
|
| D | write_batch.cc | 1905 log_number_ref_ = batch_info.log_number_; in MarkCommit()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_log_writer.h | 69 uint64_t get_log_number() const { return log_number_; } in get_log_number()
81 uint64_t log_number_; variable
|
| D | blob_log_writer.cc | 28 log_number_(log_number), in Writer()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.h | 722 uint64_t log_number_; member
805 info.second.log_number_); in DeleteRecoveredTransaction()
|
| /rocksdb-6.9/ |
| D | HISTORY.md | 61 * Fix a race condition for cfd->log_number_ between manifest switch and memtable switch (PR 6249) w…
|