| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_files.cc | 102 job_context->pending_manifest_file_number = in FindObsoleteFiles()
104 job_context->log_number = MinLogNumberToKeep(); in FindObsoleteFiles()
107 versions_->AddLiveFiles(&job_context->sst_live); in FindObsoleteFiles()
198 if (job_context->size_log_to_delete == 0) { in FindObsoleteFiles()
233 assert(job_context->logs_to_free.empty()); in FindObsoleteFiles()
234 job_context->logs_to_free = logs_to_free_; in FindObsoleteFiles()
237 if (job_context->HaveSomethingToDelete()) { in FindObsoleteFiles()
568 FindObsoleteFiles(&job_context, true); in DeleteObsoleteFiles()
571 if (job_context.HaveSomethingToDelete()) { in DeleteObsoleteFiles()
572 PurgeObsoleteFiles(job_context); in DeleteObsoleteFiles()
[all …]
|
| D | db_impl_compaction_flush.cc | 179 io_s = SyncClosedLogs(job_context); in FlushMemTableToOutputFile()
369 io_s = SyncClosedLogs(job_context); in AtomicFlushMemTablesToOutputFiles()
875 JobContext job_context(0, true); in CompactFiles()
921 PurgeObsoleteFiles(job_context); in CompactFiles()
923 job_context.Clean(); in CompactFiles()
1085 job_context->job_id); in CompactFilesImpl()
2338 PurgeObsoleteFiles(job_context); in BackgroundCallFlush()
2340 job_context.Clean(); in BackgroundCallFlush()
2436 PurgeObsoleteFiles(job_context); in BackgroundCallCompaction()
2439 job_context.Clean(); in BackgroundCallCompaction()
[all …]
|
| D | db_impl_experimental.cc | 67 JobContext job_context(next_job_id_.fetch_add(1), true); in PromoteL0() local
77 job_context.Clean(); in PromoteL0()
97 job_context.Clean(); in PromoteL0()
108 job_context.Clean(); in PromoteL0()
118 job_context.Clean(); in PromoteL0()
140 &job_context.superversion_contexts[0], in PromoteL0()
145 job_context.Clean(); in PromoteL0()
|
| D | db_impl_secondary.cc | 35 JobContext job_context(0); in Recover() local
61 s = FindAndRecoverLogFiles(&cfds_changed, &job_context); in Recover()
72 job_context.Clean(); in Recover()
79 JobContext* job_context) { in FindAndRecoverLogFiles() argument
81 assert(nullptr != job_context); in FindAndRecoverLogFiles()
177 JobContext* job_context) { in RecoverLogFiles() argument
179 assert(nullptr != job_context); in RecoverLogFiles()
508 JobContext job_context(0, true /*create_superversion*/); in TryCatchUpWithPrimary() local
531 s = FindAndRecoverLogFiles(&cfds_changed, &job_context); in TryCatchUpWithPrimary()
544 auto& sv_context = job_context.superversion_contexts.back(); in TryCatchUpWithPrimary()
[all …]
|
| D | db_impl.cc | 353 JobContext job_context(0); in ResumeImpl() local
364 job_context.Clean(); in ResumeImpl()
526 job_context.Clean(); in CloseHelper()
1441 job_context.Clean(); in CleanupIteratorState()
3198 job_context.Clean(); in DeleteFile()
3208 job_context.Clean(); in DeleteFile()
3221 job_context.Clean(); in DeleteFile()
3232 job_context.Clean(); in DeleteFile()
3253 job_context.Clean(); in DeleteFile()
3318 job_context.Clean(); in DeleteFilesInRanges()
[all …]
|
| D | db_impl.h | 606 void ScheduleBgLogWriterClose(JobContext* job_context);
623 void FindObsoleteFiles(JobContext* job_context, bool force,
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);
1389 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,
1582 Status BackgroundFlush(bool* madeProgress, JobContext* job_context,
|
| D | db_impl_secondary.h | 310 JobContext* job_context);
317 JobContext* job_context);
|
| D | db_impl_write.cc.d | 59 db/job_context.h db/log_writer.h logging/event_logger.h \
|
| D | db_impl_experimental.cc.d | 59 db/job_context.h db/log_writer.h logging/event_logger.h \
|
| /rocksdb-6.9/db/ |
| D | flush_job_test.cc | 132 JobContext job_context(0); in TEST_F() local
149 job_context.Clean(); in TEST_F()
153 JobContext job_context(0); in TEST_F() local
247 job_context.Clean(); in TEST_F()
254 JobContext job_context(0); in TEST_F() local
314 job_context.Clean(); in TEST_F()
325 JobContext job_context(0); in TEST_F() local
362 &job_context, nullptr, nullptr, nullptr, kNoCompression, in TEST_F()
423 job_context.Clean(); in TEST_F()
427 JobContext job_context(0); in TEST_F() local
[all …]
|
| D | db_filesnapshot.cc | 42 JobContext job_context(0); in EnableFileDeletions() local
54 FindObsoleteFiles(&job_context, true); in EnableFileDeletions()
60 if (job_context.HaveSomethingToDelete()) { in EnableFileDeletions()
61 PurgeObsoleteFiles(job_context); in EnableFileDeletions()
68 job_context.Clean(); in EnableFileDeletions()
|
| D | forward_iterator.cc | 236 JobContext job_context(0); in SVCleanup() local
239 db->FindObsoleteFiles(&job_context, false, true); in SVCleanup()
241 db->ScheduleBgLogWriterClose(&job_context); in SVCleanup()
249 if (job_context.HaveSomethingToDelete()) { in SVCleanup()
250 db->PurgeObsoleteFiles(job_context, background_purge_on_iterator_cleanup); in SVCleanup()
252 job_context.Clean(); in SVCleanup()
|
| D | db_options_test.cc | 537 JobContext job_context(0); in assert_candidate_files_empty() local
538 dbfull->FindObsoleteFiles(&job_context, false); in assert_candidate_files_empty()
539 ASSERT_EQ(empty, job_context.full_scan_candidate_files.empty()); in assert_candidate_files_empty()
541 if (job_context.HaveSomethingToDelete()) { in assert_candidate_files_empty()
544 dbfull->PurgeObsoleteFiles(job_context); in assert_candidate_files_empty()
546 job_context.Clean(); in assert_candidate_files_empty()
|
| D | column_family.cc | 61 JobContext job_context(0); in ~ColumnFamilyHandleImpl() local
66 db_->FindObsoleteFiles(&job_context, false, true); in ~ColumnFamilyHandleImpl()
70 if (job_context.HaveSomethingToDelete()) { in ~ColumnFamilyHandleImpl()
73 db_->PurgeObsoleteFiles(job_context, defer_purge); in ~ColumnFamilyHandleImpl()
80 job_context.Clean(); in ~ColumnFamilyHandleImpl()
|
| D | flush_job.cc | 94 SnapshotChecker* snapshot_checker, JobContext* job_context, in FlushJob() argument
113 job_context_(job_context), in FlushJob()
|
| D | db_sst_test.cc | 63 JobContext job_context(0); in TEST_F() local
65 dbfull()->FindObsoleteFiles(&job_context, true /*force*/); in TEST_F()
67 dbfull()->PurgeObsoleteFiles(job_context); in TEST_F()
68 job_context.Clean(); in TEST_F()
|
| D | flush_job.h | 69 SnapshotChecker* snapshot_checker, JobContext* job_context,
|
| D | compact_files_test.cc.d | 59 db/job_context.h db/log_writer.h logging/event_logger.h \
|
| D | compacted_db_impl.cc.d | 59 db/job_context.h db/log_writer.h logging/event_logger.h \
|
| D | db_filesnapshot.cc.d | 59 db/job_context.h db/log_writer.h logging/event_logger.h \
|
| D | experimental.cc.d | 59 db/job_context.h db/log_writer.h logging/event_logger.h \
|
| D | write_callback_test.cc.d | 59 db/job_context.h db/log_writer.h logging/event_logger.h \
|
| D | convenience.cc.d | 59 db/job_context.h db/log_writer.h logging/event_logger.h \
|
| D | external_sst_file_ingestion_job.cc.d | 62 include/rocksdb/compaction_filter.h db/job_context.h db/log_writer.h \
|
| /rocksdb-6.9/trace_replay/ |
| D | block_cache_tracer.cc.d | 58 db/job_context.h db/log_writer.h logging/event_logger.h \
|