Searched refs:JobContext (Results 1 – 18 of 18) sorted by relevance
| /rocksdb-6.9/db/ |
| D | job_context.h | 103 struct JobContext { struct
181 explicit JobContext(int _job_id, bool create_superversion = false) { argument
213 ~JobContext() { in ~JobContext() argument
|
| D | flush_job.h | 69 SnapshotChecker* snapshot_checker, JobContext* job_context,
122 JobContext* job_context_;
|
| D | flush_job_test.cc | 132 JobContext job_context(0); in TEST_F()
153 JobContext job_context(0); in TEST_F()
254 JobContext job_context(0); in TEST_F()
325 JobContext job_context(0); in TEST_F()
427 JobContext job_context(0); in TEST_F()
|
| D | db_filesnapshot.cc | 42 JobContext job_context(0); in EnableFileDeletions()
|
| D | obsolete_files_test.cc | 132 JobContext jobCxt(0); in TEST_F()
|
| D | flush_job.cc | 94 SnapshotChecker* snapshot_checker, JobContext* job_context, in FlushJob()
|
| D | forward_iterator.cc | 236 JobContext job_context(0); in SVCleanup()
|
| D | db_options_test.cc | 537 JobContext job_context(0); in assert_candidate_files_empty()
|
| D | db_sst_test.cc | 63 JobContext job_context(0); in TEST_F()
|
| D | column_family.cc | 61 JobContext job_context(0); in ~ColumnFamilyHandleImpl()
|
| D | db_wal_test.cc | 545 JobContext job_context(0); in TEST_F()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.h | 78 struct JobContext;
606 void ScheduleBgLogWriterClose(JobContext* job_context);
623 void FindObsoleteFiles(JobContext* job_context, bool force,
632 void PurgeObsoleteFiles(JobContext& background_contet,
829 void GetSnapshotContext(JobContext* job_context,
1367 IOStatus SyncClosedLogs(JobContext* job_context);
1374 bool* madeProgress, JobContext* job_context,
1385 JobContext* job_context, LogBuffer* log_buffer, Env::Priority thread_pri);
1533 JobContext* job_context, LogBuffer* log_buffer,
1578 Status BackgroundCompaction(bool* madeProgress, JobContext* job_context,
[all …]
|
| D | db_impl_files.cc | 48 void DBImpl::FindObsoleteFiles(JobContext* job_context, bool force, in FindObsoleteFiles()
244 bool CompareCandidateFile(const JobContext::CandidateFileInfo& first, in CompareCandidateFile()
245 const JobContext::CandidateFileInfo& second) { in CompareCandidateFile()
299 void DBImpl::PurgeObsoleteFiles(JobContext& state, bool schedule_only) { in PurgeObsoleteFiles()
567 JobContext job_context(next_job_id_.fetch_add(1)); in DeleteObsoleteFiles()
|
| D | db_impl_secondary.cc | 35 JobContext job_context(0); in Recover()
79 JobContext* job_context) { in FindAndRecoverLogFiles()
177 JobContext* job_context) { in RecoverLogFiles()
508 JobContext job_context(0, true /*create_superversion*/); in TryCatchUpWithPrimary()
553 JobContext purge_files_job_context(0); in TryCatchUpWithPrimary()
|
| D | db_impl_secondary.h | 310 JobContext* job_context);
317 JobContext* job_context);
|
| D | db_impl_compaction_flush.cc | 82 IOStatus DBImpl::SyncClosedLogs(JobContext* job_context) { in SyncClosedLogs()
139 bool* made_progress, JobContext* job_context, in FlushMemTableToOutputFile()
248 JobContext* job_context, LogBuffer* log_buffer, Env::Priority thread_pri) { in FlushMemTablesToOutputFiles()
290 JobContext* job_context, LogBuffer* log_buffer, Env::Priority thread_pri) { in AtomicFlushMemTablesToOutputFiles()
875 JobContext job_context(0, true); in CompactFiles()
935 int output_path_id, JobContext* job_context, LogBuffer* log_buffer, in CompactFilesImpl()
2199 Status DBImpl::BackgroundFlush(bool* made_progress, JobContext* job_context, in BackgroundFlush()
2281 JobContext job_context(next_job_id_.fetch_add(1), true); in BackgroundCallFlush()
2362 JobContext job_context(next_job_id_.fetch_add(1), true); in BackgroundCallCompaction()
2476 JobContext* job_context, in BackgroundCompaction()
[all …]
|
| D | db_impl_experimental.cc | 67 JobContext job_context(next_job_id_.fetch_add(1), true); in PromoteL0()
|
| D | db_impl.cc | 353 JobContext job_context(0); in ResumeImpl()
517 JobContext job_context(next_job_id_.fetch_add(1)); in CloseHelper()
888 void DBImpl::ScheduleBgLogWriterClose(JobContext* job_context) { in ScheduleBgLogWriterClose()
1413 JobContext job_context(0); in CleanupIteratorState()
3191 JobContext job_context(next_job_id_.fetch_add(1), true); in DeleteFile()
3265 JobContext job_context(next_job_id_.fetch_add(1), true); in DeleteFilesInRanges()
|