Lines Matching refs:compaction
52 Compaction* const compaction;
60 // Files produced by compaction
76 explicit CompactionState(Compaction* c)
77 : compaction(c),
509 s = Status::IOError("Deleting DB during memtable compaction");
586 // Wait until the compaction completes
629 // Wait a little bit before retrying background compaction in
634 Log(options_.info_log, "Waiting after background compaction error: %s",
649 // Previous compaction may have produced too many files in a level,
650 // so reschedule another compaction if needed.
662 Compaction* c;
673 "Manual compaction at level-%d from %s .. %s; will stop at %s\n",
712 // Ignore compaction errors found during shutting down
715 "Compaction error: %s", status.ToString().c_str());
740 // May happen if we get a shutdown call in the middle of compaction
834 compact->compaction->num_input_files(0),
835 compact->compaction->level(),
836 compact->compaction->num_input_files(1),
837 compact->compaction->level() + 1,
840 // Add compaction outputs
841 compact->compaction->AddInputDeletions(compact->compaction->edit());
842 const int level = compact->compaction->level();
845 compact->compaction->edit()->AddFile(
849 return versions_->LogAndApply(compact->compaction->edit(), &mutex_);
857 compact->compaction->num_input_files(0),
858 compact->compaction->level(),
859 compact->compaction->num_input_files(1),
860 compact->compaction->level() + 1);
862 assert(versions_->NumLevelFiles(compact->compaction->level()) > 0);
871 // Release mutex while we're actually doing the compaction work
874 Iterator* input = versions_->MakeInputIterator(compact->compaction);
882 // Prioritize immutable compaction work
895 if (compact->compaction->ShouldStopBefore(key) &&
925 compact->compaction->IsBaseLevelForKey(ikey.user_key)) {
944 compact->compaction->IsBaseLevelForKey(ikey.user_key),
964 compact->compaction->MaxOutputFileSize()) {
976 status = Status::IOError("Deleting DB during compaction");
990 for (int i = 0; i < compact->compaction->num_input_files(which); i++) {
991 stats.bytes_read += compact->compaction->input(which, i)->file_size;
999 stats_[compact->compaction->level() + 1].Add(stats);
1275 // this delay hands over some CPU to the compaction thread in
1295 // Attempt to switch to a new memtable and trigger compaction of old
1314 force = false; // Do not force another compaction if have room
