1// Generated by the protocol buffer compiler. DO NOT EDIT!
2// source: tensorflow/core/protobuf/queue_runner.proto
3
4#include "tensorflow/core/protobuf/queue_runner.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 QueueRunnerDefDefaultTypeInternal {
20 public:
21 ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<QueueRunnerDef> _instance;
22} _QueueRunnerDef_default_instance_;
23} // namespace tensorflow
24static void InitDefaultsscc_info_QueueRunnerDef_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto() {
25 GOOGLE_PROTOBUF_VERIFY_VERSION;
26
27 {
28 void* ptr = &::tensorflow::_QueueRunnerDef_default_instance_;
29 new (ptr) ::tensorflow::QueueRunnerDef();
30 ::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
31 }
32 ::tensorflow::QueueRunnerDef::InitAsDefaultInstance();
33}
34
35::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_QueueRunnerDef_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto =
36 {{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsscc_info_QueueRunnerDef_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto}, {}};
37
38static ::PROTOBUF_NAMESPACE_ID::Metadata file_level_metadata_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto[1];
39static constexpr ::PROTOBUF_NAMESPACE_ID::EnumDescriptor const** file_level_enum_descriptors_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto = nullptr;
40static constexpr ::PROTOBUF_NAMESPACE_ID::ServiceDescriptor const** file_level_service_descriptors_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto = nullptr;
41
42const ::PROTOBUF_NAMESPACE_ID::uint32 TableStruct_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
43 ~0u, // no _has_bits_
44 PROTOBUF_FIELD_OFFSET(::tensorflow::QueueRunnerDef, _internal_metadata_),
45 ~0u, // no _extensions_
46 ~0u, // no _oneof_case_
47 ~0u, // no _weak_field_map_
48 PROTOBUF_FIELD_OFFSET(::tensorflow::QueueRunnerDef, queue_name_),
49 PROTOBUF_FIELD_OFFSET(::tensorflow::QueueRunnerDef, enqueue_op_name_),
50 PROTOBUF_FIELD_OFFSET(::tensorflow::QueueRunnerDef, close_op_name_),
51 PROTOBUF_FIELD_OFFSET(::tensorflow::QueueRunnerDef, cancel_op_name_),
52 PROTOBUF_FIELD_OFFSET(::tensorflow::QueueRunnerDef, queue_closed_exception_types_),
53};
54static const ::PROTOBUF_NAMESPACE_ID::internal::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
55 { 0, -1, sizeof(::tensorflow::QueueRunnerDef)},
56};
57
58static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] = {
59 reinterpret_cast<const ::PROTOBUF_NAMESPACE_ID::Message*>(&::tensorflow::_QueueRunnerDef_default_instance_),
60};
61
62const char descriptor_table_protodef_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) =
63 "\n+tensorflow/core/protobuf/queue_runner."
64 "proto\022\ntensorflow\032*tensorflow/core/proto"
65 "buf/error_codes.proto\"\252\001\n\016QueueRunnerDef"
66 "\022\022\n\nqueue_name\030\001 \001(\t\022\027\n\017enqueue_op_name\030"
67 "\002 \003(\t\022\025\n\rclose_op_name\030\003 \001(\t\022\026\n\016cancel_o"
68 "p_name\030\004 \001(\t\022<\n\034queue_closed_exception_t"
69 "ypes\030\005 \003(\0162\026.tensorflow.error.CodeB\211\001\n\030o"
70 "rg.tensorflow.frameworkB\021QueueRunnerProt"
71 "osP\001ZUgithub.com/tensorflow/tensorflow/t"
72 "ensorflow/go/core/protobuf/for_core_prot"
73 "os_go_proto\370\001\001b\006proto3"
74 ;
75static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto_deps[1] = {
76 &::descriptor_table_tensorflow_2fcore_2fprotobuf_2ferror_5fcodes_2eproto,
77};
78static ::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase*const descriptor_table_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto_sccs[1] = {
79 &scc_info_QueueRunnerDef_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto.base,
80};
81static ::PROTOBUF_NAMESPACE_ID::internal::once_flag descriptor_table_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto_once;
82static bool descriptor_table_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto_initialized = false;
83const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto = {
84 &descriptor_table_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto_initialized, descriptor_table_protodef_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto, "tensorflow/core/protobuf/queue_runner.proto", 422,
85 &descriptor_table_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto_once, descriptor_table_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto_sccs, descriptor_table_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto_deps, 1, 1,
86 schemas, file_default_instances, TableStruct_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto::offsets,
87 file_level_metadata_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto, 1, file_level_enum_descriptors_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto, file_level_service_descriptors_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto,
88};
89
90// Force running AddDescriptors() at dynamic initialization time.
91static bool dynamic_init_dummy_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto = ( ::PROTOBUF_NAMESPACE_ID::internal::AddDescriptors(&descriptor_table_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto), true);
92namespace tensorflow {
93
94// ===================================================================
95
96void QueueRunnerDef::InitAsDefaultInstance() {
97}
98class QueueRunnerDef::_Internal {
99 public:
100};
101
102QueueRunnerDef::QueueRunnerDef()
103 : ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr) {
104 SharedCtor();
105 // @@protoc_insertion_point(constructor:tensorflow.QueueRunnerDef)
106}
107QueueRunnerDef::QueueRunnerDef(::PROTOBUF_NAMESPACE_ID::Arena* arena)
108 : ::PROTOBUF_NAMESPACE_ID::Message(),
109 _internal_metadata_(arena),
110 enqueue_op_name_(arena),
111 queue_closed_exception_types_(arena) {
112 SharedCtor();
113 RegisterArenaDtor(arena);
114 // @@protoc_insertion_point(arena_constructor:tensorflow.QueueRunnerDef)
115}
116QueueRunnerDef::QueueRunnerDef(const QueueRunnerDef& from)
117 : ::PROTOBUF_NAMESPACE_ID::Message(),
118 _internal_metadata_(nullptr),
119 enqueue_op_name_(from.enqueue_op_name_),
120 queue_closed_exception_types_(from.queue_closed_exception_types_) {
121 _internal_metadata_.MergeFrom(from._internal_metadata_);
122 queue_name_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
123 if (!from.queue_name().empty()) {
124 queue_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.queue_name(),
125 GetArenaNoVirtual());
126 }
127 close_op_name_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
128 if (!from.close_op_name().empty()) {
129 close_op_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.close_op_name(),
130 GetArenaNoVirtual());
131 }
132 cancel_op_name_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
133 if (!from.cancel_op_name().empty()) {
134 cancel_op_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.cancel_op_name(),
135 GetArenaNoVirtual());
136 }
137 // @@protoc_insertion_point(copy_constructor:tensorflow.QueueRunnerDef)
138}
139
140void QueueRunnerDef::SharedCtor() {
141 ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_QueueRunnerDef_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto.base);
142 queue_name_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
143 close_op_name_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
144 cancel_op_name_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
145}
146
147QueueRunnerDef::~QueueRunnerDef() {
148 // @@protoc_insertion_point(destructor:tensorflow.QueueRunnerDef)
149 SharedDtor();
150}
151
152void QueueRunnerDef::SharedDtor() {
153 GOOGLE_DCHECK(GetArenaNoVirtual() == nullptr);
154 queue_name_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
155 close_op_name_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
156 cancel_op_name_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
157}
158
159void QueueRunnerDef::ArenaDtor(void* object) {
160 QueueRunnerDef* _this = reinterpret_cast< QueueRunnerDef* >(object);
161 (void)_this;
162}
163void QueueRunnerDef::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) {
164}
165void QueueRunnerDef::SetCachedSize(int size) const {
166 _cached_size_.Set(size);
167}
168const QueueRunnerDef& QueueRunnerDef::default_instance() {
169 ::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_QueueRunnerDef_tensorflow_2fcore_2fprotobuf_2fqueue_5frunner_2eproto.base);
170 return *internal_default_instance();
171}
172
173
174void QueueRunnerDef::Clear() {
175// @@protoc_insertion_point(message_clear_start:tensorflow.QueueRunnerDef)
176 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
177 // Prevent compiler warnings about cached_has_bits being unused
178 (void) cached_has_bits;
179
180 enqueue_op_name_.Clear();
181 queue_closed_exception_types_.Clear();
182 queue_name_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArenaNoVirtual());
183 close_op_name_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArenaNoVirtual());
184 cancel_op_name_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArenaNoVirtual());
185 _internal_metadata_.Clear();
186}
187
188#if GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
189const char* QueueRunnerDef::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) {
190#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
191 ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArenaNoVirtual(); (void)arena;
192 while (!ctx->Done(&ptr)) {
193 ::PROTOBUF_NAMESPACE_ID::uint32 tag;
194 ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag);
195 CHK_(ptr);
196 switch (tag >> 3) {
197 // string queue_name = 1;
198 case 1:
199 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
200 ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(mutable_queue_name(), ptr, ctx, "tensorflow.QueueRunnerDef.queue_name");
201 CHK_(ptr);
202 } else goto handle_unusual;
203 continue;
204 // repeated string enqueue_op_name = 2;
205 case 2:
206 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) {
207 ptr -= 1;
208 do {
209 ptr += 1;
210 ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(add_enqueue_op_name(), ptr, ctx, "tensorflow.QueueRunnerDef.enqueue_op_name");
211 CHK_(ptr);
212 if (!ctx->DataAvailable(ptr)) break;
213 } while (::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<::PROTOBUF_NAMESPACE_ID::uint8>(ptr) == 18);
214 } else goto handle_unusual;
215 continue;
216 // string close_op_name = 3;
217 case 3:
218 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 26)) {
219 ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(mutable_close_op_name(), ptr, ctx, "tensorflow.QueueRunnerDef.close_op_name");
220 CHK_(ptr);
221 } else goto handle_unusual;
222 continue;
223 // string cancel_op_name = 4;
224 case 4:
225 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 34)) {
226 ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParserUTF8(mutable_cancel_op_name(), ptr, ctx, "tensorflow.QueueRunnerDef.cancel_op_name");
227 CHK_(ptr);
228 } else goto handle_unusual;
229 continue;
230 // repeated .tensorflow.error.Code queue_closed_exception_types = 5;
231 case 5:
232 if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 42)) {
233 ptr = ::PROTOBUF_NAMESPACE_ID::internal::PackedEnumParser(mutable_queue_closed_exception_types(), ptr, ctx);
234 CHK_(ptr);
235 } else if (static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 40) {
236 ::PROTOBUF_NAMESPACE_ID::uint64 val = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr);
237 CHK_(ptr);
238 add_queue_closed_exception_types(static_cast<::tensorflow::error::Code>(val));
239 } else goto handle_unusual;
240 continue;
241 default: {
242 handle_unusual:
243 if ((tag & 7) == 4 || tag == 0) {
244 ctx->SetLastTag(tag);
245 goto success;
246 }
247 ptr = UnknownFieldParse(tag, &_internal_metadata_, ptr, ctx);
248 CHK_(ptr != nullptr);
249 continue;
250 }
251 } // switch
252 } // while
253success:
254 return ptr;
255failure:
256 ptr = nullptr;
257 goto success;
258#undef CHK_
259}
260#else // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
261bool QueueRunnerDef::MergePartialFromCodedStream(
262 ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream* input) {
263#define DO_(EXPRESSION) if (!PROTOBUF_PREDICT_TRUE(EXPRESSION)) goto failure
264 ::PROTOBUF_NAMESPACE_ID::uint32 tag;
265 // @@protoc_insertion_point(parse_start:tensorflow.QueueRunnerDef)
266 for (;;) {
267 ::std::pair<::PROTOBUF_NAMESPACE_ID::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
268 tag = p.first;
269 if (!p.second) goto handle_unusual;
270 switch (::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::GetTagFieldNumber(tag)) {
271 // string queue_name = 1;
272 case 1: {
273 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (10 & 0xFF)) {
274 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString(
275 input, this->mutable_queue_name()));
276 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
277 this->queue_name().data(), static_cast<int>(this->queue_name().length()),
278 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE,
279 "tensorflow.QueueRunnerDef.queue_name"));
280 } else {
281 goto handle_unusual;
282 }
283 break;
284 }
285
286 // repeated string enqueue_op_name = 2;
287 case 2: {
288 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (18 & 0xFF)) {
289 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString(
290 input, this->add_enqueue_op_name()));
291 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
292 this->enqueue_op_name(this->enqueue_op_name_size() - 1).data(),
293 static_cast<int>(this->enqueue_op_name(this->enqueue_op_name_size() - 1).length()),
294 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE,
295 "tensorflow.QueueRunnerDef.enqueue_op_name"));
296 } else {
297 goto handle_unusual;
298 }
299 break;
300 }
301
302 // string close_op_name = 3;
303 case 3: {
304 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (26 & 0xFF)) {
305 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString(
306 input, this->mutable_close_op_name()));
307 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
308 this->close_op_name().data(), static_cast<int>(this->close_op_name().length()),
309 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE,
310 "tensorflow.QueueRunnerDef.close_op_name"));
311 } else {
312 goto handle_unusual;
313 }
314 break;
315 }
316
317 // string cancel_op_name = 4;
318 case 4: {
319 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (34 & 0xFF)) {
320 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadString(
321 input, this->mutable_cancel_op_name()));
322 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
323 this->cancel_op_name().data(), static_cast<int>(this->cancel_op_name().length()),
324 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE,
325 "tensorflow.QueueRunnerDef.cancel_op_name"));
326 } else {
327 goto handle_unusual;
328 }
329 break;
330 }
331
332 // repeated .tensorflow.error.Code queue_closed_exception_types = 5;
333 case 5: {
334 if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (42 & 0xFF)) {
335 ::PROTOBUF_NAMESPACE_ID::uint32 length;
336 DO_(input->ReadVarint32(&length));
337 ::PROTOBUF_NAMESPACE_ID::io::CodedInputStream::Limit limit = input->PushLimit(static_cast<int>(length));
338 while (input->BytesUntilLimit() > 0) {
339 int value = 0;
340 DO_((::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadPrimitive<
341 int, ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_ENUM>(
342 input, &value)));
343 add_queue_closed_exception_types(static_cast< ::tensorflow::error::Code >(value));
344 }
345 input->PopLimit(limit);
346 } else if (static_cast< ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (40 & 0xFF)) {
347 int value = 0;
348 DO_((::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadPrimitive<
349 int, ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_ENUM>(
350 input, &value)));
351 add_queue_closed_exception_types(static_cast< ::tensorflow::error::Code >(value));
352 } else {
353 goto handle_unusual;
354 }
355 break;
356 }
357
358 default: {
359 handle_unusual:
360 if (tag == 0) {
361 goto success;
362 }
363 DO_(::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SkipField(
364 input, tag, _internal_metadata_.mutable_unknown_fields()));
365 break;
366 }
367 }
368 }
369success:
370 // @@protoc_insertion_point(parse_success:tensorflow.QueueRunnerDef)
371 return true;
372failure:
373 // @@protoc_insertion_point(parse_failure:tensorflow.QueueRunnerDef)
374 return false;
375#undef DO_
376}
377#endif // GOOGLE_PROTOBUF_ENABLE_EXPERIMENTAL_PARSER
378
379void QueueRunnerDef::SerializeWithCachedSizes(
380 ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream* output) const {
381 // @@protoc_insertion_point(serialize_start:tensorflow.QueueRunnerDef)
382 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
383 (void) cached_has_bits;
384
385 // string queue_name = 1;
386 if (this->queue_name().size() > 0) {
387 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
388 this->queue_name().data(), static_cast<int>(this->queue_name().length()),
389 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
390 "tensorflow.QueueRunnerDef.queue_name");
391 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringMaybeAliased(
392 1, this->queue_name(), output);
393 }
394
395 // repeated string enqueue_op_name = 2;
396 for (int i = 0, n = this->enqueue_op_name_size(); i < n; i++) {
397 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
398 this->enqueue_op_name(i).data(), static_cast<int>(this->enqueue_op_name(i).length()),
399 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
400 "tensorflow.QueueRunnerDef.enqueue_op_name");
401 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteString(
402 2, this->enqueue_op_name(i), output);
403 }
404
405 // string close_op_name = 3;
406 if (this->close_op_name().size() > 0) {
407 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
408 this->close_op_name().data(), static_cast<int>(this->close_op_name().length()),
409 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
410 "tensorflow.QueueRunnerDef.close_op_name");
411 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringMaybeAliased(
412 3, this->close_op_name(), output);
413 }
414
415 // string cancel_op_name = 4;
416 if (this->cancel_op_name().size() > 0) {
417 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
418 this->cancel_op_name().data(), static_cast<int>(this->cancel_op_name().length()),
419 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
420 "tensorflow.QueueRunnerDef.cancel_op_name");
421 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringMaybeAliased(
422 4, this->cancel_op_name(), output);
423 }
424
425 // repeated .tensorflow.error.Code queue_closed_exception_types = 5;
426 if (this->queue_closed_exception_types_size() > 0) {
427 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteTag(
428 5,
429 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED,
430 output);
431 output->WriteVarint32(_queue_closed_exception_types_cached_byte_size_.load(
432 std::memory_order_relaxed));
433 }
434 for (int i = 0, n = this->queue_closed_exception_types_size(); i < n; i++) {
435 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteEnumNoTag(
436 this->queue_closed_exception_types(i), output);
437 }
438
439 if (_internal_metadata_.have_unknown_fields()) {
440 ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields(
441 _internal_metadata_.unknown_fields(), output);
442 }
443 // @@protoc_insertion_point(serialize_end:tensorflow.QueueRunnerDef)
444}
445
446::PROTOBUF_NAMESPACE_ID::uint8* QueueRunnerDef::InternalSerializeWithCachedSizesToArray(
447 ::PROTOBUF_NAMESPACE_ID::uint8* target) const {
448 // @@protoc_insertion_point(serialize_to_array_start:tensorflow.QueueRunnerDef)
449 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
450 (void) cached_has_bits;
451
452 // string queue_name = 1;
453 if (this->queue_name().size() > 0) {
454 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
455 this->queue_name().data(), static_cast<int>(this->queue_name().length()),
456 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
457 "tensorflow.QueueRunnerDef.queue_name");
458 target =
459 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringToArray(
460 1, this->queue_name(), target);
461 }
462
463 // repeated string enqueue_op_name = 2;
464 for (int i = 0, n = this->enqueue_op_name_size(); i < n; i++) {
465 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
466 this->enqueue_op_name(i).data(), static_cast<int>(this->enqueue_op_name(i).length()),
467 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
468 "tensorflow.QueueRunnerDef.enqueue_op_name");
469 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
470 WriteStringToArray(2, this->enqueue_op_name(i), target);
471 }
472
473 // string close_op_name = 3;
474 if (this->close_op_name().size() > 0) {
475 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
476 this->close_op_name().data(), static_cast<int>(this->close_op_name().length()),
477 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
478 "tensorflow.QueueRunnerDef.close_op_name");
479 target =
480 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringToArray(
481 3, this->close_op_name(), target);
482 }
483
484 // string cancel_op_name = 4;
485 if (this->cancel_op_name().size() > 0) {
486 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
487 this->cancel_op_name().data(), static_cast<int>(this->cancel_op_name().length()),
488 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
489 "tensorflow.QueueRunnerDef.cancel_op_name");
490 target =
491 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteStringToArray(
492 4, this->cancel_op_name(), target);
493 }
494
495 // repeated .tensorflow.error.Code queue_closed_exception_types = 5;
496 if (this->queue_closed_exception_types_size() > 0) {
497 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteTagToArray(
498 5,
499 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED,
500 target);
501 target = ::PROTOBUF_NAMESPACE_ID::io::CodedOutputStream::WriteVarint32ToArray( _queue_closed_exception_types_cached_byte_size_.load(std::memory_order_relaxed),
502 target);
503 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteEnumNoTagToArray(
504 this->queue_closed_exception_types_, target);
505 }
506
507 if (_internal_metadata_.have_unknown_fields()) {
508 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray(
509 _internal_metadata_.unknown_fields(), target);
510 }
511 // @@protoc_insertion_point(serialize_to_array_end:tensorflow.QueueRunnerDef)
512 return target;
513}
514
515size_t QueueRunnerDef::ByteSizeLong() const {
516// @@protoc_insertion_point(message_byte_size_start:tensorflow.QueueRunnerDef)
517 size_t total_size = 0;
518
519 if (_internal_metadata_.have_unknown_fields()) {
520 total_size +=
521 ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::ComputeUnknownFieldsSize(
522 _internal_metadata_.unknown_fields());
523 }
524 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
525 // Prevent compiler warnings about cached_has_bits being unused
526 (void) cached_has_bits;
527
528 // repeated string enqueue_op_name = 2;
529 total_size += 1 *
530 ::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(this->enqueue_op_name_size());
531 for (int i = 0, n = this->enqueue_op_name_size(); i < n; i++) {
532 total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
533 this->enqueue_op_name(i));
534 }
535
536 // repeated .tensorflow.error.Code queue_closed_exception_types = 5;
537 {
538 size_t data_size = 0;
539 unsigned int count = static_cast<unsigned int>(this->queue_closed_exception_types_size());for (unsigned int i = 0; i < count; i++) {
540 data_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::EnumSize(
541 this->queue_closed_exception_types(static_cast<int>(i)));
542 }
543 if (data_size > 0) {
544 total_size += 1 +
545 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::Int32Size(
546 static_cast<::PROTOBUF_NAMESPACE_ID::int32>(data_size));
547 }
548 int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(data_size);
549 _queue_closed_exception_types_cached_byte_size_.store(cached_size,
550 std::memory_order_relaxed);
551 total_size += data_size;
552 }
553
554 // string queue_name = 1;
555 if (this->queue_name().size() > 0) {
556 total_size += 1 +
557 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
558 this->queue_name());
559 }
560
561 // string close_op_name = 3;
562 if (this->close_op_name().size() > 0) {
563 total_size += 1 +
564 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
565 this->close_op_name());
566 }
567
568 // string cancel_op_name = 4;
569 if (this->cancel_op_name().size() > 0) {
570 total_size += 1 +
571 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
572 this->cancel_op_name());
573 }
574
575 int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
576 SetCachedSize(cached_size);
577 return total_size;
578}
579
580void QueueRunnerDef::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
581// @@protoc_insertion_point(generalized_merge_from_start:tensorflow.QueueRunnerDef)
582 GOOGLE_DCHECK_NE(&from, this);
583 const QueueRunnerDef* source =
584 ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated<QueueRunnerDef>(
585 &from);
586 if (source == nullptr) {
587 // @@protoc_insertion_point(generalized_merge_from_cast_fail:tensorflow.QueueRunnerDef)
588 ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this);
589 } else {
590 // @@protoc_insertion_point(generalized_merge_from_cast_success:tensorflow.QueueRunnerDef)
591 MergeFrom(*source);
592 }
593}
594
595void QueueRunnerDef::MergeFrom(const QueueRunnerDef& from) {
596// @@protoc_insertion_point(class_specific_merge_from_start:tensorflow.QueueRunnerDef)
597 GOOGLE_DCHECK_NE(&from, this);
598 _internal_metadata_.MergeFrom(from._internal_metadata_);
599 ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
600 (void) cached_has_bits;
601
602 enqueue_op_name_.MergeFrom(from.enqueue_op_name_);
603 queue_closed_exception_types_.MergeFrom(from.queue_closed_exception_types_);
604 if (from.queue_name().size() > 0) {
605 set_queue_name(from.queue_name());
606 }
607 if (from.close_op_name().size() > 0) {
608 set_close_op_name(from.close_op_name());
609 }
610 if (from.cancel_op_name().size() > 0) {
611 set_cancel_op_name(from.cancel_op_name());
612 }
613}
614
615void QueueRunnerDef::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) {
616// @@protoc_insertion_point(generalized_copy_from_start:tensorflow.QueueRunnerDef)
617 if (&from == this) return;
618 Clear();
619 MergeFrom(from);
620}
621
622void QueueRunnerDef::CopyFrom(const QueueRunnerDef& from) {
623// @@protoc_insertion_point(class_specific_copy_from_start:tensorflow.QueueRunnerDef)
624 if (&from == this) return;
625 Clear();
626 MergeFrom(from);
627}
628
629bool QueueRunnerDef::IsInitialized() const {
630 return true;
631}
632
633void QueueRunnerDef::InternalSwap(QueueRunnerDef* other) {
634 using std::swap;
635 _internal_metadata_.Swap(&other->_internal_metadata_);
636 enqueue_op_name_.InternalSwap(CastToBase(&other->enqueue_op_name_));
637 queue_closed_exception_types_.InternalSwap(&other->queue_closed_exception_types_);
638 queue_name_.Swap(&other->queue_name_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
639 GetArenaNoVirtual());
640 close_op_name_.Swap(&other->close_op_name_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
641 GetArenaNoVirtual());
642 cancel_op_name_.Swap(&other->cancel_op_name_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
643 GetArenaNoVirtual());
644}
645
646::PROTOBUF_NAMESPACE_ID::Metadata QueueRunnerDef::GetMetadata() const {
647 return GetMetadataStatic();
648}
649
650
651// @@protoc_insertion_point(namespace_scope)
652} // namespace tensorflow
653PROTOBUF_NAMESPACE_OPEN
654template<> PROTOBUF_NOINLINE ::tensorflow::QueueRunnerDef* Arena::CreateMaybeMessage< ::tensorflow::QueueRunnerDef >(Arena* arena) {
655 return Arena::CreateMessageInternal< ::tensorflow::QueueRunnerDef >(arena);
656}
657PROTOBUF_NAMESPACE_CLOSE
658
659// @@protoc_insertion_point(global_scope)
660#include <google/protobuf/port_undef.inc>
661