Home
last modified time | relevance | path

Searched refs:FlushJob (Results 1 – 5 of 5) sorted by relevance

/rocksdb-6.9/db/
Dflush_job.cc85 FlushJob::FlushJob(const std::string& dbname, ColumnFamilyData* cfd, in FlushJob() function in ROCKSDB_NAMESPACE::FlushJob
132 FlushJob::~FlushJob() { in ~FlushJob()
136 void FlushJob::ReportStartedFlush() { in ReportStartedFlush()
146 void FlushJob::ReportFlushInputSize(const autovector<MemTable*>& mems) { in ReportFlushInputSize()
156 void FlushJob::RecordFlushIOStats() { in RecordFlushIOStats()
163 void FlushJob::PickMemTable() { in PickMemTable()
193 Status FlushJob::Run(LogsWithPrepTracker* prep_tracker, in Run()
290 void FlushJob::Cancel() { in Cancel()
296 Status FlushJob::WriteLevel0Table() { in WriteLevel0Table()
449 std::unique_ptr<FlushJobInfo> FlushJob::GetFlushJobInfo() const { in GetFlushJobInfo()
Dflush_job.h57 class FlushJob {
61 FlushJob(const std::string& dbname, ColumnFamilyData* cfd,
77 ~FlushJob();
Dflush_job_test.cc136 FlushJob flush_job(dbname_, versions_->GetColumnFamilySet()->GetDefault(), in TEST_F()
219 FlushJob flush_job(dbname_, versions_->GetColumnFamilySet()->GetDefault(), in TEST_F()
286 FlushJob flush_job(dbname_, versions_->GetColumnFamilySet()->GetDefault(), in TEST_F()
354 std::vector<std::unique_ptr<FlushJob>> flush_jobs; in TEST_F()
358 flush_jobs.emplace_back(new FlushJob( in TEST_F()
474 FlushJob flush_job(dbname_, versions_->GetColumnFamilySet()->GetDefault(), in TEST_F()
/rocksdb-6.9/docs/_posts/
D2015-10-27-getthreadlist.markdown87 <td >FlushJob::WriteLevel0Table
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc149 FlushJob flush_job( in FlushMemTableToOutputFile()
313 std::vector<std::unique_ptr<FlushJob>> jobs; in AtomicFlushMemTablesToOutputFiles()
340 jobs.emplace_back(new FlushJob( in AtomicFlushMemTablesToOutputFiles()