|
@ -902,8 +902,10 @@ Status DBImpl::InstallCompactionResults(CompactionState* compact) { |
|
|
const int level = compact->compaction->level(); |
|
|
const int level = compact->compaction->level(); |
|
|
for (size_t i = 0; i < compact->outputs.size(); i++) { |
|
|
for (size_t i = 0; i < compact->outputs.size(); i++) { |
|
|
const CompactionState::Output& out = compact->outputs[i]; |
|
|
const CompactionState::Output& out = compact->outputs[i]; |
|
|
|
|
|
// compact->compaction->edit()->AddFile(level + 1, out.number, out.file_size,
|
|
|
|
|
|
// out.smallest, out.largest);
|
|
|
compact->compaction->edit()->AddFile(level + 1, out.number, out.file_size, |
|
|
compact->compaction->edit()->AddFile(level + 1, out.number, out.file_size, |
|
|
out.smallest, out.largest); |
|
|
|
|
|
|
|
|
out.smallest, out.largest,out.old_ts,out.new_ts); |
|
|
} |
|
|
} |
|
|
return versions_->LogAndApply(compact->compaction->edit(), &mutex_); |
|
|
return versions_->LogAndApply(compact->compaction->edit(), &mutex_); |
|
|
} |
|
|
} |
|
|