1// Generated by the protocol buffer compiler. DO NOT EDIT!
2// source: tensorflow/core/protobuf/distributed_runtime_payloads.proto
3
4#include "tensorflow/core/protobuf/distributed_runtime_payloads.pb.h"
5
6#include <algorithm>
7
8#include <google/protobuf/stubs/common.h>
9#include <google/protobuf/io/coded_stream.h>
10#include <google/protobuf/extension_set.h>
11#include <google/protobuf/wire_format_lite.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// @@protoc_insertion_point(includes)
17#include <google/protobuf/port_def.inc>
18extern PROTOBUF_INTERNAL_EXPORT_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_GrpcPayloadContainer_PayloadsEntry_DoNotUse_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto;
19namespace tensorflow {
20namespace distributed_runtime {
21class GrpcPayloadContainer_PayloadsEntry_DoNotUseDefaultTypeInternal {
22 public:
23 ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<GrpcPayloadContainer_PayloadsEntry_DoNotUse> _instance;
24} _GrpcPayloadContainer_PayloadsEntry_DoNotUse_default_instance_;
25class GrpcPayloadContainerDefaultTypeInternal {
26 public:
27 ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<GrpcPayloadContainer> _instance;
28} _GrpcPayloadContainer_default_instance_;
29class GrpcPayloadsLostDefaultTypeInternal {
30 public:
31 ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<GrpcPayloadsLost> _instance;
32} _GrpcPayloadsLost_default_instance_;
33class WorkerPossiblyRestartedDefaultTypeInternal {
34 public:
35 ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<WorkerPossiblyRestarted> _instance;
36} _WorkerPossiblyRestarted_default_instance_;
37} // namespace distributed_runtime
38} // namespace tensorflow
39static void InitDefaultsscc_info_GrpcPayloadContainer_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto() {
40 GOOGLE_PROTOBUF_VERIFY_VERSION;
41
42 {
43 void* ptr = &::tensorflow::distributed_runtime::_GrpcPayloadContainer_default_instance_;
44 new (ptr) ::tensorflow::distributed_runtime::GrpcPayloadContainer();
45 ::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
46 }
47 ::tensorflow::distributed_runtime::GrpcPayloadContainer::InitAsDefaultInstance();
48}
49
50::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<1> scc_info_GrpcPayloadContainer_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto =
51 {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 1, InitDefaultsscc_info_GrpcPayloadContainer_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto}, {
52 &scc_info_GrpcPayloadContainer_PayloadsEntry_DoNotUse_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.base,}};
53
54static void InitDefaultsscc_info_GrpcPayloadContainer_PayloadsEntry_DoNotUse_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto() {
55 GOOGLE_PROTOBUF_VERIFY_VERSION;
56
57 {
58 void* ptr = &::tensorflow::distributed_runtime::_GrpcPayloadContainer_PayloadsEntry_DoNotUse_default_instance_;
59 new (ptr) ::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse();
60 }
61 ::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse::InitAsDefaultInstance();
62}
63
64::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_GrpcPayloadContainer_PayloadsEntry_DoNotUse_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto =
65 {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsscc_info_GrpcPayloadContainer_PayloadsEntry_DoNotUse_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto}, {}};
66
67static void InitDefaultsscc_info_GrpcPayloadsLost_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto() {
68 GOOGLE_PROTOBUF_VERIFY_VERSION;
69
70 {
71 void* ptr = &::tensorflow::distributed_runtime::_GrpcPayloadsLost_default_instance_;
72 new (ptr) ::tensorflow::distributed_runtime::GrpcPayloadsLost();
73 ::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
74 }
75 ::tensorflow::distributed_runtime::GrpcPayloadsLost::InitAsDefaultInstance();
76}
77
78::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_GrpcPayloadsLost_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto =
79 {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsscc_info_GrpcPayloadsLost_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto}, {}};
80
81static void InitDefaultsscc_info_WorkerPossiblyRestarted_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto() {
82 GOOGLE_PROTOBUF_VERIFY_VERSION;
83
84 {
85 void* ptr = &::tensorflow::distributed_runtime::_WorkerPossiblyRestarted_default_instance_;
86 new (ptr) ::tensorflow::distributed_runtime::WorkerPossiblyRestarted();
87 ::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
88 }
89 ::tensorflow::distributed_runtime::WorkerPossiblyRestarted::InitAsDefaultInstance();
90}
91
92::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_WorkerPossiblyRestarted_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto =
93 {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsscc_info_WorkerPossiblyRestarted_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto}, {}};
94
95static ::PROTOBUF_NAMESPACE_ID::Metadata file_level_metadata_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto[4];
96static constexpr ::PROTOBUF_NAMESPACE_ID::EnumDescriptor const** file_level_enum_descriptors_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto = nullptr;
97static constexpr ::PROTOBUF_NAMESPACE_ID::ServiceDescriptor const** file_level_service_descriptors_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto = nullptr;
98
99const ::PROTOBUF_NAMESPACE_ID::uint32 TableStruct_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
100 PROTOBUF_FIELD_OFFSET(::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse, _has_bits_),
101 PROTOBUF_FIELD_OFFSET(::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse, _internal_metadata_),
102 ~0u, // no _extensions_
103 ~0u, // no _oneof_case_
104 ~0u, // no _weak_field_map_
105 PROTOBUF_FIELD_OFFSET(::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse, key_),
106 PROTOBUF_FIELD_OFFSET(::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse, value_),
107 0,
108 1,
109 ~0u, // no _has_bits_
110 PROTOBUF_FIELD_OFFSET(::tensorflow::distributed_runtime::GrpcPayloadContainer, _internal_metadata_),
111 ~0u, // no _extensions_
112 ~0u, // no _oneof_case_
113 ~0u, // no _weak_field_map_
114 PROTOBUF_FIELD_OFFSET(::tensorflow::distributed_runtime::GrpcPayloadContainer, payloads_),
115 ~0u, // no _has_bits_
116 PROTOBUF_FIELD_OFFSET(::tensorflow::distributed_runtime::GrpcPayloadsLost, _internal_metadata_),
117 ~0u, // no _extensions_
118 ~0u, // no _oneof_case_
119 ~0u, // no _weak_field_map_
120 ~0u, // no _has_bits_
121 PROTOBUF_FIELD_OFFSET(::tensorflow::distributed_runtime::WorkerPossiblyRestarted, _internal_metadata_),
122 ~0u, // no _extensions_
123 ~0u, // no _oneof_case_
124 ~0u, // no _weak_field_map_
125};
126static const ::PROTOBUF_NAMESPACE_ID::internal::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
127 { 0, 7, sizeof(::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse)},
128 { 9, -1, sizeof(::tensorflow::distributed_runtime::GrpcPayloadContainer)},
129 { 15, -1, sizeof(::tensorflow::distributed_runtime::GrpcPayloadsLost)},
130 { 20, -1, sizeof(::tensorflow::distributed_runtime::WorkerPossiblyRestarted)},
131};
132
133static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] = {
134 reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tensorflow::distributed_runtime::_GrpcPayloadContainer_PayloadsEntry_DoNotUse_default_instance_),
135 reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tensorflow::distributed_runtime::_GrpcPayloadContainer_default_instance_),
136 reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tensorflow::distributed_runtime::_GrpcPayloadsLost_default_instance_),
137 reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tensorflow::distributed_runtime::_WorkerPossiblyRestarted_default_instance_),
138};
139
140const char descriptor_table_protodef_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) =
141 "\n;tensorflow/core/protobuf/distributed_r"
142 "untime_payloads.proto\022\036tensorflow.distri"
143 "buted_runtime\"\235\001\n\024GrpcPayloadContainer\022T"
144 "\n\010payloads\030\001 \003(\0132B.tensorflow.distribute"
145 "d_runtime.GrpcPayloadContainer.PayloadsE"
146 "ntry\032/\n\rPayloadsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005va"
147 "lue\030\002 \001(\014:\0028\001\"\022\n\020GrpcPayloadsLost\"\031\n\027Wor"
148 "kerPossiblyRestartedBZZUgithub.com/tenso"
149 "rflow/tensorflow/tensorflow/go/core/prot"
150 "obuf/for_core_protos_go_proto\370\001\001b\006proto3"
151 ;
152static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto_deps[1] = {
153};
154static ::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase*const descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto_sccs[4] = {
155 &scc_info_GrpcPayloadContainer_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.base,
156 &scc_info_GrpcPayloadContainer_PayloadsEntry_DoNotUse_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.base,
157 &scc_info_GrpcPayloadsLost_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.base,
158 &scc_info_WorkerPossiblyRestarted_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.base,
159};
160static ::PROTOBUF_NAMESPACE_ID::internal::once_flag descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto_once;
161static bool descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto_initialized = false;
162const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto = {
163 &descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto_initialized, descriptor_table_protodef_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto, "tensorflow/core/protobuf/distributed_runtime_payloads.proto", 400,
164 &descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto_once, descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto_sccs, descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto_deps, 4, 0,
165 schemas, file_default_instances, TableStruct_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto::offsets,
166 file_level_metadata_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto, 4, file_level_enum_descriptors_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto, file_level_service_descriptors_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto,
167};
168
169// Force running AddDescriptors() at dynamic initialization time.
170static bool dynamic_init_dummy_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto = ( ::PROTOBUF_NAMESPACE_ID::internal::AddDescriptors(&descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto), true);
171namespace tensorflow {
172namespace distributed_runtime {
173
174// ===================================================================
175
176GrpcPayloadContainer_PayloadsEntry_DoNotUse::GrpcPayloadContainer_PayloadsEntry_DoNotUse() {}
177GrpcPayloadContainer_PayloadsEntry_DoNotUse::GrpcPayloadContainer_PayloadsEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena)
178 : SuperType(arena) {}
179void GrpcPayloadContainer_PayloadsEntry_DoNotUse::MergeFrom(const GrpcPayloadContainer_PayloadsEntry_DoNotUse& other) {
180 MergeFromInternal(other);
181}
182::PROTOBUF_NAMESPACE_ID::Metadata GrpcPayloadContainer_PayloadsEntry_DoNotUse::GetMetadata() const {
183 return GetMetadataStatic();
184}
185void GrpcPayloadContainer_PayloadsEntry_DoNotUse::MergeFrom(
186 const ::PROTOBUF_NAMESPACE_ID::Message& other) {
187 ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom(other);
188}
189
190
191// ===================================================================
192
193void GrpcPayloadContainer::InitAsDefaultInstance() {
194}
195class GrpcPayloadContainer::_Internal {
196 public:
197};
198
199GrpcPayloadContainer::GrpcPayloadContainer()
200 : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) {
201 SharedCtor();
202 // @@protoc_insertion_point(constructor:tensorflow.distributed_runtime.GrpcPayloadContainer)
203}
204GrpcPayloadContainer::GrpcPayloadContainer(::PROTOBUF_NAMESPACE_ID::Arena* arena)
205 : ::PROTOBUF_NAMESPACE_ID::Message(),
206 _internal_metadata_(arena),
207 payloads_(arena) {
208 SharedCtor();
209 RegisterArenaDtor(arena);
210 // @@protoc_insertion_point(arena_constructor:tensorflow.distributed_runtime.GrpcPayloadContainer)
211}
212GrpcPayloadContainer::GrpcPayloadContainer(const GrpcPayloadContainer& from)
213 : ::PROTOBUF_NAMESPACE_ID::Message(),
214 _internal_metadata_(nullptr) {
215 _internal_metadata_.MergeFrom(from._internal_metadata_);
216 payloads_.MergeFrom(from.payloads_);
217 // @@protoc_insertion_point(copy_constructor:tensorflow.distributed_runtime.GrpcPayloadContainer)
218}
219
220void GrpcPayloadContainer::SharedCtor() {
221 ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_GrpcPayloadContainer_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.base);
222}
223
224GrpcPayloadContainer::~GrpcPayloadContainer() {
225 // @@protoc_insertion_point(destructor:tensorflow.distributed_runtime.GrpcPayloadContainer)
226 SharedDtor();
227}
228
229void GrpcPayloadContainer::SharedDtor() {
230 GOOGLE_DCHECK(GetArenaNoVirtual() == nullptr);
231}
232
233void GrpcPayloadContainer::ArenaDtor(void* object) {
234 GrpcPayloadContainer* _this = reinterpret_cast< GrpcPayloadContainer* >(object);
235 (void)_this;
236}
237void GrpcPayloadContainer::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) {
238}
239void GrpcPayloadContainer::SetCachedSize(int size) const {
240 _cached_size_.Set(size);
241}
242const GrpcPayloadContainer& GrpcPayloadContainer::default_instance() {
243 ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_GrpcPayloadContainer_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.base);
244 return *internal_default_instance();
245}
246
247
248void GrpcPayloadContainer::Clear() {
249// @@protoc_insertion_point(message_clear_start:tensorflow.distributed_runtime.GrpcPayloadContainer)
250 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
251 // Prevent compiler warnings about cached_has_bits being unused
252 (void) cached_has_bits;
253
254 payloads_.Clear();
255 _internal_metadata_.Clear();
256}
257
258#if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
259const char* GrpcPayloadContainer::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) {
260#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
261 ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArenaNoVirtual(); (void)arena;
262 while (!ctx->Done(&ptr)) {
263 ::PROTOBUF_NAMESPACE_ID::uint32 tag;
264 ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag);
265 CHK_(ptr);
266 switch (tag >> 3) {
267 // map<string, bytes> payloads = 1;
268 case 1:
269 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
270 ptr -= 1;
271 do {
272 ptr += 1;
273 ptr = ctx->ParseMessage(&payloads_, ptr);
274 CHK_(ptr);
275 if (!ctx->DataAvailable(ptr)) break;
276 } while (::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<::PROTOBUF_NAMESPACE_ID::uint8>(ptr) == 10);
277 } else goto handle_unusual;
278 continue;
279 default: {
280 handle_unusual:
281 if ((tag & 7) == 4 || tag == 0) {
282 ctx->SetLastTag(tag);
283 goto success;
284 }
285 ptr = UnknownFieldParse(tag, &_internal_metadata_, ptr, ctx);
286 CHK_(ptr != nullptr);
287 continue;
288 }
289 } // switch
290 } // while
291success:
292 return ptr;
293failure:
294 ptr = nullptr;
295 goto success;
296#undef CHK_
297}
298#else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
299bool GrpcPayloadContainer::MergePartialFromCodedStream(
300 ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) {
301#define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure
302 ::PROTOBUF_NAMESPACE_ID::uint32 tag;
303 // @@protoc_insertion_point(parse_start:tensorflow.distributed_runtime.GrpcPayloadContainer)
304 for (;;) {
305 ::std::pair<::PROTOBUF_NAMESPACE_ID::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
306 tag = p.first;
307 if (!p.second) goto handle_unusual;
308 switch (::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::GetTagFieldNumber(tag)) {
309 // map<string, bytes> payloads = 1;
310 case 1: {
311 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (10 & 0xFF)) {
312 GrpcPayloadContainer_PayloadsEntry_DoNotUse::Parser< ::PROTOBUF_NAMESPACE_ID::internal::MapField<
313 GrpcPayloadContainer_PayloadsEntry_DoNotUse,
314 std::string, std::string,
315 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
316 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_BYTES,
317 0 >,
318 ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string > > parser(&payloads_);
319 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadMessageNoVirtual(
320 input, &parser));
321 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
322 parser.key().data(), static_cast<int>(parser.key().length()),
323 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE,
324 "tensorflow.distributed_runtime.GrpcPayloadContainer.PayloadsEntry.key"));
325 } else {
326 goto handle_unusual;
327 }
328 break;
329 }
330
331 default: {
332 handle_unusual:
333 if (tag == 0) {
334 goto success;
335 }
336 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SkipField(
337 input, tag, _internal_metadata_.mutable_unknown_fields()));
338 break;
339 }
340 }
341 }
342success:
343 // @@protoc_insertion_point(parse_success:tensorflow.distributed_runtime.GrpcPayloadContainer)
344 return true;
345failure:
346 // @@protoc_insertion_point(parse_failure:tensorflow.distributed_runtime.GrpcPayloadContainer)
347 return false;
348#undef DO_
349}
350#endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
351
352void GrpcPayloadContainer::SerializeWithCachedSizes(
353 ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const {
354 // @@protoc_insertion_point(serialize_start:tensorflow.distributed_runtime.GrpcPayloadContainer)
355 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
356 (void) cached_has_bits;
357
358 // map<string, bytes> payloads = 1;
359 if (!this->payloads().empty()) {
360 typedef ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_pointer
361 ConstPtr;
362 typedef ConstPtr SortItem;
363 typedef ::PROTOBUF_NAMESPACE_ID::internal::CompareByDerefFirst<SortItem> Less;
364 struct Utf8Check {
365 static void Check(ConstPtr p) {
366 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
367 p->first.data(), static_cast<int>(p->first.length()),
368 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
369 "tensorflow.distributed_runtime.GrpcPayloadContainer.PayloadsEntry.key");
370 }
371 };
372
373 if (output->IsSerializationDeterministic() &&
374 this->payloads().size() > 1) {
375 ::std::unique_ptr<SortItem[]> items(
376 new SortItem[this->payloads().size()]);
377 typedef ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::size_type size_type;
378 size_type n = 0;
379 for (::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_iterator
380 it = this->payloads().begin();
381 it != this->payloads().end(); ++it, ++n) {
382 items[static_cast<ptrdiff_t>(n)] = SortItem(&*it);
383 }
384 ::std::sort(&items[0], &items[static_cast<ptrdiff_t>(n)], Less());
385 for (size_type i = 0; i < n; i++) {
386 GrpcPayloadContainer_PayloadsEntry_DoNotUse::Funcs::SerializeToCodedStream(1, items[static_cast<ptrdiff_t>(i)]->first, items[static_cast<ptrdiff_t>(i)]->second, output);
387 Utf8Check::Check(&(*items[static_cast<ptrdiff_t>(i)]));
388 }
389 } else {
390 for (::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_iterator
391 it = this->payloads().begin();
392 it != this->payloads().end(); ++it) {
393 GrpcPayloadContainer_PayloadsEntry_DoNotUse::Funcs::SerializeToCodedStream(1, it->first, it->second, output);
394 Utf8Check::Check(&(*it));
395 }
396 }
397 }
398
399 if (_internal_metadata_.have_unknown_fields()) {
400 ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields(
401 _internal_metadata_.unknown_fields(), output);
402 }
403 // @@protoc_insertion_point(serialize_end:tensorflow.distributed_runtime.GrpcPayloadContainer)
404}
405
406::PROTOBUF_NAMESPACE_ID::uint8* GrpcPayloadContainer::InternalSerializeWithCachedSizesToArray(
407 ::PROTOBUF_NAMESPACE_ID::uint8* target) const {
408 // @@protoc_insertion_point(serialize_to_array_start:tensorflow.distributed_runtime.GrpcPayloadContainer)
409 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
410 (void) cached_has_bits;
411
412 // map<string, bytes> payloads = 1;
413 if (!this->payloads().empty()) {
414 typedef ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_pointer
415 ConstPtr;
416 typedef ConstPtr SortItem;
417 typedef ::PROTOBUF_NAMESPACE_ID::internal::CompareByDerefFirst<SortItem> Less;
418 struct Utf8Check {
419 static void Check(ConstPtr p) {
420 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
421 p->first.data(), static_cast<int>(p->first.length()),
422 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
423 "tensorflow.distributed_runtime.GrpcPayloadContainer.PayloadsEntry.key");
424 }
425 };
426
427 if (false &&
428 this->payloads().size() > 1) {
429 ::std::unique_ptr<SortItem[]> items(
430 new SortItem[this->payloads().size()]);
431 typedef ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::size_type size_type;
432 size_type n = 0;
433 for (::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_iterator
434 it = this->payloads().begin();
435 it != this->payloads().end(); ++it, ++n) {
436 items[static_cast<ptrdiff_t>(n)] = SortItem(&*it);
437 }
438 ::std::sort(&items[0], &items[static_cast<ptrdiff_t>(n)], Less());
439 for (size_type i = 0; i < n; i++) {
440 target = GrpcPayloadContainer_PayloadsEntry_DoNotUse::Funcs::SerializeToArray(1, items[static_cast<ptrdiff_t>(i)]->first, items[static_cast<ptrdiff_t>(i)]->second, target);
441 Utf8Check::Check(&(*items[static_cast<ptrdiff_t>(i)]));
442 }
443 } else {
444 for (::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_iterator
445 it = this->payloads().begin();
446 it != this->payloads().end(); ++it) {
447 target = GrpcPayloadContainer_PayloadsEntry_DoNotUse::Funcs::SerializeToArray(1, it->first, it->second, target);
448 Utf8Check::Check(&(*it));
449 }
450 }
451 }
452
453 if (_internal_metadata_.have_unknown_fields()) {
454 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray(
455 _internal_metadata_.unknown_fields(), target);
456 }
457 // @@protoc_insertion_point(serialize_to_array_end:tensorflow.distributed_runtime.GrpcPayloadContainer)
458 return target;
459}
460
461size_t GrpcPayloadContainer::ByteSizeLong() const {
462// @@protoc_insertion_point(message_byte_size_start:tensorflow.distributed_runtime.GrpcPayloadContainer)
463 size_t total_size = 0;
464
465 if (_internal_metadata_.have_unknown_fields()) {
466 total_size +=
467 ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::ComputeUnknownFieldsSize(
468 _internal_metadata_.unknown_fields());
469 }
470 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
471 // Prevent compiler warnings about cached_has_bits being unused
472 (void) cached_has_bits;
473
474 // map<string, bytes> payloads = 1;
475 total_size += 1 *
476 ::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(this->payloads_size());
477 for (::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_iterator
478 it = this->payloads().begin();
479 it != this->payloads().end(); ++it) {
480 total_size += GrpcPayloadContainer_PayloadsEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second);
481 }
482
483 int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
484 SetCachedSize(cached_size);
485 return total_size;
486}
487
488void GrpcPayloadContainer::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
489// @@protoc_insertion_point(generalized_merge_from_start:tensorflow.distributed_runtime.GrpcPayloadContainer)
490 GOOGLE_DCHECK_NE(&from, this);
491 const GrpcPayloadContainer* source =
492 ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated<GrpcPayloadContainer>(
493 &from);
494 if (source == nullptr) {
495 // @@protoc_insertion_point(generalized_merge_from_cast_fail:tensorflow.distributed_runtime.GrpcPayloadContainer)
496 ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this);
497 } else {
498 // @@protoc_insertion_point(generalized_merge_from_cast_success:tensorflow.distributed_runtime.GrpcPayloadContainer)
499 MergeFrom(*source);
500 }
501}
502
503void GrpcPayloadContainer::MergeFrom(const GrpcPayloadContainer& from) {
504// @@protoc_insertion_point(class_specific_merge_from_start:tensorflow.distributed_runtime.GrpcPayloadContainer)
505 GOOGLE_DCHECK_NE(&from, this);
506 _internal_metadata_.MergeFrom(from._internal_metadata_);
507 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
508 (void) cached_has_bits;
509
510 payloads_.MergeFrom(from.payloads_);
511}
512
513void GrpcPayloadContainer::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
514// @@protoc_insertion_point(generalized_copy_from_start:tensorflow.distributed_runtime.GrpcPayloadContainer)
515 if (&from == this) return;
516 Clear();
517 MergeFrom(from);
518}
519
520void GrpcPayloadContainer::CopyFrom(const GrpcPayloadContainer& from) {
521// @@protoc_insertion_point(class_specific_copy_from_start:tensorflow.distributed_runtime.GrpcPayloadContainer)
522 if (&from == this) return;
523 Clear();
524 MergeFrom(from);
525}
526
527bool GrpcPayloadContainer::IsInitialized() const {
528 return true;
529}
530
531void GrpcPayloadContainer::InternalSwap(GrpcPayloadContainer* other) {
532 using std::swap;
533 _internal_metadata_.Swap(&other->_internal_metadata_);
534 payloads_.Swap(&other->payloads_);
535}
536
537::PROTOBUF_NAMESPACE_ID::Metadata GrpcPayloadContainer::GetMetadata() const {
538 return GetMetadataStatic();
539}
540
541
542// ===================================================================
543
544void GrpcPayloadsLost::InitAsDefaultInstance() {
545}
546class GrpcPayloadsLost::_Internal {
547 public:
548};
549
550GrpcPayloadsLost::GrpcPayloadsLost()
551 : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) {
552 SharedCtor();
553 // @@protoc_insertion_point(constructor:tensorflow.distributed_runtime.GrpcPayloadsLost)
554}
555GrpcPayloadsLost::GrpcPayloadsLost(::PROTOBUF_NAMESPACE_ID::Arena* arena)
556 : ::PROTOBUF_NAMESPACE_ID::Message(),
557 _internal_metadata_(arena) {
558 SharedCtor();
559 RegisterArenaDtor(arena);
560 // @@protoc_insertion_point(arena_constructor:tensorflow.distributed_runtime.GrpcPayloadsLost)
561}
562GrpcPayloadsLost::GrpcPayloadsLost(const GrpcPayloadsLost& from)
563 : ::PROTOBUF_NAMESPACE_ID::Message(),
564 _internal_metadata_(nullptr) {
565 _internal_metadata_.MergeFrom(from._internal_metadata_);
566 // @@protoc_insertion_point(copy_constructor:tensorflow.distributed_runtime.GrpcPayloadsLost)
567}
568
569void GrpcPayloadsLost::SharedCtor() {
570}
571
572GrpcPayloadsLost::~GrpcPayloadsLost() {
573 // @@protoc_insertion_point(destructor:tensorflow.distributed_runtime.GrpcPayloadsLost)
574 SharedDtor();
575}
576
577void GrpcPayloadsLost::SharedDtor() {
578 GOOGLE_DCHECK(GetArenaNoVirtual() == nullptr);
579}
580
581void GrpcPayloadsLost::ArenaDtor(void* object) {
582 GrpcPayloadsLost* _this = reinterpret_cast< GrpcPayloadsLost* >(object);
583 (void)_this;
584}
585void GrpcPayloadsLost::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) {
586}
587void GrpcPayloadsLost::SetCachedSize(int size) const {
588 _cached_size_.Set(size);
589}
590const GrpcPayloadsLost& GrpcPayloadsLost::default_instance() {
591 ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_GrpcPayloadsLost_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.base);
592 return *internal_default_instance();
593}
594
595
596void GrpcPayloadsLost::Clear() {
597// @@protoc_insertion_point(message_clear_start:tensorflow.distributed_runtime.GrpcPayloadsLost)
598 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
599 // Prevent compiler warnings about cached_has_bits being unused
600 (void) cached_has_bits;
601
602 _internal_metadata_.Clear();
603}
604
605#if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
606const char* GrpcPayloadsLost::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) {
607#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
608 ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArenaNoVirtual(); (void)arena;
609 while (!ctx->Done(&ptr)) {
610 ::PROTOBUF_NAMESPACE_ID::uint32 tag;
611 ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag);
612 CHK_(ptr);
613 switch (tag >> 3) {
614 default: {
615 if ((tag & 7) == 4 || tag == 0) {
616 ctx->SetLastTag(tag);
617 goto success;
618 }
619 ptr = UnknownFieldParse(tag, &_internal_metadata_, ptr, ctx);
620 CHK_(ptr != nullptr);
621 continue;
622 }
623 } // switch
624 } // while
625success:
626 return ptr;
627failure:
628 ptr = nullptr;
629 goto success;
630#undef CHK_
631}
632#else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
633bool GrpcPayloadsLost::MergePartialFromCodedStream(
634 ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) {
635#define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure
636 ::PROTOBUF_NAMESPACE_ID::uint32 tag;
637 // @@protoc_insertion_point(parse_start:tensorflow.distributed_runtime.GrpcPayloadsLost)
638 for (;;) {
639 ::std::pair<::PROTOBUF_NAMESPACE_ID::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
640 tag = p.first;
641 if (!p.second) goto handle_unusual;
642 handle_unusual:
643 if (tag == 0) {
644 goto success;
645 }
646 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SkipField(
647 input, tag, _internal_metadata_.mutable_unknown_fields()));
648 }
649success:
650 // @@protoc_insertion_point(parse_success:tensorflow.distributed_runtime.GrpcPayloadsLost)
651 return true;
652failure:
653 // @@protoc_insertion_point(parse_failure:tensorflow.distributed_runtime.GrpcPayloadsLost)
654 return false;
655#undef DO_
656}
657#endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
658
659void GrpcPayloadsLost::SerializeWithCachedSizes(
660 ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const {
661 // @@protoc_insertion_point(serialize_start:tensorflow.distributed_runtime.GrpcPayloadsLost)
662 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
663 (void) cached_has_bits;
664
665 if (_internal_metadata_.have_unknown_fields()) {
666 ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields(
667 _internal_metadata_.unknown_fields(), output);
668 }
669 // @@protoc_insertion_point(serialize_end:tensorflow.distributed_runtime.GrpcPayloadsLost)
670}
671
672::PROTOBUF_NAMESPACE_ID::uint8* GrpcPayloadsLost::InternalSerializeWithCachedSizesToArray(
673 ::PROTOBUF_NAMESPACE_ID::uint8* target) const {
674 // @@protoc_insertion_point(serialize_to_array_start:tensorflow.distributed_runtime.GrpcPayloadsLost)
675 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
676 (void) cached_has_bits;
677
678 if (_internal_metadata_.have_unknown_fields()) {
679 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray(
680 _internal_metadata_.unknown_fields(), target);
681 }
682 // @@protoc_insertion_point(serialize_to_array_end:tensorflow.distributed_runtime.GrpcPayloadsLost)
683 return target;
684}
685
686size_t GrpcPayloadsLost::ByteSizeLong() const {
687// @@protoc_insertion_point(message_byte_size_start:tensorflow.distributed_runtime.GrpcPayloadsLost)
688 size_t total_size = 0;
689
690 if (_internal_metadata_.have_unknown_fields()) {
691 total_size +=
692 ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::ComputeUnknownFieldsSize(
693 _internal_metadata_.unknown_fields());
694 }
695 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
696 // Prevent compiler warnings about cached_has_bits being unused
697 (void) cached_has_bits;
698
699 int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
700 SetCachedSize(cached_size);
701 return total_size;
702}
703
704void GrpcPayloadsLost::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
705// @@protoc_insertion_point(generalized_merge_from_start:tensorflow.distributed_runtime.GrpcPayloadsLost)
706 GOOGLE_DCHECK_NE(&from, this);
707 const GrpcPayloadsLost* source =
708 ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated<GrpcPayloadsLost>(
709 &from);
710 if (source == nullptr) {
711 // @@protoc_insertion_point(generalized_merge_from_cast_fail:tensorflow.distributed_runtime.GrpcPayloadsLost)
712 ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this);
713 } else {
714 // @@protoc_insertion_point(generalized_merge_from_cast_success:tensorflow.distributed_runtime.GrpcPayloadsLost)
715 MergeFrom(*source);
716 }
717}
718
719void GrpcPayloadsLost::MergeFrom(const GrpcPayloadsLost& from) {
720// @@protoc_insertion_point(class_specific_merge_from_start:tensorflow.distributed_runtime.GrpcPayloadsLost)
721 GOOGLE_DCHECK_NE(&from, this);
722 _internal_metadata_.MergeFrom(from._internal_metadata_);
723 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
724 (void) cached_has_bits;
725
726}
727
728void GrpcPayloadsLost::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
729// @@protoc_insertion_point(generalized_copy_from_start:tensorflow.distributed_runtime.GrpcPayloadsLost)
730 if (&from == this) return;
731 Clear();
732 MergeFrom(from);
733}
734
735void GrpcPayloadsLost::CopyFrom(const GrpcPayloadsLost& from) {
736// @@protoc_insertion_point(class_specific_copy_from_start:tensorflow.distributed_runtime.GrpcPayloadsLost)
737 if (&from == this) return;
738 Clear();
739 MergeFrom(from);
740}
741
742bool GrpcPayloadsLost::IsInitialized() const {
743 return true;
744}
745
746void GrpcPayloadsLost::InternalSwap(GrpcPayloadsLost* other) {
747 using std::swap;
748 _internal_metadata_.Swap(&other->_internal_metadata_);
749}
750
751::PROTOBUF_NAMESPACE_ID::Metadata GrpcPayloadsLost::GetMetadata() const {
752 return GetMetadataStatic();
753}
754
755
756// ===================================================================
757
758void WorkerPossiblyRestarted::InitAsDefaultInstance() {
759}
760class WorkerPossiblyRestarted::_Internal {
761 public:
762};
763
764WorkerPossiblyRestarted::WorkerPossiblyRestarted()
765 : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) {
766 SharedCtor();
767 // @@protoc_insertion_point(constructor:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
768}
769WorkerPossiblyRestarted::WorkerPossiblyRestarted(::PROTOBUF_NAMESPACE_ID::Arena* arena)
770 : ::PROTOBUF_NAMESPACE_ID::Message(),
771 _internal_metadata_(arena) {
772 SharedCtor();
773 RegisterArenaDtor(arena);
774 // @@protoc_insertion_point(arena_constructor:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
775}
776WorkerPossiblyRestarted::WorkerPossiblyRestarted(const WorkerPossiblyRestarted& from)
777 : ::PROTOBUF_NAMESPACE_ID::Message(),
778 _internal_metadata_(nullptr) {
779 _internal_metadata_.MergeFrom(from._internal_metadata_);
780 // @@protoc_insertion_point(copy_constructor:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
781}
782
783void WorkerPossiblyRestarted::SharedCtor() {
784}
785
786WorkerPossiblyRestarted::~WorkerPossiblyRestarted() {
787 // @@protoc_insertion_point(destructor:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
788 SharedDtor();
789}
790
791void WorkerPossiblyRestarted::SharedDtor() {
792 GOOGLE_DCHECK(GetArenaNoVirtual() == nullptr);
793}
794
795void WorkerPossiblyRestarted::ArenaDtor(void* object) {
796 WorkerPossiblyRestarted* _this = reinterpret_cast< WorkerPossiblyRestarted* >(object);
797 (void)_this;
798}
799void WorkerPossiblyRestarted::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) {
800}
801void WorkerPossiblyRestarted::SetCachedSize(int size) const {
802 _cached_size_.Set(size);
803}
804const WorkerPossiblyRestarted& WorkerPossiblyRestarted::default_instance() {
805 ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_WorkerPossiblyRestarted_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.base);
806 return *internal_default_instance();
807}
808
809
810void WorkerPossiblyRestarted::Clear() {
811// @@protoc_insertion_point(message_clear_start:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
812 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
813 // Prevent compiler warnings about cached_has_bits being unused
814 (void) cached_has_bits;
815
816 _internal_metadata_.Clear();
817}
818
819#if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
820const char* WorkerPossiblyRestarted::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) {
821#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
822 ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArenaNoVirtual(); (void)arena;
823 while (!ctx->Done(&ptr)) {
824 ::PROTOBUF_NAMESPACE_ID::uint32 tag;
825 ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag);
826 CHK_(ptr);
827 switch (tag >> 3) {
828 default: {
829 if ((tag & 7) == 4 || tag == 0) {
830 ctx->SetLastTag(tag);
831 goto success;
832 }
833 ptr = UnknownFieldParse(tag, &_internal_metadata_, ptr, ctx);
834 CHK_(ptr != nullptr);
835 continue;
836 }
837 } // switch
838 } // while
839success:
840 return ptr;
841failure:
842 ptr = nullptr;
843 goto success;
844#undef CHK_
845}
846#else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
847bool WorkerPossiblyRestarted::MergePartialFromCodedStream(
848 ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) {
849#define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure
850 ::PROTOBUF_NAMESPACE_ID::uint32 tag;
851 // @@protoc_insertion_point(parse_start:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
852 for (;;) {
853 ::std::pair<::PROTOBUF_NAMESPACE_ID::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
854 tag = p.first;
855 if (!p.second) goto handle_unusual;
856 handle_unusual:
857 if (tag == 0) {
858 goto success;
859 }
860 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SkipField(
861 input, tag, _internal_metadata_.mutable_unknown_fields()));
862 }
863success:
864 // @@protoc_insertion_point(parse_success:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
865 return true;
866failure:
867 // @@protoc_insertion_point(parse_failure:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
868 return false;
869#undef DO_
870}
871#endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
872
873void WorkerPossiblyRestarted::SerializeWithCachedSizes(
874 ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const {
875 // @@protoc_insertion_point(serialize_start:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
876 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
877 (void) cached_has_bits;
878
879 if (_internal_metadata_.have_unknown_fields()) {
880 ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields(
881 _internal_metadata_.unknown_fields(), output);
882 }
883 // @@protoc_insertion_point(serialize_end:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
884}
885
886::PROTOBUF_NAMESPACE_ID::uint8* WorkerPossiblyRestarted::InternalSerializeWithCachedSizesToArray(
887 ::PROTOBUF_NAMESPACE_ID::uint8* target) const {
888 // @@protoc_insertion_point(serialize_to_array_start:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
889 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
890 (void) cached_has_bits;
891
892 if (_internal_metadata_.have_unknown_fields()) {
893 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray(
894 _internal_metadata_.unknown_fields(), target);
895 }
896 // @@protoc_insertion_point(serialize_to_array_end:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
897 return target;
898}
899
900size_t WorkerPossiblyRestarted::ByteSizeLong() const {
901// @@protoc_insertion_point(message_byte_size_start:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
902 size_t total_size = 0;
903
904 if (_internal_metadata_.have_unknown_fields()) {
905 total_size +=
906 ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::ComputeUnknownFieldsSize(
907 _internal_metadata_.unknown_fields());
908 }
909 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
910 // Prevent compiler warnings about cached_has_bits being unused
911 (void) cached_has_bits;
912
913 int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
914 SetCachedSize(cached_size);
915 return total_size;
916}
917
918void WorkerPossiblyRestarted::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
919// @@protoc_insertion_point(generalized_merge_from_start:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
920 GOOGLE_DCHECK_NE(&from, this);
921 const WorkerPossiblyRestarted* source =
922 ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated<WorkerPossiblyRestarted>(
923 &from);
924 if (source == nullptr) {
925 // @@protoc_insertion_point(generalized_merge_from_cast_fail:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
926 ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this);
927 } else {
928 // @@protoc_insertion_point(generalized_merge_from_cast_success:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
929 MergeFrom(*source);
930 }
931}
932
933void WorkerPossiblyRestarted::MergeFrom(const WorkerPossiblyRestarted& from) {
934// @@protoc_insertion_point(class_specific_merge_from_start:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
935 GOOGLE_DCHECK_NE(&from, this);
936 _internal_metadata_.MergeFrom(from._internal_metadata_);
937 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
938 (void) cached_has_bits;
939
940}
941
942void WorkerPossiblyRestarted::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
943// @@protoc_insertion_point(generalized_copy_from_start:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
944 if (&from == this) return;
945 Clear();
946 MergeFrom(from);
947}
948
949void WorkerPossiblyRestarted::CopyFrom(const WorkerPossiblyRestarted& from) {
950// @@protoc_insertion_point(class_specific_copy_from_start:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
951 if (&from == this) return;
952 Clear();
953 MergeFrom(from);
954}
955
956bool WorkerPossiblyRestarted::IsInitialized() const {
957 return true;
958}
959
960void WorkerPossiblyRestarted::InternalSwap(WorkerPossiblyRestarted* other) {
961 using std::swap;
962 _internal_metadata_.Swap(&other->_internal_metadata_);
963}
964
965::PROTOBUF_NAMESPACE_ID::Metadata WorkerPossiblyRestarted::GetMetadata() const {
966 return GetMetadataStatic();
967}
968
969
970// @@protoc_insertion_point(namespace_scope)
971} // namespace distributed_runtime
972} // namespace tensorflow
973PROTOBUF_NAMESPACE_OPEN
974template<> PROTOBUF_NOINLINE ::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse* Arena::CreateMaybeMessage< ::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse >(Arena* arena) {
975 return Arena::CreateMessageInternal< ::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse >(arena);
976}
977template<> PROTOBUF_NOINLINE ::tensorflow::distributed_runtime::GrpcPayloadContainer* Arena::CreateMaybeMessage< ::tensorflow::distributed_runtime::GrpcPayloadContainer >(Arena* arena) {
978 return Arena::CreateMessageInternal< ::tensorflow::distributed_runtime::GrpcPayloadContainer >(arena);
979}
980template<> PROTOBUF_NOINLINE ::tensorflow::distributed_runtime::GrpcPayloadsLost* Arena::CreateMaybeMessage< ::tensorflow::distributed_runtime::GrpcPayloadsLost >(Arena* arena) {
981 return Arena::CreateMessageInternal< ::tensorflow::distributed_runtime::GrpcPayloadsLost >(arena);
982}
983template<> PROTOBUF_NOINLINE ::tensorflow::distributed_runtime::WorkerPossiblyRestarted* Arena::CreateMaybeMessage< ::tensorflow::distributed_runtime::WorkerPossiblyRestarted >(Arena* arena) {
984 return Arena::CreateMessageInternal< ::tensorflow::distributed_runtime::WorkerPossiblyRestarted >(arena);
985}
986PROTOBUF_NAMESPACE_CLOSE
987
988// @@protoc_insertion_point(global_scope)
989#include <google/protobuf/port_undef.inc>
990