1// Generated by the protocol buffer compiler. DO NOT EDIT!
2// source: IpcConnectionContext.proto
3
4#include "IpcConnectionContext.pb.h"
5
6#include <algorithm>
7
8#include <google/protobuf/stubs/common.h>
9#include <google/protobuf/stubs/port.h>
10#include <google/protobuf/io/coded_stream.h>
11#include <google/protobuf/wire_format_lite_inl.h>
12#include <google/protobuf/descriptor.h>
13#include <google/protobuf/generated_message_reflection.h>
14#include <google/protobuf/reflection_ops.h>
15#include <google/protobuf/wire_format.h>
16// This is a temporary google only hack
17#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
18#include "third_party/protobuf/version.h"
19#endif
20// @@protoc_insertion_point(includes)
21
22namespace protobuf_IpcConnectionContext_2eproto {
23extern PROTOBUF_INTERNAL_EXPORT_protobuf_IpcConnectionContext_2eproto ::google::protobuf::internal::SCCInfo<0> scc_info_UserInformationProto;
24} // namespace protobuf_IpcConnectionContext_2eproto
25namespace Hdfs {
26namespace Internal {
27class UserInformationProtoDefaultTypeInternal {
28 public:
29 ::google::protobuf::internal::ExplicitlyConstructed<UserInformationProto>
30 _instance;
31} _UserInformationProto_default_instance_;
32class IpcConnectionContextProtoDefaultTypeInternal {
33 public:
34 ::google::protobuf::internal::ExplicitlyConstructed<IpcConnectionContextProto>
35 _instance;
36} _IpcConnectionContextProto_default_instance_;
37} // namespace Internal
38} // namespace Hdfs
39namespace protobuf_IpcConnectionContext_2eproto {
40static void InitDefaultsUserInformationProto() {
41 GOOGLE_PROTOBUF_VERIFY_VERSION;
42
43 {
44 void* ptr = &::Hdfs::Internal::_UserInformationProto_default_instance_;
45 new (ptr) ::Hdfs::Internal::UserInformationProto();
46 ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
47 }
48 ::Hdfs::Internal::UserInformationProto::InitAsDefaultInstance();
49}
50
51::google::protobuf::internal::SCCInfo<0> scc_info_UserInformationProto =
52 {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsUserInformationProto}, {}};
53
54static void InitDefaultsIpcConnectionContextProto() {
55 GOOGLE_PROTOBUF_VERIFY_VERSION;
56
57 {
58 void* ptr = &::Hdfs::Internal::_IpcConnectionContextProto_default_instance_;
59 new (ptr) ::Hdfs::Internal::IpcConnectionContextProto();
60 ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
61 }
62 ::Hdfs::Internal::IpcConnectionContextProto::InitAsDefaultInstance();
63}
64
65::google::protobuf::internal::SCCInfo<1> scc_info_IpcConnectionContextProto =
66 {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 1, InitDefaultsIpcConnectionContextProto}, {
67 &protobuf_IpcConnectionContext_2eproto::scc_info_UserInformationProto.base,}};
68
69void InitDefaults() {
70 ::google::protobuf::internal::InitSCC(&scc_info_UserInformationProto.base);
71 ::google::protobuf::internal::InitSCC(&scc_info_IpcConnectionContextProto.base);
72}
73
74::google::protobuf::Metadata file_level_metadata[2];
75
76const ::google::protobuf::uint32 TableStruct::offsets[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
77 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::UserInformationProto, _has_bits_),
78 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::UserInformationProto, _internal_metadata_),
79 ~0u, // no _extensions_
80 ~0u, // no _oneof_case_
81 ~0u, // no _weak_field_map_
82 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::UserInformationProto, effectiveuser_),
83 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::UserInformationProto, realuser_),
84 0,
85 1,
86 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::IpcConnectionContextProto, _has_bits_),
87 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::IpcConnectionContextProto, _internal_metadata_),
88 ~0u, // no _extensions_
89 ~0u, // no _oneof_case_
90 ~0u, // no _weak_field_map_
91 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::IpcConnectionContextProto, userinfo_),
92 GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::Hdfs::Internal::IpcConnectionContextProto, protocol_),
93 1,
94 0,
95};
96static const ::google::protobuf::internal::MigrationSchema schemas[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
97 { 0, 7, sizeof(::Hdfs::Internal::UserInformationProto)},
98 { 9, 16, sizeof(::Hdfs::Internal::IpcConnectionContextProto)},
99};
100
101static ::google::protobuf::Message const * const file_default_instances[] = {
102 reinterpret_cast<const ::google::protobuf::Message*>(&::Hdfs::Internal::_UserInformationProto_default_instance_),
103 reinterpret_cast<const ::google::protobuf::Message*>(&::Hdfs::Internal::_IpcConnectionContextProto_default_instance_),
104};
105
106void protobuf_AssignDescriptors() {
107 AddDescriptors();
108 AssignDescriptors(
109 "IpcConnectionContext.proto", schemas, file_default_instances, TableStruct::offsets,
110 file_level_metadata, NULL, NULL);
111}
112
113void protobuf_AssignDescriptorsOnce() {
114 static ::google::protobuf::internal::once_flag once;
115 ::google::protobuf::internal::call_once(once, protobuf_AssignDescriptors);
116}
117
118void protobuf_RegisterTypes(const ::std::string&) GOOGLE_PROTOBUF_ATTRIBUTE_COLD;
119void protobuf_RegisterTypes(const ::std::string&) {
120 protobuf_AssignDescriptorsOnce();
121 ::google::protobuf::internal::RegisterAllTypes(file_level_metadata, 2);
122}
123
124void AddDescriptorsImpl() {
125 InitDefaults();
126 static const char descriptor[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
127 "\n\032IpcConnectionContext.proto\022\rHdfs.Inter"
128 "nal\"\?\n\024UserInformationProto\022\025\n\reffective"
129 "User\030\001 \001(\t\022\020\n\010realUser\030\002 \001(\t\"d\n\031IpcConne"
130 "ctionContextProto\0225\n\010userInfo\030\002 \001(\0132#.Hd"
131 "fs.Internal.UserInformationProto\022\020\n\010prot"
132 "ocol\030\003 \001(\tB\?\n\036org.apache.hadoop.ipc.prot"
133 "obufB\032IpcConnectionContextProtos\240\001\001"
134 };
135 ::google::protobuf::DescriptorPool::InternalAddGeneratedFile(
136 descriptor, 275);
137 ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(
138 "IpcConnectionContext.proto", &protobuf_RegisterTypes);
139}
140
141void AddDescriptors() {
142 static ::google::protobuf::internal::once_flag once;
143 ::google::protobuf::internal::call_once(once, AddDescriptorsImpl);
144}
145// Force AddDescriptors() to be called at dynamic initialization time.
146struct StaticDescriptorInitializer {
147 StaticDescriptorInitializer() {
148 AddDescriptors();
149 }
150} static_descriptor_initializer;
151} // namespace protobuf_IpcConnectionContext_2eproto
152namespace Hdfs {
153namespace Internal {
154
155// ===================================================================
156
157void UserInformationProto::InitAsDefaultInstance() {
158}
159#if !defined(_MSC_VER) || _MSC_VER >= 1900
160const int UserInformationProto::kEffectiveUserFieldNumber;
161const int UserInformationProto::kRealUserFieldNumber;
162#endif // !defined(_MSC_VER) || _MSC_VER >= 1900
163
164UserInformationProto::UserInformationProto()
165 : ::google::protobuf::Message(), _internal_metadata_(NULL) {
166 ::google::protobuf::internal::InitSCC(
167 &protobuf_IpcConnectionContext_2eproto::scc_info_UserInformationProto.base);
168 SharedCtor();
169 // @@protoc_insertion_point(constructor:Hdfs.Internal.UserInformationProto)
170}
171UserInformationProto::UserInformationProto(const UserInformationProto& from)
172 : ::google::protobuf::Message(),
173 _internal_metadata_(NULL),
174 _has_bits_(from._has_bits_) {
175 _internal_metadata_.MergeFrom(from._internal_metadata_);
176 effectiveuser_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
177 if (from.has_effectiveuser()) {
178 effectiveuser_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.effectiveuser_);
179 }
180 realuser_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
181 if (from.has_realuser()) {
182 realuser_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.realuser_);
183 }
184 // @@protoc_insertion_point(copy_constructor:Hdfs.Internal.UserInformationProto)
185}
186
187void UserInformationProto::SharedCtor() {
188 effectiveuser_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
189 realuser_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
190}
191
192UserInformationProto::~UserInformationProto() {
193 // @@protoc_insertion_point(destructor:Hdfs.Internal.UserInformationProto)
194 SharedDtor();
195}
196
197void UserInformationProto::SharedDtor() {
198 effectiveuser_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
199 realuser_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
200}
201
202void UserInformationProto::SetCachedSize(int size) const {
203 _cached_size_.Set(size);
204}
205const ::google::protobuf::Descriptor* UserInformationProto::descriptor() {
206 ::protobuf_IpcConnectionContext_2eproto::protobuf_AssignDescriptorsOnce();
207 return ::protobuf_IpcConnectionContext_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
208}
209
210const UserInformationProto& UserInformationProto::default_instance() {
211 ::google::protobuf::internal::InitSCC(&protobuf_IpcConnectionContext_2eproto::scc_info_UserInformationProto.base);
212 return *internal_default_instance();
213}
214
215
216void UserInformationProto::Clear() {
217// @@protoc_insertion_point(message_clear_start:Hdfs.Internal.UserInformationProto)
218 ::google::protobuf::uint32 cached_has_bits = 0;
219 // Prevent compiler warnings about cached_has_bits being unused
220 (void) cached_has_bits;
221
222 cached_has_bits = _has_bits_[0];
223 if (cached_has_bits & 3u) {
224 if (cached_has_bits & 0x00000001u) {
225 effectiveuser_.ClearNonDefaultToEmptyNoArena();
226 }
227 if (cached_has_bits & 0x00000002u) {
228 realuser_.ClearNonDefaultToEmptyNoArena();
229 }
230 }
231 _has_bits_.Clear();
232 _internal_metadata_.Clear();
233}
234
235bool UserInformationProto::MergePartialFromCodedStream(
236 ::google::protobuf::io::CodedInputStream* input) {
237#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
238 ::google::protobuf::uint32 tag;
239 // @@protoc_insertion_point(parse_start:Hdfs.Internal.UserInformationProto)
240 for (;;) {
241 ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
242 tag = p.first;
243 if (!p.second) goto handle_unusual;
244 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
245 // optional string effectiveUser = 1;
246 case 1: {
247 if (static_cast< ::google::protobuf::uint8>(tag) ==
248 static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
249 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
250 input, this->mutable_effectiveuser()));
251 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
252 this->effectiveuser().data(), static_cast<int>(this->effectiveuser().length()),
253 ::google::protobuf::internal::WireFormat::PARSE,
254 "Hdfs.Internal.UserInformationProto.effectiveUser");
255 } else {
256 goto handle_unusual;
257 }
258 break;
259 }
260
261 // optional string realUser = 2;
262 case 2: {
263 if (static_cast< ::google::protobuf::uint8>(tag) ==
264 static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) {
265 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
266 input, this->mutable_realuser()));
267 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
268 this->realuser().data(), static_cast<int>(this->realuser().length()),
269 ::google::protobuf::internal::WireFormat::PARSE,
270 "Hdfs.Internal.UserInformationProto.realUser");
271 } else {
272 goto handle_unusual;
273 }
274 break;
275 }
276
277 default: {
278 handle_unusual:
279 if (tag == 0) {
280 goto success;
281 }
282 DO_(::google::protobuf::internal::WireFormat::SkipField(
283 input, tag, _internal_metadata_.mutable_unknown_fields()));
284 break;
285 }
286 }
287 }
288success:
289 // @@protoc_insertion_point(parse_success:Hdfs.Internal.UserInformationProto)
290 return true;
291failure:
292 // @@protoc_insertion_point(parse_failure:Hdfs.Internal.UserInformationProto)
293 return false;
294#undef DO_
295}
296
297void UserInformationProto::SerializeWithCachedSizes(
298 ::google::protobuf::io::CodedOutputStream* output) const {
299 // @@protoc_insertion_point(serialize_start:Hdfs.Internal.UserInformationProto)
300 ::google::protobuf::uint32 cached_has_bits = 0;
301 (void) cached_has_bits;
302
303 cached_has_bits = _has_bits_[0];
304 // optional string effectiveUser = 1;
305 if (cached_has_bits & 0x00000001u) {
306 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
307 this->effectiveuser().data(), static_cast<int>(this->effectiveuser().length()),
308 ::google::protobuf::internal::WireFormat::SERIALIZE,
309 "Hdfs.Internal.UserInformationProto.effectiveUser");
310 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
311 1, this->effectiveuser(), output);
312 }
313
314 // optional string realUser = 2;
315 if (cached_has_bits & 0x00000002u) {
316 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
317 this->realuser().data(), static_cast<int>(this->realuser().length()),
318 ::google::protobuf::internal::WireFormat::SERIALIZE,
319 "Hdfs.Internal.UserInformationProto.realUser");
320 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
321 2, this->realuser(), output);
322 }
323
324 if (_internal_metadata_.have_unknown_fields()) {
325 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
326 _internal_metadata_.unknown_fields(), output);
327 }
328 // @@protoc_insertion_point(serialize_end:Hdfs.Internal.UserInformationProto)
329}
330
331::google::protobuf::uint8* UserInformationProto::InternalSerializeWithCachedSizesToArray(
332 bool deterministic, ::google::protobuf::uint8* target) const {
333 (void)deterministic; // Unused
334 // @@protoc_insertion_point(serialize_to_array_start:Hdfs.Internal.UserInformationProto)
335 ::google::protobuf::uint32 cached_has_bits = 0;
336 (void) cached_has_bits;
337
338 cached_has_bits = _has_bits_[0];
339 // optional string effectiveUser = 1;
340 if (cached_has_bits & 0x00000001u) {
341 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
342 this->effectiveuser().data(), static_cast<int>(this->effectiveuser().length()),
343 ::google::protobuf::internal::WireFormat::SERIALIZE,
344 "Hdfs.Internal.UserInformationProto.effectiveUser");
345 target =
346 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
347 1, this->effectiveuser(), target);
348 }
349
350 // optional string realUser = 2;
351 if (cached_has_bits & 0x00000002u) {
352 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
353 this->realuser().data(), static_cast<int>(this->realuser().length()),
354 ::google::protobuf::internal::WireFormat::SERIALIZE,
355 "Hdfs.Internal.UserInformationProto.realUser");
356 target =
357 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
358 2, this->realuser(), target);
359 }
360
361 if (_internal_metadata_.have_unknown_fields()) {
362 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
363 _internal_metadata_.unknown_fields(), target);
364 }
365 // @@protoc_insertion_point(serialize_to_array_end:Hdfs.Internal.UserInformationProto)
366 return target;
367}
368
369size_t UserInformationProto::ByteSizeLong() const {
370// @@protoc_insertion_point(message_byte_size_start:Hdfs.Internal.UserInformationProto)
371 size_t total_size = 0;
372
373 if (_internal_metadata_.have_unknown_fields()) {
374 total_size +=
375 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
376 _internal_metadata_.unknown_fields());
377 }
378 if (_has_bits_[0 / 32] & 3u) {
379 // optional string effectiveUser = 1;
380 if (has_effectiveuser()) {
381 total_size += 1 +
382 ::google::protobuf::internal::WireFormatLite::StringSize(
383 this->effectiveuser());
384 }
385
386 // optional string realUser = 2;
387 if (has_realuser()) {
388 total_size += 1 +
389 ::google::protobuf::internal::WireFormatLite::StringSize(
390 this->realuser());
391 }
392
393 }
394 int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
395 SetCachedSize(cached_size);
396 return total_size;
397}
398
399void UserInformationProto::MergeFrom(const ::google::protobuf::Message& from) {
400// @@protoc_insertion_point(generalized_merge_from_start:Hdfs.Internal.UserInformationProto)
401 GOOGLE_DCHECK_NE(&from, this);
402 const UserInformationProto* source =
403 ::google::protobuf::internal::DynamicCastToGenerated<const UserInformationProto>(
404 &from);
405 if (source == NULL) {
406 // @@protoc_insertion_point(generalized_merge_from_cast_fail:Hdfs.Internal.UserInformationProto)
407 ::google::protobuf::internal::ReflectionOps::Merge(from, this);
408 } else {
409 // @@protoc_insertion_point(generalized_merge_from_cast_success:Hdfs.Internal.UserInformationProto)
410 MergeFrom(*source);
411 }
412}
413
414void UserInformationProto::MergeFrom(const UserInformationProto& from) {
415// @@protoc_insertion_point(class_specific_merge_from_start:Hdfs.Internal.UserInformationProto)
416 GOOGLE_DCHECK_NE(&from, this);
417 _internal_metadata_.MergeFrom(from._internal_metadata_);
418 ::google::protobuf::uint32 cached_has_bits = 0;
419 (void) cached_has_bits;
420
421 cached_has_bits = from._has_bits_[0];
422 if (cached_has_bits & 3u) {
423 if (cached_has_bits & 0x00000001u) {
424 set_has_effectiveuser();
425 effectiveuser_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.effectiveuser_);
426 }
427 if (cached_has_bits & 0x00000002u) {
428 set_has_realuser();
429 realuser_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.realuser_);
430 }
431 }
432}
433
434void UserInformationProto::CopyFrom(const ::google::protobuf::Message& from) {
435// @@protoc_insertion_point(generalized_copy_from_start:Hdfs.Internal.UserInformationProto)
436 if (&from == this) return;
437 Clear();
438 MergeFrom(from);
439}
440
441void UserInformationProto::CopyFrom(const UserInformationProto& from) {
442// @@protoc_insertion_point(class_specific_copy_from_start:Hdfs.Internal.UserInformationProto)
443 if (&from == this) return;
444 Clear();
445 MergeFrom(from);
446}
447
448bool UserInformationProto::IsInitialized() const {
449 return true;
450}
451
452void UserInformationProto::Swap(UserInformationProto* other) {
453 if (other == this) return;
454 InternalSwap(other);
455}
456void UserInformationProto::InternalSwap(UserInformationProto* other) {
457 using std::swap;
458 effectiveuser_.Swap(&other->effectiveuser_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(),
459 GetArenaNoVirtual());
460 realuser_.Swap(&other->realuser_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(),
461 GetArenaNoVirtual());
462 swap(_has_bits_[0], other->_has_bits_[0]);
463 _internal_metadata_.Swap(&other->_internal_metadata_);
464}
465
466::google::protobuf::Metadata UserInformationProto::GetMetadata() const {
467 protobuf_IpcConnectionContext_2eproto::protobuf_AssignDescriptorsOnce();
468 return ::protobuf_IpcConnectionContext_2eproto::file_level_metadata[kIndexInFileMessages];
469}
470
471
472// ===================================================================
473
474void IpcConnectionContextProto::InitAsDefaultInstance() {
475 ::Hdfs::Internal::_IpcConnectionContextProto_default_instance_._instance.get_mutable()->userinfo_ = const_cast< ::Hdfs::Internal::UserInformationProto*>(
476 ::Hdfs::Internal::UserInformationProto::internal_default_instance());
477}
478#if !defined(_MSC_VER) || _MSC_VER >= 1900
479const int IpcConnectionContextProto::kUserInfoFieldNumber;
480const int IpcConnectionContextProto::kProtocolFieldNumber;
481#endif // !defined(_MSC_VER) || _MSC_VER >= 1900
482
483IpcConnectionContextProto::IpcConnectionContextProto()
484 : ::google::protobuf::Message(), _internal_metadata_(NULL) {
485 ::google::protobuf::internal::InitSCC(
486 &protobuf_IpcConnectionContext_2eproto::scc_info_IpcConnectionContextProto.base);
487 SharedCtor();
488 // @@protoc_insertion_point(constructor:Hdfs.Internal.IpcConnectionContextProto)
489}
490IpcConnectionContextProto::IpcConnectionContextProto(const IpcConnectionContextProto& from)
491 : ::google::protobuf::Message(),
492 _internal_metadata_(NULL),
493 _has_bits_(from._has_bits_) {
494 _internal_metadata_.MergeFrom(from._internal_metadata_);
495 protocol_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
496 if (from.has_protocol()) {
497 protocol_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.protocol_);
498 }
499 if (from.has_userinfo()) {
500 userinfo_ = new ::Hdfs::Internal::UserInformationProto(*from.userinfo_);
501 } else {
502 userinfo_ = NULL;
503 }
504 // @@protoc_insertion_point(copy_constructor:Hdfs.Internal.IpcConnectionContextProto)
505}
506
507void IpcConnectionContextProto::SharedCtor() {
508 protocol_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
509 userinfo_ = NULL;
510}
511
512IpcConnectionContextProto::~IpcConnectionContextProto() {
513 // @@protoc_insertion_point(destructor:Hdfs.Internal.IpcConnectionContextProto)
514 SharedDtor();
515}
516
517void IpcConnectionContextProto::SharedDtor() {
518 protocol_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
519 if (this != internal_default_instance()) delete userinfo_;
520}
521
522void IpcConnectionContextProto::SetCachedSize(int size) const {
523 _cached_size_.Set(size);
524}
525const ::google::protobuf::Descriptor* IpcConnectionContextProto::descriptor() {
526 ::protobuf_IpcConnectionContext_2eproto::protobuf_AssignDescriptorsOnce();
527 return ::protobuf_IpcConnectionContext_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
528}
529
530const IpcConnectionContextProto& IpcConnectionContextProto::default_instance() {
531 ::google::protobuf::internal::InitSCC(&protobuf_IpcConnectionContext_2eproto::scc_info_IpcConnectionContextProto.base);
532 return *internal_default_instance();
533}
534
535
536void IpcConnectionContextProto::Clear() {
537// @@protoc_insertion_point(message_clear_start:Hdfs.Internal.IpcConnectionContextProto)
538 ::google::protobuf::uint32 cached_has_bits = 0;
539 // Prevent compiler warnings about cached_has_bits being unused
540 (void) cached_has_bits;
541
542 cached_has_bits = _has_bits_[0];
543 if (cached_has_bits & 3u) {
544 if (cached_has_bits & 0x00000001u) {
545 protocol_.ClearNonDefaultToEmptyNoArena();
546 }
547 if (cached_has_bits & 0x00000002u) {
548 GOOGLE_DCHECK(userinfo_ != NULL);
549 userinfo_->Clear();
550 }
551 }
552 _has_bits_.Clear();
553 _internal_metadata_.Clear();
554}
555
556bool IpcConnectionContextProto::MergePartialFromCodedStream(
557 ::google::protobuf::io::CodedInputStream* input) {
558#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
559 ::google::protobuf::uint32 tag;
560 // @@protoc_insertion_point(parse_start:Hdfs.Internal.IpcConnectionContextProto)
561 for (;;) {
562 ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
563 tag = p.first;
564 if (!p.second) goto handle_unusual;
565 switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
566 // optional .Hdfs.Internal.UserInformationProto userInfo = 2;
567 case 2: {
568 if (static_cast< ::google::protobuf::uint8>(tag) ==
569 static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) {
570 DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
571 input, mutable_userinfo()));
572 } else {
573 goto handle_unusual;
574 }
575 break;
576 }
577
578 // optional string protocol = 3;
579 case 3: {
580 if (static_cast< ::google::protobuf::uint8>(tag) ==
581 static_cast< ::google::protobuf::uint8>(26u /* 26 & 0xFF */)) {
582 DO_(::google::protobuf::internal::WireFormatLite::ReadString(
583 input, this->mutable_protocol()));
584 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
585 this->protocol().data(), static_cast<int>(this->protocol().length()),
586 ::google::protobuf::internal::WireFormat::PARSE,
587 "Hdfs.Internal.IpcConnectionContextProto.protocol");
588 } else {
589 goto handle_unusual;
590 }
591 break;
592 }
593
594 default: {
595 handle_unusual:
596 if (tag == 0) {
597 goto success;
598 }
599 DO_(::google::protobuf::internal::WireFormat::SkipField(
600 input, tag, _internal_metadata_.mutable_unknown_fields()));
601 break;
602 }
603 }
604 }
605success:
606 // @@protoc_insertion_point(parse_success:Hdfs.Internal.IpcConnectionContextProto)
607 return true;
608failure:
609 // @@protoc_insertion_point(parse_failure:Hdfs.Internal.IpcConnectionContextProto)
610 return false;
611#undef DO_
612}
613
614void IpcConnectionContextProto::SerializeWithCachedSizes(
615 ::google::protobuf::io::CodedOutputStream* output) const {
616 // @@protoc_insertion_point(serialize_start:Hdfs.Internal.IpcConnectionContextProto)
617 ::google::protobuf::uint32 cached_has_bits = 0;
618 (void) cached_has_bits;
619
620 cached_has_bits = _has_bits_[0];
621 // optional .Hdfs.Internal.UserInformationProto userInfo = 2;
622 if (cached_has_bits & 0x00000002u) {
623 ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
624 2, this->_internal_userinfo(), output);
625 }
626
627 // optional string protocol = 3;
628 if (cached_has_bits & 0x00000001u) {
629 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
630 this->protocol().data(), static_cast<int>(this->protocol().length()),
631 ::google::protobuf::internal::WireFormat::SERIALIZE,
632 "Hdfs.Internal.IpcConnectionContextProto.protocol");
633 ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
634 3, this->protocol(), output);
635 }
636
637 if (_internal_metadata_.have_unknown_fields()) {
638 ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
639 _internal_metadata_.unknown_fields(), output);
640 }
641 // @@protoc_insertion_point(serialize_end:Hdfs.Internal.IpcConnectionContextProto)
642}
643
644::google::protobuf::uint8* IpcConnectionContextProto::InternalSerializeWithCachedSizesToArray(
645 bool deterministic, ::google::protobuf::uint8* target) const {
646 (void)deterministic; // Unused
647 // @@protoc_insertion_point(serialize_to_array_start:Hdfs.Internal.IpcConnectionContextProto)
648 ::google::protobuf::uint32 cached_has_bits = 0;
649 (void) cached_has_bits;
650
651 cached_has_bits = _has_bits_[0];
652 // optional .Hdfs.Internal.UserInformationProto userInfo = 2;
653 if (cached_has_bits & 0x00000002u) {
654 target = ::google::protobuf::internal::WireFormatLite::
655 InternalWriteMessageToArray(
656 2, this->_internal_userinfo(), deterministic, target);
657 }
658
659 // optional string protocol = 3;
660 if (cached_has_bits & 0x00000001u) {
661 ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(
662 this->protocol().data(), static_cast<int>(this->protocol().length()),
663 ::google::protobuf::internal::WireFormat::SERIALIZE,
664 "Hdfs.Internal.IpcConnectionContextProto.protocol");
665 target =
666 ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
667 3, this->protocol(), target);
668 }
669
670 if (_internal_metadata_.have_unknown_fields()) {
671 target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
672 _internal_metadata_.unknown_fields(), target);
673 }
674 // @@protoc_insertion_point(serialize_to_array_end:Hdfs.Internal.IpcConnectionContextProto)
675 return target;
676}
677
678size_t IpcConnectionContextProto::ByteSizeLong() const {
679// @@protoc_insertion_point(message_byte_size_start:Hdfs.Internal.IpcConnectionContextProto)
680 size_t total_size = 0;
681
682 if (_internal_metadata_.have_unknown_fields()) {
683 total_size +=
684 ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
685 _internal_metadata_.unknown_fields());
686 }
687 if (_has_bits_[0 / 32] & 3u) {
688 // optional string protocol = 3;
689 if (has_protocol()) {
690 total_size += 1 +
691 ::google::protobuf::internal::WireFormatLite::StringSize(
692 this->protocol());
693 }
694
695 // optional .Hdfs.Internal.UserInformationProto userInfo = 2;
696 if (has_userinfo()) {
697 total_size += 1 +
698 ::google::protobuf::internal::WireFormatLite::MessageSize(
699 *userinfo_);
700 }
701
702 }
703 int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
704 SetCachedSize(cached_size);
705 return total_size;
706}
707
708void IpcConnectionContextProto::MergeFrom(const ::google::protobuf::Message& from) {
709// @@protoc_insertion_point(generalized_merge_from_start:Hdfs.Internal.IpcConnectionContextProto)
710 GOOGLE_DCHECK_NE(&from, this);
711 const IpcConnectionContextProto* source =
712 ::google::protobuf::internal::DynamicCastToGenerated<const IpcConnectionContextProto>(
713 &from);
714 if (source == NULL) {
715 // @@protoc_insertion_point(generalized_merge_from_cast_fail:Hdfs.Internal.IpcConnectionContextProto)
716 ::google::protobuf::internal::ReflectionOps::Merge(from, this);
717 } else {
718 // @@protoc_insertion_point(generalized_merge_from_cast_success:Hdfs.Internal.IpcConnectionContextProto)
719 MergeFrom(*source);
720 }
721}
722
723void IpcConnectionContextProto::MergeFrom(const IpcConnectionContextProto& from) {
724// @@protoc_insertion_point(class_specific_merge_from_start:Hdfs.Internal.IpcConnectionContextProto)
725 GOOGLE_DCHECK_NE(&from, this);
726 _internal_metadata_.MergeFrom(from._internal_metadata_);
727 ::google::protobuf::uint32 cached_has_bits = 0;
728 (void) cached_has_bits;
729
730 cached_has_bits = from._has_bits_[0];
731 if (cached_has_bits & 3u) {
732 if (cached_has_bits & 0x00000001u) {
733 set_has_protocol();
734 protocol_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.protocol_);
735 }
736 if (cached_has_bits & 0x00000002u) {
737 mutable_userinfo()->::Hdfs::Internal::UserInformationProto::MergeFrom(from.userinfo());
738 }
739 }
740}
741
742void IpcConnectionContextProto::CopyFrom(const ::google::protobuf::Message& from) {
743// @@protoc_insertion_point(generalized_copy_from_start:Hdfs.Internal.IpcConnectionContextProto)
744 if (&from == this) return;
745 Clear();
746 MergeFrom(from);
747}
748
749void IpcConnectionContextProto::CopyFrom(const IpcConnectionContextProto& from) {
750// @@protoc_insertion_point(class_specific_copy_from_start:Hdfs.Internal.IpcConnectionContextProto)
751 if (&from == this) return;
752 Clear();
753 MergeFrom(from);
754}
755
756bool IpcConnectionContextProto::IsInitialized() const {
757 return true;
758}
759
760void IpcConnectionContextProto::Swap(IpcConnectionContextProto* other) {
761 if (other == this) return;
762 InternalSwap(other);
763}
764void IpcConnectionContextProto::InternalSwap(IpcConnectionContextProto* other) {
765 using std::swap;
766 protocol_.Swap(&other->protocol_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(),
767 GetArenaNoVirtual());
768 swap(userinfo_, other->userinfo_);
769 swap(_has_bits_[0], other->_has_bits_[0]);
770 _internal_metadata_.Swap(&other->_internal_metadata_);
771}
772
773::google::protobuf::Metadata IpcConnectionContextProto::GetMetadata() const {
774 protobuf_IpcConnectionContext_2eproto::protobuf_AssignDescriptorsOnce();
775 return ::protobuf_IpcConnectionContext_2eproto::file_level_metadata[kIndexInFileMessages];
776}
777
778
779// @@protoc_insertion_point(namespace_scope)
780} // namespace Internal
781} // namespace Hdfs
782namespace google {
783namespace protobuf {
784template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::Hdfs::Internal::UserInformationProto* Arena::CreateMaybeMessage< ::Hdfs::Internal::UserInformationProto >(Arena* arena) {
785 return Arena::CreateInternal< ::Hdfs::Internal::UserInformationProto >(arena);
786}
787template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::Hdfs::Internal::IpcConnectionContextProto* Arena::CreateMaybeMessage< ::Hdfs::Internal::IpcConnectionContextProto >(Arena* arena) {
788 return Arena::CreateInternal< ::Hdfs::Internal::IpcConnectionContextProto >(arena);
789}
790} // namespace protobuf
791} // namespace google
792
793// @@protoc_insertion_point(global_scope)
794