Lines Matching refs:edit

665   void Apply(VersionEdit* edit) {  in Apply()  argument
667 for (size_t i = 0; i < edit->compact_pointers_.size(); i++) { in Apply()
668 const int level = edit->compact_pointers_[i].first; in Apply()
670 edit->compact_pointers_[i].second.Encode().ToString(); in Apply()
674 const VersionEdit::DeletedFileSet& del = edit->deleted_files_; in Apply()
684 for (size_t i = 0; i < edit->new_files_.size(); i++) { in Apply()
685 const int level = edit->new_files_[i].first; in Apply()
686 FileMetaData* f = new FileMetaData(edit->new_files_[i].second); in Apply()
820 Status VersionSet::LogAndApply(VersionEdit* edit, port::Mutex* mu) { in LogAndApply() argument
821 if (edit->has_log_number_) { in LogAndApply()
822 assert(edit->log_number_ >= log_number_); in LogAndApply()
823 assert(edit->log_number_ < next_file_number_); in LogAndApply()
825 edit->SetLogNumber(log_number_); in LogAndApply()
828 if (!edit->has_prev_log_number_) { in LogAndApply()
829 edit->SetPrevLogNumber(prev_log_number_); in LogAndApply()
832 edit->SetNextFile(next_file_number_); in LogAndApply()
833 edit->SetLastSequence(last_sequence_); in LogAndApply()
838 builder.Apply(edit); in LogAndApply()
852 edit->SetNextFile(next_file_number_); in LogAndApply()
867 edit->EncodeTo(&record); in LogAndApply()
889 log_number_ = edit->log_number_; in LogAndApply()
890 prev_log_number_ = edit->prev_log_number_; in LogAndApply()
948 VersionEdit edit; in Recover() local
949 s = edit.DecodeFrom(record); in Recover()
951 if (edit.has_comparator_ && in Recover()
952 edit.comparator_ != icmp_.user_comparator()->Name()) { in Recover()
954 edit.comparator_ + " does not match existing comparator ", in Recover()
960 builder.Apply(&edit); in Recover()
963 if (edit.has_log_number_) { in Recover()
964 log_number = edit.log_number_; in Recover()
968 if (edit.has_prev_log_number_) { in Recover()
969 prev_log_number = edit.prev_log_number_; in Recover()
973 if (edit.has_next_file_number_) { in Recover()
974 next_file = edit.next_file_number_; in Recover()
978 if (edit.has_last_sequence_) { in Recover()
979 last_sequence = edit.last_sequence_; in Recover()
1106 VersionEdit edit; in WriteSnapshot() local
1107 edit.SetComparatorName(icmp_.user_comparator()->Name()); in WriteSnapshot()
1114 edit.SetCompactPointer(level, key); in WriteSnapshot()
1123 edit.AddFile(level, f->number, f->file_size, f->smallest, f->largest); in WriteSnapshot()
1128 edit.EncodeTo(&record); in WriteSnapshot()
1476 void Compaction::AddInputDeletions(VersionEdit* edit) { in AddInputDeletions() argument
1479 edit->DeleteFile(level_ + which, inputs_[which][i]->number); in AddInputDeletions()