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 |
41 | PROTOBUF_NAMESPACE_OPEN |
42 | namespace internal { |
43 | class AnyMetadata; |
44 | } // namespace internal |
45 | PROTOBUF_NAMESPACE_CLOSE |
46 | |
47 | // Internal implementation detail -- do not use these members. |
48 | struct 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 | }; |
59 | extern const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto; |
60 | namespace tensorflow { |
61 | namespace distributed_runtime { |
62 | class GrpcPayloadContainer; |
63 | class GrpcPayloadContainerDefaultTypeInternal; |
64 | extern GrpcPayloadContainerDefaultTypeInternal _GrpcPayloadContainer_default_instance_; |
65 | class GrpcPayloadContainer_PayloadsEntry_DoNotUse; |
66 | class GrpcPayloadContainer_PayloadsEntry_DoNotUseDefaultTypeInternal; |
67 | extern GrpcPayloadContainer_PayloadsEntry_DoNotUseDefaultTypeInternal _GrpcPayloadContainer_PayloadsEntry_DoNotUse_default_instance_; |
68 | class GrpcPayloadsLost; |
69 | class GrpcPayloadsLostDefaultTypeInternal; |
70 | extern GrpcPayloadsLostDefaultTypeInternal _GrpcPayloadsLost_default_instance_; |
71 | class WorkerPossiblyRestarted; |
72 | class WorkerPossiblyRestartedDefaultTypeInternal; |
73 | extern WorkerPossiblyRestartedDefaultTypeInternal _WorkerPossiblyRestarted_default_instance_; |
74 | } // namespace distributed_runtime |
75 | } // namespace tensorflow |
76 | PROTOBUF_NAMESPACE_OPEN |
77 | template<> ::tensorflow::distributed_runtime::GrpcPayloadContainer* Arena::CreateMaybeMessage<::tensorflow::distributed_runtime::GrpcPayloadContainer>(Arena*); |
78 | template<> ::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse* Arena::CreateMaybeMessage<::tensorflow::distributed_runtime::GrpcPayloadContainer_PayloadsEntry_DoNotUse>(Arena*); |
79 | template<> ::tensorflow::distributed_runtime::GrpcPayloadsLost* Arena::CreateMaybeMessage<::tensorflow::distributed_runtime::GrpcPayloadsLost>(Arena*); |
80 | template<> ::tensorflow::distributed_runtime::WorkerPossiblyRestarted* Arena::CreateMaybeMessage<::tensorflow::distributed_runtime::WorkerPossiblyRestarted>(Arena*); |
81 | PROTOBUF_NAMESPACE_CLOSE |
82 | namespace tensorflow { |
83 | namespace distributed_runtime { |
84 | |
85 | // =================================================================== |
86 | |
87 | class 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 > { |
92 | public: |
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 | |
119 | class 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 | |
282 | class 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 | |
427 | class 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; |
584 | inline int GrpcPayloadContainer::payloads_size() const { |
585 | return payloads_.size(); |
586 | } |
587 | inline void GrpcPayloadContainer::clear_payloads() { |
588 | payloads_.Clear(); |
589 | } |
590 | inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& |
591 | GrpcPayloadContainer::payloads() const { |
592 | // @@protoc_insertion_point(field_map:tensorflow.distributed_runtime.GrpcPayloadContainer.payloads) |
593 | return payloads_.GetMap(); |
594 | } |
595 | inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* |
596 | GrpcPayloadContainer::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 | |