Lines Matching refs:state

299 void DBImpl::PurgeObsoleteFiles(JobContext& state, bool schedule_only) {  in PurgeObsoleteFiles()  argument
302 assert(state.HaveSomethingToDelete()); in PurgeObsoleteFiles()
305 assert(state.manifest_file_number != 0); in PurgeObsoleteFiles()
310 for (const FileDescriptor& fd : state.sst_live) { in PurgeObsoleteFiles()
314 state.log_recycle_files.begin(), state.log_recycle_files.end()); in PurgeObsoleteFiles()
316 auto candidate_files = state.full_scan_candidate_files; in PurgeObsoleteFiles()
318 candidate_files.size() + state.sst_delete_files.size() + in PurgeObsoleteFiles()
319 state.log_delete_files.size() + state.manifest_delete_files.size()); in PurgeObsoleteFiles()
321 for (auto& file : state.sst_delete_files) { in PurgeObsoleteFiles()
330 for (auto file_num : state.log_delete_files) { in PurgeObsoleteFiles()
336 for (const auto& filename : state.manifest_delete_files) { in PurgeObsoleteFiles()
348 if (state.prev_total_log_size > 0) { in PurgeObsoleteFiles()
353 state.job_id, state.size_log_to_delete, in PurgeObsoleteFiles()
354 state.prev_total_log_size, state.num_alive_log_files); in PurgeObsoleteFiles()
384 for (const auto w : state.logs_to_free) { in PurgeObsoleteFiles()
403 keep = ((number >= state.log_number) || in PurgeObsoleteFiles()
404 (number == state.prev_log_number) || in PurgeObsoleteFiles()
411 keep = (number >= state.manifest_file_number); in PurgeObsoleteFiles()
417 number >= state.min_pending_output; in PurgeObsoleteFiles()
432 (number == state.pending_manifest_file_number) || in PurgeObsoleteFiles()
498 SchedulePendingPurge(fname, dir_to_sync, type, number, state.job_id); in PurgeObsoleteFiles()
500 DeleteObsoleteFileImpl(state.job_id, fname, dir_to_sync, type, number); in PurgeObsoleteFiles()
533 "[JOB %d] Delete info log file %s\n", state.job_id, in PurgeObsoleteFiles()
542 state.job_id, to_delete.c_str(), s.ToString().c_str()); in PurgeObsoleteFiles()
546 state.job_id, to_delete.c_str(), in PurgeObsoleteFiles()