Method InitFirstLevelIter

table/two_level_iterator.cc:242–280

  };

  bool InitFirstLevelIter() {
    min_heap_.clear();
    if (!first_level_iter_->Valid()) {
      return false;
    }
    // Manual inline MapSstElement::Decode
    const char* err_msg = "Invalid MapSstElement";
    first_level_value_ = first_level_iter_->value();
    status_ = first_level_value_.fetch();
    if (!status_.ok()) {
      return false;
    }
    Slice map_input = first_level_value_.slice();
    link_.clear();
    largest_key_ = first_level_iter_->key();
    uint64_t flags;
    uint64_t link_count;
    if (!GetVarint64(&map_input, &flags) ||
        !GetVarint64(&map_input, &link_count) ||
        !GetLengthPrefixedSlice(&map_input, &smallest_key_)) {
      status_ = Status::Corruption(err_msg);
      return false;
    }
    include_smallest_ = (flags & MapSstElement::kIncludeSmallest) != 0;
    include_largest_ = (flags & MapSstElement::kIncludeLargest) != 0;
    link_.resize(link_count);
    for (uint64_t i = 0; i < link_count; ++i) {
      if (!GetVarint64(&map_input, &link_[i])) {
        status_ = Status::Corruption(err_msg);
        return false;
      }
      assert(file_meta_ == nullptr ||
             std::binary_search(file_meta_->prop.dependence.begin(),
                                file_meta_->prop.dependence.end(),
                                Dependence{link_[i], 0},
                                TERARK_CMP(file_number, <)));
    }
    return true;
  }

  void InitSecondLevelMinHeap(const Slice& target, bool include) {
    InitSecondLevelMinHeapImpl(target, include);