diff --git a/Makefile b/Makefile index 3ffa103..1b9aed4 100644 --- a/Makefile +++ b/Makefile @@ -89,8 +89,9 @@ NORMAL_UNINSTALL = : PRE_UNINSTALL = : POST_UNINSTALL = : sbin_PROGRAMS = helmetd$(EXEEXT) -noinst_PROGRAMS = udpclient_test$(EXEEXT) service_test$(EXEEXT) \ - tunclient_test$(EXEEXT) message_test$(EXEEXT) +noinst_PROGRAMS = tcpclient_test$(EXEEXT) udpclient_test$(EXEEXT) \ + service_test$(EXEEXT) tunclient_test$(EXEEXT) \ + message_test$(EXEEXT) subdir = . ACLOCAL_M4 = $(top_srcdir)/aclocal.m4 am__aclocal_m4_deps = $(top_srcdir)/configure.ac @@ -108,7 +109,8 @@ am__installdirs = "$(DESTDIR)$(sbindir)" PROGRAMS = $(noinst_PROGRAMS) $(sbin_PROGRAMS) am_helmetd_OBJECTS = helmetd.$(OBJEXT) tunclient.$(OBJEXT) \ service.$(OBJEXT) interface.$(OBJEXT) hello.pb.$(OBJEXT) \ - udpclient.$(OBJEXT) resolver.$(OBJEXT) iprouter.$(OBJEXT) + udpclient.$(OBJEXT) resolver.$(OBJEXT) iprouter.$(OBJEXT) \ + tcpclient.$(OBJEXT) rpcclient.$(OBJEXT) helmetd_OBJECTS = $(am_helmetd_OBJECTS) helmetd_LDADD = $(LDADD) am_message_test_OBJECTS = message_test.$(OBJEXT) hello.pb.$(OBJEXT) @@ -118,6 +120,10 @@ am_service_test_OBJECTS = service_test.$(OBJEXT) tunclient.$(OBJEXT) \ service.$(OBJEXT) interface.$(OBJEXT) service_test_OBJECTS = $(am_service_test_OBJECTS) service_test_LDADD = $(LDADD) +am_tcpclient_test_OBJECTS = resolver.$(OBJEXT) tcpclient.$(OBJEXT) \ + tcpclient_test.$(OBJEXT) +tcpclient_test_OBJECTS = $(am_tcpclient_test_OBJECTS) +tcpclient_test_LDADD = $(LDADD) am_tunclient_test_OBJECTS = tunclient_test.$(OBJEXT) \ tunclient.$(OBJEXT) service.$(OBJEXT) interface.$(OBJEXT) tunclient_test_OBJECTS = $(am_tunclient_test_OBJECTS) @@ -167,11 +173,11 @@ am__v_CCLD_ = $(am__v_CCLD_$(AM_DEFAULT_VERBOSITY)) am__v_CCLD_0 = @echo " CCLD " $@; am__v_CCLD_1 = SOURCES = $(helmetd_SOURCES) $(message_test_SOURCES) \ - $(service_test_SOURCES) $(tunclient_test_SOURCES) \ - $(udpclient_test_SOURCES) + $(service_test_SOURCES) $(tcpclient_test_SOURCES) \ + $(tunclient_test_SOURCES) $(udpclient_test_SOURCES) DIST_SOURCES = $(helmetd_SOURCES) $(message_test_SOURCES) \ - $(service_test_SOURCES) $(tunclient_test_SOURCES) \ - $(udpclient_test_SOURCES) + $(service_test_SOURCES) $(tcpclient_test_SOURCES) \ + $(tunclient_test_SOURCES) $(udpclient_test_SOURCES) am__can_run_installinfo = \ case $$AM_UPDATE_INFO_DIR in \ n|no|NO) false;; \ @@ -251,7 +257,7 @@ INSTALL_SCRIPT = ${INSTALL} INSTALL_STRIP_PROGRAM = $(install_sh) -c -s LDFLAGS = -pthread LIBOBJS = -LIBS = -Wl,--as-need -lprotobuf-lite +LIBS = -Wl,--as-need -lprotobuf LTLIBOBJS = MAKEINFO = ${SHELL} '/home/ziggi/Projects/tcpserv09/missing' makeinfo MKDIR_P = /bin/mkdir -p @@ -324,7 +330,9 @@ helmetd_SOURCES = helmetd.cpp \ hello.pb.cc hello.pb.h \ udpclient.cpp udpclient.hpp \ resolver.cpp resolver.hpp \ - iprouter.cpp iprouter.hpp + iprouter.cpp iprouter.hpp \ + tcpclient.cpp tcpclient.hpp \ + rpcclient.cpp rpcclient.hpp tunclient_test_SOURCES = tunclient_test.cpp \ tunclient.cpp tunclient.hpp \ @@ -341,6 +349,11 @@ udpclient_test_SOURCES = \ udpclient.cpp udpclient.hpp \ udpclient_test.cpp +tcpclient_test_SOURCES = \ + resolver.cpp resolver.hpp \ + tcpclient.cpp tcpclient.hpp \ + tcpclient_test.cpp + message_test_SOURCES = message_test.cpp \ hello.pb.cc hello.pb.h @@ -456,6 +469,10 @@ service_test$(EXEEXT): $(service_test_OBJECTS) $(service_test_DEPENDENCIES) $(EX @rm -f service_test$(EXEEXT) $(AM_V_CXXLD)$(CXXLINK) $(service_test_OBJECTS) $(service_test_LDADD) $(LIBS) +tcpclient_test$(EXEEXT): $(tcpclient_test_OBJECTS) $(tcpclient_test_DEPENDENCIES) $(EXTRA_tcpclient_test_DEPENDENCIES) + @rm -f tcpclient_test$(EXEEXT) + $(AM_V_CXXLD)$(CXXLINK) $(tcpclient_test_OBJECTS) $(tcpclient_test_LDADD) $(LIBS) + tunclient_test$(EXEEXT): $(tunclient_test_OBJECTS) $(tunclient_test_DEPENDENCIES) $(EXTRA_tunclient_test_DEPENDENCIES) @rm -f tunclient_test$(EXEEXT) $(AM_V_CXXLD)$(CXXLINK) $(tunclient_test_OBJECTS) $(tunclient_test_LDADD) $(LIBS) diff --git a/Makefile.am b/Makefile.am index 464d4a0..cc5289d 100644 --- a/Makefile.am +++ b/Makefile.am @@ -3,7 +3,7 @@ AUTOMAKE_OPTIONS = foreign no-dependencies no-installinfo subdir-objects CXXFLAGS = -std=c++23 -Wall -I. -pthread -D_GNU_SOURCE=1 LDFLAGS = -pthread -LIBS = -Wl,--as-need -lprotobuf-lite +LIBS = -Wl,--as-need -lprotobuf sbin_PROGRAMS = helmetd @@ -14,9 +14,13 @@ helmetd_SOURCES = helmetd.cpp \ hello.pb.cc hello.pb.h \ udpclient.cpp udpclient.hpp \ resolver.cpp resolver.hpp \ - iprouter.cpp iprouter.hpp + iprouter.cpp iprouter.hpp \ + tcpclient.cpp tcpclient.hpp \ + rpcclient.cpp rpcclient.hpp + noinst_PROGRAMS = \ + tcpclient_test \ udpclient_test \ service_test \ tunclient_test \ @@ -38,6 +42,12 @@ udpclient_test_SOURCES = \ udpclient.cpp udpclient.hpp \ udpclient_test.cpp +tcpclient_test_SOURCES = \ + resolver.cpp resolver.hpp \ + tcpclient.cpp tcpclient.hpp \ + tcpclient_test.cpp + + message_test_SOURCES = message_test.cpp \ hello.pb.cc hello.pb.h diff --git a/Makefile.in b/Makefile.in index 2a15e10..1c6c9e9 100644 --- a/Makefile.in +++ b/Makefile.in @@ -89,8 +89,9 @@ NORMAL_UNINSTALL = : PRE_UNINSTALL = : POST_UNINSTALL = : sbin_PROGRAMS = helmetd$(EXEEXT) -noinst_PROGRAMS = udpclient_test$(EXEEXT) service_test$(EXEEXT) \ - tunclient_test$(EXEEXT) message_test$(EXEEXT) +noinst_PROGRAMS = tcpclient_test$(EXEEXT) udpclient_test$(EXEEXT) \ + service_test$(EXEEXT) tunclient_test$(EXEEXT) \ + message_test$(EXEEXT) subdir = . ACLOCAL_M4 = $(top_srcdir)/aclocal.m4 am__aclocal_m4_deps = $(top_srcdir)/configure.ac @@ -108,7 +109,8 @@ am__installdirs = "$(DESTDIR)$(sbindir)" PROGRAMS = $(noinst_PROGRAMS) $(sbin_PROGRAMS) am_helmetd_OBJECTS = helmetd.$(OBJEXT) tunclient.$(OBJEXT) \ service.$(OBJEXT) interface.$(OBJEXT) hello.pb.$(OBJEXT) \ - udpclient.$(OBJEXT) resolver.$(OBJEXT) iprouter.$(OBJEXT) + udpclient.$(OBJEXT) resolver.$(OBJEXT) iprouter.$(OBJEXT) \ + tcpclient.$(OBJEXT) rpcclient.$(OBJEXT) helmetd_OBJECTS = $(am_helmetd_OBJECTS) helmetd_LDADD = $(LDADD) am_message_test_OBJECTS = message_test.$(OBJEXT) hello.pb.$(OBJEXT) @@ -118,6 +120,10 @@ am_service_test_OBJECTS = service_test.$(OBJEXT) tunclient.$(OBJEXT) \ service.$(OBJEXT) interface.$(OBJEXT) service_test_OBJECTS = $(am_service_test_OBJECTS) service_test_LDADD = $(LDADD) +am_tcpclient_test_OBJECTS = resolver.$(OBJEXT) tcpclient.$(OBJEXT) \ + tcpclient_test.$(OBJEXT) +tcpclient_test_OBJECTS = $(am_tcpclient_test_OBJECTS) +tcpclient_test_LDADD = $(LDADD) am_tunclient_test_OBJECTS = tunclient_test.$(OBJEXT) \ tunclient.$(OBJEXT) service.$(OBJEXT) interface.$(OBJEXT) tunclient_test_OBJECTS = $(am_tunclient_test_OBJECTS) @@ -167,11 +173,11 @@ am__v_CCLD_ = $(am__v_CCLD_@AM_DEFAULT_V@) am__v_CCLD_0 = @echo " CCLD " $@; am__v_CCLD_1 = SOURCES = $(helmetd_SOURCES) $(message_test_SOURCES) \ - $(service_test_SOURCES) $(tunclient_test_SOURCES) \ - $(udpclient_test_SOURCES) + $(service_test_SOURCES) $(tcpclient_test_SOURCES) \ + $(tunclient_test_SOURCES) $(udpclient_test_SOURCES) DIST_SOURCES = $(helmetd_SOURCES) $(message_test_SOURCES) \ - $(service_test_SOURCES) $(tunclient_test_SOURCES) \ - $(udpclient_test_SOURCES) + $(service_test_SOURCES) $(tcpclient_test_SOURCES) \ + $(tunclient_test_SOURCES) $(udpclient_test_SOURCES) am__can_run_installinfo = \ case $$AM_UPDATE_INFO_DIR in \ n|no|NO) false;; \ @@ -251,7 +257,7 @@ INSTALL_SCRIPT = @INSTALL_SCRIPT@ INSTALL_STRIP_PROGRAM = @INSTALL_STRIP_PROGRAM@ LDFLAGS = -pthread LIBOBJS = @LIBOBJS@ -LIBS = -Wl,--as-need -lprotobuf-lite +LIBS = -Wl,--as-need -lprotobuf LTLIBOBJS = @LTLIBOBJS@ MAKEINFO = @MAKEINFO@ MKDIR_P = @MKDIR_P@ @@ -324,7 +330,9 @@ helmetd_SOURCES = helmetd.cpp \ hello.pb.cc hello.pb.h \ udpclient.cpp udpclient.hpp \ resolver.cpp resolver.hpp \ - iprouter.cpp iprouter.hpp + iprouter.cpp iprouter.hpp \ + tcpclient.cpp tcpclient.hpp \ + rpcclient.cpp rpcclient.hpp tunclient_test_SOURCES = tunclient_test.cpp \ tunclient.cpp tunclient.hpp \ @@ -341,6 +349,11 @@ udpclient_test_SOURCES = \ udpclient.cpp udpclient.hpp \ udpclient_test.cpp +tcpclient_test_SOURCES = \ + resolver.cpp resolver.hpp \ + tcpclient.cpp tcpclient.hpp \ + tcpclient_test.cpp + message_test_SOURCES = message_test.cpp \ hello.pb.cc hello.pb.h @@ -456,6 +469,10 @@ service_test$(EXEEXT): $(service_test_OBJECTS) $(service_test_DEPENDENCIES) $(EX @rm -f service_test$(EXEEXT) $(AM_V_CXXLD)$(CXXLINK) $(service_test_OBJECTS) $(service_test_LDADD) $(LIBS) +tcpclient_test$(EXEEXT): $(tcpclient_test_OBJECTS) $(tcpclient_test_DEPENDENCIES) $(EXTRA_tcpclient_test_DEPENDENCIES) + @rm -f tcpclient_test$(EXEEXT) + $(AM_V_CXXLD)$(CXXLINK) $(tcpclient_test_OBJECTS) $(tcpclient_test_LDADD) $(LIBS) + tunclient_test$(EXEEXT): $(tunclient_test_OBJECTS) $(tunclient_test_DEPENDENCIES) $(EXTRA_tunclient_test_DEPENDENCIES) @rm -f tunclient_test$(EXEEXT) $(AM_V_CXXLD)$(CXXLINK) $(tunclient_test_OBJECTS) $(tunclient_test_LDADD) $(LIBS) diff --git a/header.cpp b/header.cpp new file mode 100644 index 0000000..8dff1e8 --- /dev/null +++ b/header.cpp @@ -0,0 +1,49 @@ + +extern "C" { +#include +} + +#include +#include +#include +#include +#include +#include + +#include + +Header::Header(const uint32_t ipSize) { + pSize = ipSize; +} + +Header::Header(void) { + pSize = 0; +} + +std::string Header::Encode() { + std::string buffer, tmp; + auto magic = htonl(MAGIC); + tmp = std::string(reinterpret_cast(&magic), sizeof(magic)); + buffer.append(tmp); + + auto size = htonl(pSize); + tmp = std::string(reinterpret_cast(&size), sizeof(size)); + buffer.append(tmp); + return buffer; +} + +std::expected Header::Decode(const std::string rawHeader) { + uint32_t tmp; + std::memcpy(&tmp, rawHeader.data(), sizeof(uint32_t)); + auto magic = ntohl(tmp); + if (magic != MAGIC) { + return std::unexpected("Wrong magic code"); + } + std::memcpy(&tmp, rawHeader.data() + sizeof(uint32_t), sizeof(uint32_t)); + pSize = ntohl(tmp); + return {}; +} + +uint32_t Header::PacketSize() { + return pSize; +} diff --git a/header.hpp b/header.hpp new file mode 100644 index 0000000..5849e0b --- /dev/null +++ b/header.hpp @@ -0,0 +1,16 @@ + +#include + +const uint32_t MAGIC = 0xABBA; + +class Header { +private: + uint32_t pSize = 0; +public: + Header(const uint32_t pSize); + Header(void); + std::string Encode(void); + std::expected Decode(const std::string buffer); + uint32_t PacketSize(void); +}; + diff --git a/header_test.cpp b/header_test.cpp new file mode 100644 index 0000000..025b9e8 --- /dev/null +++ b/header_test.cpp @@ -0,0 +1,20 @@ + +#include +#include +#include +#include +#include + +#include + +int main(int argc, char** argv) { + uint32_t size = + Header primary(1021); + auto rawHeader = primary.Encode(); + + Header second; + second.Decode(rawHeader); + + std::cout << std::format("{}\n", second.PacketSize()); + assert +} diff --git a/hello.pb.cc b/hello.pb.cc index 6942fd6..a6e827a 100644 --- a/hello.pb.cc +++ b/hello.pb.cc @@ -8,7 +8,10 @@ #include #include #include -#include +#include +#include +#include +#include // @@protoc_insertion_point(includes) #include @@ -19,741 +22,816 @@ namespace _pbi = _pb::internal; namespace control { PROTOBUF_CONSTEXPR Header::Header( - ::_pbi::ConstantInitialized): _impl_{ - /*decltype(_impl_.meta_)*/nullptr - , /*decltype(_impl_._cached_size_)*/{}} {} + ::_pbi::ConstantInitialized): _impl_{ + /*decltype(_impl_.meta_)*/nullptr + , /*decltype(_impl_._cached_size_)*/{}} {} struct HeaderDefaultTypeInternal { - PROTOBUF_CONSTEXPR HeaderDefaultTypeInternal() - : _instance(::_pbi::ConstantInitialized{}) {} - ~HeaderDefaultTypeInternal() {} - union { - Header _instance; - }; + PROTOBUF_CONSTEXPR HeaderDefaultTypeInternal() + : _instance(::_pbi::ConstantInitialized{}) {} + ~HeaderDefaultTypeInternal() {} + union { + Header _instance; + }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 HeaderDefaultTypeInternal _Header_default_instance_; PROTOBUF_CONSTEXPR Meta::Meta( - ::_pbi::ConstantInitialized): _impl_{ - /*decltype(_impl_.rpcname_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} - , /*decltype(_impl_._cached_size_)*/{}} {} + ::_pbi::ConstantInitialized): _impl_{ + /*decltype(_impl_.rpcname_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} + , /*decltype(_impl_._cached_size_)*/{}} {} struct MetaDefaultTypeInternal { - PROTOBUF_CONSTEXPR MetaDefaultTypeInternal() - : _instance(::_pbi::ConstantInitialized{}) {} - ~MetaDefaultTypeInternal() {} - union { - Meta _instance; - }; + PROTOBUF_CONSTEXPR MetaDefaultTypeInternal() + : _instance(::_pbi::ConstantInitialized{}) {} + ~MetaDefaultTypeInternal() {} + union { + Meta _instance; + }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 MetaDefaultTypeInternal _Meta_default_instance_; PROTOBUF_CONSTEXPR Hello::Hello( - ::_pbi::ConstantInitialized): _impl_{ - /*decltype(_impl_.name_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} - , /*decltype(_impl_.meta_)*/nullptr - , /*decltype(_impl_.id_)*/0 - , /*decltype(_impl_._cached_size_)*/{}} {} + ::_pbi::ConstantInitialized): _impl_{ + /*decltype(_impl_.name_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} + , /*decltype(_impl_.meta_)*/nullptr + , /*decltype(_impl_.id_)*/0 + , /*decltype(_impl_._cached_size_)*/{}} {} struct HelloDefaultTypeInternal { - PROTOBUF_CONSTEXPR HelloDefaultTypeInternal() - : _instance(::_pbi::ConstantInitialized{}) {} - ~HelloDefaultTypeInternal() {} - union { - Hello _instance; - }; + PROTOBUF_CONSTEXPR HelloDefaultTypeInternal() + : _instance(::_pbi::ConstantInitialized{}) {} + ~HelloDefaultTypeInternal() {} + union { + Hello _instance; + }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 HelloDefaultTypeInternal _Hello_default_instance_; } // namespace control +static ::_pb::Metadata file_level_metadata_hello_2eproto[3]; +static constexpr ::_pb::EnumDescriptor const** file_level_enum_descriptors_hello_2eproto = nullptr; +static constexpr ::_pb::ServiceDescriptor const** file_level_service_descriptors_hello_2eproto = nullptr; + +const uint32_t TableStruct_hello_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = { + ~0u, // no _has_bits_ + PROTOBUF_FIELD_OFFSET(::control::Header, _internal_metadata_), + ~0u, // no _extensions_ + ~0u, // no _oneof_case_ + ~0u, // no _weak_field_map_ + ~0u, // no _inlined_string_donated_ + PROTOBUF_FIELD_OFFSET(::control::Header, _impl_.meta_), + ~0u, // no _has_bits_ + PROTOBUF_FIELD_OFFSET(::control::Meta, _internal_metadata_), + ~0u, // no _extensions_ + ~0u, // no _oneof_case_ + ~0u, // no _weak_field_map_ + ~0u, // no _inlined_string_donated_ + PROTOBUF_FIELD_OFFSET(::control::Meta, _impl_.rpcname_), + ~0u, // no _has_bits_ + PROTOBUF_FIELD_OFFSET(::control::Hello, _internal_metadata_), + ~0u, // no _extensions_ + ~0u, // no _oneof_case_ + ~0u, // no _weak_field_map_ + ~0u, // no _inlined_string_donated_ + PROTOBUF_FIELD_OFFSET(::control::Hello, _impl_.meta_), + PROTOBUF_FIELD_OFFSET(::control::Hello, _impl_.id_), + PROTOBUF_FIELD_OFFSET(::control::Hello, _impl_.name_), +}; +static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = { + { 0, -1, -1, sizeof(::control::Header)}, + { 7, -1, -1, sizeof(::control::Meta)}, + { 14, -1, -1, sizeof(::control::Hello)}, +}; + +static const ::_pb::Message* const file_default_instances[] = { + &::control::_Header_default_instance_._instance, + &::control::_Meta_default_instance_._instance, + &::control::_Hello_default_instance_._instance, +}; + +const char descriptor_table_protodef_hello_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = + "\n\013hello.proto\022\007control\"%\n\006Header\022\033\n\004meta" + "\030\001 \001(\0132\r.control.Meta\"\027\n\004Meta\022\017\n\007rpcname" + "\030\001 \001(\t\">\n\005Hello\022\033\n\004meta\030\001 \001(\0132\r.control." + "Meta\022\n\n\002id\030\002 \001(\005\022\014\n\004name\030\003 \001(\tb\006proto3" + ; +static ::_pbi::once_flag descriptor_table_hello_2eproto_once; +const ::_pbi::DescriptorTable descriptor_table_hello_2eproto = { + false, false, 158, descriptor_table_protodef_hello_2eproto, + "hello.proto", + &descriptor_table_hello_2eproto_once, nullptr, 0, 3, + schemas, file_default_instances, TableStruct_hello_2eproto::offsets, + file_level_metadata_hello_2eproto, file_level_enum_descriptors_hello_2eproto, + file_level_service_descriptors_hello_2eproto, +}; +PROTOBUF_ATTRIBUTE_WEAK const ::_pbi::DescriptorTable* descriptor_table_hello_2eproto_getter() { + return &descriptor_table_hello_2eproto; +} + +// Force running AddDescriptors() at dynamic initialization time. +PROTOBUF_ATTRIBUTE_INIT_PRIORITY2 static ::_pbi::AddDescriptorsRunner dynamic_init_dummy_hello_2eproto(&descriptor_table_hello_2eproto); namespace control { // =================================================================== class Header::_Internal { - public: - static const ::control::Meta& meta(const Header* msg); +public: + static const ::control::Meta& meta(const Header* msg); }; const ::control::Meta& Header::_Internal::meta(const Header* msg) { - return *msg->_impl_.meta_; + return *msg->_impl_.meta_; } Header::Header(::PROTOBUF_NAMESPACE_ID::Arena* arena, - bool is_message_owned) - : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) { - SharedCtor(arena, is_message_owned); - // @@protoc_insertion_point(arena_constructor:control.Header) + bool is_message_owned) + : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) { + SharedCtor(arena, is_message_owned); + // @@protoc_insertion_point(arena_constructor:control.Header) } Header::Header(const Header& from) - : ::PROTOBUF_NAMESPACE_ID::MessageLite() { - Header* const _this = this; (void)_this; - new (&_impl_) Impl_{ - decltype(_impl_.meta_){nullptr} - , /*decltype(_impl_._cached_size_)*/{}}; + : ::PROTOBUF_NAMESPACE_ID::Message() { + Header* const _this = this; + (void)_this; + new (&_impl_) Impl_{ + decltype(_impl_.meta_) { + nullptr + } + , /*decltype(_impl_._cached_size_)*/{}}; - _internal_metadata_.MergeFrom(from._internal_metadata_); - if (from._internal_has_meta()) { - _this->_impl_.meta_ = new ::control::Meta(*from._impl_.meta_); - } - // @@protoc_insertion_point(copy_constructor:control.Header) + _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); + if (from._internal_has_meta()) { + _this->_impl_.meta_ = new ::control::Meta(*from._impl_.meta_); + } + // @@protoc_insertion_point(copy_constructor:control.Header) } inline void Header::SharedCtor( - ::_pb::Arena* arena, bool is_message_owned) { - (void)arena; - (void)is_message_owned; - new (&_impl_) Impl_{ - decltype(_impl_.meta_){nullptr} - , /*decltype(_impl_._cached_size_)*/{} - }; + ::_pb::Arena* arena, bool is_message_owned) { + (void)arena; + (void)is_message_owned; + new (&_impl_) Impl_{ + decltype(_impl_.meta_) { + nullptr + } + , /*decltype(_impl_._cached_size_)*/{} + }; } Header::~Header() { - // @@protoc_insertion_point(destructor:control.Header) - if (auto *arena = _internal_metadata_.DeleteReturnArena()) { - (void)arena; - return; - } - SharedDtor(); + // @@protoc_insertion_point(destructor:control.Header) + if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) { + (void)arena; + return; + } + SharedDtor(); } inline void Header::SharedDtor() { - GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); - if (this != internal_default_instance()) delete _impl_.meta_; + GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); + if (this != internal_default_instance()) delete _impl_.meta_; } void Header::SetCachedSize(int size) const { - _impl_._cached_size_.Set(size); + _impl_._cached_size_.Set(size); } void Header::Clear() { // @@protoc_insertion_point(message_clear_start:control.Header) - uint32_t cached_has_bits = 0; - // Prevent compiler warnings about cached_has_bits being unused - (void) cached_has_bits; + uint32_t cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; - if (GetArenaForAllocation() == nullptr && _impl_.meta_ != nullptr) { - delete _impl_.meta_; - } - _impl_.meta_ = nullptr; - _internal_metadata_.Clear(); + if (GetArenaForAllocation() == nullptr && _impl_.meta_ != nullptr) { + delete _impl_.meta_; + } + _impl_.meta_ = nullptr; + _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } const char* Header::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure - while (!ctx->Done(&ptr)) { - uint32_t tag; - ptr = ::_pbi::ReadTag(ptr, &tag); - switch (tag >> 3) { - // .control.Meta meta = 1; - case 1: - if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 10)) { - ptr = ctx->ParseMessage(_internal_mutable_meta(), ptr); - CHK_(ptr); - } else - goto handle_unusual; - continue; - default: - goto handle_unusual; - } // switch - handle_unusual: - if ((tag == 0) || ((tag & 7) == 4)) { - CHK_(ptr); - ctx->SetLastTag(tag); - goto message_done; - } - ptr = UnknownFieldParse( - tag, - _internal_metadata_.mutable_unknown_fields(), - ptr, ctx); - CHK_(ptr != nullptr); - } // while + while (!ctx->Done(&ptr)) { + uint32_t tag; + ptr = ::_pbi::ReadTag(ptr, &tag); + switch (tag >> 3) { + // .control.Meta meta = 1; + case 1: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 10)) { + ptr = ctx->ParseMessage(_internal_mutable_meta(), ptr); + CHK_(ptr); + } else + goto handle_unusual; + continue; + default: + goto handle_unusual; + } // switch +handle_unusual: + if ((tag == 0) || ((tag & 7) == 4)) { + CHK_(ptr); + ctx->SetLastTag(tag); + goto message_done; + } + ptr = UnknownFieldParse( + tag, + _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), + ptr, ctx); + CHK_(ptr != nullptr); + } // while message_done: - return ptr; + return ptr; failure: - ptr = nullptr; - goto message_done; + ptr = nullptr; + goto message_done; #undef CHK_ } uint8_t* Header::_InternalSerialize( - uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { - // @@protoc_insertion_point(serialize_to_array_start:control.Header) - uint32_t cached_has_bits = 0; - (void) cached_has_bits; + uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { + // @@protoc_insertion_point(serialize_to_array_start:control.Header) + uint32_t cached_has_bits = 0; + (void) cached_has_bits; - // .control.Meta meta = 1; - if (this->_internal_has_meta()) { - target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: - InternalWriteMessage(1, _Internal::meta(this), - _Internal::meta(this).GetCachedSize(), target, stream); - } + // .control.Meta meta = 1; + if (this->_internal_has_meta()) { + target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: + InternalWriteMessage(1, _Internal::meta(this), + _Internal::meta(this).GetCachedSize(), target, stream); + } - if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { - target = stream->WriteRaw(_internal_metadata_.unknown_fields(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(), - static_cast(_internal_metadata_.unknown_fields(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target); - } - // @@protoc_insertion_point(serialize_to_array_end:control.Header) - return target; + if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { + target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray( + _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); + } + // @@protoc_insertion_point(serialize_to_array_end:control.Header) + return target; } size_t Header::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:control.Header) - size_t total_size = 0; + size_t total_size = 0; - uint32_t cached_has_bits = 0; - // Prevent compiler warnings about cached_has_bits being unused - (void) cached_has_bits; + uint32_t cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; - // .control.Meta meta = 1; - if (this->_internal_has_meta()) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( - *_impl_.meta_); - } + // .control.Meta meta = 1; + if (this->_internal_has_meta()) { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( + *_impl_.meta_); + } - if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { - total_size += _internal_metadata_.unknown_fields(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size(); - } - int cached_size = ::_pbi::ToCachedSize(total_size); - SetCachedSize(cached_size); - return total_size; + return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_); } -void Header::CheckTypeAndMergeFrom( - const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) { - MergeFrom(*::_pbi::DownCast( - &from)); +const ::PROTOBUF_NAMESPACE_ID::Message::ClassData Header::_class_data_ = { + ::PROTOBUF_NAMESPACE_ID::Message::CopyWithSourceCheck, + Header::MergeImpl +}; +const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*Header::GetClassData() const { + return &_class_data_; } -void Header::MergeFrom(const Header& from) { - Header* const _this = this; - // @@protoc_insertion_point(class_specific_merge_from_start:control.Header) - GOOGLE_DCHECK_NE(&from, _this); - uint32_t cached_has_bits = 0; - (void) cached_has_bits; - if (from._internal_has_meta()) { - _this->_internal_mutable_meta()->::control::Meta::MergeFrom( - from._internal_meta()); - } - _this->_internal_metadata_.MergeFrom(from._internal_metadata_); +void Header::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg) { + auto* const _this = static_cast(&to_msg); + auto& from = static_cast(from_msg); + // @@protoc_insertion_point(class_specific_merge_from_start:control.Header) + GOOGLE_DCHECK_NE(&from, _this); + uint32_t cached_has_bits = 0; + (void) cached_has_bits; + + if (from._internal_has_meta()) { + _this->_internal_mutable_meta()->::control::Meta::MergeFrom( + from._internal_meta()); + } + _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); } void Header::CopyFrom(const Header& from) { // @@protoc_insertion_point(class_specific_copy_from_start:control.Header) - if (&from == this) return; - Clear(); - MergeFrom(from); + if (&from == this) return; + Clear(); + MergeFrom(from); } bool Header::IsInitialized() const { - return true; + return true; } void Header::InternalSwap(Header* other) { - using std::swap; - _internal_metadata_.InternalSwap(&other->_internal_metadata_); - swap(_impl_.meta_, other->_impl_.meta_); + using std::swap; + _internal_metadata_.InternalSwap(&other->_internal_metadata_); + swap(_impl_.meta_, other->_impl_.meta_); } -std::string Header::GetTypeName() const { - return "control.Header"; +::PROTOBUF_NAMESPACE_ID::Metadata Header::GetMetadata() const { + return ::_pbi::AssignDescriptors( + &descriptor_table_hello_2eproto_getter, &descriptor_table_hello_2eproto_once, + file_level_metadata_hello_2eproto[0]); } - // =================================================================== class Meta::_Internal { - public: +public: }; Meta::Meta(::PROTOBUF_NAMESPACE_ID::Arena* arena, - bool is_message_owned) - : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) { - SharedCtor(arena, is_message_owned); - // @@protoc_insertion_point(arena_constructor:control.Meta) + bool is_message_owned) + : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) { + SharedCtor(arena, is_message_owned); + // @@protoc_insertion_point(arena_constructor:control.Meta) } Meta::Meta(const Meta& from) - : ::PROTOBUF_NAMESPACE_ID::MessageLite() { - Meta* const _this = this; (void)_this; - new (&_impl_) Impl_{ - decltype(_impl_.rpcname_){} - , /*decltype(_impl_._cached_size_)*/{}}; + : ::PROTOBUF_NAMESPACE_ID::Message() { + Meta* const _this = this; + (void)_this; + new (&_impl_) Impl_{ + decltype(_impl_.rpcname_) {} + , /*decltype(_impl_._cached_size_)*/{}}; - _internal_metadata_.MergeFrom(from._internal_metadata_); - _impl_.rpcname_.InitDefault(); - #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING - _impl_.rpcname_.Set("", GetArenaForAllocation()); - #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING - if (!from._internal_rpcname().empty()) { - _this->_impl_.rpcname_.Set(from._internal_rpcname(), - _this->GetArenaForAllocation()); - } - // @@protoc_insertion_point(copy_constructor:control.Meta) + _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); + _impl_.rpcname_.InitDefault(); +#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING + _impl_.rpcname_.Set("", GetArenaForAllocation()); +#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING + if (!from._internal_rpcname().empty()) { + _this->_impl_.rpcname_.Set(from._internal_rpcname(), + _this->GetArenaForAllocation()); + } + // @@protoc_insertion_point(copy_constructor:control.Meta) } inline void Meta::SharedCtor( - ::_pb::Arena* arena, bool is_message_owned) { - (void)arena; - (void)is_message_owned; - new (&_impl_) Impl_{ - decltype(_impl_.rpcname_){} - , /*decltype(_impl_._cached_size_)*/{} - }; - _impl_.rpcname_.InitDefault(); - #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING - _impl_.rpcname_.Set("", GetArenaForAllocation()); - #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING + ::_pb::Arena* arena, bool is_message_owned) { + (void)arena; + (void)is_message_owned; + new (&_impl_) Impl_{ + decltype(_impl_.rpcname_) {} + , /*decltype(_impl_._cached_size_)*/{} + }; + _impl_.rpcname_.InitDefault(); +#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING + _impl_.rpcname_.Set("", GetArenaForAllocation()); +#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING } Meta::~Meta() { - // @@protoc_insertion_point(destructor:control.Meta) - if (auto *arena = _internal_metadata_.DeleteReturnArena()) { - (void)arena; - return; - } - SharedDtor(); + // @@protoc_insertion_point(destructor:control.Meta) + if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) { + (void)arena; + return; + } + SharedDtor(); } inline void Meta::SharedDtor() { - GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); - _impl_.rpcname_.Destroy(); + GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); + _impl_.rpcname_.Destroy(); } void Meta::SetCachedSize(int size) const { - _impl_._cached_size_.Set(size); + _impl_._cached_size_.Set(size); } void Meta::Clear() { // @@protoc_insertion_point(message_clear_start:control.Meta) - uint32_t cached_has_bits = 0; - // Prevent compiler warnings about cached_has_bits being unused - (void) cached_has_bits; + uint32_t cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; - _impl_.rpcname_.ClearToEmpty(); - _internal_metadata_.Clear(); + _impl_.rpcname_.ClearToEmpty(); + _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } const char* Meta::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure - while (!ctx->Done(&ptr)) { - uint32_t tag; - ptr = ::_pbi::ReadTag(ptr, &tag); - switch (tag >> 3) { - // string rpcname = 1; - case 1: - if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 10)) { - auto str = _internal_mutable_rpcname(); - ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx); - CHK_(ptr); - CHK_(::_pbi::VerifyUTF8(str, nullptr)); - } else - goto handle_unusual; - continue; - default: - goto handle_unusual; - } // switch - handle_unusual: - if ((tag == 0) || ((tag & 7) == 4)) { - CHK_(ptr); - ctx->SetLastTag(tag); - goto message_done; - } - ptr = UnknownFieldParse( - tag, - _internal_metadata_.mutable_unknown_fields(), - ptr, ctx); - CHK_(ptr != nullptr); - } // while + while (!ctx->Done(&ptr)) { + uint32_t tag; + ptr = ::_pbi::ReadTag(ptr, &tag); + switch (tag >> 3) { + // string rpcname = 1; + case 1: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 10)) { + auto str = _internal_mutable_rpcname(); + ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx); + CHK_(ptr); + CHK_(::_pbi::VerifyUTF8(str, "control.Meta.rpcname")); + } else + goto handle_unusual; + continue; + default: + goto handle_unusual; + } // switch +handle_unusual: + if ((tag == 0) || ((tag & 7) == 4)) { + CHK_(ptr); + ctx->SetLastTag(tag); + goto message_done; + } + ptr = UnknownFieldParse( + tag, + _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), + ptr, ctx); + CHK_(ptr != nullptr); + } // while message_done: - return ptr; + return ptr; failure: - ptr = nullptr; - goto message_done; + ptr = nullptr; + goto message_done; #undef CHK_ } uint8_t* Meta::_InternalSerialize( - uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { - // @@protoc_insertion_point(serialize_to_array_start:control.Meta) - uint32_t cached_has_bits = 0; - (void) cached_has_bits; + uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { + // @@protoc_insertion_point(serialize_to_array_start:control.Meta) + uint32_t cached_has_bits = 0; + (void) cached_has_bits; - // string rpcname = 1; - if (!this->_internal_rpcname().empty()) { - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( - this->_internal_rpcname().data(), static_cast(this->_internal_rpcname().length()), - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, - "control.Meta.rpcname"); - target = stream->WriteStringMaybeAliased( - 1, this->_internal_rpcname(), target); - } + // string rpcname = 1; + if (!this->_internal_rpcname().empty()) { + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( + this->_internal_rpcname().data(), static_cast(this->_internal_rpcname().length()), + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, + "control.Meta.rpcname"); + target = stream->WriteStringMaybeAliased( + 1, this->_internal_rpcname(), target); + } - if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { - target = stream->WriteRaw(_internal_metadata_.unknown_fields(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(), - static_cast(_internal_metadata_.unknown_fields(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target); - } - // @@protoc_insertion_point(serialize_to_array_end:control.Meta) - return target; + if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { + target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray( + _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); + } + // @@protoc_insertion_point(serialize_to_array_end:control.Meta) + return target; } size_t Meta::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:control.Meta) - size_t total_size = 0; + size_t total_size = 0; - uint32_t cached_has_bits = 0; - // Prevent compiler warnings about cached_has_bits being unused - (void) cached_has_bits; + uint32_t cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; - // string rpcname = 1; - if (!this->_internal_rpcname().empty()) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( - this->_internal_rpcname()); - } + // string rpcname = 1; + if (!this->_internal_rpcname().empty()) { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( + this->_internal_rpcname()); + } - if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { - total_size += _internal_metadata_.unknown_fields(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size(); - } - int cached_size = ::_pbi::ToCachedSize(total_size); - SetCachedSize(cached_size); - return total_size; + return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_); } -void Meta::CheckTypeAndMergeFrom( - const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) { - MergeFrom(*::_pbi::DownCast( - &from)); +const ::PROTOBUF_NAMESPACE_ID::Message::ClassData Meta::_class_data_ = { + ::PROTOBUF_NAMESPACE_ID::Message::CopyWithSourceCheck, + Meta::MergeImpl +}; +const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*Meta::GetClassData() const { + return &_class_data_; } -void Meta::MergeFrom(const Meta& from) { - Meta* const _this = this; - // @@protoc_insertion_point(class_specific_merge_from_start:control.Meta) - GOOGLE_DCHECK_NE(&from, _this); - uint32_t cached_has_bits = 0; - (void) cached_has_bits; - if (!from._internal_rpcname().empty()) { - _this->_internal_set_rpcname(from._internal_rpcname()); - } - _this->_internal_metadata_.MergeFrom(from._internal_metadata_); +void Meta::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg) { + auto* const _this = static_cast(&to_msg); + auto& from = static_cast(from_msg); + // @@protoc_insertion_point(class_specific_merge_from_start:control.Meta) + GOOGLE_DCHECK_NE(&from, _this); + uint32_t cached_has_bits = 0; + (void) cached_has_bits; + + if (!from._internal_rpcname().empty()) { + _this->_internal_set_rpcname(from._internal_rpcname()); + } + _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); } void Meta::CopyFrom(const Meta& from) { // @@protoc_insertion_point(class_specific_copy_from_start:control.Meta) - if (&from == this) return; - Clear(); - MergeFrom(from); + if (&from == this) return; + Clear(); + MergeFrom(from); } bool Meta::IsInitialized() const { - return true; + return true; } void Meta::InternalSwap(Meta* other) { - using std::swap; - auto* lhs_arena = GetArenaForAllocation(); - auto* rhs_arena = other->GetArenaForAllocation(); - _internal_metadata_.InternalSwap(&other->_internal_metadata_); - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap( - &_impl_.rpcname_, lhs_arena, - &other->_impl_.rpcname_, rhs_arena - ); + using std::swap; + auto* lhs_arena = GetArenaForAllocation(); + auto* rhs_arena = other->GetArenaForAllocation(); + _internal_metadata_.InternalSwap(&other->_internal_metadata_); + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap( + &_impl_.rpcname_, lhs_arena, + &other->_impl_.rpcname_, rhs_arena + ); } -std::string Meta::GetTypeName() const { - return "control.Meta"; +::PROTOBUF_NAMESPACE_ID::Metadata Meta::GetMetadata() const { + return ::_pbi::AssignDescriptors( + &descriptor_table_hello_2eproto_getter, &descriptor_table_hello_2eproto_once, + file_level_metadata_hello_2eproto[1]); } - // =================================================================== class Hello::_Internal { - public: - static const ::control::Meta& meta(const Hello* msg); +public: + static const ::control::Meta& meta(const Hello* msg); }; const ::control::Meta& Hello::_Internal::meta(const Hello* msg) { - return *msg->_impl_.meta_; + return *msg->_impl_.meta_; } Hello::Hello(::PROTOBUF_NAMESPACE_ID::Arena* arena, - bool is_message_owned) - : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) { - SharedCtor(arena, is_message_owned); - // @@protoc_insertion_point(arena_constructor:control.Hello) + bool is_message_owned) + : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) { + SharedCtor(arena, is_message_owned); + // @@protoc_insertion_point(arena_constructor:control.Hello) } Hello::Hello(const Hello& from) - : ::PROTOBUF_NAMESPACE_ID::MessageLite() { - Hello* const _this = this; (void)_this; - new (&_impl_) Impl_{ - decltype(_impl_.name_){} - , decltype(_impl_.meta_){nullptr} - , decltype(_impl_.id_){} - , /*decltype(_impl_._cached_size_)*/{}}; + : ::PROTOBUF_NAMESPACE_ID::Message() { + Hello* const _this = this; + (void)_this; + new (&_impl_) Impl_{ + decltype(_impl_.name_) {} + , decltype(_impl_.meta_) { + nullptr + } + , decltype(_impl_.id_) {} + , /*decltype(_impl_._cached_size_)*/{}}; - _internal_metadata_.MergeFrom(from._internal_metadata_); - _impl_.name_.InitDefault(); - #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING - _impl_.name_.Set("", GetArenaForAllocation()); - #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING - if (!from._internal_name().empty()) { - _this->_impl_.name_.Set(from._internal_name(), - _this->GetArenaForAllocation()); - } - if (from._internal_has_meta()) { - _this->_impl_.meta_ = new ::control::Meta(*from._impl_.meta_); - } - _this->_impl_.id_ = from._impl_.id_; - // @@protoc_insertion_point(copy_constructor:control.Hello) + _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); + _impl_.name_.InitDefault(); +#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING + _impl_.name_.Set("", GetArenaForAllocation()); +#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING + if (!from._internal_name().empty()) { + _this->_impl_.name_.Set(from._internal_name(), + _this->GetArenaForAllocation()); + } + if (from._internal_has_meta()) { + _this->_impl_.meta_ = new ::control::Meta(*from._impl_.meta_); + } + _this->_impl_.id_ = from._impl_.id_; + // @@protoc_insertion_point(copy_constructor:control.Hello) } inline void Hello::SharedCtor( - ::_pb::Arena* arena, bool is_message_owned) { - (void)arena; - (void)is_message_owned; - new (&_impl_) Impl_{ - decltype(_impl_.name_){} - , decltype(_impl_.meta_){nullptr} - , decltype(_impl_.id_){0} - , /*decltype(_impl_._cached_size_)*/{} - }; - _impl_.name_.InitDefault(); - #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING - _impl_.name_.Set("", GetArenaForAllocation()); - #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING + ::_pb::Arena* arena, bool is_message_owned) { + (void)arena; + (void)is_message_owned; + new (&_impl_) Impl_{ + decltype(_impl_.name_) {} + , decltype(_impl_.meta_) { + nullptr + } + , decltype(_impl_.id_) { + 0 + } + , /*decltype(_impl_._cached_size_)*/{} + }; + _impl_.name_.InitDefault(); +#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING + _impl_.name_.Set("", GetArenaForAllocation()); +#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING } Hello::~Hello() { - // @@protoc_insertion_point(destructor:control.Hello) - if (auto *arena = _internal_metadata_.DeleteReturnArena()) { - (void)arena; - return; - } - SharedDtor(); + // @@protoc_insertion_point(destructor:control.Hello) + if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) { + (void)arena; + return; + } + SharedDtor(); } inline void Hello::SharedDtor() { - GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); - _impl_.name_.Destroy(); - if (this != internal_default_instance()) delete _impl_.meta_; + GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); + _impl_.name_.Destroy(); + if (this != internal_default_instance()) delete _impl_.meta_; } void Hello::SetCachedSize(int size) const { - _impl_._cached_size_.Set(size); + _impl_._cached_size_.Set(size); } void Hello::Clear() { // @@protoc_insertion_point(message_clear_start:control.Hello) - uint32_t cached_has_bits = 0; - // Prevent compiler warnings about cached_has_bits being unused - (void) cached_has_bits; + uint32_t cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; - _impl_.name_.ClearToEmpty(); - if (GetArenaForAllocation() == nullptr && _impl_.meta_ != nullptr) { - delete _impl_.meta_; - } - _impl_.meta_ = nullptr; - _impl_.id_ = 0; - _internal_metadata_.Clear(); + _impl_.name_.ClearToEmpty(); + if (GetArenaForAllocation() == nullptr && _impl_.meta_ != nullptr) { + delete _impl_.meta_; + } + _impl_.meta_ = nullptr; + _impl_.id_ = 0; + _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } const char* Hello::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure - while (!ctx->Done(&ptr)) { - uint32_t tag; - ptr = ::_pbi::ReadTag(ptr, &tag); - switch (tag >> 3) { - // .control.Meta meta = 1; - case 1: - if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 10)) { - ptr = ctx->ParseMessage(_internal_mutable_meta(), ptr); - CHK_(ptr); - } else - goto handle_unusual; - continue; - // int32 id = 2; - case 2: - if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 16)) { - _impl_.id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint32(&ptr); - CHK_(ptr); - } else - goto handle_unusual; - continue; - // string name = 3; - case 3: - if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 26)) { - auto str = _internal_mutable_name(); - ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx); - CHK_(ptr); - CHK_(::_pbi::VerifyUTF8(str, nullptr)); - } else - goto handle_unusual; - continue; - default: - goto handle_unusual; - } // switch - handle_unusual: - if ((tag == 0) || ((tag & 7) == 4)) { - CHK_(ptr); - ctx->SetLastTag(tag); - goto message_done; - } - ptr = UnknownFieldParse( - tag, - _internal_metadata_.mutable_unknown_fields(), - ptr, ctx); - CHK_(ptr != nullptr); - } // while + while (!ctx->Done(&ptr)) { + uint32_t tag; + ptr = ::_pbi::ReadTag(ptr, &tag); + switch (tag >> 3) { + // .control.Meta meta = 1; + case 1: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 10)) { + ptr = ctx->ParseMessage(_internal_mutable_meta(), ptr); + CHK_(ptr); + } else + goto handle_unusual; + continue; + // int32 id = 2; + case 2: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 16)) { + _impl_.id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint32(&ptr); + CHK_(ptr); + } else + goto handle_unusual; + continue; + // string name = 3; + case 3: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 26)) { + auto str = _internal_mutable_name(); + ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx); + CHK_(ptr); + CHK_(::_pbi::VerifyUTF8(str, "control.Hello.name")); + } else + goto handle_unusual; + continue; + default: + goto handle_unusual; + } // switch +handle_unusual: + if ((tag == 0) || ((tag & 7) == 4)) { + CHK_(ptr); + ctx->SetLastTag(tag); + goto message_done; + } + ptr = UnknownFieldParse( + tag, + _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), + ptr, ctx); + CHK_(ptr != nullptr); + } // while message_done: - return ptr; + return ptr; failure: - ptr = nullptr; - goto message_done; + ptr = nullptr; + goto message_done; #undef CHK_ } uint8_t* Hello::_InternalSerialize( - uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { - // @@protoc_insertion_point(serialize_to_array_start:control.Hello) - uint32_t cached_has_bits = 0; - (void) cached_has_bits; + uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { + // @@protoc_insertion_point(serialize_to_array_start:control.Hello) + uint32_t cached_has_bits = 0; + (void) cached_has_bits; - // .control.Meta meta = 1; - if (this->_internal_has_meta()) { - target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: - InternalWriteMessage(1, _Internal::meta(this), - _Internal::meta(this).GetCachedSize(), target, stream); - } + // .control.Meta meta = 1; + if (this->_internal_has_meta()) { + target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: + InternalWriteMessage(1, _Internal::meta(this), + _Internal::meta(this).GetCachedSize(), target, stream); + } - // int32 id = 2; - if (this->_internal_id() != 0) { - target = stream->EnsureSpace(target); - target = ::_pbi::WireFormatLite::WriteInt32ToArray(2, this->_internal_id(), target); - } + // int32 id = 2; + if (this->_internal_id() != 0) { + target = stream->EnsureSpace(target); + target = ::_pbi::WireFormatLite::WriteInt32ToArray(2, this->_internal_id(), target); + } - // string name = 3; - if (!this->_internal_name().empty()) { - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( - this->_internal_name().data(), static_cast(this->_internal_name().length()), - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, - "control.Hello.name"); - target = stream->WriteStringMaybeAliased( - 3, this->_internal_name(), target); - } + // string name = 3; + if (!this->_internal_name().empty()) { + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( + this->_internal_name().data(), static_cast(this->_internal_name().length()), + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, + "control.Hello.name"); + target = stream->WriteStringMaybeAliased( + 3, this->_internal_name(), target); + } - if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { - target = stream->WriteRaw(_internal_metadata_.unknown_fields(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(), - static_cast(_internal_metadata_.unknown_fields(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target); - } - // @@protoc_insertion_point(serialize_to_array_end:control.Hello) - return target; + if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { + target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray( + _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); + } + // @@protoc_insertion_point(serialize_to_array_end:control.Hello) + return target; } size_t Hello::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:control.Hello) - size_t total_size = 0; + size_t total_size = 0; - uint32_t cached_has_bits = 0; - // Prevent compiler warnings about cached_has_bits being unused - (void) cached_has_bits; + uint32_t cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; - // string name = 3; - if (!this->_internal_name().empty()) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( - this->_internal_name()); - } + // string name = 3; + if (!this->_internal_name().empty()) { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( + this->_internal_name()); + } - // .control.Meta meta = 1; - if (this->_internal_has_meta()) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( - *_impl_.meta_); - } + // .control.Meta meta = 1; + if (this->_internal_has_meta()) { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( + *_impl_.meta_); + } - // int32 id = 2; - if (this->_internal_id() != 0) { - total_size += ::_pbi::WireFormatLite::Int32SizePlusOne(this->_internal_id()); - } + // int32 id = 2; + if (this->_internal_id() != 0) { + total_size += ::_pbi::WireFormatLite::Int32SizePlusOne(this->_internal_id()); + } - if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { - total_size += _internal_metadata_.unknown_fields(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size(); - } - int cached_size = ::_pbi::ToCachedSize(total_size); - SetCachedSize(cached_size); - return total_size; + return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_); } -void Hello::CheckTypeAndMergeFrom( - const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) { - MergeFrom(*::_pbi::DownCast( - &from)); +const ::PROTOBUF_NAMESPACE_ID::Message::ClassData Hello::_class_data_ = { + ::PROTOBUF_NAMESPACE_ID::Message::CopyWithSourceCheck, + Hello::MergeImpl +}; +const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*Hello::GetClassData() const { + return &_class_data_; } -void Hello::MergeFrom(const Hello& from) { - Hello* const _this = this; - // @@protoc_insertion_point(class_specific_merge_from_start:control.Hello) - GOOGLE_DCHECK_NE(&from, _this); - uint32_t cached_has_bits = 0; - (void) cached_has_bits; - if (!from._internal_name().empty()) { - _this->_internal_set_name(from._internal_name()); - } - if (from._internal_has_meta()) { - _this->_internal_mutable_meta()->::control::Meta::MergeFrom( - from._internal_meta()); - } - if (from._internal_id() != 0) { - _this->_internal_set_id(from._internal_id()); - } - _this->_internal_metadata_.MergeFrom(from._internal_metadata_); +void Hello::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg) { + auto* const _this = static_cast(&to_msg); + auto& from = static_cast(from_msg); + // @@protoc_insertion_point(class_specific_merge_from_start:control.Hello) + GOOGLE_DCHECK_NE(&from, _this); + uint32_t cached_has_bits = 0; + (void) cached_has_bits; + + if (!from._internal_name().empty()) { + _this->_internal_set_name(from._internal_name()); + } + if (from._internal_has_meta()) { + _this->_internal_mutable_meta()->::control::Meta::MergeFrom( + from._internal_meta()); + } + if (from._internal_id() != 0) { + _this->_internal_set_id(from._internal_id()); + } + _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); } void Hello::CopyFrom(const Hello& from) { // @@protoc_insertion_point(class_specific_copy_from_start:control.Hello) - if (&from == this) return; - Clear(); - MergeFrom(from); + if (&from == this) return; + Clear(); + MergeFrom(from); } bool Hello::IsInitialized() const { - return true; + return true; } void Hello::InternalSwap(Hello* other) { - using std::swap; - auto* lhs_arena = GetArenaForAllocation(); - auto* rhs_arena = other->GetArenaForAllocation(); - _internal_metadata_.InternalSwap(&other->_internal_metadata_); - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap( - &_impl_.name_, lhs_arena, - &other->_impl_.name_, rhs_arena - ); - ::PROTOBUF_NAMESPACE_ID::internal::memswap< - PROTOBUF_FIELD_OFFSET(Hello, _impl_.id_) - + sizeof(Hello::_impl_.id_) - - PROTOBUF_FIELD_OFFSET(Hello, _impl_.meta_)>( - reinterpret_cast(&_impl_.meta_), - reinterpret_cast(&other->_impl_.meta_)); + using std::swap; + auto* lhs_arena = GetArenaForAllocation(); + auto* rhs_arena = other->GetArenaForAllocation(); + _internal_metadata_.InternalSwap(&other->_internal_metadata_); + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap( + &_impl_.name_, lhs_arena, + &other->_impl_.name_, rhs_arena + ); + ::PROTOBUF_NAMESPACE_ID::internal::memswap< + PROTOBUF_FIELD_OFFSET(Hello, _impl_.id_) + + sizeof(Hello::_impl_.id_) + - PROTOBUF_FIELD_OFFSET(Hello, _impl_.meta_)>( + reinterpret_cast(&_impl_.meta_), + reinterpret_cast(&other->_impl_.meta_)); } -std::string Hello::GetTypeName() const { - return "control.Hello"; +::PROTOBUF_NAMESPACE_ID::Metadata Hello::GetMetadata() const { + return ::_pbi::AssignDescriptors( + &descriptor_table_hello_2eproto_getter, &descriptor_table_hello_2eproto_once, + file_level_metadata_hello_2eproto[2]); } - // @@protoc_insertion_point(namespace_scope) } // namespace control PROTOBUF_NAMESPACE_OPEN template<> PROTOBUF_NOINLINE ::control::Header* Arena::CreateMaybeMessage< ::control::Header >(Arena* arena) { - return Arena::CreateMessageInternal< ::control::Header >(arena); + return Arena::CreateMessageInternal< ::control::Header >(arena); } template<> PROTOBUF_NOINLINE ::control::Meta* Arena::CreateMaybeMessage< ::control::Meta >(Arena* arena) { - return Arena::CreateMessageInternal< ::control::Meta >(arena); + return Arena::CreateMessageInternal< ::control::Meta >(arena); } template<> PROTOBUF_NOINLINE ::control::Hello* Arena::CreateMaybeMessage< ::control::Hello >(Arena* arena) { - return Arena::CreateMessageInternal< ::control::Hello >(arena); + return Arena::CreateMessageInternal< ::control::Hello >(arena); } PROTOBUF_NAMESPACE_CLOSE diff --git a/hello.pb.h b/hello.pb.h index b000732..ecf832f 100644 --- a/hello.pb.h +++ b/hello.pb.h @@ -25,9 +25,11 @@ #include #include #include -#include +#include +#include #include // IWYU pragma: export #include // IWYU pragma: export +#include // @@protoc_insertion_point(includes) #include #define PROTOBUF_INTERNAL_EXPORT_hello_2eproto @@ -39,8 +41,9 @@ PROTOBUF_NAMESPACE_CLOSE // Internal implementation detail -- do not use these members. struct TableStruct_hello_2eproto { - static const uint32_t offsets[]; + static const uint32_t offsets[]; }; +extern const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_hello_2eproto; namespace control { class Header; struct HeaderDefaultTypeInternal; @@ -62,442 +65,508 @@ namespace control { // =================================================================== class Header final : - public ::PROTOBUF_NAMESPACE_ID::MessageLite /* @@protoc_insertion_point(class_definition:control.Header) */ { - public: - inline Header() : Header(nullptr) {} - ~Header() override; - explicit PROTOBUF_CONSTEXPR Header(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); + public ::PROTOBUF_NAMESPACE_ID::Message { /* @@protoc_insertion_point(class_definition:control.Header) */ +public: + inline Header() : Header(nullptr) {} + ~Header() override; + explicit PROTOBUF_CONSTEXPR Header(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); - Header(const Header& from); - Header(Header&& from) noexcept - : Header() { - *this = ::std::move(from); - } + Header(const Header& from); + Header(Header&& from) noexcept + : Header() { + *this = ::std::move(from); + } - inline Header& operator=(const Header& from) { - CopyFrom(from); - return *this; - } - inline Header& operator=(Header&& from) noexcept { - if (this == &from) return *this; - if (GetOwningArena() == from.GetOwningArena() - #ifdef PROTOBUF_FORCE_COPY_IN_MOVE - && GetOwningArena() != nullptr - #endif // !PROTOBUF_FORCE_COPY_IN_MOVE - ) { - InternalSwap(&from); - } else { - CopyFrom(from); - } - return *this; - } + inline Header& operator=(const Header& from) { + CopyFrom(from); + return *this; + } + inline Header& operator=(Header&& from) noexcept { + if (this == &from) return *this; + if (GetOwningArena() == from.GetOwningArena() +#ifdef PROTOBUF_FORCE_COPY_IN_MOVE + && GetOwningArena() != nullptr +#endif // !PROTOBUF_FORCE_COPY_IN_MOVE + ) { + InternalSwap(&from); + } else { + CopyFrom(from); + } + return *this; + } - static const Header& default_instance() { - return *internal_default_instance(); - } - static inline const Header* internal_default_instance() { - return reinterpret_cast( - &_Header_default_instance_); - } - static constexpr int kIndexInFileMessages = - 0; + static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { + return GetDescriptor(); + } + static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { + return default_instance().GetMetadata().descriptor; + } + static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { + return default_instance().GetMetadata().reflection; + } + static const Header& default_instance() { + return *internal_default_instance(); + } + static inline const Header* internal_default_instance() { + return reinterpret_cast( + &_Header_default_instance_); + } + static constexpr int kIndexInFileMessages = + 0; - friend void swap(Header& a, Header& b) { - a.Swap(&b); - } - inline void Swap(Header* other) { - if (other == this) return; - #ifdef PROTOBUF_FORCE_COPY_IN_SWAP - if (GetOwningArena() != nullptr && - GetOwningArena() == other->GetOwningArena()) { - #else // PROTOBUF_FORCE_COPY_IN_SWAP - if (GetOwningArena() == other->GetOwningArena()) { - #endif // !PROTOBUF_FORCE_COPY_IN_SWAP - InternalSwap(other); - } else { - ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); - } - } - void UnsafeArenaSwap(Header* other) { - if (other == this) return; - GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena()); - InternalSwap(other); - } + friend void swap(Header& a, Header& b) { + a.Swap(&b); + } + inline void Swap(Header* other) { + if (other == this) return; +#ifdef PROTOBUF_FORCE_COPY_IN_SWAP + if (GetOwningArena() != nullptr && + GetOwningArena() == other->GetOwningArena()) { +#else // PROTOBUF_FORCE_COPY_IN_SWAP + if (GetOwningArena() == other->GetOwningArena()) { +#endif // !PROTOBUF_FORCE_COPY_IN_SWAP + InternalSwap(other); + } else { + ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); + } + } + void UnsafeArenaSwap(Header* other) { + if (other == this) return; + GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena()); + InternalSwap(other); + } - // implements Message ---------------------------------------------- + // implements Message ---------------------------------------------- - Header* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final { - return CreateMaybeMessage
(arena); - } - void CheckTypeAndMergeFrom(const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) final; - void CopyFrom(const Header& from); - void MergeFrom(const Header& from); - PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; - bool IsInitialized() const final; + Header* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final { + return CreateMaybeMessage
(arena); + } + using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom; + void CopyFrom(const Header& from); + using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom; + void MergeFrom( const Header& from) { + Header::MergeImpl(*this, from); + } +private: + static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg); +public: + PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; + bool IsInitialized() const final; - size_t ByteSizeLong() const final; - const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; - uint8_t* _InternalSerialize( - uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; - int GetCachedSize() const final { return _impl_._cached_size_.Get(); } + size_t ByteSizeLong() const final; + const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; + uint8_t* _InternalSerialize( + uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; + int GetCachedSize() const final { + return _impl_._cached_size_.Get(); + } - private: - void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned); - void SharedDtor(); - void SetCachedSize(int size) const; - void InternalSwap(Header* other); +private: + void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned); + void SharedDtor(); + void SetCachedSize(int size) const final; + void InternalSwap(Header* other); - private: - friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; - static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { - return "control.Header"; - } - protected: - explicit Header(::PROTOBUF_NAMESPACE_ID::Arena* arena, - bool is_message_owned = false); - public: +private: + friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; + static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { + return "control.Header"; + } +protected: + explicit Header(::PROTOBUF_NAMESPACE_ID::Arena* arena, + bool is_message_owned = false); +public: - std::string GetTypeName() const final; + static const ClassData _class_data_; + const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final; - // nested types ---------------------------------------------------- + ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; - // accessors ------------------------------------------------------- + // nested types ---------------------------------------------------- - enum : int { - kMetaFieldNumber = 1, - }; - // .control.Meta meta = 1; - bool has_meta() const; - private: - bool _internal_has_meta() const; - public: - void clear_meta(); - const ::control::Meta& meta() const; - PROTOBUF_NODISCARD ::control::Meta* release_meta(); - ::control::Meta* mutable_meta(); - void set_allocated_meta(::control::Meta* meta); - private: - const ::control::Meta& _internal_meta() const; - ::control::Meta* _internal_mutable_meta(); - public: - void unsafe_arena_set_allocated_meta( - ::control::Meta* meta); - ::control::Meta* unsafe_arena_release_meta(); + // accessors ------------------------------------------------------- - // @@protoc_insertion_point(class_scope:control.Header) - private: - class _Internal; + enum : int { + kMetaFieldNumber = 1, + }; + // .control.Meta meta = 1; + bool has_meta() const; +private: + bool _internal_has_meta() const; +public: + void clear_meta(); + const ::control::Meta& meta() const; + PROTOBUF_NODISCARD ::control::Meta* release_meta(); + ::control::Meta* mutable_meta(); + void set_allocated_meta(::control::Meta* meta); +private: + const ::control::Meta& _internal_meta() const; + ::control::Meta* _internal_mutable_meta(); +public: + void unsafe_arena_set_allocated_meta( + ::control::Meta* meta); + ::control::Meta* unsafe_arena_release_meta(); - template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; - typedef void InternalArenaConstructable_; - typedef void DestructorSkippable_; - struct Impl_ { - ::control::Meta* meta_; - mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; - }; - union { Impl_ _impl_; }; - friend struct ::TableStruct_hello_2eproto; + // @@protoc_insertion_point(class_scope:control.Header) +private: + class _Internal; + + template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; + typedef void InternalArenaConstructable_; + typedef void DestructorSkippable_; + struct Impl_ { + ::control::Meta* meta_; + mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; + }; + union { + Impl_ _impl_; + }; + friend struct ::TableStruct_hello_2eproto; }; // ------------------------------------------------------------------- class Meta final : - public ::PROTOBUF_NAMESPACE_ID::MessageLite /* @@protoc_insertion_point(class_definition:control.Meta) */ { - public: - inline Meta() : Meta(nullptr) {} - ~Meta() override; - explicit PROTOBUF_CONSTEXPR Meta(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); + public ::PROTOBUF_NAMESPACE_ID::Message { /* @@protoc_insertion_point(class_definition:control.Meta) */ +public: + inline Meta() : Meta(nullptr) {} + ~Meta() override; + explicit PROTOBUF_CONSTEXPR Meta(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); - Meta(const Meta& from); - Meta(Meta&& from) noexcept - : Meta() { - *this = ::std::move(from); - } + Meta(const Meta& from); + Meta(Meta&& from) noexcept + : Meta() { + *this = ::std::move(from); + } - inline Meta& operator=(const Meta& from) { - CopyFrom(from); - return *this; - } - inline Meta& operator=(Meta&& from) noexcept { - if (this == &from) return *this; - if (GetOwningArena() == from.GetOwningArena() - #ifdef PROTOBUF_FORCE_COPY_IN_MOVE - && GetOwningArena() != nullptr - #endif // !PROTOBUF_FORCE_COPY_IN_MOVE - ) { - InternalSwap(&from); - } else { - CopyFrom(from); - } - return *this; - } + inline Meta& operator=(const Meta& from) { + CopyFrom(from); + return *this; + } + inline Meta& operator=(Meta&& from) noexcept { + if (this == &from) return *this; + if (GetOwningArena() == from.GetOwningArena() +#ifdef PROTOBUF_FORCE_COPY_IN_MOVE + && GetOwningArena() != nullptr +#endif // !PROTOBUF_FORCE_COPY_IN_MOVE + ) { + InternalSwap(&from); + } else { + CopyFrom(from); + } + return *this; + } - static const Meta& default_instance() { - return *internal_default_instance(); - } - static inline const Meta* internal_default_instance() { - return reinterpret_cast( - &_Meta_default_instance_); - } - static constexpr int kIndexInFileMessages = - 1; + static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { + return GetDescriptor(); + } + static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { + return default_instance().GetMetadata().descriptor; + } + static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { + return default_instance().GetMetadata().reflection; + } + static const Meta& default_instance() { + return *internal_default_instance(); + } + static inline const Meta* internal_default_instance() { + return reinterpret_cast( + &_Meta_default_instance_); + } + static constexpr int kIndexInFileMessages = + 1; - friend void swap(Meta& a, Meta& b) { - a.Swap(&b); - } - inline void Swap(Meta* other) { - if (other == this) return; - #ifdef PROTOBUF_FORCE_COPY_IN_SWAP - if (GetOwningArena() != nullptr && - GetOwningArena() == other->GetOwningArena()) { - #else // PROTOBUF_FORCE_COPY_IN_SWAP - if (GetOwningArena() == other->GetOwningArena()) { - #endif // !PROTOBUF_FORCE_COPY_IN_SWAP - InternalSwap(other); - } else { - ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); - } - } - void UnsafeArenaSwap(Meta* other) { - if (other == this) return; - GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena()); - InternalSwap(other); - } + friend void swap(Meta& a, Meta& b) { + a.Swap(&b); + } + inline void Swap(Meta* other) { + if (other == this) return; +#ifdef PROTOBUF_FORCE_COPY_IN_SWAP + if (GetOwningArena() != nullptr && + GetOwningArena() == other->GetOwningArena()) { +#else // PROTOBUF_FORCE_COPY_IN_SWAP + if (GetOwningArena() == other->GetOwningArena()) { +#endif // !PROTOBUF_FORCE_COPY_IN_SWAP + InternalSwap(other); + } else { + ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); + } + } + void UnsafeArenaSwap(Meta* other) { + if (other == this) return; + GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena()); + InternalSwap(other); + } - // implements Message ---------------------------------------------- + // implements Message ---------------------------------------------- - Meta* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final { - return CreateMaybeMessage(arena); - } - void CheckTypeAndMergeFrom(const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) final; - void CopyFrom(const Meta& from); - void MergeFrom(const Meta& from); - PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; - bool IsInitialized() const final; + Meta* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final { + return CreateMaybeMessage(arena); + } + using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom; + void CopyFrom(const Meta& from); + using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom; + void MergeFrom( const Meta& from) { + Meta::MergeImpl(*this, from); + } +private: + static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg); +public: + PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; + bool IsInitialized() const final; - size_t ByteSizeLong() const final; - const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; - uint8_t* _InternalSerialize( - uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; - int GetCachedSize() const final { return _impl_._cached_size_.Get(); } + size_t ByteSizeLong() const final; + const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; + uint8_t* _InternalSerialize( + uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; + int GetCachedSize() const final { + return _impl_._cached_size_.Get(); + } - private: - void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned); - void SharedDtor(); - void SetCachedSize(int size) const; - void InternalSwap(Meta* other); +private: + void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned); + void SharedDtor(); + void SetCachedSize(int size) const final; + void InternalSwap(Meta* other); - private: - friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; - static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { - return "control.Meta"; - } - protected: - explicit Meta(::PROTOBUF_NAMESPACE_ID::Arena* arena, - bool is_message_owned = false); - public: +private: + friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; + static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { + return "control.Meta"; + } +protected: + explicit Meta(::PROTOBUF_NAMESPACE_ID::Arena* arena, + bool is_message_owned = false); +public: - std::string GetTypeName() const final; + static const ClassData _class_data_; + const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final; - // nested types ---------------------------------------------------- + ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; - // accessors ------------------------------------------------------- + // nested types ---------------------------------------------------- - enum : int { - kRpcnameFieldNumber = 1, - }; - // string rpcname = 1; - void clear_rpcname(); - const std::string& rpcname() const; - template - void set_rpcname(ArgT0&& arg0, ArgT... args); - std::string* mutable_rpcname(); - PROTOBUF_NODISCARD std::string* release_rpcname(); - void set_allocated_rpcname(std::string* rpcname); - private: - const std::string& _internal_rpcname() const; - inline PROTOBUF_ALWAYS_INLINE void _internal_set_rpcname(const std::string& value); - std::string* _internal_mutable_rpcname(); - public: + // accessors ------------------------------------------------------- - // @@protoc_insertion_point(class_scope:control.Meta) - private: - class _Internal; + enum : int { + kRpcnameFieldNumber = 1, + }; + // string rpcname = 1; + void clear_rpcname(); + const std::string& rpcname() const; + template + void set_rpcname(ArgT0&& arg0, ArgT... args); + std::string* mutable_rpcname(); + PROTOBUF_NODISCARD std::string* release_rpcname(); + void set_allocated_rpcname(std::string* rpcname); +private: + const std::string& _internal_rpcname() const; + inline PROTOBUF_ALWAYS_INLINE void _internal_set_rpcname(const std::string& value); + std::string* _internal_mutable_rpcname(); +public: - template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; - typedef void InternalArenaConstructable_; - typedef void DestructorSkippable_; - struct Impl_ { - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr rpcname_; - mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; - }; - union { Impl_ _impl_; }; - friend struct ::TableStruct_hello_2eproto; + // @@protoc_insertion_point(class_scope:control.Meta) +private: + class _Internal; + + template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; + typedef void InternalArenaConstructable_; + typedef void DestructorSkippable_; + struct Impl_ { + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr rpcname_; + mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; + }; + union { + Impl_ _impl_; + }; + friend struct ::TableStruct_hello_2eproto; }; // ------------------------------------------------------------------- class Hello final : - public ::PROTOBUF_NAMESPACE_ID::MessageLite /* @@protoc_insertion_point(class_definition:control.Hello) */ { - public: - inline Hello() : Hello(nullptr) {} - ~Hello() override; - explicit PROTOBUF_CONSTEXPR Hello(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); + public ::PROTOBUF_NAMESPACE_ID::Message { /* @@protoc_insertion_point(class_definition:control.Hello) */ +public: + inline Hello() : Hello(nullptr) {} + ~Hello() override; + explicit PROTOBUF_CONSTEXPR Hello(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); - Hello(const Hello& from); - Hello(Hello&& from) noexcept - : Hello() { - *this = ::std::move(from); - } + Hello(const Hello& from); + Hello(Hello&& from) noexcept + : Hello() { + *this = ::std::move(from); + } - inline Hello& operator=(const Hello& from) { - CopyFrom(from); - return *this; - } - inline Hello& operator=(Hello&& from) noexcept { - if (this == &from) return *this; - if (GetOwningArena() == from.GetOwningArena() - #ifdef PROTOBUF_FORCE_COPY_IN_MOVE - && GetOwningArena() != nullptr - #endif // !PROTOBUF_FORCE_COPY_IN_MOVE - ) { - InternalSwap(&from); - } else { - CopyFrom(from); - } - return *this; - } + inline Hello& operator=(const Hello& from) { + CopyFrom(from); + return *this; + } + inline Hello& operator=(Hello&& from) noexcept { + if (this == &from) return *this; + if (GetOwningArena() == from.GetOwningArena() +#ifdef PROTOBUF_FORCE_COPY_IN_MOVE + && GetOwningArena() != nullptr +#endif // !PROTOBUF_FORCE_COPY_IN_MOVE + ) { + InternalSwap(&from); + } else { + CopyFrom(from); + } + return *this; + } - static const Hello& default_instance() { - return *internal_default_instance(); - } - static inline const Hello* internal_default_instance() { - return reinterpret_cast( - &_Hello_default_instance_); - } - static constexpr int kIndexInFileMessages = - 2; + static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { + return GetDescriptor(); + } + static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { + return default_instance().GetMetadata().descriptor; + } + static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { + return default_instance().GetMetadata().reflection; + } + static const Hello& default_instance() { + return *internal_default_instance(); + } + static inline const Hello* internal_default_instance() { + return reinterpret_cast( + &_Hello_default_instance_); + } + static constexpr int kIndexInFileMessages = + 2; - friend void swap(Hello& a, Hello& b) { - a.Swap(&b); - } - inline void Swap(Hello* other) { - if (other == this) return; - #ifdef PROTOBUF_FORCE_COPY_IN_SWAP - if (GetOwningArena() != nullptr && - GetOwningArena() == other->GetOwningArena()) { - #else // PROTOBUF_FORCE_COPY_IN_SWAP - if (GetOwningArena() == other->GetOwningArena()) { - #endif // !PROTOBUF_FORCE_COPY_IN_SWAP - InternalSwap(other); - } else { - ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); - } - } - void UnsafeArenaSwap(Hello* other) { - if (other == this) return; - GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena()); - InternalSwap(other); - } + friend void swap(Hello& a, Hello& b) { + a.Swap(&b); + } + inline void Swap(Hello* other) { + if (other == this) return; +#ifdef PROTOBUF_FORCE_COPY_IN_SWAP + if (GetOwningArena() != nullptr && + GetOwningArena() == other->GetOwningArena()) { +#else // PROTOBUF_FORCE_COPY_IN_SWAP + if (GetOwningArena() == other->GetOwningArena()) { +#endif // !PROTOBUF_FORCE_COPY_IN_SWAP + InternalSwap(other); + } else { + ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); + } + } + void UnsafeArenaSwap(Hello* other) { + if (other == this) return; + GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena()); + InternalSwap(other); + } - // implements Message ---------------------------------------------- + // implements Message ---------------------------------------------- - Hello* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final { - return CreateMaybeMessage(arena); - } - void CheckTypeAndMergeFrom(const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) final; - void CopyFrom(const Hello& from); - void MergeFrom(const Hello& from); - PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; - bool IsInitialized() const final; + Hello* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final { + return CreateMaybeMessage(arena); + } + using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom; + void CopyFrom(const Hello& from); + using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom; + void MergeFrom( const Hello& from) { + Hello::MergeImpl(*this, from); + } +private: + static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg); +public: + PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; + bool IsInitialized() const final; - size_t ByteSizeLong() const final; - const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; - uint8_t* _InternalSerialize( - uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; - int GetCachedSize() const final { return _impl_._cached_size_.Get(); } + size_t ByteSizeLong() const final; + const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; + uint8_t* _InternalSerialize( + uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; + int GetCachedSize() const final { + return _impl_._cached_size_.Get(); + } - private: - void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned); - void SharedDtor(); - void SetCachedSize(int size) const; - void InternalSwap(Hello* other); +private: + void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned); + void SharedDtor(); + void SetCachedSize(int size) const final; + void InternalSwap(Hello* other); - private: - friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; - static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { - return "control.Hello"; - } - protected: - explicit Hello(::PROTOBUF_NAMESPACE_ID::Arena* arena, +private: + friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; + static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { + return "control.Hello"; + } +protected: + explicit Hello(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned = false); - public: +public: - std::string GetTypeName() const final; + static const ClassData _class_data_; + const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final; - // nested types ---------------------------------------------------- + ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; - // accessors ------------------------------------------------------- + // nested types ---------------------------------------------------- - enum : int { - kNameFieldNumber = 3, - kMetaFieldNumber = 1, - kIdFieldNumber = 2, - }; - // string name = 3; - void clear_name(); - const std::string& name() const; - template - void set_name(ArgT0&& arg0, ArgT... args); - std::string* mutable_name(); - PROTOBUF_NODISCARD std::string* release_name(); - void set_allocated_name(std::string* name); - private: - const std::string& _internal_name() const; - inline PROTOBUF_ALWAYS_INLINE void _internal_set_name(const std::string& value); - std::string* _internal_mutable_name(); - public: + // accessors ------------------------------------------------------- - // .control.Meta meta = 1; - bool has_meta() const; - private: - bool _internal_has_meta() const; - public: - void clear_meta(); - const ::control::Meta& meta() const; - PROTOBUF_NODISCARD ::control::Meta* release_meta(); - ::control::Meta* mutable_meta(); - void set_allocated_meta(::control::Meta* meta); - private: - const ::control::Meta& _internal_meta() const; - ::control::Meta* _internal_mutable_meta(); - public: - void unsafe_arena_set_allocated_meta( - ::control::Meta* meta); - ::control::Meta* unsafe_arena_release_meta(); + enum : int { + kNameFieldNumber = 3, + kMetaFieldNumber = 1, + kIdFieldNumber = 2, + }; + // string name = 3; + void clear_name(); + const std::string& name() const; + template + void set_name(ArgT0&& arg0, ArgT... args); + std::string* mutable_name(); + PROTOBUF_NODISCARD std::string* release_name(); + void set_allocated_name(std::string* name); +private: + const std::string& _internal_name() const; + inline PROTOBUF_ALWAYS_INLINE void _internal_set_name(const std::string& value); + std::string* _internal_mutable_name(); +public: - // int32 id = 2; - void clear_id(); - int32_t id() const; - void set_id(int32_t value); - private: - int32_t _internal_id() const; - void _internal_set_id(int32_t value); - public: + // .control.Meta meta = 1; + bool has_meta() const; +private: + bool _internal_has_meta() const; +public: + void clear_meta(); + const ::control::Meta& meta() const; + PROTOBUF_NODISCARD ::control::Meta* release_meta(); + ::control::Meta* mutable_meta(); + void set_allocated_meta(::control::Meta* meta); +private: + const ::control::Meta& _internal_meta() const; + ::control::Meta* _internal_mutable_meta(); +public: + void unsafe_arena_set_allocated_meta( + ::control::Meta* meta); + ::control::Meta* unsafe_arena_release_meta(); - // @@protoc_insertion_point(class_scope:control.Hello) - private: - class _Internal; + // int32 id = 2; + void clear_id(); + int32_t id() const; + void set_id(int32_t value); +private: + int32_t _internal_id() const; + void _internal_set_id(int32_t value); +public: - template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; - typedef void InternalArenaConstructable_; - typedef void DestructorSkippable_; - struct Impl_ { - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr name_; - ::control::Meta* meta_; - int32_t id_; - mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; - }; - union { Impl_ _impl_; }; - friend struct ::TableStruct_hello_2eproto; + // @@protoc_insertion_point(class_scope:control.Hello) +private: + class _Internal; + + template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; + typedef void InternalArenaConstructable_; + typedef void DestructorSkippable_; + struct Impl_ { + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr name_; + ::control::Meta* meta_; + int32_t id_; + mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; + }; + union { + Impl_ _impl_; + }; + friend struct ::TableStruct_hello_2eproto; }; // =================================================================== @@ -505,99 +574,101 @@ class Hello final : // =================================================================== #ifdef __GNUC__ - #pragma GCC diagnostic push - #pragma GCC diagnostic ignored "-Wstrict-aliasing" +#pragma GCC diagnostic push +#pragma GCC diagnostic ignored "-Wstrict-aliasing" #endif // __GNUC__ // Header // .control.Meta meta = 1; inline bool Header::_internal_has_meta() const { - return this != internal_default_instance() && _impl_.meta_ != nullptr; + return this != internal_default_instance() && _impl_.meta_ != nullptr; } inline bool Header::has_meta() const { - return _internal_has_meta(); + return _internal_has_meta(); } inline void Header::clear_meta() { - if (GetArenaForAllocation() == nullptr && _impl_.meta_ != nullptr) { - delete _impl_.meta_; - } - _impl_.meta_ = nullptr; + if (GetArenaForAllocation() == nullptr && _impl_.meta_ != nullptr) { + delete _impl_.meta_; + } + _impl_.meta_ = nullptr; } inline const ::control::Meta& Header::_internal_meta() const { - const ::control::Meta* p = _impl_.meta_; - return p != nullptr ? *p : reinterpret_cast( - ::control::_Meta_default_instance_); + const ::control::Meta* p = _impl_.meta_; + return p != nullptr ? *p : reinterpret_cast( + ::control::_Meta_default_instance_); } inline const ::control::Meta& Header::meta() const { - // @@protoc_insertion_point(field_get:control.Header.meta) - return _internal_meta(); + // @@protoc_insertion_point(field_get:control.Header.meta) + return _internal_meta(); } inline void Header::unsafe_arena_set_allocated_meta( - ::control::Meta* meta) { - if (GetArenaForAllocation() == nullptr) { - delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.meta_); - } - _impl_.meta_ = meta; - if (meta) { - - } else { - - } - // @@protoc_insertion_point(field_unsafe_arena_set_allocated:control.Header.meta) + ::control::Meta* meta) { + if (GetArenaForAllocation() == nullptr) { + delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.meta_); + } + _impl_.meta_ = meta; + if (meta) { + + } else { + + } + // @@protoc_insertion_point(field_unsafe_arena_set_allocated:control.Header.meta) } inline ::control::Meta* Header::release_meta() { - - ::control::Meta* temp = _impl_.meta_; - _impl_.meta_ = nullptr; + + ::control::Meta* temp = _impl_.meta_; + _impl_.meta_ = nullptr; #ifdef PROTOBUF_FORCE_COPY_IN_RELEASE - auto* old = reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp); - temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp); - if (GetArenaForAllocation() == nullptr) { delete old; } + auto* old = reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp); + temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp); + if (GetArenaForAllocation() == nullptr) { + delete old; + } #else // PROTOBUF_FORCE_COPY_IN_RELEASE - if (GetArenaForAllocation() != nullptr) { - temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp); - } + if (GetArenaForAllocation() != nullptr) { + temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp); + } #endif // !PROTOBUF_FORCE_COPY_IN_RELEASE - return temp; + return temp; } inline ::control::Meta* Header::unsafe_arena_release_meta() { - // @@protoc_insertion_point(field_release:control.Header.meta) - - ::control::Meta* temp = _impl_.meta_; - _impl_.meta_ = nullptr; - return temp; + // @@protoc_insertion_point(field_release:control.Header.meta) + + ::control::Meta* temp = _impl_.meta_; + _impl_.meta_ = nullptr; + return temp; } inline ::control::Meta* Header::_internal_mutable_meta() { - - if (_impl_.meta_ == nullptr) { - auto* p = CreateMaybeMessage<::control::Meta>(GetArenaForAllocation()); - _impl_.meta_ = p; - } - return _impl_.meta_; + + if (_impl_.meta_ == nullptr) { + auto* p = CreateMaybeMessage<::control::Meta>(GetArenaForAllocation()); + _impl_.meta_ = p; + } + return _impl_.meta_; } inline ::control::Meta* Header::mutable_meta() { - ::control::Meta* _msg = _internal_mutable_meta(); - // @@protoc_insertion_point(field_mutable:control.Header.meta) - return _msg; + ::control::Meta* _msg = _internal_mutable_meta(); + // @@protoc_insertion_point(field_mutable:control.Header.meta) + return _msg; } inline void Header::set_allocated_meta(::control::Meta* meta) { - ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); - if (message_arena == nullptr) { - delete _impl_.meta_; - } - if (meta) { - ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = - ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(meta); - if (message_arena != submessage_arena) { - meta = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( - message_arena, meta, submessage_arena); - } - - } else { - - } - _impl_.meta_ = meta; - // @@protoc_insertion_point(field_set_allocated:control.Header.meta) + ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); + if (message_arena == nullptr) { + delete _impl_.meta_; + } + if (meta) { + ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = + ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(meta); + if (message_arena != submessage_arena) { + meta = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( + message_arena, meta, submessage_arena); + } + + } else { + + } + _impl_.meta_ = meta; + // @@protoc_insertion_point(field_set_allocated:control.Header.meta) } // ------------------------------------------------------------------- @@ -606,52 +677,52 @@ inline void Header::set_allocated_meta(::control::Meta* meta) { // string rpcname = 1; inline void Meta::clear_rpcname() { - _impl_.rpcname_.ClearToEmpty(); + _impl_.rpcname_.ClearToEmpty(); } inline const std::string& Meta::rpcname() const { - // @@protoc_insertion_point(field_get:control.Meta.rpcname) - return _internal_rpcname(); + // @@protoc_insertion_point(field_get:control.Meta.rpcname) + return _internal_rpcname(); } template inline PROTOBUF_ALWAYS_INLINE void Meta::set_rpcname(ArgT0&& arg0, ArgT... args) { - - _impl_.rpcname_.Set(static_cast(arg0), args..., GetArenaForAllocation()); - // @@protoc_insertion_point(field_set:control.Meta.rpcname) + + _impl_.rpcname_.Set(static_cast(arg0), args..., GetArenaForAllocation()); + // @@protoc_insertion_point(field_set:control.Meta.rpcname) } inline std::string* Meta::mutable_rpcname() { - std::string* _s = _internal_mutable_rpcname(); - // @@protoc_insertion_point(field_mutable:control.Meta.rpcname) - return _s; + std::string* _s = _internal_mutable_rpcname(); + // @@protoc_insertion_point(field_mutable:control.Meta.rpcname) + return _s; } inline const std::string& Meta::_internal_rpcname() const { - return _impl_.rpcname_.Get(); + return _impl_.rpcname_.Get(); } inline void Meta::_internal_set_rpcname(const std::string& value) { - - _impl_.rpcname_.Set(value, GetArenaForAllocation()); + + _impl_.rpcname_.Set(value, GetArenaForAllocation()); } inline std::string* Meta::_internal_mutable_rpcname() { - - return _impl_.rpcname_.Mutable(GetArenaForAllocation()); + + return _impl_.rpcname_.Mutable(GetArenaForAllocation()); } inline std::string* Meta::release_rpcname() { - // @@protoc_insertion_point(field_release:control.Meta.rpcname) - return _impl_.rpcname_.Release(); + // @@protoc_insertion_point(field_release:control.Meta.rpcname) + return _impl_.rpcname_.Release(); } inline void Meta::set_allocated_rpcname(std::string* rpcname) { - if (rpcname != nullptr) { - - } else { - - } - _impl_.rpcname_.SetAllocated(rpcname, GetArenaForAllocation()); + if (rpcname != nullptr) { + + } else { + + } + _impl_.rpcname_.SetAllocated(rpcname, GetArenaForAllocation()); #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING - if (_impl_.rpcname_.IsDefault()) { - _impl_.rpcname_.Set("", GetArenaForAllocation()); - } + if (_impl_.rpcname_.IsDefault()) { + _impl_.rpcname_.Set("", GetArenaForAllocation()); + } #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING - // @@protoc_insertion_point(field_set_allocated:control.Meta.rpcname) + // @@protoc_insertion_point(field_set_allocated:control.Meta.rpcname) } // ------------------------------------------------------------------- @@ -660,166 +731,168 @@ inline void Meta::set_allocated_rpcname(std::string* rpcname) { // .control.Meta meta = 1; inline bool Hello::_internal_has_meta() const { - return this != internal_default_instance() && _impl_.meta_ != nullptr; + return this != internal_default_instance() && _impl_.meta_ != nullptr; } inline bool Hello::has_meta() const { - return _internal_has_meta(); + return _internal_has_meta(); } inline void Hello::clear_meta() { - if (GetArenaForAllocation() == nullptr && _impl_.meta_ != nullptr) { - delete _impl_.meta_; - } - _impl_.meta_ = nullptr; + if (GetArenaForAllocation() == nullptr && _impl_.meta_ != nullptr) { + delete _impl_.meta_; + } + _impl_.meta_ = nullptr; } inline const ::control::Meta& Hello::_internal_meta() const { - const ::control::Meta* p = _impl_.meta_; - return p != nullptr ? *p : reinterpret_cast( - ::control::_Meta_default_instance_); + const ::control::Meta* p = _impl_.meta_; + return p != nullptr ? *p : reinterpret_cast( + ::control::_Meta_default_instance_); } inline const ::control::Meta& Hello::meta() const { - // @@protoc_insertion_point(field_get:control.Hello.meta) - return _internal_meta(); + // @@protoc_insertion_point(field_get:control.Hello.meta) + return _internal_meta(); } inline void Hello::unsafe_arena_set_allocated_meta( - ::control::Meta* meta) { - if (GetArenaForAllocation() == nullptr) { - delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.meta_); - } - _impl_.meta_ = meta; - if (meta) { - - } else { - - } - // @@protoc_insertion_point(field_unsafe_arena_set_allocated:control.Hello.meta) + ::control::Meta* meta) { + if (GetArenaForAllocation() == nullptr) { + delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.meta_); + } + _impl_.meta_ = meta; + if (meta) { + + } else { + + } + // @@protoc_insertion_point(field_unsafe_arena_set_allocated:control.Hello.meta) } inline ::control::Meta* Hello::release_meta() { - - ::control::Meta* temp = _impl_.meta_; - _impl_.meta_ = nullptr; + + ::control::Meta* temp = _impl_.meta_; + _impl_.meta_ = nullptr; #ifdef PROTOBUF_FORCE_COPY_IN_RELEASE - auto* old = reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp); - temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp); - if (GetArenaForAllocation() == nullptr) { delete old; } + auto* old = reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp); + temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp); + if (GetArenaForAllocation() == nullptr) { + delete old; + } #else // PROTOBUF_FORCE_COPY_IN_RELEASE - if (GetArenaForAllocation() != nullptr) { - temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp); - } + if (GetArenaForAllocation() != nullptr) { + temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp); + } #endif // !PROTOBUF_FORCE_COPY_IN_RELEASE - return temp; + return temp; } inline ::control::Meta* Hello::unsafe_arena_release_meta() { - // @@protoc_insertion_point(field_release:control.Hello.meta) - - ::control::Meta* temp = _impl_.meta_; - _impl_.meta_ = nullptr; - return temp; + // @@protoc_insertion_point(field_release:control.Hello.meta) + + ::control::Meta* temp = _impl_.meta_; + _impl_.meta_ = nullptr; + return temp; } inline ::control::Meta* Hello::_internal_mutable_meta() { - - if (_impl_.meta_ == nullptr) { - auto* p = CreateMaybeMessage<::control::Meta>(GetArenaForAllocation()); - _impl_.meta_ = p; - } - return _impl_.meta_; + + if (_impl_.meta_ == nullptr) { + auto* p = CreateMaybeMessage<::control::Meta>(GetArenaForAllocation()); + _impl_.meta_ = p; + } + return _impl_.meta_; } inline ::control::Meta* Hello::mutable_meta() { - ::control::Meta* _msg = _internal_mutable_meta(); - // @@protoc_insertion_point(field_mutable:control.Hello.meta) - return _msg; + ::control::Meta* _msg = _internal_mutable_meta(); + // @@protoc_insertion_point(field_mutable:control.Hello.meta) + return _msg; } inline void Hello::set_allocated_meta(::control::Meta* meta) { - ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); - if (message_arena == nullptr) { - delete _impl_.meta_; - } - if (meta) { - ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = - ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(meta); - if (message_arena != submessage_arena) { - meta = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( - message_arena, meta, submessage_arena); - } - - } else { - - } - _impl_.meta_ = meta; - // @@protoc_insertion_point(field_set_allocated:control.Hello.meta) + ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); + if (message_arena == nullptr) { + delete _impl_.meta_; + } + if (meta) { + ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = + ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(meta); + if (message_arena != submessage_arena) { + meta = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( + message_arena, meta, submessage_arena); + } + + } else { + + } + _impl_.meta_ = meta; + // @@protoc_insertion_point(field_set_allocated:control.Hello.meta) } // int32 id = 2; inline void Hello::clear_id() { - _impl_.id_ = 0; + _impl_.id_ = 0; } inline int32_t Hello::_internal_id() const { - return _impl_.id_; + return _impl_.id_; } inline int32_t Hello::id() const { - // @@protoc_insertion_point(field_get:control.Hello.id) - return _internal_id(); + // @@protoc_insertion_point(field_get:control.Hello.id) + return _internal_id(); } inline void Hello::_internal_set_id(int32_t value) { - - _impl_.id_ = value; + + _impl_.id_ = value; } inline void Hello::set_id(int32_t value) { - _internal_set_id(value); - // @@protoc_insertion_point(field_set:control.Hello.id) + _internal_set_id(value); + // @@protoc_insertion_point(field_set:control.Hello.id) } // string name = 3; inline void Hello::clear_name() { - _impl_.name_.ClearToEmpty(); + _impl_.name_.ClearToEmpty(); } inline const std::string& Hello::name() const { - // @@protoc_insertion_point(field_get:control.Hello.name) - return _internal_name(); + // @@protoc_insertion_point(field_get:control.Hello.name) + return _internal_name(); } template inline PROTOBUF_ALWAYS_INLINE void Hello::set_name(ArgT0&& arg0, ArgT... args) { - - _impl_.name_.Set(static_cast(arg0), args..., GetArenaForAllocation()); - // @@protoc_insertion_point(field_set:control.Hello.name) + + _impl_.name_.Set(static_cast(arg0), args..., GetArenaForAllocation()); + // @@protoc_insertion_point(field_set:control.Hello.name) } inline std::string* Hello::mutable_name() { - std::string* _s = _internal_mutable_name(); - // @@protoc_insertion_point(field_mutable:control.Hello.name) - return _s; + std::string* _s = _internal_mutable_name(); + // @@protoc_insertion_point(field_mutable:control.Hello.name) + return _s; } inline const std::string& Hello::_internal_name() const { - return _impl_.name_.Get(); + return _impl_.name_.Get(); } inline void Hello::_internal_set_name(const std::string& value) { - - _impl_.name_.Set(value, GetArenaForAllocation()); + + _impl_.name_.Set(value, GetArenaForAllocation()); } inline std::string* Hello::_internal_mutable_name() { - - return _impl_.name_.Mutable(GetArenaForAllocation()); + + return _impl_.name_.Mutable(GetArenaForAllocation()); } inline std::string* Hello::release_name() { - // @@protoc_insertion_point(field_release:control.Hello.name) - return _impl_.name_.Release(); + // @@protoc_insertion_point(field_release:control.Hello.name) + return _impl_.name_.Release(); } inline void Hello::set_allocated_name(std::string* name) { - if (name != nullptr) { - - } else { - - } - _impl_.name_.SetAllocated(name, GetArenaForAllocation()); + if (name != nullptr) { + + } else { + + } + _impl_.name_.SetAllocated(name, GetArenaForAllocation()); #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING - if (_impl_.name_.IsDefault()) { - _impl_.name_.Set("", GetArenaForAllocation()); - } + if (_impl_.name_.IsDefault()) { + _impl_.name_.Set("", GetArenaForAllocation()); + } #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING - // @@protoc_insertion_point(field_set_allocated:control.Hello.name) + // @@protoc_insertion_point(field_set_allocated:control.Hello.name) } #ifdef __GNUC__ - #pragma GCC diagnostic pop +#pragma GCC diagnostic pop #endif // __GNUC__ // ------------------------------------------------------------------- diff --git a/hello.proto b/hello.proto index 3a6b43d..0fa8d28 100644 --- a/hello.proto +++ b/hello.proto @@ -1,8 +1,8 @@ syntax = "proto3"; package control; -option optimize_for = LITE_RUNTIME; -option cc_generic_services = false; +//option optimize_for = LITE_RUNTIME; +//option cc_generic_services = false; message Header { Meta meta = 1; diff --git a/rcpclient.hpp b/rcpclient.hpp new file mode 100644 index 0000000..5aa0721 --- /dev/null +++ b/rcpclient.hpp @@ -0,0 +1,11 @@ + + +#include +#include +#include +#include +#include +#include + +class RPCClient { +}; diff --git a/rpcclient.cpp b/rpcclient.cpp new file mode 100644 index 0000000..8dbaa1c --- /dev/null +++ b/rpcclient.cpp @@ -0,0 +1,18 @@ + + +#include +#include +#include +#include +#include +#include + +#include + +#include + +//google::protobuf::Message + +std::expected Transaction(const google::protobuf::Message& m) { + return {}; +} diff --git a/tcpclient.cpp b/tcpclient.cpp index 64750ad..2ba781a 100644 --- a/tcpclient.cpp +++ b/tcpclient.cpp @@ -15,6 +15,12 @@ extern "C" { #include #include +#include +#include +#include +#include + + #include TCPClient::TCPClient() { @@ -25,9 +31,9 @@ TCPClient::TCPClient() { std::expected TCPClient::Connect(const std::string naddress, const int port) { struct sockaddr_in sa; - if (inet_pton(AF_INET, address.c_str(), &(sa.sin_addr)) == 1) { + if (inet_pton(AF_INET, naddress.c_str(), &(sa.sin_addr)) == 1) { family = AF_INET; - } else if (inet_pton(AF_INET6, address.c_str(), &(sa.sin_addr)) == 1) { + } else if (inet_pton(AF_INET6, naddress.c_str(), &(sa.sin_addr)) == 1) { family = AF_INET6; } else { int errnocopy = errno; @@ -44,7 +50,7 @@ std::expected TCPClient::Connect(const std::string naddress, serv_addr.sin_family = AF_INET; serv_addr.sin_port = htons(port); - const char* addr = address.data(); + const char* addr = naddress.data(); if (inet_pton(AF_INET, addr, &serv_addr.sin_addr) <= 0) { return std::unexpected("Invalid server IP address"); } @@ -65,15 +71,6 @@ std::expected TCPClient::Connect(const std::string naddress, return {}; } - -std::expected TCPClient::Write(std::span payload) { - int n = 0; - if ((n = write(sock, payload.data(), payload.size())) < 0) { - return std::unexpected("Write error"); - } - return n; -} - std::expected TCPClient::Write(std::string payload) { int n = 0; if ((n = write(sock, payload.data(), payload.size())) < 0) { @@ -82,16 +79,18 @@ std::expected TCPClient::Write(std::string payload) { return n; } -std::expected TCPClient::Read(std::vector* buffer) { - int n = 0; - if ((n = read(sock, buffer->data(), buffer->size())) < 0) { +std::expected TCPClient::Read(std::string& res, int size) { + char buffer[size + 1]; + memset(&buffer, 0, size + 1); + int rsize = 0; + if ((rsize = read(sock, &buffer, size)) < 0) { return std::unexpected("Read error"); } - return n; + res.append(buffer, rsize); + return rsize; } -std::expected TCPClient::Read(std::vector* buffer) { - return read(sock, buffer->data(), buffer->size()); +TCPClient::~TCPClient() { + close(sock); } - diff --git a/tcpclient.hpp b/tcpclient.hpp index 4ccf0a1..f5fbb2d 100644 --- a/tcpclient.hpp +++ b/tcpclient.hpp @@ -10,16 +10,9 @@ private: int sock; int family; public: - TCPClient(); + TCPClient(void); std::expected Connect(std::string address, const int port); - - std::expected Write(std::span payload); std::expected Write(std::string payload); - - std::expected Read(std::vector* buffer); - std::expected Read(std::vector* buffer); - - ~TCPClient() { - close(sock); - } + std::expected Read(std::string& buffer, int size); + ~TCPClient(void); }; diff --git a/tcpclient_test.cpp b/tcpclient_test.cpp index d63c98f..ae97649 100644 --- a/tcpclient_test.cpp +++ b/tcpclient_test.cpp @@ -20,15 +20,13 @@ int main( int argc, char** argv) { return 1; } - std::vector buffer; - buffer.resize(2048); - auto rSize = client.Read(&buffer); + std::string buffer; + auto rSize = client.Read(buffer, 8); if (!rSize) { std::cerr << rSize.error() << std::endl; return 1; } - std::cout << rSize.value() << std::endl; + std::cout << std::format("read {} bytes", rSize.value()) << std::endl; + std::cout << std::format("{}", buffer) << std::endl; - std::string s(buffer.begin(), buffer.end()); - std::cout << std::format("{}", s) << std::endl; } diff --git a/works/header/header.cpp b/works/header/header.cpp index f6bd4d1..8dff1e8 100644 --- a/works/header/header.cpp +++ b/works/header/header.cpp @@ -13,37 +13,37 @@ extern "C" { #include Header::Header(const uint32_t ipSize) { - pSize = ipSize; + pSize = ipSize; } Header::Header(void) { - pSize = 0; + pSize = 0; } std::string Header::Encode() { - std::string buffer, tmp; - auto magic = htonl(MAGIC); - tmp = std::string(reinterpret_cast(&magic), sizeof(magic)); - buffer.append(tmp); + std::string buffer, tmp; + auto magic = htonl(MAGIC); + tmp = std::string(reinterpret_cast(&magic), sizeof(magic)); + buffer.append(tmp); - auto size = htonl(pSize); - tmp = std::string(reinterpret_cast(&size), sizeof(size)); - buffer.append(tmp); - return buffer; + auto size = htonl(pSize); + tmp = std::string(reinterpret_cast(&size), sizeof(size)); + buffer.append(tmp); + return buffer; } std::expected Header::Decode(const std::string rawHeader) { - uint32_t tmp; - std::memcpy(&tmp, rawHeader.data(), sizeof(uint32_t)); - auto magic = ntohl(tmp); - if (magic != MAGIC) { - return std::unexpected("Wrong magic code"); - } - std::memcpy(&tmp, rawHeader.data() + sizeof(uint32_t), sizeof(uint32_t)); - pSize = ntohl(tmp); - return {}; + uint32_t tmp; + std::memcpy(&tmp, rawHeader.data(), sizeof(uint32_t)); + auto magic = ntohl(tmp); + if (magic != MAGIC) { + return std::unexpected("Wrong magic code"); + } + std::memcpy(&tmp, rawHeader.data() + sizeof(uint32_t), sizeof(uint32_t)); + pSize = ntohl(tmp); + return {}; } uint32_t Header::PacketSize() { - return pSize; + return pSize; } diff --git a/works/header/header.hpp b/works/header/header.hpp index 95a1f3a..5849e0b 100644 --- a/works/header/header.hpp +++ b/works/header/header.hpp @@ -5,12 +5,12 @@ const uint32_t MAGIC = 0xABBA; class Header { private: - uint32_t pSize = 0; + uint32_t pSize = 0; public: - Header(const uint32_t pSize); - Header(void); - std::string Encode(void); - std::expected Decode(const std::string buffer); - uint32_t PacketSize(void); + Header(const uint32_t pSize); + Header(void); + std::string Encode(void); + std::expected Decode(const std::string buffer); + uint32_t PacketSize(void); }; diff --git a/works/header/header_test.cpp b/works/header/header_test.cpp index 4701956..025b9e8 100644 --- a/works/header/header_test.cpp +++ b/works/header/header_test.cpp @@ -8,13 +8,13 @@ #include int main(int argc, char** argv) { - uint32_t size = - Header primary(1021); - auto rawHeader = primary.Encode(); + uint32_t size = + Header primary(1021); + auto rawHeader = primary.Encode(); - Header second; - second.Decode(rawHeader); + Header second; + second.Decode(rawHeader); - std::cout << std::format("{}\n", second.PacketSize()); - assert + std::cout << std::format("{}\n", second.PacketSize()); + assert } diff --git a/works/header/packet.cpp b/works/header/packet.cpp new file mode 100644 index 0000000..f1086cc --- /dev/null +++ b/works/header/packet.cpp @@ -0,0 +1,7 @@ + + + +class Packet { + std::string meta; + std::string payload; +}