Function skip_list

cpp/fory/serialization/skip.cc:165–227

}

void skip_list(ReadContext &ctx, const FieldType &field_type) {
  // Read list length
  uint64_t length = ctx.read_var_uint64(ctx.error());
  if (FORY_PREDICT_FALSE(ctx.has_error())) {
    return;
  }
  if (length == 0) {
    return;
  }

  // Read elements header
  uint8_t header = ctx.read_uint8(ctx.error());
  if (FORY_PREDICT_FALSE(ctx.has_error())) {
    return;
  }

  bool track_ref = (header & 0b1) != 0;
  bool has_null = (header & 0b10) != 0;
  bool is_declared_type = (header & 0b100) != 0;
  bool is_same_type = (header & 0b1000) != 0;

  const TypeInfo *same_type_info = nullptr;
  if (is_same_type && !is_declared_type) {
    same_type_info = ctx.read_any_type_info(ctx.error());
    if (FORY_PREDICT_FALSE(ctx.has_error())) {
      return;
    }
  }

  // get element type
  FieldType elem_type;
  if (!field_type.generics.empty()) {
    elem_type = field_type.generics[0];
  } else {
    // Unknown element type, need to read type info for each element
    elem_type.set_type_id(static_cast<uint32_t>(TypeId::UNKNOWN));
    elem_type.nullable = false;
  }

  // skip each element
  for (uint64_t i = 0; i < length; ++i) {
    bool has_value = consume_ref_flag(ctx, track_ref, has_null);
    if (FORY_PREDICT_FALSE(ctx.has_error())) {
      return;
    }
    if (!has_value) {
      continue;
    }

    if (!is_same_type) {
      const TypeInfo *elem_type_info = ctx.read_any_type_info(ctx.error());
      if (FORY_PREDICT_FALSE(ctx.has_error())) {
        return;
      }
      skip_data_with_type_info(ctx, elem_type_info);
    } else {
      skip_schema_or_type_info(ctx, elem_type, same_type_info);
    }