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> |
18 | extern 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; |
19 | namespace tensorflow { |
20 | namespace distributed_runtime { |
21 | class GrpcPayloadContainer_PayloadsEntry_DoNotUseDefaultTypeInternal { |
22 | public: |
23 | ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<GrpcPayloadContainer_PayloadsEntry_DoNotUse> _instance; |
24 | } _GrpcPayloadContainer_PayloadsEntry_DoNotUse_default_instance_; |
25 | class GrpcPayloadContainerDefaultTypeInternal { |
26 | public: |
27 | ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<GrpcPayloadContainer> _instance; |
28 | } _GrpcPayloadContainer_default_instance_; |
29 | class GrpcPayloadsLostDefaultTypeInternal { |
30 | public: |
31 | ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<GrpcPayloadsLost> _instance; |
32 | } _GrpcPayloadsLost_default_instance_; |
33 | class WorkerPossiblyRestartedDefaultTypeInternal { |
34 | public: |
35 | ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<WorkerPossiblyRestarted> _instance; |
36 | } _WorkerPossiblyRestarted_default_instance_; |
37 | } // namespace distributed_runtime |
38 | } // namespace tensorflow |
39 | static 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 | |
54 | static 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 | |
67 | static 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 | |
81 | static 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 | |
95 | static ::PROTOBUF_NAMESPACE_ID::Metadata file_level_metadata_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto[4]; |
96 | static constexpr ::PROTOBUF_NAMESPACE_ID::EnumDescriptor const** file_level_enum_descriptors_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto = nullptr; |
97 | static constexpr ::PROTOBUF_NAMESPACE_ID::ServiceDescriptor const** file_level_service_descriptors_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto = nullptr; |
98 | |
99 | const ::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 | }; |
126 | static 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 | |
133 | static ::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 | |
140 | const 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 | ; |
152 | static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto_deps[1] = { |
153 | }; |
154 | static ::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 | }; |
160 | static ::PROTOBUF_NAMESPACE_ID::internal::once_flag descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto_once; |
161 | static bool descriptor_table_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto_initialized = false; |
162 | const ::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. |
170 | static 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); |
171 | namespace tensorflow { |
172 | namespace distributed_runtime { |
173 | |
174 | // =================================================================== |
175 | |
176 | GrpcPayloadContainer_PayloadsEntry_DoNotUse::GrpcPayloadContainer_PayloadsEntry_DoNotUse() {} |
177 | GrpcPayloadContainer_PayloadsEntry_DoNotUse::GrpcPayloadContainer_PayloadsEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena) |
178 | : SuperType(arena) {} |
179 | void 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 | } |
185 | void GrpcPayloadContainer_PayloadsEntry_DoNotUse::MergeFrom( |
186 | const ::PROTOBUF_NAMESPACE_ID::Message& other) { |
187 | ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom(other); |
188 | } |
189 | |
190 | |
191 | // =================================================================== |
192 | |
193 | void GrpcPayloadContainer::InitAsDefaultInstance() { |
194 | } |
195 | class GrpcPayloadContainer::_Internal { |
196 | public: |
197 | }; |
198 | |
199 | GrpcPayloadContainer::GrpcPayloadContainer() |
200 | : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { |
201 | SharedCtor(); |
202 | // @@protoc_insertion_point(constructor:tensorflow.distributed_runtime.GrpcPayloadContainer) |
203 | } |
204 | GrpcPayloadContainer::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 | } |
212 | GrpcPayloadContainer::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 | |
220 | void GrpcPayloadContainer::SharedCtor() { |
221 | ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_GrpcPayloadContainer_tensorflow_2fcore_2fprotobuf_2fdistributed_5fruntime_5fpayloads_2eproto.base); |
222 | } |
223 | |
224 | GrpcPayloadContainer::~GrpcPayloadContainer() { |
225 | // @@protoc_insertion_point(destructor:tensorflow.distributed_runtime.GrpcPayloadContainer) |
226 | SharedDtor(); |
227 | } |
228 | |
229 | void GrpcPayloadContainer::SharedDtor() { |
230 | GOOGLE_DCHECK(GetArenaNoVirtual() == nullptr); |
231 | } |
232 | |
233 | void GrpcPayloadContainer::ArenaDtor(void* object) { |
234 | GrpcPayloadContainer* _this = reinterpret_cast< GrpcPayloadContainer* >(object); |
235 | (void)_this; |
236 | } |
237 | void GrpcPayloadContainer::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { |
238 | } |
239 | void GrpcPayloadContainer::SetCachedSize(int size) const { |
240 | _cached_size_.Set(size); |
241 | } |
242 | const 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 | |
248 | void 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 |
259 | const 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 |
291 | success: |
292 | return ptr; |
293 | failure: |
294 | ptr = nullptr; |
295 | goto success; |
296 | #undef CHK_ |
297 | } |
298 | #else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER |
299 | bool 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 | } |
342 | success: |
343 | // @@protoc_insertion_point(parse_success:tensorflow.distributed_runtime.GrpcPayloadContainer) |
344 | return true; |
345 | failure: |
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 | |
352 | void 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 | |
461 | size_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 | |
488 | void 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 | |
503 | void 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 | |
513 | void 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 | |
520 | void 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 | |
527 | bool GrpcPayloadContainer::IsInitialized() const { |
528 | return true; |
529 | } |
530 | |
531 | void 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 | |
544 | void GrpcPayloadsLost::InitAsDefaultInstance() { |
545 | } |
546 | class GrpcPayloadsLost::_Internal { |
547 | public: |
548 | }; |
549 | |
550 | GrpcPayloadsLost::GrpcPayloadsLost() |
551 | : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { |
552 | SharedCtor(); |
553 | // @@protoc_insertion_point(constructor:tensorflow.distributed_runtime.GrpcPayloadsLost) |
554 | } |
555 | GrpcPayloadsLost::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 | } |
562 | GrpcPayloadsLost::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 | |
569 | void GrpcPayloadsLost::SharedCtor() { |
570 | } |
571 | |
572 | GrpcPayloadsLost::~GrpcPayloadsLost() { |
573 | // @@protoc_insertion_point(destructor:tensorflow.distributed_runtime.GrpcPayloadsLost) |
574 | SharedDtor(); |
575 | } |
576 | |
577 | void GrpcPayloadsLost::SharedDtor() { |
578 | GOOGLE_DCHECK(GetArenaNoVirtual() == nullptr); |
579 | } |
580 | |
581 | void GrpcPayloadsLost::ArenaDtor(void* object) { |
582 | GrpcPayloadsLost* _this = reinterpret_cast< GrpcPayloadsLost* >(object); |
583 | (void)_this; |
584 | } |
585 | void GrpcPayloadsLost::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { |
586 | } |
587 | void GrpcPayloadsLost::SetCachedSize(int size) const { |
588 | _cached_size_.Set(size); |
589 | } |
590 | const 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 | |
596 | void 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 |
606 | const 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 |
625 | success: |
626 | return ptr; |
627 | failure: |
628 | ptr = nullptr; |
629 | goto success; |
630 | #undef CHK_ |
631 | } |
632 | #else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER |
633 | bool 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 | } |
649 | success: |
650 | // @@protoc_insertion_point(parse_success:tensorflow.distributed_runtime.GrpcPayloadsLost) |
651 | return true; |
652 | failure: |
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 | |
659 | void 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 | |
686 | size_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 | |
704 | void 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 | |
719 | void 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 | |
728 | void 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 | |
735 | void 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 | |
742 | bool GrpcPayloadsLost::IsInitialized() const { |
743 | return true; |
744 | } |
745 | |
746 | void 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 | |
758 | void WorkerPossiblyRestarted::InitAsDefaultInstance() { |
759 | } |
760 | class WorkerPossiblyRestarted::_Internal { |
761 | public: |
762 | }; |
763 | |
764 | WorkerPossiblyRestarted::WorkerPossiblyRestarted() |
765 | : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { |
766 | SharedCtor(); |
767 | // @@protoc_insertion_point(constructor:tensorflow.distributed_runtime.WorkerPossiblyRestarted) |
768 | } |
769 | WorkerPossiblyRestarted::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 | } |
776 | WorkerPossiblyRestarted::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 | |
783 | void WorkerPossiblyRestarted::SharedCtor() { |
784 | } |
785 | |
786 | WorkerPossiblyRestarted::~WorkerPossiblyRestarted() { |
787 | // @@protoc_insertion_point(destructor:tensorflow.distributed_runtime.WorkerPossiblyRestarted) |
788 | SharedDtor(); |
789 | } |
790 | |
791 | void WorkerPossiblyRestarted::SharedDtor() { |
792 | GOOGLE_DCHECK(GetArenaNoVirtual() == nullptr); |
793 | } |
794 | |
795 | void WorkerPossiblyRestarted::ArenaDtor(void* object) { |
796 | WorkerPossiblyRestarted* _this = reinterpret_cast< WorkerPossiblyRestarted* >(object); |
797 | (void)_this; |
798 | } |
799 | void WorkerPossiblyRestarted::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { |
800 | } |
801 | void WorkerPossiblyRestarted::SetCachedSize(int size) const { |
802 | _cached_size_.Set(size); |
803 | } |
804 | const 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 | |
810 | void 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 |
820 | const 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 |
839 | success: |
840 | return ptr; |
841 | failure: |
842 | ptr = nullptr; |
843 | goto success; |
844 | #undef CHK_ |
845 | } |
846 | #else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER |
847 | bool 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 | } |
863 | success: |
864 | // @@protoc_insertion_point(parse_success:tensorflow.distributed_runtime.WorkerPossiblyRestarted) |
865 | return true; |
866 | failure: |
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 | |
873 | void 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 | |
900 | size_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 | |
918 | void 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 | |
933 | void 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 | |
942 | void 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 | |
949 | void 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 | |
956 | bool WorkerPossiblyRestarted::IsInitialized() const { |
957 | return true; |
958 | } |
959 | |
960 | void 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 |
973 | PROTOBUF_NAMESPACE_OPEN |
974 | template<> 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 | } |
977 | template<> PROTOBUF_NOINLINE ::tensorflow::distributed_runtime::GrpcPayloadContainer* Arena::CreateMaybeMessage< ::tensorflow::distributed_runtime::GrpcPayloadContainer >(Arena* arena) { |
978 | return Arena::CreateMessageInternal< ::tensorflow::distributed_runtime::GrpcPayloadContainer >(arena); |
979 | } |
980 | template<> PROTOBUF_NOINLINE ::tensorflow::distributed_runtime::GrpcPayloadsLost* Arena::CreateMaybeMessage< ::tensorflow::distributed_runtime::GrpcPayloadsLost >(Arena* arena) { |
981 | return Arena::CreateMessageInternal< ::tensorflow::distributed_runtime::GrpcPayloadsLost >(arena); |
982 | } |
983 | template<> PROTOBUF_NOINLINE ::tensorflow::distributed_runtime::WorkerPossiblyRestarted* Arena::CreateMaybeMessage< ::tensorflow::distributed_runtime::WorkerPossiblyRestarted >(Arena* arena) { |
984 | return Arena::CreateMessageInternal< ::tensorflow::distributed_runtime::WorkerPossiblyRestarted >(arena); |
985 | } |
986 | PROTOBUF_NAMESPACE_CLOSE |
987 | |
988 | // @@protoc_insertion_point(global_scope) |
989 | #include <google/protobuf/port_undef.inc> |
990 | |