Home
last modified time | relevance | path

Searched refs:listeners (Results 1 – 25 of 47) sorted by relevance

12

/rocksdb-6.9/db/
Devent_helpers.cc35 for (auto& listener : listeners) { in NotifyTableFileCreationStarted()
46 if (listeners.size() == 0U) { in NotifyOnBackgroundError()
52 for (auto& listener : listeners) { in NotifyOnBackgroundError()
60 (void)listeners; in NotifyOnBackgroundError()
143 if (listeners.size() == 0) { in LogAndNotifyTableFileCreationFinished()
155 for (auto& listener : listeners) { in LogAndNotifyTableFileCreationFinished()
159 (void)listeners; in LogAndNotifyTableFileCreationFinished()
192 for (auto& listener : listeners) { in LogAndNotifyTableFileDeletion()
198 (void)listeners; in LogAndNotifyTableFileDeletion()
206 if (listeners.size() == 0U) { in NotifyOnErrorRecoveryCompleted()
[all …]
Devent_helpers.h24 const std::vector<std::shared_ptr<EventListener>>& listeners,
29 const std::vector<std::shared_ptr<EventListener>>& listeners,
34 const std::vector<std::shared_ptr<EventListener>>& listeners,
43 const std::vector<std::shared_ptr<EventListener>>& listeners);
45 const std::vector<std::shared_ptr<EventListener>>& listeners,
51 const std::vector<std::shared_ptr<EventListener>>& listeners,
Dlistener_test.cc178 options.listeners.emplace_back(listener); in TEST_F()
314 options.listeners.emplace_back(listener); in TEST_F()
357 options.listeners.emplace_back(listener); in TEST_F()
406 options.listeners.emplace_back(listeners[i]); in TEST_F()
443 for (auto* listener : listeners) { in TEST_F()
482 options.listeners.emplace_back(listener); in TEST_F()
777 options.listeners.push_back(listener); in TEST_F()
835 options.listeners.push_back(listener); in TEST_F()
873 options.listeners.push_back(listener); in TEST_F()
911 options.listeners.push_back(listener); in TEST_F()
[all …]
Derror_handler_fs_test.cc161 options.listeners.emplace_back(listener); in TEST_F()
193 options.listeners.emplace_back(listener); in TEST_F()
256 options.listeners.emplace_back(listener); in TEST_F()
299 options.listeners.emplace_back(listener); in TEST_F()
344 options.listeners.emplace_back(listener); in TEST_F()
395 options.listeners.emplace_back(listener); in TEST_F()
468 options.listeners.emplace_back(listener); in TEST_F()
523 options.listeners.emplace_back(listener); in TEST_F()
567 options.listeners.emplace_back(listener); in TEST_F()
653 options.listeners.emplace_back(listener); in TEST_F()
[all …]
Dcompact_files_test.cc135 options.listeners.emplace_back(collector); in TEST_F()
174 options.listeners.emplace_back(collector); in TEST_F()
210 options.listeners.emplace_back(collector); in TEST_F()
335 options.listeners.emplace_back(collector); in TEST_F()
374 options.listeners.emplace_back(collector); in TEST_F()
Dbuilder.cc107 ioptions.listeners, dbname, column_family_name, fname, job_id, reason); in BuildTable()
128 event_logger, ioptions.listeners, dbname, column_family_name, fname, in BuildTable()
137 ioptions.listeners, ioptions.file_checksum_gen_factory)); in BuildTable()
268 event_logger, ioptions.listeners, dbname, column_family_name, fname, in BuildTable()
Derror_handler.cc219 EventHelpers::NotifyOnBackgroundError(db_options_.listeners, reason, &s, in SetBGError()
258 EventHelpers::NotifyOnBackgroundError(db_options_.listeners, reason, &s, in SetBGError()
269 EventHelpers::NotifyOnBackgroundError(db_options_.listeners, reason, &s, in SetBGError()
339 EventHelpers::NotifyOnErrorRecoveryCompleted(db_options_.listeners, in ClearBGError()
Djob_context.h82 for (auto& listener : notif.immutable_cf_options->listeners) { in Clean()
/rocksdb-6.9/file/
Drandom_access_file_reader.h68 const std::vector<std::shared_ptr<EventListener>>& listeners = {})
78 std::for_each(listeners.begin(), listeners.end(), in file_()
85 (void)listeners; in file_()
Dwritable_file_writer.h83 const std::vector<std::shared_ptr<EventListener>>& listeners = {},
107 std::for_each(listeners.begin(), listeners.end(), in writable_file_()
114 (void)listeners; in writable_file_()
/rocksdb-6.9/options/
Dcf_options.cc74 listeners(db_options.listeners), in ImmutableCFOptions()
Ddb_options.cc68 listeners(options.listeners), in ImmutableDBOptions()
Ddb_options.h62 std::vector<std::shared_ptr<EventListener>> listeners; member
Dcf_options.h117 std::vector<std::shared_ptr<EventListener>> listeners; member
Doptions_settable_test.cc196 {offsetof(struct DBOptions, listeners), in TEST_F()
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc1383 event_logger_, cfd->ioptions()->listeners, dbname_, cfd->GetName(), fname, in FinishCompactionOutputFile()
1474 cfd->ioptions()->listeners, dbname_, cfd->GetName(), fname, job_id_, in OpenCompactionOutputFile()
1494 event_logger_, cfd->ioptions()->listeners, dbname_, cfd->GetName(), in OpenCompactionOutputFile()
1531 const auto& listeners = in OpenCompactionOutputFile() local
1532 sub_compact->compaction->immutable_cf_options()->listeners; in OpenCompactionOutputFile()
1535 env_, db_options_.statistics.get(), listeners, in OpenCompactionOutputFile()
Dcompaction_job_stats_test.cc651 options.listeners.emplace_back(stats_checker); in TEST_P()
872 options.listeners.emplace_back(stats_checker); in TEST_P()
961 options.listeners.emplace_back(stats_checker); in TEST_P()
/rocksdb-6.9/util/
Dlog_write_bench.cc44 options.listeners)); in RunBenchmark()
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc591 if (immutable_db_options_.listeners.size() == 0U) { in NotifyOnFlushBegin()
623 for (auto listener : immutable_db_options_.listeners) { in NotifyOnFlushBegin()
643 if (immutable_db_options_.listeners.size() == 0U) { in NotifyOnFlushCompleted()
662 for (auto listener : immutable_db_options_.listeners) { in NotifyOnFlushCompleted()
1149 if (immutable_db_options_.listeners.empty()) { in NotifyOnCompactionBegin()
1204 for (auto listener : immutable_db_options_.listeners) { in NotifyOnCompactionBegin()
1223 if (immutable_db_options_.listeners.size() == 0U) { in NotifyOnCompactionCompleted()
1243 for (auto listener : immutable_db_options_.listeners) { in NotifyOnCompactionCompleted()
Ddb_impl_open.cc284 immutable_db_options_.listeners)); in NewDB()
1356 const auto& listeners = immutable_db_options_.listeners; in CreateWAL() local
1359 env_, nullptr /* stats */, listeners)); in CreateWAL()
/rocksdb-6.9/examples/
Dcompact_files_example.cc144 options.listeners.emplace_back(new FullCompactor(options)); in main()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_test_base.cc1212 restore_options.listeners.clear(); in TestBackupRestore()
1319 tmp_opts.listeners.clear(); in TestCheckpoint()
1335 options.listeners.clear(); in TestCheckpoint()
1956 options_.listeners.clear(); in Open()
1957 options_.listeners.emplace_back( in Open()
/rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/
Dgtest-all.cc1000 TestEventListeners* listeners() { return &listeners_; } in listeners() function in testing::internal::UnitTestImpl
2192 unit_test_->listeners()->repeater()->OnTestPartResult(result); in ReportTestPartResult()
6061 TestEventListeners& UnitTest::listeners() { in listeners() function in testing::UnitTest
6062 return *impl()->listeners(); in listeners()
6375 listeners()->SuppressEventForwarding(); in SuppressTestEventsIfInSubprocess()
6384 listeners()->SetDefaultXmlGenerator(new XmlUnitTestResultPrinter( in ConfigureXmlOutput()
6387 listeners()->SetDefaultXmlGenerator(new JsonUnitTestResultPrinter( in ConfigureXmlOutput()
6403 listeners()->Append(new StreamingListener(target.substr(0, pos), in ConfigureStreamingOutput()
6425 listeners()->Append(new GTEST_CUSTOM_TEST_EVENT_LISTENER_()); in PostFlagParsingInit()
6592 TestEventListener* repeater = listeners()->repeater(); in RunAllTests()
[all …]
/rocksdb-6.9/include/rocksdb/
Doptions.h872 std::vector<std::shared_ptr<EventListener>> listeners; member
/rocksdb-6.9/table/
Dsst_file_writer.cc248 nullptr /* stats */, r->ioptions.listeners)); in Open()

12