| /rocksdb-6.9/db/ |
| D | listener_test.cc | 443 for (auto* listener : listeners) { in TEST_F() local
559 listener->compaction_reasons_.clear(); in TEST_F()
571 listener->compaction_reasons_.clear(); in TEST_F()
602 listener->compaction_reasons_.clear(); in TEST_F()
620 listener->compaction_reasons_.clear(); in TEST_F()
778 options.env = &listener->test_env; in TEST_F()
868 auto listener = in TEST_F() local
880 ASSERT_EQ(listener->getCounter(), 3); in TEST_F()
929 ASSERT_EQ(1, listener->counter()); in TEST_F()
961 ASSERT_EQ(1, listener->counter()); in TEST_F()
[all …]
|
| D | error_handler_fs_test.cc | 164 listener->EnableAutoRecovery(false); in TEST_F()
196 listener->EnableAutoRecovery(false); in TEST_F()
261 listener->EnableAutoRecovery(false); in TEST_F()
304 listener->EnableAutoRecovery(false); in TEST_F()
349 listener->EnableAutoRecovery(false); in TEST_F()
484 listener->EnableAutoRecovery(false); in TEST_F()
532 listener->OverrideBGError( in TEST_F()
656 listener->EnableAutoRecovery(); in TEST_F()
691 listener->EnableAutoRecovery(); in TEST_F()
721 listener->EnableAutoRecovery(); in TEST_F()
[all …]
|
| D | event_helpers.cc | 35 for (auto& listener : listeners) { in NotifyTableFileCreationStarted() local
36 listener->OnTableFileCreationStarted(info); in NotifyTableFileCreationStarted()
52 for (auto& listener : listeners) { in NotifyOnBackgroundError() local
53 listener->OnBackgroundError(reason, bg_error); in NotifyOnBackgroundError()
55 listener->OnErrorRecoveryBegin(reason, *bg_error, auto_recovery); in NotifyOnBackgroundError()
155 for (auto& listener : listeners) { in LogAndNotifyTableFileCreationFinished() local
156 listener->OnTableFileCreated(info); in LogAndNotifyTableFileCreationFinished()
192 for (auto& listener : listeners) { in LogAndNotifyTableFileDeletion() local
193 listener->OnTableFileDeleted(info); in LogAndNotifyTableFileDeletion()
212 for (auto& listener : listeners) { in NotifyOnErrorRecoveryCompleted() local
[all …]
|
| D | db_flush_test.cc | 394 std::shared_ptr<TestListener> listener = std::make_shared<TestListener>(); in TEST_F() local
402 "FlushJob::WriteLevel0Table", [&listener](void* arg) { in TEST_F()
405 if (mems->front()->GetEarliestSequenceNumber() == listener->seq1 - 1) { in TEST_F()
414 options.listeners.push_back(listener); in TEST_F()
422 listener->seq1 = db_->GetLatestSequenceNumber(); in TEST_F()
434 listener->seq2 = db_->GetLatestSequenceNumber(); in TEST_F()
439 ASSERT_TRUE(listener->completed1); in TEST_F()
440 ASSERT_TRUE(listener->completed2); in TEST_F()
|
| D | external_sst_file_test.cc | 2174 TestIngestExternalFileListener* listener = in TEST_P() local
2176 options.listeners.emplace_back(listener); in TEST_P()
2185 ASSERT_EQ(listener->ingested_files.size(), 1); in TEST_P()
2186 ASSERT_EQ(listener->ingested_files.back().cf_name, "default"); in TEST_P()
2187 ASSERT_EQ(listener->ingested_files.back().global_seqno, 0); in TEST_P()
2197 ASSERT_EQ(listener->ingested_files.size(), 2); in TEST_P()
2198 ASSERT_EQ(listener->ingested_files.back().cf_name, "koko"); in TEST_P()
2199 ASSERT_EQ(listener->ingested_files.back().global_seqno, 0); in TEST_P()
2209 ASSERT_EQ(listener->ingested_files.size(), 3); in TEST_P()
2210 ASSERT_EQ(listener->ingested_files.back().cf_name, "toto"); in TEST_P()
[all …]
|
| D | job_context.h | 82 for (auto& listener : notif.immutable_cf_options->listeners) { in Clean()
83 listener->OnStallConditionsChanged(notif.write_stall_info); in Clean()
|
| D | db_properties_test.cc | 1516 std::shared_ptr<TestListener> listener = std::make_shared<TestListener>(); in TEST_F() local
1520 options.listeners.push_back(listener); in TEST_F()
1535 listener->size_before_compaction = sst_size; in TEST_F()
1538 ASSERT_TRUE(listener->callback_triggered); in TEST_F()
1581 std::shared_ptr<TestListener> listener = std::make_shared<TestListener>(); in TEST_F() local
1584 options.listeners.push_back(listener); in TEST_F()
1587 listener->SetDB(db_); in TEST_F()
1596 ASSERT_TRUE(listener->Validated()); in TEST_F()
|
| /rocksdb-6.9/file/ |
| D | random_access_file_reader.h | 45 for (auto& listener : listeners_) { in NotifyOnFileReadFinish()
46 listener->OnFileReadFinish(info); in NotifyOnFileReadFinish()
|
| D | writable_file_writer.h | 46 for (auto& listener : listeners_) { in NotifyOnFileWriteFinish()
47 listener->OnFileWriteFinish(info); in NotifyOnFileWriteFinish()
|
| /rocksdb-6.9/port/ |
| D | port_posix.cc.d | 9 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| /rocksdb-6.9/util/ |
| D | status.cc.d | 8 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| D | comparator.cc.d | 9 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| D | timer_queue_test.cc.d | 10 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| D | string_util.cc.d | 9 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| D | filelock_test.cc.d | 10 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| D | thread_local.cc.d | 9 include/rocksdb/file_checksum.h include/rocksdb/listener.h \
|
| D | coding.cc.d | 9 include/rocksdb/file_checksum.h include/rocksdb/listener.h \
|
| /rocksdb-6.9/table/block_based/ |
| D | data_block_footer.cc.d | 13 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| /rocksdb-6.9/monitoring/ |
| D | histogram.cc.d | 9 include/rocksdb/file_checksum.h include/rocksdb/listener.h \
|
| D | perf_level.cc.d | 10 include/rocksdb/listener.h include/rocksdb/compaction_job_stats.h \
|
| /rocksdb-6.9/test_util/ |
| D | sync_point.cc.d | 9 include/rocksdb/file_checksum.h include/rocksdb/listener.h \
|
| /rocksdb-6.9/env/ |
| D | mock_env_test.cc.d | 8 include/rocksdb/file_checksum.h include/rocksdb/listener.h \
|
| D | env_basic_test.cc.d | 8 include/rocksdb/file_checksum.h include/rocksdb/listener.h \
|
| D | file_system.cc.d | 9 include/rocksdb/file_checksum.h include/rocksdb/listener.h \
|
| /rocksdb-6.9/utilities/table_properties_collectors/ |
| D | compact_on_deletion_collector_test.cc.d | 12 include/rocksdb/file_checksum.h include/rocksdb/listener.h \
|