25 #include "field_codec_default_message.h"
29 std::unordered_map<std::string, unsigned> dccl::v4::DefaultMessageCodec::MaxSize::oneofs_max_size;
35 void dccl::v4::DefaultMessageCodec::any_encode(Bitset* bits,
const dccl::any& wire_value)
37 if (is_empty(wire_value))
39 *bits = Bitset(min_size());
43 *bits = traverse_const_message<Encoder, Bitset>(wire_value);
46 bits->push_front(
true);
50 unsigned dccl::v4::DefaultMessageCodec::any_size(
const dccl::any& wire_value)
52 if (is_empty(wire_value))
58 unsigned size = traverse_const_message<Size, unsigned>(wire_value);
61 const unsigned presence_bit = 1;
69 void dccl::v4::DefaultMessageCodec::any_decode(Bitset* bits, dccl::any* wire_value)
73 auto* msg = dccl::any_cast<google::protobuf::Message*>(*wire_value);
77 if (!bits->to_ulong())
79 *wire_value = dccl::any();
88 const google::protobuf::Descriptor* desc = msg->GetDescriptor();
89 const google::protobuf::Reflection* refl = msg->GetReflection();
92 std::vector<int> oneof_cases(desc->oneof_decl_count());
93 for (
auto i = 0, n = desc->oneof_decl_count(); part() != HEAD && i < n; ++i)
95 Bitset case_bits(bits);
96 case_bits.get_more_bits(
oneof_size(desc->oneof_decl(i)));
99 oneof_cases[i] =
static_cast<int>(case_bits.to_ulong()) - 1;
103 for (
int i = 0, n = desc->field_count(); i < n; ++i)
105 const google::protobuf::FieldDescriptor* field_desc = desc->field(i);
107 if (!check_field(field_desc))
110 std::shared_ptr<FieldCodecBase> codec = find(field_desc);
111 std::shared_ptr<internal::FromProtoCppTypeBase> helper =
112 manager().type_helper().find(field_desc);
114 if (field_desc->is_repeated())
116 std::vector<dccl::any> field_values;
117 if (field_desc->cpp_type() == google::protobuf::FieldDescriptor::CPPTYPE_MESSAGE)
119 unsigned max_repeat =
120 field_desc->options().GetExtension(dccl::field).max_repeat();
121 for (
unsigned j = 0, m = max_repeat; j < m; ++j)
122 field_values.emplace_back(refl->AddMessage(msg, field_desc));
124 codec->field_decode_repeated(bits, &field_values, field_desc);
127 for (
int j = field_values.size(), m = max_repeat; j < m; ++j)
129 refl->RemoveLast(msg, field_desc);
135 codec->field_decode_repeated(bits, &field_values, field_desc);
136 for (
auto& field_value : field_values)
137 helper->add_value(field_desc, msg, field_value);
146 if (field_desc->index_in_oneof() !=
152 DynamicConditions& dc = dynamic_conditions(field_desc);
153 if (dc.has_omit_if())
156 dc.regenerate(this_message(), root_message());
161 dccl::any field_value;
162 if (field_desc->cpp_type() == google::protobuf::FieldDescriptor::CPPTYPE_MESSAGE)
165 field_value = refl->MutableMessage(msg, field_desc);
166 codec->field_decode(bits, &field_value, field_desc);
167 if (is_empty(field_value))
168 refl->ClearField(msg, field_desc);
173 codec->field_decode(bits, &field_value, field_desc);
174 helper->set_value(field_desc, msg, field_value);
179 std::vector<const google::protobuf::FieldDescriptor*> set_fields;
180 refl->ListFields(*msg, &set_fields);
183 catch (dccl::bad_any_cast& e)
186 "Bad type given to traverse mutable, expecting google::protobuf::Message*, got " +
187 std::string(wire_value->type().name())));
191 unsigned dccl::v4::DefaultMessageCodec::max_size()
194 traverse_descriptor<MaxSize>(&u);
198 const unsigned presence_bit = 1;
205 unsigned dccl::v4::DefaultMessageCodec::min_size()
209 const unsigned presence_bit = 1;
215 traverse_descriptor<MinSize>(&u);
220 void dccl::v4::DefaultMessageCodec::validate()
223 traverse_descriptor<Validate>(&b);
226 std::string dccl::v4::DefaultMessageCodec::info()
228 std::stringstream ss;
229 traverse_descriptor<Info>(&ss);
233 std::size_t dccl::v4::DefaultMessageCodec::hash()
235 std::size_t hash = 0;
236 traverse_descriptor<Hash>(&hash);
240 bool dccl::v4::DefaultMessageCodec::check_field(
const google::protobuf::FieldDescriptor* field)
249 if (dccl_field_options.omit())
253 else if (message_data().current_part() == UNKNOWN)
255 if ((part() == HEAD && !dccl_field_options.in_head()) ||
256 (part() == BODY && dccl_field_options.in_head()))
261 else if (message_data().current_part() != part())