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> |
18 | namespace tensorflow { |
19 | class CoordinationServiceConfigDefaultTypeInternal { |
20 | public: |
21 | ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<CoordinationServiceConfig> _instance; |
22 | } _CoordinationServiceConfig_default_instance_; |
23 | } // namespace tensorflow |
24 | static 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 | |
38 | static ::PROTOBUF_NAMESPACE_ID::Metadata file_level_metadata_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto[1]; |
39 | static constexpr ::PROTOBUF_NAMESPACE_ID::EnumDescriptor const** file_level_enum_descriptors_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto = nullptr; |
40 | static constexpr ::PROTOBUF_NAMESPACE_ID::ServiceDescriptor const** file_level_service_descriptors_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto = nullptr; |
41 | |
42 | const ::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 | }; |
58 | static const ::PROTOBUF_NAMESPACE_ID::internal::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = { |
59 | { 0, -1, sizeof(::tensorflow::CoordinationServiceConfig)}, |
60 | }; |
61 | |
62 | static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] = { |
63 | reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tensorflow::_CoordinationServiceConfig_default_instance_), |
64 | }; |
65 | |
66 | const 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 | ; |
80 | static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto_deps[1] = { |
81 | }; |
82 | static ::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 | }; |
85 | static ::PROTOBUF_NAMESPACE_ID::internal::once_flag descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto_once; |
86 | static bool descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto_initialized = false; |
87 | const ::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. |
95 | static bool dynamic_init_dummy_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto = ( ::PROTOBUF_NAMESPACE_ID::internal::AddDescriptors(&descriptor_table_tensorflow_2fcore_2fprotobuf_2fcoordination_5fconfig_2eproto), true); |
96 | namespace tensorflow { |
97 | |
98 | // =================================================================== |
99 | |
100 | void CoordinationServiceConfig::InitAsDefaultInstance() { |
101 | } |
102 | class CoordinationServiceConfig::_Internal { |
103 | public: |
104 | }; |
105 | |
106 | CoordinationServiceConfig::CoordinationServiceConfig() |
107 | : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) { |
108 | SharedCtor(); |
109 | // @@protoc_insertion_point(constructor:tensorflow.CoordinationServiceConfig) |
110 | } |
111 | CoordinationServiceConfig::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 | |
131 | void 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 | |
140 | CoordinationServiceConfig::~CoordinationServiceConfig() { |
141 | // @@protoc_insertion_point(destructor:tensorflow.CoordinationServiceConfig) |
142 | SharedDtor(); |
143 | } |
144 | |
145 | void CoordinationServiceConfig::SharedDtor() { |
146 | service_type_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); |
147 | service_leader_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); |
148 | } |
149 | |
150 | void CoordinationServiceConfig::SetCachedSize(int size) const { |
151 | _cached_size_.Set(size); |
152 | } |
153 | const 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 | |
159 | void 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 |
176 | const 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 |
268 | success: |
269 | return ptr; |
270 | failure: |
271 | ptr = nullptr; |
272 | goto success; |
273 | #undef CHK_ |
274 | } |
275 | #else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER |
276 | bool 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 | } |
424 | success: |
425 | // @@protoc_insertion_point(parse_success:tensorflow.CoordinationServiceConfig) |
426 | return true; |
427 | failure: |
428 | // @@protoc_insertion_point(parse_failure:tensorflow.CoordinationServiceConfig) |
429 | return false; |
430 | #undef DO_ |
431 | } |
432 | #endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER |
433 | |
434 | void 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 | |
593 | size_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 | |
672 | void 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 | |
687 | void 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 | |
721 | void 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 | |
728 | void 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 | |
735 | bool CoordinationServiceConfig::IsInitialized() const { |
736 | return true; |
737 | } |
738 | |
739 | void 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 |
762 | PROTOBUF_NAMESPACE_OPEN |
763 | template<> PROTOBUF_NOINLINE ::tensorflow::CoordinationServiceConfig* Arena::CreateMaybeMessage< ::tensorflow::CoordinationServiceConfig >(Arena* arena) { |
764 | return Arena::CreateInternal< ::tensorflow::CoordinationServiceConfig >(arena); |
765 | } |
766 | PROTOBUF_NAMESPACE_CLOSE |
767 | |
768 | // @@protoc_insertion_point(global_scope) |
769 | #include <google/protobuf/port_undef.inc> |
770 | |