Lines Matching refs:number

139         uint64_t number;  in FindObsoleteFiles()  local
148 if (!ParseFileName(file, &number, info_log_prefix.prefix, &type) || in FindObsoleteFiles()
149 !ShouldPurge(number)) { in FindObsoleteFiles()
187 while (alive_log_files_.begin()->number < min_log_number) { in FindObsoleteFiles()
193 earliest.number); in FindObsoleteFiles()
194 log_recycle_files_.push_back(earliest.number); in FindObsoleteFiles()
196 job_context->log_delete_files.push_back(earliest.number); in FindObsoleteFiles()
215 while (!logs_.empty() && logs_.front().number < min_log_number) { in FindObsoleteFiles()
259 FileType type, uint64_t number) { in DeleteObsoleteFileImpl() argument
273 fname.c_str(), type, number, in DeleteObsoleteFileImpl()
280 job_id, fname.c_str(), type, number, in DeleteObsoleteFileImpl()
285 job_id, fname.c_str(), type, number, in DeleteObsoleteFileImpl()
290 &event_logger_, job_id, number, fname, file_deletion_status, GetName(), in DeleteObsoleteFileImpl()
369 uint64_t number; in PurgeObsoleteFiles() local
371 if (!ParseFileName(fname, &number, info_log_prefix.prefix, &type) || in PurgeObsoleteFiles()
375 if (number > optsfile_num1) { in PurgeObsoleteFiles()
377 optsfile_num1 = number; in PurgeObsoleteFiles()
378 } else if (number > optsfile_num2) { in PurgeObsoleteFiles()
379 optsfile_num2 = number; in PurgeObsoleteFiles()
393 uint64_t number; in PurgeObsoleteFiles() local
396 if (!ParseFileName(to_delete, &number, info_log_prefix.prefix, &type)) { in PurgeObsoleteFiles()
403 keep = ((number >= state.log_number) || in PurgeObsoleteFiles()
404 (number == state.prev_log_number) || in PurgeObsoleteFiles()
405 (log_recycle_files_set.find(number) != in PurgeObsoleteFiles()
411 keep = (number >= state.manifest_file_number); in PurgeObsoleteFiles()
416 keep = (sst_live_map.find(number) != sst_live_map.end()) || in PurgeObsoleteFiles()
417 number >= state.min_pending_output; in PurgeObsoleteFiles()
419 files_to_del.insert(number); in PurgeObsoleteFiles()
431 keep = (sst_live_map.find(number) != sst_live_map.end()) || in PurgeObsoleteFiles()
432 (number == state.pending_manifest_file_number) || in PurgeObsoleteFiles()
437 if (number != 0) { in PurgeObsoleteFiles()
442 keep = (number >= optsfile_num2); in PurgeObsoleteFiles()
445 reinterpret_cast<void*>(&number)); in PurgeObsoleteFiles()
467 TableCache::Evict(table_cache_.get(), number); in PurgeObsoleteFiles()
468 fname = MakeTableFileName(candidate_file.file_path, number); in PurgeObsoleteFiles()
484 wal_manager_.ArchiveWALFile(fname, 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()
691 uint64_t number = 0; in CleanupFilesAfterRecovery() local
693 if (!ParseFileName(fname, &number, &type)) { in CleanupFilesAfterRecovery()
697 largest_file_number = std::max(largest_file_number, number); in CleanupFilesAfterRecovery()
698 if (type == kTableFile && number >= next_file_number && in CleanupFilesAfterRecovery()