// Generated by the protocol buffer compiler. DO NOT EDIT! // source: keyapis/telemetry_control/v1/keyapis_telemetry_control_stream_v1.proto #include "keyapis/telemetry_control/v1/keyapis_telemetry_control_stream_v1.pb.h" #include #include "google/protobuf/io/coded_stream.h" #include "google/protobuf/extension_set.h" #include "google/protobuf/wire_format_lite.h" #include "google/protobuf/io/zero_copy_stream_impl_lite.h" // @@protoc_insertion_point(includes) // Must be included last. #include "google/protobuf/port_def.inc" PROTOBUF_PRAGMA_INIT_SEG namespace _pb = ::PROTOBUF_NAMESPACE_ID; namespace _pbi = ::PROTOBUF_NAMESPACE_ID::internal; namespace keyapis { namespace telemetry_control { namespace v1 { template PROTOBUF_CONSTEXPR PostResourceFullDuplexResponse_RemoveResourceEvent::PostResourceFullDuplexResponse_RemoveResourceEvent( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_._has_bits_)*/{} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_.resource_id_)*/nullptr} {} struct PostResourceFullDuplexResponse_RemoveResourceEventDefaultTypeInternal { PROTOBUF_CONSTEXPR PostResourceFullDuplexResponse_RemoveResourceEventDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {} ~PostResourceFullDuplexResponse_RemoveResourceEventDefaultTypeInternal() {} union { PostResourceFullDuplexResponse_RemoveResourceEvent _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 PostResourceFullDuplexResponse_RemoveResourceEventDefaultTypeInternal _PostResourceFullDuplexResponse_RemoveResourceEvent_default_instance_; template PROTOBUF_CONSTEXPR PostResourceFullDuplexResponse_UpsertResourceEvent::PostResourceFullDuplexResponse_UpsertResourceEvent( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_._has_bits_)*/{} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_.resource_)*/nullptr} {} struct PostResourceFullDuplexResponse_UpsertResourceEventDefaultTypeInternal { PROTOBUF_CONSTEXPR PostResourceFullDuplexResponse_UpsertResourceEventDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {} ~PostResourceFullDuplexResponse_UpsertResourceEventDefaultTypeInternal() {} union { PostResourceFullDuplexResponse_UpsertResourceEvent _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 PostResourceFullDuplexResponse_UpsertResourceEventDefaultTypeInternal _PostResourceFullDuplexResponse_UpsertResourceEvent_default_instance_; template PROTOBUF_CONSTEXPR PostResourceFullDuplexResponse::PostResourceFullDuplexResponse( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_.request_id_)*/ { &::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized {} } , /*decltype(_impl_.event_)*/{} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{}} {} struct PostResourceFullDuplexResponseDefaultTypeInternal { PROTOBUF_CONSTEXPR PostResourceFullDuplexResponseDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {} ~PostResourceFullDuplexResponseDefaultTypeInternal() {} union { PostResourceFullDuplexResponse _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 PostResourceFullDuplexResponseDefaultTypeInternal _PostResourceFullDuplexResponse_default_instance_; template PROTOBUF_CONSTEXPR ResourceId::ResourceId( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_.type_)*/{} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{}} {} struct ResourceIdDefaultTypeInternal { PROTOBUF_CONSTEXPR ResourceIdDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {} ~ResourceIdDefaultTypeInternal() {} union { ResourceId _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 ResourceIdDefaultTypeInternal _ResourceId_default_instance_; template PROTOBUF_CONSTEXPR Resource::Resource( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_.type_)*/{} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{}} {} struct ResourceDefaultTypeInternal { PROTOBUF_CONSTEXPR ResourceDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {} ~ResourceDefaultTypeInternal() {} union { Resource _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 ResourceDefaultTypeInternal _Resource_default_instance_; template PROTOBUF_CONSTEXPR PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::PostResourceFullDuplexRequest_ResourceAsyncStatus_Success( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_._cached_size_)*/{}} {} struct PostResourceFullDuplexRequest_ResourceAsyncStatus_SuccessDefaultTypeInternal { PROTOBUF_CONSTEXPR PostResourceFullDuplexRequest_ResourceAsyncStatus_SuccessDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {} ~PostResourceFullDuplexRequest_ResourceAsyncStatus_SuccessDefaultTypeInternal() {} union { PostResourceFullDuplexRequest_ResourceAsyncStatus_Success _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 PostResourceFullDuplexRequest_ResourceAsyncStatus_SuccessDefaultTypeInternal _PostResourceFullDuplexRequest_ResourceAsyncStatus_Success_default_instance_; template PROTOBUF_CONSTEXPR PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_.message_)*/ { &::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized {} } , /*decltype(_impl_._cached_size_)*/{}} {} struct PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownErrorDefaultTypeInternal { PROTOBUF_CONSTEXPR PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownErrorDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {} ~PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownErrorDefaultTypeInternal() {} union { PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownErrorDefaultTypeInternal _PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError_default_instance_; template PROTOBUF_CONSTEXPR PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_.reason_)*/{} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{}} {} struct PostResourceFullDuplexRequest_ResourceAsyncStatus_ErrorDefaultTypeInternal { PROTOBUF_CONSTEXPR PostResourceFullDuplexRequest_ResourceAsyncStatus_ErrorDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {} ~PostResourceFullDuplexRequest_ResourceAsyncStatus_ErrorDefaultTypeInternal() {} union { PostResourceFullDuplexRequest_ResourceAsyncStatus_Error _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 PostResourceFullDuplexRequest_ResourceAsyncStatus_ErrorDefaultTypeInternal _PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_default_instance_; template PROTOBUF_CONSTEXPR PostResourceFullDuplexRequest_ResourceAsyncStatus::PostResourceFullDuplexRequest_ResourceAsyncStatus( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_._has_bits_)*/{} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_.resource_id_)*/nullptr , /*decltype(_impl_.type_)*/{} , /*decltype(_impl_._oneof_case_)*/{}} {} struct PostResourceFullDuplexRequest_ResourceAsyncStatusDefaultTypeInternal { PROTOBUF_CONSTEXPR PostResourceFullDuplexRequest_ResourceAsyncStatusDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {} ~PostResourceFullDuplexRequest_ResourceAsyncStatusDefaultTypeInternal() {} union { PostResourceFullDuplexRequest_ResourceAsyncStatus _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 PostResourceFullDuplexRequest_ResourceAsyncStatusDefaultTypeInternal _PostResourceFullDuplexRequest_ResourceAsyncStatus_default_instance_; template PROTOBUF_CONSTEXPR PostResourceFullDuplexRequest::PostResourceFullDuplexRequest( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_.request_id_)*/ { &::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized {} } , /*decltype(_impl_.task_)*/{} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{}} {} struct PostResourceFullDuplexRequestDefaultTypeInternal { PROTOBUF_CONSTEXPR PostResourceFullDuplexRequestDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {} ~PostResourceFullDuplexRequestDefaultTypeInternal() {} union { PostResourceFullDuplexRequest _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 PostResourceFullDuplexRequestDefaultTypeInternal _PostResourceFullDuplexRequest_default_instance_; } // namespace v1 } // namespace telemetry_control } // namespace keyapis namespace keyapis { namespace telemetry_control { namespace v1 { // =================================================================== class PostResourceFullDuplexResponse_RemoveResourceEvent::_Internal { public: using HasBits = decltype(std::declval()._impl_._has_bits_); static constexpr ::int32_t kHasBitsOffset = 8 * PROTOBUF_FIELD_OFFSET(PostResourceFullDuplexResponse_RemoveResourceEvent, _impl_._has_bits_); static const ::keyapis::telemetry_control::v1::ResourceId& resource_id(const PostResourceFullDuplexResponse_RemoveResourceEvent* msg); static void set_has_resource_id(HasBits* has_bits) { (*has_bits)[0] |= 1u; } }; const ::keyapis::telemetry_control::v1::ResourceId& PostResourceFullDuplexResponse_RemoveResourceEvent::_Internal::resource_id(const PostResourceFullDuplexResponse_RemoveResourceEvent* msg) { return *msg->_impl_.resource_id_; } PostResourceFullDuplexResponse_RemoveResourceEvent::PostResourceFullDuplexResponse_RemoveResourceEvent(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena) { SharedCtor(arena); // @@protoc_insertion_point(arena_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.RemoveResourceEvent) } PostResourceFullDuplexResponse_RemoveResourceEvent::PostResourceFullDuplexResponse_RemoveResourceEvent(const PostResourceFullDuplexResponse_RemoveResourceEvent& from) : ::PROTOBUF_NAMESPACE_ID::MessageLite() { PostResourceFullDuplexResponse_RemoveResourceEvent* const _this = this; (void)_this; new (&_impl_) Impl_{ decltype(_impl_._has_bits_){from._impl_._has_bits_} , /*decltype(_impl_._cached_size_)*/{} , decltype(_impl_.resource_id_){nullptr}}; _internal_metadata_.MergeFrom(from._internal_metadata_); if ((from._impl_._has_bits_[0] & 0x00000001u) != 0) { _this->_impl_.resource_id_ = new ::keyapis::telemetry_control::v1::ResourceId(*from._impl_.resource_id_); } // @@protoc_insertion_point(copy_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.RemoveResourceEvent) } inline void PostResourceFullDuplexResponse_RemoveResourceEvent::SharedCtor(::_pb::Arena* arena) { (void)arena; new (&_impl_) Impl_{ decltype(_impl_._has_bits_){} , /*decltype(_impl_._cached_size_)*/{} , decltype(_impl_.resource_id_){nullptr} }; } PostResourceFullDuplexResponse_RemoveResourceEvent::~PostResourceFullDuplexResponse_RemoveResourceEvent() { // @@protoc_insertion_point(destructor:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.RemoveResourceEvent) if (auto *arena = _internal_metadata_.DeleteReturnArena()) { (void)arena; return; } SharedDtor(); } inline void PostResourceFullDuplexResponse_RemoveResourceEvent::SharedDtor() { ABSL_DCHECK(GetArenaForAllocation() == nullptr); if (this != internal_default_instance()) delete _impl_.resource_id_; } void PostResourceFullDuplexResponse_RemoveResourceEvent::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } void PostResourceFullDuplexResponse_RemoveResourceEvent::Clear() { // @@protoc_insertion_point(message_clear_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.RemoveResourceEvent) ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; cached_has_bits = _impl_._has_bits_[0]; if (cached_has_bits & 0x00000001u) { ABSL_DCHECK(_impl_.resource_id_ != nullptr); _impl_.resource_id_->Clear(); } _impl_._has_bits_.Clear(); _internal_metadata_.Clear(); } const char* PostResourceFullDuplexResponse_RemoveResourceEvent::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure _Internal::HasBits has_bits{}; while (!ctx->Done(&ptr)) { ::uint32_t tag; ptr = ::_pbi::ReadTag(ptr, &tag); switch (tag >> 3) { // .keyapis.telemetry_control.v1.ResourceId resource_id = 1 [(.google.api.field_behavior) = REQUIRED]; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) { ptr = ctx->ParseMessage(_internal_mutable_resource_id(), 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 message_done: _impl_._has_bits_.Or(has_bits); return ptr; failure: ptr = nullptr; goto message_done; #undef CHK_ } ::uint8_t* PostResourceFullDuplexResponse_RemoveResourceEvent::_InternalSerialize( ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.RemoveResourceEvent) ::uint32_t cached_has_bits = 0; (void) cached_has_bits; cached_has_bits = _impl_._has_bits_[0]; // .keyapis.telemetry_control.v1.ResourceId resource_id = 1 [(.google.api.field_behavior) = REQUIRED]; if (cached_has_bits & 0x00000001u) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(1, _Internal::resource_id(this), _Internal::resource_id(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:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.RemoveResourceEvent) return target; } ::size_t PostResourceFullDuplexResponse_RemoveResourceEvent::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.RemoveResourceEvent) ::size_t total_size = 0; ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // .keyapis.telemetry_control.v1.ResourceId resource_id = 1 [(.google.api.field_behavior) = REQUIRED]; cached_has_bits = _impl_._has_bits_[0]; if (cached_has_bits & 0x00000001u) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.resource_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; } void PostResourceFullDuplexResponse_RemoveResourceEvent::CheckTypeAndMergeFrom( const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) { MergeFrom(*::_pbi::DownCast( &from)); } void PostResourceFullDuplexResponse_RemoveResourceEvent::MergeFrom(const PostResourceFullDuplexResponse_RemoveResourceEvent& from) { PostResourceFullDuplexResponse_RemoveResourceEvent* const _this = this; // @@protoc_insertion_point(class_specific_merge_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.RemoveResourceEvent) ABSL_DCHECK_NE(&from, _this); ::uint32_t cached_has_bits = 0; (void) cached_has_bits; if ((from._impl_._has_bits_[0] & 0x00000001u) != 0) { _this->_internal_mutable_resource_id()->::keyapis::telemetry_control::v1::ResourceId::MergeFrom( from._internal_resource_id()); } _this->_internal_metadata_.MergeFrom(from._internal_metadata_); } void PostResourceFullDuplexResponse_RemoveResourceEvent::CopyFrom(const PostResourceFullDuplexResponse_RemoveResourceEvent& from) { // @@protoc_insertion_point(class_specific_copy_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.RemoveResourceEvent) if (&from == this) return; Clear(); MergeFrom(from); } bool PostResourceFullDuplexResponse_RemoveResourceEvent::IsInitialized() const { return true; } void PostResourceFullDuplexResponse_RemoveResourceEvent::InternalSwap(PostResourceFullDuplexResponse_RemoveResourceEvent* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); swap(_impl_._has_bits_[0], other->_impl_._has_bits_[0]); swap(_impl_.resource_id_, other->_impl_.resource_id_); } std::string PostResourceFullDuplexResponse_RemoveResourceEvent::GetTypeName() const { return "keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.RemoveResourceEvent"; } // =================================================================== class PostResourceFullDuplexResponse_UpsertResourceEvent::_Internal { public: using HasBits = decltype(std::declval()._impl_._has_bits_); static constexpr ::int32_t kHasBitsOffset = 8 * PROTOBUF_FIELD_OFFSET(PostResourceFullDuplexResponse_UpsertResourceEvent, _impl_._has_bits_); static const ::keyapis::telemetry_control::v1::Resource& resource(const PostResourceFullDuplexResponse_UpsertResourceEvent* msg); static void set_has_resource(HasBits* has_bits) { (*has_bits)[0] |= 1u; } }; const ::keyapis::telemetry_control::v1::Resource& PostResourceFullDuplexResponse_UpsertResourceEvent::_Internal::resource(const PostResourceFullDuplexResponse_UpsertResourceEvent* msg) { return *msg->_impl_.resource_; } PostResourceFullDuplexResponse_UpsertResourceEvent::PostResourceFullDuplexResponse_UpsertResourceEvent(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena) { SharedCtor(arena); // @@protoc_insertion_point(arena_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.UpsertResourceEvent) } PostResourceFullDuplexResponse_UpsertResourceEvent::PostResourceFullDuplexResponse_UpsertResourceEvent(const PostResourceFullDuplexResponse_UpsertResourceEvent& from) : ::PROTOBUF_NAMESPACE_ID::MessageLite() { PostResourceFullDuplexResponse_UpsertResourceEvent* const _this = this; (void)_this; new (&_impl_) Impl_{ decltype(_impl_._has_bits_){from._impl_._has_bits_} , /*decltype(_impl_._cached_size_)*/{} , decltype(_impl_.resource_){nullptr}}; _internal_metadata_.MergeFrom(from._internal_metadata_); if ((from._impl_._has_bits_[0] & 0x00000001u) != 0) { _this->_impl_.resource_ = new ::keyapis::telemetry_control::v1::Resource(*from._impl_.resource_); } // @@protoc_insertion_point(copy_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.UpsertResourceEvent) } inline void PostResourceFullDuplexResponse_UpsertResourceEvent::SharedCtor(::_pb::Arena* arena) { (void)arena; new (&_impl_) Impl_{ decltype(_impl_._has_bits_){} , /*decltype(_impl_._cached_size_)*/{} , decltype(_impl_.resource_){nullptr} }; } PostResourceFullDuplexResponse_UpsertResourceEvent::~PostResourceFullDuplexResponse_UpsertResourceEvent() { // @@protoc_insertion_point(destructor:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.UpsertResourceEvent) if (auto *arena = _internal_metadata_.DeleteReturnArena()) { (void)arena; return; } SharedDtor(); } inline void PostResourceFullDuplexResponse_UpsertResourceEvent::SharedDtor() { ABSL_DCHECK(GetArenaForAllocation() == nullptr); if (this != internal_default_instance()) delete _impl_.resource_; } void PostResourceFullDuplexResponse_UpsertResourceEvent::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } void PostResourceFullDuplexResponse_UpsertResourceEvent::Clear() { // @@protoc_insertion_point(message_clear_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.UpsertResourceEvent) ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; cached_has_bits = _impl_._has_bits_[0]; if (cached_has_bits & 0x00000001u) { ABSL_DCHECK(_impl_.resource_ != nullptr); _impl_.resource_->Clear(); } _impl_._has_bits_.Clear(); _internal_metadata_.Clear(); } const char* PostResourceFullDuplexResponse_UpsertResourceEvent::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure _Internal::HasBits has_bits{}; while (!ctx->Done(&ptr)) { ::uint32_t tag; ptr = ::_pbi::ReadTag(ptr, &tag); switch (tag >> 3) { // .keyapis.telemetry_control.v1.Resource resource = 1 [(.google.api.field_behavior) = REQUIRED]; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) { ptr = ctx->ParseMessage(_internal_mutable_resource(), 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 message_done: _impl_._has_bits_.Or(has_bits); return ptr; failure: ptr = nullptr; goto message_done; #undef CHK_ } ::uint8_t* PostResourceFullDuplexResponse_UpsertResourceEvent::_InternalSerialize( ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.UpsertResourceEvent) ::uint32_t cached_has_bits = 0; (void) cached_has_bits; cached_has_bits = _impl_._has_bits_[0]; // .keyapis.telemetry_control.v1.Resource resource = 1 [(.google.api.field_behavior) = REQUIRED]; if (cached_has_bits & 0x00000001u) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(1, _Internal::resource(this), _Internal::resource(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:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.UpsertResourceEvent) return target; } ::size_t PostResourceFullDuplexResponse_UpsertResourceEvent::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.UpsertResourceEvent) ::size_t total_size = 0; ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // .keyapis.telemetry_control.v1.Resource resource = 1 [(.google.api.field_behavior) = REQUIRED]; cached_has_bits = _impl_._has_bits_[0]; if (cached_has_bits & 0x00000001u) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.resource_); } 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; } void PostResourceFullDuplexResponse_UpsertResourceEvent::CheckTypeAndMergeFrom( const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) { MergeFrom(*::_pbi::DownCast( &from)); } void PostResourceFullDuplexResponse_UpsertResourceEvent::MergeFrom(const PostResourceFullDuplexResponse_UpsertResourceEvent& from) { PostResourceFullDuplexResponse_UpsertResourceEvent* const _this = this; // @@protoc_insertion_point(class_specific_merge_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.UpsertResourceEvent) ABSL_DCHECK_NE(&from, _this); ::uint32_t cached_has_bits = 0; (void) cached_has_bits; if ((from._impl_._has_bits_[0] & 0x00000001u) != 0) { _this->_internal_mutable_resource()->::keyapis::telemetry_control::v1::Resource::MergeFrom( from._internal_resource()); } _this->_internal_metadata_.MergeFrom(from._internal_metadata_); } void PostResourceFullDuplexResponse_UpsertResourceEvent::CopyFrom(const PostResourceFullDuplexResponse_UpsertResourceEvent& from) { // @@protoc_insertion_point(class_specific_copy_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.UpsertResourceEvent) if (&from == this) return; Clear(); MergeFrom(from); } bool PostResourceFullDuplexResponse_UpsertResourceEvent::IsInitialized() const { return true; } void PostResourceFullDuplexResponse_UpsertResourceEvent::InternalSwap(PostResourceFullDuplexResponse_UpsertResourceEvent* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); swap(_impl_._has_bits_[0], other->_impl_._has_bits_[0]); swap(_impl_.resource_, other->_impl_.resource_); } std::string PostResourceFullDuplexResponse_UpsertResourceEvent::GetTypeName() const { return "keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.UpsertResourceEvent"; } // =================================================================== class PostResourceFullDuplexResponse::_Internal { public: static constexpr ::int32_t kOneofCaseOffset = PROTOBUF_FIELD_OFFSET(::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse, _impl_._oneof_case_); static const ::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_UpsertResourceEvent& upsert_resource_event(const PostResourceFullDuplexResponse* msg); static const ::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_RemoveResourceEvent& remove_resource_event(const PostResourceFullDuplexResponse* msg); }; const ::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_UpsertResourceEvent& PostResourceFullDuplexResponse::_Internal::upsert_resource_event(const PostResourceFullDuplexResponse* msg) { return *msg->_impl_.event_.upsert_resource_event_; } const ::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_RemoveResourceEvent& PostResourceFullDuplexResponse::_Internal::remove_resource_event(const PostResourceFullDuplexResponse* msg) { return *msg->_impl_.event_.remove_resource_event_; } void PostResourceFullDuplexResponse::set_allocated_upsert_resource_event(::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_UpsertResourceEvent* upsert_resource_event) { ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); clear_event(); if (upsert_resource_event) { ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(upsert_resource_event); if (message_arena != submessage_arena) { upsert_resource_event = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( message_arena, upsert_resource_event, submessage_arena); } set_has_upsert_resource_event(); _impl_.event_.upsert_resource_event_ = upsert_resource_event; } // @@protoc_insertion_point(field_set_allocated:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.upsert_resource_event) } void PostResourceFullDuplexResponse::set_allocated_remove_resource_event(::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_RemoveResourceEvent* remove_resource_event) { ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); clear_event(); if (remove_resource_event) { ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(remove_resource_event); if (message_arena != submessage_arena) { remove_resource_event = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( message_arena, remove_resource_event, submessage_arena); } set_has_remove_resource_event(); _impl_.event_.remove_resource_event_ = remove_resource_event; } // @@protoc_insertion_point(field_set_allocated:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.remove_resource_event) } PostResourceFullDuplexResponse::PostResourceFullDuplexResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena) { SharedCtor(arena); // @@protoc_insertion_point(arena_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse) } PostResourceFullDuplexResponse::PostResourceFullDuplexResponse(const PostResourceFullDuplexResponse& from) : ::PROTOBUF_NAMESPACE_ID::MessageLite() { PostResourceFullDuplexResponse* const _this = this; (void)_this; new (&_impl_) Impl_{ decltype(_impl_.request_id_) {} , decltype(_impl_.event_){} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{}}; _internal_metadata_.MergeFrom(from._internal_metadata_); _impl_.request_id_.InitDefault(); #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING _impl_.request_id_.Set("", GetArenaForAllocation()); #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING if (!from._internal_request_id().empty()) { _this->_impl_.request_id_.Set(from._internal_request_id(), _this->GetArenaForAllocation()); } clear_has_event(); switch (from.event_case()) { case kUpsertResourceEvent: { _this->_internal_mutable_upsert_resource_event()->::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_UpsertResourceEvent::MergeFrom( from._internal_upsert_resource_event()); break; } case kRemoveResourceEvent: { _this->_internal_mutable_remove_resource_event()->::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_RemoveResourceEvent::MergeFrom( from._internal_remove_resource_event()); break; } case EVENT_NOT_SET: { break; } } // @@protoc_insertion_point(copy_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse) } inline void PostResourceFullDuplexResponse::SharedCtor(::_pb::Arena* arena) { (void)arena; new (&_impl_) Impl_{ decltype(_impl_.request_id_) {} , decltype(_impl_.event_){} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{} }; _impl_.request_id_.InitDefault(); #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING _impl_.request_id_.Set("", GetArenaForAllocation()); #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING clear_has_event(); } PostResourceFullDuplexResponse::~PostResourceFullDuplexResponse() { // @@protoc_insertion_point(destructor:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse) if (auto *arena = _internal_metadata_.DeleteReturnArena()) { (void)arena; return; } SharedDtor(); } inline void PostResourceFullDuplexResponse::SharedDtor() { ABSL_DCHECK(GetArenaForAllocation() == nullptr); _impl_.request_id_.Destroy(); if (has_event()) { clear_event(); } } void PostResourceFullDuplexResponse::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } void PostResourceFullDuplexResponse::clear_event() { // @@protoc_insertion_point(one_of_clear_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse) switch (event_case()) { case kUpsertResourceEvent: { if (GetArenaForAllocation() == nullptr) { delete _impl_.event_.upsert_resource_event_; } break; } case kRemoveResourceEvent: { if (GetArenaForAllocation() == nullptr) { delete _impl_.event_.remove_resource_event_; } break; } case EVENT_NOT_SET: { break; } } _impl_._oneof_case_[0] = EVENT_NOT_SET; } void PostResourceFullDuplexResponse::Clear() { // @@protoc_insertion_point(message_clear_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse) ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; _impl_.request_id_.ClearToEmpty(); clear_event(); _internal_metadata_.Clear(); } const char* PostResourceFullDuplexResponse::_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 request_id = 1 [(.google.api.field_behavior) = REQUIRED]; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) { auto str = _internal_mutable_request_id(); ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); CHK_(::_pbi::VerifyUTF8(str, nullptr)); } else { goto handle_unusual; } continue; // .keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.UpsertResourceEvent upsert_resource_event = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 18)) { ptr = ctx->ParseMessage(_internal_mutable_upsert_resource_event(), ptr); CHK_(ptr); } else { goto handle_unusual; } continue; // .keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.RemoveResourceEvent remove_resource_event = 3; case 3: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 26)) { ptr = ctx->ParseMessage(_internal_mutable_remove_resource_event(), 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 message_done: return ptr; failure: ptr = nullptr; goto message_done; #undef CHK_ } ::uint8_t* PostResourceFullDuplexResponse::_InternalSerialize( ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse) ::uint32_t cached_has_bits = 0; (void) cached_has_bits; // string request_id = 1 [(.google.api.field_behavior) = REQUIRED]; if (!this->_internal_request_id().empty()) { const std::string& _s = this->_internal_request_id(); ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( _s.data(), static_cast(_s.length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.request_id"); target = stream->WriteStringMaybeAliased(1, _s, target); } switch (event_case()) { case kUpsertResourceEvent: { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(2, _Internal::upsert_resource_event(this), _Internal::upsert_resource_event(this).GetCachedSize(), target, stream); break; } case kRemoveResourceEvent: { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(3, _Internal::remove_resource_event(this), _Internal::remove_resource_event(this).GetCachedSize(), target, stream); break; } default: ; } 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:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse) return target; } ::size_t PostResourceFullDuplexResponse::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse) ::size_t total_size = 0; ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // string request_id = 1 [(.google.api.field_behavior) = REQUIRED]; if (!this->_internal_request_id().empty()) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( this->_internal_request_id()); } switch (event_case()) { // .keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.UpsertResourceEvent upsert_resource_event = 2; case kUpsertResourceEvent: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.event_.upsert_resource_event_); break; } // .keyapis.telemetry_control.v1.PostResourceFullDuplexResponse.RemoveResourceEvent remove_resource_event = 3; case kRemoveResourceEvent: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.event_.remove_resource_event_); break; } case EVENT_NOT_SET: { break; } } 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; } void PostResourceFullDuplexResponse::CheckTypeAndMergeFrom( const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) { MergeFrom(*::_pbi::DownCast( &from)); } void PostResourceFullDuplexResponse::MergeFrom(const PostResourceFullDuplexResponse& from) { PostResourceFullDuplexResponse* const _this = this; // @@protoc_insertion_point(class_specific_merge_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse) ABSL_DCHECK_NE(&from, _this); ::uint32_t cached_has_bits = 0; (void) cached_has_bits; if (!from._internal_request_id().empty()) { _this->_internal_set_request_id(from._internal_request_id()); } switch (from.event_case()) { case kUpsertResourceEvent: { _this->_internal_mutable_upsert_resource_event()->::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_UpsertResourceEvent::MergeFrom( from._internal_upsert_resource_event()); break; } case kRemoveResourceEvent: { _this->_internal_mutable_remove_resource_event()->::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_RemoveResourceEvent::MergeFrom( from._internal_remove_resource_event()); break; } case EVENT_NOT_SET: { break; } } _this->_internal_metadata_.MergeFrom(from._internal_metadata_); } void PostResourceFullDuplexResponse::CopyFrom(const PostResourceFullDuplexResponse& from) { // @@protoc_insertion_point(class_specific_copy_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexResponse) if (&from == this) return; Clear(); MergeFrom(from); } bool PostResourceFullDuplexResponse::IsInitialized() const { return true; } void PostResourceFullDuplexResponse::InternalSwap(PostResourceFullDuplexResponse* other) { using std::swap; auto* lhs_arena = GetArenaForAllocation(); auto* rhs_arena = other->GetArenaForAllocation(); _internal_metadata_.InternalSwap(&other->_internal_metadata_); ::_pbi::ArenaStringPtr::InternalSwap(&_impl_.request_id_, lhs_arena, &other->_impl_.request_id_, rhs_arena); swap(_impl_.event_, other->_impl_.event_); swap(_impl_._oneof_case_[0], other->_impl_._oneof_case_[0]); } std::string PostResourceFullDuplexResponse::GetTypeName() const { return "keyapis.telemetry_control.v1.PostResourceFullDuplexResponse"; } // =================================================================== class ResourceId::_Internal { public: static constexpr ::int32_t kOneofCaseOffset = PROTOBUF_FIELD_OFFSET(::keyapis::telemetry_control::v1::ResourceId, _impl_._oneof_case_); static const ::keyapis::telemetry_control::v1::DeviceIndicatorMetricPoint& indicator_metric_point(const ResourceId* msg); }; const ::keyapis::telemetry_control::v1::DeviceIndicatorMetricPoint& ResourceId::_Internal::indicator_metric_point(const ResourceId* msg) { return *msg->_impl_.type_.indicator_metric_point_; } void ResourceId::set_allocated_indicator_metric_point(::keyapis::telemetry_control::v1::DeviceIndicatorMetricPoint* indicator_metric_point) { ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); clear_type(); if (indicator_metric_point) { ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena( reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(indicator_metric_point)); if (message_arena != submessage_arena) { indicator_metric_point = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( message_arena, indicator_metric_point, submessage_arena); } set_has_indicator_metric_point(); _impl_.type_.indicator_metric_point_ = indicator_metric_point; } // @@protoc_insertion_point(field_set_allocated:keyapis.telemetry_control.v1.ResourceId.indicator_metric_point) } void ResourceId::clear_indicator_metric_point() { if (type_case() == kIndicatorMetricPoint) { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.indicator_metric_point_; } clear_has_type(); } } ResourceId::ResourceId(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena) { SharedCtor(arena); // @@protoc_insertion_point(arena_constructor:keyapis.telemetry_control.v1.ResourceId) } ResourceId::ResourceId(const ResourceId& from) : ::PROTOBUF_NAMESPACE_ID::MessageLite() { ResourceId* const _this = this; (void)_this; new (&_impl_) Impl_{ decltype(_impl_.type_){} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{}}; _internal_metadata_.MergeFrom(from._internal_metadata_); clear_has_type(); switch (from.type_case()) { case kBuildingId: { _this->_internal_set_building_id(from._internal_building_id()); break; } case kDeviceId: { _this->_internal_set_device_id(from._internal_device_id()); break; } case kMetricPointId: { _this->_internal_set_metric_point_id(from._internal_metric_point_id()); break; } case kIndicatorId: { _this->_internal_set_indicator_id(from._internal_indicator_id()); break; } case kIndicatorMetricPoint: { _this->_internal_mutable_indicator_metric_point()->::keyapis::telemetry_control::v1::DeviceIndicatorMetricPoint::MergeFrom( from._internal_indicator_metric_point()); break; } case TYPE_NOT_SET: { break; } } // @@protoc_insertion_point(copy_constructor:keyapis.telemetry_control.v1.ResourceId) } inline void ResourceId::SharedCtor(::_pb::Arena* arena) { (void)arena; new (&_impl_) Impl_{ decltype(_impl_.type_){} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{} }; clear_has_type(); } ResourceId::~ResourceId() { // @@protoc_insertion_point(destructor:keyapis.telemetry_control.v1.ResourceId) if (auto *arena = _internal_metadata_.DeleteReturnArena()) { (void)arena; return; } SharedDtor(); } inline void ResourceId::SharedDtor() { ABSL_DCHECK(GetArenaForAllocation() == nullptr); if (has_type()) { clear_type(); } } void ResourceId::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } void ResourceId::clear_type() { // @@protoc_insertion_point(one_of_clear_start:keyapis.telemetry_control.v1.ResourceId) switch (type_case()) { case kBuildingId: { // No need to clear break; } case kDeviceId: { // No need to clear break; } case kMetricPointId: { _impl_.type_.metric_point_id_.Destroy(); break; } case kIndicatorId: { // No need to clear break; } case kIndicatorMetricPoint: { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.indicator_metric_point_; } break; } case TYPE_NOT_SET: { break; } } _impl_._oneof_case_[0] = TYPE_NOT_SET; } void ResourceId::Clear() { // @@protoc_insertion_point(message_clear_start:keyapis.telemetry_control.v1.ResourceId) ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; clear_type(); _internal_metadata_.Clear(); } const char* ResourceId::_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) { // int32 building_id = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 8)) { _internal_set_building_id(::PROTOBUF_NAMESPACE_ID::internal::ReadVarint32(&ptr)); CHK_(ptr); } else { goto handle_unusual; } continue; // int32 device_id = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 16)) { _internal_set_device_id(::PROTOBUF_NAMESPACE_ID::internal::ReadVarint32(&ptr)); CHK_(ptr); } else { goto handle_unusual; } continue; // string metric_point_id = 3; case 3: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 26)) { auto str = _internal_mutable_metric_point_id(); ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); CHK_(::_pbi::VerifyUTF8(str, nullptr)); } else { goto handle_unusual; } continue; // int32 indicator_id = 4; case 4: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 32)) { _internal_set_indicator_id(::PROTOBUF_NAMESPACE_ID::internal::ReadVarint32(&ptr)); CHK_(ptr); } else { goto handle_unusual; } continue; // .keyapis.telemetry_control.v1.DeviceIndicatorMetricPoint indicator_metric_point = 5; case 5: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 42)) { ptr = ctx->ParseMessage(_internal_mutable_indicator_metric_point(), 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 message_done: return ptr; failure: ptr = nullptr; goto message_done; #undef CHK_ } ::uint8_t* ResourceId::_InternalSerialize( ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:keyapis.telemetry_control.v1.ResourceId) ::uint32_t cached_has_bits = 0; (void) cached_has_bits; switch (type_case()) { case kBuildingId: { target = stream->EnsureSpace(target); target = ::_pbi::WireFormatLite::WriteInt32ToArray( 1, this->_internal_building_id(), target); break; } case kDeviceId: { target = stream->EnsureSpace(target); target = ::_pbi::WireFormatLite::WriteInt32ToArray( 2, this->_internal_device_id(), target); break; } case kMetricPointId: { const std::string& _s = this->_internal_metric_point_id(); ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( _s.data(), static_cast(_s.length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "keyapis.telemetry_control.v1.ResourceId.metric_point_id"); target = stream->WriteStringMaybeAliased(3, _s, target); break; } case kIndicatorId: { target = stream->EnsureSpace(target); target = ::_pbi::WireFormatLite::WriteInt32ToArray( 4, this->_internal_indicator_id(), target); break; } case kIndicatorMetricPoint: { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(5, _Internal::indicator_metric_point(this), _Internal::indicator_metric_point(this).GetCachedSize(), target, stream); break; } default: ; } 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:keyapis.telemetry_control.v1.ResourceId) return target; } ::size_t ResourceId::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:keyapis.telemetry_control.v1.ResourceId) ::size_t total_size = 0; ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; switch (type_case()) { // int32 building_id = 1; case kBuildingId: { total_size += ::_pbi::WireFormatLite::Int32SizePlusOne( this->_internal_building_id()); break; } // int32 device_id = 2; case kDeviceId: { total_size += ::_pbi::WireFormatLite::Int32SizePlusOne( this->_internal_device_id()); break; } // string metric_point_id = 3; case kMetricPointId: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( this->_internal_metric_point_id()); break; } // int32 indicator_id = 4; case kIndicatorId: { total_size += ::_pbi::WireFormatLite::Int32SizePlusOne( this->_internal_indicator_id()); break; } // .keyapis.telemetry_control.v1.DeviceIndicatorMetricPoint indicator_metric_point = 5; case kIndicatorMetricPoint: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.type_.indicator_metric_point_); break; } case TYPE_NOT_SET: { break; } } 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; } void ResourceId::CheckTypeAndMergeFrom( const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) { MergeFrom(*::_pbi::DownCast( &from)); } void ResourceId::MergeFrom(const ResourceId& from) { ResourceId* const _this = this; // @@protoc_insertion_point(class_specific_merge_from_start:keyapis.telemetry_control.v1.ResourceId) ABSL_DCHECK_NE(&from, _this); ::uint32_t cached_has_bits = 0; (void) cached_has_bits; switch (from.type_case()) { case kBuildingId: { _this->_internal_set_building_id(from._internal_building_id()); break; } case kDeviceId: { _this->_internal_set_device_id(from._internal_device_id()); break; } case kMetricPointId: { _this->_internal_set_metric_point_id(from._internal_metric_point_id()); break; } case kIndicatorId: { _this->_internal_set_indicator_id(from._internal_indicator_id()); break; } case kIndicatorMetricPoint: { _this->_internal_mutable_indicator_metric_point()->::keyapis::telemetry_control::v1::DeviceIndicatorMetricPoint::MergeFrom( from._internal_indicator_metric_point()); break; } case TYPE_NOT_SET: { break; } } _this->_internal_metadata_.MergeFrom(from._internal_metadata_); } void ResourceId::CopyFrom(const ResourceId& from) { // @@protoc_insertion_point(class_specific_copy_from_start:keyapis.telemetry_control.v1.ResourceId) if (&from == this) return; Clear(); MergeFrom(from); } bool ResourceId::IsInitialized() const { return true; } void ResourceId::InternalSwap(ResourceId* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); swap(_impl_.type_, other->_impl_.type_); swap(_impl_._oneof_case_[0], other->_impl_._oneof_case_[0]); } std::string ResourceId::GetTypeName() const { return "keyapis.telemetry_control.v1.ResourceId"; } // =================================================================== class Resource::_Internal { public: static constexpr ::int32_t kOneofCaseOffset = PROTOBUF_FIELD_OFFSET(::keyapis::telemetry_control::v1::Resource, _impl_._oneof_case_); static const ::keyapis::telemetry_control::v1::Building& building(const Resource* msg); static const ::keyapis::telemetry_control::v1::Device& device(const Resource* msg); static const ::keyapis::telemetry_control::v1::Device_MetricPoint& metric_point(const Resource* msg); static const ::keyapis::telemetry_control::v1::Indicator& indicator(const Resource* msg); static const ::keyapis::telemetry_control::v1::DeviceIndicatorMetricPoint& indicator_metric_point(const Resource* msg); }; const ::keyapis::telemetry_control::v1::Building& Resource::_Internal::building(const Resource* msg) { return *msg->_impl_.type_.building_; } const ::keyapis::telemetry_control::v1::Device& Resource::_Internal::device(const Resource* msg) { return *msg->_impl_.type_.device_; } const ::keyapis::telemetry_control::v1::Device_MetricPoint& Resource::_Internal::metric_point(const Resource* msg) { return *msg->_impl_.type_.metric_point_; } const ::keyapis::telemetry_control::v1::Indicator& Resource::_Internal::indicator(const Resource* msg) { return *msg->_impl_.type_.indicator_; } const ::keyapis::telemetry_control::v1::DeviceIndicatorMetricPoint& Resource::_Internal::indicator_metric_point(const Resource* msg) { return *msg->_impl_.type_.indicator_metric_point_; } void Resource::set_allocated_building(::keyapis::telemetry_control::v1::Building* building) { ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); clear_type(); if (building) { ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena( reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(building)); if (message_arena != submessage_arena) { building = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( message_arena, building, submessage_arena); } set_has_building(); _impl_.type_.building_ = building; } // @@protoc_insertion_point(field_set_allocated:keyapis.telemetry_control.v1.Resource.building) } void Resource::clear_building() { if (type_case() == kBuilding) { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.building_; } clear_has_type(); } } void Resource::set_allocated_device(::keyapis::telemetry_control::v1::Device* device) { ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); clear_type(); if (device) { ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena( reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(device)); if (message_arena != submessage_arena) { device = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( message_arena, device, submessage_arena); } set_has_device(); _impl_.type_.device_ = device; } // @@protoc_insertion_point(field_set_allocated:keyapis.telemetry_control.v1.Resource.device) } void Resource::clear_device() { if (type_case() == kDevice) { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.device_; } clear_has_type(); } } void Resource::set_allocated_metric_point(::keyapis::telemetry_control::v1::Device_MetricPoint* metric_point) { ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); clear_type(); if (metric_point) { ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena( reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(metric_point)); if (message_arena != submessage_arena) { metric_point = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( message_arena, metric_point, submessage_arena); } set_has_metric_point(); _impl_.type_.metric_point_ = metric_point; } // @@protoc_insertion_point(field_set_allocated:keyapis.telemetry_control.v1.Resource.metric_point) } void Resource::clear_metric_point() { if (type_case() == kMetricPoint) { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.metric_point_; } clear_has_type(); } } void Resource::set_allocated_indicator(::keyapis::telemetry_control::v1::Indicator* indicator) { ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); clear_type(); if (indicator) { ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena( reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(indicator)); if (message_arena != submessage_arena) { indicator = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( message_arena, indicator, submessage_arena); } set_has_indicator(); _impl_.type_.indicator_ = indicator; } // @@protoc_insertion_point(field_set_allocated:keyapis.telemetry_control.v1.Resource.indicator) } void Resource::clear_indicator() { if (type_case() == kIndicator) { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.indicator_; } clear_has_type(); } } void Resource::set_allocated_indicator_metric_point(::keyapis::telemetry_control::v1::DeviceIndicatorMetricPoint* indicator_metric_point) { ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); clear_type(); if (indicator_metric_point) { ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena( reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(indicator_metric_point)); if (message_arena != submessage_arena) { indicator_metric_point = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( message_arena, indicator_metric_point, submessage_arena); } set_has_indicator_metric_point(); _impl_.type_.indicator_metric_point_ = indicator_metric_point; } // @@protoc_insertion_point(field_set_allocated:keyapis.telemetry_control.v1.Resource.indicator_metric_point) } void Resource::clear_indicator_metric_point() { if (type_case() == kIndicatorMetricPoint) { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.indicator_metric_point_; } clear_has_type(); } } Resource::Resource(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena) { SharedCtor(arena); // @@protoc_insertion_point(arena_constructor:keyapis.telemetry_control.v1.Resource) } Resource::Resource(const Resource& from) : ::PROTOBUF_NAMESPACE_ID::MessageLite() { Resource* const _this = this; (void)_this; new (&_impl_) Impl_{ decltype(_impl_.type_){} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{}}; _internal_metadata_.MergeFrom(from._internal_metadata_); clear_has_type(); switch (from.type_case()) { case kBuilding: { _this->_internal_mutable_building()->::keyapis::telemetry_control::v1::Building::MergeFrom( from._internal_building()); break; } case kDevice: { _this->_internal_mutable_device()->::keyapis::telemetry_control::v1::Device::MergeFrom( from._internal_device()); break; } case kMetricPoint: { _this->_internal_mutable_metric_point()->::keyapis::telemetry_control::v1::Device_MetricPoint::MergeFrom( from._internal_metric_point()); break; } case kIndicator: { _this->_internal_mutable_indicator()->::keyapis::telemetry_control::v1::Indicator::MergeFrom( from._internal_indicator()); break; } case kIndicatorMetricPoint: { _this->_internal_mutable_indicator_metric_point()->::keyapis::telemetry_control::v1::DeviceIndicatorMetricPoint::MergeFrom( from._internal_indicator_metric_point()); break; } case TYPE_NOT_SET: { break; } } // @@protoc_insertion_point(copy_constructor:keyapis.telemetry_control.v1.Resource) } inline void Resource::SharedCtor(::_pb::Arena* arena) { (void)arena; new (&_impl_) Impl_{ decltype(_impl_.type_){} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{} }; clear_has_type(); } Resource::~Resource() { // @@protoc_insertion_point(destructor:keyapis.telemetry_control.v1.Resource) if (auto *arena = _internal_metadata_.DeleteReturnArena()) { (void)arena; return; } SharedDtor(); } inline void Resource::SharedDtor() { ABSL_DCHECK(GetArenaForAllocation() == nullptr); if (has_type()) { clear_type(); } } void Resource::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } void Resource::clear_type() { // @@protoc_insertion_point(one_of_clear_start:keyapis.telemetry_control.v1.Resource) switch (type_case()) { case kBuilding: { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.building_; } break; } case kDevice: { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.device_; } break; } case kMetricPoint: { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.metric_point_; } break; } case kIndicator: { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.indicator_; } break; } case kIndicatorMetricPoint: { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.indicator_metric_point_; } break; } case TYPE_NOT_SET: { break; } } _impl_._oneof_case_[0] = TYPE_NOT_SET; } void Resource::Clear() { // @@protoc_insertion_point(message_clear_start:keyapis.telemetry_control.v1.Resource) ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; clear_type(); _internal_metadata_.Clear(); } const char* Resource::_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) { // .keyapis.telemetry_control.v1.Building building = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) { ptr = ctx->ParseMessage(_internal_mutable_building(), ptr); CHK_(ptr); } else { goto handle_unusual; } continue; // .keyapis.telemetry_control.v1.Device device = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 18)) { ptr = ctx->ParseMessage(_internal_mutable_device(), ptr); CHK_(ptr); } else { goto handle_unusual; } continue; // .keyapis.telemetry_control.v1.Device.MetricPoint metric_point = 3; case 3: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 26)) { ptr = ctx->ParseMessage(_internal_mutable_metric_point(), ptr); CHK_(ptr); } else { goto handle_unusual; } continue; // .keyapis.telemetry_control.v1.Indicator indicator = 4; case 4: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 34)) { ptr = ctx->ParseMessage(_internal_mutable_indicator(), ptr); CHK_(ptr); } else { goto handle_unusual; } continue; // .keyapis.telemetry_control.v1.DeviceIndicatorMetricPoint indicator_metric_point = 5; case 5: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 42)) { ptr = ctx->ParseMessage(_internal_mutable_indicator_metric_point(), 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 message_done: return ptr; failure: ptr = nullptr; goto message_done; #undef CHK_ } ::uint8_t* Resource::_InternalSerialize( ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:keyapis.telemetry_control.v1.Resource) ::uint32_t cached_has_bits = 0; (void) cached_has_bits; switch (type_case()) { case kBuilding: { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(1, _Internal::building(this), _Internal::building(this).GetCachedSize(), target, stream); break; } case kDevice: { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(2, _Internal::device(this), _Internal::device(this).GetCachedSize(), target, stream); break; } case kMetricPoint: { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(3, _Internal::metric_point(this), _Internal::metric_point(this).GetCachedSize(), target, stream); break; } case kIndicator: { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(4, _Internal::indicator(this), _Internal::indicator(this).GetCachedSize(), target, stream); break; } case kIndicatorMetricPoint: { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(5, _Internal::indicator_metric_point(this), _Internal::indicator_metric_point(this).GetCachedSize(), target, stream); break; } default: ; } 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:keyapis.telemetry_control.v1.Resource) return target; } ::size_t Resource::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:keyapis.telemetry_control.v1.Resource) ::size_t total_size = 0; ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; switch (type_case()) { // .keyapis.telemetry_control.v1.Building building = 1; case kBuilding: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.type_.building_); break; } // .keyapis.telemetry_control.v1.Device device = 2; case kDevice: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.type_.device_); break; } // .keyapis.telemetry_control.v1.Device.MetricPoint metric_point = 3; case kMetricPoint: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.type_.metric_point_); break; } // .keyapis.telemetry_control.v1.Indicator indicator = 4; case kIndicator: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.type_.indicator_); break; } // .keyapis.telemetry_control.v1.DeviceIndicatorMetricPoint indicator_metric_point = 5; case kIndicatorMetricPoint: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.type_.indicator_metric_point_); break; } case TYPE_NOT_SET: { break; } } 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; } void Resource::CheckTypeAndMergeFrom( const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) { MergeFrom(*::_pbi::DownCast( &from)); } void Resource::MergeFrom(const Resource& from) { Resource* const _this = this; // @@protoc_insertion_point(class_specific_merge_from_start:keyapis.telemetry_control.v1.Resource) ABSL_DCHECK_NE(&from, _this); ::uint32_t cached_has_bits = 0; (void) cached_has_bits; switch (from.type_case()) { case kBuilding: { _this->_internal_mutable_building()->::keyapis::telemetry_control::v1::Building::MergeFrom( from._internal_building()); break; } case kDevice: { _this->_internal_mutable_device()->::keyapis::telemetry_control::v1::Device::MergeFrom( from._internal_device()); break; } case kMetricPoint: { _this->_internal_mutable_metric_point()->::keyapis::telemetry_control::v1::Device_MetricPoint::MergeFrom( from._internal_metric_point()); break; } case kIndicator: { _this->_internal_mutable_indicator()->::keyapis::telemetry_control::v1::Indicator::MergeFrom( from._internal_indicator()); break; } case kIndicatorMetricPoint: { _this->_internal_mutable_indicator_metric_point()->::keyapis::telemetry_control::v1::DeviceIndicatorMetricPoint::MergeFrom( from._internal_indicator_metric_point()); break; } case TYPE_NOT_SET: { break; } } _this->_internal_metadata_.MergeFrom(from._internal_metadata_); } void Resource::CopyFrom(const Resource& from) { // @@protoc_insertion_point(class_specific_copy_from_start:keyapis.telemetry_control.v1.Resource) if (&from == this) return; Clear(); MergeFrom(from); } bool Resource::IsInitialized() const { return true; } void Resource::InternalSwap(Resource* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); swap(_impl_.type_, other->_impl_.type_); swap(_impl_._oneof_case_[0], other->_impl_._oneof_case_[0]); } std::string Resource::GetTypeName() const { return "keyapis.telemetry_control.v1.Resource"; } // =================================================================== class PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::_Internal { public: }; PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::PostResourceFullDuplexRequest_ResourceAsyncStatus_Success(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena) { SharedCtor(arena); // @@protoc_insertion_point(arena_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Success) } PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::PostResourceFullDuplexRequest_ResourceAsyncStatus_Success(const PostResourceFullDuplexRequest_ResourceAsyncStatus_Success& from) : ::PROTOBUF_NAMESPACE_ID::MessageLite(), _impl_(from._impl_) { _internal_metadata_.MergeFrom( from._internal_metadata_); // @@protoc_insertion_point(copy_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Success) } inline void PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::SharedCtor(::_pb::Arena* arena) { (void)arena; new (&_impl_) Impl_{ /*decltype(_impl_._cached_size_)*/{} }; } PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::~PostResourceFullDuplexRequest_ResourceAsyncStatus_Success() { // @@protoc_insertion_point(destructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Success) if (auto *arena = _internal_metadata_.DeleteReturnArena()) { (void)arena; return; } SharedDtor(); } inline void PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::SharedDtor() { ABSL_DCHECK(GetArenaForAllocation() == nullptr); } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::Clear() { // @@protoc_insertion_point(message_clear_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Success) ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; _internal_metadata_.Clear(); } const char* PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::_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); 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 message_done: return ptr; failure: ptr = nullptr; goto message_done; #undef CHK_ } ::uint8_t* PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::_InternalSerialize( ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Success) ::uint32_t cached_has_bits = 0; (void) cached_has_bits; 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:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Success) return target; } ::size_t PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Success) ::size_t total_size = 0; ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; 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; } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::CheckTypeAndMergeFrom( const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) { MergeFrom(*::_pbi::DownCast( &from)); } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::MergeFrom(const PostResourceFullDuplexRequest_ResourceAsyncStatus_Success& from) { PostResourceFullDuplexRequest_ResourceAsyncStatus_Success* const _this = this; // @@protoc_insertion_point(class_specific_merge_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Success) ABSL_DCHECK_NE(&from, _this); ::uint32_t cached_has_bits = 0; (void) cached_has_bits; _this->_internal_metadata_.MergeFrom(from._internal_metadata_); } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::CopyFrom(const PostResourceFullDuplexRequest_ResourceAsyncStatus_Success& from) { // @@protoc_insertion_point(class_specific_copy_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Success) if (&from == this) return; Clear(); MergeFrom(from); } bool PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::IsInitialized() const { return true; } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::InternalSwap(PostResourceFullDuplexRequest_ResourceAsyncStatus_Success* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); } std::string PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::GetTypeName() const { return "keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Success"; } // =================================================================== class PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::_Internal { public: }; PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena) { SharedCtor(arena); // @@protoc_insertion_point(arena_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError) } PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError(const PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError& from) : ::PROTOBUF_NAMESPACE_ID::MessageLite() { PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError* const _this = this; (void)_this; new (&_impl_) Impl_{ decltype(_impl_.message_) {} , /*decltype(_impl_._cached_size_)*/{}}; _internal_metadata_.MergeFrom(from._internal_metadata_); _impl_.message_.InitDefault(); #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING _impl_.message_.Set("", GetArenaForAllocation()); #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING if (!from._internal_message().empty()) { _this->_impl_.message_.Set(from._internal_message(), _this->GetArenaForAllocation()); } // @@protoc_insertion_point(copy_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError) } inline void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::SharedCtor(::_pb::Arena* arena) { (void)arena; new (&_impl_) Impl_{ decltype(_impl_.message_) {} , /*decltype(_impl_._cached_size_)*/{} }; _impl_.message_.InitDefault(); #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING _impl_.message_.Set("", GetArenaForAllocation()); #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING } PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::~PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError() { // @@protoc_insertion_point(destructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError) if (auto *arena = _internal_metadata_.DeleteReturnArena()) { (void)arena; return; } SharedDtor(); } inline void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::SharedDtor() { ABSL_DCHECK(GetArenaForAllocation() == nullptr); _impl_.message_.Destroy(); } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::Clear() { // @@protoc_insertion_point(message_clear_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError) ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; _impl_.message_.ClearToEmpty(); _internal_metadata_.Clear(); } const char* PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::_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 message = 1 [(.google.api.field_behavior) = REQUIRED]; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) { auto str = _internal_mutable_message(); 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 message_done: return ptr; failure: ptr = nullptr; goto message_done; #undef CHK_ } ::uint8_t* PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::_InternalSerialize( ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError) ::uint32_t cached_has_bits = 0; (void) cached_has_bits; // string message = 1 [(.google.api.field_behavior) = REQUIRED]; if (!this->_internal_message().empty()) { const std::string& _s = this->_internal_message(); ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( _s.data(), static_cast(_s.length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError.message"); target = stream->WriteStringMaybeAliased(1, _s, 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:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError) return target; } ::size_t PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError) ::size_t total_size = 0; ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // string message = 1 [(.google.api.field_behavior) = REQUIRED]; if (!this->_internal_message().empty()) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( this->_internal_message()); } 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; } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::CheckTypeAndMergeFrom( const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) { MergeFrom(*::_pbi::DownCast( &from)); } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::MergeFrom(const PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError& from) { PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError* const _this = this; // @@protoc_insertion_point(class_specific_merge_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError) ABSL_DCHECK_NE(&from, _this); ::uint32_t cached_has_bits = 0; (void) cached_has_bits; if (!from._internal_message().empty()) { _this->_internal_set_message(from._internal_message()); } _this->_internal_metadata_.MergeFrom(from._internal_metadata_); } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::CopyFrom(const PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError& from) { // @@protoc_insertion_point(class_specific_copy_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError) if (&from == this) return; Clear(); MergeFrom(from); } bool PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::IsInitialized() const { return true; } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::InternalSwap(PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError* other) { using std::swap; auto* lhs_arena = GetArenaForAllocation(); auto* rhs_arena = other->GetArenaForAllocation(); _internal_metadata_.InternalSwap(&other->_internal_metadata_); ::_pbi::ArenaStringPtr::InternalSwap(&_impl_.message_, lhs_arena, &other->_impl_.message_, rhs_arena); } std::string PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::GetTypeName() const { return "keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError"; } // =================================================================== class PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::_Internal { public: static constexpr ::int32_t kOneofCaseOffset = PROTOBUF_FIELD_OFFSET(::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error, _impl_._oneof_case_); static const ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError& unknown(const PostResourceFullDuplexRequest_ResourceAsyncStatus_Error* msg); }; const ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError& PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::_Internal::unknown(const PostResourceFullDuplexRequest_ResourceAsyncStatus_Error* msg) { return *msg->_impl_.reason_.unknown_; } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::set_allocated_unknown(::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError* unknown) { ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); clear_reason(); if (unknown) { ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(unknown); if (message_arena != submessage_arena) { unknown = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( message_arena, unknown, submessage_arena); } set_has_unknown(); _impl_.reason_.unknown_ = unknown; } // @@protoc_insertion_point(field_set_allocated:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.unknown) } PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena) { SharedCtor(arena); // @@protoc_insertion_point(arena_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error) } PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error(const PostResourceFullDuplexRequest_ResourceAsyncStatus_Error& from) : ::PROTOBUF_NAMESPACE_ID::MessageLite() { PostResourceFullDuplexRequest_ResourceAsyncStatus_Error* const _this = this; (void)_this; new (&_impl_) Impl_{ decltype(_impl_.reason_){} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{}}; _internal_metadata_.MergeFrom(from._internal_metadata_); clear_has_reason(); switch (from.reason_case()) { case kUnknown: { _this->_internal_mutable_unknown()->::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::MergeFrom( from._internal_unknown()); break; } case REASON_NOT_SET: { break; } } // @@protoc_insertion_point(copy_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error) } inline void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::SharedCtor(::_pb::Arena* arena) { (void)arena; new (&_impl_) Impl_{ decltype(_impl_.reason_){} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{} }; clear_has_reason(); } PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::~PostResourceFullDuplexRequest_ResourceAsyncStatus_Error() { // @@protoc_insertion_point(destructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error) if (auto *arena = _internal_metadata_.DeleteReturnArena()) { (void)arena; return; } SharedDtor(); } inline void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::SharedDtor() { ABSL_DCHECK(GetArenaForAllocation() == nullptr); if (has_reason()) { clear_reason(); } } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::clear_reason() { // @@protoc_insertion_point(one_of_clear_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error) switch (reason_case()) { case kUnknown: { if (GetArenaForAllocation() == nullptr) { delete _impl_.reason_.unknown_; } break; } case REASON_NOT_SET: { break; } } _impl_._oneof_case_[0] = REASON_NOT_SET; } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::Clear() { // @@protoc_insertion_point(message_clear_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error) ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; clear_reason(); _internal_metadata_.Clear(); } const char* PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::_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) { // .keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError unknown = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) { ptr = ctx->ParseMessage(_internal_mutable_unknown(), 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 message_done: return ptr; failure: ptr = nullptr; goto message_done; #undef CHK_ } ::uint8_t* PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::_InternalSerialize( ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error) ::uint32_t cached_has_bits = 0; (void) cached_has_bits; // .keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError unknown = 1; if (reason_case() == kUnknown) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(1, _Internal::unknown(this), _Internal::unknown(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:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error) return target; } ::size_t PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error) ::size_t total_size = 0; ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; switch (reason_case()) { // .keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error.UnknownError unknown = 1; case kUnknown: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.reason_.unknown_); break; } case REASON_NOT_SET: { break; } } 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; } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::CheckTypeAndMergeFrom( const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) { MergeFrom(*::_pbi::DownCast( &from)); } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::MergeFrom(const PostResourceFullDuplexRequest_ResourceAsyncStatus_Error& from) { PostResourceFullDuplexRequest_ResourceAsyncStatus_Error* const _this = this; // @@protoc_insertion_point(class_specific_merge_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error) ABSL_DCHECK_NE(&from, _this); ::uint32_t cached_has_bits = 0; (void) cached_has_bits; switch (from.reason_case()) { case kUnknown: { _this->_internal_mutable_unknown()->::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError::MergeFrom( from._internal_unknown()); break; } case REASON_NOT_SET: { break; } } _this->_internal_metadata_.MergeFrom(from._internal_metadata_); } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::CopyFrom(const PostResourceFullDuplexRequest_ResourceAsyncStatus_Error& from) { // @@protoc_insertion_point(class_specific_copy_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error) if (&from == this) return; Clear(); MergeFrom(from); } bool PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::IsInitialized() const { return true; } void PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::InternalSwap(PostResourceFullDuplexRequest_ResourceAsyncStatus_Error* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); swap(_impl_.reason_, other->_impl_.reason_); swap(_impl_._oneof_case_[0], other->_impl_._oneof_case_[0]); } std::string PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::GetTypeName() const { return "keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error"; } // =================================================================== class PostResourceFullDuplexRequest_ResourceAsyncStatus::_Internal { public: using HasBits = decltype(std::declval()._impl_._has_bits_); static constexpr ::int32_t kHasBitsOffset = 8 * PROTOBUF_FIELD_OFFSET(PostResourceFullDuplexRequest_ResourceAsyncStatus, _impl_._has_bits_); static constexpr ::int32_t kOneofCaseOffset = PROTOBUF_FIELD_OFFSET(::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus, _impl_._oneof_case_); static const ::keyapis::telemetry_control::v1::ResourceId& resource_id(const PostResourceFullDuplexRequest_ResourceAsyncStatus* msg); static void set_has_resource_id(HasBits* has_bits) { (*has_bits)[0] |= 1u; } static const ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Success& data(const PostResourceFullDuplexRequest_ResourceAsyncStatus* msg); static const ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error& error(const PostResourceFullDuplexRequest_ResourceAsyncStatus* msg); }; const ::keyapis::telemetry_control::v1::ResourceId& PostResourceFullDuplexRequest_ResourceAsyncStatus::_Internal::resource_id(const PostResourceFullDuplexRequest_ResourceAsyncStatus* msg) { return *msg->_impl_.resource_id_; } const ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Success& PostResourceFullDuplexRequest_ResourceAsyncStatus::_Internal::data(const PostResourceFullDuplexRequest_ResourceAsyncStatus* msg) { return *msg->_impl_.type_.data_; } const ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error& PostResourceFullDuplexRequest_ResourceAsyncStatus::_Internal::error(const PostResourceFullDuplexRequest_ResourceAsyncStatus* msg) { return *msg->_impl_.type_.error_; } void PostResourceFullDuplexRequest_ResourceAsyncStatus::set_allocated_data(::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Success* data) { ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); clear_type(); if (data) { ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(data); if (message_arena != submessage_arena) { data = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( message_arena, data, submessage_arena); } set_has_data(); _impl_.type_.data_ = data; } // @@protoc_insertion_point(field_set_allocated:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.data) } void PostResourceFullDuplexRequest_ResourceAsyncStatus::set_allocated_error(::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error* error) { ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); clear_type(); if (error) { ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(error); if (message_arena != submessage_arena) { error = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( message_arena, error, submessage_arena); } set_has_error(); _impl_.type_.error_ = error; } // @@protoc_insertion_point(field_set_allocated:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.error) } PostResourceFullDuplexRequest_ResourceAsyncStatus::PostResourceFullDuplexRequest_ResourceAsyncStatus(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena) { SharedCtor(arena); // @@protoc_insertion_point(arena_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus) } PostResourceFullDuplexRequest_ResourceAsyncStatus::PostResourceFullDuplexRequest_ResourceAsyncStatus(const PostResourceFullDuplexRequest_ResourceAsyncStatus& from) : ::PROTOBUF_NAMESPACE_ID::MessageLite() { PostResourceFullDuplexRequest_ResourceAsyncStatus* const _this = this; (void)_this; new (&_impl_) Impl_{ decltype(_impl_._has_bits_){from._impl_._has_bits_} , /*decltype(_impl_._cached_size_)*/{} , decltype(_impl_.resource_id_){nullptr} , decltype(_impl_.type_){} , /*decltype(_impl_._oneof_case_)*/{}}; _internal_metadata_.MergeFrom(from._internal_metadata_); if ((from._impl_._has_bits_[0] & 0x00000001u) != 0) { _this->_impl_.resource_id_ = new ::keyapis::telemetry_control::v1::ResourceId(*from._impl_.resource_id_); } clear_has_type(); switch (from.type_case()) { case kData: { _this->_internal_mutable_data()->::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::MergeFrom( from._internal_data()); break; } case kError: { _this->_internal_mutable_error()->::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::MergeFrom( from._internal_error()); break; } case TYPE_NOT_SET: { break; } } // @@protoc_insertion_point(copy_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus) } inline void PostResourceFullDuplexRequest_ResourceAsyncStatus::SharedCtor(::_pb::Arena* arena) { (void)arena; new (&_impl_) Impl_{ decltype(_impl_._has_bits_){} , /*decltype(_impl_._cached_size_)*/{} , decltype(_impl_.resource_id_){nullptr} , decltype(_impl_.type_){} , /*decltype(_impl_._oneof_case_)*/{} }; clear_has_type(); } PostResourceFullDuplexRequest_ResourceAsyncStatus::~PostResourceFullDuplexRequest_ResourceAsyncStatus() { // @@protoc_insertion_point(destructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus) if (auto *arena = _internal_metadata_.DeleteReturnArena()) { (void)arena; return; } SharedDtor(); } inline void PostResourceFullDuplexRequest_ResourceAsyncStatus::SharedDtor() { ABSL_DCHECK(GetArenaForAllocation() == nullptr); if (this != internal_default_instance()) delete _impl_.resource_id_; if (has_type()) { clear_type(); } } void PostResourceFullDuplexRequest_ResourceAsyncStatus::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } void PostResourceFullDuplexRequest_ResourceAsyncStatus::clear_type() { // @@protoc_insertion_point(one_of_clear_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus) switch (type_case()) { case kData: { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.data_; } break; } case kError: { if (GetArenaForAllocation() == nullptr) { delete _impl_.type_.error_; } break; } case TYPE_NOT_SET: { break; } } _impl_._oneof_case_[0] = TYPE_NOT_SET; } void PostResourceFullDuplexRequest_ResourceAsyncStatus::Clear() { // @@protoc_insertion_point(message_clear_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus) ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; cached_has_bits = _impl_._has_bits_[0]; if (cached_has_bits & 0x00000001u) { ABSL_DCHECK(_impl_.resource_id_ != nullptr); _impl_.resource_id_->Clear(); } clear_type(); _impl_._has_bits_.Clear(); _internal_metadata_.Clear(); } const char* PostResourceFullDuplexRequest_ResourceAsyncStatus::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure _Internal::HasBits has_bits{}; while (!ctx->Done(&ptr)) { ::uint32_t tag; ptr = ::_pbi::ReadTag(ptr, &tag); switch (tag >> 3) { // .keyapis.telemetry_control.v1.ResourceId resource_id = 1 [(.google.api.field_behavior) = REQUIRED]; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) { ptr = ctx->ParseMessage(_internal_mutable_resource_id(), ptr); CHK_(ptr); } else { goto handle_unusual; } continue; // .keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Success data = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 18)) { ptr = ctx->ParseMessage(_internal_mutable_data(), ptr); CHK_(ptr); } else { goto handle_unusual; } continue; // .keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error error = 3; case 3: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 26)) { ptr = ctx->ParseMessage(_internal_mutable_error(), 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 message_done: _impl_._has_bits_.Or(has_bits); return ptr; failure: ptr = nullptr; goto message_done; #undef CHK_ } ::uint8_t* PostResourceFullDuplexRequest_ResourceAsyncStatus::_InternalSerialize( ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus) ::uint32_t cached_has_bits = 0; (void) cached_has_bits; cached_has_bits = _impl_._has_bits_[0]; // .keyapis.telemetry_control.v1.ResourceId resource_id = 1 [(.google.api.field_behavior) = REQUIRED]; if (cached_has_bits & 0x00000001u) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(1, _Internal::resource_id(this), _Internal::resource_id(this).GetCachedSize(), target, stream); } switch (type_case()) { case kData: { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(2, _Internal::data(this), _Internal::data(this).GetCachedSize(), target, stream); break; } case kError: { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(3, _Internal::error(this), _Internal::error(this).GetCachedSize(), target, stream); break; } default: ; } 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:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus) return target; } ::size_t PostResourceFullDuplexRequest_ResourceAsyncStatus::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus) ::size_t total_size = 0; ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // .keyapis.telemetry_control.v1.ResourceId resource_id = 1 [(.google.api.field_behavior) = REQUIRED]; cached_has_bits = _impl_._has_bits_[0]; if (cached_has_bits & 0x00000001u) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.resource_id_); } switch (type_case()) { // .keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Success data = 2; case kData: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.type_.data_); break; } // .keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus.Error error = 3; case kError: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.type_.error_); break; } case TYPE_NOT_SET: { break; } } 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; } void PostResourceFullDuplexRequest_ResourceAsyncStatus::CheckTypeAndMergeFrom( const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) { MergeFrom(*::_pbi::DownCast( &from)); } void PostResourceFullDuplexRequest_ResourceAsyncStatus::MergeFrom(const PostResourceFullDuplexRequest_ResourceAsyncStatus& from) { PostResourceFullDuplexRequest_ResourceAsyncStatus* const _this = this; // @@protoc_insertion_point(class_specific_merge_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus) ABSL_DCHECK_NE(&from, _this); ::uint32_t cached_has_bits = 0; (void) cached_has_bits; if ((from._impl_._has_bits_[0] & 0x00000001u) != 0) { _this->_internal_mutable_resource_id()->::keyapis::telemetry_control::v1::ResourceId::MergeFrom( from._internal_resource_id()); } switch (from.type_case()) { case kData: { _this->_internal_mutable_data()->::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Success::MergeFrom( from._internal_data()); break; } case kError: { _this->_internal_mutable_error()->::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error::MergeFrom( from._internal_error()); break; } case TYPE_NOT_SET: { break; } } _this->_internal_metadata_.MergeFrom(from._internal_metadata_); } void PostResourceFullDuplexRequest_ResourceAsyncStatus::CopyFrom(const PostResourceFullDuplexRequest_ResourceAsyncStatus& from) { // @@protoc_insertion_point(class_specific_copy_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus) if (&from == this) return; Clear(); MergeFrom(from); } bool PostResourceFullDuplexRequest_ResourceAsyncStatus::IsInitialized() const { return true; } void PostResourceFullDuplexRequest_ResourceAsyncStatus::InternalSwap(PostResourceFullDuplexRequest_ResourceAsyncStatus* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); swap(_impl_._has_bits_[0], other->_impl_._has_bits_[0]); swap(_impl_.resource_id_, other->_impl_.resource_id_); swap(_impl_.type_, other->_impl_.type_); swap(_impl_._oneof_case_[0], other->_impl_._oneof_case_[0]); } std::string PostResourceFullDuplexRequest_ResourceAsyncStatus::GetTypeName() const { return "keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus"; } // =================================================================== class PostResourceFullDuplexRequest::_Internal { public: static constexpr ::int32_t kOneofCaseOffset = PROTOBUF_FIELD_OFFSET(::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest, _impl_._oneof_case_); static const ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus& resource_async_status(const PostResourceFullDuplexRequest* msg); }; const ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus& PostResourceFullDuplexRequest::_Internal::resource_async_status(const PostResourceFullDuplexRequest* msg) { return *msg->_impl_.task_.resource_async_status_; } void PostResourceFullDuplexRequest::set_allocated_resource_async_status(::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus* resource_async_status) { ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation(); clear_task(); if (resource_async_status) { ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(resource_async_status); if (message_arena != submessage_arena) { resource_async_status = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( message_arena, resource_async_status, submessage_arena); } set_has_resource_async_status(); _impl_.task_.resource_async_status_ = resource_async_status; } // @@protoc_insertion_point(field_set_allocated:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.resource_async_status) } PostResourceFullDuplexRequest::PostResourceFullDuplexRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena) { SharedCtor(arena); // @@protoc_insertion_point(arena_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest) } PostResourceFullDuplexRequest::PostResourceFullDuplexRequest(const PostResourceFullDuplexRequest& from) : ::PROTOBUF_NAMESPACE_ID::MessageLite() { PostResourceFullDuplexRequest* const _this = this; (void)_this; new (&_impl_) Impl_{ decltype(_impl_.request_id_) {} , decltype(_impl_.task_){} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{}}; _internal_metadata_.MergeFrom(from._internal_metadata_); _impl_.request_id_.InitDefault(); #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING _impl_.request_id_.Set("", GetArenaForAllocation()); #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING if (!from._internal_request_id().empty()) { _this->_impl_.request_id_.Set(from._internal_request_id(), _this->GetArenaForAllocation()); } clear_has_task(); switch (from.task_case()) { case kResourceAsyncStatus: { _this->_internal_mutable_resource_async_status()->::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus::MergeFrom( from._internal_resource_async_status()); break; } case TASK_NOT_SET: { break; } } // @@protoc_insertion_point(copy_constructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest) } inline void PostResourceFullDuplexRequest::SharedCtor(::_pb::Arena* arena) { (void)arena; new (&_impl_) Impl_{ decltype(_impl_.request_id_) {} , decltype(_impl_.task_){} , /*decltype(_impl_._cached_size_)*/{} , /*decltype(_impl_._oneof_case_)*/{} }; _impl_.request_id_.InitDefault(); #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING _impl_.request_id_.Set("", GetArenaForAllocation()); #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING clear_has_task(); } PostResourceFullDuplexRequest::~PostResourceFullDuplexRequest() { // @@protoc_insertion_point(destructor:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest) if (auto *arena = _internal_metadata_.DeleteReturnArena()) { (void)arena; return; } SharedDtor(); } inline void PostResourceFullDuplexRequest::SharedDtor() { ABSL_DCHECK(GetArenaForAllocation() == nullptr); _impl_.request_id_.Destroy(); if (has_task()) { clear_task(); } } void PostResourceFullDuplexRequest::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } void PostResourceFullDuplexRequest::clear_task() { // @@protoc_insertion_point(one_of_clear_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest) switch (task_case()) { case kResourceAsyncStatus: { if (GetArenaForAllocation() == nullptr) { delete _impl_.task_.resource_async_status_; } break; } case TASK_NOT_SET: { break; } } _impl_._oneof_case_[0] = TASK_NOT_SET; } void PostResourceFullDuplexRequest::Clear() { // @@protoc_insertion_point(message_clear_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest) ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; _impl_.request_id_.ClearToEmpty(); clear_task(); _internal_metadata_.Clear(); } const char* PostResourceFullDuplexRequest::_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 request_id = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) { auto str = _internal_mutable_request_id(); ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); CHK_(::_pbi::VerifyUTF8(str, nullptr)); } else { goto handle_unusual; } continue; // .keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus resource_async_status = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 18)) { ptr = ctx->ParseMessage(_internal_mutable_resource_async_status(), 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 message_done: return ptr; failure: ptr = nullptr; goto message_done; #undef CHK_ } ::uint8_t* PostResourceFullDuplexRequest::_InternalSerialize( ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest) ::uint32_t cached_has_bits = 0; (void) cached_has_bits; // string request_id = 1; if (!this->_internal_request_id().empty()) { const std::string& _s = this->_internal_request_id(); ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( _s.data(), static_cast(_s.length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, "keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.request_id"); target = stream->WriteStringMaybeAliased(1, _s, target); } // .keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus resource_async_status = 2; if (task_case() == kResourceAsyncStatus) { target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: InternalWriteMessage(2, _Internal::resource_async_status(this), _Internal::resource_async_status(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:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest) return target; } ::size_t PostResourceFullDuplexRequest::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest) ::size_t total_size = 0; ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // string request_id = 1; if (!this->_internal_request_id().empty()) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( this->_internal_request_id()); } switch (task_case()) { // .keyapis.telemetry_control.v1.PostResourceFullDuplexRequest.ResourceAsyncStatus resource_async_status = 2; case kResourceAsyncStatus: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( *_impl_.task_.resource_async_status_); break; } case TASK_NOT_SET: { break; } } 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; } void PostResourceFullDuplexRequest::CheckTypeAndMergeFrom( const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) { MergeFrom(*::_pbi::DownCast( &from)); } void PostResourceFullDuplexRequest::MergeFrom(const PostResourceFullDuplexRequest& from) { PostResourceFullDuplexRequest* const _this = this; // @@protoc_insertion_point(class_specific_merge_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest) ABSL_DCHECK_NE(&from, _this); ::uint32_t cached_has_bits = 0; (void) cached_has_bits; if (!from._internal_request_id().empty()) { _this->_internal_set_request_id(from._internal_request_id()); } switch (from.task_case()) { case kResourceAsyncStatus: { _this->_internal_mutable_resource_async_status()->::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus::MergeFrom( from._internal_resource_async_status()); break; } case TASK_NOT_SET: { break; } } _this->_internal_metadata_.MergeFrom(from._internal_metadata_); } void PostResourceFullDuplexRequest::CopyFrom(const PostResourceFullDuplexRequest& from) { // @@protoc_insertion_point(class_specific_copy_from_start:keyapis.telemetry_control.v1.PostResourceFullDuplexRequest) if (&from == this) return; Clear(); MergeFrom(from); } bool PostResourceFullDuplexRequest::IsInitialized() const { return true; } void PostResourceFullDuplexRequest::InternalSwap(PostResourceFullDuplexRequest* other) { using std::swap; auto* lhs_arena = GetArenaForAllocation(); auto* rhs_arena = other->GetArenaForAllocation(); _internal_metadata_.InternalSwap(&other->_internal_metadata_); ::_pbi::ArenaStringPtr::InternalSwap(&_impl_.request_id_, lhs_arena, &other->_impl_.request_id_, rhs_arena); swap(_impl_.task_, other->_impl_.task_); swap(_impl_._oneof_case_[0], other->_impl_._oneof_case_[0]); } std::string PostResourceFullDuplexRequest::GetTypeName() const { return "keyapis.telemetry_control.v1.PostResourceFullDuplexRequest"; } // @@protoc_insertion_point(namespace_scope) } // namespace v1 } // namespace telemetry_control } // namespace keyapis PROTOBUF_NAMESPACE_OPEN template<> PROTOBUF_NOINLINE ::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_RemoveResourceEvent* Arena::CreateMaybeMessage< ::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_RemoveResourceEvent >(Arena* arena) { return Arena::CreateMessageInternal< ::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_RemoveResourceEvent >(arena); } template<> PROTOBUF_NOINLINE ::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_UpsertResourceEvent* Arena::CreateMaybeMessage< ::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_UpsertResourceEvent >(Arena* arena) { return Arena::CreateMessageInternal< ::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse_UpsertResourceEvent >(arena); } template<> PROTOBUF_NOINLINE ::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse* Arena::CreateMaybeMessage< ::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse >(Arena* arena) { return Arena::CreateMessageInternal< ::keyapis::telemetry_control::v1::PostResourceFullDuplexResponse >(arena); } template<> PROTOBUF_NOINLINE ::keyapis::telemetry_control::v1::ResourceId* Arena::CreateMaybeMessage< ::keyapis::telemetry_control::v1::ResourceId >(Arena* arena) { return Arena::CreateMessageInternal< ::keyapis::telemetry_control::v1::ResourceId >(arena); } template<> PROTOBUF_NOINLINE ::keyapis::telemetry_control::v1::Resource* Arena::CreateMaybeMessage< ::keyapis::telemetry_control::v1::Resource >(Arena* arena) { return Arena::CreateMessageInternal< ::keyapis::telemetry_control::v1::Resource >(arena); } template<> PROTOBUF_NOINLINE ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Success* Arena::CreateMaybeMessage< ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Success >(Arena* arena) { return Arena::CreateMessageInternal< ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Success >(arena); } template<> PROTOBUF_NOINLINE ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError* Arena::CreateMaybeMessage< ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError >(Arena* arena) { return Arena::CreateMessageInternal< ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error_UnknownError >(arena); } template<> PROTOBUF_NOINLINE ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error* Arena::CreateMaybeMessage< ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error >(Arena* arena) { return Arena::CreateMessageInternal< ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus_Error >(arena); } template<> PROTOBUF_NOINLINE ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus* Arena::CreateMaybeMessage< ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus >(Arena* arena) { return Arena::CreateMessageInternal< ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest_ResourceAsyncStatus >(arena); } template<> PROTOBUF_NOINLINE ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest* Arena::CreateMaybeMessage< ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest >(Arena* arena) { return Arena::CreateMessageInternal< ::keyapis::telemetry_control::v1::PostResourceFullDuplexRequest >(arena); } PROTOBUF_NAMESPACE_CLOSE // @@protoc_insertion_point(global_scope) #include "google/protobuf/port_undef.inc"