Lines Matching refs:level
127 for (int level = 0; level < num_levels_; level++) { in ~Rep() local
128 const auto& added = levels_[level].added_files; in ~Rep()
211 for (int level = 0; level < num_levels_; level++) { in CheckConsistency() local
212 auto& level_files = vstorage->LevelFiles(level); in CheckConsistency()
239 if (level == 0) { in CheckConsistency()
279 fprintf(stderr, "L%d files are not sorted properly", level); in CheckConsistency()
280 return Status::Corruption("L" + NumberToString(level) + in CheckConsistency()
287 fprintf(stderr, "L%d have overlapping ranges %s vs. %s\n", level, in CheckConsistency()
291 "L" + NumberToString(level) + " have overlapping ranges " + in CheckConsistency()
319 int level) { in CheckConsistencyForDeletes() argument
343 for (int l = level + 1; !found && l < num_levels_; l++) { in CheckConsistencyForDeletes()
354 auto& level_added = levels_[level].added_files; in CheckConsistencyForDeletes()
372 for (auto& level : invalid_levels_) { in CheckConsistencyForNumLevels() local
373 if (level.second.size() > 0) { in CheckConsistencyForNumLevels()
440 const auto level = del_file.first; in Apply() local
442 if (level < num_levels_) { in Apply()
443 levels_[level].deleted_files.insert(number); in Apply()
444 CheckConsistencyForDeletes(edit, number, level); in Apply()
446 auto exising = levels_[level].added_files.find(number); in Apply()
447 if (exising != levels_[level].added_files.end()) { in Apply()
449 levels_[level].added_files.erase(exising); in Apply()
452 if (invalid_levels_[level].erase(number) == 0) { in Apply()
461 const int level = new_file.first; in Apply() local
462 if (level < num_levels_) { in Apply()
466 assert(levels_[level].added_files.find(f->fd.GetNumber()) == in Apply()
467 levels_[level].added_files.end()); in Apply()
468 levels_[level].deleted_files.erase(f->fd.GetNumber()); in Apply()
469 levels_[level].added_files[f->fd.GetNumber()] = f; in Apply()
472 auto& lvls = invalid_levels_[level]; in Apply()
591 for (int level = 0; level < num_levels_; level++) { in SaveTo() local
592 const auto& cmp = (level == 0) ? level_zero_cmp_ : level_nonzero_cmp_; in SaveTo()
595 const auto& base_files = base_vstorage_->LevelFiles(level); in SaveTo()
596 const auto& unordered_added_files = levels_[level].added_files; in SaveTo()
597 vstorage->Reserve(level, in SaveTo()
611 if (level > 0 && prev_added_file != nullptr) { in SaveTo()
626 MaybeAddFile(vstorage, level, *added_iter++); in SaveTo()
628 MaybeAddFile(vstorage, level, *base_iter++); in SaveTo()
679 for (int level = 0; level < num_levels_; level++) { in LoadTableHandlers() local
680 for (auto& file_meta_pair : levels_[level].added_files) { in LoadTableHandlers()
684 files_meta.emplace_back(file_meta, level); in LoadTableHandlers()
705 int level = files_meta[file_idx].second; in LoadTableHandlers() local
710 internal_stats->GetFileReadHist(level), false, level, in LoadTableHandlers()
736 void MaybeAddFile(VersionStorageInfo* vstorage, int level, FileMetaData* f) { in MaybeAddFile() argument
737 if (levels_[level].deleted_files.count(f->fd.GetNumber()) > 0) { in MaybeAddFile()
741 vstorage->AddFile(level, f, info_log_); in MaybeAddFile()