1// Generated by the protocol buffer compiler. DO NOT EDIT!
2// source: tensorflow/core/protobuf/coordination_config.proto
3
4#include "tensorflow/core/protobuf/coordination_config.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>
18namespace tensorflow {
19class CoordinationServiceConfigDefaultTypeInternal {
20 public:
21 ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<CoordinationServiceConfig> _instance;
22} _CoordinationServiceConfig_default_instance_;
23} // namespace tensorflow
24static void InitDefaultsscc_info_CoordinationServiceConfig_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto() {
25 GOOGLE_PROTOBUF_VERIFY_VERSION;
26
27 {
28 void* ptr = &::tensorflow::_CoordinationServiceConfig_default_instance_;
29 new (ptr) ::tensorflow::CoordinationServiceConfig();
30 ::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
31 }
32 ::tensorflow::CoordinationServiceConfig::InitAsDefaultInstance();
33}
34
35::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_CoordinationServiceConfig_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto =
36 {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsscc_info_CoordinationServiceConfig_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto}, {}};
37
38static ::PROTOBUF_NAMESPACE_ID::Metadata file_level_metadata_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto[1];
39static constexpr ::PROTOBUF_NAMESPACE_ID::EnumDescriptor const** file_level_enum_descriptors_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto = nullptr;
40static constexpr ::PROTOBUF_NAMESPACE_ID::ServiceDescriptor const** file_level_service_descriptors_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto = nullptr;
41
42const ::PROTOBUF_NAMESPACE_ID::uint32 TableStruct_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
43 ~0u, // no _has_bits_
44 PROTOBUF_FIELD_OFFSET(::tensorflow::CoordinationServiceConfig, _internal_metadata_),
45 ~0u, // no _extensions_
46 ~0u, // no _oneof_case_
47 ~0u, // no _weak_field_map_
48 PROTOBUF_FIELD_OFFSET(::tensorflow::CoordinationServiceConfig, service_type_),
49 PROTOBUF_FIELD_OFFSET(::tensorflow::CoordinationServiceConfig, service_leader_),
50 PROTOBUF_FIELD_OFFSET(::tensorflow::CoordinationServiceConfig, enable_health_check_),
51 PROTOBUF_FIELD_OFFSET(::tensorflow::CoordinationServiceConfig, cluster_register_timeout_in_ms_),
52 PROTOBUF_FIELD_OFFSET(::tensorflow::CoordinationServiceConfig, heartbeat_timeout_in_ms_),
53 PROTOBUF_FIELD_OFFSET(::tensorflow::CoordinationServiceConfig, coordinated_jobs_),
54 PROTOBUF_FIELD_OFFSET(::tensorflow::CoordinationServiceConfig, shutdown_barrier_timeout_in_ms_),
55 PROTOBUF_FIELD_OFFSET(::tensorflow::CoordinationServiceConfig, agent_destruction_without_shutdown_),
56 PROTOBUF_FIELD_OFFSET(::tensorflow::CoordinationServiceConfig, recoverable_jobs_),
57};
58static const ::PROTOBUF_NAMESPACE_ID::internal::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
59 { 0, -1, sizeof(::tensorflow::CoordinationServiceConfig)},
60};
61
62static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] = {
63 reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tensorflow::_CoordinationServiceConfig_default_instance_),
64};
65
66const char descriptor_table_protodef_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) =
67 "\n2tensorflow/core/protobuf/coordination_"
68 "config.proto\022\ntensorflow\"\267\002\n\031Coordinatio"
69 "nServiceConfig\022\024\n\014service_type\030\001 \001(\t\022\026\n\016"
70 "service_leader\030\002 \001(\t\022\033\n\023enable_health_ch"
71 "eck\030\003 \001(\010\022&\n\036cluster_register_timeout_in"
72 "_ms\030\004 \001(\003\022\037\n\027heartbeat_timeout_in_ms\030\005 \001"
73 "(\003\022\030\n\020coordinated_jobs\030\006 \003(\t\022&\n\036shutdown"
74 "_barrier_timeout_in_ms\030\007 \001(\003\022*\n\"agent_de"
75 "struction_without_shutdown\030\010 \001(\010\022\030\n\020reco"
76 "verable_jobs\030\t \003(\tBWZUgithub.com/tensorf"
77 "low/tensorflow/tensorflow/go/core/protob"
78 "uf/for_core_protos_go_protob\006proto3"
79 ;
80static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto_deps[1] = {
81};
82static ::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase*const descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto_sccs[1] = {
83 &scc_info_CoordinationServiceConfig_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto.base,
84};
85static ::PROTOBUF_NAMESPACE_ID::internal::once_flag descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto_once;
86static bool descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto_initialized = false;
87const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto = {
88 &descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto_initialized, descriptor_table_protodef_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto, "tensorflow/core/protobuf/coordination_config.proto", 475,
89 &descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto_once, descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto_sccs, descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto_deps, 1, 0,
90 schemas, file_default_instances, TableStruct_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto::offsets,
91 file_level_metadata_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto, 1, file_level_enum_descriptors_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto, file_level_service_descriptors_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto,
92};
93
94// Force running AddDescriptors() at dynamic initialization time.
95static bool dynamic_init_dummy_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto = ( ::PROTOBUF_NAMESPACE_ID::internal::AddDescriptors(&descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto), true);
96namespace tensorflow {
97
98// ===================================================================
99
100void CoordinationServiceConfig::InitAsDefaultInstance() {
101}
102class CoordinationServiceConfig::_Internal {
103 public:
104};
105
106CoordinationServiceConfig::CoordinationServiceConfig()
107 : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) {
108 SharedCtor();
109 // @@protoc_insertion_point(constructor:tensorflow.CoordinationServiceConfig)
110}
111CoordinationServiceConfig::CoordinationServiceConfig(const CoordinationServiceConfig& from)
112 : ::PROTOBUF_NAMESPACE_ID::Message(),
113 _internal_metadata_(nullptr),
114 coordinated_jobs_(from.coordinated_jobs_),
115 recoverable_jobs_(from.recoverable_jobs_) {
116 _internal_metadata_.MergeFrom(from._internal_metadata_);
117 service_type_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
118 if (!from.service_type().empty()) {
119 service_type_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.service_type_);
120 }
121 service_leader_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
122 if (!from.service_leader().empty()) {
123 service_leader_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.service_leader_);
124 }
125 ::memcpy(&cluster_register_timeout_in_ms_, &from.cluster_register_timeout_in_ms_,
126 static_cast<size_t>(reinterpret_cast<char*>(&agent_destruction_without_shutdown_) -
127 reinterpret_cast<char*>(&cluster_register_timeout_in_ms_)) + sizeof(agent_destruction_without_shutdown_));
128 // @@protoc_insertion_point(copy_constructor:tensorflow.CoordinationServiceConfig)
129}
130
131void CoordinationServiceConfig::SharedCtor() {
132 ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_CoordinationServiceConfig_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto.base);
133 service_type_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
134 service_leader_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
135 ::memset(&cluster_register_timeout_in_ms_, 0, static_cast<size_t>(
136 reinterpret_cast<char*>(&agent_destruction_without_shutdown_) -
137 reinterpret_cast<char*>(&cluster_register_timeout_in_ms_)) + sizeof(agent_destruction_without_shutdown_));
138}
139
140CoordinationServiceConfig::~CoordinationServiceConfig() {
141 // @@protoc_insertion_point(destructor:tensorflow.CoordinationServiceConfig)
142 SharedDtor();
143}
144
145void CoordinationServiceConfig::SharedDtor() {
146 service_type_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
147 service_leader_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
148}
149
150void CoordinationServiceConfig::SetCachedSize(int size) const {
151 _cached_size_.Set(size);
152}
153const CoordinationServiceConfig& CoordinationServiceConfig::default_instance() {
154 ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_CoordinationServiceConfig_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto.base);
155 return *internal_default_instance();
156}
157
158
159void CoordinationServiceConfig::Clear() {
160// @@protoc_insertion_point(message_clear_start:tensorflow.CoordinationServiceConfig)
161 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
162 // Prevent compiler warnings about cached_has_bits being unused
163 (void) cached_has_bits;
164
165 coordinated_jobs_.Clear();
166 recoverable_jobs_.Clear();
167 service_type_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
168 service_leader_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
169 ::memset(&cluster_register_timeout_in_ms_, 0, static_cast<size_t>(
170 reinterpret_cast<char*>(&agent_destruction_without_shutdown_) -
171 reinterpret_cast<char*>(&cluster_register_timeout_in_ms_)) + sizeof(agent_destruction_without_shutdown_));
172 _internal_metadata_.Clear();
173}
174
175#if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
176const char* CoordinationServiceConfig::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) {
177#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
178 while (!ctx->Done(&ptr)) {
179 ::PROTOBUF_NAMESPACE_ID::uint32 tag;
180 ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag);
181 CHK_(ptr);
182 switch (tag >> 3) {
183 // string service_type = 1;
184 case 1:
185 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
186 ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(mutable_service_type(), ptr, ctx, "tensorflow.CoordinationServiceConfig.service_type");
187 CHK_(ptr);
188 } else goto handle_unusual;
189 continue;
190 // string service_leader = 2;
191 case 2:
192 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) {
193 ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(mutable_service_leader(), ptr, ctx, "tensorflow.CoordinationServiceConfig.service_leader");
194 CHK_(ptr);
195 } else goto handle_unusual;
196 continue;
197 // bool enable_health_check = 3;
198 case 3:
199 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 24)) {
200 enable_health_check_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr);
201 CHK_(ptr);
202 } else goto handle_unusual;
203 continue;
204 // int64 cluster_register_timeout_in_ms = 4;
205 case 4:
206 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 32)) {
207 cluster_register_timeout_in_ms_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr);
208 CHK_(ptr);
209 } else goto handle_unusual;
210 continue;
211 // int64 heartbeat_timeout_in_ms = 5;
212 case 5:
213 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 40)) {
214 heartbeat_timeout_in_ms_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr);
215 CHK_(ptr);
216 } else goto handle_unusual;
217 continue;
218 // repeated string coordinated_jobs = 6;
219 case 6:
220 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 50)) {
221 ptr -= 1;
222 do {
223 ptr += 1;
224 ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(add_coordinated_jobs(), ptr, ctx, "tensorflow.CoordinationServiceConfig.coordinated_jobs");
225 CHK_(ptr);
226 if (!ctx->DataAvailable(ptr)) break;
227 } while (::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<::PROTOBUF_NAMESPACE_ID::uint8>(ptr) == 50);
228 } else goto handle_unusual;
229 continue;
230 // int64 shutdown_barrier_timeout_in_ms = 7;
231 case 7:
232 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 56)) {
233 shutdown_barrier_timeout_in_ms_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr);
234 CHK_(ptr);
235 } else goto handle_unusual;
236 continue;
237 // bool agent_destruction_without_shutdown = 8;
238 case 8:
239 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 64)) {
240 agent_destruction_without_shutdown_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr);
241 CHK_(ptr);
242 } else goto handle_unusual;
243 continue;
244 // repeated string recoverable_jobs = 9;
245 case 9:
246 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 74)) {
247 ptr -= 1;
248 do {
249 ptr += 1;
250 ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(add_recoverable_jobs(), ptr, ctx, "tensorflow.CoordinationServiceConfig.recoverable_jobs");
251 CHK_(ptr);
252 if (!ctx->DataAvailable(ptr)) break;
253 } while (::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<::PROTOBUF_NAMESPACE_ID::uint8>(ptr) == 74);
254 } else goto handle_unusual;
255 continue;
256 default: {
257 handle_unusual:
258 if ((tag & 7) == 4 || tag == 0) {
259 ctx->SetLastTag(tag);
260 goto success;
261 }
262 ptr = UnknownFieldParse(tag, &_internal_metadata_, ptr, ctx);
263 CHK_(ptr != nullptr);
264 continue;
265 }
266 } // switch
267 } // while
268success:
269 return ptr;
270failure:
271 ptr = nullptr;
272 goto success;
273#undef CHK_
274}
275#else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
276bool CoordinationServiceConfig::MergePartialFromCodedStream(
277 ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) {
278#define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure
279 ::PROTOBUF_NAMESPACE_ID::uint32 tag;
280 // @@protoc_insertion_point(parse_start:tensorflow.CoordinationServiceConfig)
281 for (;;) {
282 ::std::pair<::PROTOBUF_NAMESPACE_ID::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
283 tag = p.first;
284 if (!p.second) goto handle_unusual;
285 switch (::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::GetTagFieldNumber(tag)) {
286 // string service_type = 1;
287 case 1: {
288 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (10 & 0xFF)) {
289 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString(
290 input, this->mutable_service_type()));
291 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
292 this->service_type().data(), static_cast<int>(this->service_type().length()),
293 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE,
294 "tensorflow.CoordinationServiceConfig.service_type"));
295 } else {
296 goto handle_unusual;
297 }
298 break;
299 }
300
301 // string service_leader = 2;
302 case 2: {
303 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (18 & 0xFF)) {
304 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString(
305 input, this->mutable_service_leader()));
306 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
307 this->service_leader().data(), static_cast<int>(this->service_leader().length()),
308 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE,
309 "tensorflow.CoordinationServiceConfig.service_leader"));
310 } else {
311 goto handle_unusual;
312 }
313 break;
314 }
315
316 // bool enable_health_check = 3;
317 case 3: {
318 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (24 & 0xFF)) {
319
320 DO_((::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadPrimitive<
321 bool, ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_BOOL>(
322 input, &enable_health_check_)));
323 } else {
324 goto handle_unusual;
325 }
326 break;
327 }
328
329 // int64 cluster_register_timeout_in_ms = 4;
330 case 4: {
331 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (32 & 0xFF)) {
332
333 DO_((::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadPrimitive<
334 ::PROTOBUF_NAMESPACE_ID::int64, ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_INT64>(
335 input, &cluster_register_timeout_in_ms_)));
336 } else {
337 goto handle_unusual;
338 }
339 break;
340 }
341
342 // int64 heartbeat_timeout_in_ms = 5;
343 case 5: {
344 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (40 & 0xFF)) {
345
346 DO_((::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadPrimitive<
347 ::PROTOBUF_NAMESPACE_ID::int64, ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_INT64>(
348 input, &heartbeat_timeout_in_ms_)));
349 } else {
350 goto handle_unusual;
351 }
352 break;
353 }
354
355 // repeated string coordinated_jobs = 6;
356 case 6: {
357 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (50 & 0xFF)) {
358 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString(
359 input, this->add_coordinated_jobs()));
360 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
361 this->coordinated_jobs(this->coordinated_jobs_size() - 1).data(),
362 static_cast<int>(this->coordinated_jobs(this->coordinated_jobs_size() - 1).length()),
363 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE,
364 "tensorflow.CoordinationServiceConfig.coordinated_jobs"));
365 } else {
366 goto handle_unusual;
367 }
368 break;
369 }
370
371 // int64 shutdown_barrier_timeout_in_ms = 7;
372 case 7: {
373 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (56 & 0xFF)) {
374
375 DO_((::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadPrimitive<
376 ::PROTOBUF_NAMESPACE_ID::int64, ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_INT64>(
377 input, &shutdown_barrier_timeout_in_ms_)));
378 } else {
379 goto handle_unusual;
380 }
381 break;
382 }
383
384 // bool agent_destruction_without_shutdown = 8;
385 case 8: {
386 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (64 & 0xFF)) {
387
388 DO_((::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadPrimitive<
389 bool, ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_BOOL>(
390 input, &agent_destruction_without_shutdown_)));
391 } else {
392 goto handle_unusual;
393 }
394 break;
395 }
396
397 // repeated string recoverable_jobs = 9;
398 case 9: {
399 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (74 & 0xFF)) {
400 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString(
401 input, this->add_recoverable_jobs()));
402 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
403 this->recoverable_jobs(this->recoverable_jobs_size() - 1).data(),
404 static_cast<int>(this->recoverable_jobs(this->recoverable_jobs_size() - 1).length()),
405 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE,
406 "tensorflow.CoordinationServiceConfig.recoverable_jobs"));
407 } else {
408 goto handle_unusual;
409 }
410 break;
411 }
412
413 default: {
414 handle_unusual:
415 if (tag == 0) {
416 goto success;
417 }
418 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SkipField(
419 input, tag, _internal_metadata_.mutable_unknown_fields()));
420 break;
421 }
422 }
423 }
424success:
425 // @@protoc_insertion_point(parse_success:tensorflow.CoordinationServiceConfig)
426 return true;
427failure:
428 // @@protoc_insertion_point(parse_failure:tensorflow.CoordinationServiceConfig)
429 return false;
430#undef DO_
431}
432#endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
433
434void CoordinationServiceConfig::SerializeWithCachedSizes(
435 ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const {
436 // @@protoc_insertion_point(serialize_start:tensorflow.CoordinationServiceConfig)
437 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
438 (void) cached_has_bits;
439
440 // string service_type = 1;
441 if (this->service_type().size() > 0) {
442 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
443 this->service_type().data(), static_cast<int>(this->service_type().length()),
444 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
445 "tensorflow.CoordinationServiceConfig.service_type");
446 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringMaybeAliased(
447 1, this->service_type(), output);
448 }
449
450 // string service_leader = 2;
451 if (this->service_leader().size() > 0) {
452 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
453 this->service_leader().data(), static_cast<int>(this->service_leader().length()),
454 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
455 "tensorflow.CoordinationServiceConfig.service_leader");
456 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringMaybeAliased(
457 2, this->service_leader(), output);
458 }
459
460 // bool enable_health_check = 3;
461 if (this->enable_health_check() != 0) {
462 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBool(3, this->enable_health_check(), output);
463 }
464
465 // int64 cluster_register_timeout_in_ms = 4;
466 if (this->cluster_register_timeout_in_ms() != 0) {
467 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt64(4, this->cluster_register_timeout_in_ms(), output);
468 }
469
470 // int64 heartbeat_timeout_in_ms = 5;
471 if (this->heartbeat_timeout_in_ms() != 0) {
472 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt64(5, this->heartbeat_timeout_in_ms(), output);
473 }
474
475 // repeated string coordinated_jobs = 6;
476 for (int i = 0, n = this->coordinated_jobs_size(); i < n; i++) {
477 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
478 this->coordinated_jobs(i).data(), static_cast<int>(this->coordinated_jobs(i).length()),
479 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
480 "tensorflow.CoordinationServiceConfig.coordinated_jobs");
481 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteString(
482 6, this->coordinated_jobs(i), output);
483 }
484
485 // int64 shutdown_barrier_timeout_in_ms = 7;
486 if (this->shutdown_barrier_timeout_in_ms() != 0) {
487 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt64(7, this->shutdown_barrier_timeout_in_ms(), output);
488 }
489
490 // bool agent_destruction_without_shutdown = 8;
491 if (this->agent_destruction_without_shutdown() != 0) {
492 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBool(8, this->agent_destruction_without_shutdown(), output);
493 }
494
495 // repeated string recoverable_jobs = 9;
496 for (int i = 0, n = this->recoverable_jobs_size(); i < n; i++) {
497 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
498 this->recoverable_jobs(i).data(), static_cast<int>(this->recoverable_jobs(i).length()),
499 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
500 "tensorflow.CoordinationServiceConfig.recoverable_jobs");
501 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteString(
502 9, this->recoverable_jobs(i), output);
503 }
504
505 if (_internal_metadata_.have_unknown_fields()) {
506 ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields(
507 _internal_metadata_.unknown_fields(), output);
508 }
509 // @@protoc_insertion_point(serialize_end:tensorflow.CoordinationServiceConfig)
510}
511
512::PROTOBUF_NAMESPACE_ID::uint8* CoordinationServiceConfig::InternalSerializeWithCachedSizesToArray(
513 ::PROTOBUF_NAMESPACE_ID::uint8* target) const {
514 // @@protoc_insertion_point(serialize_to_array_start:tensorflow.CoordinationServiceConfig)
515 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
516 (void) cached_has_bits;
517
518 // string service_type = 1;
519 if (this->service_type().size() > 0) {
520 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
521 this->service_type().data(), static_cast<int>(this->service_type().length()),
522 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
523 "tensorflow.CoordinationServiceConfig.service_type");
524 target =
525 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringToArray(
526 1, this->service_type(), target);
527 }
528
529 // string service_leader = 2;
530 if (this->service_leader().size() > 0) {
531 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
532 this->service_leader().data(), static_cast<int>(this->service_leader().length()),
533 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
534 "tensorflow.CoordinationServiceConfig.service_leader");
535 target =
536 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringToArray(
537 2, this->service_leader(), target);
538 }
539
540 // bool enable_health_check = 3;
541 if (this->enable_health_check() != 0) {
542 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBoolToArray(3, this->enable_health_check(), target);
543 }
544
545 // int64 cluster_register_timeout_in_ms = 4;
546 if (this->cluster_register_timeout_in_ms() != 0) {
547 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt64ToArray(4, this->cluster_register_timeout_in_ms(), target);
548 }
549
550 // int64 heartbeat_timeout_in_ms = 5;
551 if (this->heartbeat_timeout_in_ms() != 0) {
552 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt64ToArray(5, this->heartbeat_timeout_in_ms(), target);
553 }
554
555 // repeated string coordinated_jobs = 6;
556 for (int i = 0, n = this->coordinated_jobs_size(); i < n; i++) {
557 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
558 this->coordinated_jobs(i).data(), static_cast<int>(this->coordinated_jobs(i).length()),
559 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
560 "tensorflow.CoordinationServiceConfig.coordinated_jobs");
561 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
562 WriteStringToArray(6, this->coordinated_jobs(i), target);
563 }
564
565 // int64 shutdown_barrier_timeout_in_ms = 7;
566 if (this->shutdown_barrier_timeout_in_ms() != 0) {
567 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt64ToArray(7, this->shutdown_barrier_timeout_in_ms(), target);
568 }
569
570 // bool agent_destruction_without_shutdown = 8;
571 if (this->agent_destruction_without_shutdown() != 0) {
572 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBoolToArray(8, this->agent_destruction_without_shutdown(), target);
573 }
574
575 // repeated string recoverable_jobs = 9;
576 for (int i = 0, n = this->recoverable_jobs_size(); i < n; i++) {
577 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
578 this->recoverable_jobs(i).data(), static_cast<int>(this->recoverable_jobs(i).length()),
579 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
580 "tensorflow.CoordinationServiceConfig.recoverable_jobs");
581 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
582 WriteStringToArray(9, this->recoverable_jobs(i), target);
583 }
584
585 if (_internal_metadata_.have_unknown_fields()) {
586 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray(
587 _internal_metadata_.unknown_fields(), target);
588 }
589 // @@protoc_insertion_point(serialize_to_array_end:tensorflow.CoordinationServiceConfig)
590 return target;
591}
592
593size_t CoordinationServiceConfig::ByteSizeLong() const {
594// @@protoc_insertion_point(message_byte_size_start:tensorflow.CoordinationServiceConfig)
595 size_t total_size = 0;
596
597 if (_internal_metadata_.have_unknown_fields()) {
598 total_size +=
599 ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::ComputeUnknownFieldsSize(
600 _internal_metadata_.unknown_fields());
601 }
602 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
603 // Prevent compiler warnings about cached_has_bits being unused
604 (void) cached_has_bits;
605
606 // repeated string coordinated_jobs = 6;
607 total_size += 1 *
608 ::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(this->coordinated_jobs_size());
609 for (int i = 0, n = this->coordinated_jobs_size(); i < n; i++) {
610 total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
611 this->coordinated_jobs(i));
612 }
613
614 // repeated string recoverable_jobs = 9;
615 total_size += 1 *
616 ::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(this->recoverable_jobs_size());
617 for (int i = 0, n = this->recoverable_jobs_size(); i < n; i++) {
618 total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
619 this->recoverable_jobs(i));
620 }
621
622 // string service_type = 1;
623 if (this->service_type().size() > 0) {
624 total_size += 1 +
625 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
626 this->service_type());
627 }
628
629 // string service_leader = 2;
630 if (this->service_leader().size() > 0) {
631 total_size += 1 +
632 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
633 this->service_leader());
634 }
635
636 // int64 cluster_register_timeout_in_ms = 4;
637 if (this->cluster_register_timeout_in_ms() != 0) {
638 total_size += 1 +
639 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::Int64Size(
640 this->cluster_register_timeout_in_ms());
641 }
642
643 // int64 heartbeat_timeout_in_ms = 5;
644 if (this->heartbeat_timeout_in_ms() != 0) {
645 total_size += 1 +
646 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::Int64Size(
647 this->heartbeat_timeout_in_ms());
648 }
649
650 // int64 shutdown_barrier_timeout_in_ms = 7;
651 if (this->shutdown_barrier_timeout_in_ms() != 0) {
652 total_size += 1 +
653 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::Int64Size(
654 this->shutdown_barrier_timeout_in_ms());
655 }
656
657 // bool enable_health_check = 3;
658 if (this->enable_health_check() != 0) {
659 total_size += 1 + 1;
660 }
661
662 // bool agent_destruction_without_shutdown = 8;
663 if (this->agent_destruction_without_shutdown() != 0) {
664 total_size += 1 + 1;
665 }
666
667 int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
668 SetCachedSize(cached_size);
669 return total_size;
670}
671
672void CoordinationServiceConfig::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
673// @@protoc_insertion_point(generalized_merge_from_start:tensorflow.CoordinationServiceConfig)
674 GOOGLE_DCHECK_NE(&from, this);
675 const CoordinationServiceConfig* source =
676 ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated<CoordinationServiceConfig>(
677 &from);
678 if (source == nullptr) {
679 // @@protoc_insertion_point(generalized_merge_from_cast_fail:tensorflow.CoordinationServiceConfig)
680 ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this);
681 } else {
682 // @@protoc_insertion_point(generalized_merge_from_cast_success:tensorflow.CoordinationServiceConfig)
683 MergeFrom(*source);
684 }
685}
686
687void CoordinationServiceConfig::MergeFrom(const CoordinationServiceConfig& from) {
688// @@protoc_insertion_point(class_specific_merge_from_start:tensorflow.CoordinationServiceConfig)
689 GOOGLE_DCHECK_NE(&from, this);
690 _internal_metadata_.MergeFrom(from._internal_metadata_);
691 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
692 (void) cached_has_bits;
693
694 coordinated_jobs_.MergeFrom(from.coordinated_jobs_);
695 recoverable_jobs_.MergeFrom(from.recoverable_jobs_);
696 if (from.service_type().size() > 0) {
697
698 service_type_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.service_type_);
699 }
700 if (from.service_leader().size() > 0) {
701
702 service_leader_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.service_leader_);
703 }
704 if (from.cluster_register_timeout_in_ms() != 0) {
705 set_cluster_register_timeout_in_ms(from.cluster_register_timeout_in_ms());
706 }
707 if (from.heartbeat_timeout_in_ms() != 0) {
708 set_heartbeat_timeout_in_ms(from.heartbeat_timeout_in_ms());
709 }
710 if (from.shutdown_barrier_timeout_in_ms() != 0) {
711 set_shutdown_barrier_timeout_in_ms(from.shutdown_barrier_timeout_in_ms());
712 }
713 if (from.enable_health_check() != 0) {
714 set_enable_health_check(from.enable_health_check());
715 }
716 if (from.agent_destruction_without_shutdown() != 0) {
717 set_agent_destruction_without_shutdown(from.agent_destruction_without_shutdown());
718 }
719}
720
721void CoordinationServiceConfig::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
722// @@protoc_insertion_point(generalized_copy_from_start:tensorflow.CoordinationServiceConfig)
723 if (&from == this) return;
724 Clear();
725 MergeFrom(from);
726}
727
728void CoordinationServiceConfig::CopyFrom(const CoordinationServiceConfig& from) {
729// @@protoc_insertion_point(class_specific_copy_from_start:tensorflow.CoordinationServiceConfig)
730 if (&from == this) return;
731 Clear();
732 MergeFrom(from);
733}
734
735bool CoordinationServiceConfig::IsInitialized() const {
736 return true;
737}
738
739void CoordinationServiceConfig::InternalSwap(CoordinationServiceConfig* other) {
740 using std::swap;
741 _internal_metadata_.Swap(&other->_internal_metadata_);
742 coordinated_jobs_.InternalSwap(CastToBase(&other->coordinated_jobs_));
743 recoverable_jobs_.InternalSwap(CastToBase(&other->recoverable_jobs_));
744 service_type_.Swap(&other->service_type_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
745 GetArenaNoVirtual());
746 service_leader_.Swap(&other->service_leader_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
747 GetArenaNoVirtual());
748 swap(cluster_register_timeout_in_ms_, other->cluster_register_timeout_in_ms_);
749 swap(heartbeat_timeout_in_ms_, other->heartbeat_timeout_in_ms_);
750 swap(shutdown_barrier_timeout_in_ms_, other->shutdown_barrier_timeout_in_ms_);
751 swap(enable_health_check_, other->enable_health_check_);
752 swap(agent_destruction_without_shutdown_, other->agent_destruction_without_shutdown_);
753}
754
755::PROTOBUF_NAMESPACE_ID::Metadata CoordinationServiceConfig::GetMetadata() const {
756 return GetMetadataStatic();
757}
758
759
760// @@protoc_insertion_point(namespace_scope)
761} // namespace tensorflow
762PROTOBUF_NAMESPACE_OPEN
763template<> PROTOBUF_NOINLINE ::tensorflow::CoordinationServiceConfig* Arena::CreateMaybeMessage< ::tensorflow::CoordinationServiceConfig >(Arena* arena) {
764 return Arena::CreateInternal< ::tensorflow::CoordinationServiceConfig >(arena);
765}
766PROTOBUF_NAMESPACE_CLOSE
767
768// @@protoc_insertion_point(global_scope)
769#include <google/protobuf/port_undef.inc>
770