Function write_configured_map_data

cpp/fory/serialization/struct_serializer.h:999–1044

template <typename MapType, typename StructT, size_t Index, int8_t KeyNode,
          int8_t ValueNode>
void write_configured_map_data(const MapType &map, WriteContext &ctx) {
  using Key = key_type_t<MapType>;
  using Value = mapped_type_t<MapType>;
  ctx.write_var_uint32(static_cast<uint32_t>(map.size()));
  if (map.empty()) {
    return;
  }
  size_t header_offset = 0;
  uint8_t pair_counter = 0;
  bool need_write_header = true;
  for (const auto &[key, value] : map) {
    if (need_write_header) {
      ctx.enter_flush_barrier();
      header_offset = ctx.buffer().writer_index();
      ctx.write_uint16(0);
      ctx.buffer().unsafe_put_byte(
          header_offset, static_cast<uint8_t>(DECL_KEY_TYPE | DECL_VALUE_TYPE));
      need_write_header = false;
    }
    if constexpr (KeyNode >= 0) {
      write_configured_value<Key, StructT, Index, KeyNode>(
          key, ctx, RefMode::None, false, true);
    } else {
      Serializer<Key>::write_data(key, ctx);
    }
    if constexpr (ValueNode >= 0) {
      write_configured_value<Value, StructT, Index, ValueNode>(
          value, ctx, RefMode::None, false, true);
    } else {
      Serializer<Value>::write_data(value, ctx);
    }
    ++pair_counter;
    if (pair_counter == MAX_CHUNK_SIZE) {
      write_chunk_size(ctx, header_offset, pair_counter);
      ctx.exit_flush_barrier();
      ctx.try_flush();
      pair_counter = 0;
      need_write_header = true;
    }
  }
  if (pair_counter > 0) {
    write_chunk_size(ctx, header_offset, pair_counter);
    ctx.exit_flush_barrier();
    ctx.try_flush();
  }
}

template <typename MapType, typename StructT, size_t Index, int8_t KeyNode,
          int8_t ValueNode>