Lines Matching refs:job_context
353 JobContext job_context(0); in ResumeImpl() local
354 FindObsoleteFiles(&job_context, true); in ResumeImpl()
360 job_context.manifest_file_number = 1; in ResumeImpl()
361 if (job_context.HaveSomethingToDelete()) { in ResumeImpl()
362 PurgeObsoleteFiles(job_context); in ResumeImpl()
364 job_context.Clean(); in ResumeImpl()
517 JobContext job_context(next_job_id_.fetch_add(1)); in CloseHelper() local
518 FindObsoleteFiles(&job_context, true); in CloseHelper()
522 job_context.manifest_file_number = 1; in CloseHelper()
523 if (job_context.HaveSomethingToDelete()) { in CloseHelper()
524 PurgeObsoleteFiles(job_context); in CloseHelper()
526 job_context.Clean(); in CloseHelper()
888 void DBImpl::ScheduleBgLogWriterClose(JobContext* job_context) { in ScheduleBgLogWriterClose() argument
889 if (!job_context->logs_to_free.empty()) { in ScheduleBgLogWriterClose()
890 for (auto l : job_context->logs_to_free) { in ScheduleBgLogWriterClose()
893 job_context->logs_to_free.clear(); in ScheduleBgLogWriterClose()
1413 JobContext job_context(0); in CleanupIteratorState() local
1417 state->db->FindObsoleteFiles(&job_context, false, true); in CleanupIteratorState()
1419 state->db->ScheduleBgLogWriterClose(&job_context); in CleanupIteratorState()
1428 if (job_context.HaveSomethingToDelete()) { in CleanupIteratorState()
1433 state->db->PurgeObsoleteFiles(job_context, true /* schedule only */); in CleanupIteratorState()
1438 state->db->PurgeObsoleteFiles(job_context); in CleanupIteratorState()
1441 job_context.Clean(); in CleanupIteratorState()
3191 JobContext job_context(next_job_id_.fetch_add(1), true); in DeleteFile() local
3198 job_context.Clean(); in DeleteFile()
3208 job_context.Clean(); in DeleteFile()
3221 job_context.Clean(); in DeleteFile()
3232 job_context.Clean(); in DeleteFile()
3241 &job_context.superversion_contexts[0], in DeleteFile()
3244 FindObsoleteFiles(&job_context, false); in DeleteFile()
3249 if (job_context.HaveSomethingToDelete()) { in DeleteFile()
3251 PurgeObsoleteFiles(job_context); in DeleteFile()
3253 job_context.Clean(); in DeleteFile()
3265 JobContext job_context(next_job_id_.fetch_add(1), true); in DeleteFilesInRanges() local
3318 job_context.Clean(); in DeleteFilesInRanges()
3326 &job_context.superversion_contexts[0], in DeleteFilesInRanges()
3333 FindObsoleteFiles(&job_context, false); in DeleteFilesInRanges()
3338 if (job_context.HaveSomethingToDelete()) { in DeleteFilesInRanges()
3340 PurgeObsoleteFiles(job_context); in DeleteFilesInRanges()
3342 job_context.Clean(); in DeleteFilesInRanges()