def.pb.cc 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658
  1. // Generated by the protocol buffer compiler. DO NOT EDIT!
  2. // source: def.proto
  3. #include "def.pb.h"
  4. #include <algorithm>
  5. #include <google/protobuf/stubs/common.h>
  6. #include <google/protobuf/stubs/port.h>
  7. #include <google/protobuf/io/coded_stream.h>
  8. #include <google/protobuf/wire_format_lite_inl.h>
  9. #include <google/protobuf/descriptor.h>
  10. #include <google/protobuf/generated_message_reflection.h>
  11. #include <google/protobuf/reflection_ops.h>
  12. #include <google/protobuf/wire_format.h>
  13. // This is a temporary google only hack
  14. #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
  15. #include "third_party/protobuf/version.h"
  16. #endif
  17. // @@protoc_insertion_point(includes)
  18. namespace JetStream {
  19. class RequestCmdDefaultTypeInternal {
  20. public:
  21. ::google::protobuf::internal::ExplicitlyConstructed<RequestCmd>
  22. _instance;
  23. } _RequestCmd_default_instance_;
  24. class ResponseDefaultTypeInternal {
  25. public:
  26. ::google::protobuf::internal::ExplicitlyConstructed<Response>
  27. _instance;
  28. } _Response_default_instance_;
  29. } // namespace JetStream
  30. namespace protobuf_def_2eproto {
  31. static void InitDefaultsRequestCmd() {
  32. GOOGLE_PROTOBUF_VERIFY_VERSION;
  33. {
  34. void* ptr = &::JetStream::_RequestCmd_default_instance_;
  35. new (ptr) ::JetStream::RequestCmd();
  36. ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
  37. }
  38. ::JetStream::RequestCmd::InitAsDefaultInstance();
  39. }
  40. ::google::protobuf::internal::SCCInfo<0> scc_info_RequestCmd =
  41. {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsRequestCmd}, {}};
  42. static void InitDefaultsResponse() {
  43. GOOGLE_PROTOBUF_VERIFY_VERSION;
  44. {
  45. void* ptr = &::JetStream::_Response_default_instance_;
  46. new (ptr) ::JetStream::Response();
  47. ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
  48. }
  49. ::JetStream::Response::InitAsDefaultInstance();
  50. }
  51. ::google::protobuf::internal::SCCInfo<0> scc_info_Response =
  52. {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsResponse}, {}};
  53. void InitDefaults() {
  54. ::google::protobuf::internal::InitSCC(&scc_info_RequestCmd.base);
  55. ::google::protobuf::internal::InitSCC(&scc_info_Response.base);
  56. }
  57. ::google::protobuf::Metadata file_level_metadata[2];
  58. const ::google::protobuf::uint32 TableStruct::offsets[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
  59. ~0u, // no _has_bits_
  60. GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::JetStream::RequestCmd, _internal_metadata_),
  61. ~0u, // no _extensions_
  62. ~0u, // no _oneof_case_
  63. ~0u, // no _weak_field_map_
  64. GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::JetStream::RequestCmd, action_),
  65. ~0u, // no _has_bits_
  66. GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::JetStream::Response, _internal_metadata_),
  67. ~0u, // no _extensions_
  68. ~0u, // no _oneof_case_
  69. ~0u, // no _weak_field_map_
  70. GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::JetStream::Response, ret_),
  71. GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::JetStream::Response, info_),
  72. };
  73. static const ::google::protobuf::internal::MigrationSchema schemas[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
  74. { 0, -1, sizeof(::JetStream::RequestCmd)},
  75. { 6, -1, sizeof(::JetStream::Response)},
  76. };
  77. static ::google::protobuf::Message const * const file_default_instances[] = {
  78. reinterpret_cast<const ::google::protobuf::Message*>(&::JetStream::_RequestCmd_default_instance_),
  79. reinterpret_cast<const ::google::protobuf::Message*>(&::JetStream::_Response_default_instance_),
  80. };
  81. void protobuf_AssignDescriptors() {
  82. AddDescriptors();
  83. AssignDescriptors(
  84. "def.proto", schemas, file_default_instances, TableStruct::offsets,
  85. file_level_metadata, NULL, NULL);
  86. }
  87. void protobuf_AssignDescriptorsOnce() {
  88. static ::google::protobuf::internal::once_flag once;
  89. ::google::protobuf::internal::call_once(once, protobuf_AssignDescriptors);
  90. }
  91. void protobuf_RegisterTypes(const ::std::string&) GOOGLE_PROTOBUF_ATTRIBUTE_COLD;
  92. void protobuf_RegisterTypes(const ::std::string&) {
  93. protobuf_AssignDescriptorsOnce();
  94. ::google::protobuf::internal::RegisterAllTypes(file_level_metadata, 2);
  95. }
  96. void AddDescriptorsImpl() {
  97. InitDefaults();
  98. static const char descriptor[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
  99. "\n\tdef.proto\022\tJetStream\"\034\n\nRequestCmd\022\016\n\006"
  100. "action\030\001 \001(\005\"%\n\010Response\022\013\n\003ret\030\001 \001(\005\022\014\n"
  101. "\004info\030\002 \001(\t2L\n\nNavExcutor\022>\n\014DetectStrea"
  102. "m\022\025.JetStream.RequestCmd\032\023.JetStream.Res"
  103. "ponse\"\0000\001b\006proto3"
  104. };
  105. ::google::protobuf::DescriptorPool::InternalAddGeneratedFile(
  106. descriptor, 177);
  107. ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(
  108. "def.proto", &protobuf_RegisterTypes);
  109. }
  110. void AddDescriptors() {
  111. static ::google::protobuf::internal::once_flag once;
  112. ::google::protobuf::internal::call_once(once, AddDescriptorsImpl);
  113. }
  114. // Force AddDescriptors() to be called at dynamic initialization time.
  115. struct StaticDescriptorInitializer {
  116. StaticDescriptorInitializer() {
  117. AddDescriptors();
  118. }
  119. } static_descriptor_initializer;
  120. } // namespace protobuf_def_2eproto
  121. namespace JetStream {
  122. // ===================================================================
  123. void RequestCmd::InitAsDefaultInstance() {
  124. }
  125. #if !defined(_MSC_VER) || _MSC_VER >= 1900
  126. const int RequestCmd::kActionFieldNumber;
  127. #endif // !defined(_MSC_VER) || _MSC_VER >= 1900
  128. RequestCmd::RequestCmd()
  129. : ::google::protobuf::Message(), _internal_metadata_(NULL) {
  130. ::google::protobuf::internal::InitSCC(
  131. &protobuf_def_2eproto::scc_info_RequestCmd.base);
  132. SharedCtor();
  133. // @@protoc_insertion_point(constructor:JetStream.RequestCmd)
  134. }
  135. RequestCmd::RequestCmd(const RequestCmd& from)
  136. : ::google::protobuf::Message(),
  137. _internal_metadata_(NULL) {
  138. _internal_metadata_.MergeFrom(from._internal_metadata_);
  139. action_ = from.action_;
  140. // @@protoc_insertion_point(copy_constructor:JetStream.RequestCmd)
  141. }
  142. void RequestCmd::SharedCtor() {
  143. action_ = 0;
  144. }
  145. RequestCmd::~RequestCmd() {
  146. // @@protoc_insertion_point(destructor:JetStream.RequestCmd)
  147. SharedDtor();
  148. }
  149. void RequestCmd::SharedDtor() {
  150. }
  151. void RequestCmd::SetCachedSize(int size) const {
  152. _cached_size_.Set(size);
  153. }
  154. const ::google::protobuf::Descriptor* RequestCmd::descriptor() {
  155. ::protobuf_def_2eproto::protobuf_AssignDescriptorsOnce();
  156. return ::protobuf_def_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
  157. }
  158. const RequestCmd& RequestCmd::default_instance() {
  159. ::google::protobuf::internal::InitSCC(&protobuf_def_2eproto::scc_info_RequestCmd.base);
  160. return *internal_default_instance();
  161. }
  162. void RequestCmd::Clear() {
  163. // @@protoc_insertion_point(message_clear_start:JetStream.RequestCmd)
  164. ::google::protobuf::uint32 cached_has_bits = 0;
  165. // Prevent compiler warnings about cached_has_bits being unused
  166. (void) cached_has_bits;
  167. action_ = 0;
  168. _internal_metadata_.Clear();
  169. }
  170. bool RequestCmd::MergePartialFromCodedStream(
  171. ::google::protobuf::io::CodedInputStream* input) {
  172. #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
  173. ::google::protobuf::uint32 tag;
  174. // @@protoc_insertion_point(parse_start:JetStream.RequestCmd)
  175. for (;;) {
  176. ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
  177. tag = p.first;
  178. if (!p.second) goto handle_unusual;
  179. switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
  180. // int32 action = 1;
  181. case 1: {
  182. if (static_cast< ::google::protobuf::uint8>(tag) ==
  183. static_cast< ::google::protobuf::uint8>(8u /* 8 & 0xFF */)) {
  184. DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
  185. ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>(
  186. input, &action_)));
  187. } else {
  188. goto handle_unusual;
  189. }
  190. break;
  191. }
  192. default: {
  193. handle_unusual:
  194. if (tag == 0) {
  195. goto success;
  196. }
  197. DO_(::google::protobuf::internal::WireFormat::SkipField(
  198. input, tag, _internal_metadata_.mutable_unknown_fields()));
  199. break;
  200. }
  201. }
  202. }
  203. success:
  204. // @@protoc_insertion_point(parse_success:JetStream.RequestCmd)
  205. return true;
  206. failure:
  207. // @@protoc_insertion_point(parse_failure:JetStream.RequestCmd)
  208. return false;
  209. #undef DO_
  210. }
  211. void RequestCmd::SerializeWithCachedSizes(
  212. ::google::protobuf::io::CodedOutputStream* output) const {
  213. // @@protoc_insertion_point(serialize_start:JetStream.RequestCmd)
  214. ::google::protobuf::uint32 cached_has_bits = 0;
  215. (void) cached_has_bits;
  216. // int32 action = 1;
  217. if (this->action() != 0) {
  218. ::google::protobuf::internal::WireFormatLite::WriteInt32(1, this->action(), output);
  219. }
  220. if ((_internal_metadata_.have_unknown_fields() && ::google::protobuf::internal::GetProto3PreserveUnknownsDefault())) {
  221. ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
  222. (::google::protobuf::internal::GetProto3PreserveUnknownsDefault() ? _internal_metadata_.unknown_fields() : _internal_metadata_.default_instance()), output);
  223. }
  224. // @@protoc_insertion_point(serialize_end:JetStream.RequestCmd)
  225. }
  226. ::google::protobuf::uint8* RequestCmd::InternalSerializeWithCachedSizesToArray(
  227. bool deterministic, ::google::protobuf::uint8* target) const {
  228. (void)deterministic; // Unused
  229. // @@protoc_insertion_point(serialize_to_array_start:JetStream.RequestCmd)
  230. ::google::protobuf::uint32 cached_has_bits = 0;
  231. (void) cached_has_bits;
  232. // int32 action = 1;
  233. if (this->action() != 0) {
  234. target = ::google::protobuf::internal::WireFormatLite::WriteInt32ToArray(1, this->action(), target);
  235. }
  236. if ((_internal_metadata_.have_unknown_fields() && ::google::protobuf::internal::GetProto3PreserveUnknownsDefault())) {
  237. target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
  238. (::google::protobuf::internal::GetProto3PreserveUnknownsDefault() ? _internal_metadata_.unknown_fields() : _internal_metadata_.default_instance()), target);
  239. }
  240. // @@protoc_insertion_point(serialize_to_array_end:JetStream.RequestCmd)
  241. return target;
  242. }
  243. size_t RequestCmd::ByteSizeLong() const {
  244. // @@protoc_insertion_point(message_byte_size_start:JetStream.RequestCmd)
  245. size_t total_size = 0;
  246. if ((_internal_metadata_.have_unknown_fields() && ::google::protobuf::internal::GetProto3PreserveUnknownsDefault())) {
  247. total_size +=
  248. ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
  249. (::google::protobuf::internal::GetProto3PreserveUnknownsDefault() ? _internal_metadata_.unknown_fields() : _internal_metadata_.default_instance()));
  250. }
  251. // int32 action = 1;
  252. if (this->action() != 0) {
  253. total_size += 1 +
  254. ::google::protobuf::internal::WireFormatLite::Int32Size(
  255. this->action());
  256. }
  257. int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
  258. SetCachedSize(cached_size);
  259. return total_size;
  260. }
  261. void RequestCmd::MergeFrom(const ::google::protobuf::Message& from) {
  262. // @@protoc_insertion_point(generalized_merge_from_start:JetStream.RequestCmd)
  263. GOOGLE_DCHECK_NE(&from, this);
  264. const RequestCmd* source =
  265. ::google::protobuf::internal::DynamicCastToGenerated<const RequestCmd>(
  266. &from);
  267. if (source == NULL) {
  268. // @@protoc_insertion_point(generalized_merge_from_cast_fail:JetStream.RequestCmd)
  269. ::google::protobuf::internal::ReflectionOps::Merge(from, this);
  270. } else {
  271. // @@protoc_insertion_point(generalized_merge_from_cast_success:JetStream.RequestCmd)
  272. MergeFrom(*source);
  273. }
  274. }
  275. void RequestCmd::MergeFrom(const RequestCmd& from) {
  276. // @@protoc_insertion_point(class_specific_merge_from_start:JetStream.RequestCmd)
  277. GOOGLE_DCHECK_NE(&from, this);
  278. _internal_metadata_.MergeFrom(from._internal_metadata_);
  279. ::google::protobuf::uint32 cached_has_bits = 0;
  280. (void) cached_has_bits;
  281. if (from.action() != 0) {
  282. set_action(from.action());
  283. }
  284. }
  285. void RequestCmd::CopyFrom(const ::google::protobuf::Message& from) {
  286. // @@protoc_insertion_point(generalized_copy_from_start:JetStream.RequestCmd)
  287. if (&from == this) return;
  288. Clear();
  289. MergeFrom(from);
  290. }
  291. void RequestCmd::CopyFrom(const RequestCmd& from) {
  292. // @@protoc_insertion_point(class_specific_copy_from_start:JetStream.RequestCmd)
  293. if (&from == this) return;
  294. Clear();
  295. MergeFrom(from);
  296. }
  297. bool RequestCmd::IsInitialized() const {
  298. return true;
  299. }
  300. void RequestCmd::Swap(RequestCmd* other) {
  301. if (other == this) return;
  302. InternalSwap(other);
  303. }
  304. void RequestCmd::InternalSwap(RequestCmd* other) {
  305. using std::swap;
  306. swap(action_, other->action_);
  307. _internal_metadata_.Swap(&other->_internal_metadata_);
  308. }
  309. ::google::protobuf::Metadata RequestCmd::GetMetadata() const {
  310. protobuf_def_2eproto::protobuf_AssignDescriptorsOnce();
  311. return ::protobuf_def_2eproto::file_level_metadata[kIndexInFileMessages];
  312. }
  313. // ===================================================================
  314. void Response::InitAsDefaultInstance() {
  315. }
  316. #if !defined(_MSC_VER) || _MSC_VER >= 1900
  317. const int Response::kRetFieldNumber;
  318. const int Response::kInfoFieldNumber;
  319. #endif // !defined(_MSC_VER) || _MSC_VER >= 1900
  320. Response::Response()
  321. : ::google::protobuf::Message(), _internal_metadata_(NULL) {
  322. ::google::protobuf::internal::InitSCC(
  323. &protobuf_def_2eproto::scc_info_Response.base);
  324. SharedCtor();
  325. // @@protoc_insertion_point(constructor:JetStream.Response)
  326. }
  327. Response::Response(const Response& from)
  328. : ::google::protobuf::Message(),
  329. _internal_metadata_(NULL) {
  330. _internal_metadata_.MergeFrom(from._internal_metadata_);
  331. info_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  332. if (from.info().size() > 0) {
  333. info_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.info_);
  334. }
  335. ret_ = from.ret_;
  336. // @@protoc_insertion_point(copy_constructor:JetStream.Response)
  337. }
  338. void Response::SharedCtor() {
  339. info_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  340. ret_ = 0;
  341. }
  342. Response::~Response() {
  343. // @@protoc_insertion_point(destructor:JetStream.Response)
  344. SharedDtor();
  345. }
  346. void Response::SharedDtor() {
  347. info_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  348. }
  349. void Response::SetCachedSize(int size) const {
  350. _cached_size_.Set(size);
  351. }
  352. const ::google::protobuf::Descriptor* Response::descriptor() {
  353. ::protobuf_def_2eproto::protobuf_AssignDescriptorsOnce();
  354. return ::protobuf_def_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
  355. }
  356. const Response& Response::default_instance() {
  357. ::google::protobuf::internal::InitSCC(&protobuf_def_2eproto::scc_info_Response.base);
  358. return *internal_default_instance();
  359. }
  360. void Response::Clear() {
  361. // @@protoc_insertion_point(message_clear_start:JetStream.Response)
  362. ::google::protobuf::uint32 cached_has_bits = 0;
  363. // Prevent compiler warnings about cached_has_bits being unused
  364. (void) cached_has_bits;
  365. info_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  366. ret_ = 0;
  367. _internal_metadata_.Clear();
  368. }
  369. bool Response::MergePartialFromCodedStream(
  370. ::google::protobuf::io::CodedInputStream* input) {
  371. #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
  372. ::google::protobuf::uint32 tag;
  373. // @@protoc_insertion_point(parse_start:JetStream.Response)
  374. for (;;) {
  375. ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
  376. tag = p.first;
  377. if (!p.second) goto handle_unusual;
  378. switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
  379. // int32 ret = 1;
  380. case 1: {
  381. if (static_cast< ::google::protobuf::uint8>(tag) ==
  382. static_cast< ::google::protobuf::uint8>(8u /* 8 & 0xFF */)) {
  383. DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
  384. ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>(
  385. input, &ret_)));
  386. } else {
  387. goto handle_unusual;
  388. }
  389. break;
  390. }
  391. // string info = 2;
  392. case 2: {
  393. if (static_cast< ::google::protobuf::uint8>(tag) ==
  394. static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) {
  395. DO_(::google::protobuf::internal::WireFormatLite::ReadString(
  396. input, this->mutable_info()));
  397. DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String(
  398. this->info().data(), static_cast<int>(this->info().length()),
  399. ::google::protobuf::internal::WireFormatLite::PARSE,
  400. "JetStream.Response.info"));
  401. } else {
  402. goto handle_unusual;
  403. }
  404. break;
  405. }
  406. default: {
  407. handle_unusual:
  408. if (tag == 0) {
  409. goto success;
  410. }
  411. DO_(::google::protobuf::internal::WireFormat::SkipField(
  412. input, tag, _internal_metadata_.mutable_unknown_fields()));
  413. break;
  414. }
  415. }
  416. }
  417. success:
  418. // @@protoc_insertion_point(parse_success:JetStream.Response)
  419. return true;
  420. failure:
  421. // @@protoc_insertion_point(parse_failure:JetStream.Response)
  422. return false;
  423. #undef DO_
  424. }
  425. void Response::SerializeWithCachedSizes(
  426. ::google::protobuf::io::CodedOutputStream* output) const {
  427. // @@protoc_insertion_point(serialize_start:JetStream.Response)
  428. ::google::protobuf::uint32 cached_has_bits = 0;
  429. (void) cached_has_bits;
  430. // int32 ret = 1;
  431. if (this->ret() != 0) {
  432. ::google::protobuf::internal::WireFormatLite::WriteInt32(1, this->ret(), output);
  433. }
  434. // string info = 2;
  435. if (this->info().size() > 0) {
  436. ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(
  437. this->info().data(), static_cast<int>(this->info().length()),
  438. ::google::protobuf::internal::WireFormatLite::SERIALIZE,
  439. "JetStream.Response.info");
  440. ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(
  441. 2, this->info(), output);
  442. }
  443. if ((_internal_metadata_.have_unknown_fields() && ::google::protobuf::internal::GetProto3PreserveUnknownsDefault())) {
  444. ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
  445. (::google::protobuf::internal::GetProto3PreserveUnknownsDefault() ? _internal_metadata_.unknown_fields() : _internal_metadata_.default_instance()), output);
  446. }
  447. // @@protoc_insertion_point(serialize_end:JetStream.Response)
  448. }
  449. ::google::protobuf::uint8* Response::InternalSerializeWithCachedSizesToArray(
  450. bool deterministic, ::google::protobuf::uint8* target) const {
  451. (void)deterministic; // Unused
  452. // @@protoc_insertion_point(serialize_to_array_start:JetStream.Response)
  453. ::google::protobuf::uint32 cached_has_bits = 0;
  454. (void) cached_has_bits;
  455. // int32 ret = 1;
  456. if (this->ret() != 0) {
  457. target = ::google::protobuf::internal::WireFormatLite::WriteInt32ToArray(1, this->ret(), target);
  458. }
  459. // string info = 2;
  460. if (this->info().size() > 0) {
  461. ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(
  462. this->info().data(), static_cast<int>(this->info().length()),
  463. ::google::protobuf::internal::WireFormatLite::SERIALIZE,
  464. "JetStream.Response.info");
  465. target =
  466. ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
  467. 2, this->info(), target);
  468. }
  469. if ((_internal_metadata_.have_unknown_fields() && ::google::protobuf::internal::GetProto3PreserveUnknownsDefault())) {
  470. target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
  471. (::google::protobuf::internal::GetProto3PreserveUnknownsDefault() ? _internal_metadata_.unknown_fields() : _internal_metadata_.default_instance()), target);
  472. }
  473. // @@protoc_insertion_point(serialize_to_array_end:JetStream.Response)
  474. return target;
  475. }
  476. size_t Response::ByteSizeLong() const {
  477. // @@protoc_insertion_point(message_byte_size_start:JetStream.Response)
  478. size_t total_size = 0;
  479. if ((_internal_metadata_.have_unknown_fields() && ::google::protobuf::internal::GetProto3PreserveUnknownsDefault())) {
  480. total_size +=
  481. ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
  482. (::google::protobuf::internal::GetProto3PreserveUnknownsDefault() ? _internal_metadata_.unknown_fields() : _internal_metadata_.default_instance()));
  483. }
  484. // string info = 2;
  485. if (this->info().size() > 0) {
  486. total_size += 1 +
  487. ::google::protobuf::internal::WireFormatLite::StringSize(
  488. this->info());
  489. }
  490. // int32 ret = 1;
  491. if (this->ret() != 0) {
  492. total_size += 1 +
  493. ::google::protobuf::internal::WireFormatLite::Int32Size(
  494. this->ret());
  495. }
  496. int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
  497. SetCachedSize(cached_size);
  498. return total_size;
  499. }
  500. void Response::MergeFrom(const ::google::protobuf::Message& from) {
  501. // @@protoc_insertion_point(generalized_merge_from_start:JetStream.Response)
  502. GOOGLE_DCHECK_NE(&from, this);
  503. const Response* source =
  504. ::google::protobuf::internal::DynamicCastToGenerated<const Response>(
  505. &from);
  506. if (source == NULL) {
  507. // @@protoc_insertion_point(generalized_merge_from_cast_fail:JetStream.Response)
  508. ::google::protobuf::internal::ReflectionOps::Merge(from, this);
  509. } else {
  510. // @@protoc_insertion_point(generalized_merge_from_cast_success:JetStream.Response)
  511. MergeFrom(*source);
  512. }
  513. }
  514. void Response::MergeFrom(const Response& from) {
  515. // @@protoc_insertion_point(class_specific_merge_from_start:JetStream.Response)
  516. GOOGLE_DCHECK_NE(&from, this);
  517. _internal_metadata_.MergeFrom(from._internal_metadata_);
  518. ::google::protobuf::uint32 cached_has_bits = 0;
  519. (void) cached_has_bits;
  520. if (from.info().size() > 0) {
  521. info_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.info_);
  522. }
  523. if (from.ret() != 0) {
  524. set_ret(from.ret());
  525. }
  526. }
  527. void Response::CopyFrom(const ::google::protobuf::Message& from) {
  528. // @@protoc_insertion_point(generalized_copy_from_start:JetStream.Response)
  529. if (&from == this) return;
  530. Clear();
  531. MergeFrom(from);
  532. }
  533. void Response::CopyFrom(const Response& from) {
  534. // @@protoc_insertion_point(class_specific_copy_from_start:JetStream.Response)
  535. if (&from == this) return;
  536. Clear();
  537. MergeFrom(from);
  538. }
  539. bool Response::IsInitialized() const {
  540. return true;
  541. }
  542. void Response::Swap(Response* other) {
  543. if (other == this) return;
  544. InternalSwap(other);
  545. }
  546. void Response::InternalSwap(Response* other) {
  547. using std::swap;
  548. info_.Swap(&other->info_, &::google::protobuf::internal::GetEmptyStringAlreadyInited(),
  549. GetArenaNoVirtual());
  550. swap(ret_, other->ret_);
  551. _internal_metadata_.Swap(&other->_internal_metadata_);
  552. }
  553. ::google::protobuf::Metadata Response::GetMetadata() const {
  554. protobuf_def_2eproto::protobuf_AssignDescriptorsOnce();
  555. return ::protobuf_def_2eproto::file_level_metadata[kIndexInFileMessages];
  556. }
  557. // @@protoc_insertion_point(namespace_scope)
  558. } // namespace JetStream
  559. namespace google {
  560. namespace protobuf {
  561. template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::JetStream::RequestCmd* Arena::CreateMaybeMessage< ::JetStream::RequestCmd >(Arena* arena) {
  562. return Arena::CreateInternal< ::JetStream::RequestCmd >(arena);
  563. }
  564. template<> GOOGLE_PROTOBUF_ATTRIBUTE_NOINLINE ::JetStream::Response* Arena::CreateMaybeMessage< ::JetStream::Response >(Arena* arena) {
  565. return Arena::CreateInternal< ::JetStream::Response >(arena);
  566. }
  567. } // namespace protobuf
  568. } // namespace google
  569. // @@protoc_insertion_point(global_scope)