Lines Matching refs:job_context
48 void DBImpl::FindObsoleteFiles(JobContext* job_context, bool force, in FindObsoleteFiles() argument
81 job_context->min_pending_output = *pending_outputs_.begin(); in FindObsoleteFiles()
84 job_context->min_pending_output = std::numeric_limits<uint64_t>::max(); in FindObsoleteFiles()
89 versions_->GetObsoleteFiles(&job_context->sst_delete_files, in FindObsoleteFiles()
90 &job_context->manifest_delete_files, in FindObsoleteFiles()
91 job_context->min_pending_output); in FindObsoleteFiles()
96 for (const auto& sst_to_del : job_context->sst_delete_files) { in FindObsoleteFiles()
101 job_context->manifest_file_number = versions_->manifest_file_number(); in FindObsoleteFiles()
102 job_context->pending_manifest_file_number = in FindObsoleteFiles()
104 job_context->log_number = MinLogNumberToKeep(); in FindObsoleteFiles()
105 job_context->prev_log_number = versions_->prev_log_number(); in FindObsoleteFiles()
107 versions_->AddLiveFiles(&job_context->sst_live); in FindObsoleteFiles()
154 job_context->full_scan_candidate_files.emplace_back("/" + file, path); in FindObsoleteFiles()
164 job_context->full_scan_candidate_files.emplace_back( in FindObsoleteFiles()
175 job_context->full_scan_candidate_files.emplace_back( in FindObsoleteFiles()
184 uint64_t min_log_number = job_context->log_number; in FindObsoleteFiles()
196 job_context->log_delete_files.push_back(earliest.number); in FindObsoleteFiles()
198 if (job_context->size_log_to_delete == 0) { in FindObsoleteFiles()
199 job_context->prev_total_log_size = total_log_size_; in FindObsoleteFiles()
200 job_context->num_alive_log_files = num_alive_log_files; in FindObsoleteFiles()
202 job_context->size_log_to_delete += earliest.size; in FindObsoleteFiles()
233 assert(job_context->logs_to_free.empty()); in FindObsoleteFiles()
234 job_context->logs_to_free = logs_to_free_; in FindObsoleteFiles()
235 job_context->log_recycle_files.assign(log_recycle_files_.begin(), in FindObsoleteFiles()
237 if (job_context->HaveSomethingToDelete()) { in FindObsoleteFiles()
567 JobContext job_context(next_job_id_.fetch_add(1)); in DeleteObsoleteFiles() local
568 FindObsoleteFiles(&job_context, true); in DeleteObsoleteFiles()
571 if (job_context.HaveSomethingToDelete()) { in DeleteObsoleteFiles()
572 PurgeObsoleteFiles(job_context); in DeleteObsoleteFiles()
574 job_context.Clean(); in DeleteObsoleteFiles()