/src/brpc/build/brpc/options.pb.cc
Line | Count | Source |
1 | | // Generated by the protocol buffer compiler. DO NOT EDIT! |
2 | | // source: brpc/options.proto |
3 | | |
4 | | #include "brpc/options.pb.h" |
5 | | |
6 | | #include <algorithm> |
7 | | |
8 | | #include <google/protobuf/io/coded_stream.h> |
9 | | #include <google/protobuf/extension_set.h> |
10 | | #include <google/protobuf/wire_format_lite.h> |
11 | | #include <google/protobuf/descriptor.h> |
12 | | #include <google/protobuf/generated_message_reflection.h> |
13 | | #include <google/protobuf/reflection_ops.h> |
14 | | #include <google/protobuf/wire_format.h> |
15 | | // @@protoc_insertion_point(includes) |
16 | | #include <google/protobuf/port_def.inc> |
17 | | |
18 | | PROTOBUF_PRAGMA_INIT_SEG |
19 | | |
20 | | namespace _pb = ::PROTOBUF_NAMESPACE_ID; |
21 | | namespace _pbi = _pb::internal; |
22 | | |
23 | | namespace brpc { |
24 | | PROTOBUF_CONSTEXPR ChunkInfo::ChunkInfo( |
25 | | ::_pbi::ConstantInitialized): _impl_{ |
26 | | /*decltype(_impl_._has_bits_)*/{} |
27 | | , /*decltype(_impl_._cached_size_)*/{} |
28 | | , /*decltype(_impl_.stream_id_)*/int64_t{0} |
29 | | , /*decltype(_impl_.chunk_id_)*/int64_t{0}} {} |
30 | | struct ChunkInfoDefaultTypeInternal { |
31 | | PROTOBUF_CONSTEXPR ChunkInfoDefaultTypeInternal() |
32 | 0 | : _instance(::_pbi::ConstantInitialized{}) {} |
33 | 0 | ~ChunkInfoDefaultTypeInternal() {} |
34 | | union { |
35 | | ChunkInfo _instance; |
36 | | }; |
37 | | }; |
38 | | PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 ChunkInfoDefaultTypeInternal _ChunkInfo_default_instance_; |
39 | | } // namespace brpc |
40 | | static ::_pb::Metadata file_level_metadata_brpc_2foptions_2eproto[1]; |
41 | | static const ::_pb::EnumDescriptor* file_level_enum_descriptors_brpc_2foptions_2eproto[6]; |
42 | | static constexpr ::_pb::ServiceDescriptor const** file_level_service_descriptors_brpc_2foptions_2eproto = nullptr; |
43 | | |
44 | | const uint32_t TableStruct_brpc_2foptions_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = { |
45 | | PROTOBUF_FIELD_OFFSET(::brpc::ChunkInfo, _impl_._has_bits_), |
46 | | PROTOBUF_FIELD_OFFSET(::brpc::ChunkInfo, _internal_metadata_), |
47 | | ~0u, // no _extensions_ |
48 | | ~0u, // no _oneof_case_ |
49 | | ~0u, // no _weak_field_map_ |
50 | | ~0u, // no _inlined_string_donated_ |
51 | | PROTOBUF_FIELD_OFFSET(::brpc::ChunkInfo, _impl_.stream_id_), |
52 | | PROTOBUF_FIELD_OFFSET(::brpc::ChunkInfo, _impl_.chunk_id_), |
53 | | 0, |
54 | | 1, |
55 | | }; |
56 | | static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = { |
57 | | { 0, 8, -1, sizeof(::brpc::ChunkInfo)}, |
58 | | }; |
59 | | |
60 | | static const ::_pb::Message* const file_default_instances[] = { |
61 | | &::brpc::_ChunkInfo_default_instance_._instance, |
62 | | }; |
63 | | |
64 | | const char descriptor_table_protodef_brpc_2foptions_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = |
65 | | "\n\022brpc/options.proto\022\004brpc\032 google/proto" |
66 | | "buf/descriptor.proto\"0\n\tChunkInfo\022\021\n\tstr" |
67 | | "eam_id\030\001 \002(\003\022\020\n\010chunk_id\030\002 \002(\003*6\n\010TalkTy" |
68 | | "pe\022\024\n\020TALK_TYPE_NORMAL\020\000\022\024\n\020TALK_TYPE_ON" |
69 | | "EWAY\020\001*\200\001\n\016ConnectionType\022\033\n\027CONNECTION_" |
70 | | "TYPE_UNKNOWN\020\000\022\032\n\026CONNECTION_TYPE_SINGLE" |
71 | | "\020\001\022\032\n\026CONNECTION_TYPE_POOLED\020\002\022\031\n\025CONNEC" |
72 | | "TION_TYPE_SHORT\020\004*\247\005\n\014ProtocolType\022\024\n\020PR" |
73 | | "OTOCOL_UNKNOWN\020\000\022\026\n\022PROTOCOL_BAIDU_STD\020\001" |
74 | | "\022\032\n\026PROTOCOL_STREAMING_RPC\020\002\022\027\n\023PROTOCOL" |
75 | | "_HULU_PBRPC\020\003\022\027\n\023PROTOCOL_SOFA_PBRPC\020\004\022\021" |
76 | | "\n\rPROTOCOL_RTMP\020\005\022\023\n\017PROTOCOL_THRIFT\020\006\022\021" |
77 | | "\n\rPROTOCOL_HTTP\020\007\022\031\n\025PROTOCOL_PUBLIC_PBR" |
78 | | "PC\020\010\022\027\n\023PROTOCOL_NOVA_PBRPC\020\t\022\022\n\016PROTOCO" |
79 | | "L_REDIS\020\n\022\032\n\026PROTOCOL_NSHEAD_CLIENT\020\013\022\023\n" |
80 | | "\017PROTOCOL_NSHEAD\020\014\022\027\n\023PROTOCOL_HADOOP_RP" |
81 | | "C\020\r\022\036\n\032PROTOCOL_HADOOP_SERVER_RPC\020\016\022\022\n\016P" |
82 | | "ROTOCOL_MONGO\020\017\022\032\n\026PROTOCOL_UBRPC_COMPAC" |
83 | | "K\020\020\022\030\n\024PROTOCOL_DIDX_CLIENT\020\021\022\025\n\021PROTOCO" |
84 | | "L_MEMCACHE\020\022\022\020\n\014PROTOCOL_ITP\020\023\022\032\n\026PROTOC" |
85 | | "OL_NSHEAD_MCPACK\020\024\022\025\n\021PROTOCOL_DISP_IDL\020" |
86 | | "\025\022\031\n\025PROTOCOL_ERSDA_CLIENT\020\026\022\032\n\026PROTOCOL" |
87 | | "_UBRPC_MCPACK2\020\027\022\026\n\022PROTOCOL_CDS_AGENT\020\030" |
88 | | "\022\020\n\014PROTOCOL_ESP\020\031\022\017\n\013PROTOCOL_H2\020\032\022\026\n\022P" |
89 | | "ROTOCOL_COUCHBASE\020\033*\207\001\n\014CompressType\022\026\n\022" |
90 | | "COMPRESS_TYPE_NONE\020\000\022\030\n\024COMPRESS_TYPE_SN" |
91 | | "APPY\020\001\022\026\n\022COMPRESS_TYPE_GZIP\020\002\022\026\n\022COMPRE" |
92 | | "SS_TYPE_ZLIB\020\003\022\025\n\021COMPRESS_TYPE_LZ4\020\004*@\n" |
93 | | "\014ChecksumType\022\026\n\022CHECKSUM_TYPE_NONE\020\000\022\030\n" |
94 | | "\024CHECKSUM_TYPE_CRC32C\020\001*s\n\013ContentType\022\023" |
95 | | "\n\017CONTENT_TYPE_PB\020\000\022\025\n\021CONTENT_TYPE_JSON" |
96 | | "\020\001\022\033\n\027CONTENT_TYPE_PROTO_JSON\020\002\022\033\n\027CONTE" |
97 | | "NT_TYPE_PROTO_TEXT\020\003:A\n\017service_timeout\022" |
98 | | "\037.google.protobuf.ServiceOptions\030\220\277\005 \001(\003" |
99 | | ":\00510000:]\n\021request_talk_type\022\036.google.pr" |
100 | | "otobuf.MethodOptions\030\221\277\005 \001(\0162\016.brpc.Talk" |
101 | | "Type:\020TALK_TYPE_NORMAL:^\n\022response_talk_" |
102 | | "type\022\036.google.protobuf.MethodOptions\030\222\277\005" |
103 | | " \001(\0162\016.brpc.TalkType:\020TALK_TYPE_NORMAL:8" |
104 | | "\n\016method_timeout\022\036.google.protobuf.Metho" |
105 | | "dOptions\030\223\277\005 \001(\003:e\n\023request_compression\022" |
106 | | "\036.google.protobuf.MethodOptions\030\224\277\005 \001(\0162" |
107 | | "\022.brpc.CompressType:\022COMPRESS_TYPE_NONE:" |
108 | | "f\n\024response_compression\022\036.google.protobu" |
109 | | "f.MethodOptions\030\225\277\005 \001(\0162\022.brpc.CompressT" |
110 | | "ype:\022COMPRESS_TYPE_NONEB\023\n\010com.brpcB\007Opt" |
111 | | "ions" |
112 | | ; |
113 | | static const ::_pbi::DescriptorTable* const descriptor_table_brpc_2foptions_2eproto_deps[1] = { |
114 | | &::descriptor_table_google_2fprotobuf_2fdescriptor_2eproto, |
115 | | }; |
116 | | static ::_pbi::once_flag descriptor_table_brpc_2foptions_2eproto_once; |
117 | | const ::_pbi::DescriptorTable descriptor_table_brpc_2foptions_2eproto = { |
118 | | false, false, 1844, descriptor_table_protodef_brpc_2foptions_2eproto, |
119 | | "brpc/options.proto", |
120 | | &descriptor_table_brpc_2foptions_2eproto_once, descriptor_table_brpc_2foptions_2eproto_deps, 1, 1, |
121 | | schemas, file_default_instances, TableStruct_brpc_2foptions_2eproto::offsets, |
122 | | file_level_metadata_brpc_2foptions_2eproto, file_level_enum_descriptors_brpc_2foptions_2eproto, |
123 | | file_level_service_descriptors_brpc_2foptions_2eproto, |
124 | | }; |
125 | 0 | PROTOBUF_ATTRIBUTE_WEAK const ::_pbi::DescriptorTable* descriptor_table_brpc_2foptions_2eproto_getter() { |
126 | 0 | return &descriptor_table_brpc_2foptions_2eproto; |
127 | 0 | } |
128 | | |
129 | | // Force running AddDescriptors() at dynamic initialization time. |
130 | | PROTOBUF_ATTRIBUTE_INIT_PRIORITY2 static ::_pbi::AddDescriptorsRunner dynamic_init_dummy_brpc_2foptions_2eproto(&descriptor_table_brpc_2foptions_2eproto); |
131 | | namespace brpc { |
132 | 0 | const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* TalkType_descriptor() { |
133 | 0 | ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_brpc_2foptions_2eproto); |
134 | 0 | return file_level_enum_descriptors_brpc_2foptions_2eproto[0]; |
135 | 0 | } |
136 | 0 | bool TalkType_IsValid(int value) { |
137 | 0 | switch (value) { |
138 | 0 | case 0: |
139 | 0 | case 1: |
140 | 0 | return true; |
141 | 0 | default: |
142 | 0 | return false; |
143 | 0 | } |
144 | 0 | } |
145 | | |
146 | 0 | const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* ConnectionType_descriptor() { |
147 | 0 | ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_brpc_2foptions_2eproto); |
148 | 0 | return file_level_enum_descriptors_brpc_2foptions_2eproto[1]; |
149 | 0 | } |
150 | 0 | bool ConnectionType_IsValid(int value) { |
151 | 0 | switch (value) { |
152 | 0 | case 0: |
153 | 0 | case 1: |
154 | 0 | case 2: |
155 | 0 | case 4: |
156 | 0 | return true; |
157 | 0 | default: |
158 | 0 | return false; |
159 | 0 | } |
160 | 0 | } |
161 | | |
162 | 0 | const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* ProtocolType_descriptor() { |
163 | 0 | ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_brpc_2foptions_2eproto); |
164 | 0 | return file_level_enum_descriptors_brpc_2foptions_2eproto[2]; |
165 | 0 | } |
166 | 0 | bool ProtocolType_IsValid(int value) { |
167 | 0 | switch (value) { |
168 | 0 | case 0: |
169 | 0 | case 1: |
170 | 0 | case 2: |
171 | 0 | case 3: |
172 | 0 | case 4: |
173 | 0 | case 5: |
174 | 0 | case 6: |
175 | 0 | case 7: |
176 | 0 | case 8: |
177 | 0 | case 9: |
178 | 0 | case 10: |
179 | 0 | case 11: |
180 | 0 | case 12: |
181 | 0 | case 13: |
182 | 0 | case 14: |
183 | 0 | case 15: |
184 | 0 | case 16: |
185 | 0 | case 17: |
186 | 0 | case 18: |
187 | 0 | case 19: |
188 | 0 | case 20: |
189 | 0 | case 21: |
190 | 0 | case 22: |
191 | 0 | case 23: |
192 | 0 | case 24: |
193 | 0 | case 25: |
194 | 0 | case 26: |
195 | 0 | case 27: |
196 | 0 | return true; |
197 | 0 | default: |
198 | 0 | return false; |
199 | 0 | } |
200 | 0 | } |
201 | | |
202 | 0 | const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* CompressType_descriptor() { |
203 | 0 | ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_brpc_2foptions_2eproto); |
204 | 0 | return file_level_enum_descriptors_brpc_2foptions_2eproto[3]; |
205 | 0 | } |
206 | 0 | bool CompressType_IsValid(int value) { |
207 | 0 | switch (value) { |
208 | 0 | case 0: |
209 | 0 | case 1: |
210 | 0 | case 2: |
211 | 0 | case 3: |
212 | 0 | case 4: |
213 | 0 | return true; |
214 | 0 | default: |
215 | 0 | return false; |
216 | 0 | } |
217 | 0 | } |
218 | | |
219 | 0 | const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* ChecksumType_descriptor() { |
220 | 0 | ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_brpc_2foptions_2eproto); |
221 | 0 | return file_level_enum_descriptors_brpc_2foptions_2eproto[4]; |
222 | 0 | } |
223 | 0 | bool ChecksumType_IsValid(int value) { |
224 | 0 | switch (value) { |
225 | 0 | case 0: |
226 | 0 | case 1: |
227 | 0 | return true; |
228 | 0 | default: |
229 | 0 | return false; |
230 | 0 | } |
231 | 0 | } |
232 | | |
233 | 0 | const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* ContentType_descriptor() { |
234 | 0 | ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_brpc_2foptions_2eproto); |
235 | 0 | return file_level_enum_descriptors_brpc_2foptions_2eproto[5]; |
236 | 0 | } |
237 | 0 | bool ContentType_IsValid(int value) { |
238 | 0 | switch (value) { |
239 | 0 | case 0: |
240 | 0 | case 1: |
241 | 0 | case 2: |
242 | 0 | case 3: |
243 | 0 | return true; |
244 | 0 | default: |
245 | 0 | return false; |
246 | 0 | } |
247 | 0 | } |
248 | | |
249 | | |
250 | | // =================================================================== |
251 | | |
252 | | class ChunkInfo::_Internal { |
253 | | public: |
254 | | using HasBits = decltype(std::declval<ChunkInfo>()._impl_._has_bits_); |
255 | 0 | static void set_has_stream_id(HasBits* has_bits) { |
256 | 0 | (*has_bits)[0] |= 1u; |
257 | 0 | } |
258 | 0 | static void set_has_chunk_id(HasBits* has_bits) { |
259 | 0 | (*has_bits)[0] |= 2u; |
260 | 0 | } |
261 | 0 | static bool MissingRequiredFields(const HasBits& has_bits) { |
262 | 0 | return ((has_bits[0] & 0x00000003) ^ 0x00000003) != 0; |
263 | 0 | } |
264 | | }; |
265 | | |
266 | | ChunkInfo::ChunkInfo(::PROTOBUF_NAMESPACE_ID::Arena* arena, |
267 | | bool is_message_owned) |
268 | 0 | : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) { |
269 | 0 | SharedCtor(arena, is_message_owned); |
270 | | // @@protoc_insertion_point(arena_constructor:brpc.ChunkInfo) |
271 | 0 | } |
272 | | ChunkInfo::ChunkInfo(const ChunkInfo& from) |
273 | 0 | : ::PROTOBUF_NAMESPACE_ID::Message() { |
274 | 0 | ChunkInfo* const _this = this; (void)_this; |
275 | 0 | new (&_impl_) Impl_{ |
276 | 0 | decltype(_impl_._has_bits_){from._impl_._has_bits_} |
277 | 0 | , /*decltype(_impl_._cached_size_)*/{} |
278 | 0 | , decltype(_impl_.stream_id_){} |
279 | 0 | , decltype(_impl_.chunk_id_){}}; |
280 | |
|
281 | 0 | _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); |
282 | 0 | ::memcpy(&_impl_.stream_id_, &from._impl_.stream_id_, |
283 | 0 | static_cast<size_t>(reinterpret_cast<char*>(&_impl_.chunk_id_) - |
284 | 0 | reinterpret_cast<char*>(&_impl_.stream_id_)) + sizeof(_impl_.chunk_id_)); |
285 | | // @@protoc_insertion_point(copy_constructor:brpc.ChunkInfo) |
286 | 0 | } |
287 | | |
288 | | inline void ChunkInfo::SharedCtor( |
289 | 0 | ::_pb::Arena* arena, bool is_message_owned) { |
290 | 0 | (void)arena; |
291 | 0 | (void)is_message_owned; |
292 | 0 | new (&_impl_) Impl_{ |
293 | 0 | decltype(_impl_._has_bits_){} |
294 | 0 | , /*decltype(_impl_._cached_size_)*/{} |
295 | 0 | , decltype(_impl_.stream_id_){int64_t{0}} |
296 | 0 | , decltype(_impl_.chunk_id_){int64_t{0}} |
297 | 0 | }; |
298 | 0 | } |
299 | | |
300 | 0 | ChunkInfo::~ChunkInfo() { |
301 | | // @@protoc_insertion_point(destructor:brpc.ChunkInfo) |
302 | 0 | if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) { |
303 | 0 | (void)arena; |
304 | 0 | return; |
305 | 0 | } |
306 | 0 | SharedDtor(); |
307 | 0 | } |
308 | | |
309 | 0 | inline void ChunkInfo::SharedDtor() { |
310 | 0 | GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); |
311 | 0 | } |
312 | | |
313 | 0 | void ChunkInfo::SetCachedSize(int size) const { |
314 | 0 | _impl_._cached_size_.Set(size); |
315 | 0 | } |
316 | | |
317 | 0 | void ChunkInfo::Clear() { |
318 | | // @@protoc_insertion_point(message_clear_start:brpc.ChunkInfo) |
319 | 0 | uint32_t cached_has_bits = 0; |
320 | | // Prevent compiler warnings about cached_has_bits being unused |
321 | 0 | (void) cached_has_bits; |
322 | |
|
323 | 0 | cached_has_bits = _impl_._has_bits_[0]; |
324 | 0 | if (cached_has_bits & 0x00000003u) { |
325 | 0 | ::memset(&_impl_.stream_id_, 0, static_cast<size_t>( |
326 | 0 | reinterpret_cast<char*>(&_impl_.chunk_id_) - |
327 | 0 | reinterpret_cast<char*>(&_impl_.stream_id_)) + sizeof(_impl_.chunk_id_)); |
328 | 0 | } |
329 | 0 | _impl_._has_bits_.Clear(); |
330 | 0 | _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); |
331 | 0 | } |
332 | | |
333 | 0 | const char* ChunkInfo::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) { |
334 | 0 | #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure |
335 | 0 | _Internal::HasBits has_bits{}; |
336 | 0 | while (!ctx->Done(&ptr)) { |
337 | 0 | uint32_t tag; |
338 | 0 | ptr = ::_pbi::ReadTag(ptr, &tag); |
339 | 0 | switch (tag >> 3) { |
340 | | // required int64 stream_id = 1; |
341 | 0 | case 1: |
342 | 0 | if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 8)) { |
343 | 0 | _Internal::set_has_stream_id(&has_bits); |
344 | 0 | _impl_.stream_id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr); |
345 | 0 | CHK_(ptr); |
346 | 0 | } else |
347 | 0 | goto handle_unusual; |
348 | 0 | continue; |
349 | | // required int64 chunk_id = 2; |
350 | 0 | case 2: |
351 | 0 | if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 16)) { |
352 | 0 | _Internal::set_has_chunk_id(&has_bits); |
353 | 0 | _impl_.chunk_id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr); |
354 | 0 | CHK_(ptr); |
355 | 0 | } else |
356 | 0 | goto handle_unusual; |
357 | 0 | continue; |
358 | 0 | default: |
359 | 0 | goto handle_unusual; |
360 | 0 | } // switch |
361 | 0 | handle_unusual: |
362 | 0 | if ((tag == 0) || ((tag & 7) == 4)) { |
363 | 0 | CHK_(ptr); |
364 | 0 | ctx->SetLastTag(tag); |
365 | 0 | goto message_done; |
366 | 0 | } |
367 | 0 | ptr = UnknownFieldParse( |
368 | 0 | tag, |
369 | 0 | _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), |
370 | 0 | ptr, ctx); |
371 | 0 | CHK_(ptr != nullptr); |
372 | 0 | } // while |
373 | 0 | message_done: |
374 | 0 | _impl_._has_bits_.Or(has_bits); |
375 | 0 | return ptr; |
376 | 0 | failure: |
377 | 0 | ptr = nullptr; |
378 | 0 | goto message_done; |
379 | 0 | #undef CHK_ |
380 | 0 | } |
381 | | |
382 | | uint8_t* ChunkInfo::_InternalSerialize( |
383 | 0 | uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { |
384 | | // @@protoc_insertion_point(serialize_to_array_start:brpc.ChunkInfo) |
385 | 0 | uint32_t cached_has_bits = 0; |
386 | 0 | (void) cached_has_bits; |
387 | |
|
388 | 0 | cached_has_bits = _impl_._has_bits_[0]; |
389 | | // required int64 stream_id = 1; |
390 | 0 | if (cached_has_bits & 0x00000001u) { |
391 | 0 | target = stream->EnsureSpace(target); |
392 | 0 | target = ::_pbi::WireFormatLite::WriteInt64ToArray(1, this->_internal_stream_id(), target); |
393 | 0 | } |
394 | | |
395 | | // required int64 chunk_id = 2; |
396 | 0 | if (cached_has_bits & 0x00000002u) { |
397 | 0 | target = stream->EnsureSpace(target); |
398 | 0 | target = ::_pbi::WireFormatLite::WriteInt64ToArray(2, this->_internal_chunk_id(), target); |
399 | 0 | } |
400 | |
|
401 | 0 | if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { |
402 | 0 | target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray( |
403 | 0 | _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); |
404 | 0 | } |
405 | | // @@protoc_insertion_point(serialize_to_array_end:brpc.ChunkInfo) |
406 | 0 | return target; |
407 | 0 | } |
408 | | |
409 | 0 | size_t ChunkInfo::RequiredFieldsByteSizeFallback() const { |
410 | | // @@protoc_insertion_point(required_fields_byte_size_fallback_start:brpc.ChunkInfo) |
411 | 0 | size_t total_size = 0; |
412 | |
|
413 | 0 | if (_internal_has_stream_id()) { |
414 | | // required int64 stream_id = 1; |
415 | 0 | total_size += ::_pbi::WireFormatLite::Int64SizePlusOne(this->_internal_stream_id()); |
416 | 0 | } |
417 | |
|
418 | 0 | if (_internal_has_chunk_id()) { |
419 | | // required int64 chunk_id = 2; |
420 | 0 | total_size += ::_pbi::WireFormatLite::Int64SizePlusOne(this->_internal_chunk_id()); |
421 | 0 | } |
422 | |
|
423 | 0 | return total_size; |
424 | 0 | } |
425 | 0 | size_t ChunkInfo::ByteSizeLong() const { |
426 | | // @@protoc_insertion_point(message_byte_size_start:brpc.ChunkInfo) |
427 | 0 | size_t total_size = 0; |
428 | |
|
429 | 0 | if (((_impl_._has_bits_[0] & 0x00000003) ^ 0x00000003) == 0) { // All required fields are present. |
430 | | // required int64 stream_id = 1; |
431 | 0 | total_size += ::_pbi::WireFormatLite::Int64SizePlusOne(this->_internal_stream_id()); |
432 | | |
433 | | // required int64 chunk_id = 2; |
434 | 0 | total_size += ::_pbi::WireFormatLite::Int64SizePlusOne(this->_internal_chunk_id()); |
435 | |
|
436 | 0 | } else { |
437 | 0 | total_size += RequiredFieldsByteSizeFallback(); |
438 | 0 | } |
439 | 0 | uint32_t cached_has_bits = 0; |
440 | | // Prevent compiler warnings about cached_has_bits being unused |
441 | 0 | (void) cached_has_bits; |
442 | |
|
443 | 0 | return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_); |
444 | 0 | } |
445 | | |
446 | | const ::PROTOBUF_NAMESPACE_ID::Message::ClassData ChunkInfo::_class_data_ = { |
447 | | ::PROTOBUF_NAMESPACE_ID::Message::CopyWithSourceCheck, |
448 | | ChunkInfo::MergeImpl |
449 | | }; |
450 | 0 | const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*ChunkInfo::GetClassData() const { return &_class_data_; } |
451 | | |
452 | | |
453 | 0 | void ChunkInfo::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg) { |
454 | 0 | auto* const _this = static_cast<ChunkInfo*>(&to_msg); |
455 | 0 | auto& from = static_cast<const ChunkInfo&>(from_msg); |
456 | | // @@protoc_insertion_point(class_specific_merge_from_start:brpc.ChunkInfo) |
457 | 0 | GOOGLE_DCHECK_NE(&from, _this); |
458 | 0 | uint32_t cached_has_bits = 0; |
459 | 0 | (void) cached_has_bits; |
460 | |
|
461 | 0 | cached_has_bits = from._impl_._has_bits_[0]; |
462 | 0 | if (cached_has_bits & 0x00000003u) { |
463 | 0 | if (cached_has_bits & 0x00000001u) { |
464 | 0 | _this->_impl_.stream_id_ = from._impl_.stream_id_; |
465 | 0 | } |
466 | 0 | if (cached_has_bits & 0x00000002u) { |
467 | 0 | _this->_impl_.chunk_id_ = from._impl_.chunk_id_; |
468 | 0 | } |
469 | 0 | _this->_impl_._has_bits_[0] |= cached_has_bits; |
470 | 0 | } |
471 | 0 | _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); |
472 | 0 | } |
473 | | |
474 | 0 | void ChunkInfo::CopyFrom(const ChunkInfo& from) { |
475 | | // @@protoc_insertion_point(class_specific_copy_from_start:brpc.ChunkInfo) |
476 | 0 | if (&from == this) return; |
477 | 0 | Clear(); |
478 | 0 | MergeFrom(from); |
479 | 0 | } |
480 | | |
481 | 0 | bool ChunkInfo::IsInitialized() const { |
482 | 0 | if (_Internal::MissingRequiredFields(_impl_._has_bits_)) return false; |
483 | 0 | return true; |
484 | 0 | } |
485 | | |
486 | 0 | void ChunkInfo::InternalSwap(ChunkInfo* other) { |
487 | 0 | using std::swap; |
488 | 0 | _internal_metadata_.InternalSwap(&other->_internal_metadata_); |
489 | 0 | swap(_impl_._has_bits_[0], other->_impl_._has_bits_[0]); |
490 | 0 | ::PROTOBUF_NAMESPACE_ID::internal::memswap< |
491 | 0 | PROTOBUF_FIELD_OFFSET(ChunkInfo, _impl_.chunk_id_) |
492 | 0 | + sizeof(ChunkInfo::_impl_.chunk_id_) |
493 | 0 | - PROTOBUF_FIELD_OFFSET(ChunkInfo, _impl_.stream_id_)>( |
494 | 0 | reinterpret_cast<char*>(&_impl_.stream_id_), |
495 | 0 | reinterpret_cast<char*>(&other->_impl_.stream_id_)); |
496 | 0 | } |
497 | | |
498 | 0 | ::PROTOBUF_NAMESPACE_ID::Metadata ChunkInfo::GetMetadata() const { |
499 | 0 | return ::_pbi::AssignDescriptors( |
500 | 0 | &descriptor_table_brpc_2foptions_2eproto_getter, &descriptor_table_brpc_2foptions_2eproto_once, |
501 | 0 | file_level_metadata_brpc_2foptions_2eproto[0]); |
502 | 0 | } |
503 | | PROTOBUF_ATTRIBUTE_INIT_PRIORITY2 ::PROTOBUF_NAMESPACE_ID::internal::ExtensionIdentifier< ::PROTOBUF_NAMESPACE_ID::ServiceOptions, |
504 | | ::PROTOBUF_NAMESPACE_ID::internal::PrimitiveTypeTraits< int64_t >, 3, false> |
505 | | service_timeout(kServiceTimeoutFieldNumber, int64_t{10000}, nullptr); |
506 | | PROTOBUF_ATTRIBUTE_INIT_PRIORITY2 ::PROTOBUF_NAMESPACE_ID::internal::ExtensionIdentifier< ::PROTOBUF_NAMESPACE_ID::MethodOptions, |
507 | | ::PROTOBUF_NAMESPACE_ID::internal::EnumTypeTraits< ::brpc::TalkType, ::brpc::TalkType_IsValid>, 14, false> |
508 | | request_talk_type(kRequestTalkTypeFieldNumber, static_cast< ::brpc::TalkType >(0), nullptr); |
509 | | PROTOBUF_ATTRIBUTE_INIT_PRIORITY2 ::PROTOBUF_NAMESPACE_ID::internal::ExtensionIdentifier< ::PROTOBUF_NAMESPACE_ID::MethodOptions, |
510 | | ::PROTOBUF_NAMESPACE_ID::internal::EnumTypeTraits< ::brpc::TalkType, ::brpc::TalkType_IsValid>, 14, false> |
511 | | response_talk_type(kResponseTalkTypeFieldNumber, static_cast< ::brpc::TalkType >(0), nullptr); |
512 | | PROTOBUF_ATTRIBUTE_INIT_PRIORITY2 ::PROTOBUF_NAMESPACE_ID::internal::ExtensionIdentifier< ::PROTOBUF_NAMESPACE_ID::MethodOptions, |
513 | | ::PROTOBUF_NAMESPACE_ID::internal::PrimitiveTypeTraits< int64_t >, 3, false> |
514 | | method_timeout(kMethodTimeoutFieldNumber, int64_t{0}, nullptr); |
515 | | PROTOBUF_ATTRIBUTE_INIT_PRIORITY2 ::PROTOBUF_NAMESPACE_ID::internal::ExtensionIdentifier< ::PROTOBUF_NAMESPACE_ID::MethodOptions, |
516 | | ::PROTOBUF_NAMESPACE_ID::internal::EnumTypeTraits< ::brpc::CompressType, ::brpc::CompressType_IsValid>, 14, false> |
517 | | request_compression(kRequestCompressionFieldNumber, static_cast< ::brpc::CompressType >(0), nullptr); |
518 | | PROTOBUF_ATTRIBUTE_INIT_PRIORITY2 ::PROTOBUF_NAMESPACE_ID::internal::ExtensionIdentifier< ::PROTOBUF_NAMESPACE_ID::MethodOptions, |
519 | | ::PROTOBUF_NAMESPACE_ID::internal::EnumTypeTraits< ::brpc::CompressType, ::brpc::CompressType_IsValid>, 14, false> |
520 | | response_compression(kResponseCompressionFieldNumber, static_cast< ::brpc::CompressType >(0), nullptr); |
521 | | |
522 | | // @@protoc_insertion_point(namespace_scope) |
523 | | } // namespace brpc |
524 | | PROTOBUF_NAMESPACE_OPEN |
525 | | template<> PROTOBUF_NOINLINE ::brpc::ChunkInfo* |
526 | 0 | Arena::CreateMaybeMessage< ::brpc::ChunkInfo >(Arena* arena) { |
527 | 0 | return Arena::CreateMessageInternal< ::brpc::ChunkInfo >(arena); |
528 | 0 | } |
529 | | PROTOBUF_NAMESPACE_CLOSE |
530 | | |
531 | | // @@protoc_insertion_point(global_scope) |
532 | | #include <google/protobuf/port_undef.inc> |