| /rocksdb-6.9/monitoring/ |
| D | stats_history_test.cc | 603 ASSERT_EQ(cfd_stats->GetLogNumber(), cfd_test->GetLogNumber()); in TEST_F()
604 ASSERT_LT(cfd_stats->GetLogNumber(), cfd_default->GetLogNumber()); in TEST_F()
615 ASSERT_EQ(cfd_stats->GetLogNumber(), cfd_test->GetLogNumber()); in TEST_F()
616 ASSERT_GT(cfd_stats->GetLogNumber(), cfd_default->GetLogNumber()); in TEST_F()
627 ASSERT_EQ(cfd_stats->GetLogNumber(), cfd_test->GetLogNumber()); in TEST_F()
628 ASSERT_EQ(cfd_stats->GetLogNumber(), cfd_default->GetLogNumber()); in TEST_F()
641 ASSERT_LT(cfd_stats->GetLogNumber(), cfd_test->GetLogNumber()); in TEST_F()
642 ASSERT_EQ(cfd_stats->GetLogNumber(), cfd_default->GetLogNumber()); in TEST_F()
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_unprepared_transaction_test.cc | 518 ASSERT_GT(txn1->GetLogNumber(), 0); in TEST_P()
519 ASSERT_GT(txn2->GetLogNumber(), 0); in TEST_P()
522 txn1->GetLogNumber()); in TEST_P()
523 ASSERT_GT(db_impl->TEST_LogfileNumber(), txn1->GetLogNumber()); in TEST_P()
530 ASSERT_GE(db_impl->TEST_LogfileNumber(), txn1->GetLogNumber()); in TEST_P()
531 ASSERT_GE(db_impl->TEST_LogfileNumber(), txn2->GetLogNumber()); in TEST_P()
534 txn1->GetLogNumber()); in TEST_P()
542 txn2->GetLogNumber()); in TEST_P()
|
| D | transaction_test.cc | 1731 txn1->GetLogNumber()); in TEST_P()
1750 txn1->GetLogNumber()); in TEST_P()
1758 txn2->GetLogNumber()); in TEST_P()
1763 ASSERT_EQ(txn1->GetLogNumber(), in TEST_P()
1794 ASSERT_EQ(txn1->GetLogNumber(), in TEST_P()
1813 ASSERT_EQ(txn2->GetLogNumber(), in TEST_P()
1898 ASSERT_GT(cfh_a->cfd()->GetLogNumber(), prepare_log_no); in TEST_P()
1899 ASSERT_EQ(cfh_a->cfd()->GetLogNumber(), db_impl->TEST_LogfileNumber()); in TEST_P()
1904 ASSERT_EQ(cfh_a->cfd()->GetLogNumber(), prepare_log_no); in TEST_P()
1910 txn1->GetLogNumber()); in TEST_P()
|
| /rocksdb-6.9/db/ |
| D | write_batch_internal.h | 34 virtual uint64_t GetLogNumber() const = 0;
50 uint64_t GetLogNumber() const override { return 0; } in GetLogNumber() function
|
| D | column_family.h | 320 uint64_t GetLogNumber() const { return log_number_; } in GetLogNumber() function
738 uint64_t GetLogNumber() const override;
|
| D | log_reader.h | 94 uint64_t GetLogNumber() const { return log_number_; } in GetLogNumber() function
|
| D | column_family.cc | 690 auto current_log = GetLogNumber(); in OldestLogToKeep()
1531 uint64_t ColumnFamilyMemTablesImpl::GetLogNumber() const { in GetLogNumber() function in ROCKSDB_NAMESPACE::ColumnFamilyMemTablesImpl
1533 return current_->GetLogNumber(); in GetLogNumber()
|
| D | version_set.h | 1022 if (min_log_num > cfd->GetLogNumber() && !cfd->IsDropped()) { in PreComputeMinLogNumberWithUnflushedData()
1023 min_log_num = cfd->GetLogNumber(); in PreComputeMinLogNumberWithUnflushedData()
|
| D | version_edit_test.cc | 268 ASSERT_EQ(66, ve.GetLogNumber()); in TEST_F()
|
| D | version_edit.h | 274 uint64_t GetLogNumber() const { return log_number_; } in GetLogNumber() function
|
| D | version_edit_handler.cc | 429 if (cfd->GetLogNumber() > edit.log_number_) { in ExtractInfoFromVersionEdit()
|
| D | version_set.cc | 3826 curr_state[cfd->GetID()] = {cfd->GetLogNumber()}; in ProcessManifestWrites()
3987 assert(version->cfd_->GetLogNumber() <= max_log_number_in_batch); in ProcessManifestWrites()
4173 assert(edit->log_number_ >= cfd->GetLogNumber()); in LogAndApplyHelper()
4296 if (cfd->GetLogNumber() > from_edit.log_number_) { in ExtractInfoFromVersionEdit()
4618 cfd->GetName().c_str(), cfd->GetID(), cfd->GetLogNumber()); in Recover()
5141 printf("log number: %" PRIu64 "\n", cfd->GetLogNumber()); in DumpManifest()
5932 cfd->GetName().c_str(), cfd->GetID(), cfd->GetLogNumber()); in Recover()
|
| D | write_batch.cc | 1374 recovering_log_number_ < cf_mems_->GetLogNumber()) { in SeekToColumnFamily()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_files.cc | 624 std::max(cf_min_log_number_to_keep, e->GetLogNumber()); in PrecomputeMinLogNumberToKeep()
630 cf_min_log_number_to_keep = cfd_to_flush.GetLogNumber(); in PrecomputeMinLogNumberToKeep()
|
| D | db_impl_open.cc | 741 std::make_pair(cfd->GetID(), cfd->GetLogNumber())); in RecoverLogFiles()
963 assert(cfd->GetLogNumber() <= log_number); in RecoverLogFiles()
1038 if (cfd->GetLogNumber() > corrupted_log_number) { in RecoverLogFiles()
1059 if (cfd->GetLogNumber() > max_log_number) { in RecoverLogFiles()
|
| D | db_impl_secondary.cc | 132 iter->second->reader_->GetLogNumber() != log_number) { in MaybeInitLogReader()
542 cfd->imm()->RemoveOldMemTables(cfd->GetLogNumber(), in TryCatchUpWithPrimary()
|
| D | db_impl_write.cc | 1525 if (loop_cfd->GetLogNumber() <= cfd_stats->GetLogNumber()) { in MaybeFlushStatsCF()
|
| D | db_impl_compaction_flush.cc | 1629 if (loop_cfd->GetLogNumber() <= cfd_stats->GetLogNumber()) { in FlushMemTable()
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | transaction.h | 473 virtual uint64_t GetLogNumber() const { return log_number_; } in GetLogNumber() function
|
| /rocksdb-6.9/java/rocksjni/ |
| D | transaction.cc | 1505 return txn->GetLogNumber(); in Java_org_rocksdb_Transaction_getLogNumber()
|