Home
last modified time | relevance | path

Searched refs:FlushJobInfo (Results 1 – 23 of 23) sorted by relevance

/rocksdb-6.9/utilities/blob_db/
Dblob_db_listener.h24 void OnFlushBegin(DB* /*db*/, const FlushJobInfo& /*info*/) override { in OnFlushBegin() argument
29 void OnFlushCompleted(DB* /*db*/, const FlushJobInfo& /*info*/) override { in OnFlushCompleted() argument
49 void OnFlushCompleted(DB* db, const FlushJobInfo& info) override { in OnFlushCompleted()
Dblob_db_impl.h42 struct FlushJobInfo;
207 void TEST_ProcessFlushJobInfo(const FlushJobInfo& info);
336 void ProcessFlushJobInfo(const FlushJobInfo& info);
Dblob_db_test.cc1725 FlushJobInfo info{}; in TEST_F()
1753 FlushJobInfo info{}; in TEST_F()
1884 FlushJobInfo info{}; in TEST_F()
Dblob_db_impl.cc456 void BlobDBImpl::ProcessFlushJobInfo(const FlushJobInfo& info) { in ProcessFlushJobInfo()
2112 void BlobDBImpl::TEST_ProcessFlushJobInfo(const FlushJobInfo& info) { in TEST_ProcessFlushJobInfo()
/rocksdb-6.9/include/rocksdb/
Dlistener.h166 struct FlushJobInfo { struct
323 const FlushJobInfo& /*flush_job_info*/) {} in OnFlushCompleted() argument
333 const FlushJobInfo& /*flush_job_info*/) {} in OnFlushBegin() argument
487 struct FlushJobInfo {}; struct
/rocksdb-6.9/db/
Dflush_job.h88 std::list<std::unique_ptr<FlushJobInfo>>* GetCommittedFlushJobsInfo() { in GetCommittedFlushJobsInfo()
102 std::unique_ptr<FlushJobInfo> GetFlushJobInfo() const;
151 std::list<std::unique_ptr<FlushJobInfo>> committed_flush_jobs_info_;
Dmemtable.h35 struct FlushJobInfo;
439 void SetFlushJobInfo(std::unique_ptr<FlushJobInfo>&& info) { in SetFlushJobInfo()
443 std::unique_ptr<FlushJobInfo> ReleaseFlushJobInfo() { in ReleaseFlushJobInfo()
532 std::unique_ptr<FlushJobInfo> flush_job_info_;
Dflush_job.cc449 std::unique_ptr<FlushJobInfo> FlushJob::GetFlushJobInfo() const { in GetFlushJobInfo()
451 std::unique_ptr<FlushJobInfo> info(new FlushJobInfo{}); in GetFlushJobInfo()
Dmemtable_list.h36 struct FlushJobInfo;
269 std::list<std::unique_ptr<FlushJobInfo>>* committed_flush_jobs_info,
Dmemtable_list.cc393 std::list<std::unique_ptr<FlushJobInfo>>* committed_flush_jobs_info, in TryInstallMemtableFlushResults()
453 std::unique_ptr<FlushJobInfo> info = m->ReleaseFlushJobInfo(); in TryInstallMemtableFlushResults()
Dcompact_files_test.cc40 void OnFlushCompleted(DB* /*db*/, const FlushJobInfo& info) override { in OnFlushCompleted()
Dlistener_test.cc252 DB* db, const FlushJobInfo& info) override { in OnFlushCompleted()
826 const FlushJobInfo& flush_job_info) override { in OnFlushCompleted()
Ddb_flush_test.cc360 void OnFlushCompleted(DB* db, const FlushJobInfo& info) override { in TEST_F()
Ddb_with_timestamp_basic_test.cc512 void OnFlushCompleted(DB* /*db*/, const FlushJobInfo& info) override { in OnFlushCompleted()
Dmemtable_list_test.cc121 std::list<std::unique_ptr<FlushJobInfo>> flush_jobs_info; in Mock_InstallMemtableFlushResults()
Ddb_sst_test.cc30 void OnFlushCompleted(DB* /*db*/, const FlushJobInfo& info) override { in OnFlushCompleted()
Ddb_wal_test.cc1472 void OnFlushBegin(DB* /*db*/, const FlushJobInfo& flush_job_info) override { in TEST_F()
Ddb_compaction_test.cc61 void OnFlushCompleted(DB* /*db*/, const FlushJobInfo& info) override { in OnFlushCompleted()
107 void OnFlushCompleted(DB* /* db */, const FlushJobInfo& /* info */) override { in OnFlushCompleted() argument
/rocksdb-6.9/db_stress_tool/
Ddb_stress_listener.h26 void OnFlushCompleted(DB* /*db*/, const FlushJobInfo& info) override { in OnFlushCompleted()
34 const FlushJobInfo& /*flush_job_info*/) override { in OnFlushBegin() argument
/rocksdb-6.9/examples/
Dcompact_files_example.cc74 DB* db, const FlushJobInfo& info) override { in OnFlushCompleted()
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc607 FlushJobInfo info{}; in NotifyOnFlushBegin()
640 std::list<std::unique_ptr<FlushJobInfo>>* flush_jobs_info) { in NotifyOnFlushCompleted()
Ddb_impl.h1044 std::list<std::unique_ptr<FlushJobInfo>>* flush_jobs_info);
/rocksdb-6.9/
DHISTORY.md895 * EventListener::OnFlushCompleted() now passes FlushJobInfo instead of a list of parameters.