Line data Source code
1 : // Generated by the protocol buffer compiler. DO NOT EDIT!
2 : // source: test/proto/messages.proto
3 :
4 : #define INTERNAL_SUPPRESS_PROTOBUF_FIELD_DEPRECATION
5 : #include "test/proto/messages.pb.h"
6 :
7 : #include <algorithm>
8 :
9 : #include <google/protobuf/stubs/common.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 : // @@protoc_insertion_point(includes)
18 :
19 : namespace grpc {
20 : namespace testing {
21 :
22 : namespace {
23 :
24 : const ::google::protobuf::Descriptor* Payload_descriptor_ = NULL;
25 : const ::google::protobuf::internal::GeneratedMessageReflection*
26 : Payload_reflection_ = NULL;
27 : const ::google::protobuf::Descriptor* EchoStatus_descriptor_ = NULL;
28 : const ::google::protobuf::internal::GeneratedMessageReflection*
29 : EchoStatus_reflection_ = NULL;
30 : const ::google::protobuf::Descriptor* SimpleRequest_descriptor_ = NULL;
31 : const ::google::protobuf::internal::GeneratedMessageReflection*
32 : SimpleRequest_reflection_ = NULL;
33 : const ::google::protobuf::Descriptor* SimpleResponse_descriptor_ = NULL;
34 : const ::google::protobuf::internal::GeneratedMessageReflection*
35 : SimpleResponse_reflection_ = NULL;
36 : const ::google::protobuf::Descriptor* StreamingInputCallRequest_descriptor_ = NULL;
37 : const ::google::protobuf::internal::GeneratedMessageReflection*
38 : StreamingInputCallRequest_reflection_ = NULL;
39 : const ::google::protobuf::Descriptor* StreamingInputCallResponse_descriptor_ = NULL;
40 : const ::google::protobuf::internal::GeneratedMessageReflection*
41 : StreamingInputCallResponse_reflection_ = NULL;
42 : const ::google::protobuf::Descriptor* ResponseParameters_descriptor_ = NULL;
43 : const ::google::protobuf::internal::GeneratedMessageReflection*
44 : ResponseParameters_reflection_ = NULL;
45 : const ::google::protobuf::Descriptor* StreamingOutputCallRequest_descriptor_ = NULL;
46 : const ::google::protobuf::internal::GeneratedMessageReflection*
47 : StreamingOutputCallRequest_reflection_ = NULL;
48 : const ::google::protobuf::Descriptor* StreamingOutputCallResponse_descriptor_ = NULL;
49 : const ::google::protobuf::internal::GeneratedMessageReflection*
50 : StreamingOutputCallResponse_reflection_ = NULL;
51 : const ::google::protobuf::Descriptor* ReconnectInfo_descriptor_ = NULL;
52 : const ::google::protobuf::internal::GeneratedMessageReflection*
53 : ReconnectInfo_reflection_ = NULL;
54 : const ::google::protobuf::EnumDescriptor* PayloadType_descriptor_ = NULL;
55 : const ::google::protobuf::EnumDescriptor* CompressionType_descriptor_ = NULL;
56 :
57 : } // namespace
58 :
59 :
60 0 : void protobuf_AssignDesc_test_2fproto_2fmessages_2eproto() {
61 0 : protobuf_AddDesc_test_2fproto_2fmessages_2eproto();
62 : const ::google::protobuf::FileDescriptor* file =
63 : ::google::protobuf::DescriptorPool::generated_pool()->FindFileByName(
64 0 : "test/proto/messages.proto");
65 0 : GOOGLE_CHECK(file != NULL);
66 0 : Payload_descriptor_ = file->message_type(0);
67 : static const int Payload_offsets_[2] = {
68 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Payload, type_),
69 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Payload, body_),
70 : };
71 : Payload_reflection_ =
72 : ::google::protobuf::internal::GeneratedMessageReflection::NewGeneratedMessageReflection(
73 : Payload_descriptor_,
74 : Payload::default_instance_,
75 : Payload_offsets_,
76 : -1,
77 : -1,
78 : -1,
79 : sizeof(Payload),
80 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Payload, _internal_metadata_),
81 0 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(Payload, _is_default_instance_));
82 0 : EchoStatus_descriptor_ = file->message_type(1);
83 : static const int EchoStatus_offsets_[2] = {
84 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(EchoStatus, code_),
85 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(EchoStatus, message_),
86 : };
87 : EchoStatus_reflection_ =
88 : ::google::protobuf::internal::GeneratedMessageReflection::NewGeneratedMessageReflection(
89 : EchoStatus_descriptor_,
90 : EchoStatus::default_instance_,
91 : EchoStatus_offsets_,
92 : -1,
93 : -1,
94 : -1,
95 : sizeof(EchoStatus),
96 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(EchoStatus, _internal_metadata_),
97 0 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(EchoStatus, _is_default_instance_));
98 0 : SimpleRequest_descriptor_ = file->message_type(2);
99 : static const int SimpleRequest_offsets_[7] = {
100 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleRequest, response_type_),
101 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleRequest, response_size_),
102 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleRequest, payload_),
103 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleRequest, fill_username_),
104 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleRequest, fill_oauth_scope_),
105 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleRequest, response_compression_),
106 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleRequest, response_status_),
107 : };
108 : SimpleRequest_reflection_ =
109 : ::google::protobuf::internal::GeneratedMessageReflection::NewGeneratedMessageReflection(
110 : SimpleRequest_descriptor_,
111 : SimpleRequest::default_instance_,
112 : SimpleRequest_offsets_,
113 : -1,
114 : -1,
115 : -1,
116 : sizeof(SimpleRequest),
117 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleRequest, _internal_metadata_),
118 0 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleRequest, _is_default_instance_));
119 0 : SimpleResponse_descriptor_ = file->message_type(3);
120 : static const int SimpleResponse_offsets_[3] = {
121 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleResponse, payload_),
122 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleResponse, username_),
123 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleResponse, oauth_scope_),
124 : };
125 : SimpleResponse_reflection_ =
126 : ::google::protobuf::internal::GeneratedMessageReflection::NewGeneratedMessageReflection(
127 : SimpleResponse_descriptor_,
128 : SimpleResponse::default_instance_,
129 : SimpleResponse_offsets_,
130 : -1,
131 : -1,
132 : -1,
133 : sizeof(SimpleResponse),
134 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleResponse, _internal_metadata_),
135 0 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SimpleResponse, _is_default_instance_));
136 0 : StreamingInputCallRequest_descriptor_ = file->message_type(4);
137 : static const int StreamingInputCallRequest_offsets_[1] = {
138 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingInputCallRequest, payload_),
139 : };
140 : StreamingInputCallRequest_reflection_ =
141 : ::google::protobuf::internal::GeneratedMessageReflection::NewGeneratedMessageReflection(
142 : StreamingInputCallRequest_descriptor_,
143 : StreamingInputCallRequest::default_instance_,
144 : StreamingInputCallRequest_offsets_,
145 : -1,
146 : -1,
147 : -1,
148 : sizeof(StreamingInputCallRequest),
149 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingInputCallRequest, _internal_metadata_),
150 0 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingInputCallRequest, _is_default_instance_));
151 0 : StreamingInputCallResponse_descriptor_ = file->message_type(5);
152 : static const int StreamingInputCallResponse_offsets_[1] = {
153 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingInputCallResponse, aggregated_payload_size_),
154 : };
155 : StreamingInputCallResponse_reflection_ =
156 : ::google::protobuf::internal::GeneratedMessageReflection::NewGeneratedMessageReflection(
157 : StreamingInputCallResponse_descriptor_,
158 : StreamingInputCallResponse::default_instance_,
159 : StreamingInputCallResponse_offsets_,
160 : -1,
161 : -1,
162 : -1,
163 : sizeof(StreamingInputCallResponse),
164 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingInputCallResponse, _internal_metadata_),
165 0 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingInputCallResponse, _is_default_instance_));
166 0 : ResponseParameters_descriptor_ = file->message_type(6);
167 : static const int ResponseParameters_offsets_[2] = {
168 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(ResponseParameters, size_),
169 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(ResponseParameters, interval_us_),
170 : };
171 : ResponseParameters_reflection_ =
172 : ::google::protobuf::internal::GeneratedMessageReflection::NewGeneratedMessageReflection(
173 : ResponseParameters_descriptor_,
174 : ResponseParameters::default_instance_,
175 : ResponseParameters_offsets_,
176 : -1,
177 : -1,
178 : -1,
179 : sizeof(ResponseParameters),
180 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(ResponseParameters, _internal_metadata_),
181 0 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(ResponseParameters, _is_default_instance_));
182 0 : StreamingOutputCallRequest_descriptor_ = file->message_type(7);
183 : static const int StreamingOutputCallRequest_offsets_[5] = {
184 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingOutputCallRequest, response_type_),
185 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingOutputCallRequest, response_parameters_),
186 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingOutputCallRequest, payload_),
187 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingOutputCallRequest, response_compression_),
188 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingOutputCallRequest, response_status_),
189 : };
190 : StreamingOutputCallRequest_reflection_ =
191 : ::google::protobuf::internal::GeneratedMessageReflection::NewGeneratedMessageReflection(
192 : StreamingOutputCallRequest_descriptor_,
193 : StreamingOutputCallRequest::default_instance_,
194 : StreamingOutputCallRequest_offsets_,
195 : -1,
196 : -1,
197 : -1,
198 : sizeof(StreamingOutputCallRequest),
199 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingOutputCallRequest, _internal_metadata_),
200 0 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingOutputCallRequest, _is_default_instance_));
201 0 : StreamingOutputCallResponse_descriptor_ = file->message_type(8);
202 : static const int StreamingOutputCallResponse_offsets_[1] = {
203 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingOutputCallResponse, payload_),
204 : };
205 : StreamingOutputCallResponse_reflection_ =
206 : ::google::protobuf::internal::GeneratedMessageReflection::NewGeneratedMessageReflection(
207 : StreamingOutputCallResponse_descriptor_,
208 : StreamingOutputCallResponse::default_instance_,
209 : StreamingOutputCallResponse_offsets_,
210 : -1,
211 : -1,
212 : -1,
213 : sizeof(StreamingOutputCallResponse),
214 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingOutputCallResponse, _internal_metadata_),
215 0 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(StreamingOutputCallResponse, _is_default_instance_));
216 0 : ReconnectInfo_descriptor_ = file->message_type(9);
217 : static const int ReconnectInfo_offsets_[2] = {
218 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(ReconnectInfo, passed_),
219 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(ReconnectInfo, backoff_ms_),
220 : };
221 : ReconnectInfo_reflection_ =
222 : ::google::protobuf::internal::GeneratedMessageReflection::NewGeneratedMessageReflection(
223 : ReconnectInfo_descriptor_,
224 : ReconnectInfo::default_instance_,
225 : ReconnectInfo_offsets_,
226 : -1,
227 : -1,
228 : -1,
229 : sizeof(ReconnectInfo),
230 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(ReconnectInfo, _internal_metadata_),
231 0 : GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(ReconnectInfo, _is_default_instance_));
232 0 : PayloadType_descriptor_ = file->enum_type(0);
233 0 : CompressionType_descriptor_ = file->enum_type(1);
234 0 : }
235 :
236 : namespace {
237 :
238 : GOOGLE_PROTOBUF_DECLARE_ONCE(protobuf_AssignDescriptors_once_);
239 0 : inline void protobuf_AssignDescriptorsOnce() {
240 : ::google::protobuf::GoogleOnceInit(&protobuf_AssignDescriptors_once_,
241 0 : &protobuf_AssignDesc_test_2fproto_2fmessages_2eproto);
242 0 : }
243 :
244 0 : void protobuf_RegisterTypes(const ::std::string&) {
245 0 : protobuf_AssignDescriptorsOnce();
246 : ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
247 0 : Payload_descriptor_, &Payload::default_instance());
248 : ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
249 0 : EchoStatus_descriptor_, &EchoStatus::default_instance());
250 : ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
251 0 : SimpleRequest_descriptor_, &SimpleRequest::default_instance());
252 : ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
253 0 : SimpleResponse_descriptor_, &SimpleResponse::default_instance());
254 : ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
255 0 : StreamingInputCallRequest_descriptor_, &StreamingInputCallRequest::default_instance());
256 : ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
257 0 : StreamingInputCallResponse_descriptor_, &StreamingInputCallResponse::default_instance());
258 : ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
259 0 : ResponseParameters_descriptor_, &ResponseParameters::default_instance());
260 : ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
261 0 : StreamingOutputCallRequest_descriptor_, &StreamingOutputCallRequest::default_instance());
262 : ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
263 0 : StreamingOutputCallResponse_descriptor_, &StreamingOutputCallResponse::default_instance());
264 : ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
265 0 : ReconnectInfo_descriptor_, &ReconnectInfo::default_instance());
266 0 : }
267 :
268 : } // namespace
269 :
270 0 : void protobuf_ShutdownFile_test_2fproto_2fmessages_2eproto() {
271 0 : delete Payload::default_instance_;
272 0 : delete Payload_reflection_;
273 0 : delete EchoStatus::default_instance_;
274 0 : delete EchoStatus_reflection_;
275 0 : delete SimpleRequest::default_instance_;
276 0 : delete SimpleRequest_reflection_;
277 0 : delete SimpleResponse::default_instance_;
278 0 : delete SimpleResponse_reflection_;
279 0 : delete StreamingInputCallRequest::default_instance_;
280 0 : delete StreamingInputCallRequest_reflection_;
281 0 : delete StreamingInputCallResponse::default_instance_;
282 0 : delete StreamingInputCallResponse_reflection_;
283 0 : delete ResponseParameters::default_instance_;
284 0 : delete ResponseParameters_reflection_;
285 0 : delete StreamingOutputCallRequest::default_instance_;
286 0 : delete StreamingOutputCallRequest_reflection_;
287 0 : delete StreamingOutputCallResponse::default_instance_;
288 0 : delete StreamingOutputCallResponse_reflection_;
289 0 : delete ReconnectInfo::default_instance_;
290 0 : delete ReconnectInfo_reflection_;
291 0 : }
292 :
293 5 : void protobuf_AddDesc_test_2fproto_2fmessages_2eproto() {
294 : static bool already_here = false;
295 10 : if (already_here) return;
296 5 : already_here = true;
297 5 : GOOGLE_PROTOBUF_VERIFY_VERSION;
298 :
299 : ::google::protobuf::DescriptorPool::InternalAddGeneratedFile(
300 : "\n\031test/proto/messages.proto\022\014grpc.testin"
301 : "g\"@\n\007Payload\022\'\n\004type\030\001 \001(\0162\031.grpc.testin"
302 : "g.PayloadType\022\014\n\004body\030\002 \001(\014\"+\n\nEchoStatu"
303 : "s\022\014\n\004code\030\001 \001(\005\022\017\n\007message\030\002 \001(\t\"\241\002\n\rSim"
304 : "pleRequest\0220\n\rresponse_type\030\001 \001(\0162\031.grpc"
305 : ".testing.PayloadType\022\025\n\rresponse_size\030\002 "
306 : "\001(\005\022&\n\007payload\030\003 \001(\0132\025.grpc.testing.Payl"
307 : "oad\022\025\n\rfill_username\030\004 \001(\010\022\030\n\020fill_oauth"
308 : "_scope\030\005 \001(\010\022;\n\024response_compression\030\006 \001"
309 : "(\0162\035.grpc.testing.CompressionType\0221\n\017res"
310 : "ponse_status\030\007 \001(\0132\030.grpc.testing.EchoSt"
311 : "atus\"_\n\016SimpleResponse\022&\n\007payload\030\001 \001(\0132"
312 : "\025.grpc.testing.Payload\022\020\n\010username\030\002 \001(\t"
313 : "\022\023\n\013oauth_scope\030\003 \001(\t\"C\n\031StreamingInputC"
314 : "allRequest\022&\n\007payload\030\001 \001(\0132\025.grpc.testi"
315 : "ng.Payload\"=\n\032StreamingInputCallResponse"
316 : "\022\037\n\027aggregated_payload_size\030\001 \001(\005\"7\n\022Res"
317 : "ponseParameters\022\014\n\004size\030\001 \001(\005\022\023\n\013interva"
318 : "l_us\030\002 \001(\005\"\245\002\n\032StreamingOutputCallReques"
319 : "t\0220\n\rresponse_type\030\001 \001(\0162\031.grpc.testing."
320 : "PayloadType\022=\n\023response_parameters\030\002 \003(\013"
321 : "2 .grpc.testing.ResponseParameters\022&\n\007pa"
322 : "yload\030\003 \001(\0132\025.grpc.testing.Payload\022;\n\024re"
323 : "sponse_compression\030\006 \001(\0162\035.grpc.testing."
324 : "CompressionType\0221\n\017response_status\030\007 \001(\013"
325 : "2\030.grpc.testing.EchoStatus\"E\n\033StreamingO"
326 : "utputCallResponse\022&\n\007payload\030\001 \001(\0132\025.grp"
327 : "c.testing.Payload\"3\n\rReconnectInfo\022\016\n\006pa"
328 : "ssed\030\001 \001(\010\022\022\n\nbackoff_ms\030\002 \003(\005*\?\n\013Payloa"
329 : "dType\022\020\n\014COMPRESSABLE\020\000\022\022\n\016UNCOMPRESSABL"
330 : "E\020\001\022\n\n\006RANDOM\020\002*2\n\017CompressionType\022\010\n\004NO"
331 5 : "NE\020\000\022\010\n\004GZIP\020\001\022\013\n\007DEFLATE\020\002b\006proto3", 1275);
332 : ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(
333 5 : "test/proto/messages.proto", &protobuf_RegisterTypes);
334 5 : Payload::default_instance_ = new Payload();
335 5 : EchoStatus::default_instance_ = new EchoStatus();
336 5 : SimpleRequest::default_instance_ = new SimpleRequest();
337 5 : SimpleResponse::default_instance_ = new SimpleResponse();
338 5 : StreamingInputCallRequest::default_instance_ = new StreamingInputCallRequest();
339 5 : StreamingInputCallResponse::default_instance_ = new StreamingInputCallResponse();
340 5 : ResponseParameters::default_instance_ = new ResponseParameters();
341 5 : StreamingOutputCallRequest::default_instance_ = new StreamingOutputCallRequest();
342 5 : StreamingOutputCallResponse::default_instance_ = new StreamingOutputCallResponse();
343 5 : ReconnectInfo::default_instance_ = new ReconnectInfo();
344 5 : Payload::default_instance_->InitAsDefaultInstance();
345 5 : EchoStatus::default_instance_->InitAsDefaultInstance();
346 5 : SimpleRequest::default_instance_->InitAsDefaultInstance();
347 5 : SimpleResponse::default_instance_->InitAsDefaultInstance();
348 5 : StreamingInputCallRequest::default_instance_->InitAsDefaultInstance();
349 5 : StreamingInputCallResponse::default_instance_->InitAsDefaultInstance();
350 5 : ResponseParameters::default_instance_->InitAsDefaultInstance();
351 5 : StreamingOutputCallRequest::default_instance_->InitAsDefaultInstance();
352 5 : StreamingOutputCallResponse::default_instance_->InitAsDefaultInstance();
353 5 : ReconnectInfo::default_instance_->InitAsDefaultInstance();
354 5 : ::google::protobuf::internal::OnShutdown(&protobuf_ShutdownFile_test_2fproto_2fmessages_2eproto);
355 : }
356 :
357 : // Force AddDescriptors() to be called at static initialization time.
358 : struct StaticDescriptorInitializer_test_2fproto_2fmessages_2eproto {
359 5 : StaticDescriptorInitializer_test_2fproto_2fmessages_2eproto() {
360 5 : protobuf_AddDesc_test_2fproto_2fmessages_2eproto();
361 5 : }
362 5 : } static_descriptor_initializer_test_2fproto_2fmessages_2eproto_;
363 0 : const ::google::protobuf::EnumDescriptor* PayloadType_descriptor() {
364 0 : protobuf_AssignDescriptorsOnce();
365 0 : return PayloadType_descriptor_;
366 : }
367 0 : bool PayloadType_IsValid(int value) {
368 0 : switch(value) {
369 : case 0:
370 : case 1:
371 : case 2:
372 0 : return true;
373 : default:
374 0 : return false;
375 : }
376 : }
377 :
378 0 : const ::google::protobuf::EnumDescriptor* CompressionType_descriptor() {
379 0 : protobuf_AssignDescriptorsOnce();
380 0 : return CompressionType_descriptor_;
381 : }
382 0 : bool CompressionType_IsValid(int value) {
383 0 : switch(value) {
384 : case 0:
385 : case 1:
386 : case 2:
387 0 : return true;
388 : default:
389 0 : return false;
390 : }
391 : }
392 :
393 :
394 : namespace {
395 :
396 : static void MergeFromFail(int line) GOOGLE_ATTRIBUTE_COLD;
397 0 : static void MergeFromFail(int line) {
398 0 : GOOGLE_CHECK(false) << __FILE__ << ":" << line;
399 0 : }
400 :
401 : } // namespace
402 :
403 :
404 : // ===================================================================
405 :
406 : #ifndef _MSC_VER
407 : const int Payload::kTypeFieldNumber;
408 : const int Payload::kBodyFieldNumber;
409 : #endif // !_MSC_VER
410 :
411 21 : Payload::Payload()
412 21 : : ::google::protobuf::Message(), _internal_metadata_(NULL) {
413 21 : SharedCtor();
414 : // @@protoc_insertion_point(constructor:grpc.testing.Payload)
415 21 : }
416 :
417 5 : void Payload::InitAsDefaultInstance() {
418 5 : _is_default_instance_ = true;
419 5 : }
420 :
421 0 : Payload::Payload(const Payload& from)
422 : : ::google::protobuf::Message(),
423 0 : _internal_metadata_(NULL) {
424 0 : SharedCtor();
425 0 : MergeFrom(from);
426 : // @@protoc_insertion_point(copy_constructor:grpc.testing.Payload)
427 0 : }
428 :
429 21 : void Payload::SharedCtor() {
430 21 : _is_default_instance_ = false;
431 21 : ::google::protobuf::internal::GetEmptyString();
432 21 : _cached_size_ = 0;
433 21 : type_ = 0;
434 21 : body_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
435 21 : }
436 :
437 48 : Payload::~Payload() {
438 : // @@protoc_insertion_point(destructor:grpc.testing.Payload)
439 16 : SharedDtor();
440 32 : }
441 :
442 16 : void Payload::SharedDtor() {
443 16 : body_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
444 16 : if (this != default_instance_) {
445 : }
446 16 : }
447 :
448 0 : void Payload::SetCachedSize(int size) const {
449 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
450 0 : _cached_size_ = size;
451 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
452 0 : }
453 0 : const ::google::protobuf::Descriptor* Payload::descriptor() {
454 0 : protobuf_AssignDescriptorsOnce();
455 0 : return Payload_descriptor_;
456 : }
457 :
458 25 : const Payload& Payload::default_instance() {
459 25 : if (default_instance_ == NULL) protobuf_AddDesc_test_2fproto_2fmessages_2eproto();
460 25 : return *default_instance_;
461 : }
462 :
463 : Payload* Payload::default_instance_ = NULL;
464 :
465 0 : Payload* Payload::New(::google::protobuf::Arena* arena) const {
466 0 : Payload* n = new Payload;
467 0 : if (arena != NULL) {
468 0 : arena->Own(n);
469 : }
470 0 : return n;
471 : }
472 :
473 0 : void Payload::Clear() {
474 0 : type_ = 0;
475 0 : body_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
476 0 : }
477 :
478 8 : bool Payload::MergePartialFromCodedStream(
479 : ::google::protobuf::io::CodedInputStream* input) {
480 : #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
481 : ::google::protobuf::uint32 tag;
482 : // @@protoc_insertion_point(parse_start:grpc.testing.Payload)
483 : for (;;) {
484 : ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
485 8 : tag = p.first;
486 8 : if (!p.second) goto handle_unusual;
487 8 : switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
488 : // optional .grpc.testing.PayloadType type = 1;
489 : case 1: {
490 0 : if (tag == 8) {
491 : int value;
492 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
493 : int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
494 : input, &value)));
495 0 : set_type(static_cast< ::grpc::testing::PayloadType >(value));
496 : } else {
497 0 : goto handle_unusual;
498 : }
499 0 : if (input->ExpectTag(18)) goto parse_body;
500 0 : break;
501 : }
502 :
503 : // optional bytes body = 2;
504 : case 2: {
505 8 : if (tag == 18) {
506 : parse_body:
507 8 : DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
508 : input, this->mutable_body()));
509 : } else {
510 0 : goto handle_unusual;
511 : }
512 16 : if (input->ExpectAtEnd()) goto success;
513 0 : break;
514 : }
515 :
516 : default: {
517 : handle_unusual:
518 0 : if (tag == 0 ||
519 0 : ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
520 : ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
521 0 : goto success;
522 : }
523 0 : DO_(::google::protobuf::internal::WireFormatLite::SkipField(input, tag));
524 0 : break;
525 : }
526 : }
527 0 : }
528 : success:
529 : // @@protoc_insertion_point(parse_success:grpc.testing.Payload)
530 8 : return true;
531 : failure:
532 : // @@protoc_insertion_point(parse_failure:grpc.testing.Payload)
533 0 : return false;
534 : #undef DO_
535 : }
536 :
537 8 : void Payload::SerializeWithCachedSizes(
538 : ::google::protobuf::io::CodedOutputStream* output) const {
539 : // @@protoc_insertion_point(serialize_start:grpc.testing.Payload)
540 : // optional .grpc.testing.PayloadType type = 1;
541 8 : if (this->type() != 0) {
542 : ::google::protobuf::internal::WireFormatLite::WriteEnum(
543 0 : 1, this->type(), output);
544 : }
545 :
546 : // optional bytes body = 2;
547 8 : if (this->body().size() > 0) {
548 : ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased(
549 8 : 2, this->body(), output);
550 : }
551 :
552 : // @@protoc_insertion_point(serialize_end:grpc.testing.Payload)
553 8 : }
554 :
555 0 : ::google::protobuf::uint8* Payload::SerializeWithCachedSizesToArray(
556 : ::google::protobuf::uint8* target) const {
557 : // @@protoc_insertion_point(serialize_to_array_start:grpc.testing.Payload)
558 : // optional .grpc.testing.PayloadType type = 1;
559 0 : if (this->type() != 0) {
560 : target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
561 0 : 1, this->type(), target);
562 : }
563 :
564 : // optional bytes body = 2;
565 0 : if (this->body().size() > 0) {
566 : target =
567 : ::google::protobuf::internal::WireFormatLite::WriteBytesToArray(
568 0 : 2, this->body(), target);
569 : }
570 :
571 : // @@protoc_insertion_point(serialize_to_array_end:grpc.testing.Payload)
572 0 : return target;
573 : }
574 :
575 16 : int Payload::ByteSize() const {
576 16 : int total_size = 0;
577 :
578 : // optional .grpc.testing.PayloadType type = 1;
579 16 : if (this->type() != 0) {
580 : total_size += 1 +
581 0 : ::google::protobuf::internal::WireFormatLite::EnumSize(this->type());
582 : }
583 :
584 : // optional bytes body = 2;
585 16 : if (this->body().size() > 0) {
586 : total_size += 1 +
587 : ::google::protobuf::internal::WireFormatLite::BytesSize(
588 16 : this->body());
589 : }
590 :
591 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
592 16 : _cached_size_ = total_size;
593 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
594 16 : return total_size;
595 : }
596 :
597 0 : void Payload::MergeFrom(const ::google::protobuf::Message& from) {
598 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
599 : const Payload* source =
600 : ::google::protobuf::internal::DynamicCastToGenerated<const Payload>(
601 0 : &from);
602 0 : if (source == NULL) {
603 0 : ::google::protobuf::internal::ReflectionOps::Merge(from, this);
604 : } else {
605 0 : MergeFrom(*source);
606 : }
607 0 : }
608 :
609 0 : void Payload::MergeFrom(const Payload& from) {
610 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
611 0 : if (from.type() != 0) {
612 0 : set_type(from.type());
613 : }
614 0 : if (from.body().size() > 0) {
615 :
616 0 : body_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.body_);
617 : }
618 0 : }
619 :
620 0 : void Payload::CopyFrom(const ::google::protobuf::Message& from) {
621 0 : if (&from == this) return;
622 0 : Clear();
623 0 : MergeFrom(from);
624 : }
625 :
626 0 : void Payload::CopyFrom(const Payload& from) {
627 0 : if (&from == this) return;
628 0 : Clear();
629 0 : MergeFrom(from);
630 : }
631 :
632 0 : bool Payload::IsInitialized() const {
633 :
634 0 : return true;
635 : }
636 :
637 0 : void Payload::Swap(Payload* other) {
638 0 : if (other == this) return;
639 0 : InternalSwap(other);
640 : }
641 0 : void Payload::InternalSwap(Payload* other) {
642 0 : std::swap(type_, other->type_);
643 0 : body_.Swap(&other->body_);
644 0 : _internal_metadata_.Swap(&other->_internal_metadata_);
645 0 : std::swap(_cached_size_, other->_cached_size_);
646 0 : }
647 :
648 0 : ::google::protobuf::Metadata Payload::GetMetadata() const {
649 0 : protobuf_AssignDescriptorsOnce();
650 : ::google::protobuf::Metadata metadata;
651 0 : metadata.descriptor = Payload_descriptor_;
652 0 : metadata.reflection = Payload_reflection_;
653 0 : return metadata;
654 : }
655 :
656 : #if PROTOBUF_INLINE_NOT_IN_HEADERS
657 : // Payload
658 :
659 : // optional .grpc.testing.PayloadType type = 1;
660 : void Payload::clear_type() {
661 : type_ = 0;
662 : }
663 : ::grpc::testing::PayloadType Payload::type() const {
664 : // @@protoc_insertion_point(field_get:grpc.testing.Payload.type)
665 : return static_cast< ::grpc::testing::PayloadType >(type_);
666 : }
667 : void Payload::set_type(::grpc::testing::PayloadType value) {
668 :
669 : type_ = value;
670 : // @@protoc_insertion_point(field_set:grpc.testing.Payload.type)
671 : }
672 :
673 : // optional bytes body = 2;
674 : void Payload::clear_body() {
675 : body_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
676 : }
677 : const ::std::string& Payload::body() const {
678 : // @@protoc_insertion_point(field_get:grpc.testing.Payload.body)
679 : return body_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
680 : }
681 : void Payload::set_body(const ::std::string& value) {
682 :
683 : body_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
684 : // @@protoc_insertion_point(field_set:grpc.testing.Payload.body)
685 : }
686 : void Payload::set_body(const char* value) {
687 :
688 : body_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
689 : // @@protoc_insertion_point(field_set_char:grpc.testing.Payload.body)
690 : }
691 : void Payload::set_body(const void* value, size_t size) {
692 :
693 : body_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
694 : ::std::string(reinterpret_cast<const char*>(value), size));
695 : // @@protoc_insertion_point(field_set_pointer:grpc.testing.Payload.body)
696 : }
697 : ::std::string* Payload::mutable_body() {
698 :
699 : // @@protoc_insertion_point(field_mutable:grpc.testing.Payload.body)
700 : return body_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
701 : }
702 : ::std::string* Payload::release_body() {
703 :
704 : return body_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
705 : }
706 : void Payload::set_allocated_body(::std::string* body) {
707 : if (body != NULL) {
708 :
709 : } else {
710 :
711 : }
712 : body_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), body);
713 : // @@protoc_insertion_point(field_set_allocated:grpc.testing.Payload.body)
714 : }
715 :
716 : #endif // PROTOBUF_INLINE_NOT_IN_HEADERS
717 :
718 : // ===================================================================
719 :
720 : #ifndef _MSC_VER
721 : const int EchoStatus::kCodeFieldNumber;
722 : const int EchoStatus::kMessageFieldNumber;
723 : #endif // !_MSC_VER
724 :
725 5 : EchoStatus::EchoStatus()
726 5 : : ::google::protobuf::Message(), _internal_metadata_(NULL) {
727 5 : SharedCtor();
728 : // @@protoc_insertion_point(constructor:grpc.testing.EchoStatus)
729 5 : }
730 :
731 5 : void EchoStatus::InitAsDefaultInstance() {
732 5 : _is_default_instance_ = true;
733 5 : }
734 :
735 0 : EchoStatus::EchoStatus(const EchoStatus& from)
736 : : ::google::protobuf::Message(),
737 0 : _internal_metadata_(NULL) {
738 0 : SharedCtor();
739 0 : MergeFrom(from);
740 : // @@protoc_insertion_point(copy_constructor:grpc.testing.EchoStatus)
741 0 : }
742 :
743 5 : void EchoStatus::SharedCtor() {
744 5 : _is_default_instance_ = false;
745 5 : ::google::protobuf::internal::GetEmptyString();
746 5 : _cached_size_ = 0;
747 5 : code_ = 0;
748 5 : message_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
749 5 : }
750 :
751 0 : EchoStatus::~EchoStatus() {
752 : // @@protoc_insertion_point(destructor:grpc.testing.EchoStatus)
753 0 : SharedDtor();
754 0 : }
755 :
756 0 : void EchoStatus::SharedDtor() {
757 0 : message_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
758 0 : if (this != default_instance_) {
759 : }
760 0 : }
761 :
762 0 : void EchoStatus::SetCachedSize(int size) const {
763 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
764 0 : _cached_size_ = size;
765 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
766 0 : }
767 0 : const ::google::protobuf::Descriptor* EchoStatus::descriptor() {
768 0 : protobuf_AssignDescriptorsOnce();
769 0 : return EchoStatus_descriptor_;
770 : }
771 :
772 10 : const EchoStatus& EchoStatus::default_instance() {
773 10 : if (default_instance_ == NULL) protobuf_AddDesc_test_2fproto_2fmessages_2eproto();
774 10 : return *default_instance_;
775 : }
776 :
777 : EchoStatus* EchoStatus::default_instance_ = NULL;
778 :
779 0 : EchoStatus* EchoStatus::New(::google::protobuf::Arena* arena) const {
780 0 : EchoStatus* n = new EchoStatus;
781 0 : if (arena != NULL) {
782 0 : arena->Own(n);
783 : }
784 0 : return n;
785 : }
786 :
787 0 : void EchoStatus::Clear() {
788 0 : code_ = 0;
789 0 : message_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
790 0 : }
791 :
792 0 : bool EchoStatus::MergePartialFromCodedStream(
793 : ::google::protobuf::io::CodedInputStream* input) {
794 : #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
795 : ::google::protobuf::uint32 tag;
796 : // @@protoc_insertion_point(parse_start:grpc.testing.EchoStatus)
797 : for (;;) {
798 : ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
799 0 : tag = p.first;
800 0 : if (!p.second) goto handle_unusual;
801 0 : switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
802 : // optional int32 code = 1;
803 : case 1: {
804 0 : if (tag == 8) {
805 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
806 : ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>(
807 : input, &code_)));
808 :
809 : } else {
810 0 : goto handle_unusual;
811 : }
812 0 : if (input->ExpectTag(18)) goto parse_message;
813 0 : break;
814 : }
815 :
816 : // optional string message = 2;
817 : case 2: {
818 0 : if (tag == 18) {
819 : parse_message:
820 0 : DO_(::google::protobuf::internal::WireFormatLite::ReadString(
821 : input, this->mutable_message()));
822 0 : DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String(
823 : this->message().data(), this->message().length(),
824 : ::google::protobuf::internal::WireFormatLite::PARSE,
825 : "grpc.testing.EchoStatus.message"));
826 : } else {
827 0 : goto handle_unusual;
828 : }
829 0 : if (input->ExpectAtEnd()) goto success;
830 0 : break;
831 : }
832 :
833 : default: {
834 : handle_unusual:
835 0 : if (tag == 0 ||
836 0 : ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
837 : ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
838 0 : goto success;
839 : }
840 0 : DO_(::google::protobuf::internal::WireFormatLite::SkipField(input, tag));
841 0 : break;
842 : }
843 : }
844 0 : }
845 : success:
846 : // @@protoc_insertion_point(parse_success:grpc.testing.EchoStatus)
847 0 : return true;
848 : failure:
849 : // @@protoc_insertion_point(parse_failure:grpc.testing.EchoStatus)
850 0 : return false;
851 : #undef DO_
852 : }
853 :
854 0 : void EchoStatus::SerializeWithCachedSizes(
855 : ::google::protobuf::io::CodedOutputStream* output) const {
856 : // @@protoc_insertion_point(serialize_start:grpc.testing.EchoStatus)
857 : // optional int32 code = 1;
858 0 : if (this->code() != 0) {
859 0 : ::google::protobuf::internal::WireFormatLite::WriteInt32(1, this->code(), output);
860 : }
861 :
862 : // optional string message = 2;
863 0 : if (this->message().size() > 0) {
864 : ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(
865 0 : this->message().data(), this->message().length(),
866 : ::google::protobuf::internal::WireFormatLite::SERIALIZE,
867 0 : "grpc.testing.EchoStatus.message");
868 : ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
869 0 : 2, this->message(), output);
870 : }
871 :
872 : // @@protoc_insertion_point(serialize_end:grpc.testing.EchoStatus)
873 0 : }
874 :
875 0 : ::google::protobuf::uint8* EchoStatus::SerializeWithCachedSizesToArray(
876 : ::google::protobuf::uint8* target) const {
877 : // @@protoc_insertion_point(serialize_to_array_start:grpc.testing.EchoStatus)
878 : // optional int32 code = 1;
879 0 : if (this->code() != 0) {
880 0 : target = ::google::protobuf::internal::WireFormatLite::WriteInt32ToArray(1, this->code(), target);
881 : }
882 :
883 : // optional string message = 2;
884 0 : if (this->message().size() > 0) {
885 : ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(
886 0 : this->message().data(), this->message().length(),
887 : ::google::protobuf::internal::WireFormatLite::SERIALIZE,
888 0 : "grpc.testing.EchoStatus.message");
889 : target =
890 : ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
891 0 : 2, this->message(), target);
892 : }
893 :
894 : // @@protoc_insertion_point(serialize_to_array_end:grpc.testing.EchoStatus)
895 0 : return target;
896 : }
897 :
898 0 : int EchoStatus::ByteSize() const {
899 0 : int total_size = 0;
900 :
901 : // optional int32 code = 1;
902 0 : if (this->code() != 0) {
903 : total_size += 1 +
904 : ::google::protobuf::internal::WireFormatLite::Int32Size(
905 0 : this->code());
906 : }
907 :
908 : // optional string message = 2;
909 0 : if (this->message().size() > 0) {
910 : total_size += 1 +
911 : ::google::protobuf::internal::WireFormatLite::StringSize(
912 0 : this->message());
913 : }
914 :
915 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
916 0 : _cached_size_ = total_size;
917 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
918 0 : return total_size;
919 : }
920 :
921 0 : void EchoStatus::MergeFrom(const ::google::protobuf::Message& from) {
922 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
923 : const EchoStatus* source =
924 : ::google::protobuf::internal::DynamicCastToGenerated<const EchoStatus>(
925 0 : &from);
926 0 : if (source == NULL) {
927 0 : ::google::protobuf::internal::ReflectionOps::Merge(from, this);
928 : } else {
929 0 : MergeFrom(*source);
930 : }
931 0 : }
932 :
933 0 : void EchoStatus::MergeFrom(const EchoStatus& from) {
934 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
935 0 : if (from.code() != 0) {
936 0 : set_code(from.code());
937 : }
938 0 : if (from.message().size() > 0) {
939 :
940 0 : message_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.message_);
941 : }
942 0 : }
943 :
944 0 : void EchoStatus::CopyFrom(const ::google::protobuf::Message& from) {
945 0 : if (&from == this) return;
946 0 : Clear();
947 0 : MergeFrom(from);
948 : }
949 :
950 0 : void EchoStatus::CopyFrom(const EchoStatus& from) {
951 0 : if (&from == this) return;
952 0 : Clear();
953 0 : MergeFrom(from);
954 : }
955 :
956 0 : bool EchoStatus::IsInitialized() const {
957 :
958 0 : return true;
959 : }
960 :
961 0 : void EchoStatus::Swap(EchoStatus* other) {
962 0 : if (other == this) return;
963 0 : InternalSwap(other);
964 : }
965 0 : void EchoStatus::InternalSwap(EchoStatus* other) {
966 0 : std::swap(code_, other->code_);
967 0 : message_.Swap(&other->message_);
968 0 : _internal_metadata_.Swap(&other->_internal_metadata_);
969 0 : std::swap(_cached_size_, other->_cached_size_);
970 0 : }
971 :
972 0 : ::google::protobuf::Metadata EchoStatus::GetMetadata() const {
973 0 : protobuf_AssignDescriptorsOnce();
974 : ::google::protobuf::Metadata metadata;
975 0 : metadata.descriptor = EchoStatus_descriptor_;
976 0 : metadata.reflection = EchoStatus_reflection_;
977 0 : return metadata;
978 : }
979 :
980 : #if PROTOBUF_INLINE_NOT_IN_HEADERS
981 : // EchoStatus
982 :
983 : // optional int32 code = 1;
984 : void EchoStatus::clear_code() {
985 : code_ = 0;
986 : }
987 : ::google::protobuf::int32 EchoStatus::code() const {
988 : // @@protoc_insertion_point(field_get:grpc.testing.EchoStatus.code)
989 : return code_;
990 : }
991 : void EchoStatus::set_code(::google::protobuf::int32 value) {
992 :
993 : code_ = value;
994 : // @@protoc_insertion_point(field_set:grpc.testing.EchoStatus.code)
995 : }
996 :
997 : // optional string message = 2;
998 : void EchoStatus::clear_message() {
999 : message_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1000 : }
1001 : const ::std::string& EchoStatus::message() const {
1002 : // @@protoc_insertion_point(field_get:grpc.testing.EchoStatus.message)
1003 : return message_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1004 : }
1005 : void EchoStatus::set_message(const ::std::string& value) {
1006 :
1007 : message_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
1008 : // @@protoc_insertion_point(field_set:grpc.testing.EchoStatus.message)
1009 : }
1010 : void EchoStatus::set_message(const char* value) {
1011 :
1012 : message_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
1013 : // @@protoc_insertion_point(field_set_char:grpc.testing.EchoStatus.message)
1014 : }
1015 : void EchoStatus::set_message(const char* value, size_t size) {
1016 :
1017 : message_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
1018 : ::std::string(reinterpret_cast<const char*>(value), size));
1019 : // @@protoc_insertion_point(field_set_pointer:grpc.testing.EchoStatus.message)
1020 : }
1021 : ::std::string* EchoStatus::mutable_message() {
1022 :
1023 : // @@protoc_insertion_point(field_mutable:grpc.testing.EchoStatus.message)
1024 : return message_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1025 : }
1026 : ::std::string* EchoStatus::release_message() {
1027 :
1028 : return message_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1029 : }
1030 : void EchoStatus::set_allocated_message(::std::string* message) {
1031 : if (message != NULL) {
1032 :
1033 : } else {
1034 :
1035 : }
1036 : message_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), message);
1037 : // @@protoc_insertion_point(field_set_allocated:grpc.testing.EchoStatus.message)
1038 : }
1039 :
1040 : #endif // PROTOBUF_INLINE_NOT_IN_HEADERS
1041 :
1042 : // ===================================================================
1043 :
1044 : #ifndef _MSC_VER
1045 : const int SimpleRequest::kResponseTypeFieldNumber;
1046 : const int SimpleRequest::kResponseSizeFieldNumber;
1047 : const int SimpleRequest::kPayloadFieldNumber;
1048 : const int SimpleRequest::kFillUsernameFieldNumber;
1049 : const int SimpleRequest::kFillOauthScopeFieldNumber;
1050 : const int SimpleRequest::kResponseCompressionFieldNumber;
1051 : const int SimpleRequest::kResponseStatusFieldNumber;
1052 : #endif // !_MSC_VER
1053 :
1054 14 : SimpleRequest::SimpleRequest()
1055 14 : : ::google::protobuf::Message(), _internal_metadata_(NULL) {
1056 14 : SharedCtor();
1057 : // @@protoc_insertion_point(constructor:grpc.testing.SimpleRequest)
1058 14 : }
1059 :
1060 5 : void SimpleRequest::InitAsDefaultInstance() {
1061 5 : _is_default_instance_ = true;
1062 5 : payload_ = const_cast< ::grpc::testing::Payload*>(&::grpc::testing::Payload::default_instance());
1063 5 : response_status_ = const_cast< ::grpc::testing::EchoStatus*>(&::grpc::testing::EchoStatus::default_instance());
1064 5 : }
1065 :
1066 0 : SimpleRequest::SimpleRequest(const SimpleRequest& from)
1067 : : ::google::protobuf::Message(),
1068 0 : _internal_metadata_(NULL) {
1069 0 : SharedCtor();
1070 0 : MergeFrom(from);
1071 : // @@protoc_insertion_point(copy_constructor:grpc.testing.SimpleRequest)
1072 0 : }
1073 :
1074 14 : void SimpleRequest::SharedCtor() {
1075 14 : _is_default_instance_ = false;
1076 14 : _cached_size_ = 0;
1077 14 : response_type_ = 0;
1078 14 : response_size_ = 0;
1079 14 : payload_ = NULL;
1080 14 : fill_username_ = false;
1081 14 : fill_oauth_scope_ = false;
1082 14 : response_compression_ = 0;
1083 14 : response_status_ = NULL;
1084 14 : }
1085 :
1086 18 : SimpleRequest::~SimpleRequest() {
1087 : // @@protoc_insertion_point(destructor:grpc.testing.SimpleRequest)
1088 9 : SharedDtor();
1089 9 : }
1090 :
1091 9 : void SimpleRequest::SharedDtor() {
1092 9 : if (this != default_instance_) {
1093 9 : delete payload_;
1094 9 : delete response_status_;
1095 : }
1096 9 : }
1097 :
1098 0 : void SimpleRequest::SetCachedSize(int size) const {
1099 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1100 0 : _cached_size_ = size;
1101 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
1102 0 : }
1103 0 : const ::google::protobuf::Descriptor* SimpleRequest::descriptor() {
1104 0 : protobuf_AssignDescriptorsOnce();
1105 0 : return SimpleRequest_descriptor_;
1106 : }
1107 :
1108 0 : const SimpleRequest& SimpleRequest::default_instance() {
1109 0 : if (default_instance_ == NULL) protobuf_AddDesc_test_2fproto_2fmessages_2eproto();
1110 0 : return *default_instance_;
1111 : }
1112 :
1113 : SimpleRequest* SimpleRequest::default_instance_ = NULL;
1114 :
1115 0 : SimpleRequest* SimpleRequest::New(::google::protobuf::Arena* arena) const {
1116 0 : SimpleRequest* n = new SimpleRequest;
1117 0 : if (arena != NULL) {
1118 0 : arena->Own(n);
1119 : }
1120 0 : return n;
1121 : }
1122 :
1123 4 : void SimpleRequest::Clear() {
1124 : #define ZR_HELPER_(f) reinterpret_cast<char*>(\
1125 : &reinterpret_cast<SimpleRequest*>(16)->f)
1126 :
1127 : #define ZR_(first, last) do {\
1128 : ::memset(&first, 0,\
1129 : ZR_HELPER_(last) - ZR_HELPER_(first) + sizeof(last));\
1130 : } while (0)
1131 :
1132 4 : ZR_(response_type_, response_size_);
1133 4 : ZR_(fill_username_, response_compression_);
1134 4 : if (GetArenaNoVirtual() == NULL && payload_ != NULL) delete payload_;
1135 4 : payload_ = NULL;
1136 4 : if (GetArenaNoVirtual() == NULL && response_status_ != NULL) delete response_status_;
1137 4 : response_status_ = NULL;
1138 :
1139 : #undef ZR_HELPER_
1140 : #undef ZR_
1141 :
1142 4 : }
1143 :
1144 8 : bool SimpleRequest::MergePartialFromCodedStream(
1145 : ::google::protobuf::io::CodedInputStream* input) {
1146 : #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
1147 : ::google::protobuf::uint32 tag;
1148 : // @@protoc_insertion_point(parse_start:grpc.testing.SimpleRequest)
1149 : for (;;) {
1150 : ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
1151 8 : tag = p.first;
1152 12 : if (!p.second) goto handle_unusual;
1153 4 : switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1154 : // optional .grpc.testing.PayloadType response_type = 1;
1155 : case 1: {
1156 0 : if (tag == 8) {
1157 : int value;
1158 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1159 : int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
1160 : input, &value)));
1161 0 : set_response_type(static_cast< ::grpc::testing::PayloadType >(value));
1162 : } else {
1163 0 : goto handle_unusual;
1164 : }
1165 0 : if (input->ExpectTag(16)) goto parse_response_size;
1166 0 : break;
1167 : }
1168 :
1169 : // optional int32 response_size = 2;
1170 : case 2: {
1171 4 : if (tag == 16) {
1172 : parse_response_size:
1173 8 : DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1174 : ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>(
1175 : input, &response_size_)));
1176 :
1177 : } else {
1178 0 : goto handle_unusual;
1179 : }
1180 4 : if (input->ExpectTag(26)) goto parse_payload;
1181 0 : break;
1182 : }
1183 :
1184 : // optional .grpc.testing.Payload payload = 3;
1185 : case 3: {
1186 0 : if (tag == 26) {
1187 : parse_payload:
1188 4 : DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
1189 : input, mutable_payload()));
1190 : } else {
1191 0 : goto handle_unusual;
1192 : }
1193 4 : if (input->ExpectTag(32)) goto parse_fill_username;
1194 4 : break;
1195 : }
1196 :
1197 : // optional bool fill_username = 4;
1198 : case 4: {
1199 0 : if (tag == 32) {
1200 : parse_fill_username:
1201 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1202 : bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
1203 : input, &fill_username_)));
1204 :
1205 : } else {
1206 0 : goto handle_unusual;
1207 : }
1208 0 : if (input->ExpectTag(40)) goto parse_fill_oauth_scope;
1209 0 : break;
1210 : }
1211 :
1212 : // optional bool fill_oauth_scope = 5;
1213 : case 5: {
1214 0 : if (tag == 40) {
1215 : parse_fill_oauth_scope:
1216 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1217 : bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
1218 : input, &fill_oauth_scope_)));
1219 :
1220 : } else {
1221 0 : goto handle_unusual;
1222 : }
1223 0 : if (input->ExpectTag(48)) goto parse_response_compression;
1224 0 : break;
1225 : }
1226 :
1227 : // optional .grpc.testing.CompressionType response_compression = 6;
1228 : case 6: {
1229 0 : if (tag == 48) {
1230 : parse_response_compression:
1231 : int value;
1232 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1233 : int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
1234 : input, &value)));
1235 0 : set_response_compression(static_cast< ::grpc::testing::CompressionType >(value));
1236 : } else {
1237 0 : goto handle_unusual;
1238 : }
1239 0 : if (input->ExpectTag(58)) goto parse_response_status;
1240 0 : break;
1241 : }
1242 :
1243 : // optional .grpc.testing.EchoStatus response_status = 7;
1244 : case 7: {
1245 0 : if (tag == 58) {
1246 : parse_response_status:
1247 0 : DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
1248 : input, mutable_response_status()));
1249 : } else {
1250 0 : goto handle_unusual;
1251 : }
1252 4 : if (input->ExpectAtEnd()) goto success;
1253 0 : break;
1254 : }
1255 :
1256 : default: {
1257 : handle_unusual:
1258 4 : if (tag == 0 ||
1259 0 : ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1260 : ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
1261 4 : goto success;
1262 : }
1263 0 : DO_(::google::protobuf::internal::WireFormatLite::SkipField(input, tag));
1264 0 : break;
1265 : }
1266 : }
1267 4 : }
1268 : success:
1269 : // @@protoc_insertion_point(parse_success:grpc.testing.SimpleRequest)
1270 4 : return true;
1271 : failure:
1272 : // @@protoc_insertion_point(parse_failure:grpc.testing.SimpleRequest)
1273 0 : return false;
1274 : #undef DO_
1275 : }
1276 :
1277 4 : void SimpleRequest::SerializeWithCachedSizes(
1278 : ::google::protobuf::io::CodedOutputStream* output) const {
1279 : // @@protoc_insertion_point(serialize_start:grpc.testing.SimpleRequest)
1280 : // optional .grpc.testing.PayloadType response_type = 1;
1281 4 : if (this->response_type() != 0) {
1282 : ::google::protobuf::internal::WireFormatLite::WriteEnum(
1283 0 : 1, this->response_type(), output);
1284 : }
1285 :
1286 : // optional int32 response_size = 2;
1287 4 : if (this->response_size() != 0) {
1288 4 : ::google::protobuf::internal::WireFormatLite::WriteInt32(2, this->response_size(), output);
1289 : }
1290 :
1291 : // optional .grpc.testing.Payload payload = 3;
1292 4 : if (this->has_payload()) {
1293 : ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
1294 4 : 3, *this->payload_, output);
1295 : }
1296 :
1297 : // optional bool fill_username = 4;
1298 4 : if (this->fill_username() != 0) {
1299 0 : ::google::protobuf::internal::WireFormatLite::WriteBool(4, this->fill_username(), output);
1300 : }
1301 :
1302 : // optional bool fill_oauth_scope = 5;
1303 4 : if (this->fill_oauth_scope() != 0) {
1304 0 : ::google::protobuf::internal::WireFormatLite::WriteBool(5, this->fill_oauth_scope(), output);
1305 : }
1306 :
1307 : // optional .grpc.testing.CompressionType response_compression = 6;
1308 4 : if (this->response_compression() != 0) {
1309 : ::google::protobuf::internal::WireFormatLite::WriteEnum(
1310 0 : 6, this->response_compression(), output);
1311 : }
1312 :
1313 : // optional .grpc.testing.EchoStatus response_status = 7;
1314 4 : if (this->has_response_status()) {
1315 : ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
1316 0 : 7, *this->response_status_, output);
1317 : }
1318 :
1319 : // @@protoc_insertion_point(serialize_end:grpc.testing.SimpleRequest)
1320 4 : }
1321 :
1322 0 : ::google::protobuf::uint8* SimpleRequest::SerializeWithCachedSizesToArray(
1323 : ::google::protobuf::uint8* target) const {
1324 : // @@protoc_insertion_point(serialize_to_array_start:grpc.testing.SimpleRequest)
1325 : // optional .grpc.testing.PayloadType response_type = 1;
1326 0 : if (this->response_type() != 0) {
1327 : target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
1328 0 : 1, this->response_type(), target);
1329 : }
1330 :
1331 : // optional int32 response_size = 2;
1332 0 : if (this->response_size() != 0) {
1333 0 : target = ::google::protobuf::internal::WireFormatLite::WriteInt32ToArray(2, this->response_size(), target);
1334 : }
1335 :
1336 : // optional .grpc.testing.Payload payload = 3;
1337 0 : if (this->has_payload()) {
1338 : target = ::google::protobuf::internal::WireFormatLite::
1339 : WriteMessageNoVirtualToArray(
1340 0 : 3, *this->payload_, target);
1341 : }
1342 :
1343 : // optional bool fill_username = 4;
1344 0 : if (this->fill_username() != 0) {
1345 0 : target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(4, this->fill_username(), target);
1346 : }
1347 :
1348 : // optional bool fill_oauth_scope = 5;
1349 0 : if (this->fill_oauth_scope() != 0) {
1350 0 : target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(5, this->fill_oauth_scope(), target);
1351 : }
1352 :
1353 : // optional .grpc.testing.CompressionType response_compression = 6;
1354 0 : if (this->response_compression() != 0) {
1355 : target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
1356 0 : 6, this->response_compression(), target);
1357 : }
1358 :
1359 : // optional .grpc.testing.EchoStatus response_status = 7;
1360 0 : if (this->has_response_status()) {
1361 : target = ::google::protobuf::internal::WireFormatLite::
1362 : WriteMessageNoVirtualToArray(
1363 0 : 7, *this->response_status_, target);
1364 : }
1365 :
1366 : // @@protoc_insertion_point(serialize_to_array_end:grpc.testing.SimpleRequest)
1367 0 : return target;
1368 : }
1369 :
1370 8 : int SimpleRequest::ByteSize() const {
1371 8 : int total_size = 0;
1372 :
1373 : // optional .grpc.testing.PayloadType response_type = 1;
1374 8 : if (this->response_type() != 0) {
1375 : total_size += 1 +
1376 0 : ::google::protobuf::internal::WireFormatLite::EnumSize(this->response_type());
1377 : }
1378 :
1379 : // optional int32 response_size = 2;
1380 8 : if (this->response_size() != 0) {
1381 : total_size += 1 +
1382 : ::google::protobuf::internal::WireFormatLite::Int32Size(
1383 8 : this->response_size());
1384 : }
1385 :
1386 : // optional .grpc.testing.Payload payload = 3;
1387 8 : if (this->has_payload()) {
1388 : total_size += 1 +
1389 : ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
1390 8 : *this->payload_);
1391 : }
1392 :
1393 : // optional bool fill_username = 4;
1394 8 : if (this->fill_username() != 0) {
1395 0 : total_size += 1 + 1;
1396 : }
1397 :
1398 : // optional bool fill_oauth_scope = 5;
1399 8 : if (this->fill_oauth_scope() != 0) {
1400 0 : total_size += 1 + 1;
1401 : }
1402 :
1403 : // optional .grpc.testing.CompressionType response_compression = 6;
1404 8 : if (this->response_compression() != 0) {
1405 : total_size += 1 +
1406 0 : ::google::protobuf::internal::WireFormatLite::EnumSize(this->response_compression());
1407 : }
1408 :
1409 : // optional .grpc.testing.EchoStatus response_status = 7;
1410 8 : if (this->has_response_status()) {
1411 : total_size += 1 +
1412 : ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
1413 0 : *this->response_status_);
1414 : }
1415 :
1416 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1417 8 : _cached_size_ = total_size;
1418 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
1419 8 : return total_size;
1420 : }
1421 :
1422 0 : void SimpleRequest::MergeFrom(const ::google::protobuf::Message& from) {
1423 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
1424 : const SimpleRequest* source =
1425 : ::google::protobuf::internal::DynamicCastToGenerated<const SimpleRequest>(
1426 0 : &from);
1427 0 : if (source == NULL) {
1428 0 : ::google::protobuf::internal::ReflectionOps::Merge(from, this);
1429 : } else {
1430 0 : MergeFrom(*source);
1431 : }
1432 0 : }
1433 :
1434 0 : void SimpleRequest::MergeFrom(const SimpleRequest& from) {
1435 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
1436 0 : if (from.response_type() != 0) {
1437 0 : set_response_type(from.response_type());
1438 : }
1439 0 : if (from.response_size() != 0) {
1440 0 : set_response_size(from.response_size());
1441 : }
1442 0 : if (from.has_payload()) {
1443 0 : mutable_payload()->::grpc::testing::Payload::MergeFrom(from.payload());
1444 : }
1445 0 : if (from.fill_username() != 0) {
1446 0 : set_fill_username(from.fill_username());
1447 : }
1448 0 : if (from.fill_oauth_scope() != 0) {
1449 0 : set_fill_oauth_scope(from.fill_oauth_scope());
1450 : }
1451 0 : if (from.response_compression() != 0) {
1452 0 : set_response_compression(from.response_compression());
1453 : }
1454 0 : if (from.has_response_status()) {
1455 0 : mutable_response_status()->::grpc::testing::EchoStatus::MergeFrom(from.response_status());
1456 : }
1457 0 : }
1458 :
1459 0 : void SimpleRequest::CopyFrom(const ::google::protobuf::Message& from) {
1460 0 : if (&from == this) return;
1461 0 : Clear();
1462 0 : MergeFrom(from);
1463 : }
1464 :
1465 0 : void SimpleRequest::CopyFrom(const SimpleRequest& from) {
1466 0 : if (&from == this) return;
1467 0 : Clear();
1468 0 : MergeFrom(from);
1469 : }
1470 :
1471 4 : bool SimpleRequest::IsInitialized() const {
1472 :
1473 4 : return true;
1474 : }
1475 :
1476 0 : void SimpleRequest::Swap(SimpleRequest* other) {
1477 0 : if (other == this) return;
1478 0 : InternalSwap(other);
1479 : }
1480 0 : void SimpleRequest::InternalSwap(SimpleRequest* other) {
1481 0 : std::swap(response_type_, other->response_type_);
1482 0 : std::swap(response_size_, other->response_size_);
1483 0 : std::swap(payload_, other->payload_);
1484 0 : std::swap(fill_username_, other->fill_username_);
1485 0 : std::swap(fill_oauth_scope_, other->fill_oauth_scope_);
1486 0 : std::swap(response_compression_, other->response_compression_);
1487 0 : std::swap(response_status_, other->response_status_);
1488 0 : _internal_metadata_.Swap(&other->_internal_metadata_);
1489 0 : std::swap(_cached_size_, other->_cached_size_);
1490 0 : }
1491 :
1492 0 : ::google::protobuf::Metadata SimpleRequest::GetMetadata() const {
1493 0 : protobuf_AssignDescriptorsOnce();
1494 : ::google::protobuf::Metadata metadata;
1495 0 : metadata.descriptor = SimpleRequest_descriptor_;
1496 0 : metadata.reflection = SimpleRequest_reflection_;
1497 0 : return metadata;
1498 : }
1499 :
1500 : #if PROTOBUF_INLINE_NOT_IN_HEADERS
1501 : // SimpleRequest
1502 :
1503 : // optional .grpc.testing.PayloadType response_type = 1;
1504 : void SimpleRequest::clear_response_type() {
1505 : response_type_ = 0;
1506 : }
1507 : ::grpc::testing::PayloadType SimpleRequest::response_type() const {
1508 : // @@protoc_insertion_point(field_get:grpc.testing.SimpleRequest.response_type)
1509 : return static_cast< ::grpc::testing::PayloadType >(response_type_);
1510 : }
1511 : void SimpleRequest::set_response_type(::grpc::testing::PayloadType value) {
1512 :
1513 : response_type_ = value;
1514 : // @@protoc_insertion_point(field_set:grpc.testing.SimpleRequest.response_type)
1515 : }
1516 :
1517 : // optional int32 response_size = 2;
1518 : void SimpleRequest::clear_response_size() {
1519 : response_size_ = 0;
1520 : }
1521 : ::google::protobuf::int32 SimpleRequest::response_size() const {
1522 : // @@protoc_insertion_point(field_get:grpc.testing.SimpleRequest.response_size)
1523 : return response_size_;
1524 : }
1525 : void SimpleRequest::set_response_size(::google::protobuf::int32 value) {
1526 :
1527 : response_size_ = value;
1528 : // @@protoc_insertion_point(field_set:grpc.testing.SimpleRequest.response_size)
1529 : }
1530 :
1531 : // optional .grpc.testing.Payload payload = 3;
1532 : bool SimpleRequest::has_payload() const {
1533 : return !_is_default_instance_ && payload_ != NULL;
1534 : }
1535 : void SimpleRequest::clear_payload() {
1536 : if (GetArenaNoVirtual() == NULL && payload_ != NULL) delete payload_;
1537 : payload_ = NULL;
1538 : }
1539 : const ::grpc::testing::Payload& SimpleRequest::payload() const {
1540 : // @@protoc_insertion_point(field_get:grpc.testing.SimpleRequest.payload)
1541 : return payload_ != NULL ? *payload_ : *default_instance_->payload_;
1542 : }
1543 : ::grpc::testing::Payload* SimpleRequest::mutable_payload() {
1544 :
1545 : if (payload_ == NULL) {
1546 : payload_ = new ::grpc::testing::Payload;
1547 : }
1548 : // @@protoc_insertion_point(field_mutable:grpc.testing.SimpleRequest.payload)
1549 : return payload_;
1550 : }
1551 : ::grpc::testing::Payload* SimpleRequest::release_payload() {
1552 :
1553 : ::grpc::testing::Payload* temp = payload_;
1554 : payload_ = NULL;
1555 : return temp;
1556 : }
1557 : void SimpleRequest::set_allocated_payload(::grpc::testing::Payload* payload) {
1558 : delete payload_;
1559 : payload_ = payload;
1560 : if (payload) {
1561 :
1562 : } else {
1563 :
1564 : }
1565 : // @@protoc_insertion_point(field_set_allocated:grpc.testing.SimpleRequest.payload)
1566 : }
1567 :
1568 : // optional bool fill_username = 4;
1569 : void SimpleRequest::clear_fill_username() {
1570 : fill_username_ = false;
1571 : }
1572 : bool SimpleRequest::fill_username() const {
1573 : // @@protoc_insertion_point(field_get:grpc.testing.SimpleRequest.fill_username)
1574 : return fill_username_;
1575 : }
1576 : void SimpleRequest::set_fill_username(bool value) {
1577 :
1578 : fill_username_ = value;
1579 : // @@protoc_insertion_point(field_set:grpc.testing.SimpleRequest.fill_username)
1580 : }
1581 :
1582 : // optional bool fill_oauth_scope = 5;
1583 : void SimpleRequest::clear_fill_oauth_scope() {
1584 : fill_oauth_scope_ = false;
1585 : }
1586 : bool SimpleRequest::fill_oauth_scope() const {
1587 : // @@protoc_insertion_point(field_get:grpc.testing.SimpleRequest.fill_oauth_scope)
1588 : return fill_oauth_scope_;
1589 : }
1590 : void SimpleRequest::set_fill_oauth_scope(bool value) {
1591 :
1592 : fill_oauth_scope_ = value;
1593 : // @@protoc_insertion_point(field_set:grpc.testing.SimpleRequest.fill_oauth_scope)
1594 : }
1595 :
1596 : // optional .grpc.testing.CompressionType response_compression = 6;
1597 : void SimpleRequest::clear_response_compression() {
1598 : response_compression_ = 0;
1599 : }
1600 : ::grpc::testing::CompressionType SimpleRequest::response_compression() const {
1601 : // @@protoc_insertion_point(field_get:grpc.testing.SimpleRequest.response_compression)
1602 : return static_cast< ::grpc::testing::CompressionType >(response_compression_);
1603 : }
1604 : void SimpleRequest::set_response_compression(::grpc::testing::CompressionType value) {
1605 :
1606 : response_compression_ = value;
1607 : // @@protoc_insertion_point(field_set:grpc.testing.SimpleRequest.response_compression)
1608 : }
1609 :
1610 : // optional .grpc.testing.EchoStatus response_status = 7;
1611 : bool SimpleRequest::has_response_status() const {
1612 : return !_is_default_instance_ && response_status_ != NULL;
1613 : }
1614 : void SimpleRequest::clear_response_status() {
1615 : if (GetArenaNoVirtual() == NULL && response_status_ != NULL) delete response_status_;
1616 : response_status_ = NULL;
1617 : }
1618 : const ::grpc::testing::EchoStatus& SimpleRequest::response_status() const {
1619 : // @@protoc_insertion_point(field_get:grpc.testing.SimpleRequest.response_status)
1620 : return response_status_ != NULL ? *response_status_ : *default_instance_->response_status_;
1621 : }
1622 : ::grpc::testing::EchoStatus* SimpleRequest::mutable_response_status() {
1623 :
1624 : if (response_status_ == NULL) {
1625 : response_status_ = new ::grpc::testing::EchoStatus;
1626 : }
1627 : // @@protoc_insertion_point(field_mutable:grpc.testing.SimpleRequest.response_status)
1628 : return response_status_;
1629 : }
1630 : ::grpc::testing::EchoStatus* SimpleRequest::release_response_status() {
1631 :
1632 : ::grpc::testing::EchoStatus* temp = response_status_;
1633 : response_status_ = NULL;
1634 : return temp;
1635 : }
1636 : void SimpleRequest::set_allocated_response_status(::grpc::testing::EchoStatus* response_status) {
1637 : delete response_status_;
1638 : response_status_ = response_status;
1639 : if (response_status) {
1640 :
1641 : } else {
1642 :
1643 : }
1644 : // @@protoc_insertion_point(field_set_allocated:grpc.testing.SimpleRequest.response_status)
1645 : }
1646 :
1647 : #endif // PROTOBUF_INLINE_NOT_IN_HEADERS
1648 :
1649 : // ===================================================================
1650 :
1651 : #ifndef _MSC_VER
1652 : const int SimpleResponse::kPayloadFieldNumber;
1653 : const int SimpleResponse::kUsernameFieldNumber;
1654 : const int SimpleResponse::kOauthScopeFieldNumber;
1655 : #endif // !_MSC_VER
1656 :
1657 14 : SimpleResponse::SimpleResponse()
1658 14 : : ::google::protobuf::Message(), _internal_metadata_(NULL) {
1659 14 : SharedCtor();
1660 : // @@protoc_insertion_point(constructor:grpc.testing.SimpleResponse)
1661 14 : }
1662 :
1663 5 : void SimpleResponse::InitAsDefaultInstance() {
1664 5 : _is_default_instance_ = true;
1665 5 : payload_ = const_cast< ::grpc::testing::Payload*>(&::grpc::testing::Payload::default_instance());
1666 5 : }
1667 :
1668 0 : SimpleResponse::SimpleResponse(const SimpleResponse& from)
1669 : : ::google::protobuf::Message(),
1670 0 : _internal_metadata_(NULL) {
1671 0 : SharedCtor();
1672 0 : MergeFrom(from);
1673 : // @@protoc_insertion_point(copy_constructor:grpc.testing.SimpleResponse)
1674 0 : }
1675 :
1676 14 : void SimpleResponse::SharedCtor() {
1677 14 : _is_default_instance_ = false;
1678 14 : ::google::protobuf::internal::GetEmptyString();
1679 14 : _cached_size_ = 0;
1680 14 : payload_ = NULL;
1681 14 : username_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1682 14 : oauth_scope_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1683 14 : }
1684 :
1685 18 : SimpleResponse::~SimpleResponse() {
1686 : // @@protoc_insertion_point(destructor:grpc.testing.SimpleResponse)
1687 9 : SharedDtor();
1688 9 : }
1689 :
1690 9 : void SimpleResponse::SharedDtor() {
1691 9 : username_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1692 9 : oauth_scope_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1693 9 : if (this != default_instance_) {
1694 9 : delete payload_;
1695 : }
1696 9 : }
1697 :
1698 0 : void SimpleResponse::SetCachedSize(int size) const {
1699 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1700 0 : _cached_size_ = size;
1701 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
1702 0 : }
1703 0 : const ::google::protobuf::Descriptor* SimpleResponse::descriptor() {
1704 0 : protobuf_AssignDescriptorsOnce();
1705 0 : return SimpleResponse_descriptor_;
1706 : }
1707 :
1708 0 : const SimpleResponse& SimpleResponse::default_instance() {
1709 0 : if (default_instance_ == NULL) protobuf_AddDesc_test_2fproto_2fmessages_2eproto();
1710 0 : return *default_instance_;
1711 : }
1712 :
1713 : SimpleResponse* SimpleResponse::default_instance_ = NULL;
1714 :
1715 0 : SimpleResponse* SimpleResponse::New(::google::protobuf::Arena* arena) const {
1716 0 : SimpleResponse* n = new SimpleResponse;
1717 0 : if (arena != NULL) {
1718 0 : arena->Own(n);
1719 : }
1720 0 : return n;
1721 : }
1722 :
1723 4 : void SimpleResponse::Clear() {
1724 4 : if (GetArenaNoVirtual() == NULL && payload_ != NULL) delete payload_;
1725 4 : payload_ = NULL;
1726 4 : username_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1727 4 : oauth_scope_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
1728 4 : }
1729 :
1730 8 : bool SimpleResponse::MergePartialFromCodedStream(
1731 : ::google::protobuf::io::CodedInputStream* input) {
1732 : #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
1733 : ::google::protobuf::uint32 tag;
1734 : // @@protoc_insertion_point(parse_start:grpc.testing.SimpleResponse)
1735 : for (;;) {
1736 : ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
1737 8 : tag = p.first;
1738 12 : if (!p.second) goto handle_unusual;
1739 4 : switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1740 : // optional .grpc.testing.Payload payload = 1;
1741 : case 1: {
1742 4 : if (tag == 10) {
1743 4 : DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
1744 : input, mutable_payload()));
1745 : } else {
1746 0 : goto handle_unusual;
1747 : }
1748 4 : if (input->ExpectTag(18)) goto parse_username;
1749 4 : break;
1750 : }
1751 :
1752 : // optional string username = 2;
1753 : case 2: {
1754 0 : if (tag == 18) {
1755 : parse_username:
1756 0 : DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1757 : input, this->mutable_username()));
1758 0 : DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String(
1759 : this->username().data(), this->username().length(),
1760 : ::google::protobuf::internal::WireFormatLite::PARSE,
1761 : "grpc.testing.SimpleResponse.username"));
1762 : } else {
1763 0 : goto handle_unusual;
1764 : }
1765 0 : if (input->ExpectTag(26)) goto parse_oauth_scope;
1766 0 : break;
1767 : }
1768 :
1769 : // optional string oauth_scope = 3;
1770 : case 3: {
1771 0 : if (tag == 26) {
1772 : parse_oauth_scope:
1773 0 : DO_(::google::protobuf::internal::WireFormatLite::ReadString(
1774 : input, this->mutable_oauth_scope()));
1775 0 : DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String(
1776 : this->oauth_scope().data(), this->oauth_scope().length(),
1777 : ::google::protobuf::internal::WireFormatLite::PARSE,
1778 : "grpc.testing.SimpleResponse.oauth_scope"));
1779 : } else {
1780 0 : goto handle_unusual;
1781 : }
1782 4 : if (input->ExpectAtEnd()) goto success;
1783 0 : break;
1784 : }
1785 :
1786 : default: {
1787 : handle_unusual:
1788 4 : if (tag == 0 ||
1789 0 : ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
1790 : ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
1791 4 : goto success;
1792 : }
1793 0 : DO_(::google::protobuf::internal::WireFormatLite::SkipField(input, tag));
1794 0 : break;
1795 : }
1796 : }
1797 4 : }
1798 : success:
1799 : // @@protoc_insertion_point(parse_success:grpc.testing.SimpleResponse)
1800 4 : return true;
1801 : failure:
1802 : // @@protoc_insertion_point(parse_failure:grpc.testing.SimpleResponse)
1803 0 : return false;
1804 : #undef DO_
1805 : }
1806 :
1807 4 : void SimpleResponse::SerializeWithCachedSizes(
1808 : ::google::protobuf::io::CodedOutputStream* output) const {
1809 : // @@protoc_insertion_point(serialize_start:grpc.testing.SimpleResponse)
1810 : // optional .grpc.testing.Payload payload = 1;
1811 4 : if (this->has_payload()) {
1812 : ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
1813 4 : 1, *this->payload_, output);
1814 : }
1815 :
1816 : // optional string username = 2;
1817 4 : if (this->username().size() > 0) {
1818 : ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(
1819 0 : this->username().data(), this->username().length(),
1820 : ::google::protobuf::internal::WireFormatLite::SERIALIZE,
1821 0 : "grpc.testing.SimpleResponse.username");
1822 : ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
1823 0 : 2, this->username(), output);
1824 : }
1825 :
1826 : // optional string oauth_scope = 3;
1827 4 : if (this->oauth_scope().size() > 0) {
1828 : ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(
1829 0 : this->oauth_scope().data(), this->oauth_scope().length(),
1830 : ::google::protobuf::internal::WireFormatLite::SERIALIZE,
1831 0 : "grpc.testing.SimpleResponse.oauth_scope");
1832 : ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
1833 0 : 3, this->oauth_scope(), output);
1834 : }
1835 :
1836 : // @@protoc_insertion_point(serialize_end:grpc.testing.SimpleResponse)
1837 4 : }
1838 :
1839 0 : ::google::protobuf::uint8* SimpleResponse::SerializeWithCachedSizesToArray(
1840 : ::google::protobuf::uint8* target) const {
1841 : // @@protoc_insertion_point(serialize_to_array_start:grpc.testing.SimpleResponse)
1842 : // optional .grpc.testing.Payload payload = 1;
1843 0 : if (this->has_payload()) {
1844 : target = ::google::protobuf::internal::WireFormatLite::
1845 : WriteMessageNoVirtualToArray(
1846 0 : 1, *this->payload_, target);
1847 : }
1848 :
1849 : // optional string username = 2;
1850 0 : if (this->username().size() > 0) {
1851 : ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(
1852 0 : this->username().data(), this->username().length(),
1853 : ::google::protobuf::internal::WireFormatLite::SERIALIZE,
1854 0 : "grpc.testing.SimpleResponse.username");
1855 : target =
1856 : ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1857 0 : 2, this->username(), target);
1858 : }
1859 :
1860 : // optional string oauth_scope = 3;
1861 0 : if (this->oauth_scope().size() > 0) {
1862 : ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(
1863 0 : this->oauth_scope().data(), this->oauth_scope().length(),
1864 : ::google::protobuf::internal::WireFormatLite::SERIALIZE,
1865 0 : "grpc.testing.SimpleResponse.oauth_scope");
1866 : target =
1867 : ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
1868 0 : 3, this->oauth_scope(), target);
1869 : }
1870 :
1871 : // @@protoc_insertion_point(serialize_to_array_end:grpc.testing.SimpleResponse)
1872 0 : return target;
1873 : }
1874 :
1875 8 : int SimpleResponse::ByteSize() const {
1876 8 : int total_size = 0;
1877 :
1878 : // optional .grpc.testing.Payload payload = 1;
1879 8 : if (this->has_payload()) {
1880 : total_size += 1 +
1881 : ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
1882 8 : *this->payload_);
1883 : }
1884 :
1885 : // optional string username = 2;
1886 8 : if (this->username().size() > 0) {
1887 : total_size += 1 +
1888 : ::google::protobuf::internal::WireFormatLite::StringSize(
1889 0 : this->username());
1890 : }
1891 :
1892 : // optional string oauth_scope = 3;
1893 8 : if (this->oauth_scope().size() > 0) {
1894 : total_size += 1 +
1895 : ::google::protobuf::internal::WireFormatLite::StringSize(
1896 0 : this->oauth_scope());
1897 : }
1898 :
1899 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1900 8 : _cached_size_ = total_size;
1901 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
1902 8 : return total_size;
1903 : }
1904 :
1905 0 : void SimpleResponse::MergeFrom(const ::google::protobuf::Message& from) {
1906 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
1907 : const SimpleResponse* source =
1908 : ::google::protobuf::internal::DynamicCastToGenerated<const SimpleResponse>(
1909 0 : &from);
1910 0 : if (source == NULL) {
1911 0 : ::google::protobuf::internal::ReflectionOps::Merge(from, this);
1912 : } else {
1913 0 : MergeFrom(*source);
1914 : }
1915 0 : }
1916 :
1917 0 : void SimpleResponse::MergeFrom(const SimpleResponse& from) {
1918 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
1919 0 : if (from.has_payload()) {
1920 0 : mutable_payload()->::grpc::testing::Payload::MergeFrom(from.payload());
1921 : }
1922 0 : if (from.username().size() > 0) {
1923 :
1924 0 : username_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.username_);
1925 : }
1926 0 : if (from.oauth_scope().size() > 0) {
1927 :
1928 0 : oauth_scope_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.oauth_scope_);
1929 : }
1930 0 : }
1931 :
1932 0 : void SimpleResponse::CopyFrom(const ::google::protobuf::Message& from) {
1933 0 : if (&from == this) return;
1934 0 : Clear();
1935 0 : MergeFrom(from);
1936 : }
1937 :
1938 0 : void SimpleResponse::CopyFrom(const SimpleResponse& from) {
1939 0 : if (&from == this) return;
1940 0 : Clear();
1941 0 : MergeFrom(from);
1942 : }
1943 :
1944 4 : bool SimpleResponse::IsInitialized() const {
1945 :
1946 4 : return true;
1947 : }
1948 :
1949 0 : void SimpleResponse::Swap(SimpleResponse* other) {
1950 0 : if (other == this) return;
1951 0 : InternalSwap(other);
1952 : }
1953 0 : void SimpleResponse::InternalSwap(SimpleResponse* other) {
1954 0 : std::swap(payload_, other->payload_);
1955 0 : username_.Swap(&other->username_);
1956 0 : oauth_scope_.Swap(&other->oauth_scope_);
1957 0 : _internal_metadata_.Swap(&other->_internal_metadata_);
1958 0 : std::swap(_cached_size_, other->_cached_size_);
1959 0 : }
1960 :
1961 0 : ::google::protobuf::Metadata SimpleResponse::GetMetadata() const {
1962 0 : protobuf_AssignDescriptorsOnce();
1963 : ::google::protobuf::Metadata metadata;
1964 0 : metadata.descriptor = SimpleResponse_descriptor_;
1965 0 : metadata.reflection = SimpleResponse_reflection_;
1966 0 : return metadata;
1967 : }
1968 :
1969 : #if PROTOBUF_INLINE_NOT_IN_HEADERS
1970 : // SimpleResponse
1971 :
1972 : // optional .grpc.testing.Payload payload = 1;
1973 : bool SimpleResponse::has_payload() const {
1974 : return !_is_default_instance_ && payload_ != NULL;
1975 : }
1976 : void SimpleResponse::clear_payload() {
1977 : if (GetArenaNoVirtual() == NULL && payload_ != NULL) delete payload_;
1978 : payload_ = NULL;
1979 : }
1980 : const ::grpc::testing::Payload& SimpleResponse::payload() const {
1981 : // @@protoc_insertion_point(field_get:grpc.testing.SimpleResponse.payload)
1982 : return payload_ != NULL ? *payload_ : *default_instance_->payload_;
1983 : }
1984 : ::grpc::testing::Payload* SimpleResponse::mutable_payload() {
1985 :
1986 : if (payload_ == NULL) {
1987 : payload_ = new ::grpc::testing::Payload;
1988 : }
1989 : // @@protoc_insertion_point(field_mutable:grpc.testing.SimpleResponse.payload)
1990 : return payload_;
1991 : }
1992 : ::grpc::testing::Payload* SimpleResponse::release_payload() {
1993 :
1994 : ::grpc::testing::Payload* temp = payload_;
1995 : payload_ = NULL;
1996 : return temp;
1997 : }
1998 : void SimpleResponse::set_allocated_payload(::grpc::testing::Payload* payload) {
1999 : delete payload_;
2000 : payload_ = payload;
2001 : if (payload) {
2002 :
2003 : } else {
2004 :
2005 : }
2006 : // @@protoc_insertion_point(field_set_allocated:grpc.testing.SimpleResponse.payload)
2007 : }
2008 :
2009 : // optional string username = 2;
2010 : void SimpleResponse::clear_username() {
2011 : username_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2012 : }
2013 : const ::std::string& SimpleResponse::username() const {
2014 : // @@protoc_insertion_point(field_get:grpc.testing.SimpleResponse.username)
2015 : return username_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2016 : }
2017 : void SimpleResponse::set_username(const ::std::string& value) {
2018 :
2019 : username_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
2020 : // @@protoc_insertion_point(field_set:grpc.testing.SimpleResponse.username)
2021 : }
2022 : void SimpleResponse::set_username(const char* value) {
2023 :
2024 : username_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
2025 : // @@protoc_insertion_point(field_set_char:grpc.testing.SimpleResponse.username)
2026 : }
2027 : void SimpleResponse::set_username(const char* value, size_t size) {
2028 :
2029 : username_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
2030 : ::std::string(reinterpret_cast<const char*>(value), size));
2031 : // @@protoc_insertion_point(field_set_pointer:grpc.testing.SimpleResponse.username)
2032 : }
2033 : ::std::string* SimpleResponse::mutable_username() {
2034 :
2035 : // @@protoc_insertion_point(field_mutable:grpc.testing.SimpleResponse.username)
2036 : return username_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2037 : }
2038 : ::std::string* SimpleResponse::release_username() {
2039 :
2040 : return username_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2041 : }
2042 : void SimpleResponse::set_allocated_username(::std::string* username) {
2043 : if (username != NULL) {
2044 :
2045 : } else {
2046 :
2047 : }
2048 : username_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), username);
2049 : // @@protoc_insertion_point(field_set_allocated:grpc.testing.SimpleResponse.username)
2050 : }
2051 :
2052 : // optional string oauth_scope = 3;
2053 : void SimpleResponse::clear_oauth_scope() {
2054 : oauth_scope_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2055 : }
2056 : const ::std::string& SimpleResponse::oauth_scope() const {
2057 : // @@protoc_insertion_point(field_get:grpc.testing.SimpleResponse.oauth_scope)
2058 : return oauth_scope_.GetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2059 : }
2060 : void SimpleResponse::set_oauth_scope(const ::std::string& value) {
2061 :
2062 : oauth_scope_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), value);
2063 : // @@protoc_insertion_point(field_set:grpc.testing.SimpleResponse.oauth_scope)
2064 : }
2065 : void SimpleResponse::set_oauth_scope(const char* value) {
2066 :
2067 : oauth_scope_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), ::std::string(value));
2068 : // @@protoc_insertion_point(field_set_char:grpc.testing.SimpleResponse.oauth_scope)
2069 : }
2070 : void SimpleResponse::set_oauth_scope(const char* value, size_t size) {
2071 :
2072 : oauth_scope_.SetNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(),
2073 : ::std::string(reinterpret_cast<const char*>(value), size));
2074 : // @@protoc_insertion_point(field_set_pointer:grpc.testing.SimpleResponse.oauth_scope)
2075 : }
2076 : ::std::string* SimpleResponse::mutable_oauth_scope() {
2077 :
2078 : // @@protoc_insertion_point(field_mutable:grpc.testing.SimpleResponse.oauth_scope)
2079 : return oauth_scope_.MutableNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2080 : }
2081 : ::std::string* SimpleResponse::release_oauth_scope() {
2082 :
2083 : return oauth_scope_.ReleaseNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2084 : }
2085 : void SimpleResponse::set_allocated_oauth_scope(::std::string* oauth_scope) {
2086 : if (oauth_scope != NULL) {
2087 :
2088 : } else {
2089 :
2090 : }
2091 : oauth_scope_.SetAllocatedNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), oauth_scope);
2092 : // @@protoc_insertion_point(field_set_allocated:grpc.testing.SimpleResponse.oauth_scope)
2093 : }
2094 :
2095 : #endif // PROTOBUF_INLINE_NOT_IN_HEADERS
2096 :
2097 : // ===================================================================
2098 :
2099 : #ifndef _MSC_VER
2100 : const int StreamingInputCallRequest::kPayloadFieldNumber;
2101 : #endif // !_MSC_VER
2102 :
2103 5 : StreamingInputCallRequest::StreamingInputCallRequest()
2104 5 : : ::google::protobuf::Message(), _internal_metadata_(NULL) {
2105 5 : SharedCtor();
2106 : // @@protoc_insertion_point(constructor:grpc.testing.StreamingInputCallRequest)
2107 5 : }
2108 :
2109 5 : void StreamingInputCallRequest::InitAsDefaultInstance() {
2110 5 : _is_default_instance_ = true;
2111 5 : payload_ = const_cast< ::grpc::testing::Payload*>(&::grpc::testing::Payload::default_instance());
2112 5 : }
2113 :
2114 0 : StreamingInputCallRequest::StreamingInputCallRequest(const StreamingInputCallRequest& from)
2115 : : ::google::protobuf::Message(),
2116 0 : _internal_metadata_(NULL) {
2117 0 : SharedCtor();
2118 0 : MergeFrom(from);
2119 : // @@protoc_insertion_point(copy_constructor:grpc.testing.StreamingInputCallRequest)
2120 0 : }
2121 :
2122 5 : void StreamingInputCallRequest::SharedCtor() {
2123 5 : _is_default_instance_ = false;
2124 5 : _cached_size_ = 0;
2125 5 : payload_ = NULL;
2126 5 : }
2127 :
2128 0 : StreamingInputCallRequest::~StreamingInputCallRequest() {
2129 : // @@protoc_insertion_point(destructor:grpc.testing.StreamingInputCallRequest)
2130 0 : SharedDtor();
2131 0 : }
2132 :
2133 0 : void StreamingInputCallRequest::SharedDtor() {
2134 0 : if (this != default_instance_) {
2135 0 : delete payload_;
2136 : }
2137 0 : }
2138 :
2139 0 : void StreamingInputCallRequest::SetCachedSize(int size) const {
2140 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2141 0 : _cached_size_ = size;
2142 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
2143 0 : }
2144 0 : const ::google::protobuf::Descriptor* StreamingInputCallRequest::descriptor() {
2145 0 : protobuf_AssignDescriptorsOnce();
2146 0 : return StreamingInputCallRequest_descriptor_;
2147 : }
2148 :
2149 0 : const StreamingInputCallRequest& StreamingInputCallRequest::default_instance() {
2150 0 : if (default_instance_ == NULL) protobuf_AddDesc_test_2fproto_2fmessages_2eproto();
2151 0 : return *default_instance_;
2152 : }
2153 :
2154 : StreamingInputCallRequest* StreamingInputCallRequest::default_instance_ = NULL;
2155 :
2156 0 : StreamingInputCallRequest* StreamingInputCallRequest::New(::google::protobuf::Arena* arena) const {
2157 0 : StreamingInputCallRequest* n = new StreamingInputCallRequest;
2158 0 : if (arena != NULL) {
2159 0 : arena->Own(n);
2160 : }
2161 0 : return n;
2162 : }
2163 :
2164 0 : void StreamingInputCallRequest::Clear() {
2165 0 : if (GetArenaNoVirtual() == NULL && payload_ != NULL) delete payload_;
2166 0 : payload_ = NULL;
2167 0 : }
2168 :
2169 0 : bool StreamingInputCallRequest::MergePartialFromCodedStream(
2170 : ::google::protobuf::io::CodedInputStream* input) {
2171 : #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
2172 : ::google::protobuf::uint32 tag;
2173 : // @@protoc_insertion_point(parse_start:grpc.testing.StreamingInputCallRequest)
2174 : for (;;) {
2175 : ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
2176 0 : tag = p.first;
2177 0 : if (!p.second) goto handle_unusual;
2178 0 : switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2179 : // optional .grpc.testing.Payload payload = 1;
2180 : case 1: {
2181 0 : if (tag == 10) {
2182 0 : DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
2183 : input, mutable_payload()));
2184 : } else {
2185 0 : goto handle_unusual;
2186 : }
2187 0 : if (input->ExpectAtEnd()) goto success;
2188 0 : break;
2189 : }
2190 :
2191 : default: {
2192 : handle_unusual:
2193 0 : if (tag == 0 ||
2194 0 : ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2195 : ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2196 0 : goto success;
2197 : }
2198 0 : DO_(::google::protobuf::internal::WireFormatLite::SkipField(input, tag));
2199 0 : break;
2200 : }
2201 : }
2202 0 : }
2203 : success:
2204 : // @@protoc_insertion_point(parse_success:grpc.testing.StreamingInputCallRequest)
2205 0 : return true;
2206 : failure:
2207 : // @@protoc_insertion_point(parse_failure:grpc.testing.StreamingInputCallRequest)
2208 0 : return false;
2209 : #undef DO_
2210 : }
2211 :
2212 0 : void StreamingInputCallRequest::SerializeWithCachedSizes(
2213 : ::google::protobuf::io::CodedOutputStream* output) const {
2214 : // @@protoc_insertion_point(serialize_start:grpc.testing.StreamingInputCallRequest)
2215 : // optional .grpc.testing.Payload payload = 1;
2216 0 : if (this->has_payload()) {
2217 : ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2218 0 : 1, *this->payload_, output);
2219 : }
2220 :
2221 : // @@protoc_insertion_point(serialize_end:grpc.testing.StreamingInputCallRequest)
2222 0 : }
2223 :
2224 0 : ::google::protobuf::uint8* StreamingInputCallRequest::SerializeWithCachedSizesToArray(
2225 : ::google::protobuf::uint8* target) const {
2226 : // @@protoc_insertion_point(serialize_to_array_start:grpc.testing.StreamingInputCallRequest)
2227 : // optional .grpc.testing.Payload payload = 1;
2228 0 : if (this->has_payload()) {
2229 : target = ::google::protobuf::internal::WireFormatLite::
2230 : WriteMessageNoVirtualToArray(
2231 0 : 1, *this->payload_, target);
2232 : }
2233 :
2234 : // @@protoc_insertion_point(serialize_to_array_end:grpc.testing.StreamingInputCallRequest)
2235 0 : return target;
2236 : }
2237 :
2238 0 : int StreamingInputCallRequest::ByteSize() const {
2239 0 : int total_size = 0;
2240 :
2241 : // optional .grpc.testing.Payload payload = 1;
2242 0 : if (this->has_payload()) {
2243 : total_size += 1 +
2244 : ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
2245 0 : *this->payload_);
2246 : }
2247 :
2248 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2249 0 : _cached_size_ = total_size;
2250 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
2251 0 : return total_size;
2252 : }
2253 :
2254 0 : void StreamingInputCallRequest::MergeFrom(const ::google::protobuf::Message& from) {
2255 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
2256 : const StreamingInputCallRequest* source =
2257 : ::google::protobuf::internal::DynamicCastToGenerated<const StreamingInputCallRequest>(
2258 0 : &from);
2259 0 : if (source == NULL) {
2260 0 : ::google::protobuf::internal::ReflectionOps::Merge(from, this);
2261 : } else {
2262 0 : MergeFrom(*source);
2263 : }
2264 0 : }
2265 :
2266 0 : void StreamingInputCallRequest::MergeFrom(const StreamingInputCallRequest& from) {
2267 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
2268 0 : if (from.has_payload()) {
2269 0 : mutable_payload()->::grpc::testing::Payload::MergeFrom(from.payload());
2270 : }
2271 0 : }
2272 :
2273 0 : void StreamingInputCallRequest::CopyFrom(const ::google::protobuf::Message& from) {
2274 0 : if (&from == this) return;
2275 0 : Clear();
2276 0 : MergeFrom(from);
2277 : }
2278 :
2279 0 : void StreamingInputCallRequest::CopyFrom(const StreamingInputCallRequest& from) {
2280 0 : if (&from == this) return;
2281 0 : Clear();
2282 0 : MergeFrom(from);
2283 : }
2284 :
2285 0 : bool StreamingInputCallRequest::IsInitialized() const {
2286 :
2287 0 : return true;
2288 : }
2289 :
2290 0 : void StreamingInputCallRequest::Swap(StreamingInputCallRequest* other) {
2291 0 : if (other == this) return;
2292 0 : InternalSwap(other);
2293 : }
2294 0 : void StreamingInputCallRequest::InternalSwap(StreamingInputCallRequest* other) {
2295 0 : std::swap(payload_, other->payload_);
2296 0 : _internal_metadata_.Swap(&other->_internal_metadata_);
2297 0 : std::swap(_cached_size_, other->_cached_size_);
2298 0 : }
2299 :
2300 0 : ::google::protobuf::Metadata StreamingInputCallRequest::GetMetadata() const {
2301 0 : protobuf_AssignDescriptorsOnce();
2302 : ::google::protobuf::Metadata metadata;
2303 0 : metadata.descriptor = StreamingInputCallRequest_descriptor_;
2304 0 : metadata.reflection = StreamingInputCallRequest_reflection_;
2305 0 : return metadata;
2306 : }
2307 :
2308 : #if PROTOBUF_INLINE_NOT_IN_HEADERS
2309 : // StreamingInputCallRequest
2310 :
2311 : // optional .grpc.testing.Payload payload = 1;
2312 : bool StreamingInputCallRequest::has_payload() const {
2313 : return !_is_default_instance_ && payload_ != NULL;
2314 : }
2315 : void StreamingInputCallRequest::clear_payload() {
2316 : if (GetArenaNoVirtual() == NULL && payload_ != NULL) delete payload_;
2317 : payload_ = NULL;
2318 : }
2319 : const ::grpc::testing::Payload& StreamingInputCallRequest::payload() const {
2320 : // @@protoc_insertion_point(field_get:grpc.testing.StreamingInputCallRequest.payload)
2321 : return payload_ != NULL ? *payload_ : *default_instance_->payload_;
2322 : }
2323 : ::grpc::testing::Payload* StreamingInputCallRequest::mutable_payload() {
2324 :
2325 : if (payload_ == NULL) {
2326 : payload_ = new ::grpc::testing::Payload;
2327 : }
2328 : // @@protoc_insertion_point(field_mutable:grpc.testing.StreamingInputCallRequest.payload)
2329 : return payload_;
2330 : }
2331 : ::grpc::testing::Payload* StreamingInputCallRequest::release_payload() {
2332 :
2333 : ::grpc::testing::Payload* temp = payload_;
2334 : payload_ = NULL;
2335 : return temp;
2336 : }
2337 : void StreamingInputCallRequest::set_allocated_payload(::grpc::testing::Payload* payload) {
2338 : delete payload_;
2339 : payload_ = payload;
2340 : if (payload) {
2341 :
2342 : } else {
2343 :
2344 : }
2345 : // @@protoc_insertion_point(field_set_allocated:grpc.testing.StreamingInputCallRequest.payload)
2346 : }
2347 :
2348 : #endif // PROTOBUF_INLINE_NOT_IN_HEADERS
2349 :
2350 : // ===================================================================
2351 :
2352 : #ifndef _MSC_VER
2353 : const int StreamingInputCallResponse::kAggregatedPayloadSizeFieldNumber;
2354 : #endif // !_MSC_VER
2355 :
2356 5 : StreamingInputCallResponse::StreamingInputCallResponse()
2357 5 : : ::google::protobuf::Message(), _internal_metadata_(NULL) {
2358 5 : SharedCtor();
2359 : // @@protoc_insertion_point(constructor:grpc.testing.StreamingInputCallResponse)
2360 5 : }
2361 :
2362 5 : void StreamingInputCallResponse::InitAsDefaultInstance() {
2363 5 : _is_default_instance_ = true;
2364 5 : }
2365 :
2366 0 : StreamingInputCallResponse::StreamingInputCallResponse(const StreamingInputCallResponse& from)
2367 : : ::google::protobuf::Message(),
2368 0 : _internal_metadata_(NULL) {
2369 0 : SharedCtor();
2370 0 : MergeFrom(from);
2371 : // @@protoc_insertion_point(copy_constructor:grpc.testing.StreamingInputCallResponse)
2372 0 : }
2373 :
2374 5 : void StreamingInputCallResponse::SharedCtor() {
2375 5 : _is_default_instance_ = false;
2376 5 : _cached_size_ = 0;
2377 5 : aggregated_payload_size_ = 0;
2378 5 : }
2379 :
2380 0 : StreamingInputCallResponse::~StreamingInputCallResponse() {
2381 : // @@protoc_insertion_point(destructor:grpc.testing.StreamingInputCallResponse)
2382 0 : SharedDtor();
2383 0 : }
2384 :
2385 0 : void StreamingInputCallResponse::SharedDtor() {
2386 0 : if (this != default_instance_) {
2387 : }
2388 0 : }
2389 :
2390 0 : void StreamingInputCallResponse::SetCachedSize(int size) const {
2391 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2392 0 : _cached_size_ = size;
2393 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
2394 0 : }
2395 0 : const ::google::protobuf::Descriptor* StreamingInputCallResponse::descriptor() {
2396 0 : protobuf_AssignDescriptorsOnce();
2397 0 : return StreamingInputCallResponse_descriptor_;
2398 : }
2399 :
2400 0 : const StreamingInputCallResponse& StreamingInputCallResponse::default_instance() {
2401 0 : if (default_instance_ == NULL) protobuf_AddDesc_test_2fproto_2fmessages_2eproto();
2402 0 : return *default_instance_;
2403 : }
2404 :
2405 : StreamingInputCallResponse* StreamingInputCallResponse::default_instance_ = NULL;
2406 :
2407 0 : StreamingInputCallResponse* StreamingInputCallResponse::New(::google::protobuf::Arena* arena) const {
2408 0 : StreamingInputCallResponse* n = new StreamingInputCallResponse;
2409 0 : if (arena != NULL) {
2410 0 : arena->Own(n);
2411 : }
2412 0 : return n;
2413 : }
2414 :
2415 0 : void StreamingInputCallResponse::Clear() {
2416 0 : aggregated_payload_size_ = 0;
2417 0 : }
2418 :
2419 0 : bool StreamingInputCallResponse::MergePartialFromCodedStream(
2420 : ::google::protobuf::io::CodedInputStream* input) {
2421 : #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
2422 : ::google::protobuf::uint32 tag;
2423 : // @@protoc_insertion_point(parse_start:grpc.testing.StreamingInputCallResponse)
2424 : for (;;) {
2425 : ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
2426 0 : tag = p.first;
2427 0 : if (!p.second) goto handle_unusual;
2428 0 : switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2429 : // optional int32 aggregated_payload_size = 1;
2430 : case 1: {
2431 0 : if (tag == 8) {
2432 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
2433 : ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>(
2434 : input, &aggregated_payload_size_)));
2435 :
2436 : } else {
2437 0 : goto handle_unusual;
2438 : }
2439 0 : if (input->ExpectAtEnd()) goto success;
2440 0 : break;
2441 : }
2442 :
2443 : default: {
2444 : handle_unusual:
2445 0 : if (tag == 0 ||
2446 0 : ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2447 : ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2448 0 : goto success;
2449 : }
2450 0 : DO_(::google::protobuf::internal::WireFormatLite::SkipField(input, tag));
2451 0 : break;
2452 : }
2453 : }
2454 0 : }
2455 : success:
2456 : // @@protoc_insertion_point(parse_success:grpc.testing.StreamingInputCallResponse)
2457 0 : return true;
2458 : failure:
2459 : // @@protoc_insertion_point(parse_failure:grpc.testing.StreamingInputCallResponse)
2460 0 : return false;
2461 : #undef DO_
2462 : }
2463 :
2464 0 : void StreamingInputCallResponse::SerializeWithCachedSizes(
2465 : ::google::protobuf::io::CodedOutputStream* output) const {
2466 : // @@protoc_insertion_point(serialize_start:grpc.testing.StreamingInputCallResponse)
2467 : // optional int32 aggregated_payload_size = 1;
2468 0 : if (this->aggregated_payload_size() != 0) {
2469 0 : ::google::protobuf::internal::WireFormatLite::WriteInt32(1, this->aggregated_payload_size(), output);
2470 : }
2471 :
2472 : // @@protoc_insertion_point(serialize_end:grpc.testing.StreamingInputCallResponse)
2473 0 : }
2474 :
2475 0 : ::google::protobuf::uint8* StreamingInputCallResponse::SerializeWithCachedSizesToArray(
2476 : ::google::protobuf::uint8* target) const {
2477 : // @@protoc_insertion_point(serialize_to_array_start:grpc.testing.StreamingInputCallResponse)
2478 : // optional int32 aggregated_payload_size = 1;
2479 0 : if (this->aggregated_payload_size() != 0) {
2480 0 : target = ::google::protobuf::internal::WireFormatLite::WriteInt32ToArray(1, this->aggregated_payload_size(), target);
2481 : }
2482 :
2483 : // @@protoc_insertion_point(serialize_to_array_end:grpc.testing.StreamingInputCallResponse)
2484 0 : return target;
2485 : }
2486 :
2487 0 : int StreamingInputCallResponse::ByteSize() const {
2488 0 : int total_size = 0;
2489 :
2490 : // optional int32 aggregated_payload_size = 1;
2491 0 : if (this->aggregated_payload_size() != 0) {
2492 : total_size += 1 +
2493 : ::google::protobuf::internal::WireFormatLite::Int32Size(
2494 0 : this->aggregated_payload_size());
2495 : }
2496 :
2497 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2498 0 : _cached_size_ = total_size;
2499 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
2500 0 : return total_size;
2501 : }
2502 :
2503 0 : void StreamingInputCallResponse::MergeFrom(const ::google::protobuf::Message& from) {
2504 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
2505 : const StreamingInputCallResponse* source =
2506 : ::google::protobuf::internal::DynamicCastToGenerated<const StreamingInputCallResponse>(
2507 0 : &from);
2508 0 : if (source == NULL) {
2509 0 : ::google::protobuf::internal::ReflectionOps::Merge(from, this);
2510 : } else {
2511 0 : MergeFrom(*source);
2512 : }
2513 0 : }
2514 :
2515 0 : void StreamingInputCallResponse::MergeFrom(const StreamingInputCallResponse& from) {
2516 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
2517 0 : if (from.aggregated_payload_size() != 0) {
2518 0 : set_aggregated_payload_size(from.aggregated_payload_size());
2519 : }
2520 0 : }
2521 :
2522 0 : void StreamingInputCallResponse::CopyFrom(const ::google::protobuf::Message& from) {
2523 0 : if (&from == this) return;
2524 0 : Clear();
2525 0 : MergeFrom(from);
2526 : }
2527 :
2528 0 : void StreamingInputCallResponse::CopyFrom(const StreamingInputCallResponse& from) {
2529 0 : if (&from == this) return;
2530 0 : Clear();
2531 0 : MergeFrom(from);
2532 : }
2533 :
2534 0 : bool StreamingInputCallResponse::IsInitialized() const {
2535 :
2536 0 : return true;
2537 : }
2538 :
2539 0 : void StreamingInputCallResponse::Swap(StreamingInputCallResponse* other) {
2540 0 : if (other == this) return;
2541 0 : InternalSwap(other);
2542 : }
2543 0 : void StreamingInputCallResponse::InternalSwap(StreamingInputCallResponse* other) {
2544 0 : std::swap(aggregated_payload_size_, other->aggregated_payload_size_);
2545 0 : _internal_metadata_.Swap(&other->_internal_metadata_);
2546 0 : std::swap(_cached_size_, other->_cached_size_);
2547 0 : }
2548 :
2549 0 : ::google::protobuf::Metadata StreamingInputCallResponse::GetMetadata() const {
2550 0 : protobuf_AssignDescriptorsOnce();
2551 : ::google::protobuf::Metadata metadata;
2552 0 : metadata.descriptor = StreamingInputCallResponse_descriptor_;
2553 0 : metadata.reflection = StreamingInputCallResponse_reflection_;
2554 0 : return metadata;
2555 : }
2556 :
2557 : #if PROTOBUF_INLINE_NOT_IN_HEADERS
2558 : // StreamingInputCallResponse
2559 :
2560 : // optional int32 aggregated_payload_size = 1;
2561 : void StreamingInputCallResponse::clear_aggregated_payload_size() {
2562 : aggregated_payload_size_ = 0;
2563 : }
2564 : ::google::protobuf::int32 StreamingInputCallResponse::aggregated_payload_size() const {
2565 : // @@protoc_insertion_point(field_get:grpc.testing.StreamingInputCallResponse.aggregated_payload_size)
2566 : return aggregated_payload_size_;
2567 : }
2568 : void StreamingInputCallResponse::set_aggregated_payload_size(::google::protobuf::int32 value) {
2569 :
2570 : aggregated_payload_size_ = value;
2571 : // @@protoc_insertion_point(field_set:grpc.testing.StreamingInputCallResponse.aggregated_payload_size)
2572 : }
2573 :
2574 : #endif // PROTOBUF_INLINE_NOT_IN_HEADERS
2575 :
2576 : // ===================================================================
2577 :
2578 : #ifndef _MSC_VER
2579 : const int ResponseParameters::kSizeFieldNumber;
2580 : const int ResponseParameters::kIntervalUsFieldNumber;
2581 : #endif // !_MSC_VER
2582 :
2583 5 : ResponseParameters::ResponseParameters()
2584 5 : : ::google::protobuf::Message(), _internal_metadata_(NULL) {
2585 5 : SharedCtor();
2586 : // @@protoc_insertion_point(constructor:grpc.testing.ResponseParameters)
2587 5 : }
2588 :
2589 5 : void ResponseParameters::InitAsDefaultInstance() {
2590 5 : _is_default_instance_ = true;
2591 5 : }
2592 :
2593 0 : ResponseParameters::ResponseParameters(const ResponseParameters& from)
2594 : : ::google::protobuf::Message(),
2595 0 : _internal_metadata_(NULL) {
2596 0 : SharedCtor();
2597 0 : MergeFrom(from);
2598 : // @@protoc_insertion_point(copy_constructor:grpc.testing.ResponseParameters)
2599 0 : }
2600 :
2601 5 : void ResponseParameters::SharedCtor() {
2602 5 : _is_default_instance_ = false;
2603 5 : _cached_size_ = 0;
2604 5 : size_ = 0;
2605 5 : interval_us_ = 0;
2606 5 : }
2607 :
2608 0 : ResponseParameters::~ResponseParameters() {
2609 : // @@protoc_insertion_point(destructor:grpc.testing.ResponseParameters)
2610 0 : SharedDtor();
2611 0 : }
2612 :
2613 0 : void ResponseParameters::SharedDtor() {
2614 0 : if (this != default_instance_) {
2615 : }
2616 0 : }
2617 :
2618 0 : void ResponseParameters::SetCachedSize(int size) const {
2619 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2620 0 : _cached_size_ = size;
2621 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
2622 0 : }
2623 0 : const ::google::protobuf::Descriptor* ResponseParameters::descriptor() {
2624 0 : protobuf_AssignDescriptorsOnce();
2625 0 : return ResponseParameters_descriptor_;
2626 : }
2627 :
2628 0 : const ResponseParameters& ResponseParameters::default_instance() {
2629 0 : if (default_instance_ == NULL) protobuf_AddDesc_test_2fproto_2fmessages_2eproto();
2630 0 : return *default_instance_;
2631 : }
2632 :
2633 : ResponseParameters* ResponseParameters::default_instance_ = NULL;
2634 :
2635 0 : ResponseParameters* ResponseParameters::New(::google::protobuf::Arena* arena) const {
2636 0 : ResponseParameters* n = new ResponseParameters;
2637 0 : if (arena != NULL) {
2638 0 : arena->Own(n);
2639 : }
2640 0 : return n;
2641 : }
2642 :
2643 0 : void ResponseParameters::Clear() {
2644 : #define ZR_HELPER_(f) reinterpret_cast<char*>(\
2645 : &reinterpret_cast<ResponseParameters*>(16)->f)
2646 :
2647 : #define ZR_(first, last) do {\
2648 : ::memset(&first, 0,\
2649 : ZR_HELPER_(last) - ZR_HELPER_(first) + sizeof(last));\
2650 : } while (0)
2651 :
2652 0 : ZR_(size_, interval_us_);
2653 :
2654 : #undef ZR_HELPER_
2655 : #undef ZR_
2656 :
2657 0 : }
2658 :
2659 0 : bool ResponseParameters::MergePartialFromCodedStream(
2660 : ::google::protobuf::io::CodedInputStream* input) {
2661 : #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
2662 : ::google::protobuf::uint32 tag;
2663 : // @@protoc_insertion_point(parse_start:grpc.testing.ResponseParameters)
2664 : for (;;) {
2665 : ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
2666 0 : tag = p.first;
2667 0 : if (!p.second) goto handle_unusual;
2668 0 : switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2669 : // optional int32 size = 1;
2670 : case 1: {
2671 0 : if (tag == 8) {
2672 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
2673 : ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>(
2674 : input, &size_)));
2675 :
2676 : } else {
2677 0 : goto handle_unusual;
2678 : }
2679 0 : if (input->ExpectTag(16)) goto parse_interval_us;
2680 0 : break;
2681 : }
2682 :
2683 : // optional int32 interval_us = 2;
2684 : case 2: {
2685 0 : if (tag == 16) {
2686 : parse_interval_us:
2687 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
2688 : ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>(
2689 : input, &interval_us_)));
2690 :
2691 : } else {
2692 0 : goto handle_unusual;
2693 : }
2694 0 : if (input->ExpectAtEnd()) goto success;
2695 0 : break;
2696 : }
2697 :
2698 : default: {
2699 : handle_unusual:
2700 0 : if (tag == 0 ||
2701 0 : ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
2702 : ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
2703 0 : goto success;
2704 : }
2705 0 : DO_(::google::protobuf::internal::WireFormatLite::SkipField(input, tag));
2706 0 : break;
2707 : }
2708 : }
2709 0 : }
2710 : success:
2711 : // @@protoc_insertion_point(parse_success:grpc.testing.ResponseParameters)
2712 0 : return true;
2713 : failure:
2714 : // @@protoc_insertion_point(parse_failure:grpc.testing.ResponseParameters)
2715 0 : return false;
2716 : #undef DO_
2717 : }
2718 :
2719 0 : void ResponseParameters::SerializeWithCachedSizes(
2720 : ::google::protobuf::io::CodedOutputStream* output) const {
2721 : // @@protoc_insertion_point(serialize_start:grpc.testing.ResponseParameters)
2722 : // optional int32 size = 1;
2723 0 : if (this->size() != 0) {
2724 0 : ::google::protobuf::internal::WireFormatLite::WriteInt32(1, this->size(), output);
2725 : }
2726 :
2727 : // optional int32 interval_us = 2;
2728 0 : if (this->interval_us() != 0) {
2729 0 : ::google::protobuf::internal::WireFormatLite::WriteInt32(2, this->interval_us(), output);
2730 : }
2731 :
2732 : // @@protoc_insertion_point(serialize_end:grpc.testing.ResponseParameters)
2733 0 : }
2734 :
2735 0 : ::google::protobuf::uint8* ResponseParameters::SerializeWithCachedSizesToArray(
2736 : ::google::protobuf::uint8* target) const {
2737 : // @@protoc_insertion_point(serialize_to_array_start:grpc.testing.ResponseParameters)
2738 : // optional int32 size = 1;
2739 0 : if (this->size() != 0) {
2740 0 : target = ::google::protobuf::internal::WireFormatLite::WriteInt32ToArray(1, this->size(), target);
2741 : }
2742 :
2743 : // optional int32 interval_us = 2;
2744 0 : if (this->interval_us() != 0) {
2745 0 : target = ::google::protobuf::internal::WireFormatLite::WriteInt32ToArray(2, this->interval_us(), target);
2746 : }
2747 :
2748 : // @@protoc_insertion_point(serialize_to_array_end:grpc.testing.ResponseParameters)
2749 0 : return target;
2750 : }
2751 :
2752 0 : int ResponseParameters::ByteSize() const {
2753 0 : int total_size = 0;
2754 :
2755 : // optional int32 size = 1;
2756 0 : if (this->size() != 0) {
2757 : total_size += 1 +
2758 : ::google::protobuf::internal::WireFormatLite::Int32Size(
2759 0 : this->size());
2760 : }
2761 :
2762 : // optional int32 interval_us = 2;
2763 0 : if (this->interval_us() != 0) {
2764 : total_size += 1 +
2765 : ::google::protobuf::internal::WireFormatLite::Int32Size(
2766 0 : this->interval_us());
2767 : }
2768 :
2769 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2770 0 : _cached_size_ = total_size;
2771 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
2772 0 : return total_size;
2773 : }
2774 :
2775 0 : void ResponseParameters::MergeFrom(const ::google::protobuf::Message& from) {
2776 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
2777 : const ResponseParameters* source =
2778 : ::google::protobuf::internal::DynamicCastToGenerated<const ResponseParameters>(
2779 0 : &from);
2780 0 : if (source == NULL) {
2781 0 : ::google::protobuf::internal::ReflectionOps::Merge(from, this);
2782 : } else {
2783 0 : MergeFrom(*source);
2784 : }
2785 0 : }
2786 :
2787 0 : void ResponseParameters::MergeFrom(const ResponseParameters& from) {
2788 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
2789 0 : if (from.size() != 0) {
2790 0 : set_size(from.size());
2791 : }
2792 0 : if (from.interval_us() != 0) {
2793 0 : set_interval_us(from.interval_us());
2794 : }
2795 0 : }
2796 :
2797 0 : void ResponseParameters::CopyFrom(const ::google::protobuf::Message& from) {
2798 0 : if (&from == this) return;
2799 0 : Clear();
2800 0 : MergeFrom(from);
2801 : }
2802 :
2803 0 : void ResponseParameters::CopyFrom(const ResponseParameters& from) {
2804 0 : if (&from == this) return;
2805 0 : Clear();
2806 0 : MergeFrom(from);
2807 : }
2808 :
2809 0 : bool ResponseParameters::IsInitialized() const {
2810 :
2811 0 : return true;
2812 : }
2813 :
2814 0 : void ResponseParameters::Swap(ResponseParameters* other) {
2815 0 : if (other == this) return;
2816 0 : InternalSwap(other);
2817 : }
2818 0 : void ResponseParameters::InternalSwap(ResponseParameters* other) {
2819 0 : std::swap(size_, other->size_);
2820 0 : std::swap(interval_us_, other->interval_us_);
2821 0 : _internal_metadata_.Swap(&other->_internal_metadata_);
2822 0 : std::swap(_cached_size_, other->_cached_size_);
2823 0 : }
2824 :
2825 0 : ::google::protobuf::Metadata ResponseParameters::GetMetadata() const {
2826 0 : protobuf_AssignDescriptorsOnce();
2827 : ::google::protobuf::Metadata metadata;
2828 0 : metadata.descriptor = ResponseParameters_descriptor_;
2829 0 : metadata.reflection = ResponseParameters_reflection_;
2830 0 : return metadata;
2831 : }
2832 :
2833 : #if PROTOBUF_INLINE_NOT_IN_HEADERS
2834 : // ResponseParameters
2835 :
2836 : // optional int32 size = 1;
2837 : void ResponseParameters::clear_size() {
2838 : size_ = 0;
2839 : }
2840 : ::google::protobuf::int32 ResponseParameters::size() const {
2841 : // @@protoc_insertion_point(field_get:grpc.testing.ResponseParameters.size)
2842 : return size_;
2843 : }
2844 : void ResponseParameters::set_size(::google::protobuf::int32 value) {
2845 :
2846 : size_ = value;
2847 : // @@protoc_insertion_point(field_set:grpc.testing.ResponseParameters.size)
2848 : }
2849 :
2850 : // optional int32 interval_us = 2;
2851 : void ResponseParameters::clear_interval_us() {
2852 : interval_us_ = 0;
2853 : }
2854 : ::google::protobuf::int32 ResponseParameters::interval_us() const {
2855 : // @@protoc_insertion_point(field_get:grpc.testing.ResponseParameters.interval_us)
2856 : return interval_us_;
2857 : }
2858 : void ResponseParameters::set_interval_us(::google::protobuf::int32 value) {
2859 :
2860 : interval_us_ = value;
2861 : // @@protoc_insertion_point(field_set:grpc.testing.ResponseParameters.interval_us)
2862 : }
2863 :
2864 : #endif // PROTOBUF_INLINE_NOT_IN_HEADERS
2865 :
2866 : // ===================================================================
2867 :
2868 : #ifndef _MSC_VER
2869 : const int StreamingOutputCallRequest::kResponseTypeFieldNumber;
2870 : const int StreamingOutputCallRequest::kResponseParametersFieldNumber;
2871 : const int StreamingOutputCallRequest::kPayloadFieldNumber;
2872 : const int StreamingOutputCallRequest::kResponseCompressionFieldNumber;
2873 : const int StreamingOutputCallRequest::kResponseStatusFieldNumber;
2874 : #endif // !_MSC_VER
2875 :
2876 5 : StreamingOutputCallRequest::StreamingOutputCallRequest()
2877 5 : : ::google::protobuf::Message(), _internal_metadata_(NULL) {
2878 5 : SharedCtor();
2879 : // @@protoc_insertion_point(constructor:grpc.testing.StreamingOutputCallRequest)
2880 5 : }
2881 :
2882 5 : void StreamingOutputCallRequest::InitAsDefaultInstance() {
2883 5 : _is_default_instance_ = true;
2884 5 : payload_ = const_cast< ::grpc::testing::Payload*>(&::grpc::testing::Payload::default_instance());
2885 5 : response_status_ = const_cast< ::grpc::testing::EchoStatus*>(&::grpc::testing::EchoStatus::default_instance());
2886 5 : }
2887 :
2888 0 : StreamingOutputCallRequest::StreamingOutputCallRequest(const StreamingOutputCallRequest& from)
2889 : : ::google::protobuf::Message(),
2890 0 : _internal_metadata_(NULL) {
2891 0 : SharedCtor();
2892 0 : MergeFrom(from);
2893 : // @@protoc_insertion_point(copy_constructor:grpc.testing.StreamingOutputCallRequest)
2894 0 : }
2895 :
2896 5 : void StreamingOutputCallRequest::SharedCtor() {
2897 5 : _is_default_instance_ = false;
2898 5 : _cached_size_ = 0;
2899 5 : response_type_ = 0;
2900 5 : payload_ = NULL;
2901 5 : response_compression_ = 0;
2902 5 : response_status_ = NULL;
2903 5 : }
2904 :
2905 0 : StreamingOutputCallRequest::~StreamingOutputCallRequest() {
2906 : // @@protoc_insertion_point(destructor:grpc.testing.StreamingOutputCallRequest)
2907 0 : SharedDtor();
2908 0 : }
2909 :
2910 0 : void StreamingOutputCallRequest::SharedDtor() {
2911 0 : if (this != default_instance_) {
2912 0 : delete payload_;
2913 0 : delete response_status_;
2914 : }
2915 0 : }
2916 :
2917 0 : void StreamingOutputCallRequest::SetCachedSize(int size) const {
2918 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2919 0 : _cached_size_ = size;
2920 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
2921 0 : }
2922 0 : const ::google::protobuf::Descriptor* StreamingOutputCallRequest::descriptor() {
2923 0 : protobuf_AssignDescriptorsOnce();
2924 0 : return StreamingOutputCallRequest_descriptor_;
2925 : }
2926 :
2927 0 : const StreamingOutputCallRequest& StreamingOutputCallRequest::default_instance() {
2928 0 : if (default_instance_ == NULL) protobuf_AddDesc_test_2fproto_2fmessages_2eproto();
2929 0 : return *default_instance_;
2930 : }
2931 :
2932 : StreamingOutputCallRequest* StreamingOutputCallRequest::default_instance_ = NULL;
2933 :
2934 0 : StreamingOutputCallRequest* StreamingOutputCallRequest::New(::google::protobuf::Arena* arena) const {
2935 0 : StreamingOutputCallRequest* n = new StreamingOutputCallRequest;
2936 0 : if (arena != NULL) {
2937 0 : arena->Own(n);
2938 : }
2939 0 : return n;
2940 : }
2941 :
2942 0 : void StreamingOutputCallRequest::Clear() {
2943 : #define ZR_HELPER_(f) reinterpret_cast<char*>(\
2944 : &reinterpret_cast<StreamingOutputCallRequest*>(16)->f)
2945 :
2946 : #define ZR_(first, last) do {\
2947 : ::memset(&first, 0,\
2948 : ZR_HELPER_(last) - ZR_HELPER_(first) + sizeof(last));\
2949 : } while (0)
2950 :
2951 0 : ZR_(response_type_, response_compression_);
2952 0 : if (GetArenaNoVirtual() == NULL && payload_ != NULL) delete payload_;
2953 0 : payload_ = NULL;
2954 0 : if (GetArenaNoVirtual() == NULL && response_status_ != NULL) delete response_status_;
2955 0 : response_status_ = NULL;
2956 :
2957 : #undef ZR_HELPER_
2958 : #undef ZR_
2959 :
2960 0 : response_parameters_.Clear();
2961 0 : }
2962 :
2963 0 : bool StreamingOutputCallRequest::MergePartialFromCodedStream(
2964 : ::google::protobuf::io::CodedInputStream* input) {
2965 : #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
2966 : ::google::protobuf::uint32 tag;
2967 : // @@protoc_insertion_point(parse_start:grpc.testing.StreamingOutputCallRequest)
2968 : for (;;) {
2969 : ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
2970 0 : tag = p.first;
2971 0 : if (!p.second) goto handle_unusual;
2972 0 : switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2973 : // optional .grpc.testing.PayloadType response_type = 1;
2974 : case 1: {
2975 0 : if (tag == 8) {
2976 : int value;
2977 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
2978 : int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
2979 : input, &value)));
2980 0 : set_response_type(static_cast< ::grpc::testing::PayloadType >(value));
2981 : } else {
2982 0 : goto handle_unusual;
2983 : }
2984 0 : if (input->ExpectTag(18)) goto parse_response_parameters;
2985 0 : break;
2986 : }
2987 :
2988 : // repeated .grpc.testing.ResponseParameters response_parameters = 2;
2989 : case 2: {
2990 0 : if (tag == 18) {
2991 : parse_response_parameters:
2992 0 : DO_(input->IncrementRecursionDepth());
2993 : parse_loop_response_parameters:
2994 0 : DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtualNoRecursionDepth(
2995 : input, add_response_parameters()));
2996 : } else {
2997 0 : goto handle_unusual;
2998 : }
2999 0 : if (input->ExpectTag(18)) goto parse_loop_response_parameters;
3000 0 : input->UnsafeDecrementRecursionDepth();
3001 0 : if (input->ExpectTag(26)) goto parse_payload;
3002 0 : break;
3003 : }
3004 :
3005 : // optional .grpc.testing.Payload payload = 3;
3006 : case 3: {
3007 0 : if (tag == 26) {
3008 : parse_payload:
3009 0 : DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3010 : input, mutable_payload()));
3011 : } else {
3012 0 : goto handle_unusual;
3013 : }
3014 0 : if (input->ExpectTag(48)) goto parse_response_compression;
3015 0 : break;
3016 : }
3017 :
3018 : // optional .grpc.testing.CompressionType response_compression = 6;
3019 : case 6: {
3020 0 : if (tag == 48) {
3021 : parse_response_compression:
3022 : int value;
3023 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
3024 : int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
3025 : input, &value)));
3026 0 : set_response_compression(static_cast< ::grpc::testing::CompressionType >(value));
3027 : } else {
3028 0 : goto handle_unusual;
3029 : }
3030 0 : if (input->ExpectTag(58)) goto parse_response_status;
3031 0 : break;
3032 : }
3033 :
3034 : // optional .grpc.testing.EchoStatus response_status = 7;
3035 : case 7: {
3036 0 : if (tag == 58) {
3037 : parse_response_status:
3038 0 : DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3039 : input, mutable_response_status()));
3040 : } else {
3041 0 : goto handle_unusual;
3042 : }
3043 0 : if (input->ExpectAtEnd()) goto success;
3044 0 : break;
3045 : }
3046 :
3047 : default: {
3048 : handle_unusual:
3049 0 : if (tag == 0 ||
3050 0 : ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3051 : ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3052 0 : goto success;
3053 : }
3054 0 : DO_(::google::protobuf::internal::WireFormatLite::SkipField(input, tag));
3055 0 : break;
3056 : }
3057 : }
3058 0 : }
3059 : success:
3060 : // @@protoc_insertion_point(parse_success:grpc.testing.StreamingOutputCallRequest)
3061 0 : return true;
3062 : failure:
3063 : // @@protoc_insertion_point(parse_failure:grpc.testing.StreamingOutputCallRequest)
3064 0 : return false;
3065 : #undef DO_
3066 : }
3067 :
3068 0 : void StreamingOutputCallRequest::SerializeWithCachedSizes(
3069 : ::google::protobuf::io::CodedOutputStream* output) const {
3070 : // @@protoc_insertion_point(serialize_start:grpc.testing.StreamingOutputCallRequest)
3071 : // optional .grpc.testing.PayloadType response_type = 1;
3072 0 : if (this->response_type() != 0) {
3073 : ::google::protobuf::internal::WireFormatLite::WriteEnum(
3074 0 : 1, this->response_type(), output);
3075 : }
3076 :
3077 : // repeated .grpc.testing.ResponseParameters response_parameters = 2;
3078 0 : for (unsigned int i = 0, n = this->response_parameters_size(); i < n; i++) {
3079 : ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3080 0 : 2, this->response_parameters(i), output);
3081 : }
3082 :
3083 : // optional .grpc.testing.Payload payload = 3;
3084 0 : if (this->has_payload()) {
3085 : ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3086 0 : 3, *this->payload_, output);
3087 : }
3088 :
3089 : // optional .grpc.testing.CompressionType response_compression = 6;
3090 0 : if (this->response_compression() != 0) {
3091 : ::google::protobuf::internal::WireFormatLite::WriteEnum(
3092 0 : 6, this->response_compression(), output);
3093 : }
3094 :
3095 : // optional .grpc.testing.EchoStatus response_status = 7;
3096 0 : if (this->has_response_status()) {
3097 : ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3098 0 : 7, *this->response_status_, output);
3099 : }
3100 :
3101 : // @@protoc_insertion_point(serialize_end:grpc.testing.StreamingOutputCallRequest)
3102 0 : }
3103 :
3104 0 : ::google::protobuf::uint8* StreamingOutputCallRequest::SerializeWithCachedSizesToArray(
3105 : ::google::protobuf::uint8* target) const {
3106 : // @@protoc_insertion_point(serialize_to_array_start:grpc.testing.StreamingOutputCallRequest)
3107 : // optional .grpc.testing.PayloadType response_type = 1;
3108 0 : if (this->response_type() != 0) {
3109 : target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
3110 0 : 1, this->response_type(), target);
3111 : }
3112 :
3113 : // repeated .grpc.testing.ResponseParameters response_parameters = 2;
3114 0 : for (unsigned int i = 0, n = this->response_parameters_size(); i < n; i++) {
3115 : target = ::google::protobuf::internal::WireFormatLite::
3116 : WriteMessageNoVirtualToArray(
3117 0 : 2, this->response_parameters(i), target);
3118 : }
3119 :
3120 : // optional .grpc.testing.Payload payload = 3;
3121 0 : if (this->has_payload()) {
3122 : target = ::google::protobuf::internal::WireFormatLite::
3123 : WriteMessageNoVirtualToArray(
3124 0 : 3, *this->payload_, target);
3125 : }
3126 :
3127 : // optional .grpc.testing.CompressionType response_compression = 6;
3128 0 : if (this->response_compression() != 0) {
3129 : target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
3130 0 : 6, this->response_compression(), target);
3131 : }
3132 :
3133 : // optional .grpc.testing.EchoStatus response_status = 7;
3134 0 : if (this->has_response_status()) {
3135 : target = ::google::protobuf::internal::WireFormatLite::
3136 : WriteMessageNoVirtualToArray(
3137 0 : 7, *this->response_status_, target);
3138 : }
3139 :
3140 : // @@protoc_insertion_point(serialize_to_array_end:grpc.testing.StreamingOutputCallRequest)
3141 0 : return target;
3142 : }
3143 :
3144 0 : int StreamingOutputCallRequest::ByteSize() const {
3145 0 : int total_size = 0;
3146 :
3147 : // optional .grpc.testing.PayloadType response_type = 1;
3148 0 : if (this->response_type() != 0) {
3149 : total_size += 1 +
3150 0 : ::google::protobuf::internal::WireFormatLite::EnumSize(this->response_type());
3151 : }
3152 :
3153 : // optional .grpc.testing.Payload payload = 3;
3154 0 : if (this->has_payload()) {
3155 : total_size += 1 +
3156 : ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3157 0 : *this->payload_);
3158 : }
3159 :
3160 : // optional .grpc.testing.CompressionType response_compression = 6;
3161 0 : if (this->response_compression() != 0) {
3162 : total_size += 1 +
3163 0 : ::google::protobuf::internal::WireFormatLite::EnumSize(this->response_compression());
3164 : }
3165 :
3166 : // optional .grpc.testing.EchoStatus response_status = 7;
3167 0 : if (this->has_response_status()) {
3168 : total_size += 1 +
3169 : ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3170 0 : *this->response_status_);
3171 : }
3172 :
3173 : // repeated .grpc.testing.ResponseParameters response_parameters = 2;
3174 0 : total_size += 1 * this->response_parameters_size();
3175 0 : for (int i = 0; i < this->response_parameters_size(); i++) {
3176 : total_size +=
3177 : ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3178 0 : this->response_parameters(i));
3179 : }
3180 :
3181 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3182 0 : _cached_size_ = total_size;
3183 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
3184 0 : return total_size;
3185 : }
3186 :
3187 0 : void StreamingOutputCallRequest::MergeFrom(const ::google::protobuf::Message& from) {
3188 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
3189 : const StreamingOutputCallRequest* source =
3190 : ::google::protobuf::internal::DynamicCastToGenerated<const StreamingOutputCallRequest>(
3191 0 : &from);
3192 0 : if (source == NULL) {
3193 0 : ::google::protobuf::internal::ReflectionOps::Merge(from, this);
3194 : } else {
3195 0 : MergeFrom(*source);
3196 : }
3197 0 : }
3198 :
3199 0 : void StreamingOutputCallRequest::MergeFrom(const StreamingOutputCallRequest& from) {
3200 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
3201 0 : response_parameters_.MergeFrom(from.response_parameters_);
3202 0 : if (from.response_type() != 0) {
3203 0 : set_response_type(from.response_type());
3204 : }
3205 0 : if (from.has_payload()) {
3206 0 : mutable_payload()->::grpc::testing::Payload::MergeFrom(from.payload());
3207 : }
3208 0 : if (from.response_compression() != 0) {
3209 0 : set_response_compression(from.response_compression());
3210 : }
3211 0 : if (from.has_response_status()) {
3212 0 : mutable_response_status()->::grpc::testing::EchoStatus::MergeFrom(from.response_status());
3213 : }
3214 0 : }
3215 :
3216 0 : void StreamingOutputCallRequest::CopyFrom(const ::google::protobuf::Message& from) {
3217 0 : if (&from == this) return;
3218 0 : Clear();
3219 0 : MergeFrom(from);
3220 : }
3221 :
3222 0 : void StreamingOutputCallRequest::CopyFrom(const StreamingOutputCallRequest& from) {
3223 0 : if (&from == this) return;
3224 0 : Clear();
3225 0 : MergeFrom(from);
3226 : }
3227 :
3228 0 : bool StreamingOutputCallRequest::IsInitialized() const {
3229 :
3230 0 : return true;
3231 : }
3232 :
3233 0 : void StreamingOutputCallRequest::Swap(StreamingOutputCallRequest* other) {
3234 0 : if (other == this) return;
3235 0 : InternalSwap(other);
3236 : }
3237 0 : void StreamingOutputCallRequest::InternalSwap(StreamingOutputCallRequest* other) {
3238 0 : std::swap(response_type_, other->response_type_);
3239 0 : response_parameters_.UnsafeArenaSwap(&other->response_parameters_);
3240 0 : std::swap(payload_, other->payload_);
3241 0 : std::swap(response_compression_, other->response_compression_);
3242 0 : std::swap(response_status_, other->response_status_);
3243 0 : _internal_metadata_.Swap(&other->_internal_metadata_);
3244 0 : std::swap(_cached_size_, other->_cached_size_);
3245 0 : }
3246 :
3247 0 : ::google::protobuf::Metadata StreamingOutputCallRequest::GetMetadata() const {
3248 0 : protobuf_AssignDescriptorsOnce();
3249 : ::google::protobuf::Metadata metadata;
3250 0 : metadata.descriptor = StreamingOutputCallRequest_descriptor_;
3251 0 : metadata.reflection = StreamingOutputCallRequest_reflection_;
3252 0 : return metadata;
3253 : }
3254 :
3255 : #if PROTOBUF_INLINE_NOT_IN_HEADERS
3256 : // StreamingOutputCallRequest
3257 :
3258 : // optional .grpc.testing.PayloadType response_type = 1;
3259 : void StreamingOutputCallRequest::clear_response_type() {
3260 : response_type_ = 0;
3261 : }
3262 : ::grpc::testing::PayloadType StreamingOutputCallRequest::response_type() const {
3263 : // @@protoc_insertion_point(field_get:grpc.testing.StreamingOutputCallRequest.response_type)
3264 : return static_cast< ::grpc::testing::PayloadType >(response_type_);
3265 : }
3266 : void StreamingOutputCallRequest::set_response_type(::grpc::testing::PayloadType value) {
3267 :
3268 : response_type_ = value;
3269 : // @@protoc_insertion_point(field_set:grpc.testing.StreamingOutputCallRequest.response_type)
3270 : }
3271 :
3272 : // repeated .grpc.testing.ResponseParameters response_parameters = 2;
3273 : int StreamingOutputCallRequest::response_parameters_size() const {
3274 : return response_parameters_.size();
3275 : }
3276 : void StreamingOutputCallRequest::clear_response_parameters() {
3277 : response_parameters_.Clear();
3278 : }
3279 : const ::grpc::testing::ResponseParameters& StreamingOutputCallRequest::response_parameters(int index) const {
3280 : // @@protoc_insertion_point(field_get:grpc.testing.StreamingOutputCallRequest.response_parameters)
3281 : return response_parameters_.Get(index);
3282 : }
3283 : ::grpc::testing::ResponseParameters* StreamingOutputCallRequest::mutable_response_parameters(int index) {
3284 : // @@protoc_insertion_point(field_mutable:grpc.testing.StreamingOutputCallRequest.response_parameters)
3285 : return response_parameters_.Mutable(index);
3286 : }
3287 : ::grpc::testing::ResponseParameters* StreamingOutputCallRequest::add_response_parameters() {
3288 : // @@protoc_insertion_point(field_add:grpc.testing.StreamingOutputCallRequest.response_parameters)
3289 : return response_parameters_.Add();
3290 : }
3291 : ::google::protobuf::RepeatedPtrField< ::grpc::testing::ResponseParameters >*
3292 : StreamingOutputCallRequest::mutable_response_parameters() {
3293 : // @@protoc_insertion_point(field_mutable_list:grpc.testing.StreamingOutputCallRequest.response_parameters)
3294 : return &response_parameters_;
3295 : }
3296 : const ::google::protobuf::RepeatedPtrField< ::grpc::testing::ResponseParameters >&
3297 : StreamingOutputCallRequest::response_parameters() const {
3298 : // @@protoc_insertion_point(field_list:grpc.testing.StreamingOutputCallRequest.response_parameters)
3299 : return response_parameters_;
3300 : }
3301 :
3302 : // optional .grpc.testing.Payload payload = 3;
3303 : bool StreamingOutputCallRequest::has_payload() const {
3304 : return !_is_default_instance_ && payload_ != NULL;
3305 : }
3306 : void StreamingOutputCallRequest::clear_payload() {
3307 : if (GetArenaNoVirtual() == NULL && payload_ != NULL) delete payload_;
3308 : payload_ = NULL;
3309 : }
3310 : const ::grpc::testing::Payload& StreamingOutputCallRequest::payload() const {
3311 : // @@protoc_insertion_point(field_get:grpc.testing.StreamingOutputCallRequest.payload)
3312 : return payload_ != NULL ? *payload_ : *default_instance_->payload_;
3313 : }
3314 : ::grpc::testing::Payload* StreamingOutputCallRequest::mutable_payload() {
3315 :
3316 : if (payload_ == NULL) {
3317 : payload_ = new ::grpc::testing::Payload;
3318 : }
3319 : // @@protoc_insertion_point(field_mutable:grpc.testing.StreamingOutputCallRequest.payload)
3320 : return payload_;
3321 : }
3322 : ::grpc::testing::Payload* StreamingOutputCallRequest::release_payload() {
3323 :
3324 : ::grpc::testing::Payload* temp = payload_;
3325 : payload_ = NULL;
3326 : return temp;
3327 : }
3328 : void StreamingOutputCallRequest::set_allocated_payload(::grpc::testing::Payload* payload) {
3329 : delete payload_;
3330 : payload_ = payload;
3331 : if (payload) {
3332 :
3333 : } else {
3334 :
3335 : }
3336 : // @@protoc_insertion_point(field_set_allocated:grpc.testing.StreamingOutputCallRequest.payload)
3337 : }
3338 :
3339 : // optional .grpc.testing.CompressionType response_compression = 6;
3340 : void StreamingOutputCallRequest::clear_response_compression() {
3341 : response_compression_ = 0;
3342 : }
3343 : ::grpc::testing::CompressionType StreamingOutputCallRequest::response_compression() const {
3344 : // @@protoc_insertion_point(field_get:grpc.testing.StreamingOutputCallRequest.response_compression)
3345 : return static_cast< ::grpc::testing::CompressionType >(response_compression_);
3346 : }
3347 : void StreamingOutputCallRequest::set_response_compression(::grpc::testing::CompressionType value) {
3348 :
3349 : response_compression_ = value;
3350 : // @@protoc_insertion_point(field_set:grpc.testing.StreamingOutputCallRequest.response_compression)
3351 : }
3352 :
3353 : // optional .grpc.testing.EchoStatus response_status = 7;
3354 : bool StreamingOutputCallRequest::has_response_status() const {
3355 : return !_is_default_instance_ && response_status_ != NULL;
3356 : }
3357 : void StreamingOutputCallRequest::clear_response_status() {
3358 : if (GetArenaNoVirtual() == NULL && response_status_ != NULL) delete response_status_;
3359 : response_status_ = NULL;
3360 : }
3361 : const ::grpc::testing::EchoStatus& StreamingOutputCallRequest::response_status() const {
3362 : // @@protoc_insertion_point(field_get:grpc.testing.StreamingOutputCallRequest.response_status)
3363 : return response_status_ != NULL ? *response_status_ : *default_instance_->response_status_;
3364 : }
3365 : ::grpc::testing::EchoStatus* StreamingOutputCallRequest::mutable_response_status() {
3366 :
3367 : if (response_status_ == NULL) {
3368 : response_status_ = new ::grpc::testing::EchoStatus;
3369 : }
3370 : // @@protoc_insertion_point(field_mutable:grpc.testing.StreamingOutputCallRequest.response_status)
3371 : return response_status_;
3372 : }
3373 : ::grpc::testing::EchoStatus* StreamingOutputCallRequest::release_response_status() {
3374 :
3375 : ::grpc::testing::EchoStatus* temp = response_status_;
3376 : response_status_ = NULL;
3377 : return temp;
3378 : }
3379 : void StreamingOutputCallRequest::set_allocated_response_status(::grpc::testing::EchoStatus* response_status) {
3380 : delete response_status_;
3381 : response_status_ = response_status;
3382 : if (response_status) {
3383 :
3384 : } else {
3385 :
3386 : }
3387 : // @@protoc_insertion_point(field_set_allocated:grpc.testing.StreamingOutputCallRequest.response_status)
3388 : }
3389 :
3390 : #endif // PROTOBUF_INLINE_NOT_IN_HEADERS
3391 :
3392 : // ===================================================================
3393 :
3394 : #ifndef _MSC_VER
3395 : const int StreamingOutputCallResponse::kPayloadFieldNumber;
3396 : #endif // !_MSC_VER
3397 :
3398 5 : StreamingOutputCallResponse::StreamingOutputCallResponse()
3399 5 : : ::google::protobuf::Message(), _internal_metadata_(NULL) {
3400 5 : SharedCtor();
3401 : // @@protoc_insertion_point(constructor:grpc.testing.StreamingOutputCallResponse)
3402 5 : }
3403 :
3404 5 : void StreamingOutputCallResponse::InitAsDefaultInstance() {
3405 5 : _is_default_instance_ = true;
3406 5 : payload_ = const_cast< ::grpc::testing::Payload*>(&::grpc::testing::Payload::default_instance());
3407 5 : }
3408 :
3409 0 : StreamingOutputCallResponse::StreamingOutputCallResponse(const StreamingOutputCallResponse& from)
3410 : : ::google::protobuf::Message(),
3411 0 : _internal_metadata_(NULL) {
3412 0 : SharedCtor();
3413 0 : MergeFrom(from);
3414 : // @@protoc_insertion_point(copy_constructor:grpc.testing.StreamingOutputCallResponse)
3415 0 : }
3416 :
3417 5 : void StreamingOutputCallResponse::SharedCtor() {
3418 5 : _is_default_instance_ = false;
3419 5 : _cached_size_ = 0;
3420 5 : payload_ = NULL;
3421 5 : }
3422 :
3423 0 : StreamingOutputCallResponse::~StreamingOutputCallResponse() {
3424 : // @@protoc_insertion_point(destructor:grpc.testing.StreamingOutputCallResponse)
3425 0 : SharedDtor();
3426 0 : }
3427 :
3428 0 : void StreamingOutputCallResponse::SharedDtor() {
3429 0 : if (this != default_instance_) {
3430 0 : delete payload_;
3431 : }
3432 0 : }
3433 :
3434 0 : void StreamingOutputCallResponse::SetCachedSize(int size) const {
3435 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3436 0 : _cached_size_ = size;
3437 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
3438 0 : }
3439 0 : const ::google::protobuf::Descriptor* StreamingOutputCallResponse::descriptor() {
3440 0 : protobuf_AssignDescriptorsOnce();
3441 0 : return StreamingOutputCallResponse_descriptor_;
3442 : }
3443 :
3444 0 : const StreamingOutputCallResponse& StreamingOutputCallResponse::default_instance() {
3445 0 : if (default_instance_ == NULL) protobuf_AddDesc_test_2fproto_2fmessages_2eproto();
3446 0 : return *default_instance_;
3447 : }
3448 :
3449 : StreamingOutputCallResponse* StreamingOutputCallResponse::default_instance_ = NULL;
3450 :
3451 0 : StreamingOutputCallResponse* StreamingOutputCallResponse::New(::google::protobuf::Arena* arena) const {
3452 0 : StreamingOutputCallResponse* n = new StreamingOutputCallResponse;
3453 0 : if (arena != NULL) {
3454 0 : arena->Own(n);
3455 : }
3456 0 : return n;
3457 : }
3458 :
3459 0 : void StreamingOutputCallResponse::Clear() {
3460 0 : if (GetArenaNoVirtual() == NULL && payload_ != NULL) delete payload_;
3461 0 : payload_ = NULL;
3462 0 : }
3463 :
3464 0 : bool StreamingOutputCallResponse::MergePartialFromCodedStream(
3465 : ::google::protobuf::io::CodedInputStream* input) {
3466 : #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
3467 : ::google::protobuf::uint32 tag;
3468 : // @@protoc_insertion_point(parse_start:grpc.testing.StreamingOutputCallResponse)
3469 : for (;;) {
3470 : ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
3471 0 : tag = p.first;
3472 0 : if (!p.second) goto handle_unusual;
3473 0 : switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3474 : // optional .grpc.testing.Payload payload = 1;
3475 : case 1: {
3476 0 : if (tag == 10) {
3477 0 : DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(
3478 : input, mutable_payload()));
3479 : } else {
3480 0 : goto handle_unusual;
3481 : }
3482 0 : if (input->ExpectAtEnd()) goto success;
3483 0 : break;
3484 : }
3485 :
3486 : default: {
3487 : handle_unusual:
3488 0 : if (tag == 0 ||
3489 0 : ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3490 : ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3491 0 : goto success;
3492 : }
3493 0 : DO_(::google::protobuf::internal::WireFormatLite::SkipField(input, tag));
3494 0 : break;
3495 : }
3496 : }
3497 0 : }
3498 : success:
3499 : // @@protoc_insertion_point(parse_success:grpc.testing.StreamingOutputCallResponse)
3500 0 : return true;
3501 : failure:
3502 : // @@protoc_insertion_point(parse_failure:grpc.testing.StreamingOutputCallResponse)
3503 0 : return false;
3504 : #undef DO_
3505 : }
3506 :
3507 0 : void StreamingOutputCallResponse::SerializeWithCachedSizes(
3508 : ::google::protobuf::io::CodedOutputStream* output) const {
3509 : // @@protoc_insertion_point(serialize_start:grpc.testing.StreamingOutputCallResponse)
3510 : // optional .grpc.testing.Payload payload = 1;
3511 0 : if (this->has_payload()) {
3512 : ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
3513 0 : 1, *this->payload_, output);
3514 : }
3515 :
3516 : // @@protoc_insertion_point(serialize_end:grpc.testing.StreamingOutputCallResponse)
3517 0 : }
3518 :
3519 0 : ::google::protobuf::uint8* StreamingOutputCallResponse::SerializeWithCachedSizesToArray(
3520 : ::google::protobuf::uint8* target) const {
3521 : // @@protoc_insertion_point(serialize_to_array_start:grpc.testing.StreamingOutputCallResponse)
3522 : // optional .grpc.testing.Payload payload = 1;
3523 0 : if (this->has_payload()) {
3524 : target = ::google::protobuf::internal::WireFormatLite::
3525 : WriteMessageNoVirtualToArray(
3526 0 : 1, *this->payload_, target);
3527 : }
3528 :
3529 : // @@protoc_insertion_point(serialize_to_array_end:grpc.testing.StreamingOutputCallResponse)
3530 0 : return target;
3531 : }
3532 :
3533 0 : int StreamingOutputCallResponse::ByteSize() const {
3534 0 : int total_size = 0;
3535 :
3536 : // optional .grpc.testing.Payload payload = 1;
3537 0 : if (this->has_payload()) {
3538 : total_size += 1 +
3539 : ::google::protobuf::internal::WireFormatLite::MessageSizeNoVirtual(
3540 0 : *this->payload_);
3541 : }
3542 :
3543 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3544 0 : _cached_size_ = total_size;
3545 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
3546 0 : return total_size;
3547 : }
3548 :
3549 0 : void StreamingOutputCallResponse::MergeFrom(const ::google::protobuf::Message& from) {
3550 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
3551 : const StreamingOutputCallResponse* source =
3552 : ::google::protobuf::internal::DynamicCastToGenerated<const StreamingOutputCallResponse>(
3553 0 : &from);
3554 0 : if (source == NULL) {
3555 0 : ::google::protobuf::internal::ReflectionOps::Merge(from, this);
3556 : } else {
3557 0 : MergeFrom(*source);
3558 : }
3559 0 : }
3560 :
3561 0 : void StreamingOutputCallResponse::MergeFrom(const StreamingOutputCallResponse& from) {
3562 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
3563 0 : if (from.has_payload()) {
3564 0 : mutable_payload()->::grpc::testing::Payload::MergeFrom(from.payload());
3565 : }
3566 0 : }
3567 :
3568 0 : void StreamingOutputCallResponse::CopyFrom(const ::google::protobuf::Message& from) {
3569 0 : if (&from == this) return;
3570 0 : Clear();
3571 0 : MergeFrom(from);
3572 : }
3573 :
3574 0 : void StreamingOutputCallResponse::CopyFrom(const StreamingOutputCallResponse& from) {
3575 0 : if (&from == this) return;
3576 0 : Clear();
3577 0 : MergeFrom(from);
3578 : }
3579 :
3580 0 : bool StreamingOutputCallResponse::IsInitialized() const {
3581 :
3582 0 : return true;
3583 : }
3584 :
3585 0 : void StreamingOutputCallResponse::Swap(StreamingOutputCallResponse* other) {
3586 0 : if (other == this) return;
3587 0 : InternalSwap(other);
3588 : }
3589 0 : void StreamingOutputCallResponse::InternalSwap(StreamingOutputCallResponse* other) {
3590 0 : std::swap(payload_, other->payload_);
3591 0 : _internal_metadata_.Swap(&other->_internal_metadata_);
3592 0 : std::swap(_cached_size_, other->_cached_size_);
3593 0 : }
3594 :
3595 0 : ::google::protobuf::Metadata StreamingOutputCallResponse::GetMetadata() const {
3596 0 : protobuf_AssignDescriptorsOnce();
3597 : ::google::protobuf::Metadata metadata;
3598 0 : metadata.descriptor = StreamingOutputCallResponse_descriptor_;
3599 0 : metadata.reflection = StreamingOutputCallResponse_reflection_;
3600 0 : return metadata;
3601 : }
3602 :
3603 : #if PROTOBUF_INLINE_NOT_IN_HEADERS
3604 : // StreamingOutputCallResponse
3605 :
3606 : // optional .grpc.testing.Payload payload = 1;
3607 : bool StreamingOutputCallResponse::has_payload() const {
3608 : return !_is_default_instance_ && payload_ != NULL;
3609 : }
3610 : void StreamingOutputCallResponse::clear_payload() {
3611 : if (GetArenaNoVirtual() == NULL && payload_ != NULL) delete payload_;
3612 : payload_ = NULL;
3613 : }
3614 : const ::grpc::testing::Payload& StreamingOutputCallResponse::payload() const {
3615 : // @@protoc_insertion_point(field_get:grpc.testing.StreamingOutputCallResponse.payload)
3616 : return payload_ != NULL ? *payload_ : *default_instance_->payload_;
3617 : }
3618 : ::grpc::testing::Payload* StreamingOutputCallResponse::mutable_payload() {
3619 :
3620 : if (payload_ == NULL) {
3621 : payload_ = new ::grpc::testing::Payload;
3622 : }
3623 : // @@protoc_insertion_point(field_mutable:grpc.testing.StreamingOutputCallResponse.payload)
3624 : return payload_;
3625 : }
3626 : ::grpc::testing::Payload* StreamingOutputCallResponse::release_payload() {
3627 :
3628 : ::grpc::testing::Payload* temp = payload_;
3629 : payload_ = NULL;
3630 : return temp;
3631 : }
3632 : void StreamingOutputCallResponse::set_allocated_payload(::grpc::testing::Payload* payload) {
3633 : delete payload_;
3634 : payload_ = payload;
3635 : if (payload) {
3636 :
3637 : } else {
3638 :
3639 : }
3640 : // @@protoc_insertion_point(field_set_allocated:grpc.testing.StreamingOutputCallResponse.payload)
3641 : }
3642 :
3643 : #endif // PROTOBUF_INLINE_NOT_IN_HEADERS
3644 :
3645 : // ===================================================================
3646 :
3647 : #ifndef _MSC_VER
3648 : const int ReconnectInfo::kPassedFieldNumber;
3649 : const int ReconnectInfo::kBackoffMsFieldNumber;
3650 : #endif // !_MSC_VER
3651 :
3652 5 : ReconnectInfo::ReconnectInfo()
3653 5 : : ::google::protobuf::Message(), _internal_metadata_(NULL) {
3654 5 : SharedCtor();
3655 : // @@protoc_insertion_point(constructor:grpc.testing.ReconnectInfo)
3656 5 : }
3657 :
3658 5 : void ReconnectInfo::InitAsDefaultInstance() {
3659 5 : _is_default_instance_ = true;
3660 5 : }
3661 :
3662 0 : ReconnectInfo::ReconnectInfo(const ReconnectInfo& from)
3663 : : ::google::protobuf::Message(),
3664 0 : _internal_metadata_(NULL) {
3665 0 : SharedCtor();
3666 0 : MergeFrom(from);
3667 : // @@protoc_insertion_point(copy_constructor:grpc.testing.ReconnectInfo)
3668 0 : }
3669 :
3670 5 : void ReconnectInfo::SharedCtor() {
3671 5 : _is_default_instance_ = false;
3672 5 : _cached_size_ = 0;
3673 5 : passed_ = false;
3674 5 : }
3675 :
3676 0 : ReconnectInfo::~ReconnectInfo() {
3677 : // @@protoc_insertion_point(destructor:grpc.testing.ReconnectInfo)
3678 0 : SharedDtor();
3679 0 : }
3680 :
3681 0 : void ReconnectInfo::SharedDtor() {
3682 0 : if (this != default_instance_) {
3683 : }
3684 0 : }
3685 :
3686 0 : void ReconnectInfo::SetCachedSize(int size) const {
3687 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3688 0 : _cached_size_ = size;
3689 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
3690 0 : }
3691 0 : const ::google::protobuf::Descriptor* ReconnectInfo::descriptor() {
3692 0 : protobuf_AssignDescriptorsOnce();
3693 0 : return ReconnectInfo_descriptor_;
3694 : }
3695 :
3696 0 : const ReconnectInfo& ReconnectInfo::default_instance() {
3697 0 : if (default_instance_ == NULL) protobuf_AddDesc_test_2fproto_2fmessages_2eproto();
3698 0 : return *default_instance_;
3699 : }
3700 :
3701 : ReconnectInfo* ReconnectInfo::default_instance_ = NULL;
3702 :
3703 0 : ReconnectInfo* ReconnectInfo::New(::google::protobuf::Arena* arena) const {
3704 0 : ReconnectInfo* n = new ReconnectInfo;
3705 0 : if (arena != NULL) {
3706 0 : arena->Own(n);
3707 : }
3708 0 : return n;
3709 : }
3710 :
3711 0 : void ReconnectInfo::Clear() {
3712 0 : passed_ = false;
3713 0 : backoff_ms_.Clear();
3714 0 : }
3715 :
3716 0 : bool ReconnectInfo::MergePartialFromCodedStream(
3717 : ::google::protobuf::io::CodedInputStream* input) {
3718 : #define DO_(EXPRESSION) if (!(EXPRESSION)) goto failure
3719 : ::google::protobuf::uint32 tag;
3720 : // @@protoc_insertion_point(parse_start:grpc.testing.ReconnectInfo)
3721 : for (;;) {
3722 : ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoff(127);
3723 0 : tag = p.first;
3724 0 : if (!p.second) goto handle_unusual;
3725 0 : switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
3726 : // optional bool passed = 1;
3727 : case 1: {
3728 0 : if (tag == 8) {
3729 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
3730 : bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
3731 : input, &passed_)));
3732 :
3733 : } else {
3734 0 : goto handle_unusual;
3735 : }
3736 0 : if (input->ExpectTag(18)) goto parse_backoff_ms;
3737 0 : break;
3738 : }
3739 :
3740 : // repeated int32 backoff_ms = 2;
3741 : case 2: {
3742 0 : if (tag == 18) {
3743 : parse_backoff_ms:
3744 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadPackedPrimitive<
3745 : ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>(
3746 : input, this->mutable_backoff_ms())));
3747 0 : } else if (tag == 16) {
3748 0 : DO_((::google::protobuf::internal::WireFormatLite::ReadRepeatedPrimitiveNoInline<
3749 : ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>(
3750 : 1, 18, input, this->mutable_backoff_ms())));
3751 : } else {
3752 0 : goto handle_unusual;
3753 : }
3754 0 : if (input->ExpectAtEnd()) goto success;
3755 0 : break;
3756 : }
3757 :
3758 : default: {
3759 : handle_unusual:
3760 0 : if (tag == 0 ||
3761 0 : ::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
3762 : ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
3763 0 : goto success;
3764 : }
3765 0 : DO_(::google::protobuf::internal::WireFormatLite::SkipField(input, tag));
3766 0 : break;
3767 : }
3768 : }
3769 0 : }
3770 : success:
3771 : // @@protoc_insertion_point(parse_success:grpc.testing.ReconnectInfo)
3772 0 : return true;
3773 : failure:
3774 : // @@protoc_insertion_point(parse_failure:grpc.testing.ReconnectInfo)
3775 0 : return false;
3776 : #undef DO_
3777 : }
3778 :
3779 0 : void ReconnectInfo::SerializeWithCachedSizes(
3780 : ::google::protobuf::io::CodedOutputStream* output) const {
3781 : // @@protoc_insertion_point(serialize_start:grpc.testing.ReconnectInfo)
3782 : // optional bool passed = 1;
3783 0 : if (this->passed() != 0) {
3784 0 : ::google::protobuf::internal::WireFormatLite::WriteBool(1, this->passed(), output);
3785 : }
3786 :
3787 : // repeated int32 backoff_ms = 2;
3788 0 : if (this->backoff_ms_size() > 0) {
3789 : ::google::protobuf::internal::WireFormatLite::WriteTag(2, ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED, output);
3790 0 : output->WriteVarint32(_backoff_ms_cached_byte_size_);
3791 : }
3792 0 : for (int i = 0; i < this->backoff_ms_size(); i++) {
3793 : ::google::protobuf::internal::WireFormatLite::WriteInt32NoTag(
3794 0 : this->backoff_ms(i), output);
3795 : }
3796 :
3797 : // @@protoc_insertion_point(serialize_end:grpc.testing.ReconnectInfo)
3798 0 : }
3799 :
3800 0 : ::google::protobuf::uint8* ReconnectInfo::SerializeWithCachedSizesToArray(
3801 : ::google::protobuf::uint8* target) const {
3802 : // @@protoc_insertion_point(serialize_to_array_start:grpc.testing.ReconnectInfo)
3803 : // optional bool passed = 1;
3804 0 : if (this->passed() != 0) {
3805 0 : target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(1, this->passed(), target);
3806 : }
3807 :
3808 : // repeated int32 backoff_ms = 2;
3809 0 : if (this->backoff_ms_size() > 0) {
3810 : target = ::google::protobuf::internal::WireFormatLite::WriteTagToArray(
3811 : 2,
3812 : ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED,
3813 0 : target);
3814 : target = ::google::protobuf::io::CodedOutputStream::WriteVarint32ToArray(
3815 0 : _backoff_ms_cached_byte_size_, target);
3816 : }
3817 0 : for (int i = 0; i < this->backoff_ms_size(); i++) {
3818 : target = ::google::protobuf::internal::WireFormatLite::
3819 0 : WriteInt32NoTagToArray(this->backoff_ms(i), target);
3820 : }
3821 :
3822 : // @@protoc_insertion_point(serialize_to_array_end:grpc.testing.ReconnectInfo)
3823 0 : return target;
3824 : }
3825 :
3826 0 : int ReconnectInfo::ByteSize() const {
3827 0 : int total_size = 0;
3828 :
3829 : // optional bool passed = 1;
3830 0 : if (this->passed() != 0) {
3831 0 : total_size += 1 + 1;
3832 : }
3833 :
3834 : // repeated int32 backoff_ms = 2;
3835 : {
3836 0 : int data_size = 0;
3837 0 : for (int i = 0; i < this->backoff_ms_size(); i++) {
3838 : data_size += ::google::protobuf::internal::WireFormatLite::
3839 0 : Int32Size(this->backoff_ms(i));
3840 : }
3841 0 : if (data_size > 0) {
3842 : total_size += 1 +
3843 0 : ::google::protobuf::internal::WireFormatLite::Int32Size(data_size);
3844 : }
3845 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3846 0 : _backoff_ms_cached_byte_size_ = data_size;
3847 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
3848 0 : total_size += data_size;
3849 : }
3850 :
3851 : GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
3852 0 : _cached_size_ = total_size;
3853 : GOOGLE_SAFE_CONCURRENT_WRITES_END();
3854 0 : return total_size;
3855 : }
3856 :
3857 0 : void ReconnectInfo::MergeFrom(const ::google::protobuf::Message& from) {
3858 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
3859 : const ReconnectInfo* source =
3860 : ::google::protobuf::internal::DynamicCastToGenerated<const ReconnectInfo>(
3861 0 : &from);
3862 0 : if (source == NULL) {
3863 0 : ::google::protobuf::internal::ReflectionOps::Merge(from, this);
3864 : } else {
3865 0 : MergeFrom(*source);
3866 : }
3867 0 : }
3868 :
3869 0 : void ReconnectInfo::MergeFrom(const ReconnectInfo& from) {
3870 0 : if (GOOGLE_PREDICT_FALSE(&from == this)) MergeFromFail(__LINE__);
3871 0 : backoff_ms_.MergeFrom(from.backoff_ms_);
3872 0 : if (from.passed() != 0) {
3873 0 : set_passed(from.passed());
3874 : }
3875 0 : }
3876 :
3877 0 : void ReconnectInfo::CopyFrom(const ::google::protobuf::Message& from) {
3878 0 : if (&from == this) return;
3879 0 : Clear();
3880 0 : MergeFrom(from);
3881 : }
3882 :
3883 0 : void ReconnectInfo::CopyFrom(const ReconnectInfo& from) {
3884 0 : if (&from == this) return;
3885 0 : Clear();
3886 0 : MergeFrom(from);
3887 : }
3888 :
3889 0 : bool ReconnectInfo::IsInitialized() const {
3890 :
3891 0 : return true;
3892 : }
3893 :
3894 0 : void ReconnectInfo::Swap(ReconnectInfo* other) {
3895 0 : if (other == this) return;
3896 0 : InternalSwap(other);
3897 : }
3898 0 : void ReconnectInfo::InternalSwap(ReconnectInfo* other) {
3899 0 : std::swap(passed_, other->passed_);
3900 0 : backoff_ms_.UnsafeArenaSwap(&other->backoff_ms_);
3901 0 : _internal_metadata_.Swap(&other->_internal_metadata_);
3902 0 : std::swap(_cached_size_, other->_cached_size_);
3903 0 : }
3904 :
3905 0 : ::google::protobuf::Metadata ReconnectInfo::GetMetadata() const {
3906 0 : protobuf_AssignDescriptorsOnce();
3907 : ::google::protobuf::Metadata metadata;
3908 0 : metadata.descriptor = ReconnectInfo_descriptor_;
3909 0 : metadata.reflection = ReconnectInfo_reflection_;
3910 0 : return metadata;
3911 : }
3912 :
3913 : #if PROTOBUF_INLINE_NOT_IN_HEADERS
3914 : // ReconnectInfo
3915 :
3916 : // optional bool passed = 1;
3917 : void ReconnectInfo::clear_passed() {
3918 : passed_ = false;
3919 : }
3920 : bool ReconnectInfo::passed() const {
3921 : // @@protoc_insertion_point(field_get:grpc.testing.ReconnectInfo.passed)
3922 : return passed_;
3923 : }
3924 : void ReconnectInfo::set_passed(bool value) {
3925 :
3926 : passed_ = value;
3927 : // @@protoc_insertion_point(field_set:grpc.testing.ReconnectInfo.passed)
3928 : }
3929 :
3930 : // repeated int32 backoff_ms = 2;
3931 : int ReconnectInfo::backoff_ms_size() const {
3932 : return backoff_ms_.size();
3933 : }
3934 : void ReconnectInfo::clear_backoff_ms() {
3935 : backoff_ms_.Clear();
3936 : }
3937 : ::google::protobuf::int32 ReconnectInfo::backoff_ms(int index) const {
3938 : // @@protoc_insertion_point(field_get:grpc.testing.ReconnectInfo.backoff_ms)
3939 : return backoff_ms_.Get(index);
3940 : }
3941 : void ReconnectInfo::set_backoff_ms(int index, ::google::protobuf::int32 value) {
3942 : backoff_ms_.Set(index, value);
3943 : // @@protoc_insertion_point(field_set:grpc.testing.ReconnectInfo.backoff_ms)
3944 : }
3945 : void ReconnectInfo::add_backoff_ms(::google::protobuf::int32 value) {
3946 : backoff_ms_.Add(value);
3947 : // @@protoc_insertion_point(field_add:grpc.testing.ReconnectInfo.backoff_ms)
3948 : }
3949 : const ::google::protobuf::RepeatedField< ::google::protobuf::int32 >&
3950 : ReconnectInfo::backoff_ms() const {
3951 : // @@protoc_insertion_point(field_list:grpc.testing.ReconnectInfo.backoff_ms)
3952 : return backoff_ms_;
3953 : }
3954 : ::google::protobuf::RepeatedField< ::google::protobuf::int32 >*
3955 : ReconnectInfo::mutable_backoff_ms() {
3956 : // @@protoc_insertion_point(field_mutable_list:grpc.testing.ReconnectInfo.backoff_ms)
3957 : return &backoff_ms_;
3958 : }
3959 :
3960 : #endif // PROTOBUF_INLINE_NOT_IN_HEADERS
3961 :
3962 : // @@protoc_insertion_point(namespace_scope)
3963 :
3964 : } // namespace testing
3965 15 : } // namespace grpc
3966 :
3967 : // @@protoc_insertion_point(global_scope)
|
