1// Generated by the protocol buffer compiler. DO NOT EDIT!
2// source: tensorflow/core/protobuf/distributed_runtime_payloads.proto
3
4#ifndef GOOGLE_PROTOBUF_INCLUDED_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto
5#define GOOGLE_PROTOBUF_INCLUDED_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto
6
7#include <limits>
8#include <string>
9
10#include <google/protobuf/port_def.inc>
11#if PROTOBUF_VERSION < 3009000
12#error This file was generated by a newer version of protoc which is
13#error incompatible with your Protocol Buffer headers. Please update
14#error your headers.
15#endif
16#if 3009002 < PROTOBUF_MIN_PROTOC_VERSION
17#error This file was generated by an older version of protoc which is
18#error incompatible with your Protocol Buffer headers. Please
19#error regenerate this file with a newer version of protoc.
20#endif
21
22#include <google/protobuf/port_undef.inc>
23#include <google/protobuf/io/coded_stream.h>
24#include <google/protobuf/arena.h>
25#include <google/protobuf/arenastring.h>
26#include <google/protobuf/generated_message_table_driven.h>
27#include <google/protobuf/generated_message_util.h>
28#include <google/protobuf/inlined_string_field.h>
29#include <google/protobuf/metadata.h>
30#include <google/protobuf/generated_message_reflection.h>
31#include <google/protobuf/message.h>
32#include <google/protobuf/repeated_field.h> // IWYU pragma: export
33#include <google/protobuf/extension_set.h> // IWYU pragma: export
34#include <google/protobuf/map.h> // IWYU pragma: export
35#include <google/protobuf/map_entry.h>
36#include <google/protobuf/map_field_inl.h>
37#include <google/protobuf/unknown_field_set.h>
38// @@protoc_insertion_point(includes)
39#include <google/protobuf/port_def.inc>
40#define PROTOBUF_INTERNAL_EXPORT_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto
41PROTOBUF_NAMESPACE_OPEN
42namespace internal {
43class AnyMetadata;
44} // namespace internal
45PROTOBUF_NAMESPACE_CLOSE
46
47// Internal implementation detail -- do not use these members.
48struct TableStruct_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto {
49 static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTableField entries[]
50 PROTOBUF_SECTION_VARIABLE(protodesc_cold);
51 static const ::PROTOBUF_NAMESPACE_ID::internal::AuxillaryParseTableField aux[]
52 PROTOBUF_SECTION_VARIABLE(protodesc_cold);
53 static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTable schema[4]
54 PROTOBUF_SECTION_VARIABLE(protodesc_cold);
55 static const ::PROTOBUF_NAMESPACE_ID::internal::FieldMetadata field_metadata[];
56 static const ::PROTOBUF_NAMESPACE_ID::internal::SerializationTable serialization_table[];
57 static const ::PROTOBUF_NAMESPACE_ID::uint32 offsets[];
58};
59extern const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto;
60namespace tensorflow {
61namespace distributed_runtime {
62class GrpcPayloadContainer;
63class GrpcPayloadContainerDefaultTypeInternal;
64extern GrpcPayloadContainerDefaultTypeInternal _GrpcPayloadContainer_default_instance_;
65class GrpcPayloadContainer_PayloadsEntry_DoNotUse;
66class GrpcPayloadContainer_PayloadsEntry_DoNotUseDefaultTypeInternal;
67extern GrpcPayloadContainer_PayloadsEntry_DoNotUseDefaultTypeInternal _GrpcPayloadContainer_PayloadsEntry_DoNotUse_default_instance_;
68class GrpcPayloadsLost;
69class GrpcPayloadsLostDefaultTypeInternal;
70extern GrpcPayloadsLostDefaultTypeInternal _GrpcPayloadsLost_default_instance_;
71class WorkerPossiblyRestarted;
72class WorkerPossiblyRestartedDefaultTypeInternal;
73extern WorkerPossiblyRestartedDefaultTypeInternal _WorkerPossiblyRestarted_default_instance_;
74} // namespace distributed_runtime
75} // namespace tensorflow
76PROTOBUF_NAMESPACE_OPEN
77template<> ::tensorflow::distributed_runtime::GrpcPayloadContainer* Arena::CreateMaybeMessage<::tensorflow::distributed_runtime::GrpcPayloadContainer>(Arena*);
78template<> ::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse* Arena::CreateMaybeMessage<::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse>(Arena*);
79template<> ::tensorflow::distributed_runtime::GrpcPayloadsLost* Arena::CreateMaybeMessage<::tensorflow::distributed_runtime::GrpcPayloadsLost>(Arena*);
80template<> ::tensorflow::distributed_runtime::WorkerPossiblyRestarted* Arena::CreateMaybeMessage<::tensorflow::distributed_runtime::WorkerPossiblyRestarted>(Arena*);
81PROTOBUF_NAMESPACE_CLOSE
82namespace tensorflow {
83namespace distributed_runtime {
84
85// ===================================================================
86
87class GrpcPayloadContainer_PayloadsEntry_DoNotUse : public ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<GrpcPayloadContainer_PayloadsEntry_DoNotUse,
88 std::string, std::string,
89 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
90 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_BYTES,
91 0 > {
92public:
93 typedef ::PROTOBUF_NAMESPACE_ID::internal::MapEntry<GrpcPayloadContainer_PayloadsEntry_DoNotUse,
94 std::string, std::string,
95 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
96 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_BYTES,
97 0 > SuperType;
98 GrpcPayloadContainer_PayloadsEntry_DoNotUse();
99 GrpcPayloadContainer_PayloadsEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena);
100 void MergeFrom(const GrpcPayloadContainer_PayloadsEntry_DoNotUse& other);
101 static const GrpcPayloadContainer_PayloadsEntry_DoNotUse* internal_default_instance() { return reinterpret_cast<const GrpcPayloadContainer_PayloadsEntry_DoNotUse*>(&_GrpcPayloadContainer_PayloadsEntry_DoNotUse_default_instance_); }
102 static bool ValidateKey(std::string* s) {
103 return ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(s->data(), s->size(), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "tensorflow.distributed_runtime.GrpcPayloadContainer.PayloadsEntry.key");
104 }
105 static bool ValidateValue(void*) { return true; }
106 void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& other) final;
107 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
108 private:
109 static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
110 ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto);
111 return ::descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.file_level_metadata[0];
112 }
113
114 public:
115};
116
117// -------------------------------------------------------------------
118
119class GrpcPayloadContainer :
120 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tensorflow.distributed_runtime.GrpcPayloadContainer) */ {
121 public:
122 GrpcPayloadContainer();
123 virtual ~GrpcPayloadContainer();
124
125 GrpcPayloadContainer(const GrpcPayloadContainer& from);
126 GrpcPayloadContainer(GrpcPayloadContainer&& from) noexcept
127 : GrpcPayloadContainer() {
128 *this = ::std::move(from);
129 }
130
131 inline GrpcPayloadContainer& operator=(const GrpcPayloadContainer& from) {
132 CopyFrom(from);
133 return *this;
134 }
135 inline GrpcPayloadContainer& operator=(GrpcPayloadContainer&& from) noexcept {
136 if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {
137 if (this != &from) InternalSwap(&from);
138 } else {
139 CopyFrom(from);
140 }
141 return *this;
142 }
143
144 inline ::PROTOBUF_NAMESPACE_ID::Arena* GetArena() const final {
145 return GetArenaNoVirtual();
146 }
147 inline void* GetMaybeArenaPointer() const final {
148 return MaybeArenaPtr();
149 }
150 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
151 return GetDescriptor();
152 }
153 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
154 return GetMetadataStatic().descriptor;
155 }
156 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
157 return GetMetadataStatic().reflection;
158 }
159 static const GrpcPayloadContainer& default_instance();
160
161 static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
162 static inline const GrpcPayloadContainer* internal_default_instance() {
163 return reinterpret_cast<const GrpcPayloadContainer*>(
164 &_GrpcPayloadContainer_default_instance_);
165 }
166 static constexpr int kIndexInFileMessages =
167 1;
168
169 friend void swap(GrpcPayloadContainer& a, GrpcPayloadContainer& b) {
170 a.Swap(&b);
171 }
172 inline void Swap(GrpcPayloadContainer* other) {
173 if (other == this) return;
174 if (GetArenaNoVirtual() == other->GetArenaNoVirtual()) {
175 InternalSwap(other);
176 } else {
177 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
178 }
179 }
180 void UnsafeArenaSwap(GrpcPayloadContainer* other) {
181 if (other == this) return;
182 GOOGLE_DCHECK(GetArenaNoVirtual() == other->GetArenaNoVirtual());
183 InternalSwap(other);
184 }
185
186 // implements Message ----------------------------------------------
187
188 inline GrpcPayloadContainer* New() const final {
189 return CreateMaybeMessage<GrpcPayloadContainer>(nullptr);
190 }
191
192 GrpcPayloadContainer* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
193 return CreateMaybeMessage<GrpcPayloadContainer>(arena);
194 }
195 void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
196 void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
197 void CopyFrom(const GrpcPayloadContainer& from);
198 void MergeFrom(const GrpcPayloadContainer& from);
199 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
200 bool IsInitialized() const final;
201
202 size_t ByteSizeLong() const final;
203 #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
204 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
205 #else
206 bool MergePartialFromCodedStream(
207 ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) final;
208 #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
209 void SerializeWithCachedSizes(
210 ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const final;
211 ::PROTOBUF_NAMESPACE_ID::uint8* InternalSerializeWithCachedSizesToArray(
212 ::PROTOBUF_NAMESPACE_ID::uint8* target) const final;
213 int GetCachedSize() const final { return _cached_size_.Get(); }
214
215 private:
216 inline void SharedCtor();
217 inline void SharedDtor();
218 void SetCachedSize(int size) const final;
219 void InternalSwap(GrpcPayloadContainer* other);
220 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
221 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
222 return "tensorflow.distributed_runtime.GrpcPayloadContainer";
223 }
224 protected:
225 explicit GrpcPayloadContainer(::PROTOBUF_NAMESPACE_ID::Arena* arena);
226 private:
227 static void ArenaDtor(void* object);
228 inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
229 private:
230 inline ::PROTOBUF_NAMESPACE_ID::Arena* GetArenaNoVirtual() const {
231 return _internal_metadata_.arena();
232 }
233 inline void* MaybeArenaPtr() const {
234 return _internal_metadata_.raw_arena_ptr();
235 }
236 public:
237
238 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
239 private:
240 static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
241 ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto);
242 return ::descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.file_level_metadata[kIndexInFileMessages];
243 }
244
245 public:
246
247 // nested types ----------------------------------------------------
248
249
250 // accessors -------------------------------------------------------
251
252 enum : int {
253 kPayloadsFieldNumber = 1,
254 };
255 // map<string, bytes> payloads = 1;
256 int payloads_size() const;
257 void clear_payloads();
258 const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
259 payloads() const;
260 ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
261 mutable_payloads();
262
263 // @@protoc_insertion_point(class_scope:tensorflow.distributed_runtime.GrpcPayloadContainer)
264 private:
265 class _Internal;
266
267 ::PROTOBUF_NAMESPACE_ID::internal::InternalMetadataWithArena _internal_metadata_;
268 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
269 typedef void InternalArenaConstructable_;
270 typedef void DestructorSkippable_;
271 ::PROTOBUF_NAMESPACE_ID::internal::MapField<
272 GrpcPayloadContainer_PayloadsEntry_DoNotUse,
273 std::string, std::string,
274 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING,
275 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_BYTES,
276 0 > payloads_;
277 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
278 friend struct ::TableStruct_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto;
279};
280// -------------------------------------------------------------------
281
282class GrpcPayloadsLost :
283 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tensorflow.distributed_runtime.GrpcPayloadsLost) */ {
284 public:
285 GrpcPayloadsLost();
286 virtual ~GrpcPayloadsLost();
287
288 GrpcPayloadsLost(const GrpcPayloadsLost& from);
289 GrpcPayloadsLost(GrpcPayloadsLost&& from) noexcept
290 : GrpcPayloadsLost() {
291 *this = ::std::move(from);
292 }
293
294 inline GrpcPayloadsLost& operator=(const GrpcPayloadsLost& from) {
295 CopyFrom(from);
296 return *this;
297 }
298 inline GrpcPayloadsLost& operator=(GrpcPayloadsLost&& from) noexcept {
299 if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {
300 if (this != &from) InternalSwap(&from);
301 } else {
302 CopyFrom(from);
303 }
304 return *this;
305 }
306
307 inline ::PROTOBUF_NAMESPACE_ID::Arena* GetArena() const final {
308 return GetArenaNoVirtual();
309 }
310 inline void* GetMaybeArenaPointer() const final {
311 return MaybeArenaPtr();
312 }
313 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
314 return GetDescriptor();
315 }
316 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
317 return GetMetadataStatic().descriptor;
318 }
319 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
320 return GetMetadataStatic().reflection;
321 }
322 static const GrpcPayloadsLost& default_instance();
323
324 static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
325 static inline const GrpcPayloadsLost* internal_default_instance() {
326 return reinterpret_cast<const GrpcPayloadsLost*>(
327 &_GrpcPayloadsLost_default_instance_);
328 }
329 static constexpr int kIndexInFileMessages =
330 2;
331
332 friend void swap(GrpcPayloadsLost& a, GrpcPayloadsLost& b) {
333 a.Swap(&b);
334 }
335 inline void Swap(GrpcPayloadsLost* other) {
336 if (other == this) return;
337 if (GetArenaNoVirtual() == other->GetArenaNoVirtual()) {
338 InternalSwap(other);
339 } else {
340 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
341 }
342 }
343 void UnsafeArenaSwap(GrpcPayloadsLost* other) {
344 if (other == this) return;
345 GOOGLE_DCHECK(GetArenaNoVirtual() == other->GetArenaNoVirtual());
346 InternalSwap(other);
347 }
348
349 // implements Message ----------------------------------------------
350
351 inline GrpcPayloadsLost* New() const final {
352 return CreateMaybeMessage<GrpcPayloadsLost>(nullptr);
353 }
354
355 GrpcPayloadsLost* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
356 return CreateMaybeMessage<GrpcPayloadsLost>(arena);
357 }
358 void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
359 void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
360 void CopyFrom(const GrpcPayloadsLost& from);
361 void MergeFrom(const GrpcPayloadsLost& from);
362 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
363 bool IsInitialized() const final;
364
365 size_t ByteSizeLong() const final;
366 #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
367 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
368 #else
369 bool MergePartialFromCodedStream(
370 ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) final;
371 #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
372 void SerializeWithCachedSizes(
373 ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const final;
374 ::PROTOBUF_NAMESPACE_ID::uint8* InternalSerializeWithCachedSizesToArray(
375 ::PROTOBUF_NAMESPACE_ID::uint8* target) const final;
376 int GetCachedSize() const final { return _cached_size_.Get(); }
377
378 private:
379 inline void SharedCtor();
380 inline void SharedDtor();
381 void SetCachedSize(int size) const final;
382 void InternalSwap(GrpcPayloadsLost* other);
383 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
384 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
385 return "tensorflow.distributed_runtime.GrpcPayloadsLost";
386 }
387 protected:
388 explicit GrpcPayloadsLost(::PROTOBUF_NAMESPACE_ID::Arena* arena);
389 private:
390 static void ArenaDtor(void* object);
391 inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
392 private:
393 inline ::PROTOBUF_NAMESPACE_ID::Arena* GetArenaNoVirtual() const {
394 return _internal_metadata_.arena();
395 }
396 inline void* MaybeArenaPtr() const {
397 return _internal_metadata_.raw_arena_ptr();
398 }
399 public:
400
401 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
402 private:
403 static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
404 ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto);
405 return ::descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.file_level_metadata[kIndexInFileMessages];
406 }
407
408 public:
409
410 // nested types ----------------------------------------------------
411
412 // accessors -------------------------------------------------------
413
414 // @@protoc_insertion_point(class_scope:tensorflow.distributed_runtime.GrpcPayloadsLost)
415 private:
416 class _Internal;
417
418 ::PROTOBUF_NAMESPACE_ID::internal::InternalMetadataWithArena _internal_metadata_;
419 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
420 typedef void InternalArenaConstructable_;
421 typedef void DestructorSkippable_;
422 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
423 friend struct ::TableStruct_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto;
424};
425// -------------------------------------------------------------------
426
427class WorkerPossiblyRestarted :
428 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tensorflow.distributed_runtime.WorkerPossiblyRestarted) */ {
429 public:
430 WorkerPossiblyRestarted();
431 virtual ~WorkerPossiblyRestarted();
432
433 WorkerPossiblyRestarted(const WorkerPossiblyRestarted& from);
434 WorkerPossiblyRestarted(WorkerPossiblyRestarted&& from) noexcept
435 : WorkerPossiblyRestarted() {
436 *this = ::std::move(from);
437 }
438
439 inline WorkerPossiblyRestarted& operator=(const WorkerPossiblyRestarted& from) {
440 CopyFrom(from);
441 return *this;
442 }
443 inline WorkerPossiblyRestarted& operator=(WorkerPossiblyRestarted&& from) noexcept {
444 if (GetArenaNoVirtual() == from.GetArenaNoVirtual()) {
445 if (this != &from) InternalSwap(&from);
446 } else {
447 CopyFrom(from);
448 }
449 return *this;
450 }
451
452 inline ::PROTOBUF_NAMESPACE_ID::Arena* GetArena() const final {
453 return GetArenaNoVirtual();
454 }
455 inline void* GetMaybeArenaPointer() const final {
456 return MaybeArenaPtr();
457 }
458 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
459 return GetDescriptor();
460 }
461 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
462 return GetMetadataStatic().descriptor;
463 }
464 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
465 return GetMetadataStatic().reflection;
466 }
467 static const WorkerPossiblyRestarted& default_instance();
468
469 static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
470 static inline const WorkerPossiblyRestarted* internal_default_instance() {
471 return reinterpret_cast<const WorkerPossiblyRestarted*>(
472 &_WorkerPossiblyRestarted_default_instance_);
473 }
474 static constexpr int kIndexInFileMessages =
475 3;
476
477 friend void swap(WorkerPossiblyRestarted& a, WorkerPossiblyRestarted& b) {
478 a.Swap(&b);
479 }
480 inline void Swap(WorkerPossiblyRestarted* other) {
481 if (other == this) return;
482 if (GetArenaNoVirtual() == other->GetArenaNoVirtual()) {
483 InternalSwap(other);
484 } else {
485 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
486 }
487 }
488 void UnsafeArenaSwap(WorkerPossiblyRestarted* other) {
489 if (other == this) return;
490 GOOGLE_DCHECK(GetArenaNoVirtual() == other->GetArenaNoVirtual());
491 InternalSwap(other);
492 }
493
494 // implements Message ----------------------------------------------
495
496 inline WorkerPossiblyRestarted* New() const final {
497 return CreateMaybeMessage<WorkerPossiblyRestarted>(nullptr);
498 }
499
500 WorkerPossiblyRestarted* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
501 return CreateMaybeMessage<WorkerPossiblyRestarted>(arena);
502 }
503 void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
504 void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
505 void CopyFrom(const WorkerPossiblyRestarted& from);
506 void MergeFrom(const WorkerPossiblyRestarted& from);
507 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
508 bool IsInitialized() const final;
509
510 size_t ByteSizeLong() const final;
511 #if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
512 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
513 #else
514 bool MergePartialFromCodedStream(
515 ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) final;
516 #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
517 void SerializeWithCachedSizes(
518 ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const final;
519 ::PROTOBUF_NAMESPACE_ID::uint8* InternalSerializeWithCachedSizesToArray(
520 ::PROTOBUF_NAMESPACE_ID::uint8* target) const final;
521 int GetCachedSize() const final { return _cached_size_.Get(); }
522
523 private:
524 inline void SharedCtor();
525 inline void SharedDtor();
526 void SetCachedSize(int size) const final;
527 void InternalSwap(WorkerPossiblyRestarted* other);
528 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
529 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
530 return "tensorflow.distributed_runtime.WorkerPossiblyRestarted";
531 }
532 protected:
533 explicit WorkerPossiblyRestarted(::PROTOBUF_NAMESPACE_ID::Arena* arena);
534 private:
535 static void ArenaDtor(void* object);
536 inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
537 private:
538 inline ::PROTOBUF_NAMESPACE_ID::Arena* GetArenaNoVirtual() const {
539 return _internal_metadata_.arena();
540 }
541 inline void* MaybeArenaPtr() const {
542 return _internal_metadata_.raw_arena_ptr();
543 }
544 public:
545
546 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
547 private:
548 static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
549 ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto);
550 return ::descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.file_level_metadata[kIndexInFileMessages];
551 }
552
553 public:
554
555 // nested types ----------------------------------------------------
556
557 // accessors -------------------------------------------------------
558
559 // @@protoc_insertion_point(class_scope:tensorflow.distributed_runtime.WorkerPossiblyRestarted)
560 private:
561 class _Internal;
562
563 ::PROTOBUF_NAMESPACE_ID::internal::InternalMetadataWithArena _internal_metadata_;
564 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
565 typedef void InternalArenaConstructable_;
566 typedef void DestructorSkippable_;
567 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
568 friend struct ::TableStruct_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto;
569};
570// ===================================================================
571
572
573// ===================================================================
574
575#ifdef __GNUC__
576 #pragma GCC diagnostic push
577 #pragma GCC diagnostic ignored "-Wstrict-aliasing"
578#endif // __GNUC__
579// -------------------------------------------------------------------
580
581// GrpcPayloadContainer
582
583// map<string, bytes> payloads = 1;
584inline int GrpcPayloadContainer::payloads_size() const {
585 return payloads_.size();
586}
587inline void GrpcPayloadContainer::clear_payloads() {
588 payloads_.Clear();
589}
590inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >&
591GrpcPayloadContainer::payloads() const {
592 // @@protoc_insertion_point(field_map:tensorflow.distributed_runtime.GrpcPayloadContainer.payloads)
593 return payloads_.GetMap();
594}
595inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >*
596GrpcPayloadContainer::mutable_payloads() {
597 // @@protoc_insertion_point(field_mutable_map:tensorflow.distributed_runtime.GrpcPayloadContainer.payloads)
598 return payloads_.MutableMap();
599}
600
601// -------------------------------------------------------------------
602
603// GrpcPayloadsLost
604
605// -------------------------------------------------------------------
606
607// WorkerPossiblyRestarted
608
609#ifdef __GNUC__
610 #pragma GCC diagnostic pop
611#endif // __GNUC__
612// -------------------------------------------------------------------
613
614// -------------------------------------------------------------------
615
616// -------------------------------------------------------------------
617
618
619// @@protoc_insertion_point(namespace_scope)
620
621} // namespace distributed_runtime
622} // namespace tensorflow
623
624// @@protoc_insertion_point(global_scope)
625
626#include <google/protobuf/port_undef.inc>
627#endif // GOOGLE_PROTOBUF_INCLUDED_GOOGLE_PROTOBUF_INCLUDED_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto
628