/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/rpc/rpc_header.pb.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // Generated by the protocol buffer compiler. DO NOT EDIT! |
2 | | // source: yb/rpc/rpc_header.proto |
3 | | |
4 | | #include "yb/rpc/rpc_header.pb.h" |
5 | | |
6 | | #include <algorithm> |
7 | | |
8 | | #include <google/protobuf/stubs/common.h> |
9 | | #include <google/protobuf/stubs/port.h> |
10 | | #include <google/protobuf/stubs/once.h> |
11 | | #include <google/protobuf/io/coded_stream.h> |
12 | | #include <google/protobuf/wire_format_lite_inl.h> |
13 | | #include <google/protobuf/descriptor.h> |
14 | | #include <google/protobuf/generated_message_reflection.h> |
15 | | #include <google/protobuf/reflection_ops.h> |
16 | | #include <google/protobuf/wire_format.h> |
17 | | // This is a temporary google only hack |
18 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
19 | | #include "third_party/protobuf/version.h" |
20 | | #endif |
21 | | #include "yb/util/protobuf-annotations.h" |
22 | | // @@protoc_insertion_point(includes) |
23 | | namespace yb { |
24 | | namespace rpc { |
25 | | class RemoteMethodPBDefaultTypeInternal { |
26 | | public: |
27 | | ::google::protobuf::internal::ExplicitlyConstructed<RemoteMethodPB> |
28 | | _instance; |
29 | | } _RemoteMethodPB_default_instance_; |
30 | | class RequestHeaderDefaultTypeInternal { |
31 | | public: |
32 | | ::google::protobuf::internal::ExplicitlyConstructed<RequestHeader> |
33 | | _instance; |
34 | | } _RequestHeader_default_instance_; |
35 | | class ResponseHeaderDefaultTypeInternal { |
36 | | public: |
37 | | ::google::protobuf::internal::ExplicitlyConstructed<ResponseHeader> |
38 | | _instance; |
39 | | } _ResponseHeader_default_instance_; |
40 | | class EmptyMessagePBDefaultTypeInternal { |
41 | | public: |
42 | | ::google::protobuf::internal::ExplicitlyConstructed<EmptyMessagePB> |
43 | | _instance; |
44 | | } _EmptyMessagePB_default_instance_; |
45 | | class ErrorStatusPBDefaultTypeInternal { |
46 | | public: |
47 | | ::google::protobuf::internal::ExplicitlyConstructed<ErrorStatusPB> |
48 | | _instance; |
49 | | } _ErrorStatusPB_default_instance_; |
50 | | } // namespace rpc |
51 | | } // namespace yb |
52 | | namespace protobuf_yb_2frpc_2frpc_5fheader_2eproto { |
53 | 17.2k | void InitDefaultsRemoteMethodPBImpl() { |
54 | 17.2k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
55 | | |
56 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
57 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
58 | | #else |
59 | 17.2k | ::google::protobuf::internal::InitProtobufDefaults(); |
60 | 17.2k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
61 | 17.2k | { |
62 | 17.2k | void* ptr = &::yb::rpc::_RemoteMethodPB_default_instance_; |
63 | 17.2k | new (ptr) ::yb::rpc::RemoteMethodPB(); |
64 | 17.2k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
65 | 17.2k | } |
66 | 17.2k | ::yb::rpc::RemoteMethodPB::InitAsDefaultInstance(); |
67 | 17.2k | } |
68 | | |
69 | 1.63M | void InitDefaultsRemoteMethodPB() { |
70 | 1.63M | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
71 | 1.63M | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsRemoteMethodPBImpl); |
72 | 1.63M | } |
73 | | |
74 | 17.2k | void InitDefaultsRequestHeaderImpl() { |
75 | 17.2k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
76 | | |
77 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
78 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
79 | | #else |
80 | 17.2k | ::google::protobuf::internal::InitProtobufDefaults(); |
81 | 17.2k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
82 | 17.2k | protobuf_yb_2frpc_2frpc_5fheader_2eproto::InitDefaultsRemoteMethodPB(); |
83 | 17.2k | { |
84 | 17.2k | void* ptr = &::yb::rpc::_RequestHeader_default_instance_; |
85 | 17.2k | new (ptr) ::yb::rpc::RequestHeader(); |
86 | 17.2k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
87 | 17.2k | } |
88 | 17.2k | ::yb::rpc::RequestHeader::InitAsDefaultInstance(); |
89 | 17.2k | } |
90 | | |
91 | 1.63M | void InitDefaultsRequestHeader() { |
92 | 1.63M | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
93 | 1.63M | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsRequestHeaderImpl); |
94 | 1.63M | } |
95 | | |
96 | 17.2k | void InitDefaultsResponseHeaderImpl() { |
97 | 17.2k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
98 | | |
99 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
100 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
101 | | #else |
102 | 17.2k | ::google::protobuf::internal::InitProtobufDefaults(); |
103 | 17.2k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
104 | 17.2k | { |
105 | 17.2k | void* ptr = &::yb::rpc::_ResponseHeader_default_instance_; |
106 | 17.2k | new (ptr) ::yb::rpc::ResponseHeader(); |
107 | 17.2k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
108 | 17.2k | } |
109 | 17.2k | ::yb::rpc::ResponseHeader::InitAsDefaultInstance(); |
110 | 17.2k | } |
111 | | |
112 | 64.7M | void InitDefaultsResponseHeader() { |
113 | 64.7M | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
114 | 64.7M | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsResponseHeaderImpl); |
115 | 64.7M | } |
116 | | |
117 | 17.2k | void InitDefaultsEmptyMessagePBImpl() { |
118 | 17.2k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
119 | | |
120 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
121 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
122 | | #else |
123 | 17.2k | ::google::protobuf::internal::InitProtobufDefaults(); |
124 | 17.2k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
125 | 17.2k | { |
126 | 17.2k | void* ptr = &::yb::rpc::_EmptyMessagePB_default_instance_; |
127 | 17.2k | new (ptr) ::yb::rpc::EmptyMessagePB(); |
128 | 17.2k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
129 | 17.2k | } |
130 | 17.2k | ::yb::rpc::EmptyMessagePB::InitAsDefaultInstance(); |
131 | 17.2k | } |
132 | | |
133 | 17.2k | void InitDefaultsEmptyMessagePB() { |
134 | 17.2k | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
135 | 17.2k | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsEmptyMessagePBImpl); |
136 | 17.2k | } |
137 | | |
138 | 17.2k | void InitDefaultsErrorStatusPBImpl() { |
139 | 17.2k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
140 | | |
141 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
142 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
143 | | #else |
144 | 17.2k | ::google::protobuf::internal::InitProtobufDefaults(); |
145 | 17.2k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
146 | 17.2k | { |
147 | 17.2k | void* ptr = &::yb::rpc::_ErrorStatusPB_default_instance_; |
148 | 17.2k | new (ptr) ::yb::rpc::ErrorStatusPB(); |
149 | 17.2k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
150 | 17.2k | } |
151 | 17.2k | ::yb::rpc::ErrorStatusPB::InitAsDefaultInstance(); |
152 | 17.2k | } |
153 | | |
154 | 37.8k | void InitDefaultsErrorStatusPB() { |
155 | 37.8k | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
156 | 37.8k | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsErrorStatusPBImpl); |
157 | 37.8k | } |
158 | | |
159 | | ::google::protobuf::Metadata file_level_metadata[5]; |
160 | | const ::google::protobuf::EnumDescriptor* file_level_enum_descriptors[1]; |
161 | | |
162 | | const ::google::protobuf::uint32 TableStruct::offsets[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = { |
163 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::RemoteMethodPB, _has_bits_), |
164 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::RemoteMethodPB, _internal_metadata_), |
165 | | ~0u, // no _extensions_ |
166 | | ~0u, // no _oneof_case_ |
167 | | ~0u, // no _weak_field_map_ |
168 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::RemoteMethodPB, service_name_), |
169 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::RemoteMethodPB, method_name_), |
170 | | 0, |
171 | | 1, |
172 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::RequestHeader, _has_bits_), |
173 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::RequestHeader, _internal_metadata_), |
174 | | ~0u, // no _extensions_ |
175 | | ~0u, // no _oneof_case_ |
176 | | ~0u, // no _weak_field_map_ |
177 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::RequestHeader, call_id_), |
178 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::RequestHeader, remote_method_), |
179 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::RequestHeader, timeout_millis_), |
180 | | 1, |
181 | | 0, |
182 | | 2, |
183 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::ResponseHeader, _has_bits_), |
184 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::ResponseHeader, _internal_metadata_), |
185 | | ~0u, // no _extensions_ |
186 | | ~0u, // no _oneof_case_ |
187 | | ~0u, // no _weak_field_map_ |
188 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::ResponseHeader, call_id_), |
189 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::ResponseHeader, is_error_), |
190 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::ResponseHeader, sidecar_offsets_), |
191 | | 0, |
192 | | 1, |
193 | | ~0u, |
194 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::EmptyMessagePB, _has_bits_), |
195 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::EmptyMessagePB, _internal_metadata_), |
196 | | ~0u, // no _extensions_ |
197 | | ~0u, // no _oneof_case_ |
198 | | ~0u, // no _weak_field_map_ |
199 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::ErrorStatusPB, _has_bits_), |
200 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::ErrorStatusPB, _internal_metadata_), |
201 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::ErrorStatusPB, _extensions_), |
202 | | ~0u, // no _oneof_case_ |
203 | | ~0u, // no _weak_field_map_ |
204 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::ErrorStatusPB, message_), |
205 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::rpc::ErrorStatusPB, code_), |
206 | | 0, |
207 | | 1, |
208 | | }; |
209 | | static const ::google::protobuf::internal::MigrationSchema schemas[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = { |
210 | | { 0, 7, sizeof(::yb::rpc::RemoteMethodPB)}, |
211 | | { 9, 17, sizeof(::yb::rpc::RequestHeader)}, |
212 | | { 20, 28, sizeof(::yb::rpc::ResponseHeader)}, |
213 | | { 31, 36, sizeof(::yb::rpc::EmptyMessagePB)}, |
214 | | { 36, 43, sizeof(::yb::rpc::ErrorStatusPB)}, |
215 | | }; |
216 | | |
217 | | static ::google::protobuf::Message const * const file_default_instances[] = { |
218 | | reinterpret_cast<const ::google::protobuf::Message*>(&::yb::rpc::_RemoteMethodPB_default_instance_), |
219 | | reinterpret_cast<const ::google::protobuf::Message*>(&::yb::rpc::_RequestHeader_default_instance_), |
220 | | reinterpret_cast<const ::google::protobuf::Message*>(&::yb::rpc::_ResponseHeader_default_instance_), |
221 | | reinterpret_cast<const ::google::protobuf::Message*>(&::yb::rpc::_EmptyMessagePB_default_instance_), |
222 | | reinterpret_cast<const ::google::protobuf::Message*>(&::yb::rpc::_ErrorStatusPB_default_instance_), |
223 | | }; |
224 | | |
225 | 12.7k | void protobuf_AssignDescriptors() { |
226 | 12.7k | AddDescriptors(); |
227 | 12.7k | ::google::protobuf::MessageFactory* factory = NULL; |
228 | 12.7k | AssignDescriptors( |
229 | 12.7k | "yb/rpc/rpc_header.proto", schemas, file_default_instances, TableStruct::offsets, factory, |
230 | 12.7k | file_level_metadata, file_level_enum_descriptors, NULL); |
231 | 12.7k | } |
232 | | |
233 | 19.5M | void protobuf_AssignDescriptorsOnce() { |
234 | 19.5M | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
235 | 19.5M | ::google::protobuf::GoogleOnceInit(&once, &protobuf_AssignDescriptors); |
236 | 19.5M | } |
237 | | |
238 | | void protobuf_RegisterTypes(const ::std::string&) GOOGLE_PROTOBUF_ATTRIBUTE_COLD; |
239 | 0 | void protobuf_RegisterTypes(const ::std::string&) { |
240 | 0 | protobuf_AssignDescriptorsOnce(); |
241 | 0 | ::google::protobuf::internal::RegisterAllTypes(file_level_metadata, 5); |
242 | 0 | } |
243 | | |
244 | 17.2k | void AddDescriptorsImpl() { |
245 | 17.2k | InitDefaults(); |
246 | 17.2k | static const char descriptor[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = { |
247 | 17.2k | "\n\027yb/rpc/rpc_header.proto\022\006yb.rpc\";\n\016Rem" |
248 | 17.2k | "oteMethodPB\022\024\n\014service_name\030\001 \002(\t\022\023\n\013met" |
249 | 17.2k | "hod_name\030\002 \002(\t\"g\n\rRequestHeader\022\017\n\007call_" |
250 | 17.2k | "id\030\001 \001(\005\022-\n\rremote_method\030\002 \001(\0132\026.yb.rpc" |
251 | 17.2k | ".RemoteMethodPB\022\026\n\016timeout_millis\030\003 \001(\r\"" |
252 | 17.2k | "S\n\016ResponseHeader\022\017\n\007call_id\030\001 \002(\005\022\027\n\010is" |
253 | 17.2k | "_error\030\002 \001(\010:\005false\022\027\n\017sidecar_offsets\030\003" |
254 | 17.2k | " \003(\r\"\020\n\016EmptyMessagePB\"\373\002\n\rErrorStatusPB" |
255 | 17.2k | "\022\017\n\007message\030\001 \002(\t\0222\n\004code\030\002 \001(\0162$.yb.rpc" |
256 | 17.2k | ".ErrorStatusPB.RpcErrorCodePB\"\232\002\n\016RpcErr" |
257 | 17.2k | "orCodePB\022\021\n\rFATAL_UNKNOWN\020\n\022\025\n\021ERROR_APP" |
258 | 17.2k | "LICATION\020\001\022\030\n\024ERROR_NO_SUCH_METHOD\020\002\022\031\n\025" |
259 | 17.2k | "ERROR_NO_SUCH_SERVICE\020\003\022\031\n\025ERROR_SERVER_" |
260 | 17.2k | "TOO_BUSY\020\004\022\031\n\025ERROR_INVALID_REQUEST\020\005\022\036\n" |
261 | 17.2k | "\032FATAL_SERVER_SHUTTING_DOWN\020\013\022\037\n\033FATAL_D" |
262 | 17.2k | "ESERIALIZING_REQUEST\020\r\022\032\n\026FATAL_VERSION_" |
263 | 17.2k | "MISMATCH\020\016\022\026\n\022FATAL_UNAUTHORIZED\020\017*\010\010d\020\200" |
264 | 17.2k | "\200\200\200\002B\014\n\norg.yb.rpc" |
265 | 17.2k | }; |
266 | 17.2k | ::google::protobuf::DescriptorPool::InternalAddGeneratedFile( |
267 | 17.2k | descriptor, 698); |
268 | 17.2k | ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile( |
269 | 17.2k | "yb/rpc/rpc_header.proto", &protobuf_RegisterTypes); |
270 | 17.2k | } |
271 | | |
272 | 63.2k | void AddDescriptors() { |
273 | 63.2k | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
274 | 63.2k | ::google::protobuf::GoogleOnceInit(&once, &AddDescriptorsImpl); |
275 | 63.2k | } |
276 | | // Force AddDescriptors() to be called at dynamic initialization time. |
277 | | struct StaticDescriptorInitializer { |
278 | 17.2k | StaticDescriptorInitializer() { |
279 | 17.2k | AddDescriptors(); |
280 | 17.2k | } |
281 | | } static_descriptor_initializer; |
282 | | } // namespace protobuf_yb_2frpc_2frpc_5fheader_2eproto |
283 | | namespace yb { |
284 | | namespace rpc { |
285 | 0 | const ::google::protobuf::EnumDescriptor* ErrorStatusPB_RpcErrorCodePB_descriptor() { |
286 | 0 | protobuf_yb_2frpc_2frpc_5fheader_2eproto::protobuf_AssignDescriptorsOnce(); |
287 | 0 | return protobuf_yb_2frpc_2frpc_5fheader_2eproto::file_level_enum_descriptors[0]; |
288 | 0 | } |
289 | 3.82k | bool ErrorStatusPB_RpcErrorCodePB_IsValid(int value) { |
290 | 3.82k | switch (value) { |
291 | 42 | case 1: |
292 | 48 | case 2: |
293 | 57 | case 3: |
294 | 3.76k | case 4: |
295 | 3.77k | case 5: |
296 | 3.77k | case 10: |
297 | 3.82k | case 11: |
298 | 3.82k | case 13: |
299 | 3.82k | case 14: |
300 | 3.82k | case 15: |
301 | 3.82k | return true; |
302 | 0 | default: |
303 | 0 | return false; |
304 | 3.82k | } |
305 | 3.82k | } |
306 | | |
307 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
308 | | const ErrorStatusPB_RpcErrorCodePB ErrorStatusPB::FATAL_UNKNOWN; |
309 | | const ErrorStatusPB_RpcErrorCodePB ErrorStatusPB::ERROR_APPLICATION; |
310 | | const ErrorStatusPB_RpcErrorCodePB ErrorStatusPB::ERROR_NO_SUCH_METHOD; |
311 | | const ErrorStatusPB_RpcErrorCodePB ErrorStatusPB::ERROR_NO_SUCH_SERVICE; |
312 | | const ErrorStatusPB_RpcErrorCodePB ErrorStatusPB::ERROR_SERVER_TOO_BUSY; |
313 | | const ErrorStatusPB_RpcErrorCodePB ErrorStatusPB::ERROR_INVALID_REQUEST; |
314 | | const ErrorStatusPB_RpcErrorCodePB ErrorStatusPB::FATAL_SERVER_SHUTTING_DOWN; |
315 | | const ErrorStatusPB_RpcErrorCodePB ErrorStatusPB::FATAL_DESERIALIZING_REQUEST; |
316 | | const ErrorStatusPB_RpcErrorCodePB ErrorStatusPB::FATAL_VERSION_MISMATCH; |
317 | | const ErrorStatusPB_RpcErrorCodePB ErrorStatusPB::FATAL_UNAUTHORIZED; |
318 | | const ErrorStatusPB_RpcErrorCodePB ErrorStatusPB::RpcErrorCodePB_MIN; |
319 | | const ErrorStatusPB_RpcErrorCodePB ErrorStatusPB::RpcErrorCodePB_MAX; |
320 | | const int ErrorStatusPB::RpcErrorCodePB_ARRAYSIZE; |
321 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
322 | | |
323 | | // =================================================================== |
324 | | |
325 | 17.2k | void RemoteMethodPB::InitAsDefaultInstance() { |
326 | 17.2k | } |
327 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
328 | | const int RemoteMethodPB::kServiceNameFieldNumber; |
329 | | const int RemoteMethodPB::kMethodNameFieldNumber; |
330 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
331 | | |
332 | | RemoteMethodPB::RemoteMethodPB() |
333 | 1.61M | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
334 | 1.60M | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
335 | 1.60M | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::InitDefaultsRemoteMethodPB(); |
336 | 1.60M | } |
337 | 1.61M | SharedCtor(); |
338 | | // @@protoc_insertion_point(constructor:yb.rpc.RemoteMethodPB) |
339 | 1.61M | } |
340 | | RemoteMethodPB::RemoteMethodPB(const RemoteMethodPB& from) |
341 | | : ::google::protobuf::Message(), |
342 | | _internal_metadata_(NULL), |
343 | | _has_bits_(from._has_bits_), |
344 | 0 | _cached_size_(0) { |
345 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
346 | 0 | service_name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
347 | 0 | if (from.has_service_name()) { |
348 | 0 | service_name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.service_name_); |
349 | 0 | } |
350 | 0 | method_name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
351 | 0 | if (from.has_method_name()) { |
352 | 0 | method_name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.method_name_); |
353 | 0 | } |
354 | | // @@protoc_insertion_point(copy_constructor:yb.rpc.RemoteMethodPB) |
355 | 0 | } |
356 | | |
357 | 1.61M | void RemoteMethodPB::SharedCtor() { |
358 | 1.61M | _cached_size_ = 0; |
359 | 1.61M | service_name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
360 | 1.61M | method_name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
361 | 1.61M | } |
362 | | |
363 | 1.60M | RemoteMethodPB::~RemoteMethodPB() { |
364 | | // @@protoc_insertion_point(destructor:yb.rpc.RemoteMethodPB) |
365 | 1.60M | SharedDtor(); |
366 | 1.60M | } |
367 | | |
368 | 1.60M | void RemoteMethodPB::SharedDtor() { |
369 | 1.60M | service_name_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
370 | 1.60M | method_name_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
371 | 1.60M | } |
372 | | |
373 | 0 | void RemoteMethodPB::SetCachedSize(int size) const { |
374 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
375 | 0 | _cached_size_ = size; |
376 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
377 | 0 | } |
378 | 0 | const ::google::protobuf::Descriptor* RemoteMethodPB::descriptor() { |
379 | 0 | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::protobuf_AssignDescriptorsOnce(); |
380 | 0 | return ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
381 | 0 | } |
382 | | |
383 | 0 | const RemoteMethodPB& RemoteMethodPB::default_instance() { |
384 | 0 | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::InitDefaultsRemoteMethodPB(); |
385 | 0 | return *internal_default_instance(); |
386 | 0 | } |
387 | | |
388 | 0 | RemoteMethodPB* RemoteMethodPB::New(::google::protobuf::Arena* arena) const { |
389 | 0 | RemoteMethodPB* n = new RemoteMethodPB; |
390 | 0 | if (arena != NULL) { |
391 | 0 | arena->Own(n); |
392 | 0 | } |
393 | 0 | return n; |
394 | 0 | } |
395 | | |
396 | 1 | void RemoteMethodPB::Clear() { |
397 | | // @@protoc_insertion_point(message_clear_start:yb.rpc.RemoteMethodPB) |
398 | 1 | ::google::protobuf::uint32 cached_has_bits = 0; |
399 | | // Prevent compiler warnings about cached_has_bits being unused |
400 | 1 | (void) cached_has_bits; |
401 | | |
402 | 1 | cached_has_bits = _has_bits_[0]; |
403 | 1 | if (cached_has_bits & 3u) { |
404 | 1 | if (cached_has_bits & 0x00000001u) { |
405 | 1 | GOOGLE_DCHECK(!service_name_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
406 | 1 | (*service_name_.UnsafeRawStringPointer())->clear(); |
407 | 1 | } |
408 | 1 | if (cached_has_bits & 0x00000002u) { |
409 | 1 | GOOGLE_DCHECK(!method_name_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
410 | 1 | (*method_name_.UnsafeRawStringPointer())->clear(); |
411 | 1 | } |
412 | 1 | } |
413 | 1 | _has_bits_.Clear(); |
414 | 1 | _internal_metadata_.Clear(); |
415 | 1 | } |
416 | | |
417 | | bool RemoteMethodPB::MergePartialFromCodedStream( |
418 | 0 | ::google::protobuf::io::CodedInputStream* input) { |
419 | 0 | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure |
420 | 0 | ::google::protobuf::uint32 tag; |
421 | | // @@protoc_insertion_point(parse_start:yb.rpc.RemoteMethodPB) |
422 | 0 | for (;;) { |
423 | 0 | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
424 | 0 | tag = p.first; |
425 | 0 | if (!p.second) goto handle_unusual; |
426 | 0 | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
427 | | // required string service_name = 1; |
428 | 0 | case 1: { |
429 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
430 | 0 | static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) { |
431 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadString( |
432 | 0 | input, this->mutable_service_name())); |
433 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
434 | 0 | this->service_name().data(), static_cast<int>(this->service_name().length()), |
435 | 0 | ::google::protobuf::internal::WireFormat::PARSE, |
436 | 0 | "yb.rpc.RemoteMethodPB.service_name"); |
437 | 0 | } else { |
438 | 0 | goto handle_unusual; |
439 | 0 | } |
440 | 0 | break; |
441 | 0 | } |
442 | | |
443 | | // required string method_name = 2; |
444 | 0 | case 2: { |
445 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
446 | 0 | static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) { |
447 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadString( |
448 | 0 | input, this->mutable_method_name())); |
449 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
450 | 0 | this->method_name().data(), static_cast<int>(this->method_name().length()), |
451 | 0 | ::google::protobuf::internal::WireFormat::PARSE, |
452 | 0 | "yb.rpc.RemoteMethodPB.method_name"); |
453 | 0 | } else { |
454 | 0 | goto handle_unusual; |
455 | 0 | } |
456 | 0 | break; |
457 | 0 | } |
458 | | |
459 | 0 | default: { |
460 | 0 | handle_unusual: |
461 | 0 | if (tag == 0) { |
462 | 0 | goto success; |
463 | 0 | } |
464 | 0 | DO_(::google::protobuf::internal::WireFormat::SkipField( |
465 | 0 | input, tag, _internal_metadata_.mutable_unknown_fields())); |
466 | 0 | break; |
467 | 0 | } |
468 | 0 | } |
469 | 0 | } |
470 | 0 | success: |
471 | | // @@protoc_insertion_point(parse_success:yb.rpc.RemoteMethodPB) |
472 | 0 | return true; |
473 | 0 | failure: |
474 | | // @@protoc_insertion_point(parse_failure:yb.rpc.RemoteMethodPB) |
475 | 0 | return false; |
476 | 0 | #undef DO_ |
477 | 0 | } |
478 | | |
479 | | void RemoteMethodPB::SerializeWithCachedSizes( |
480 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
481 | | // @@protoc_insertion_point(serialize_start:yb.rpc.RemoteMethodPB) |
482 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
483 | 0 | (void) cached_has_bits; |
484 | |
|
485 | 0 | cached_has_bits = _has_bits_[0]; |
486 | | // required string service_name = 1; |
487 | 0 | if (cached_has_bits & 0x00000001u) { |
488 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
489 | 0 | this->service_name().data(), static_cast<int>(this->service_name().length()), |
490 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
491 | 0 | "yb.rpc.RemoteMethodPB.service_name"); |
492 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( |
493 | 0 | 1, this->service_name(), output); |
494 | 0 | } |
495 | | |
496 | | // required string method_name = 2; |
497 | 0 | if (cached_has_bits & 0x00000002u) { |
498 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
499 | 0 | this->method_name().data(), static_cast<int>(this->method_name().length()), |
500 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
501 | 0 | "yb.rpc.RemoteMethodPB.method_name"); |
502 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( |
503 | 0 | 2, this->method_name(), output); |
504 | 0 | } |
505 | |
|
506 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
507 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
508 | 0 | _internal_metadata_.unknown_fields(), output); |
509 | 0 | } |
510 | | // @@protoc_insertion_point(serialize_end:yb.rpc.RemoteMethodPB) |
511 | 0 | } |
512 | | |
513 | | ::google::protobuf::uint8* RemoteMethodPB::InternalSerializeWithCachedSizesToArray( |
514 | 1.60M | bool deterministic, ::google::protobuf::uint8* target) const { |
515 | 1.60M | (void)deterministic; // Unused |
516 | | // @@protoc_insertion_point(serialize_to_array_start:yb.rpc.RemoteMethodPB) |
517 | 1.60M | ::google::protobuf::uint32 cached_has_bits = 0; |
518 | 1.60M | (void) cached_has_bits; |
519 | | |
520 | 1.60M | cached_has_bits = _has_bits_[0]; |
521 | | // required string service_name = 1; |
522 | 1.60M | if (cached_has_bits & 0x00000001u) { |
523 | 1.60M | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
524 | 1.60M | this->service_name().data(), static_cast<int>(this->service_name().length()), |
525 | 1.60M | ::google::protobuf::internal::WireFormat::SERIALIZE, |
526 | 1.60M | "yb.rpc.RemoteMethodPB.service_name"); |
527 | 1.60M | target = |
528 | 1.60M | ::google::protobuf::internal::WireFormatLite::WriteStringToArray( |
529 | 1.60M | 1, this->service_name(), target); |
530 | 1.60M | } |
531 | | |
532 | | // required string method_name = 2; |
533 | 1.60M | if (cached_has_bits & 0x00000002u) { |
534 | 1.60M | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
535 | 1.60M | this->method_name().data(), static_cast<int>(this->method_name().length()), |
536 | 1.60M | ::google::protobuf::internal::WireFormat::SERIALIZE, |
537 | 1.60M | "yb.rpc.RemoteMethodPB.method_name"); |
538 | 1.60M | target = |
539 | 1.60M | ::google::protobuf::internal::WireFormatLite::WriteStringToArray( |
540 | 1.60M | 2, this->method_name(), target); |
541 | 1.60M | } |
542 | | |
543 | 1.60M | if (_internal_metadata_.have_unknown_fields()) { |
544 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
545 | 0 | _internal_metadata_.unknown_fields(), target); |
546 | 0 | } |
547 | | // @@protoc_insertion_point(serialize_to_array_end:yb.rpc.RemoteMethodPB) |
548 | 1.60M | return target; |
549 | 1.60M | } |
550 | | |
551 | 0 | size_t RemoteMethodPB::RequiredFieldsByteSizeFallback() const { |
552 | | // @@protoc_insertion_point(required_fields_byte_size_fallback_start:yb.rpc.RemoteMethodPB) |
553 | 0 | size_t total_size = 0; |
554 | |
|
555 | 0 | if (has_service_name()) { |
556 | | // required string service_name = 1; |
557 | 0 | total_size += 1 + |
558 | 0 | ::google::protobuf::internal::WireFormatLite::StringSize( |
559 | 0 | this->service_name()); |
560 | 0 | } |
561 | |
|
562 | 0 | if (has_method_name()) { |
563 | | // required string method_name = 2; |
564 | 0 | total_size += 1 + |
565 | 0 | ::google::protobuf::internal::WireFormatLite::StringSize( |
566 | 0 | this->method_name()); |
567 | 0 | } |
568 | |
|
569 | 0 | return total_size; |
570 | 0 | } |
571 | 1.60M | size_t RemoteMethodPB::ByteSizeLong() const { |
572 | | // @@protoc_insertion_point(message_byte_size_start:yb.rpc.RemoteMethodPB) |
573 | 1.60M | size_t total_size = 0; |
574 | | |
575 | 1.60M | if (_internal_metadata_.have_unknown_fields()) { |
576 | 0 | total_size += |
577 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
578 | 0 | _internal_metadata_.unknown_fields()); |
579 | 0 | } |
580 | 1.60M | if (((_has_bits_[0] & 0x00000003) ^ 0x00000003) == 0) { // All required fields are present. |
581 | | // required string service_name = 1; |
582 | 1.60M | total_size += 1 + |
583 | 1.60M | ::google::protobuf::internal::WireFormatLite::StringSize( |
584 | 1.60M | this->service_name()); |
585 | | |
586 | | // required string method_name = 2; |
587 | 1.60M | total_size += 1 + |
588 | 1.60M | ::google::protobuf::internal::WireFormatLite::StringSize( |
589 | 1.60M | this->method_name()); |
590 | | |
591 | 3 | } else { |
592 | 3 | total_size += RequiredFieldsByteSizeFallback(); |
593 | 3 | } |
594 | 1.60M | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
595 | 1.60M | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
596 | 1.60M | _cached_size_ = cached_size; |
597 | 1.60M | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
598 | 1.60M | return total_size; |
599 | 1.60M | } |
600 | | |
601 | 0 | void RemoteMethodPB::MergeFrom(const ::google::protobuf::Message& from) { |
602 | | // @@protoc_insertion_point(generalized_merge_from_start:yb.rpc.RemoteMethodPB) |
603 | 0 | GOOGLE_DCHECK_NE(&from, this); |
604 | 0 | const RemoteMethodPB* source = |
605 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const RemoteMethodPB>( |
606 | 0 | &from); |
607 | 0 | if (source == NULL) { |
608 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.rpc.RemoteMethodPB) |
609 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
610 | 0 | } else { |
611 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.rpc.RemoteMethodPB) |
612 | 0 | MergeFrom(*source); |
613 | 0 | } |
614 | 0 | } |
615 | | |
616 | 0 | void RemoteMethodPB::MergeFrom(const RemoteMethodPB& from) { |
617 | | // @@protoc_insertion_point(class_specific_merge_from_start:yb.rpc.RemoteMethodPB) |
618 | 0 | GOOGLE_DCHECK_NE(&from, this); |
619 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
620 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
621 | 0 | (void) cached_has_bits; |
622 | |
|
623 | 0 | cached_has_bits = from._has_bits_[0]; |
624 | 0 | if (cached_has_bits & 3u) { |
625 | 0 | if (cached_has_bits & 0x00000001u) { |
626 | 0 | set_has_service_name(); |
627 | 0 | service_name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.service_name_); |
628 | 0 | } |
629 | 0 | if (cached_has_bits & 0x00000002u) { |
630 | 0 | set_has_method_name(); |
631 | 0 | method_name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.method_name_); |
632 | 0 | } |
633 | 0 | } |
634 | 0 | } |
635 | | |
636 | 0 | void RemoteMethodPB::CopyFrom(const ::google::protobuf::Message& from) { |
637 | | // @@protoc_insertion_point(generalized_copy_from_start:yb.rpc.RemoteMethodPB) |
638 | 0 | if (&from == this) return; |
639 | 0 | Clear(); |
640 | 0 | MergeFrom(from); |
641 | 0 | } |
642 | | |
643 | 0 | void RemoteMethodPB::CopyFrom(const RemoteMethodPB& from) { |
644 | | // @@protoc_insertion_point(class_specific_copy_from_start:yb.rpc.RemoteMethodPB) |
645 | 0 | if (&from == this) return; |
646 | 0 | Clear(); |
647 | 0 | MergeFrom(from); |
648 | 0 | } |
649 | | |
650 | 1.60M | bool RemoteMethodPB::IsInitialized() const { |
651 | 1.60M | if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false; |
652 | 1.60M | return true; |
653 | 1.60M | } |
654 | | |
655 | 0 | void RemoteMethodPB::Swap(RemoteMethodPB* other) { |
656 | 0 | if (other == this) return; |
657 | 0 | InternalSwap(other); |
658 | 0 | } |
659 | 0 | void RemoteMethodPB::InternalSwap(RemoteMethodPB* other) { |
660 | 0 | using std::swap; |
661 | 0 | service_name_.Swap(&other->service_name_); |
662 | 0 | method_name_.Swap(&other->method_name_); |
663 | 0 | swap(_has_bits_[0], other->_has_bits_[0]); |
664 | 0 | _internal_metadata_.Swap(&other->_internal_metadata_); |
665 | 0 | swap(_cached_size_, other->_cached_size_); |
666 | 0 | } |
667 | | |
668 | 4 | ::google::protobuf::Metadata RemoteMethodPB::GetMetadata() const { |
669 | 4 | protobuf_yb_2frpc_2frpc_5fheader_2eproto::protobuf_AssignDescriptorsOnce(); |
670 | 4 | return ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::file_level_metadata[kIndexInFileMessages]; |
671 | 4 | } |
672 | | |
673 | | |
674 | | // =================================================================== |
675 | | |
676 | 17.2k | void RequestHeader::InitAsDefaultInstance() { |
677 | 17.2k | ::yb::rpc::_RequestHeader_default_instance_._instance.get_mutable()->remote_method_ = const_cast< ::yb::rpc::RemoteMethodPB*>( |
678 | 17.2k | ::yb::rpc::RemoteMethodPB::internal_default_instance()); |
679 | 17.2k | } |
680 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
681 | | const int RequestHeader::kCallIdFieldNumber; |
682 | | const int RequestHeader::kRemoteMethodFieldNumber; |
683 | | const int RequestHeader::kTimeoutMillisFieldNumber; |
684 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
685 | | |
686 | | RequestHeader::RequestHeader() |
687 | 1.61M | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
688 | 1.60M | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
689 | 1.60M | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::InitDefaultsRequestHeader(); |
690 | 1.60M | } |
691 | 1.61M | SharedCtor(); |
692 | | // @@protoc_insertion_point(constructor:yb.rpc.RequestHeader) |
693 | 1.61M | } |
694 | | RequestHeader::RequestHeader(const RequestHeader& from) |
695 | | : ::google::protobuf::Message(), |
696 | | _internal_metadata_(NULL), |
697 | | _has_bits_(from._has_bits_), |
698 | 0 | _cached_size_(0) { |
699 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
700 | 0 | if (from.has_remote_method()) { |
701 | 0 | remote_method_ = new ::yb::rpc::RemoteMethodPB(*from.remote_method_); |
702 | 0 | } else { |
703 | 0 | remote_method_ = NULL; |
704 | 0 | } |
705 | 0 | ::memcpy(&call_id_, &from.call_id_, |
706 | 0 | static_cast<size_t>(reinterpret_cast<char*>(&timeout_millis_) - |
707 | 0 | reinterpret_cast<char*>(&call_id_)) + sizeof(timeout_millis_)); |
708 | | // @@protoc_insertion_point(copy_constructor:yb.rpc.RequestHeader) |
709 | 0 | } |
710 | | |
711 | 1.61M | void RequestHeader::SharedCtor() { |
712 | 1.61M | _cached_size_ = 0; |
713 | 1.61M | ::memset(&remote_method_, 0, static_cast<size_t>( |
714 | 1.61M | reinterpret_cast<char*>(&timeout_millis_) - |
715 | 1.61M | reinterpret_cast<char*>(&remote_method_)) + sizeof(timeout_millis_)); |
716 | 1.61M | } |
717 | | |
718 | 1.60M | RequestHeader::~RequestHeader() { |
719 | | // @@protoc_insertion_point(destructor:yb.rpc.RequestHeader) |
720 | 1.60M | SharedDtor(); |
721 | 1.60M | } |
722 | | |
723 | 1.60M | void RequestHeader::SharedDtor() { |
724 | 1.60M | if (this != internal_default_instance()) delete remote_method_; |
725 | 1.60M | } |
726 | | |
727 | 0 | void RequestHeader::SetCachedSize(int size) const { |
728 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
729 | 0 | _cached_size_ = size; |
730 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
731 | 0 | } |
732 | 0 | const ::google::protobuf::Descriptor* RequestHeader::descriptor() { |
733 | 0 | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::protobuf_AssignDescriptorsOnce(); |
734 | 0 | return ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
735 | 0 | } |
736 | | |
737 | 0 | const RequestHeader& RequestHeader::default_instance() { |
738 | 0 | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::InitDefaultsRequestHeader(); |
739 | 0 | return *internal_default_instance(); |
740 | 0 | } |
741 | | |
742 | 0 | RequestHeader* RequestHeader::New(::google::protobuf::Arena* arena) const { |
743 | 0 | RequestHeader* n = new RequestHeader; |
744 | 0 | if (arena != NULL) { |
745 | 0 | arena->Own(n); |
746 | 0 | } |
747 | 0 | return n; |
748 | 0 | } |
749 | | |
750 | 1 | void RequestHeader::Clear() { |
751 | | // @@protoc_insertion_point(message_clear_start:yb.rpc.RequestHeader) |
752 | 1 | ::google::protobuf::uint32 cached_has_bits = 0; |
753 | | // Prevent compiler warnings about cached_has_bits being unused |
754 | 1 | (void) cached_has_bits; |
755 | | |
756 | 1 | cached_has_bits = _has_bits_[0]; |
757 | 1 | if (cached_has_bits & 0x00000001u) { |
758 | 1 | GOOGLE_DCHECK(remote_method_ != NULL); |
759 | 1 | remote_method_->Clear(); |
760 | 1 | } |
761 | 1 | if (cached_has_bits & 6u) { |
762 | 1 | ::memset(&call_id_, 0, static_cast<size_t>( |
763 | 1 | reinterpret_cast<char*>(&timeout_millis_) - |
764 | 1 | reinterpret_cast<char*>(&call_id_)) + sizeof(timeout_millis_)); |
765 | 1 | } |
766 | 1 | _has_bits_.Clear(); |
767 | 1 | _internal_metadata_.Clear(); |
768 | 1 | } |
769 | | |
770 | | bool RequestHeader::MergePartialFromCodedStream( |
771 | 0 | ::google::protobuf::io::CodedInputStream* input) { |
772 | 0 | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure |
773 | 0 | ::google::protobuf::uint32 tag; |
774 | | // @@protoc_insertion_point(parse_start:yb.rpc.RequestHeader) |
775 | 0 | for (;;) { |
776 | 0 | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
777 | 0 | tag = p.first; |
778 | 0 | if (!p.second) goto handle_unusual; |
779 | 0 | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
780 | | // optional int32 call_id = 1; |
781 | 0 | case 1: { |
782 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
783 | 0 | static_cast< ::google::protobuf::uint8>(8u /* 8 & 0xFF */)) { |
784 | 0 | set_has_call_id(); |
785 | 0 | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
786 | 0 | ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>( |
787 | 0 | input, &call_id_))); |
788 | 0 | } else { |
789 | 0 | goto handle_unusual; |
790 | 0 | } |
791 | 0 | break; |
792 | 0 | } |
793 | | |
794 | | // optional .yb.rpc.RemoteMethodPB remote_method = 2; |
795 | 0 | case 2: { |
796 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
797 | 0 | static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) { |
798 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
799 | 0 | input, mutable_remote_method())); |
800 | 0 | } else { |
801 | 0 | goto handle_unusual; |
802 | 0 | } |
803 | 0 | break; |
804 | 0 | } |
805 | | |
806 | | // optional uint32 timeout_millis = 3; |
807 | 0 | case 3: { |
808 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
809 | 0 | static_cast< ::google::protobuf::uint8>(24u /* 24 & 0xFF */)) { |
810 | 0 | set_has_timeout_millis(); |
811 | 0 | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
812 | 0 | ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>( |
813 | 0 | input, &timeout_millis_))); |
814 | 0 | } else { |
815 | 0 | goto handle_unusual; |
816 | 0 | } |
817 | 0 | break; |
818 | 0 | } |
819 | | |
820 | 0 | default: { |
821 | 0 | handle_unusual: |
822 | 0 | if (tag == 0) { |
823 | 0 | goto success; |
824 | 0 | } |
825 | 0 | DO_(::google::protobuf::internal::WireFormat::SkipField( |
826 | 0 | input, tag, _internal_metadata_.mutable_unknown_fields())); |
827 | 0 | break; |
828 | 0 | } |
829 | 0 | } |
830 | 0 | } |
831 | 0 | success: |
832 | | // @@protoc_insertion_point(parse_success:yb.rpc.RequestHeader) |
833 | 0 | return true; |
834 | 0 | failure: |
835 | | // @@protoc_insertion_point(parse_failure:yb.rpc.RequestHeader) |
836 | 0 | return false; |
837 | 0 | #undef DO_ |
838 | 0 | } |
839 | | |
840 | | void RequestHeader::SerializeWithCachedSizes( |
841 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
842 | | // @@protoc_insertion_point(serialize_start:yb.rpc.RequestHeader) |
843 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
844 | 0 | (void) cached_has_bits; |
845 | |
|
846 | 0 | cached_has_bits = _has_bits_[0]; |
847 | | // optional int32 call_id = 1; |
848 | 0 | if (cached_has_bits & 0x00000002u) { |
849 | 0 | ::google::protobuf::internal::WireFormatLite::WriteInt32(1, this->call_id(), output); |
850 | 0 | } |
851 | | |
852 | | // optional .yb.rpc.RemoteMethodPB remote_method = 2; |
853 | 0 | if (cached_has_bits & 0x00000001u) { |
854 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
855 | 0 | 2, *this->remote_method_, output); |
856 | 0 | } |
857 | | |
858 | | // optional uint32 timeout_millis = 3; |
859 | 0 | if (cached_has_bits & 0x00000004u) { |
860 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt32(3, this->timeout_millis(), output); |
861 | 0 | } |
862 | |
|
863 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
864 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
865 | 0 | _internal_metadata_.unknown_fields(), output); |
866 | 0 | } |
867 | | // @@protoc_insertion_point(serialize_end:yb.rpc.RequestHeader) |
868 | 0 | } |
869 | | |
870 | | ::google::protobuf::uint8* RequestHeader::InternalSerializeWithCachedSizesToArray( |
871 | 1.60M | bool deterministic, ::google::protobuf::uint8* target) const { |
872 | 1.60M | (void)deterministic; // Unused |
873 | | // @@protoc_insertion_point(serialize_to_array_start:yb.rpc.RequestHeader) |
874 | 1.60M | ::google::protobuf::uint32 cached_has_bits = 0; |
875 | 1.60M | (void) cached_has_bits; |
876 | | |
877 | 1.60M | cached_has_bits = _has_bits_[0]; |
878 | | // optional int32 call_id = 1; |
879 | 1.60M | if (cached_has_bits & 0x00000002u) { |
880 | 0 | target = ::google::protobuf::internal::WireFormatLite::WriteInt32ToArray(1, this->call_id(), target); |
881 | 0 | } |
882 | | |
883 | | // optional .yb.rpc.RemoteMethodPB remote_method = 2; |
884 | 1.60M | if (cached_has_bits & 0x00000001u) { |
885 | 1.60M | target = ::google::protobuf::internal::WireFormatLite:: |
886 | 1.60M | InternalWriteMessageToArray( |
887 | 1.60M | 2, *this->remote_method_, deterministic, target); |
888 | 1.60M | } |
889 | | |
890 | | // optional uint32 timeout_millis = 3; |
891 | 1.60M | if (cached_has_bits & 0x00000004u) { |
892 | 0 | target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(3, this->timeout_millis(), target); |
893 | 0 | } |
894 | | |
895 | 1.60M | if (_internal_metadata_.have_unknown_fields()) { |
896 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
897 | 0 | _internal_metadata_.unknown_fields(), target); |
898 | 0 | } |
899 | | // @@protoc_insertion_point(serialize_to_array_end:yb.rpc.RequestHeader) |
900 | 1.60M | return target; |
901 | 1.60M | } |
902 | | |
903 | 1.60M | size_t RequestHeader::ByteSizeLong() const { |
904 | | // @@protoc_insertion_point(message_byte_size_start:yb.rpc.RequestHeader) |
905 | 1.60M | size_t total_size = 0; |
906 | | |
907 | 1.60M | if (_internal_metadata_.have_unknown_fields()) { |
908 | 0 | total_size += |
909 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
910 | 0 | _internal_metadata_.unknown_fields()); |
911 | 0 | } |
912 | 1.60M | if (_has_bits_[0 / 32] & 7u) { |
913 | | // optional .yb.rpc.RemoteMethodPB remote_method = 2; |
914 | 1.60M | if (has_remote_method()) { |
915 | 1.60M | total_size += 1 + |
916 | 1.60M | ::google::protobuf::internal::WireFormatLite::MessageSize( |
917 | 1.60M | *this->remote_method_); |
918 | 1.60M | } |
919 | | |
920 | | // optional int32 call_id = 1; |
921 | 1.60M | if (has_call_id()) { |
922 | 0 | total_size += 1 + |
923 | 0 | ::google::protobuf::internal::WireFormatLite::Int32Size( |
924 | 0 | this->call_id()); |
925 | 0 | } |
926 | | |
927 | | // optional uint32 timeout_millis = 3; |
928 | 1.60M | if (has_timeout_millis()) { |
929 | 0 | total_size += 1 + |
930 | 0 | ::google::protobuf::internal::WireFormatLite::UInt32Size( |
931 | 0 | this->timeout_millis()); |
932 | 0 | } |
933 | | |
934 | 1.60M | } |
935 | 1.60M | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
936 | 1.60M | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
937 | 1.60M | _cached_size_ = cached_size; |
938 | 1.60M | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
939 | 1.60M | return total_size; |
940 | 1.60M | } |
941 | | |
942 | 0 | void RequestHeader::MergeFrom(const ::google::protobuf::Message& from) { |
943 | | // @@protoc_insertion_point(generalized_merge_from_start:yb.rpc.RequestHeader) |
944 | 0 | GOOGLE_DCHECK_NE(&from, this); |
945 | 0 | const RequestHeader* source = |
946 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const RequestHeader>( |
947 | 0 | &from); |
948 | 0 | if (source == NULL) { |
949 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.rpc.RequestHeader) |
950 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
951 | 0 | } else { |
952 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.rpc.RequestHeader) |
953 | 0 | MergeFrom(*source); |
954 | 0 | } |
955 | 0 | } |
956 | | |
957 | 0 | void RequestHeader::MergeFrom(const RequestHeader& from) { |
958 | | // @@protoc_insertion_point(class_specific_merge_from_start:yb.rpc.RequestHeader) |
959 | 0 | GOOGLE_DCHECK_NE(&from, this); |
960 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
961 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
962 | 0 | (void) cached_has_bits; |
963 | |
|
964 | 0 | cached_has_bits = from._has_bits_[0]; |
965 | 0 | if (cached_has_bits & 7u) { |
966 | 0 | if (cached_has_bits & 0x00000001u) { |
967 | 0 | mutable_remote_method()->::yb::rpc::RemoteMethodPB::MergeFrom(from.remote_method()); |
968 | 0 | } |
969 | 0 | if (cached_has_bits & 0x00000002u) { |
970 | 0 | call_id_ = from.call_id_; |
971 | 0 | } |
972 | 0 | if (cached_has_bits & 0x00000004u) { |
973 | 0 | timeout_millis_ = from.timeout_millis_; |
974 | 0 | } |
975 | 0 | _has_bits_[0] |= cached_has_bits; |
976 | 0 | } |
977 | 0 | } |
978 | | |
979 | 0 | void RequestHeader::CopyFrom(const ::google::protobuf::Message& from) { |
980 | | // @@protoc_insertion_point(generalized_copy_from_start:yb.rpc.RequestHeader) |
981 | 0 | if (&from == this) return; |
982 | 0 | Clear(); |
983 | 0 | MergeFrom(from); |
984 | 0 | } |
985 | | |
986 | 0 | void RequestHeader::CopyFrom(const RequestHeader& from) { |
987 | | // @@protoc_insertion_point(class_specific_copy_from_start:yb.rpc.RequestHeader) |
988 | 0 | if (&from == this) return; |
989 | 0 | Clear(); |
990 | 0 | MergeFrom(from); |
991 | 0 | } |
992 | | |
993 | 1.60M | bool RequestHeader::IsInitialized() const { |
994 | 1.60M | if (has_remote_method()) { |
995 | 1.60M | if (!this->remote_method_->IsInitialized()) return false; |
996 | 1.60M | } |
997 | 1.60M | return true; |
998 | 1.60M | } |
999 | | |
1000 | 0 | void RequestHeader::Swap(RequestHeader* other) { |
1001 | 0 | if (other == this) return; |
1002 | 0 | InternalSwap(other); |
1003 | 0 | } |
1004 | 0 | void RequestHeader::InternalSwap(RequestHeader* other) { |
1005 | 0 | using std::swap; |
1006 | 0 | swap(remote_method_, other->remote_method_); |
1007 | 0 | swap(call_id_, other->call_id_); |
1008 | 0 | swap(timeout_millis_, other->timeout_millis_); |
1009 | 0 | swap(_has_bits_[0], other->_has_bits_[0]); |
1010 | 0 | _internal_metadata_.Swap(&other->_internal_metadata_); |
1011 | 0 | swap(_cached_size_, other->_cached_size_); |
1012 | 0 | } |
1013 | | |
1014 | 4 | ::google::protobuf::Metadata RequestHeader::GetMetadata() const { |
1015 | 4 | protobuf_yb_2frpc_2frpc_5fheader_2eproto::protobuf_AssignDescriptorsOnce(); |
1016 | 4 | return ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::file_level_metadata[kIndexInFileMessages]; |
1017 | 4 | } |
1018 | | |
1019 | | |
1020 | | // =================================================================== |
1021 | | |
1022 | 17.2k | void ResponseHeader::InitAsDefaultInstance() { |
1023 | 17.2k | } |
1024 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
1025 | | const int ResponseHeader::kCallIdFieldNumber; |
1026 | | const int ResponseHeader::kIsErrorFieldNumber; |
1027 | | const int ResponseHeader::kSidecarOffsetsFieldNumber; |
1028 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
1029 | | |
1030 | | ResponseHeader::ResponseHeader() |
1031 | 64.7M | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
1032 | 64.6M | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
1033 | 64.6M | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::InitDefaultsResponseHeader(); |
1034 | 64.6M | } |
1035 | 64.7M | SharedCtor(); |
1036 | | // @@protoc_insertion_point(constructor:yb.rpc.ResponseHeader) |
1037 | 64.7M | } |
1038 | | ResponseHeader::ResponseHeader(const ResponseHeader& from) |
1039 | | : ::google::protobuf::Message(), |
1040 | | _internal_metadata_(NULL), |
1041 | | _has_bits_(from._has_bits_), |
1042 | | _cached_size_(0), |
1043 | 0 | sidecar_offsets_(from.sidecar_offsets_) { |
1044 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
1045 | 0 | ::memcpy(&call_id_, &from.call_id_, |
1046 | 0 | static_cast<size_t>(reinterpret_cast<char*>(&is_error_) - |
1047 | 0 | reinterpret_cast<char*>(&call_id_)) + sizeof(is_error_)); |
1048 | | // @@protoc_insertion_point(copy_constructor:yb.rpc.ResponseHeader) |
1049 | 0 | } |
1050 | | |
1051 | 64.6M | void ResponseHeader::SharedCtor() { |
1052 | 64.6M | _cached_size_ = 0; |
1053 | 64.6M | ::memset(&call_id_, 0, static_cast<size_t>( |
1054 | 64.6M | reinterpret_cast<char*>(&is_error_) - |
1055 | 64.6M | reinterpret_cast<char*>(&call_id_)) + sizeof(is_error_)); |
1056 | 64.6M | } |
1057 | | |
1058 | 64.6M | ResponseHeader::~ResponseHeader() { |
1059 | | // @@protoc_insertion_point(destructor:yb.rpc.ResponseHeader) |
1060 | 64.6M | SharedDtor(); |
1061 | 64.6M | } |
1062 | | |
1063 | 64.6M | void ResponseHeader::SharedDtor() { |
1064 | 64.6M | } |
1065 | | |
1066 | 0 | void ResponseHeader::SetCachedSize(int size) const { |
1067 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
1068 | 0 | _cached_size_ = size; |
1069 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1070 | 0 | } |
1071 | 0 | const ::google::protobuf::Descriptor* ResponseHeader::descriptor() { |
1072 | 0 | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::protobuf_AssignDescriptorsOnce(); |
1073 | 0 | return ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
1074 | 0 | } |
1075 | | |
1076 | 0 | const ResponseHeader& ResponseHeader::default_instance() { |
1077 | 0 | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::InitDefaultsResponseHeader(); |
1078 | 0 | return *internal_default_instance(); |
1079 | 0 | } |
1080 | | |
1081 | 0 | ResponseHeader* ResponseHeader::New(::google::protobuf::Arena* arena) const { |
1082 | 0 | ResponseHeader* n = new ResponseHeader; |
1083 | 0 | if (arena != NULL) { |
1084 | 0 | arena->Own(n); |
1085 | 0 | } |
1086 | 0 | return n; |
1087 | 0 | } |
1088 | | |
1089 | 19.5M | void ResponseHeader::Clear() { |
1090 | | // @@protoc_insertion_point(message_clear_start:yb.rpc.ResponseHeader) |
1091 | 19.5M | ::google::protobuf::uint32 cached_has_bits = 0; |
1092 | | // Prevent compiler warnings about cached_has_bits being unused |
1093 | 19.5M | (void) cached_has_bits; |
1094 | | |
1095 | 19.5M | sidecar_offsets_.Clear(); |
1096 | 19.5M | cached_has_bits = _has_bits_[0]; |
1097 | 19.5M | if (cached_has_bits & 3u) { |
1098 | 0 | ::memset(&call_id_, 0, static_cast<size_t>( |
1099 | 0 | reinterpret_cast<char*>(&is_error_) - |
1100 | 0 | reinterpret_cast<char*>(&call_id_)) + sizeof(is_error_)); |
1101 | 0 | } |
1102 | 19.5M | _has_bits_.Clear(); |
1103 | 19.5M | _internal_metadata_.Clear(); |
1104 | 19.5M | } |
1105 | | |
1106 | | bool ResponseHeader::MergePartialFromCodedStream( |
1107 | 19.4M | ::google::protobuf::io::CodedInputStream* input) { |
1108 | 41.0M | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure |
1109 | 19.4M | ::google::protobuf::uint32 tag; |
1110 | | // @@protoc_insertion_point(parse_start:yb.rpc.ResponseHeader) |
1111 | 60.5M | for (;;) { |
1112 | 60.5M | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
1113 | 60.5M | tag = p.first; |
1114 | 60.5M | if (!p.second) goto handle_unusual; |
1115 | 41.0M | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
1116 | | // required int32 call_id = 1; |
1117 | 19.4M | case 1: { |
1118 | 19.4M | if (static_cast< ::google::protobuf::uint8>(tag) == |
1119 | 19.4M | static_cast< ::google::protobuf::uint8>(8u /* 8 & 0xFF */)) { |
1120 | 19.4M | set_has_call_id(); |
1121 | 19.4M | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
1122 | 19.4M | ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>( |
1123 | 19.4M | input, &call_id_))); |
1124 | 18.4E | } else { |
1125 | 18.4E | goto handle_unusual; |
1126 | 18.4E | } |
1127 | 19.4M | break; |
1128 | 19.4M | } |
1129 | | |
1130 | | // optional bool is_error = 2 [default = false]; |
1131 | 19.5M | case 2: { |
1132 | 19.5M | if (static_cast< ::google::protobuf::uint8>(tag) == |
1133 | 19.5M | static_cast< ::google::protobuf::uint8>(16u /* 16 & 0xFF */)) { |
1134 | 19.5M | set_has_is_error(); |
1135 | 19.5M | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
1136 | 19.5M | bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>( |
1137 | 19.5M | input, &is_error_))); |
1138 | 18.4E | } else { |
1139 | 18.4E | goto handle_unusual; |
1140 | 18.4E | } |
1141 | 19.5M | break; |
1142 | 19.5M | } |
1143 | | |
1144 | | // repeated uint32 sidecar_offsets = 3; |
1145 | 2.10M | case 3: { |
1146 | 2.10M | if (static_cast< ::google::protobuf::uint8>(tag) == |
1147 | 2.10M | static_cast< ::google::protobuf::uint8>(24u /* 24 & 0xFF */)) { |
1148 | 2.10M | DO_((::google::protobuf::internal::WireFormatLite::ReadRepeatedPrimitive< |
1149 | 2.10M | ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>( |
1150 | 2.10M | 1, 24u, input, this->mutable_sidecar_offsets()))); |
1151 | 18.4E | } else if ( |
1152 | 18.4E | static_cast< ::google::protobuf::uint8>(tag) == |
1153 | 0 | static_cast< ::google::protobuf::uint8>(26u /* 26 & 0xFF */)) { |
1154 | 0 | DO_((::google::protobuf::internal::WireFormatLite::ReadPackedPrimitiveNoInline< |
1155 | 0 | ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>( |
1156 | 0 | input, this->mutable_sidecar_offsets()))); |
1157 | 18.4E | } else { |
1158 | 18.4E | goto handle_unusual; |
1159 | 18.4E | } |
1160 | 2.10M | break; |
1161 | 19.5M | } |
1162 | | |
1163 | 0 | default: { |
1164 | 19.5M | handle_unusual: |
1165 | 19.5M | if (tag == 0) { |
1166 | 19.5M | goto success; |
1167 | 19.5M | } |
1168 | 18.4E | DO_(::google::protobuf::internal::WireFormat::SkipField( |
1169 | 18.4E | input, tag, _internal_metadata_.mutable_unknown_fields())); |
1170 | 18.4E | break; |
1171 | 18.4E | } |
1172 | 41.0M | } |
1173 | 41.0M | } |
1174 | 19.5M | success: |
1175 | | // @@protoc_insertion_point(parse_success:yb.rpc.ResponseHeader) |
1176 | 19.5M | return true; |
1177 | 0 | failure: |
1178 | | // @@protoc_insertion_point(parse_failure:yb.rpc.ResponseHeader) |
1179 | 0 | return false; |
1180 | 19.4M | #undef DO_ |
1181 | 19.4M | } |
1182 | | |
1183 | | void ResponseHeader::SerializeWithCachedSizes( |
1184 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
1185 | | // @@protoc_insertion_point(serialize_start:yb.rpc.ResponseHeader) |
1186 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1187 | 0 | (void) cached_has_bits; |
1188 | |
|
1189 | 0 | cached_has_bits = _has_bits_[0]; |
1190 | | // required int32 call_id = 1; |
1191 | 0 | if (cached_has_bits & 0x00000001u) { |
1192 | 0 | ::google::protobuf::internal::WireFormatLite::WriteInt32(1, this->call_id(), output); |
1193 | 0 | } |
1194 | | |
1195 | | // optional bool is_error = 2 [default = false]; |
1196 | 0 | if (cached_has_bits & 0x00000002u) { |
1197 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBool(2, this->is_error(), output); |
1198 | 0 | } |
1199 | | |
1200 | | // repeated uint32 sidecar_offsets = 3; |
1201 | 0 | for (int i = 0, n = this->sidecar_offsets_size(); i < n; i++) { |
1202 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt32( |
1203 | 0 | 3, this->sidecar_offsets(i), output); |
1204 | 0 | } |
1205 | |
|
1206 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
1207 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
1208 | 0 | _internal_metadata_.unknown_fields(), output); |
1209 | 0 | } |
1210 | | // @@protoc_insertion_point(serialize_end:yb.rpc.ResponseHeader) |
1211 | 0 | } |
1212 | | |
1213 | | ::google::protobuf::uint8* ResponseHeader::InternalSerializeWithCachedSizesToArray( |
1214 | 19.5M | bool deterministic, ::google::protobuf::uint8* target) const { |
1215 | 19.5M | (void)deterministic; // Unused |
1216 | | // @@protoc_insertion_point(serialize_to_array_start:yb.rpc.ResponseHeader) |
1217 | 19.5M | ::google::protobuf::uint32 cached_has_bits = 0; |
1218 | 19.5M | (void) cached_has_bits; |
1219 | | |
1220 | 19.5M | cached_has_bits = _has_bits_[0]; |
1221 | | // required int32 call_id = 1; |
1222 | 19.5M | if (cached_has_bits & 0x00000001u) { |
1223 | 19.5M | target = ::google::protobuf::internal::WireFormatLite::WriteInt32ToArray(1, this->call_id(), target); |
1224 | 19.5M | } |
1225 | | |
1226 | | // optional bool is_error = 2 [default = false]; |
1227 | 19.5M | if (cached_has_bits & 0x00000002u) { |
1228 | 19.5M | target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(2, this->is_error(), target); |
1229 | 19.5M | } |
1230 | | |
1231 | | // repeated uint32 sidecar_offsets = 3; |
1232 | 19.5M | target = ::google::protobuf::internal::WireFormatLite:: |
1233 | 19.5M | WriteUInt32ToArray(3, this->sidecar_offsets_, target); |
1234 | | |
1235 | 19.5M | if (_internal_metadata_.have_unknown_fields()) { |
1236 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
1237 | 0 | _internal_metadata_.unknown_fields(), target); |
1238 | 0 | } |
1239 | | // @@protoc_insertion_point(serialize_to_array_end:yb.rpc.ResponseHeader) |
1240 | 19.5M | return target; |
1241 | 19.5M | } |
1242 | | |
1243 | 19.5M | size_t ResponseHeader::ByteSizeLong() const { |
1244 | | // @@protoc_insertion_point(message_byte_size_start:yb.rpc.ResponseHeader) |
1245 | 19.5M | size_t total_size = 0; |
1246 | | |
1247 | 19.5M | if (_internal_metadata_.have_unknown_fields()) { |
1248 | 0 | total_size += |
1249 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
1250 | 0 | _internal_metadata_.unknown_fields()); |
1251 | 0 | } |
1252 | | // required int32 call_id = 1; |
1253 | 19.5M | if (has_call_id()) { |
1254 | 19.5M | total_size += 1 + |
1255 | 19.5M | ::google::protobuf::internal::WireFormatLite::Int32Size( |
1256 | 19.5M | this->call_id()); |
1257 | 19.5M | } |
1258 | | // repeated uint32 sidecar_offsets = 3; |
1259 | 19.5M | { |
1260 | 19.5M | size_t data_size = ::google::protobuf::internal::WireFormatLite:: |
1261 | 19.5M | UInt32Size(this->sidecar_offsets_); |
1262 | 19.5M | total_size += 1 * |
1263 | 19.5M | ::google::protobuf::internal::FromIntSize(this->sidecar_offsets_size()); |
1264 | 19.5M | total_size += data_size; |
1265 | 19.5M | } |
1266 | | |
1267 | | // optional bool is_error = 2 [default = false]; |
1268 | 19.5M | if (has_is_error()) { |
1269 | 19.5M | total_size += 1 + 1; |
1270 | 19.5M | } |
1271 | | |
1272 | 19.5M | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
1273 | 19.5M | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
1274 | 19.5M | _cached_size_ = cached_size; |
1275 | 19.5M | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1276 | 19.5M | return total_size; |
1277 | 19.5M | } |
1278 | | |
1279 | 0 | void ResponseHeader::MergeFrom(const ::google::protobuf::Message& from) { |
1280 | | // @@protoc_insertion_point(generalized_merge_from_start:yb.rpc.ResponseHeader) |
1281 | 0 | GOOGLE_DCHECK_NE(&from, this); |
1282 | 0 | const ResponseHeader* source = |
1283 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const ResponseHeader>( |
1284 | 0 | &from); |
1285 | 0 | if (source == NULL) { |
1286 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.rpc.ResponseHeader) |
1287 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
1288 | 0 | } else { |
1289 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.rpc.ResponseHeader) |
1290 | 0 | MergeFrom(*source); |
1291 | 0 | } |
1292 | 0 | } |
1293 | | |
1294 | 0 | void ResponseHeader::MergeFrom(const ResponseHeader& from) { |
1295 | | // @@protoc_insertion_point(class_specific_merge_from_start:yb.rpc.ResponseHeader) |
1296 | 0 | GOOGLE_DCHECK_NE(&from, this); |
1297 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
1298 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1299 | 0 | (void) cached_has_bits; |
1300 | |
|
1301 | 0 | sidecar_offsets_.MergeFrom(from.sidecar_offsets_); |
1302 | 0 | cached_has_bits = from._has_bits_[0]; |
1303 | 0 | if (cached_has_bits & 3u) { |
1304 | 0 | if (cached_has_bits & 0x00000001u) { |
1305 | 0 | call_id_ = from.call_id_; |
1306 | 0 | } |
1307 | 0 | if (cached_has_bits & 0x00000002u) { |
1308 | 0 | is_error_ = from.is_error_; |
1309 | 0 | } |
1310 | 0 | _has_bits_[0] |= cached_has_bits; |
1311 | 0 | } |
1312 | 0 | } |
1313 | | |
1314 | 0 | void ResponseHeader::CopyFrom(const ::google::protobuf::Message& from) { |
1315 | | // @@protoc_insertion_point(generalized_copy_from_start:yb.rpc.ResponseHeader) |
1316 | 0 | if (&from == this) return; |
1317 | 0 | Clear(); |
1318 | 0 | MergeFrom(from); |
1319 | 0 | } |
1320 | | |
1321 | 0 | void ResponseHeader::CopyFrom(const ResponseHeader& from) { |
1322 | | // @@protoc_insertion_point(class_specific_copy_from_start:yb.rpc.ResponseHeader) |
1323 | 0 | if (&from == this) return; |
1324 | 0 | Clear(); |
1325 | 0 | MergeFrom(from); |
1326 | 0 | } |
1327 | | |
1328 | 39.1M | bool ResponseHeader::IsInitialized() const { |
1329 | 39.1M | if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false; |
1330 | 39.1M | return true; |
1331 | 39.1M | } |
1332 | | |
1333 | 0 | void ResponseHeader::Swap(ResponseHeader* other) { |
1334 | 0 | if (other == this) return; |
1335 | 0 | InternalSwap(other); |
1336 | 0 | } |
1337 | 19.5M | void ResponseHeader::InternalSwap(ResponseHeader* other) { |
1338 | 19.5M | using std::swap; |
1339 | 19.5M | sidecar_offsets_.InternalSwap(&other->sidecar_offsets_); |
1340 | 19.5M | swap(call_id_, other->call_id_); |
1341 | 19.5M | swap(is_error_, other->is_error_); |
1342 | 19.5M | swap(_has_bits_[0], other->_has_bits_[0]); |
1343 | 19.5M | _internal_metadata_.Swap(&other->_internal_metadata_); |
1344 | 19.5M | swap(_cached_size_, other->_cached_size_); |
1345 | 19.5M | } |
1346 | | |
1347 | 19.5M | ::google::protobuf::Metadata ResponseHeader::GetMetadata() const { |
1348 | 19.5M | protobuf_yb_2frpc_2frpc_5fheader_2eproto::protobuf_AssignDescriptorsOnce(); |
1349 | 19.5M | return ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::file_level_metadata[kIndexInFileMessages]; |
1350 | 19.5M | } |
1351 | | |
1352 | | |
1353 | | // =================================================================== |
1354 | | |
1355 | 17.2k | void EmptyMessagePB::InitAsDefaultInstance() { |
1356 | 17.2k | } |
1357 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
1358 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
1359 | | |
1360 | | EmptyMessagePB::EmptyMessagePB() |
1361 | 17.2k | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
1362 | 0 | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
1363 | 0 | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::InitDefaultsEmptyMessagePB(); |
1364 | 0 | } |
1365 | 17.2k | SharedCtor(); |
1366 | | // @@protoc_insertion_point(constructor:yb.rpc.EmptyMessagePB) |
1367 | 17.2k | } |
1368 | | EmptyMessagePB::EmptyMessagePB(const EmptyMessagePB& from) |
1369 | | : ::google::protobuf::Message(), |
1370 | | _internal_metadata_(NULL), |
1371 | | _has_bits_(from._has_bits_), |
1372 | 0 | _cached_size_(0) { |
1373 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
1374 | | // @@protoc_insertion_point(copy_constructor:yb.rpc.EmptyMessagePB) |
1375 | 0 | } |
1376 | | |
1377 | 17.2k | void EmptyMessagePB::SharedCtor() { |
1378 | 17.2k | _cached_size_ = 0; |
1379 | 17.2k | } |
1380 | | |
1381 | 0 | EmptyMessagePB::~EmptyMessagePB() { |
1382 | | // @@protoc_insertion_point(destructor:yb.rpc.EmptyMessagePB) |
1383 | 0 | SharedDtor(); |
1384 | 0 | } |
1385 | | |
1386 | 0 | void EmptyMessagePB::SharedDtor() { |
1387 | 0 | } |
1388 | | |
1389 | 0 | void EmptyMessagePB::SetCachedSize(int size) const { |
1390 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
1391 | 0 | _cached_size_ = size; |
1392 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1393 | 0 | } |
1394 | 0 | const ::google::protobuf::Descriptor* EmptyMessagePB::descriptor() { |
1395 | 0 | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::protobuf_AssignDescriptorsOnce(); |
1396 | 0 | return ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
1397 | 0 | } |
1398 | | |
1399 | 0 | const EmptyMessagePB& EmptyMessagePB::default_instance() { |
1400 | 0 | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::InitDefaultsEmptyMessagePB(); |
1401 | 0 | return *internal_default_instance(); |
1402 | 0 | } |
1403 | | |
1404 | 0 | EmptyMessagePB* EmptyMessagePB::New(::google::protobuf::Arena* arena) const { |
1405 | 0 | EmptyMessagePB* n = new EmptyMessagePB; |
1406 | 0 | if (arena != NULL) { |
1407 | 0 | arena->Own(n); |
1408 | 0 | } |
1409 | 0 | return n; |
1410 | 0 | } |
1411 | | |
1412 | 0 | void EmptyMessagePB::Clear() { |
1413 | | // @@protoc_insertion_point(message_clear_start:yb.rpc.EmptyMessagePB) |
1414 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1415 | | // Prevent compiler warnings about cached_has_bits being unused |
1416 | 0 | (void) cached_has_bits; |
1417 | |
|
1418 | 0 | _has_bits_.Clear(); |
1419 | 0 | _internal_metadata_.Clear(); |
1420 | 0 | } |
1421 | | |
1422 | | bool EmptyMessagePB::MergePartialFromCodedStream( |
1423 | 0 | ::google::protobuf::io::CodedInputStream* input) { |
1424 | 0 | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure |
1425 | 0 | ::google::protobuf::uint32 tag; |
1426 | | // @@protoc_insertion_point(parse_start:yb.rpc.EmptyMessagePB) |
1427 | 0 | for (;;) { |
1428 | 0 | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
1429 | 0 | tag = p.first; |
1430 | 0 | if (!p.second) goto handle_unusual; |
1431 | 0 | handle_unusual: |
1432 | 0 | if (tag == 0) { |
1433 | 0 | goto success; |
1434 | 0 | } |
1435 | 0 | DO_(::google::protobuf::internal::WireFormat::SkipField( |
1436 | 0 | input, tag, _internal_metadata_.mutable_unknown_fields())); |
1437 | 0 | } |
1438 | 0 | success: |
1439 | | // @@protoc_insertion_point(parse_success:yb.rpc.EmptyMessagePB) |
1440 | 0 | return true; |
1441 | 0 | failure: |
1442 | | // @@protoc_insertion_point(parse_failure:yb.rpc.EmptyMessagePB) |
1443 | 0 | return false; |
1444 | 0 | #undef DO_ |
1445 | 0 | } |
1446 | | |
1447 | | void EmptyMessagePB::SerializeWithCachedSizes( |
1448 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
1449 | | // @@protoc_insertion_point(serialize_start:yb.rpc.EmptyMessagePB) |
1450 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1451 | 0 | (void) cached_has_bits; |
1452 | |
|
1453 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
1454 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
1455 | 0 | _internal_metadata_.unknown_fields(), output); |
1456 | 0 | } |
1457 | | // @@protoc_insertion_point(serialize_end:yb.rpc.EmptyMessagePB) |
1458 | 0 | } |
1459 | | |
1460 | | ::google::protobuf::uint8* EmptyMessagePB::InternalSerializeWithCachedSizesToArray( |
1461 | 0 | bool deterministic, ::google::protobuf::uint8* target) const { |
1462 | 0 | (void)deterministic; // Unused |
1463 | | // @@protoc_insertion_point(serialize_to_array_start:yb.rpc.EmptyMessagePB) |
1464 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1465 | 0 | (void) cached_has_bits; |
1466 | |
|
1467 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
1468 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
1469 | 0 | _internal_metadata_.unknown_fields(), target); |
1470 | 0 | } |
1471 | | // @@protoc_insertion_point(serialize_to_array_end:yb.rpc.EmptyMessagePB) |
1472 | 0 | return target; |
1473 | 0 | } |
1474 | | |
1475 | 0 | size_t EmptyMessagePB::ByteSizeLong() const { |
1476 | | // @@protoc_insertion_point(message_byte_size_start:yb.rpc.EmptyMessagePB) |
1477 | 0 | size_t total_size = 0; |
1478 | |
|
1479 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
1480 | 0 | total_size += |
1481 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
1482 | 0 | _internal_metadata_.unknown_fields()); |
1483 | 0 | } |
1484 | 0 | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
1485 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
1486 | 0 | _cached_size_ = cached_size; |
1487 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1488 | 0 | return total_size; |
1489 | 0 | } |
1490 | | |
1491 | 0 | void EmptyMessagePB::MergeFrom(const ::google::protobuf::Message& from) { |
1492 | | // @@protoc_insertion_point(generalized_merge_from_start:yb.rpc.EmptyMessagePB) |
1493 | 0 | GOOGLE_DCHECK_NE(&from, this); |
1494 | 0 | const EmptyMessagePB* source = |
1495 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const EmptyMessagePB>( |
1496 | 0 | &from); |
1497 | 0 | if (source == NULL) { |
1498 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.rpc.EmptyMessagePB) |
1499 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
1500 | 0 | } else { |
1501 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.rpc.EmptyMessagePB) |
1502 | 0 | MergeFrom(*source); |
1503 | 0 | } |
1504 | 0 | } |
1505 | | |
1506 | 0 | void EmptyMessagePB::MergeFrom(const EmptyMessagePB& from) { |
1507 | | // @@protoc_insertion_point(class_specific_merge_from_start:yb.rpc.EmptyMessagePB) |
1508 | 0 | GOOGLE_DCHECK_NE(&from, this); |
1509 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
1510 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1511 | 0 | (void) cached_has_bits; |
1512 | |
|
1513 | 0 | } |
1514 | | |
1515 | 0 | void EmptyMessagePB::CopyFrom(const ::google::protobuf::Message& from) { |
1516 | | // @@protoc_insertion_point(generalized_copy_from_start:yb.rpc.EmptyMessagePB) |
1517 | 0 | if (&from == this) return; |
1518 | 0 | Clear(); |
1519 | 0 | MergeFrom(from); |
1520 | 0 | } |
1521 | | |
1522 | 0 | void EmptyMessagePB::CopyFrom(const EmptyMessagePB& from) { |
1523 | | // @@protoc_insertion_point(class_specific_copy_from_start:yb.rpc.EmptyMessagePB) |
1524 | 0 | if (&from == this) return; |
1525 | 0 | Clear(); |
1526 | 0 | MergeFrom(from); |
1527 | 0 | } |
1528 | | |
1529 | 0 | bool EmptyMessagePB::IsInitialized() const { |
1530 | 0 | return true; |
1531 | 0 | } |
1532 | | |
1533 | 0 | void EmptyMessagePB::Swap(EmptyMessagePB* other) { |
1534 | 0 | if (other == this) return; |
1535 | 0 | InternalSwap(other); |
1536 | 0 | } |
1537 | 0 | void EmptyMessagePB::InternalSwap(EmptyMessagePB* other) { |
1538 | 0 | using std::swap; |
1539 | 0 | swap(_has_bits_[0], other->_has_bits_[0]); |
1540 | 0 | _internal_metadata_.Swap(&other->_internal_metadata_); |
1541 | 0 | swap(_cached_size_, other->_cached_size_); |
1542 | 0 | } |
1543 | | |
1544 | 0 | ::google::protobuf::Metadata EmptyMessagePB::GetMetadata() const { |
1545 | 0 | protobuf_yb_2frpc_2frpc_5fheader_2eproto::protobuf_AssignDescriptorsOnce(); |
1546 | 0 | return ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::file_level_metadata[kIndexInFileMessages]; |
1547 | 0 | } |
1548 | | |
1549 | | |
1550 | | // =================================================================== |
1551 | | |
1552 | 17.2k | void ErrorStatusPB::InitAsDefaultInstance() { |
1553 | 17.2k | } |
1554 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
1555 | | const int ErrorStatusPB::kMessageFieldNumber; |
1556 | | const int ErrorStatusPB::kCodeFieldNumber; |
1557 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
1558 | | |
1559 | | ErrorStatusPB::ErrorStatusPB() |
1560 | 21.8k | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
1561 | 4.62k | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
1562 | 4.62k | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::InitDefaultsErrorStatusPB(); |
1563 | 4.62k | } |
1564 | 21.8k | SharedCtor(); |
1565 | | // @@protoc_insertion_point(constructor:yb.rpc.ErrorStatusPB) |
1566 | 21.8k | } |
1567 | | ErrorStatusPB::ErrorStatusPB(const ErrorStatusPB& from) |
1568 | | : ::google::protobuf::Message(), |
1569 | | _internal_metadata_(NULL), |
1570 | | _has_bits_(from._has_bits_), |
1571 | 18 | _cached_size_(0) { |
1572 | 18 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
1573 | 18 | _extensions_.MergeFrom(from._extensions_); |
1574 | 18 | message_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1575 | 18 | if (from.has_message()) { |
1576 | 18 | message_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.message_); |
1577 | 18 | } |
1578 | 18 | code_ = from.code_; |
1579 | | // @@protoc_insertion_point(copy_constructor:yb.rpc.ErrorStatusPB) |
1580 | 18 | } |
1581 | | |
1582 | 21.8k | void ErrorStatusPB::SharedCtor() { |
1583 | 21.8k | _cached_size_ = 0; |
1584 | 21.8k | message_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1585 | 21.8k | code_ = 10; |
1586 | 21.8k | } |
1587 | | |
1588 | 4.64k | ErrorStatusPB::~ErrorStatusPB() { |
1589 | | // @@protoc_insertion_point(destructor:yb.rpc.ErrorStatusPB) |
1590 | 4.64k | SharedDtor(); |
1591 | 4.64k | } |
1592 | | |
1593 | 4.64k | void ErrorStatusPB::SharedDtor() { |
1594 | 4.64k | message_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1595 | 4.64k | } |
1596 | | |
1597 | 0 | void ErrorStatusPB::SetCachedSize(int size) const { |
1598 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
1599 | 0 | _cached_size_ = size; |
1600 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1601 | 0 | } |
1602 | 0 | const ::google::protobuf::Descriptor* ErrorStatusPB::descriptor() { |
1603 | 0 | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::protobuf_AssignDescriptorsOnce(); |
1604 | 0 | return ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
1605 | 0 | } |
1606 | | |
1607 | 15.9k | const ErrorStatusPB& ErrorStatusPB::default_instance() { |
1608 | 15.9k | ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::InitDefaultsErrorStatusPB(); |
1609 | 15.9k | return *internal_default_instance(); |
1610 | 15.9k | } |
1611 | | |
1612 | 0 | ErrorStatusPB* ErrorStatusPB::New(::google::protobuf::Arena* arena) const { |
1613 | 0 | ErrorStatusPB* n = new ErrorStatusPB; |
1614 | 0 | if (arena != NULL) { |
1615 | 0 | arena->Own(n); |
1616 | 0 | } |
1617 | 0 | return n; |
1618 | 0 | } |
1619 | | |
1620 | 2.28k | void ErrorStatusPB::Clear() { |
1621 | | // @@protoc_insertion_point(message_clear_start:yb.rpc.ErrorStatusPB) |
1622 | 2.28k | ::google::protobuf::uint32 cached_has_bits = 0; |
1623 | | // Prevent compiler warnings about cached_has_bits being unused |
1624 | 2.28k | (void) cached_has_bits; |
1625 | | |
1626 | 2.28k | _extensions_.Clear(); |
1627 | 2.28k | cached_has_bits = _has_bits_[0]; |
1628 | 2.28k | if (cached_has_bits & 3u) { |
1629 | 0 | if (cached_has_bits & 0x00000001u) { |
1630 | 0 | GOOGLE_DCHECK(!message_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
1631 | 0 | (*message_.UnsafeRawStringPointer())->clear(); |
1632 | 0 | } |
1633 | 0 | code_ = 10; |
1634 | 0 | } |
1635 | 2.28k | _has_bits_.Clear(); |
1636 | 2.28k | _internal_metadata_.Clear(); |
1637 | 2.28k | } |
1638 | | |
1639 | | bool ErrorStatusPB::MergePartialFromCodedStream( |
1640 | 2.28k | ::google::protobuf::io::CodedInputStream* input) { |
1641 | 4.56k | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure |
1642 | 2.28k | ::google::protobuf::uint32 tag; |
1643 | | // @@protoc_insertion_point(parse_start:yb.rpc.ErrorStatusPB) |
1644 | 6.84k | for (;;) { |
1645 | 6.84k | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
1646 | 6.84k | tag = p.first; |
1647 | 6.84k | if (!p.second) goto handle_unusual; |
1648 | 3.53k | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
1649 | | // required string message = 1; |
1650 | 2.28k | case 1: { |
1651 | 2.28k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1652 | 2.28k | static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) { |
1653 | 2.28k | DO_(::google::protobuf::internal::WireFormatLite::ReadString( |
1654 | 2.28k | input, this->mutable_message())); |
1655 | 2.28k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
1656 | 2.28k | this->message().data(), static_cast<int>(this->message().length()), |
1657 | 2.28k | ::google::protobuf::internal::WireFormat::PARSE, |
1658 | 2.28k | "yb.rpc.ErrorStatusPB.message"); |
1659 | 0 | } else { |
1660 | 0 | goto handle_unusual; |
1661 | 0 | } |
1662 | 2.28k | break; |
1663 | 2.28k | } |
1664 | | |
1665 | | // optional .yb.rpc.ErrorStatusPB.RpcErrorCodePB code = 2; |
1666 | 1.25k | case 2: { |
1667 | 1.25k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1668 | 1.25k | static_cast< ::google::protobuf::uint8>(16u /* 16 & 0xFF */)) { |
1669 | 1.25k | int value; |
1670 | 1.25k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
1671 | 1.25k | int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>( |
1672 | 1.25k | input, &value))); |
1673 | 1.25k | if (::yb::rpc::ErrorStatusPB_RpcErrorCodePB_IsValid(value)) { |
1674 | 1.25k | set_code(static_cast< ::yb::rpc::ErrorStatusPB_RpcErrorCodePB >(value)); |
1675 | 0 | } else { |
1676 | 0 | mutable_unknown_fields()->AddVarint( |
1677 | 0 | 2, static_cast< ::google::protobuf::uint64>(value)); |
1678 | 0 | } |
1679 | 0 | } else { |
1680 | 0 | goto handle_unusual; |
1681 | 0 | } |
1682 | 1.25k | break; |
1683 | 3.30k | } |
1684 | | |
1685 | 0 | default: { |
1686 | 3.30k | handle_unusual: |
1687 | 3.30k | if (tag == 0) { |
1688 | 2.28k | goto success; |
1689 | 2.28k | } |
1690 | 1.02k | if ((800u <= tag)) { |
1691 | 1.02k | DO_(_extensions_.ParseField(tag, input, |
1692 | 1.02k | internal_default_instance(), |
1693 | 1.02k | _internal_metadata_.mutable_unknown_fields())); |
1694 | 1.02k | continue; |
1695 | 18.4E | } |
1696 | 18.4E | DO_(::google::protobuf::internal::WireFormat::SkipField( |
1697 | 18.4E | input, tag, _internal_metadata_.mutable_unknown_fields())); |
1698 | 18.4E | break; |
1699 | 18.4E | } |
1700 | 3.53k | } |
1701 | 3.53k | } |
1702 | 2.28k | success: |
1703 | | // @@protoc_insertion_point(parse_success:yb.rpc.ErrorStatusPB) |
1704 | 2.28k | return true; |
1705 | 0 | failure: |
1706 | | // @@protoc_insertion_point(parse_failure:yb.rpc.ErrorStatusPB) |
1707 | 0 | return false; |
1708 | 2.28k | #undef DO_ |
1709 | 2.28k | } |
1710 | | |
1711 | | void ErrorStatusPB::SerializeWithCachedSizes( |
1712 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
1713 | | // @@protoc_insertion_point(serialize_start:yb.rpc.ErrorStatusPB) |
1714 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1715 | 0 | (void) cached_has_bits; |
1716 | |
|
1717 | 0 | cached_has_bits = _has_bits_[0]; |
1718 | | // required string message = 1; |
1719 | 0 | if (cached_has_bits & 0x00000001u) { |
1720 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
1721 | 0 | this->message().data(), static_cast<int>(this->message().length()), |
1722 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
1723 | 0 | "yb.rpc.ErrorStatusPB.message"); |
1724 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( |
1725 | 0 | 1, this->message(), output); |
1726 | 0 | } |
1727 | | |
1728 | | // optional .yb.rpc.ErrorStatusPB.RpcErrorCodePB code = 2; |
1729 | 0 | if (cached_has_bits & 0x00000002u) { |
1730 | 0 | ::google::protobuf::internal::WireFormatLite::WriteEnum( |
1731 | 0 | 2, this->code(), output); |
1732 | 0 | } |
1733 | | |
1734 | | // Extension range [100, 536870912) |
1735 | 0 | _extensions_.SerializeWithCachedSizes( |
1736 | 0 | 100, 536870912, output); |
1737 | |
|
1738 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
1739 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
1740 | 0 | _internal_metadata_.unknown_fields(), output); |
1741 | 0 | } |
1742 | | // @@protoc_insertion_point(serialize_end:yb.rpc.ErrorStatusPB) |
1743 | 0 | } |
1744 | | |
1745 | | ::google::protobuf::uint8* ErrorStatusPB::InternalSerializeWithCachedSizesToArray( |
1746 | 2.32k | bool deterministic, ::google::protobuf::uint8* target) const { |
1747 | 2.32k | (void)deterministic; // Unused |
1748 | | // @@protoc_insertion_point(serialize_to_array_start:yb.rpc.ErrorStatusPB) |
1749 | 2.32k | ::google::protobuf::uint32 cached_has_bits = 0; |
1750 | 2.32k | (void) cached_has_bits; |
1751 | | |
1752 | 2.32k | cached_has_bits = _has_bits_[0]; |
1753 | | // required string message = 1; |
1754 | 2.32k | if (cached_has_bits & 0x00000001u) { |
1755 | 2.32k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
1756 | 2.32k | this->message().data(), static_cast<int>(this->message().length()), |
1757 | 2.32k | ::google::protobuf::internal::WireFormat::SERIALIZE, |
1758 | 2.32k | "yb.rpc.ErrorStatusPB.message"); |
1759 | 2.32k | target = |
1760 | 2.32k | ::google::protobuf::internal::WireFormatLite::WriteStringToArray( |
1761 | 2.32k | 1, this->message(), target); |
1762 | 2.32k | } |
1763 | | |
1764 | | // optional .yb.rpc.ErrorStatusPB.RpcErrorCodePB code = 2; |
1765 | 2.32k | if (cached_has_bits & 0x00000002u) { |
1766 | 1.29k | target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray( |
1767 | 1.29k | 2, this->code(), target); |
1768 | 1.29k | } |
1769 | | |
1770 | | // Extension range [100, 536870912) |
1771 | 2.32k | target = _extensions_.InternalSerializeWithCachedSizesToArray( |
1772 | 2.32k | 100, 536870912, deterministic, target); |
1773 | | |
1774 | 2.32k | if (_internal_metadata_.have_unknown_fields()) { |
1775 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
1776 | 0 | _internal_metadata_.unknown_fields(), target); |
1777 | 0 | } |
1778 | | // @@protoc_insertion_point(serialize_to_array_end:yb.rpc.ErrorStatusPB) |
1779 | 2.32k | return target; |
1780 | 2.32k | } |
1781 | | |
1782 | 4.65k | size_t ErrorStatusPB::ByteSizeLong() const { |
1783 | | // @@protoc_insertion_point(message_byte_size_start:yb.rpc.ErrorStatusPB) |
1784 | 4.65k | size_t total_size = 0; |
1785 | | |
1786 | 4.65k | total_size += _extensions_.ByteSize(); |
1787 | | |
1788 | 4.65k | if (_internal_metadata_.have_unknown_fields()) { |
1789 | 0 | total_size += |
1790 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
1791 | 0 | _internal_metadata_.unknown_fields()); |
1792 | 0 | } |
1793 | | // required string message = 1; |
1794 | 4.65k | if (has_message()) { |
1795 | 4.64k | total_size += 1 + |
1796 | 4.64k | ::google::protobuf::internal::WireFormatLite::StringSize( |
1797 | 4.64k | this->message()); |
1798 | 4.64k | } |
1799 | | // optional .yb.rpc.ErrorStatusPB.RpcErrorCodePB code = 2; |
1800 | 4.65k | if (has_code()) { |
1801 | 2.58k | total_size += 1 + |
1802 | 2.58k | ::google::protobuf::internal::WireFormatLite::EnumSize(this->code()); |
1803 | 2.58k | } |
1804 | | |
1805 | 4.65k | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
1806 | 4.65k | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
1807 | 4.65k | _cached_size_ = cached_size; |
1808 | 4.65k | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1809 | 4.65k | return total_size; |
1810 | 4.65k | } |
1811 | | |
1812 | 0 | void ErrorStatusPB::MergeFrom(const ::google::protobuf::Message& from) { |
1813 | | // @@protoc_insertion_point(generalized_merge_from_start:yb.rpc.ErrorStatusPB) |
1814 | 0 | GOOGLE_DCHECK_NE(&from, this); |
1815 | 0 | const ErrorStatusPB* source = |
1816 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const ErrorStatusPB>( |
1817 | 0 | &from); |
1818 | 0 | if (source == NULL) { |
1819 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.rpc.ErrorStatusPB) |
1820 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
1821 | 0 | } else { |
1822 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.rpc.ErrorStatusPB) |
1823 | 0 | MergeFrom(*source); |
1824 | 0 | } |
1825 | 0 | } |
1826 | | |
1827 | 0 | void ErrorStatusPB::MergeFrom(const ErrorStatusPB& from) { |
1828 | | // @@protoc_insertion_point(class_specific_merge_from_start:yb.rpc.ErrorStatusPB) |
1829 | 0 | GOOGLE_DCHECK_NE(&from, this); |
1830 | 0 | _extensions_.MergeFrom(from._extensions_); |
1831 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
1832 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1833 | 0 | (void) cached_has_bits; |
1834 | |
|
1835 | 0 | cached_has_bits = from._has_bits_[0]; |
1836 | 0 | if (cached_has_bits & 3u) { |
1837 | 0 | if (cached_has_bits & 0x00000001u) { |
1838 | 0 | set_has_message(); |
1839 | 0 | message_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.message_); |
1840 | 0 | } |
1841 | 0 | if (cached_has_bits & 0x00000002u) { |
1842 | 0 | code_ = from.code_; |
1843 | 0 | } |
1844 | 0 | _has_bits_[0] |= cached_has_bits; |
1845 | 0 | } |
1846 | 0 | } |
1847 | | |
1848 | 0 | void ErrorStatusPB::CopyFrom(const ::google::protobuf::Message& from) { |
1849 | | // @@protoc_insertion_point(generalized_copy_from_start:yb.rpc.ErrorStatusPB) |
1850 | 0 | if (&from == this) return; |
1851 | 0 | Clear(); |
1852 | 0 | MergeFrom(from); |
1853 | 0 | } |
1854 | | |
1855 | 0 | void ErrorStatusPB::CopyFrom(const ErrorStatusPB& from) { |
1856 | | // @@protoc_insertion_point(class_specific_copy_from_start:yb.rpc.ErrorStatusPB) |
1857 | 0 | if (&from == this) return; |
1858 | 0 | Clear(); |
1859 | 0 | MergeFrom(from); |
1860 | 0 | } |
1861 | | |
1862 | 4.60k | bool ErrorStatusPB::IsInitialized() const { |
1863 | 4.60k | if (!_extensions_.IsInitialized()) { |
1864 | 0 | return false; |
1865 | 0 | } |
1866 | | |
1867 | 4.60k | if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false; |
1868 | 4.60k | return true; |
1869 | 4.60k | } |
1870 | | |
1871 | 0 | void ErrorStatusPB::Swap(ErrorStatusPB* other) { |
1872 | 0 | if (other == this) return; |
1873 | 0 | InternalSwap(other); |
1874 | 0 | } |
1875 | 0 | void ErrorStatusPB::InternalSwap(ErrorStatusPB* other) { |
1876 | 0 | using std::swap; |
1877 | 0 | message_.Swap(&other->message_); |
1878 | 0 | swap(code_, other->code_); |
1879 | 0 | swap(_has_bits_[0], other->_has_bits_[0]); |
1880 | 0 | _internal_metadata_.Swap(&other->_internal_metadata_); |
1881 | 0 | swap(_cached_size_, other->_cached_size_); |
1882 | 0 | _extensions_.Swap(&other->_extensions_); |
1883 | 0 | } |
1884 | | |
1885 | 2.04k | ::google::protobuf::Metadata ErrorStatusPB::GetMetadata() const { |
1886 | 2.04k | protobuf_yb_2frpc_2frpc_5fheader_2eproto::protobuf_AssignDescriptorsOnce(); |
1887 | 2.04k | return ::protobuf_yb_2frpc_2frpc_5fheader_2eproto::file_level_metadata[kIndexInFileMessages]; |
1888 | 2.04k | } |
1889 | | |
1890 | | |
1891 | | // @@protoc_insertion_point(namespace_scope) |
1892 | | } // namespace rpc |
1893 | | } // namespace yb |
1894 | | |
1895 | | // @@protoc_insertion_point(global_scope) |