| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_secondary.cc | 129 auto iter = log_readers_.find(log_number); in MaybeInitLogReader()
162 std::move(file_reader), log_number); in MaybeInitLogReader()
166 iter = log_readers_.find(log_number); in MaybeInitLogReader()
182 for (auto log_number : log_numbers) { in RecoverLogFiles() local
184 status = MaybeInitLogReader(log_number, &reader); in RecoverLogFiles()
190 for (auto log_number : log_numbers) { in RecoverLogFiles() local
191 auto it = log_readers_.find(log_number); in RecoverLogFiles()
195 versions_->MarkFileNumberUsed(log_number); in RecoverLogFiles()
249 cfd->mem()->SetNextLogNumber(log_number); in RecoverLogFiles()
280 } else if (log_number > iter->second) { in RecoverLogFiles()
[all …]
|
| D | db_impl_open.cc | 728 for (auto log_number : log_numbers) { in RecoverLogFiles() local
729 stream << log_number; in RecoverLogFiles()
754 for (auto log_number : log_numbers) { in RecoverLogFiles() local
755 if (log_number < min_log_number) { in RecoverLogFiles()
759 log_number, min_log_number); in RecoverLogFiles()
765 versions_->MarkFileNumberUsed(log_number); in RecoverLogFiles()
916 log_number, in RecoverLogFiles()
997 corrupted_log_number = log_number; in RecoverLogFiles()
1151 for (auto log_number : log_numbers) { in RestoreAliveLogFiles() local
1152 LogFileNumberSize log(log_number); in RestoreAliveLogFiles()
[all …]
|
| D | db_impl_secondary.h | 24 uint64_t log_number) { in LogReaderContainer() argument
38 log_number); in LogReaderContainer()
216 Status MaybeInitLogReader(uint64_t log_number,
|
| D | db_impl_files.cc | 104 job_context->log_number = MinLogNumberToKeep(); in FindObsoleteFiles()
184 uint64_t min_log_number = job_context->log_number; in FindObsoleteFiles()
403 keep = ((number >= state.log_number) || in PurgeObsoleteFiles()
|
| D | db_impl.h | 753 void AddBatch(SequenceNumber seq, uint64_t log_number, WriteBatch* batch, in AddBatch()
756 batches_[seq] = {log_number, batch, batch_cnt}; in AddBatch()
|
| D | db_impl.cc | 534 uint64_t log_number = log.writer->get_log_number(); in CloseHelper() local
540 LogFileName(immutable_db_options_.wal_dir, log_number).c_str(), in CloseHelper()
|
| /rocksdb-6.9/db/ |
| D | write_batch_internal.h | 168 bool ignore_missing_column_families = false, uint64_t log_number = 0,
178 bool ignore_missing_column_families = false, uint64_t log_number = 0,
188 uint64_t log_number = 0, DB* db = nullptr,
|
| D | log_writer.cc | 21 Writer::Writer(std::unique_ptr<WritableFileWriter>&& dest, uint64_t log_number, in Writer() argument
25 log_number_(log_number), in Writer()
|
| D | job_context.h | 170 uint64_t log_number; member
185 log_number = 0;
|
| D | pre_release_callback.h | 35 uint64_t log_number, size_t index, size_t total) = 0;
|
| D | log_writer.h | 75 uint64_t log_number, bool recycle_log_files,
|
| D | column_family.h | 319 void SetLogNumber(uint64_t log_number) { log_number_ = log_number; } in SetLogNumber() argument
|
| D | memtable_list.cc | 748 void MemTableList::RemoveOldMemTables(uint64_t log_number, in RemoveOldMemTables() argument
756 if (mem->GetNextLogNumber() > log_number) { in RemoveOldMemTables()
|
| D | memtable_list.h | 372 void RemoveOldMemTables(uint64_t log_number,
|
| D | write_batch.cc | 2004 bool ignore_missing_column_families, uint64_t log_number, DB* db, in InsertInto() argument
2013 ignore_missing_column_families, log_number, db, in InsertInto()
2031 bool ignore_missing_column_families, uint64_t log_number, DB* db, in InsertInto() argument
2036 ignore_missing_column_families, log_number, db, in InsertInto()
|
| D | version_set.h | 1113 uint64_t log_number; member
|
| D | version_set.cc | 5259 uint64_t log_number = iter->second.log_number; in WriteCurrentStateToManifest() local
5260 edit.SetLogNumber(log_number); in WriteCurrentStateToManifest()
|
| D | db_test2.cc | 892 WalProcessingOption LogRecordFound(unsigned long long log_number, in TEST_F() argument
924 } handler(log_number, cf_log_number_map_, cf_wal_keys_); in TEST_F()
|
| /rocksdb-6.9/java/rocksjni/ |
| D | wal_filter_jnicallback.cc | 96 unsigned long long log_number, const std::string& log_file_name, in LogRecordFound() argument
114 static_cast<jlong>(log_number), in LogRecordFound()
|
| D | wal_filter_jnicallback.h | 30 unsigned long long log_number, const std::string& log_file_name,
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_log_writer.cc | 23 Statistics* statistics, uint64_t log_number, uint64_t bpsync, in Writer() argument
28 log_number_(log_number), in Writer()
|
| D | blob_log_writer.h | 40 Statistics* statistics, uint64_t log_number, uint64_t bpsync,
|
| /rocksdb-6.9/utilities/transactions/ |
| D | pessimistic_transaction.cc | 234 uint64_t log_number, size_t /*index*/, in PrepareInternal() argument
239 assert(log_number != 0); in PrepareInternal()
241 db_->logs_with_prep_tracker()->MarkLogAsContainingPrepSection(log_number); in PrepareInternal()
|
| D | write_prepared_txn_db.h | 862 uint64_t log_number, size_t index, in Callback() argument
885 assert(log_number != 0); in Callback()
887 log_number); in Callback()
|
| /rocksdb-6.9/tools/ |
| D | ldb_cmd.cc | 2215 uint64_t log_number; in DumpWalFile() local
2223 if (!ParseFileName(sanitized, &log_number, &type)) { in DumpWalFile()
2225 log_number = 0; in DumpWalFile()
2228 true /* checksum */, log_number); in DumpWalFile()
|