1 // Generated by the protocol buffer compiler. DO NOT EDIT!
2 // source: fcp/protos/federatedcompute/task_assignments.proto
3
4 #include "fcp/protos/federatedcompute/task_assignments.pb.h"
5
6 #include <algorithm>
7 #include <cstdint>
8
9 #include <google/protobuf/io/coded_stream.h>
10 #include <google/protobuf/extension_set.h>
11 #include <google/protobuf/wire_format_lite.h>
12 #include <google/protobuf/io/zero_copy_stream_impl_lite.h>
13 // @@protoc_insertion_point(includes)
14 #include <google/protobuf/port_def.inc>
15
16 PROTOBUF_PRAGMA_INIT_SEG
17
18 namespace _pb = ::PROTOBUF_NAMESPACE_ID;
19 namespace _pbi = _pb::internal;
20
21 namespace google {
22 namespace internal {
23 namespace federatedcompute {
24 namespace v1 {
StartTaskAssignmentRequest(::_pbi::ConstantInitialized)25 PROTOBUF_CONSTEXPR StartTaskAssignmentRequest::StartTaskAssignmentRequest(
26 ::_pbi::ConstantInitialized): _impl_{
27 /*decltype(_impl_.population_name_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
28 , /*decltype(_impl_.session_id_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
29 , /*decltype(_impl_.client_version_)*/nullptr
30 , /*decltype(_impl_.task_eligibility_info_)*/nullptr
31 , /*decltype(_impl_.resource_capabilities_)*/nullptr
32 , /*decltype(_impl_._cached_size_)*/{}} {}
33 struct StartTaskAssignmentRequestDefaultTypeInternal {
StartTaskAssignmentRequestDefaultTypeInternalgoogle::internal::federatedcompute::v1::StartTaskAssignmentRequestDefaultTypeInternal34 PROTOBUF_CONSTEXPR StartTaskAssignmentRequestDefaultTypeInternal()
35 : _instance(::_pbi::ConstantInitialized{}) {}
~StartTaskAssignmentRequestDefaultTypeInternalgoogle::internal::federatedcompute::v1::StartTaskAssignmentRequestDefaultTypeInternal36 ~StartTaskAssignmentRequestDefaultTypeInternal() {}
37 union { // NOLINT(misc-non-private-member-variables-in-classes)
38 StartTaskAssignmentRequest _instance;
39 };
40 };
41 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 StartTaskAssignmentRequestDefaultTypeInternal _StartTaskAssignmentRequest_default_instance_;
StartTaskAssignmentMetadata(::_pbi::ConstantInitialized)42 PROTOBUF_CONSTEXPR StartTaskAssignmentMetadata::StartTaskAssignmentMetadata(
43 ::_pbi::ConstantInitialized): _impl_{
44 /*decltype(_impl_.polling_interval_)*/nullptr
45 , /*decltype(_impl_._cached_size_)*/{}} {}
46 struct StartTaskAssignmentMetadataDefaultTypeInternal {
StartTaskAssignmentMetadataDefaultTypeInternalgoogle::internal::federatedcompute::v1::StartTaskAssignmentMetadataDefaultTypeInternal47 PROTOBUF_CONSTEXPR StartTaskAssignmentMetadataDefaultTypeInternal()
48 : _instance(::_pbi::ConstantInitialized{}) {}
~StartTaskAssignmentMetadataDefaultTypeInternalgoogle::internal::federatedcompute::v1::StartTaskAssignmentMetadataDefaultTypeInternal49 ~StartTaskAssignmentMetadataDefaultTypeInternal() {}
50 union { // NOLINT(misc-non-private-member-variables-in-classes)
51 StartTaskAssignmentMetadata _instance;
52 };
53 };
54 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 StartTaskAssignmentMetadataDefaultTypeInternal _StartTaskAssignmentMetadata_default_instance_;
StartTaskAssignmentResponse(::_pbi::ConstantInitialized)55 PROTOBUF_CONSTEXPR StartTaskAssignmentResponse::StartTaskAssignmentResponse(
56 ::_pbi::ConstantInitialized): _impl_{
57 /*decltype(_impl_.result_)*/{}
58 , /*decltype(_impl_._cached_size_)*/{}
59 , /*decltype(_impl_._oneof_case_)*/{}} {}
60 struct StartTaskAssignmentResponseDefaultTypeInternal {
StartTaskAssignmentResponseDefaultTypeInternalgoogle::internal::federatedcompute::v1::StartTaskAssignmentResponseDefaultTypeInternal61 PROTOBUF_CONSTEXPR StartTaskAssignmentResponseDefaultTypeInternal()
62 : _instance(::_pbi::ConstantInitialized{}) {}
~StartTaskAssignmentResponseDefaultTypeInternalgoogle::internal::federatedcompute::v1::StartTaskAssignmentResponseDefaultTypeInternal63 ~StartTaskAssignmentResponseDefaultTypeInternal() {}
64 union { // NOLINT(misc-non-private-member-variables-in-classes)
65 StartTaskAssignmentResponse _instance;
66 };
67 };
68 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 StartTaskAssignmentResponseDefaultTypeInternal _StartTaskAssignmentResponse_default_instance_;
PerformMultipleTaskAssignmentsRequest(::_pbi::ConstantInitialized)69 PROTOBUF_CONSTEXPR PerformMultipleTaskAssignmentsRequest::PerformMultipleTaskAssignmentsRequest(
70 ::_pbi::ConstantInitialized): _impl_{
71 /*decltype(_impl_.task_names_)*/{}
72 , /*decltype(_impl_.population_name_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
73 , /*decltype(_impl_.session_id_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
74 , /*decltype(_impl_.client_version_)*/nullptr
75 , /*decltype(_impl_.resource_capabilities_)*/nullptr
76 , /*decltype(_impl_._cached_size_)*/{}} {}
77 struct PerformMultipleTaskAssignmentsRequestDefaultTypeInternal {
PerformMultipleTaskAssignmentsRequestDefaultTypeInternalgoogle::internal::federatedcompute::v1::PerformMultipleTaskAssignmentsRequestDefaultTypeInternal78 PROTOBUF_CONSTEXPR PerformMultipleTaskAssignmentsRequestDefaultTypeInternal()
79 : _instance(::_pbi::ConstantInitialized{}) {}
~PerformMultipleTaskAssignmentsRequestDefaultTypeInternalgoogle::internal::federatedcompute::v1::PerformMultipleTaskAssignmentsRequestDefaultTypeInternal80 ~PerformMultipleTaskAssignmentsRequestDefaultTypeInternal() {}
81 union { // NOLINT(misc-non-private-member-variables-in-classes)
82 PerformMultipleTaskAssignmentsRequest _instance;
83 };
84 };
85 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 PerformMultipleTaskAssignmentsRequestDefaultTypeInternal _PerformMultipleTaskAssignmentsRequest_default_instance_;
PerformMultipleTaskAssignmentsResponse(::_pbi::ConstantInitialized)86 PROTOBUF_CONSTEXPR PerformMultipleTaskAssignmentsResponse::PerformMultipleTaskAssignmentsResponse(
87 ::_pbi::ConstantInitialized): _impl_{
88 /*decltype(_impl_.task_assignments_)*/{}
89 , /*decltype(_impl_._cached_size_)*/{}} {}
90 struct PerformMultipleTaskAssignmentsResponseDefaultTypeInternal {
PerformMultipleTaskAssignmentsResponseDefaultTypeInternalgoogle::internal::federatedcompute::v1::PerformMultipleTaskAssignmentsResponseDefaultTypeInternal91 PROTOBUF_CONSTEXPR PerformMultipleTaskAssignmentsResponseDefaultTypeInternal()
92 : _instance(::_pbi::ConstantInitialized{}) {}
~PerformMultipleTaskAssignmentsResponseDefaultTypeInternalgoogle::internal::federatedcompute::v1::PerformMultipleTaskAssignmentsResponseDefaultTypeInternal93 ~PerformMultipleTaskAssignmentsResponseDefaultTypeInternal() {}
94 union { // NOLINT(misc-non-private-member-variables-in-classes)
95 PerformMultipleTaskAssignmentsResponse _instance;
96 };
97 };
98 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 PerformMultipleTaskAssignmentsResponseDefaultTypeInternal _PerformMultipleTaskAssignmentsResponse_default_instance_;
TaskAssignment_AggregationInfo(::_pbi::ConstantInitialized)99 PROTOBUF_CONSTEXPR TaskAssignment_AggregationInfo::TaskAssignment_AggregationInfo(
100 ::_pbi::ConstantInitialized): _impl_{
101 /*decltype(_impl_._cached_size_)*/{}} {}
102 struct TaskAssignment_AggregationInfoDefaultTypeInternal {
TaskAssignment_AggregationInfoDefaultTypeInternalgoogle::internal::federatedcompute::v1::TaskAssignment_AggregationInfoDefaultTypeInternal103 PROTOBUF_CONSTEXPR TaskAssignment_AggregationInfoDefaultTypeInternal()
104 : _instance(::_pbi::ConstantInitialized{}) {}
~TaskAssignment_AggregationInfoDefaultTypeInternalgoogle::internal::federatedcompute::v1::TaskAssignment_AggregationInfoDefaultTypeInternal105 ~TaskAssignment_AggregationInfoDefaultTypeInternal() {}
106 union { // NOLINT(misc-non-private-member-variables-in-classes)
107 TaskAssignment_AggregationInfo _instance;
108 };
109 };
110 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TaskAssignment_AggregationInfoDefaultTypeInternal _TaskAssignment_AggregationInfo_default_instance_;
TaskAssignment_SecureAggregationInfo(::_pbi::ConstantInitialized)111 PROTOBUF_CONSTEXPR TaskAssignment_SecureAggregationInfo::TaskAssignment_SecureAggregationInfo(
112 ::_pbi::ConstantInitialized): _impl_{
113 /*decltype(_impl_.minimum_clients_in_server_visible_aggregate_)*/0
114 , /*decltype(_impl_._cached_size_)*/{}} {}
115 struct TaskAssignment_SecureAggregationInfoDefaultTypeInternal {
TaskAssignment_SecureAggregationInfoDefaultTypeInternalgoogle::internal::federatedcompute::v1::TaskAssignment_SecureAggregationInfoDefaultTypeInternal116 PROTOBUF_CONSTEXPR TaskAssignment_SecureAggregationInfoDefaultTypeInternal()
117 : _instance(::_pbi::ConstantInitialized{}) {}
~TaskAssignment_SecureAggregationInfoDefaultTypeInternalgoogle::internal::federatedcompute::v1::TaskAssignment_SecureAggregationInfoDefaultTypeInternal118 ~TaskAssignment_SecureAggregationInfoDefaultTypeInternal() {}
119 union { // NOLINT(misc-non-private-member-variables-in-classes)
120 TaskAssignment_SecureAggregationInfo _instance;
121 };
122 };
123 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TaskAssignment_SecureAggregationInfoDefaultTypeInternal _TaskAssignment_SecureAggregationInfo_default_instance_;
TaskAssignment(::_pbi::ConstantInitialized)124 PROTOBUF_CONSTEXPR TaskAssignment::TaskAssignment(
125 ::_pbi::ConstantInitialized): _impl_{
126 /*decltype(_impl_.aggregation_id_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
127 , /*decltype(_impl_.session_id_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
128 , /*decltype(_impl_.authorization_token_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
129 , /*decltype(_impl_.task_name_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
130 , /*decltype(_impl_.aggregation_data_forwarding_info_)*/nullptr
131 , /*decltype(_impl_.init_checkpoint_)*/nullptr
132 , /*decltype(_impl_.plan_)*/nullptr
133 , /*decltype(_impl_.federated_select_uri_info_)*/nullptr
134 , /*decltype(_impl_.aggregation_type_)*/{}
135 , /*decltype(_impl_._cached_size_)*/{}
136 , /*decltype(_impl_._oneof_case_)*/{}} {}
137 struct TaskAssignmentDefaultTypeInternal {
TaskAssignmentDefaultTypeInternalgoogle::internal::federatedcompute::v1::TaskAssignmentDefaultTypeInternal138 PROTOBUF_CONSTEXPR TaskAssignmentDefaultTypeInternal()
139 : _instance(::_pbi::ConstantInitialized{}) {}
~TaskAssignmentDefaultTypeInternalgoogle::internal::federatedcompute::v1::TaskAssignmentDefaultTypeInternal140 ~TaskAssignmentDefaultTypeInternal() {}
141 union { // NOLINT(misc-non-private-member-variables-in-classes)
142 TaskAssignment _instance;
143 };
144 };
145 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TaskAssignmentDefaultTypeInternal _TaskAssignment_default_instance_;
FederatedSelectUriInfo(::_pbi::ConstantInitialized)146 PROTOBUF_CONSTEXPR FederatedSelectUriInfo::FederatedSelectUriInfo(
147 ::_pbi::ConstantInitialized): _impl_{
148 /*decltype(_impl_.uri_template_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
149 , /*decltype(_impl_._cached_size_)*/{}} {}
150 struct FederatedSelectUriInfoDefaultTypeInternal {
FederatedSelectUriInfoDefaultTypeInternalgoogle::internal::federatedcompute::v1::FederatedSelectUriInfoDefaultTypeInternal151 PROTOBUF_CONSTEXPR FederatedSelectUriInfoDefaultTypeInternal()
152 : _instance(::_pbi::ConstantInitialized{}) {}
~FederatedSelectUriInfoDefaultTypeInternalgoogle::internal::federatedcompute::v1::FederatedSelectUriInfoDefaultTypeInternal153 ~FederatedSelectUriInfoDefaultTypeInternal() {}
154 union { // NOLINT(misc-non-private-member-variables-in-classes)
155 FederatedSelectUriInfo _instance;
156 };
157 };
158 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 FederatedSelectUriInfoDefaultTypeInternal _FederatedSelectUriInfo_default_instance_;
ReportTaskResultRequest(::_pbi::ConstantInitialized)159 PROTOBUF_CONSTEXPR ReportTaskResultRequest::ReportTaskResultRequest(
160 ::_pbi::ConstantInitialized): _impl_{
161 /*decltype(_impl_.population_name_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
162 , /*decltype(_impl_.session_id_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
163 , /*decltype(_impl_.aggregation_id_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
164 , /*decltype(_impl_.task_name_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
165 , /*decltype(_impl_.client_stats_)*/nullptr
166 , /*decltype(_impl_.computation_status_code_)*/0
167 , /*decltype(_impl_._cached_size_)*/{}} {}
168 struct ReportTaskResultRequestDefaultTypeInternal {
ReportTaskResultRequestDefaultTypeInternalgoogle::internal::federatedcompute::v1::ReportTaskResultRequestDefaultTypeInternal169 PROTOBUF_CONSTEXPR ReportTaskResultRequestDefaultTypeInternal()
170 : _instance(::_pbi::ConstantInitialized{}) {}
~ReportTaskResultRequestDefaultTypeInternalgoogle::internal::federatedcompute::v1::ReportTaskResultRequestDefaultTypeInternal171 ~ReportTaskResultRequestDefaultTypeInternal() {}
172 union { // NOLINT(misc-non-private-member-variables-in-classes)
173 ReportTaskResultRequest _instance;
174 };
175 };
176 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 ReportTaskResultRequestDefaultTypeInternal _ReportTaskResultRequest_default_instance_;
ClientStats(::_pbi::ConstantInitialized)177 PROTOBUF_CONSTEXPR ClientStats::ClientStats(
178 ::_pbi::ConstantInitialized): _impl_{
179 /*decltype(_impl_.computation_execution_duration_)*/nullptr
180 , /*decltype(_impl_._cached_size_)*/{}} {}
181 struct ClientStatsDefaultTypeInternal {
ClientStatsDefaultTypeInternalgoogle::internal::federatedcompute::v1::ClientStatsDefaultTypeInternal182 PROTOBUF_CONSTEXPR ClientStatsDefaultTypeInternal()
183 : _instance(::_pbi::ConstantInitialized{}) {}
~ClientStatsDefaultTypeInternalgoogle::internal::federatedcompute::v1::ClientStatsDefaultTypeInternal184 ~ClientStatsDefaultTypeInternal() {}
185 union { // NOLINT(misc-non-private-member-variables-in-classes)
186 ClientStats _instance;
187 };
188 };
189 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 ClientStatsDefaultTypeInternal _ClientStats_default_instance_;
ReportTaskResultResponse(::_pbi::ConstantInitialized)190 PROTOBUF_CONSTEXPR ReportTaskResultResponse::ReportTaskResultResponse(
191 ::_pbi::ConstantInitialized): _impl_{
192 /*decltype(_impl_._cached_size_)*/{}} {}
193 struct ReportTaskResultResponseDefaultTypeInternal {
ReportTaskResultResponseDefaultTypeInternalgoogle::internal::federatedcompute::v1::ReportTaskResultResponseDefaultTypeInternal194 PROTOBUF_CONSTEXPR ReportTaskResultResponseDefaultTypeInternal()
195 : _instance(::_pbi::ConstantInitialized{}) {}
~ReportTaskResultResponseDefaultTypeInternalgoogle::internal::federatedcompute::v1::ReportTaskResultResponseDefaultTypeInternal196 ~ReportTaskResultResponseDefaultTypeInternal() {}
197 union { // NOLINT(misc-non-private-member-variables-in-classes)
198 ReportTaskResultResponse _instance;
199 };
200 };
201 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 ReportTaskResultResponseDefaultTypeInternal _ReportTaskResultResponse_default_instance_;
202 } // namespace v1
203 } // namespace federatedcompute
204 } // namespace internal
205 } // namespace google
206 namespace google {
207 namespace internal {
208 namespace federatedcompute {
209 namespace v1 {
210
211 // ===================================================================
212
213 class StartTaskAssignmentRequest::_Internal {
214 public:
215 static const ::google::internal::federatedcompute::v1::ClientVersion& client_version(const StartTaskAssignmentRequest* msg);
216 static const ::google::internal::federatedml::v2::TaskEligibilityInfo& task_eligibility_info(const StartTaskAssignmentRequest* msg);
217 static const ::google::internal::federatedcompute::v1::ResourceCapabilities& resource_capabilities(const StartTaskAssignmentRequest* msg);
218 };
219
220 const ::google::internal::federatedcompute::v1::ClientVersion&
client_version(const StartTaskAssignmentRequest * msg)221 StartTaskAssignmentRequest::_Internal::client_version(const StartTaskAssignmentRequest* msg) {
222 return *msg->_impl_.client_version_;
223 }
224 const ::google::internal::federatedml::v2::TaskEligibilityInfo&
task_eligibility_info(const StartTaskAssignmentRequest * msg)225 StartTaskAssignmentRequest::_Internal::task_eligibility_info(const StartTaskAssignmentRequest* msg) {
226 return *msg->_impl_.task_eligibility_info_;
227 }
228 const ::google::internal::federatedcompute::v1::ResourceCapabilities&
resource_capabilities(const StartTaskAssignmentRequest * msg)229 StartTaskAssignmentRequest::_Internal::resource_capabilities(const StartTaskAssignmentRequest* msg) {
230 return *msg->_impl_.resource_capabilities_;
231 }
clear_client_version()232 void StartTaskAssignmentRequest::clear_client_version() {
233 if (GetArenaForAllocation() == nullptr && _impl_.client_version_ != nullptr) {
234 delete _impl_.client_version_;
235 }
236 _impl_.client_version_ = nullptr;
237 }
clear_task_eligibility_info()238 void StartTaskAssignmentRequest::clear_task_eligibility_info() {
239 if (GetArenaForAllocation() == nullptr && _impl_.task_eligibility_info_ != nullptr) {
240 delete _impl_.task_eligibility_info_;
241 }
242 _impl_.task_eligibility_info_ = nullptr;
243 }
clear_resource_capabilities()244 void StartTaskAssignmentRequest::clear_resource_capabilities() {
245 if (GetArenaForAllocation() == nullptr && _impl_.resource_capabilities_ != nullptr) {
246 delete _impl_.resource_capabilities_;
247 }
248 _impl_.resource_capabilities_ = nullptr;
249 }
StartTaskAssignmentRequest(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)250 StartTaskAssignmentRequest::StartTaskAssignmentRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
251 bool is_message_owned)
252 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
253 SharedCtor(arena, is_message_owned);
254 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.StartTaskAssignmentRequest)
255 }
StartTaskAssignmentRequest(const StartTaskAssignmentRequest & from)256 StartTaskAssignmentRequest::StartTaskAssignmentRequest(const StartTaskAssignmentRequest& from)
257 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
258 StartTaskAssignmentRequest* const _this = this; (void)_this;
259 new (&_impl_) Impl_{
260 decltype(_impl_.population_name_){}
261 , decltype(_impl_.session_id_){}
262 , decltype(_impl_.client_version_){nullptr}
263 , decltype(_impl_.task_eligibility_info_){nullptr}
264 , decltype(_impl_.resource_capabilities_){nullptr}
265 , /*decltype(_impl_._cached_size_)*/{}};
266
267 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
268 _impl_.population_name_.InitDefault();
269 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
270 _impl_.population_name_.Set("", GetArenaForAllocation());
271 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
272 if (!from._internal_population_name().empty()) {
273 _this->_impl_.population_name_.Set(from._internal_population_name(),
274 _this->GetArenaForAllocation());
275 }
276 _impl_.session_id_.InitDefault();
277 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
278 _impl_.session_id_.Set("", GetArenaForAllocation());
279 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
280 if (!from._internal_session_id().empty()) {
281 _this->_impl_.session_id_.Set(from._internal_session_id(),
282 _this->GetArenaForAllocation());
283 }
284 if (from._internal_has_client_version()) {
285 _this->_impl_.client_version_ = new ::google::internal::federatedcompute::v1::ClientVersion(*from._impl_.client_version_);
286 }
287 if (from._internal_has_task_eligibility_info()) {
288 _this->_impl_.task_eligibility_info_ = new ::google::internal::federatedml::v2::TaskEligibilityInfo(*from._impl_.task_eligibility_info_);
289 }
290 if (from._internal_has_resource_capabilities()) {
291 _this->_impl_.resource_capabilities_ = new ::google::internal::federatedcompute::v1::ResourceCapabilities(*from._impl_.resource_capabilities_);
292 }
293 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.StartTaskAssignmentRequest)
294 }
295
SharedCtor(::_pb::Arena * arena,bool is_message_owned)296 inline void StartTaskAssignmentRequest::SharedCtor(
297 ::_pb::Arena* arena, bool is_message_owned) {
298 (void)arena;
299 (void)is_message_owned;
300 new (&_impl_) Impl_{
301 decltype(_impl_.population_name_){}
302 , decltype(_impl_.session_id_){}
303 , decltype(_impl_.client_version_){nullptr}
304 , decltype(_impl_.task_eligibility_info_){nullptr}
305 , decltype(_impl_.resource_capabilities_){nullptr}
306 , /*decltype(_impl_._cached_size_)*/{}
307 };
308 _impl_.population_name_.InitDefault();
309 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
310 _impl_.population_name_.Set("", GetArenaForAllocation());
311 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
312 _impl_.session_id_.InitDefault();
313 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
314 _impl_.session_id_.Set("", GetArenaForAllocation());
315 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
316 }
317
~StartTaskAssignmentRequest()318 StartTaskAssignmentRequest::~StartTaskAssignmentRequest() {
319 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.StartTaskAssignmentRequest)
320 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
321 (void)arena;
322 return;
323 }
324 SharedDtor();
325 }
326
SharedDtor()327 inline void StartTaskAssignmentRequest::SharedDtor() {
328 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
329 _impl_.population_name_.Destroy();
330 _impl_.session_id_.Destroy();
331 if (this != internal_default_instance()) delete _impl_.client_version_;
332 if (this != internal_default_instance()) delete _impl_.task_eligibility_info_;
333 if (this != internal_default_instance()) delete _impl_.resource_capabilities_;
334 }
335
SetCachedSize(int size) const336 void StartTaskAssignmentRequest::SetCachedSize(int size) const {
337 _impl_._cached_size_.Set(size);
338 }
339
Clear()340 void StartTaskAssignmentRequest::Clear() {
341 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.StartTaskAssignmentRequest)
342 ::uint32_t cached_has_bits = 0;
343 // Prevent compiler warnings about cached_has_bits being unused
344 (void) cached_has_bits;
345
346 _impl_.population_name_.ClearToEmpty();
347 _impl_.session_id_.ClearToEmpty();
348 if (GetArenaForAllocation() == nullptr && _impl_.client_version_ != nullptr) {
349 delete _impl_.client_version_;
350 }
351 _impl_.client_version_ = nullptr;
352 if (GetArenaForAllocation() == nullptr && _impl_.task_eligibility_info_ != nullptr) {
353 delete _impl_.task_eligibility_info_;
354 }
355 _impl_.task_eligibility_info_ = nullptr;
356 if (GetArenaForAllocation() == nullptr && _impl_.resource_capabilities_ != nullptr) {
357 delete _impl_.resource_capabilities_;
358 }
359 _impl_.resource_capabilities_ = nullptr;
360 _internal_metadata_.Clear<std::string>();
361 }
362
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)363 const char* StartTaskAssignmentRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
364 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
365 while (!ctx->Done(&ptr)) {
366 ::uint32_t tag;
367 ptr = ::_pbi::ReadTag(ptr, &tag);
368 switch (tag >> 3) {
369 // string population_name = 1;
370 case 1:
371 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) {
372 auto str = _internal_mutable_population_name();
373 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
374 CHK_(ptr);
375 CHK_(::_pbi::VerifyUTF8(str, nullptr));
376 } else {
377 goto handle_unusual;
378 }
379 continue;
380 // string session_id = 2;
381 case 2:
382 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 18)) {
383 auto str = _internal_mutable_session_id();
384 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
385 CHK_(ptr);
386 CHK_(::_pbi::VerifyUTF8(str, nullptr));
387 } else {
388 goto handle_unusual;
389 }
390 continue;
391 // .google.internal.federatedcompute.v1.ClientVersion client_version = 4;
392 case 4:
393 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 34)) {
394 ptr = ctx->ParseMessage(_internal_mutable_client_version(), ptr);
395 CHK_(ptr);
396 } else {
397 goto handle_unusual;
398 }
399 continue;
400 // .google.internal.federatedml.v2.TaskEligibilityInfo task_eligibility_info = 5;
401 case 5:
402 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 42)) {
403 ptr = ctx->ParseMessage(_internal_mutable_task_eligibility_info(), ptr);
404 CHK_(ptr);
405 } else {
406 goto handle_unusual;
407 }
408 continue;
409 // .google.internal.federatedcompute.v1.ResourceCapabilities resource_capabilities = 6;
410 case 6:
411 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 50)) {
412 ptr = ctx->ParseMessage(_internal_mutable_resource_capabilities(), ptr);
413 CHK_(ptr);
414 } else {
415 goto handle_unusual;
416 }
417 continue;
418 default:
419 goto handle_unusual;
420 } // switch
421 handle_unusual:
422 if ((tag == 0) || ((tag & 7) == 4)) {
423 CHK_(ptr);
424 ctx->SetLastTag(tag);
425 goto message_done;
426 }
427 ptr = UnknownFieldParse(
428 tag,
429 _internal_metadata_.mutable_unknown_fields<std::string>(),
430 ptr, ctx);
431 CHK_(ptr != nullptr);
432 } // while
433 message_done:
434 return ptr;
435 failure:
436 ptr = nullptr;
437 goto message_done;
438 #undef CHK_
439 }
440
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const441 ::uint8_t* StartTaskAssignmentRequest::_InternalSerialize(
442 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
443 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.StartTaskAssignmentRequest)
444 ::uint32_t cached_has_bits = 0;
445 (void) cached_has_bits;
446
447 // string population_name = 1;
448 if (!this->_internal_population_name().empty()) {
449 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
450 this->_internal_population_name().data(), static_cast<int>(this->_internal_population_name().length()),
451 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
452 "google.internal.federatedcompute.v1.StartTaskAssignmentRequest.population_name");
453 target = stream->WriteStringMaybeAliased(
454 1, this->_internal_population_name(), target);
455 }
456
457 // string session_id = 2;
458 if (!this->_internal_session_id().empty()) {
459 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
460 this->_internal_session_id().data(), static_cast<int>(this->_internal_session_id().length()),
461 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
462 "google.internal.federatedcompute.v1.StartTaskAssignmentRequest.session_id");
463 target = stream->WriteStringMaybeAliased(
464 2, this->_internal_session_id(), target);
465 }
466
467 // .google.internal.federatedcompute.v1.ClientVersion client_version = 4;
468 if (this->_internal_has_client_version()) {
469 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
470 InternalWriteMessage(4, _Internal::client_version(this),
471 _Internal::client_version(this).GetCachedSize(), target, stream);
472 }
473
474 // .google.internal.federatedml.v2.TaskEligibilityInfo task_eligibility_info = 5;
475 if (this->_internal_has_task_eligibility_info()) {
476 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
477 InternalWriteMessage(5, _Internal::task_eligibility_info(this),
478 _Internal::task_eligibility_info(this).GetCachedSize(), target, stream);
479 }
480
481 // .google.internal.federatedcompute.v1.ResourceCapabilities resource_capabilities = 6;
482 if (this->_internal_has_resource_capabilities()) {
483 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
484 InternalWriteMessage(6, _Internal::resource_capabilities(this),
485 _Internal::resource_capabilities(this).GetCachedSize(), target, stream);
486 }
487
488 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
489 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
490 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
491 }
492 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.StartTaskAssignmentRequest)
493 return target;
494 }
495
ByteSizeLong() const496 size_t StartTaskAssignmentRequest::ByteSizeLong() const {
497 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.StartTaskAssignmentRequest)
498 size_t total_size = 0;
499
500 ::uint32_t cached_has_bits = 0;
501 // Prevent compiler warnings about cached_has_bits being unused
502 (void) cached_has_bits;
503
504 // string population_name = 1;
505 if (!this->_internal_population_name().empty()) {
506 total_size += 1 +
507 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
508 this->_internal_population_name());
509 }
510
511 // string session_id = 2;
512 if (!this->_internal_session_id().empty()) {
513 total_size += 1 +
514 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
515 this->_internal_session_id());
516 }
517
518 // .google.internal.federatedcompute.v1.ClientVersion client_version = 4;
519 if (this->_internal_has_client_version()) {
520 total_size += 1 +
521 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
522 *_impl_.client_version_);
523 }
524
525 // .google.internal.federatedml.v2.TaskEligibilityInfo task_eligibility_info = 5;
526 if (this->_internal_has_task_eligibility_info()) {
527 total_size += 1 +
528 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
529 *_impl_.task_eligibility_info_);
530 }
531
532 // .google.internal.federatedcompute.v1.ResourceCapabilities resource_capabilities = 6;
533 if (this->_internal_has_resource_capabilities()) {
534 total_size += 1 +
535 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
536 *_impl_.resource_capabilities_);
537 }
538
539 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
540 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
541 }
542 int cached_size = ::_pbi::ToCachedSize(total_size);
543 SetCachedSize(cached_size);
544 return total_size;
545 }
546
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)547 void StartTaskAssignmentRequest::CheckTypeAndMergeFrom(
548 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
549 MergeFrom(*::_pbi::DownCast<const StartTaskAssignmentRequest*>(
550 &from));
551 }
552
MergeFrom(const StartTaskAssignmentRequest & from)553 void StartTaskAssignmentRequest::MergeFrom(const StartTaskAssignmentRequest& from) {
554 StartTaskAssignmentRequest* const _this = this;
555 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.StartTaskAssignmentRequest)
556 GOOGLE_DCHECK_NE(&from, _this);
557 ::uint32_t cached_has_bits = 0;
558 (void) cached_has_bits;
559
560 if (!from._internal_population_name().empty()) {
561 _this->_internal_set_population_name(from._internal_population_name());
562 }
563 if (!from._internal_session_id().empty()) {
564 _this->_internal_set_session_id(from._internal_session_id());
565 }
566 if (from._internal_has_client_version()) {
567 _this->_internal_mutable_client_version()->::google::internal::federatedcompute::v1::ClientVersion::MergeFrom(
568 from._internal_client_version());
569 }
570 if (from._internal_has_task_eligibility_info()) {
571 _this->_internal_mutable_task_eligibility_info()->::google::internal::federatedml::v2::TaskEligibilityInfo::MergeFrom(
572 from._internal_task_eligibility_info());
573 }
574 if (from._internal_has_resource_capabilities()) {
575 _this->_internal_mutable_resource_capabilities()->::google::internal::federatedcompute::v1::ResourceCapabilities::MergeFrom(
576 from._internal_resource_capabilities());
577 }
578 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
579 }
580
CopyFrom(const StartTaskAssignmentRequest & from)581 void StartTaskAssignmentRequest::CopyFrom(const StartTaskAssignmentRequest& from) {
582 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.StartTaskAssignmentRequest)
583 if (&from == this) return;
584 Clear();
585 MergeFrom(from);
586 }
587
IsInitialized() const588 bool StartTaskAssignmentRequest::IsInitialized() const {
589 return true;
590 }
591
InternalSwap(StartTaskAssignmentRequest * other)592 void StartTaskAssignmentRequest::InternalSwap(StartTaskAssignmentRequest* other) {
593 using std::swap;
594 auto* lhs_arena = GetArenaForAllocation();
595 auto* rhs_arena = other->GetArenaForAllocation();
596 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
597 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
598 &_impl_.population_name_, lhs_arena,
599 &other->_impl_.population_name_, rhs_arena
600 );
601 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
602 &_impl_.session_id_, lhs_arena,
603 &other->_impl_.session_id_, rhs_arena
604 );
605 ::PROTOBUF_NAMESPACE_ID::internal::memswap<
606 PROTOBUF_FIELD_OFFSET(StartTaskAssignmentRequest, _impl_.resource_capabilities_)
607 + sizeof(StartTaskAssignmentRequest::_impl_.resource_capabilities_) // NOLINT
608 - PROTOBUF_FIELD_OFFSET(StartTaskAssignmentRequest, _impl_.client_version_)>(
609 reinterpret_cast<char*>(&_impl_.client_version_),
610 reinterpret_cast<char*>(&other->_impl_.client_version_));
611 }
612
GetTypeName() const613 std::string StartTaskAssignmentRequest::GetTypeName() const {
614 return "google.internal.federatedcompute.v1.StartTaskAssignmentRequest";
615 }
616
617
618 // ===================================================================
619
620 class StartTaskAssignmentMetadata::_Internal {
621 public:
622 static const ::PROTOBUF_NAMESPACE_ID::Duration& polling_interval(const StartTaskAssignmentMetadata* msg);
623 };
624
625 const ::PROTOBUF_NAMESPACE_ID::Duration&
polling_interval(const StartTaskAssignmentMetadata * msg)626 StartTaskAssignmentMetadata::_Internal::polling_interval(const StartTaskAssignmentMetadata* msg) {
627 return *msg->_impl_.polling_interval_;
628 }
clear_polling_interval()629 void StartTaskAssignmentMetadata::clear_polling_interval() {
630 if (GetArenaForAllocation() == nullptr && _impl_.polling_interval_ != nullptr) {
631 delete _impl_.polling_interval_;
632 }
633 _impl_.polling_interval_ = nullptr;
634 }
StartTaskAssignmentMetadata(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)635 StartTaskAssignmentMetadata::StartTaskAssignmentMetadata(::PROTOBUF_NAMESPACE_ID::Arena* arena,
636 bool is_message_owned)
637 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
638 SharedCtor(arena, is_message_owned);
639 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.StartTaskAssignmentMetadata)
640 }
StartTaskAssignmentMetadata(const StartTaskAssignmentMetadata & from)641 StartTaskAssignmentMetadata::StartTaskAssignmentMetadata(const StartTaskAssignmentMetadata& from)
642 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
643 StartTaskAssignmentMetadata* const _this = this; (void)_this;
644 new (&_impl_) Impl_{
645 decltype(_impl_.polling_interval_){nullptr}
646 , /*decltype(_impl_._cached_size_)*/{}};
647
648 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
649 if (from._internal_has_polling_interval()) {
650 _this->_impl_.polling_interval_ = new ::PROTOBUF_NAMESPACE_ID::Duration(*from._impl_.polling_interval_);
651 }
652 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.StartTaskAssignmentMetadata)
653 }
654
SharedCtor(::_pb::Arena * arena,bool is_message_owned)655 inline void StartTaskAssignmentMetadata::SharedCtor(
656 ::_pb::Arena* arena, bool is_message_owned) {
657 (void)arena;
658 (void)is_message_owned;
659 new (&_impl_) Impl_{
660 decltype(_impl_.polling_interval_){nullptr}
661 , /*decltype(_impl_._cached_size_)*/{}
662 };
663 }
664
~StartTaskAssignmentMetadata()665 StartTaskAssignmentMetadata::~StartTaskAssignmentMetadata() {
666 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.StartTaskAssignmentMetadata)
667 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
668 (void)arena;
669 return;
670 }
671 SharedDtor();
672 }
673
SharedDtor()674 inline void StartTaskAssignmentMetadata::SharedDtor() {
675 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
676 if (this != internal_default_instance()) delete _impl_.polling_interval_;
677 }
678
SetCachedSize(int size) const679 void StartTaskAssignmentMetadata::SetCachedSize(int size) const {
680 _impl_._cached_size_.Set(size);
681 }
682
Clear()683 void StartTaskAssignmentMetadata::Clear() {
684 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.StartTaskAssignmentMetadata)
685 ::uint32_t cached_has_bits = 0;
686 // Prevent compiler warnings about cached_has_bits being unused
687 (void) cached_has_bits;
688
689 if (GetArenaForAllocation() == nullptr && _impl_.polling_interval_ != nullptr) {
690 delete _impl_.polling_interval_;
691 }
692 _impl_.polling_interval_ = nullptr;
693 _internal_metadata_.Clear<std::string>();
694 }
695
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)696 const char* StartTaskAssignmentMetadata::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
697 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
698 while (!ctx->Done(&ptr)) {
699 ::uint32_t tag;
700 ptr = ::_pbi::ReadTag(ptr, &tag);
701 switch (tag >> 3) {
702 // .google.protobuf.Duration polling_interval = 1;
703 case 1:
704 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) {
705 ptr = ctx->ParseMessage(_internal_mutable_polling_interval(), ptr);
706 CHK_(ptr);
707 } else {
708 goto handle_unusual;
709 }
710 continue;
711 default:
712 goto handle_unusual;
713 } // switch
714 handle_unusual:
715 if ((tag == 0) || ((tag & 7) == 4)) {
716 CHK_(ptr);
717 ctx->SetLastTag(tag);
718 goto message_done;
719 }
720 ptr = UnknownFieldParse(
721 tag,
722 _internal_metadata_.mutable_unknown_fields<std::string>(),
723 ptr, ctx);
724 CHK_(ptr != nullptr);
725 } // while
726 message_done:
727 return ptr;
728 failure:
729 ptr = nullptr;
730 goto message_done;
731 #undef CHK_
732 }
733
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const734 ::uint8_t* StartTaskAssignmentMetadata::_InternalSerialize(
735 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
736 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.StartTaskAssignmentMetadata)
737 ::uint32_t cached_has_bits = 0;
738 (void) cached_has_bits;
739
740 // .google.protobuf.Duration polling_interval = 1;
741 if (this->_internal_has_polling_interval()) {
742 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
743 InternalWriteMessage(1, _Internal::polling_interval(this),
744 _Internal::polling_interval(this).GetCachedSize(), target, stream);
745 }
746
747 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
748 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
749 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
750 }
751 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.StartTaskAssignmentMetadata)
752 return target;
753 }
754
ByteSizeLong() const755 size_t StartTaskAssignmentMetadata::ByteSizeLong() const {
756 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.StartTaskAssignmentMetadata)
757 size_t total_size = 0;
758
759 ::uint32_t cached_has_bits = 0;
760 // Prevent compiler warnings about cached_has_bits being unused
761 (void) cached_has_bits;
762
763 // .google.protobuf.Duration polling_interval = 1;
764 if (this->_internal_has_polling_interval()) {
765 total_size += 1 +
766 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
767 *_impl_.polling_interval_);
768 }
769
770 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
771 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
772 }
773 int cached_size = ::_pbi::ToCachedSize(total_size);
774 SetCachedSize(cached_size);
775 return total_size;
776 }
777
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)778 void StartTaskAssignmentMetadata::CheckTypeAndMergeFrom(
779 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
780 MergeFrom(*::_pbi::DownCast<const StartTaskAssignmentMetadata*>(
781 &from));
782 }
783
MergeFrom(const StartTaskAssignmentMetadata & from)784 void StartTaskAssignmentMetadata::MergeFrom(const StartTaskAssignmentMetadata& from) {
785 StartTaskAssignmentMetadata* const _this = this;
786 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.StartTaskAssignmentMetadata)
787 GOOGLE_DCHECK_NE(&from, _this);
788 ::uint32_t cached_has_bits = 0;
789 (void) cached_has_bits;
790
791 if (from._internal_has_polling_interval()) {
792 _this->_internal_mutable_polling_interval()->::PROTOBUF_NAMESPACE_ID::Duration::MergeFrom(
793 from._internal_polling_interval());
794 }
795 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
796 }
797
CopyFrom(const StartTaskAssignmentMetadata & from)798 void StartTaskAssignmentMetadata::CopyFrom(const StartTaskAssignmentMetadata& from) {
799 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.StartTaskAssignmentMetadata)
800 if (&from == this) return;
801 Clear();
802 MergeFrom(from);
803 }
804
IsInitialized() const805 bool StartTaskAssignmentMetadata::IsInitialized() const {
806 return true;
807 }
808
InternalSwap(StartTaskAssignmentMetadata * other)809 void StartTaskAssignmentMetadata::InternalSwap(StartTaskAssignmentMetadata* other) {
810 using std::swap;
811 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
812 swap(_impl_.polling_interval_, other->_impl_.polling_interval_);
813 }
814
GetTypeName() const815 std::string StartTaskAssignmentMetadata::GetTypeName() const {
816 return "google.internal.federatedcompute.v1.StartTaskAssignmentMetadata";
817 }
818
819
820 // ===================================================================
821
822 class StartTaskAssignmentResponse::_Internal {
823 public:
824 static const ::google::internal::federatedcompute::v1::TaskAssignment& task_assignment(const StartTaskAssignmentResponse* msg);
825 static const ::google::internal::federatedcompute::v1::RejectionInfo& rejection_info(const StartTaskAssignmentResponse* msg);
826 };
827
828 const ::google::internal::federatedcompute::v1::TaskAssignment&
task_assignment(const StartTaskAssignmentResponse * msg)829 StartTaskAssignmentResponse::_Internal::task_assignment(const StartTaskAssignmentResponse* msg) {
830 return *msg->_impl_.result_.task_assignment_;
831 }
832 const ::google::internal::federatedcompute::v1::RejectionInfo&
rejection_info(const StartTaskAssignmentResponse * msg)833 StartTaskAssignmentResponse::_Internal::rejection_info(const StartTaskAssignmentResponse* msg) {
834 return *msg->_impl_.result_.rejection_info_;
835 }
set_allocated_task_assignment(::google::internal::federatedcompute::v1::TaskAssignment * task_assignment)836 void StartTaskAssignmentResponse::set_allocated_task_assignment(::google::internal::federatedcompute::v1::TaskAssignment* task_assignment) {
837 ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
838 clear_result();
839 if (task_assignment) {
840 ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
841 ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(task_assignment);
842 if (message_arena != submessage_arena) {
843 task_assignment = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
844 message_arena, task_assignment, submessage_arena);
845 }
846 set_has_task_assignment();
847 _impl_.result_.task_assignment_ = task_assignment;
848 }
849 // @@protoc_insertion_point(field_set_allocated:google.internal.federatedcompute.v1.StartTaskAssignmentResponse.task_assignment)
850 }
set_allocated_rejection_info(::google::internal::federatedcompute::v1::RejectionInfo * rejection_info)851 void StartTaskAssignmentResponse::set_allocated_rejection_info(::google::internal::federatedcompute::v1::RejectionInfo* rejection_info) {
852 ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
853 clear_result();
854 if (rejection_info) {
855 ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
856 ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(
857 reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(rejection_info));
858 if (message_arena != submessage_arena) {
859 rejection_info = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
860 message_arena, rejection_info, submessage_arena);
861 }
862 set_has_rejection_info();
863 _impl_.result_.rejection_info_ = rejection_info;
864 }
865 // @@protoc_insertion_point(field_set_allocated:google.internal.federatedcompute.v1.StartTaskAssignmentResponse.rejection_info)
866 }
clear_rejection_info()867 void StartTaskAssignmentResponse::clear_rejection_info() {
868 if (_internal_has_rejection_info()) {
869 if (GetArenaForAllocation() == nullptr) {
870 delete _impl_.result_.rejection_info_;
871 }
872 clear_has_result();
873 }
874 }
StartTaskAssignmentResponse(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)875 StartTaskAssignmentResponse::StartTaskAssignmentResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena,
876 bool is_message_owned)
877 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
878 SharedCtor(arena, is_message_owned);
879 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.StartTaskAssignmentResponse)
880 }
StartTaskAssignmentResponse(const StartTaskAssignmentResponse & from)881 StartTaskAssignmentResponse::StartTaskAssignmentResponse(const StartTaskAssignmentResponse& from)
882 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
883 StartTaskAssignmentResponse* const _this = this; (void)_this;
884 new (&_impl_) Impl_{
885 decltype(_impl_.result_){}
886 , /*decltype(_impl_._cached_size_)*/{}
887 , /*decltype(_impl_._oneof_case_)*/{}};
888
889 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
890 clear_has_result();
891 switch (from.result_case()) {
892 case kTaskAssignment: {
893 _this->_internal_mutable_task_assignment()->::google::internal::federatedcompute::v1::TaskAssignment::MergeFrom(
894 from._internal_task_assignment());
895 break;
896 }
897 case kRejectionInfo: {
898 _this->_internal_mutable_rejection_info()->::google::internal::federatedcompute::v1::RejectionInfo::MergeFrom(
899 from._internal_rejection_info());
900 break;
901 }
902 case RESULT_NOT_SET: {
903 break;
904 }
905 }
906 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.StartTaskAssignmentResponse)
907 }
908
SharedCtor(::_pb::Arena * arena,bool is_message_owned)909 inline void StartTaskAssignmentResponse::SharedCtor(
910 ::_pb::Arena* arena, bool is_message_owned) {
911 (void)arena;
912 (void)is_message_owned;
913 new (&_impl_) Impl_{
914 decltype(_impl_.result_){}
915 , /*decltype(_impl_._cached_size_)*/{}
916 , /*decltype(_impl_._oneof_case_)*/{}
917 };
918 clear_has_result();
919 }
920
~StartTaskAssignmentResponse()921 StartTaskAssignmentResponse::~StartTaskAssignmentResponse() {
922 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.StartTaskAssignmentResponse)
923 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
924 (void)arena;
925 return;
926 }
927 SharedDtor();
928 }
929
SharedDtor()930 inline void StartTaskAssignmentResponse::SharedDtor() {
931 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
932 if (has_result()) {
933 clear_result();
934 }
935 }
936
SetCachedSize(int size) const937 void StartTaskAssignmentResponse::SetCachedSize(int size) const {
938 _impl_._cached_size_.Set(size);
939 }
940
clear_result()941 void StartTaskAssignmentResponse::clear_result() {
942 // @@protoc_insertion_point(one_of_clear_start:google.internal.federatedcompute.v1.StartTaskAssignmentResponse)
943 switch (result_case()) {
944 case kTaskAssignment: {
945 if (GetArenaForAllocation() == nullptr) {
946 delete _impl_.result_.task_assignment_;
947 }
948 break;
949 }
950 case kRejectionInfo: {
951 if (GetArenaForAllocation() == nullptr) {
952 delete _impl_.result_.rejection_info_;
953 }
954 break;
955 }
956 case RESULT_NOT_SET: {
957 break;
958 }
959 }
960 _impl_._oneof_case_[0] = RESULT_NOT_SET;
961 }
962
963
Clear()964 void StartTaskAssignmentResponse::Clear() {
965 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.StartTaskAssignmentResponse)
966 ::uint32_t cached_has_bits = 0;
967 // Prevent compiler warnings about cached_has_bits being unused
968 (void) cached_has_bits;
969
970 clear_result();
971 _internal_metadata_.Clear<std::string>();
972 }
973
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)974 const char* StartTaskAssignmentResponse::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
975 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
976 while (!ctx->Done(&ptr)) {
977 ::uint32_t tag;
978 ptr = ::_pbi::ReadTag(ptr, &tag);
979 switch (tag >> 3) {
980 // .google.internal.federatedcompute.v1.TaskAssignment task_assignment = 1;
981 case 1:
982 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) {
983 ptr = ctx->ParseMessage(_internal_mutable_task_assignment(), ptr);
984 CHK_(ptr);
985 } else {
986 goto handle_unusual;
987 }
988 continue;
989 // .google.internal.federatedcompute.v1.RejectionInfo rejection_info = 2;
990 case 2:
991 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 18)) {
992 ptr = ctx->ParseMessage(_internal_mutable_rejection_info(), ptr);
993 CHK_(ptr);
994 } else {
995 goto handle_unusual;
996 }
997 continue;
998 default:
999 goto handle_unusual;
1000 } // switch
1001 handle_unusual:
1002 if ((tag == 0) || ((tag & 7) == 4)) {
1003 CHK_(ptr);
1004 ctx->SetLastTag(tag);
1005 goto message_done;
1006 }
1007 ptr = UnknownFieldParse(
1008 tag,
1009 _internal_metadata_.mutable_unknown_fields<std::string>(),
1010 ptr, ctx);
1011 CHK_(ptr != nullptr);
1012 } // while
1013 message_done:
1014 return ptr;
1015 failure:
1016 ptr = nullptr;
1017 goto message_done;
1018 #undef CHK_
1019 }
1020
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const1021 ::uint8_t* StartTaskAssignmentResponse::_InternalSerialize(
1022 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
1023 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.StartTaskAssignmentResponse)
1024 ::uint32_t cached_has_bits = 0;
1025 (void) cached_has_bits;
1026
1027 // .google.internal.federatedcompute.v1.TaskAssignment task_assignment = 1;
1028 if (_internal_has_task_assignment()) {
1029 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
1030 InternalWriteMessage(1, _Internal::task_assignment(this),
1031 _Internal::task_assignment(this).GetCachedSize(), target, stream);
1032 }
1033
1034 // .google.internal.federatedcompute.v1.RejectionInfo rejection_info = 2;
1035 if (_internal_has_rejection_info()) {
1036 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
1037 InternalWriteMessage(2, _Internal::rejection_info(this),
1038 _Internal::rejection_info(this).GetCachedSize(), target, stream);
1039 }
1040
1041 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1042 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
1043 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
1044 }
1045 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.StartTaskAssignmentResponse)
1046 return target;
1047 }
1048
ByteSizeLong() const1049 size_t StartTaskAssignmentResponse::ByteSizeLong() const {
1050 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.StartTaskAssignmentResponse)
1051 size_t total_size = 0;
1052
1053 switch (result_case()) {
1054 // .google.internal.federatedcompute.v1.TaskAssignment task_assignment = 1;
1055 case kTaskAssignment: {
1056 total_size += 1 +
1057 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
1058 *_impl_.result_.task_assignment_);
1059 break;
1060 }
1061 // .google.internal.federatedcompute.v1.RejectionInfo rejection_info = 2;
1062 case kRejectionInfo: {
1063 total_size += 1 +
1064 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
1065 *_impl_.result_.rejection_info_);
1066 break;
1067 }
1068 case RESULT_NOT_SET: {
1069 break;
1070 }
1071 }
1072 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1073 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
1074 }
1075 int cached_size = ::_pbi::ToCachedSize(total_size);
1076 SetCachedSize(cached_size);
1077 return total_size;
1078 }
1079
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)1080 void StartTaskAssignmentResponse::CheckTypeAndMergeFrom(
1081 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
1082 MergeFrom(*::_pbi::DownCast<const StartTaskAssignmentResponse*>(
1083 &from));
1084 }
1085
MergeFrom(const StartTaskAssignmentResponse & from)1086 void StartTaskAssignmentResponse::MergeFrom(const StartTaskAssignmentResponse& from) {
1087 StartTaskAssignmentResponse* const _this = this;
1088 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.StartTaskAssignmentResponse)
1089 GOOGLE_DCHECK_NE(&from, _this);
1090 ::uint32_t cached_has_bits = 0;
1091 (void) cached_has_bits;
1092
1093 switch (from.result_case()) {
1094 case kTaskAssignment: {
1095 _this->_internal_mutable_task_assignment()->::google::internal::federatedcompute::v1::TaskAssignment::MergeFrom(
1096 from._internal_task_assignment());
1097 break;
1098 }
1099 case kRejectionInfo: {
1100 _this->_internal_mutable_rejection_info()->::google::internal::federatedcompute::v1::RejectionInfo::MergeFrom(
1101 from._internal_rejection_info());
1102 break;
1103 }
1104 case RESULT_NOT_SET: {
1105 break;
1106 }
1107 }
1108 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1109 }
1110
CopyFrom(const StartTaskAssignmentResponse & from)1111 void StartTaskAssignmentResponse::CopyFrom(const StartTaskAssignmentResponse& from) {
1112 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.StartTaskAssignmentResponse)
1113 if (&from == this) return;
1114 Clear();
1115 MergeFrom(from);
1116 }
1117
IsInitialized() const1118 bool StartTaskAssignmentResponse::IsInitialized() const {
1119 return true;
1120 }
1121
InternalSwap(StartTaskAssignmentResponse * other)1122 void StartTaskAssignmentResponse::InternalSwap(StartTaskAssignmentResponse* other) {
1123 using std::swap;
1124 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
1125 swap(_impl_.result_, other->_impl_.result_);
1126 swap(_impl_._oneof_case_[0], other->_impl_._oneof_case_[0]);
1127 }
1128
GetTypeName() const1129 std::string StartTaskAssignmentResponse::GetTypeName() const {
1130 return "google.internal.federatedcompute.v1.StartTaskAssignmentResponse";
1131 }
1132
1133
1134 // ===================================================================
1135
1136 class PerformMultipleTaskAssignmentsRequest::_Internal {
1137 public:
1138 static const ::google::internal::federatedcompute::v1::ClientVersion& client_version(const PerformMultipleTaskAssignmentsRequest* msg);
1139 static const ::google::internal::federatedcompute::v1::ResourceCapabilities& resource_capabilities(const PerformMultipleTaskAssignmentsRequest* msg);
1140 };
1141
1142 const ::google::internal::federatedcompute::v1::ClientVersion&
client_version(const PerformMultipleTaskAssignmentsRequest * msg)1143 PerformMultipleTaskAssignmentsRequest::_Internal::client_version(const PerformMultipleTaskAssignmentsRequest* msg) {
1144 return *msg->_impl_.client_version_;
1145 }
1146 const ::google::internal::federatedcompute::v1::ResourceCapabilities&
resource_capabilities(const PerformMultipleTaskAssignmentsRequest * msg)1147 PerformMultipleTaskAssignmentsRequest::_Internal::resource_capabilities(const PerformMultipleTaskAssignmentsRequest* msg) {
1148 return *msg->_impl_.resource_capabilities_;
1149 }
clear_client_version()1150 void PerformMultipleTaskAssignmentsRequest::clear_client_version() {
1151 if (GetArenaForAllocation() == nullptr && _impl_.client_version_ != nullptr) {
1152 delete _impl_.client_version_;
1153 }
1154 _impl_.client_version_ = nullptr;
1155 }
clear_resource_capabilities()1156 void PerformMultipleTaskAssignmentsRequest::clear_resource_capabilities() {
1157 if (GetArenaForAllocation() == nullptr && _impl_.resource_capabilities_ != nullptr) {
1158 delete _impl_.resource_capabilities_;
1159 }
1160 _impl_.resource_capabilities_ = nullptr;
1161 }
PerformMultipleTaskAssignmentsRequest(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)1162 PerformMultipleTaskAssignmentsRequest::PerformMultipleTaskAssignmentsRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1163 bool is_message_owned)
1164 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
1165 SharedCtor(arena, is_message_owned);
1166 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsRequest)
1167 }
PerformMultipleTaskAssignmentsRequest(const PerformMultipleTaskAssignmentsRequest & from)1168 PerformMultipleTaskAssignmentsRequest::PerformMultipleTaskAssignmentsRequest(const PerformMultipleTaskAssignmentsRequest& from)
1169 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
1170 PerformMultipleTaskAssignmentsRequest* const _this = this; (void)_this;
1171 new (&_impl_) Impl_{
1172 decltype(_impl_.task_names_){from._impl_.task_names_}
1173 , decltype(_impl_.population_name_){}
1174 , decltype(_impl_.session_id_){}
1175 , decltype(_impl_.client_version_){nullptr}
1176 , decltype(_impl_.resource_capabilities_){nullptr}
1177 , /*decltype(_impl_._cached_size_)*/{}};
1178
1179 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1180 _impl_.population_name_.InitDefault();
1181 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1182 _impl_.population_name_.Set("", GetArenaForAllocation());
1183 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1184 if (!from._internal_population_name().empty()) {
1185 _this->_impl_.population_name_.Set(from._internal_population_name(),
1186 _this->GetArenaForAllocation());
1187 }
1188 _impl_.session_id_.InitDefault();
1189 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1190 _impl_.session_id_.Set("", GetArenaForAllocation());
1191 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1192 if (!from._internal_session_id().empty()) {
1193 _this->_impl_.session_id_.Set(from._internal_session_id(),
1194 _this->GetArenaForAllocation());
1195 }
1196 if (from._internal_has_client_version()) {
1197 _this->_impl_.client_version_ = new ::google::internal::federatedcompute::v1::ClientVersion(*from._impl_.client_version_);
1198 }
1199 if (from._internal_has_resource_capabilities()) {
1200 _this->_impl_.resource_capabilities_ = new ::google::internal::federatedcompute::v1::ResourceCapabilities(*from._impl_.resource_capabilities_);
1201 }
1202 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsRequest)
1203 }
1204
SharedCtor(::_pb::Arena * arena,bool is_message_owned)1205 inline void PerformMultipleTaskAssignmentsRequest::SharedCtor(
1206 ::_pb::Arena* arena, bool is_message_owned) {
1207 (void)arena;
1208 (void)is_message_owned;
1209 new (&_impl_) Impl_{
1210 decltype(_impl_.task_names_){arena}
1211 , decltype(_impl_.population_name_){}
1212 , decltype(_impl_.session_id_){}
1213 , decltype(_impl_.client_version_){nullptr}
1214 , decltype(_impl_.resource_capabilities_){nullptr}
1215 , /*decltype(_impl_._cached_size_)*/{}
1216 };
1217 _impl_.population_name_.InitDefault();
1218 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1219 _impl_.population_name_.Set("", GetArenaForAllocation());
1220 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1221 _impl_.session_id_.InitDefault();
1222 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1223 _impl_.session_id_.Set("", GetArenaForAllocation());
1224 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1225 }
1226
~PerformMultipleTaskAssignmentsRequest()1227 PerformMultipleTaskAssignmentsRequest::~PerformMultipleTaskAssignmentsRequest() {
1228 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsRequest)
1229 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
1230 (void)arena;
1231 return;
1232 }
1233 SharedDtor();
1234 }
1235
SharedDtor()1236 inline void PerformMultipleTaskAssignmentsRequest::SharedDtor() {
1237 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
1238 _impl_.task_names_.~RepeatedPtrField();
1239 _impl_.population_name_.Destroy();
1240 _impl_.session_id_.Destroy();
1241 if (this != internal_default_instance()) delete _impl_.client_version_;
1242 if (this != internal_default_instance()) delete _impl_.resource_capabilities_;
1243 }
1244
SetCachedSize(int size) const1245 void PerformMultipleTaskAssignmentsRequest::SetCachedSize(int size) const {
1246 _impl_._cached_size_.Set(size);
1247 }
1248
Clear()1249 void PerformMultipleTaskAssignmentsRequest::Clear() {
1250 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsRequest)
1251 ::uint32_t cached_has_bits = 0;
1252 // Prevent compiler warnings about cached_has_bits being unused
1253 (void) cached_has_bits;
1254
1255 _impl_.task_names_.Clear();
1256 _impl_.population_name_.ClearToEmpty();
1257 _impl_.session_id_.ClearToEmpty();
1258 if (GetArenaForAllocation() == nullptr && _impl_.client_version_ != nullptr) {
1259 delete _impl_.client_version_;
1260 }
1261 _impl_.client_version_ = nullptr;
1262 if (GetArenaForAllocation() == nullptr && _impl_.resource_capabilities_ != nullptr) {
1263 delete _impl_.resource_capabilities_;
1264 }
1265 _impl_.resource_capabilities_ = nullptr;
1266 _internal_metadata_.Clear<std::string>();
1267 }
1268
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)1269 const char* PerformMultipleTaskAssignmentsRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
1270 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
1271 while (!ctx->Done(&ptr)) {
1272 ::uint32_t tag;
1273 ptr = ::_pbi::ReadTag(ptr, &tag);
1274 switch (tag >> 3) {
1275 // string population_name = 1;
1276 case 1:
1277 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) {
1278 auto str = _internal_mutable_population_name();
1279 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
1280 CHK_(ptr);
1281 CHK_(::_pbi::VerifyUTF8(str, nullptr));
1282 } else {
1283 goto handle_unusual;
1284 }
1285 continue;
1286 // string session_id = 2;
1287 case 2:
1288 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 18)) {
1289 auto str = _internal_mutable_session_id();
1290 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
1291 CHK_(ptr);
1292 CHK_(::_pbi::VerifyUTF8(str, nullptr));
1293 } else {
1294 goto handle_unusual;
1295 }
1296 continue;
1297 // .google.internal.federatedcompute.v1.ClientVersion client_version = 3;
1298 case 3:
1299 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 26)) {
1300 ptr = ctx->ParseMessage(_internal_mutable_client_version(), ptr);
1301 CHK_(ptr);
1302 } else {
1303 goto handle_unusual;
1304 }
1305 continue;
1306 // .google.internal.federatedcompute.v1.ResourceCapabilities resource_capabilities = 4;
1307 case 4:
1308 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 34)) {
1309 ptr = ctx->ParseMessage(_internal_mutable_resource_capabilities(), ptr);
1310 CHK_(ptr);
1311 } else {
1312 goto handle_unusual;
1313 }
1314 continue;
1315 // repeated string task_names = 5;
1316 case 5:
1317 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 42)) {
1318 ptr -= 1;
1319 do {
1320 ptr += 1;
1321 auto str = _internal_add_task_names();
1322 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
1323 CHK_(ptr);
1324 CHK_(::_pbi::VerifyUTF8(str, nullptr));
1325 if (!ctx->DataAvailable(ptr)) break;
1326 } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<42>(ptr));
1327 } else {
1328 goto handle_unusual;
1329 }
1330 continue;
1331 default:
1332 goto handle_unusual;
1333 } // switch
1334 handle_unusual:
1335 if ((tag == 0) || ((tag & 7) == 4)) {
1336 CHK_(ptr);
1337 ctx->SetLastTag(tag);
1338 goto message_done;
1339 }
1340 ptr = UnknownFieldParse(
1341 tag,
1342 _internal_metadata_.mutable_unknown_fields<std::string>(),
1343 ptr, ctx);
1344 CHK_(ptr != nullptr);
1345 } // while
1346 message_done:
1347 return ptr;
1348 failure:
1349 ptr = nullptr;
1350 goto message_done;
1351 #undef CHK_
1352 }
1353
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const1354 ::uint8_t* PerformMultipleTaskAssignmentsRequest::_InternalSerialize(
1355 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
1356 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsRequest)
1357 ::uint32_t cached_has_bits = 0;
1358 (void) cached_has_bits;
1359
1360 // string population_name = 1;
1361 if (!this->_internal_population_name().empty()) {
1362 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
1363 this->_internal_population_name().data(), static_cast<int>(this->_internal_population_name().length()),
1364 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
1365 "google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsRequest.population_name");
1366 target = stream->WriteStringMaybeAliased(
1367 1, this->_internal_population_name(), target);
1368 }
1369
1370 // string session_id = 2;
1371 if (!this->_internal_session_id().empty()) {
1372 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
1373 this->_internal_session_id().data(), static_cast<int>(this->_internal_session_id().length()),
1374 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
1375 "google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsRequest.session_id");
1376 target = stream->WriteStringMaybeAliased(
1377 2, this->_internal_session_id(), target);
1378 }
1379
1380 // .google.internal.federatedcompute.v1.ClientVersion client_version = 3;
1381 if (this->_internal_has_client_version()) {
1382 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
1383 InternalWriteMessage(3, _Internal::client_version(this),
1384 _Internal::client_version(this).GetCachedSize(), target, stream);
1385 }
1386
1387 // .google.internal.federatedcompute.v1.ResourceCapabilities resource_capabilities = 4;
1388 if (this->_internal_has_resource_capabilities()) {
1389 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
1390 InternalWriteMessage(4, _Internal::resource_capabilities(this),
1391 _Internal::resource_capabilities(this).GetCachedSize(), target, stream);
1392 }
1393
1394 // repeated string task_names = 5;
1395 for (int i = 0, n = this->_internal_task_names_size(); i < n; i++) {
1396 const auto& s = this->_internal_task_names(i);
1397 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
1398 s.data(), static_cast<int>(s.length()),
1399 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
1400 "google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsRequest.task_names");
1401 target = stream->WriteString(5, s, target);
1402 }
1403
1404 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1405 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
1406 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
1407 }
1408 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsRequest)
1409 return target;
1410 }
1411
ByteSizeLong() const1412 size_t PerformMultipleTaskAssignmentsRequest::ByteSizeLong() const {
1413 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsRequest)
1414 size_t total_size = 0;
1415
1416 ::uint32_t cached_has_bits = 0;
1417 // Prevent compiler warnings about cached_has_bits being unused
1418 (void) cached_has_bits;
1419
1420 // repeated string task_names = 5;
1421 total_size += 1 *
1422 ::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(_impl_.task_names_.size());
1423 for (int i = 0, n = _impl_.task_names_.size(); i < n; i++) {
1424 total_size += ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1425 _impl_.task_names_.Get(i));
1426 }
1427
1428 // string population_name = 1;
1429 if (!this->_internal_population_name().empty()) {
1430 total_size += 1 +
1431 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1432 this->_internal_population_name());
1433 }
1434
1435 // string session_id = 2;
1436 if (!this->_internal_session_id().empty()) {
1437 total_size += 1 +
1438 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1439 this->_internal_session_id());
1440 }
1441
1442 // .google.internal.federatedcompute.v1.ClientVersion client_version = 3;
1443 if (this->_internal_has_client_version()) {
1444 total_size += 1 +
1445 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
1446 *_impl_.client_version_);
1447 }
1448
1449 // .google.internal.federatedcompute.v1.ResourceCapabilities resource_capabilities = 4;
1450 if (this->_internal_has_resource_capabilities()) {
1451 total_size += 1 +
1452 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
1453 *_impl_.resource_capabilities_);
1454 }
1455
1456 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1457 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
1458 }
1459 int cached_size = ::_pbi::ToCachedSize(total_size);
1460 SetCachedSize(cached_size);
1461 return total_size;
1462 }
1463
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)1464 void PerformMultipleTaskAssignmentsRequest::CheckTypeAndMergeFrom(
1465 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
1466 MergeFrom(*::_pbi::DownCast<const PerformMultipleTaskAssignmentsRequest*>(
1467 &from));
1468 }
1469
MergeFrom(const PerformMultipleTaskAssignmentsRequest & from)1470 void PerformMultipleTaskAssignmentsRequest::MergeFrom(const PerformMultipleTaskAssignmentsRequest& from) {
1471 PerformMultipleTaskAssignmentsRequest* const _this = this;
1472 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsRequest)
1473 GOOGLE_DCHECK_NE(&from, _this);
1474 ::uint32_t cached_has_bits = 0;
1475 (void) cached_has_bits;
1476
1477 _this->_impl_.task_names_.MergeFrom(from._impl_.task_names_);
1478 if (!from._internal_population_name().empty()) {
1479 _this->_internal_set_population_name(from._internal_population_name());
1480 }
1481 if (!from._internal_session_id().empty()) {
1482 _this->_internal_set_session_id(from._internal_session_id());
1483 }
1484 if (from._internal_has_client_version()) {
1485 _this->_internal_mutable_client_version()->::google::internal::federatedcompute::v1::ClientVersion::MergeFrom(
1486 from._internal_client_version());
1487 }
1488 if (from._internal_has_resource_capabilities()) {
1489 _this->_internal_mutable_resource_capabilities()->::google::internal::federatedcompute::v1::ResourceCapabilities::MergeFrom(
1490 from._internal_resource_capabilities());
1491 }
1492 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1493 }
1494
CopyFrom(const PerformMultipleTaskAssignmentsRequest & from)1495 void PerformMultipleTaskAssignmentsRequest::CopyFrom(const PerformMultipleTaskAssignmentsRequest& from) {
1496 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsRequest)
1497 if (&from == this) return;
1498 Clear();
1499 MergeFrom(from);
1500 }
1501
IsInitialized() const1502 bool PerformMultipleTaskAssignmentsRequest::IsInitialized() const {
1503 return true;
1504 }
1505
InternalSwap(PerformMultipleTaskAssignmentsRequest * other)1506 void PerformMultipleTaskAssignmentsRequest::InternalSwap(PerformMultipleTaskAssignmentsRequest* other) {
1507 using std::swap;
1508 auto* lhs_arena = GetArenaForAllocation();
1509 auto* rhs_arena = other->GetArenaForAllocation();
1510 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
1511 _impl_.task_names_.InternalSwap(&other->_impl_.task_names_);
1512 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
1513 &_impl_.population_name_, lhs_arena,
1514 &other->_impl_.population_name_, rhs_arena
1515 );
1516 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
1517 &_impl_.session_id_, lhs_arena,
1518 &other->_impl_.session_id_, rhs_arena
1519 );
1520 ::PROTOBUF_NAMESPACE_ID::internal::memswap<
1521 PROTOBUF_FIELD_OFFSET(PerformMultipleTaskAssignmentsRequest, _impl_.resource_capabilities_)
1522 + sizeof(PerformMultipleTaskAssignmentsRequest::_impl_.resource_capabilities_) // NOLINT
1523 - PROTOBUF_FIELD_OFFSET(PerformMultipleTaskAssignmentsRequest, _impl_.client_version_)>(
1524 reinterpret_cast<char*>(&_impl_.client_version_),
1525 reinterpret_cast<char*>(&other->_impl_.client_version_));
1526 }
1527
GetTypeName() const1528 std::string PerformMultipleTaskAssignmentsRequest::GetTypeName() const {
1529 return "google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsRequest";
1530 }
1531
1532
1533 // ===================================================================
1534
1535 class PerformMultipleTaskAssignmentsResponse::_Internal {
1536 public:
1537 };
1538
PerformMultipleTaskAssignmentsResponse(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)1539 PerformMultipleTaskAssignmentsResponse::PerformMultipleTaskAssignmentsResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1540 bool is_message_owned)
1541 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
1542 SharedCtor(arena, is_message_owned);
1543 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsResponse)
1544 }
PerformMultipleTaskAssignmentsResponse(const PerformMultipleTaskAssignmentsResponse & from)1545 PerformMultipleTaskAssignmentsResponse::PerformMultipleTaskAssignmentsResponse(const PerformMultipleTaskAssignmentsResponse& from)
1546 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
1547 PerformMultipleTaskAssignmentsResponse* const _this = this; (void)_this;
1548 new (&_impl_) Impl_{
1549 decltype(_impl_.task_assignments_){from._impl_.task_assignments_}
1550 , /*decltype(_impl_._cached_size_)*/{}};
1551
1552 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1553 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsResponse)
1554 }
1555
SharedCtor(::_pb::Arena * arena,bool is_message_owned)1556 inline void PerformMultipleTaskAssignmentsResponse::SharedCtor(
1557 ::_pb::Arena* arena, bool is_message_owned) {
1558 (void)arena;
1559 (void)is_message_owned;
1560 new (&_impl_) Impl_{
1561 decltype(_impl_.task_assignments_){arena}
1562 , /*decltype(_impl_._cached_size_)*/{}
1563 };
1564 }
1565
~PerformMultipleTaskAssignmentsResponse()1566 PerformMultipleTaskAssignmentsResponse::~PerformMultipleTaskAssignmentsResponse() {
1567 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsResponse)
1568 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
1569 (void)arena;
1570 return;
1571 }
1572 SharedDtor();
1573 }
1574
SharedDtor()1575 inline void PerformMultipleTaskAssignmentsResponse::SharedDtor() {
1576 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
1577 _impl_.task_assignments_.~RepeatedPtrField();
1578 }
1579
SetCachedSize(int size) const1580 void PerformMultipleTaskAssignmentsResponse::SetCachedSize(int size) const {
1581 _impl_._cached_size_.Set(size);
1582 }
1583
Clear()1584 void PerformMultipleTaskAssignmentsResponse::Clear() {
1585 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsResponse)
1586 ::uint32_t cached_has_bits = 0;
1587 // Prevent compiler warnings about cached_has_bits being unused
1588 (void) cached_has_bits;
1589
1590 _impl_.task_assignments_.Clear();
1591 _internal_metadata_.Clear<std::string>();
1592 }
1593
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)1594 const char* PerformMultipleTaskAssignmentsResponse::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
1595 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
1596 while (!ctx->Done(&ptr)) {
1597 ::uint32_t tag;
1598 ptr = ::_pbi::ReadTag(ptr, &tag);
1599 switch (tag >> 3) {
1600 // repeated .google.internal.federatedcompute.v1.TaskAssignment task_assignments = 1;
1601 case 1:
1602 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) {
1603 ptr -= 1;
1604 do {
1605 ptr += 1;
1606 ptr = ctx->ParseMessage(_internal_add_task_assignments(), ptr);
1607 CHK_(ptr);
1608 if (!ctx->DataAvailable(ptr)) break;
1609 } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<10>(ptr));
1610 } else {
1611 goto handle_unusual;
1612 }
1613 continue;
1614 default:
1615 goto handle_unusual;
1616 } // switch
1617 handle_unusual:
1618 if ((tag == 0) || ((tag & 7) == 4)) {
1619 CHK_(ptr);
1620 ctx->SetLastTag(tag);
1621 goto message_done;
1622 }
1623 ptr = UnknownFieldParse(
1624 tag,
1625 _internal_metadata_.mutable_unknown_fields<std::string>(),
1626 ptr, ctx);
1627 CHK_(ptr != nullptr);
1628 } // while
1629 message_done:
1630 return ptr;
1631 failure:
1632 ptr = nullptr;
1633 goto message_done;
1634 #undef CHK_
1635 }
1636
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const1637 ::uint8_t* PerformMultipleTaskAssignmentsResponse::_InternalSerialize(
1638 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
1639 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsResponse)
1640 ::uint32_t cached_has_bits = 0;
1641 (void) cached_has_bits;
1642
1643 // repeated .google.internal.federatedcompute.v1.TaskAssignment task_assignments = 1;
1644 for (unsigned i = 0,
1645 n = static_cast<unsigned>(this->_internal_task_assignments_size()); i < n; i++) {
1646 const auto& repfield = this->_internal_task_assignments(i);
1647 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
1648 InternalWriteMessage(1, repfield, repfield.GetCachedSize(), target, stream);
1649 }
1650
1651 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1652 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
1653 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
1654 }
1655 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsResponse)
1656 return target;
1657 }
1658
ByteSizeLong() const1659 size_t PerformMultipleTaskAssignmentsResponse::ByteSizeLong() const {
1660 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsResponse)
1661 size_t total_size = 0;
1662
1663 ::uint32_t cached_has_bits = 0;
1664 // Prevent compiler warnings about cached_has_bits being unused
1665 (void) cached_has_bits;
1666
1667 // repeated .google.internal.federatedcompute.v1.TaskAssignment task_assignments = 1;
1668 total_size += 1UL * this->_internal_task_assignments_size();
1669 for (const auto& msg : this->_impl_.task_assignments_) {
1670 total_size +=
1671 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(msg);
1672 }
1673
1674 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1675 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
1676 }
1677 int cached_size = ::_pbi::ToCachedSize(total_size);
1678 SetCachedSize(cached_size);
1679 return total_size;
1680 }
1681
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)1682 void PerformMultipleTaskAssignmentsResponse::CheckTypeAndMergeFrom(
1683 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
1684 MergeFrom(*::_pbi::DownCast<const PerformMultipleTaskAssignmentsResponse*>(
1685 &from));
1686 }
1687
MergeFrom(const PerformMultipleTaskAssignmentsResponse & from)1688 void PerformMultipleTaskAssignmentsResponse::MergeFrom(const PerformMultipleTaskAssignmentsResponse& from) {
1689 PerformMultipleTaskAssignmentsResponse* const _this = this;
1690 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsResponse)
1691 GOOGLE_DCHECK_NE(&from, _this);
1692 ::uint32_t cached_has_bits = 0;
1693 (void) cached_has_bits;
1694
1695 _this->_impl_.task_assignments_.MergeFrom(from._impl_.task_assignments_);
1696 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1697 }
1698
CopyFrom(const PerformMultipleTaskAssignmentsResponse & from)1699 void PerformMultipleTaskAssignmentsResponse::CopyFrom(const PerformMultipleTaskAssignmentsResponse& from) {
1700 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsResponse)
1701 if (&from == this) return;
1702 Clear();
1703 MergeFrom(from);
1704 }
1705
IsInitialized() const1706 bool PerformMultipleTaskAssignmentsResponse::IsInitialized() const {
1707 return true;
1708 }
1709
InternalSwap(PerformMultipleTaskAssignmentsResponse * other)1710 void PerformMultipleTaskAssignmentsResponse::InternalSwap(PerformMultipleTaskAssignmentsResponse* other) {
1711 using std::swap;
1712 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
1713 _impl_.task_assignments_.InternalSwap(&other->_impl_.task_assignments_);
1714 }
1715
GetTypeName() const1716 std::string PerformMultipleTaskAssignmentsResponse::GetTypeName() const {
1717 return "google.internal.federatedcompute.v1.PerformMultipleTaskAssignmentsResponse";
1718 }
1719
1720
1721 // ===================================================================
1722
1723 class TaskAssignment_AggregationInfo::_Internal {
1724 public:
1725 };
1726
TaskAssignment_AggregationInfo(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)1727 TaskAssignment_AggregationInfo::TaskAssignment_AggregationInfo(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1728 bool is_message_owned)
1729 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
1730 SharedCtor(arena, is_message_owned);
1731 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.TaskAssignment.AggregationInfo)
1732 }
TaskAssignment_AggregationInfo(const TaskAssignment_AggregationInfo & from)1733 TaskAssignment_AggregationInfo::TaskAssignment_AggregationInfo(const TaskAssignment_AggregationInfo& from)
1734 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
1735 TaskAssignment_AggregationInfo* const _this = this; (void)_this;
1736 new (&_impl_) Impl_{
1737 /*decltype(_impl_._cached_size_)*/{}};
1738
1739 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1740 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.TaskAssignment.AggregationInfo)
1741 }
1742
SharedCtor(::_pb::Arena * arena,bool is_message_owned)1743 inline void TaskAssignment_AggregationInfo::SharedCtor(
1744 ::_pb::Arena* arena, bool is_message_owned) {
1745 (void)arena;
1746 (void)is_message_owned;
1747 new (&_impl_) Impl_{
1748 /*decltype(_impl_._cached_size_)*/{}
1749 };
1750 }
1751
~TaskAssignment_AggregationInfo()1752 TaskAssignment_AggregationInfo::~TaskAssignment_AggregationInfo() {
1753 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.TaskAssignment.AggregationInfo)
1754 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
1755 (void)arena;
1756 return;
1757 }
1758 SharedDtor();
1759 }
1760
SharedDtor()1761 inline void TaskAssignment_AggregationInfo::SharedDtor() {
1762 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
1763 }
1764
SetCachedSize(int size) const1765 void TaskAssignment_AggregationInfo::SetCachedSize(int size) const {
1766 _impl_._cached_size_.Set(size);
1767 }
1768
Clear()1769 void TaskAssignment_AggregationInfo::Clear() {
1770 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.TaskAssignment.AggregationInfo)
1771 ::uint32_t cached_has_bits = 0;
1772 // Prevent compiler warnings about cached_has_bits being unused
1773 (void) cached_has_bits;
1774
1775 _internal_metadata_.Clear<std::string>();
1776 }
1777
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)1778 const char* TaskAssignment_AggregationInfo::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
1779 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
1780 while (!ctx->Done(&ptr)) {
1781 ::uint32_t tag;
1782 ptr = ::_pbi::ReadTag(ptr, &tag);
1783 if ((tag == 0) || ((tag & 7) == 4)) {
1784 CHK_(ptr);
1785 ctx->SetLastTag(tag);
1786 goto message_done;
1787 }
1788 ptr = UnknownFieldParse(
1789 tag,
1790 _internal_metadata_.mutable_unknown_fields<std::string>(),
1791 ptr, ctx);
1792 CHK_(ptr != nullptr);
1793 } // while
1794 message_done:
1795 return ptr;
1796 failure:
1797 ptr = nullptr;
1798 goto message_done;
1799 #undef CHK_
1800 }
1801
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const1802 ::uint8_t* TaskAssignment_AggregationInfo::_InternalSerialize(
1803 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
1804 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.TaskAssignment.AggregationInfo)
1805 ::uint32_t cached_has_bits = 0;
1806 (void) cached_has_bits;
1807
1808 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1809 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
1810 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
1811 }
1812 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.TaskAssignment.AggregationInfo)
1813 return target;
1814 }
1815
ByteSizeLong() const1816 size_t TaskAssignment_AggregationInfo::ByteSizeLong() const {
1817 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.TaskAssignment.AggregationInfo)
1818 size_t total_size = 0;
1819
1820 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1821 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
1822 }
1823 int cached_size = ::_pbi::ToCachedSize(total_size);
1824 SetCachedSize(cached_size);
1825 return total_size;
1826 }
1827
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)1828 void TaskAssignment_AggregationInfo::CheckTypeAndMergeFrom(
1829 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
1830 MergeFrom(*::_pbi::DownCast<const TaskAssignment_AggregationInfo*>(
1831 &from));
1832 }
1833
MergeFrom(const TaskAssignment_AggregationInfo & from)1834 void TaskAssignment_AggregationInfo::MergeFrom(const TaskAssignment_AggregationInfo& from) {
1835 TaskAssignment_AggregationInfo* const _this = this;
1836 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.TaskAssignment.AggregationInfo)
1837 GOOGLE_DCHECK_NE(&from, _this);
1838 ::uint32_t cached_has_bits = 0;
1839 (void) cached_has_bits;
1840
1841 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1842 }
1843
CopyFrom(const TaskAssignment_AggregationInfo & from)1844 void TaskAssignment_AggregationInfo::CopyFrom(const TaskAssignment_AggregationInfo& from) {
1845 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.TaskAssignment.AggregationInfo)
1846 if (&from == this) return;
1847 Clear();
1848 MergeFrom(from);
1849 }
1850
IsInitialized() const1851 bool TaskAssignment_AggregationInfo::IsInitialized() const {
1852 return true;
1853 }
1854
InternalSwap(TaskAssignment_AggregationInfo * other)1855 void TaskAssignment_AggregationInfo::InternalSwap(TaskAssignment_AggregationInfo* other) {
1856 using std::swap;
1857 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
1858 }
1859
GetTypeName() const1860 std::string TaskAssignment_AggregationInfo::GetTypeName() const {
1861 return "google.internal.federatedcompute.v1.TaskAssignment.AggregationInfo";
1862 }
1863
1864
1865 // ===================================================================
1866
1867 class TaskAssignment_SecureAggregationInfo::_Internal {
1868 public:
1869 };
1870
TaskAssignment_SecureAggregationInfo(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)1871 TaskAssignment_SecureAggregationInfo::TaskAssignment_SecureAggregationInfo(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1872 bool is_message_owned)
1873 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
1874 SharedCtor(arena, is_message_owned);
1875 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.TaskAssignment.SecureAggregationInfo)
1876 }
TaskAssignment_SecureAggregationInfo(const TaskAssignment_SecureAggregationInfo & from)1877 TaskAssignment_SecureAggregationInfo::TaskAssignment_SecureAggregationInfo(const TaskAssignment_SecureAggregationInfo& from)
1878 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
1879 TaskAssignment_SecureAggregationInfo* const _this = this; (void)_this;
1880 new (&_impl_) Impl_{
1881 decltype(_impl_.minimum_clients_in_server_visible_aggregate_){}
1882 , /*decltype(_impl_._cached_size_)*/{}};
1883
1884 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1885 _this->_impl_.minimum_clients_in_server_visible_aggregate_ = from._impl_.minimum_clients_in_server_visible_aggregate_;
1886 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.TaskAssignment.SecureAggregationInfo)
1887 }
1888
SharedCtor(::_pb::Arena * arena,bool is_message_owned)1889 inline void TaskAssignment_SecureAggregationInfo::SharedCtor(
1890 ::_pb::Arena* arena, bool is_message_owned) {
1891 (void)arena;
1892 (void)is_message_owned;
1893 new (&_impl_) Impl_{
1894 decltype(_impl_.minimum_clients_in_server_visible_aggregate_){0}
1895 , /*decltype(_impl_._cached_size_)*/{}
1896 };
1897 }
1898
~TaskAssignment_SecureAggregationInfo()1899 TaskAssignment_SecureAggregationInfo::~TaskAssignment_SecureAggregationInfo() {
1900 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.TaskAssignment.SecureAggregationInfo)
1901 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
1902 (void)arena;
1903 return;
1904 }
1905 SharedDtor();
1906 }
1907
SharedDtor()1908 inline void TaskAssignment_SecureAggregationInfo::SharedDtor() {
1909 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
1910 }
1911
SetCachedSize(int size) const1912 void TaskAssignment_SecureAggregationInfo::SetCachedSize(int size) const {
1913 _impl_._cached_size_.Set(size);
1914 }
1915
Clear()1916 void TaskAssignment_SecureAggregationInfo::Clear() {
1917 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.TaskAssignment.SecureAggregationInfo)
1918 ::uint32_t cached_has_bits = 0;
1919 // Prevent compiler warnings about cached_has_bits being unused
1920 (void) cached_has_bits;
1921
1922 _impl_.minimum_clients_in_server_visible_aggregate_ = 0;
1923 _internal_metadata_.Clear<std::string>();
1924 }
1925
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)1926 const char* TaskAssignment_SecureAggregationInfo::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
1927 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
1928 while (!ctx->Done(&ptr)) {
1929 ::uint32_t tag;
1930 ptr = ::_pbi::ReadTag(ptr, &tag);
1931 switch (tag >> 3) {
1932 // int32 minimum_clients_in_server_visible_aggregate = 1;
1933 case 1:
1934 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 8)) {
1935 _impl_.minimum_clients_in_server_visible_aggregate_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint32(&ptr);
1936 CHK_(ptr);
1937 } else {
1938 goto handle_unusual;
1939 }
1940 continue;
1941 default:
1942 goto handle_unusual;
1943 } // switch
1944 handle_unusual:
1945 if ((tag == 0) || ((tag & 7) == 4)) {
1946 CHK_(ptr);
1947 ctx->SetLastTag(tag);
1948 goto message_done;
1949 }
1950 ptr = UnknownFieldParse(
1951 tag,
1952 _internal_metadata_.mutable_unknown_fields<std::string>(),
1953 ptr, ctx);
1954 CHK_(ptr != nullptr);
1955 } // while
1956 message_done:
1957 return ptr;
1958 failure:
1959 ptr = nullptr;
1960 goto message_done;
1961 #undef CHK_
1962 }
1963
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const1964 ::uint8_t* TaskAssignment_SecureAggregationInfo::_InternalSerialize(
1965 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
1966 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.TaskAssignment.SecureAggregationInfo)
1967 ::uint32_t cached_has_bits = 0;
1968 (void) cached_has_bits;
1969
1970 // int32 minimum_clients_in_server_visible_aggregate = 1;
1971 if (this->_internal_minimum_clients_in_server_visible_aggregate() != 0) {
1972 target = stream->EnsureSpace(target);
1973 target = ::_pbi::WireFormatLite::WriteInt32ToArray(1, this->_internal_minimum_clients_in_server_visible_aggregate(), target);
1974 }
1975
1976 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1977 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
1978 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
1979 }
1980 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.TaskAssignment.SecureAggregationInfo)
1981 return target;
1982 }
1983
ByteSizeLong() const1984 size_t TaskAssignment_SecureAggregationInfo::ByteSizeLong() const {
1985 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.TaskAssignment.SecureAggregationInfo)
1986 size_t total_size = 0;
1987
1988 ::uint32_t cached_has_bits = 0;
1989 // Prevent compiler warnings about cached_has_bits being unused
1990 (void) cached_has_bits;
1991
1992 // int32 minimum_clients_in_server_visible_aggregate = 1;
1993 if (this->_internal_minimum_clients_in_server_visible_aggregate() != 0) {
1994 total_size += ::_pbi::WireFormatLite::Int32SizePlusOne(this->_internal_minimum_clients_in_server_visible_aggregate());
1995 }
1996
1997 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1998 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
1999 }
2000 int cached_size = ::_pbi::ToCachedSize(total_size);
2001 SetCachedSize(cached_size);
2002 return total_size;
2003 }
2004
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)2005 void TaskAssignment_SecureAggregationInfo::CheckTypeAndMergeFrom(
2006 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
2007 MergeFrom(*::_pbi::DownCast<const TaskAssignment_SecureAggregationInfo*>(
2008 &from));
2009 }
2010
MergeFrom(const TaskAssignment_SecureAggregationInfo & from)2011 void TaskAssignment_SecureAggregationInfo::MergeFrom(const TaskAssignment_SecureAggregationInfo& from) {
2012 TaskAssignment_SecureAggregationInfo* const _this = this;
2013 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.TaskAssignment.SecureAggregationInfo)
2014 GOOGLE_DCHECK_NE(&from, _this);
2015 ::uint32_t cached_has_bits = 0;
2016 (void) cached_has_bits;
2017
2018 if (from._internal_minimum_clients_in_server_visible_aggregate() != 0) {
2019 _this->_internal_set_minimum_clients_in_server_visible_aggregate(from._internal_minimum_clients_in_server_visible_aggregate());
2020 }
2021 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
2022 }
2023
CopyFrom(const TaskAssignment_SecureAggregationInfo & from)2024 void TaskAssignment_SecureAggregationInfo::CopyFrom(const TaskAssignment_SecureAggregationInfo& from) {
2025 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.TaskAssignment.SecureAggregationInfo)
2026 if (&from == this) return;
2027 Clear();
2028 MergeFrom(from);
2029 }
2030
IsInitialized() const2031 bool TaskAssignment_SecureAggregationInfo::IsInitialized() const {
2032 return true;
2033 }
2034
InternalSwap(TaskAssignment_SecureAggregationInfo * other)2035 void TaskAssignment_SecureAggregationInfo::InternalSwap(TaskAssignment_SecureAggregationInfo* other) {
2036 using std::swap;
2037 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
2038 swap(_impl_.minimum_clients_in_server_visible_aggregate_, other->_impl_.minimum_clients_in_server_visible_aggregate_);
2039 }
2040
GetTypeName() const2041 std::string TaskAssignment_SecureAggregationInfo::GetTypeName() const {
2042 return "google.internal.federatedcompute.v1.TaskAssignment.SecureAggregationInfo";
2043 }
2044
2045
2046 // ===================================================================
2047
2048 class TaskAssignment::_Internal {
2049 public:
2050 static const ::google::internal::federatedcompute::v1::ForwardingInfo& aggregation_data_forwarding_info(const TaskAssignment* msg);
2051 static const ::google::internal::federatedcompute::v1::TaskAssignment_AggregationInfo& aggregation_info(const TaskAssignment* msg);
2052 static const ::google::internal::federatedcompute::v1::TaskAssignment_SecureAggregationInfo& secure_aggregation_info(const TaskAssignment* msg);
2053 static const ::google::internal::federatedcompute::v1::Resource& init_checkpoint(const TaskAssignment* msg);
2054 static const ::google::internal::federatedcompute::v1::Resource& plan(const TaskAssignment* msg);
2055 static const ::google::internal::federatedcompute::v1::FederatedSelectUriInfo& federated_select_uri_info(const TaskAssignment* msg);
2056 };
2057
2058 const ::google::internal::federatedcompute::v1::ForwardingInfo&
aggregation_data_forwarding_info(const TaskAssignment * msg)2059 TaskAssignment::_Internal::aggregation_data_forwarding_info(const TaskAssignment* msg) {
2060 return *msg->_impl_.aggregation_data_forwarding_info_;
2061 }
2062 const ::google::internal::federatedcompute::v1::TaskAssignment_AggregationInfo&
aggregation_info(const TaskAssignment * msg)2063 TaskAssignment::_Internal::aggregation_info(const TaskAssignment* msg) {
2064 return *msg->_impl_.aggregation_type_.aggregation_info_;
2065 }
2066 const ::google::internal::federatedcompute::v1::TaskAssignment_SecureAggregationInfo&
secure_aggregation_info(const TaskAssignment * msg)2067 TaskAssignment::_Internal::secure_aggregation_info(const TaskAssignment* msg) {
2068 return *msg->_impl_.aggregation_type_.secure_aggregation_info_;
2069 }
2070 const ::google::internal::federatedcompute::v1::Resource&
init_checkpoint(const TaskAssignment * msg)2071 TaskAssignment::_Internal::init_checkpoint(const TaskAssignment* msg) {
2072 return *msg->_impl_.init_checkpoint_;
2073 }
2074 const ::google::internal::federatedcompute::v1::Resource&
plan(const TaskAssignment * msg)2075 TaskAssignment::_Internal::plan(const TaskAssignment* msg) {
2076 return *msg->_impl_.plan_;
2077 }
2078 const ::google::internal::federatedcompute::v1::FederatedSelectUriInfo&
federated_select_uri_info(const TaskAssignment * msg)2079 TaskAssignment::_Internal::federated_select_uri_info(const TaskAssignment* msg) {
2080 return *msg->_impl_.federated_select_uri_info_;
2081 }
clear_aggregation_data_forwarding_info()2082 void TaskAssignment::clear_aggregation_data_forwarding_info() {
2083 if (GetArenaForAllocation() == nullptr && _impl_.aggregation_data_forwarding_info_ != nullptr) {
2084 delete _impl_.aggregation_data_forwarding_info_;
2085 }
2086 _impl_.aggregation_data_forwarding_info_ = nullptr;
2087 }
set_allocated_aggregation_info(::google::internal::federatedcompute::v1::TaskAssignment_AggregationInfo * aggregation_info)2088 void TaskAssignment::set_allocated_aggregation_info(::google::internal::federatedcompute::v1::TaskAssignment_AggregationInfo* aggregation_info) {
2089 ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
2090 clear_aggregation_type();
2091 if (aggregation_info) {
2092 ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
2093 ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(aggregation_info);
2094 if (message_arena != submessage_arena) {
2095 aggregation_info = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
2096 message_arena, aggregation_info, submessage_arena);
2097 }
2098 set_has_aggregation_info();
2099 _impl_.aggregation_type_.aggregation_info_ = aggregation_info;
2100 }
2101 // @@protoc_insertion_point(field_set_allocated:google.internal.federatedcompute.v1.TaskAssignment.aggregation_info)
2102 }
set_allocated_secure_aggregation_info(::google::internal::federatedcompute::v1::TaskAssignment_SecureAggregationInfo * secure_aggregation_info)2103 void TaskAssignment::set_allocated_secure_aggregation_info(::google::internal::federatedcompute::v1::TaskAssignment_SecureAggregationInfo* secure_aggregation_info) {
2104 ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
2105 clear_aggregation_type();
2106 if (secure_aggregation_info) {
2107 ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
2108 ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(secure_aggregation_info);
2109 if (message_arena != submessage_arena) {
2110 secure_aggregation_info = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
2111 message_arena, secure_aggregation_info, submessage_arena);
2112 }
2113 set_has_secure_aggregation_info();
2114 _impl_.aggregation_type_.secure_aggregation_info_ = secure_aggregation_info;
2115 }
2116 // @@protoc_insertion_point(field_set_allocated:google.internal.federatedcompute.v1.TaskAssignment.secure_aggregation_info)
2117 }
clear_init_checkpoint()2118 void TaskAssignment::clear_init_checkpoint() {
2119 if (GetArenaForAllocation() == nullptr && _impl_.init_checkpoint_ != nullptr) {
2120 delete _impl_.init_checkpoint_;
2121 }
2122 _impl_.init_checkpoint_ = nullptr;
2123 }
clear_plan()2124 void TaskAssignment::clear_plan() {
2125 if (GetArenaForAllocation() == nullptr && _impl_.plan_ != nullptr) {
2126 delete _impl_.plan_;
2127 }
2128 _impl_.plan_ = nullptr;
2129 }
TaskAssignment(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)2130 TaskAssignment::TaskAssignment(::PROTOBUF_NAMESPACE_ID::Arena* arena,
2131 bool is_message_owned)
2132 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
2133 SharedCtor(arena, is_message_owned);
2134 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.TaskAssignment)
2135 }
TaskAssignment(const TaskAssignment & from)2136 TaskAssignment::TaskAssignment(const TaskAssignment& from)
2137 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
2138 TaskAssignment* const _this = this; (void)_this;
2139 new (&_impl_) Impl_{
2140 decltype(_impl_.aggregation_id_){}
2141 , decltype(_impl_.session_id_){}
2142 , decltype(_impl_.authorization_token_){}
2143 , decltype(_impl_.task_name_){}
2144 , decltype(_impl_.aggregation_data_forwarding_info_){nullptr}
2145 , decltype(_impl_.init_checkpoint_){nullptr}
2146 , decltype(_impl_.plan_){nullptr}
2147 , decltype(_impl_.federated_select_uri_info_){nullptr}
2148 , decltype(_impl_.aggregation_type_){}
2149 , /*decltype(_impl_._cached_size_)*/{}
2150 , /*decltype(_impl_._oneof_case_)*/{}};
2151
2152 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
2153 _impl_.aggregation_id_.InitDefault();
2154 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2155 _impl_.aggregation_id_.Set("", GetArenaForAllocation());
2156 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2157 if (!from._internal_aggregation_id().empty()) {
2158 _this->_impl_.aggregation_id_.Set(from._internal_aggregation_id(),
2159 _this->GetArenaForAllocation());
2160 }
2161 _impl_.session_id_.InitDefault();
2162 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2163 _impl_.session_id_.Set("", GetArenaForAllocation());
2164 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2165 if (!from._internal_session_id().empty()) {
2166 _this->_impl_.session_id_.Set(from._internal_session_id(),
2167 _this->GetArenaForAllocation());
2168 }
2169 _impl_.authorization_token_.InitDefault();
2170 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2171 _impl_.authorization_token_.Set("", GetArenaForAllocation());
2172 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2173 if (!from._internal_authorization_token().empty()) {
2174 _this->_impl_.authorization_token_.Set(from._internal_authorization_token(),
2175 _this->GetArenaForAllocation());
2176 }
2177 _impl_.task_name_.InitDefault();
2178 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2179 _impl_.task_name_.Set("", GetArenaForAllocation());
2180 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2181 if (!from._internal_task_name().empty()) {
2182 _this->_impl_.task_name_.Set(from._internal_task_name(),
2183 _this->GetArenaForAllocation());
2184 }
2185 if (from._internal_has_aggregation_data_forwarding_info()) {
2186 _this->_impl_.aggregation_data_forwarding_info_ = new ::google::internal::federatedcompute::v1::ForwardingInfo(*from._impl_.aggregation_data_forwarding_info_);
2187 }
2188 if (from._internal_has_init_checkpoint()) {
2189 _this->_impl_.init_checkpoint_ = new ::google::internal::federatedcompute::v1::Resource(*from._impl_.init_checkpoint_);
2190 }
2191 if (from._internal_has_plan()) {
2192 _this->_impl_.plan_ = new ::google::internal::federatedcompute::v1::Resource(*from._impl_.plan_);
2193 }
2194 if (from._internal_has_federated_select_uri_info()) {
2195 _this->_impl_.federated_select_uri_info_ = new ::google::internal::federatedcompute::v1::FederatedSelectUriInfo(*from._impl_.federated_select_uri_info_);
2196 }
2197 clear_has_aggregation_type();
2198 switch (from.aggregation_type_case()) {
2199 case kAggregationInfo: {
2200 _this->_internal_mutable_aggregation_info()->::google::internal::federatedcompute::v1::TaskAssignment_AggregationInfo::MergeFrom(
2201 from._internal_aggregation_info());
2202 break;
2203 }
2204 case kSecureAggregationInfo: {
2205 _this->_internal_mutable_secure_aggregation_info()->::google::internal::federatedcompute::v1::TaskAssignment_SecureAggregationInfo::MergeFrom(
2206 from._internal_secure_aggregation_info());
2207 break;
2208 }
2209 case AGGREGATION_TYPE_NOT_SET: {
2210 break;
2211 }
2212 }
2213 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.TaskAssignment)
2214 }
2215
SharedCtor(::_pb::Arena * arena,bool is_message_owned)2216 inline void TaskAssignment::SharedCtor(
2217 ::_pb::Arena* arena, bool is_message_owned) {
2218 (void)arena;
2219 (void)is_message_owned;
2220 new (&_impl_) Impl_{
2221 decltype(_impl_.aggregation_id_){}
2222 , decltype(_impl_.session_id_){}
2223 , decltype(_impl_.authorization_token_){}
2224 , decltype(_impl_.task_name_){}
2225 , decltype(_impl_.aggregation_data_forwarding_info_){nullptr}
2226 , decltype(_impl_.init_checkpoint_){nullptr}
2227 , decltype(_impl_.plan_){nullptr}
2228 , decltype(_impl_.federated_select_uri_info_){nullptr}
2229 , decltype(_impl_.aggregation_type_){}
2230 , /*decltype(_impl_._cached_size_)*/{}
2231 , /*decltype(_impl_._oneof_case_)*/{}
2232 };
2233 _impl_.aggregation_id_.InitDefault();
2234 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2235 _impl_.aggregation_id_.Set("", GetArenaForAllocation());
2236 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2237 _impl_.session_id_.InitDefault();
2238 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2239 _impl_.session_id_.Set("", GetArenaForAllocation());
2240 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2241 _impl_.authorization_token_.InitDefault();
2242 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2243 _impl_.authorization_token_.Set("", GetArenaForAllocation());
2244 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2245 _impl_.task_name_.InitDefault();
2246 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2247 _impl_.task_name_.Set("", GetArenaForAllocation());
2248 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2249 clear_has_aggregation_type();
2250 }
2251
~TaskAssignment()2252 TaskAssignment::~TaskAssignment() {
2253 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.TaskAssignment)
2254 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
2255 (void)arena;
2256 return;
2257 }
2258 SharedDtor();
2259 }
2260
SharedDtor()2261 inline void TaskAssignment::SharedDtor() {
2262 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
2263 _impl_.aggregation_id_.Destroy();
2264 _impl_.session_id_.Destroy();
2265 _impl_.authorization_token_.Destroy();
2266 _impl_.task_name_.Destroy();
2267 if (this != internal_default_instance()) delete _impl_.aggregation_data_forwarding_info_;
2268 if (this != internal_default_instance()) delete _impl_.init_checkpoint_;
2269 if (this != internal_default_instance()) delete _impl_.plan_;
2270 if (this != internal_default_instance()) delete _impl_.federated_select_uri_info_;
2271 if (has_aggregation_type()) {
2272 clear_aggregation_type();
2273 }
2274 }
2275
SetCachedSize(int size) const2276 void TaskAssignment::SetCachedSize(int size) const {
2277 _impl_._cached_size_.Set(size);
2278 }
2279
clear_aggregation_type()2280 void TaskAssignment::clear_aggregation_type() {
2281 // @@protoc_insertion_point(one_of_clear_start:google.internal.federatedcompute.v1.TaskAssignment)
2282 switch (aggregation_type_case()) {
2283 case kAggregationInfo: {
2284 if (GetArenaForAllocation() == nullptr) {
2285 delete _impl_.aggregation_type_.aggregation_info_;
2286 }
2287 break;
2288 }
2289 case kSecureAggregationInfo: {
2290 if (GetArenaForAllocation() == nullptr) {
2291 delete _impl_.aggregation_type_.secure_aggregation_info_;
2292 }
2293 break;
2294 }
2295 case AGGREGATION_TYPE_NOT_SET: {
2296 break;
2297 }
2298 }
2299 _impl_._oneof_case_[0] = AGGREGATION_TYPE_NOT_SET;
2300 }
2301
2302
Clear()2303 void TaskAssignment::Clear() {
2304 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.TaskAssignment)
2305 ::uint32_t cached_has_bits = 0;
2306 // Prevent compiler warnings about cached_has_bits being unused
2307 (void) cached_has_bits;
2308
2309 _impl_.aggregation_id_.ClearToEmpty();
2310 _impl_.session_id_.ClearToEmpty();
2311 _impl_.authorization_token_.ClearToEmpty();
2312 _impl_.task_name_.ClearToEmpty();
2313 if (GetArenaForAllocation() == nullptr && _impl_.aggregation_data_forwarding_info_ != nullptr) {
2314 delete _impl_.aggregation_data_forwarding_info_;
2315 }
2316 _impl_.aggregation_data_forwarding_info_ = nullptr;
2317 if (GetArenaForAllocation() == nullptr && _impl_.init_checkpoint_ != nullptr) {
2318 delete _impl_.init_checkpoint_;
2319 }
2320 _impl_.init_checkpoint_ = nullptr;
2321 if (GetArenaForAllocation() == nullptr && _impl_.plan_ != nullptr) {
2322 delete _impl_.plan_;
2323 }
2324 _impl_.plan_ = nullptr;
2325 if (GetArenaForAllocation() == nullptr && _impl_.federated_select_uri_info_ != nullptr) {
2326 delete _impl_.federated_select_uri_info_;
2327 }
2328 _impl_.federated_select_uri_info_ = nullptr;
2329 clear_aggregation_type();
2330 _internal_metadata_.Clear<std::string>();
2331 }
2332
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)2333 const char* TaskAssignment::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
2334 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
2335 while (!ctx->Done(&ptr)) {
2336 ::uint32_t tag;
2337 ptr = ::_pbi::ReadTag(ptr, &tag);
2338 switch (tag >> 3) {
2339 // .google.internal.federatedcompute.v1.ForwardingInfo aggregation_data_forwarding_info = 1;
2340 case 1:
2341 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) {
2342 ptr = ctx->ParseMessage(_internal_mutable_aggregation_data_forwarding_info(), ptr);
2343 CHK_(ptr);
2344 } else {
2345 goto handle_unusual;
2346 }
2347 continue;
2348 // string aggregation_id = 2;
2349 case 2:
2350 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 18)) {
2351 auto str = _internal_mutable_aggregation_id();
2352 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
2353 CHK_(ptr);
2354 CHK_(::_pbi::VerifyUTF8(str, nullptr));
2355 } else {
2356 goto handle_unusual;
2357 }
2358 continue;
2359 // .google.internal.federatedcompute.v1.Resource init_checkpoint = 3;
2360 case 3:
2361 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 26)) {
2362 ptr = ctx->ParseMessage(_internal_mutable_init_checkpoint(), ptr);
2363 CHK_(ptr);
2364 } else {
2365 goto handle_unusual;
2366 }
2367 continue;
2368 // .google.internal.federatedcompute.v1.Resource plan = 4;
2369 case 4:
2370 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 34)) {
2371 ptr = ctx->ParseMessage(_internal_mutable_plan(), ptr);
2372 CHK_(ptr);
2373 } else {
2374 goto handle_unusual;
2375 }
2376 continue;
2377 // string session_id = 5;
2378 case 5:
2379 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 42)) {
2380 auto str = _internal_mutable_session_id();
2381 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
2382 CHK_(ptr);
2383 CHK_(::_pbi::VerifyUTF8(str, nullptr));
2384 } else {
2385 goto handle_unusual;
2386 }
2387 continue;
2388 // string authorization_token = 6;
2389 case 6:
2390 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 50)) {
2391 auto str = _internal_mutable_authorization_token();
2392 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
2393 CHK_(ptr);
2394 CHK_(::_pbi::VerifyUTF8(str, nullptr));
2395 } else {
2396 goto handle_unusual;
2397 }
2398 continue;
2399 // string task_name = 7;
2400 case 7:
2401 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 58)) {
2402 auto str = _internal_mutable_task_name();
2403 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
2404 CHK_(ptr);
2405 CHK_(::_pbi::VerifyUTF8(str, nullptr));
2406 } else {
2407 goto handle_unusual;
2408 }
2409 continue;
2410 // .google.internal.federatedcompute.v1.FederatedSelectUriInfo federated_select_uri_info = 8;
2411 case 8:
2412 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 66)) {
2413 ptr = ctx->ParseMessage(_internal_mutable_federated_select_uri_info(), ptr);
2414 CHK_(ptr);
2415 } else {
2416 goto handle_unusual;
2417 }
2418 continue;
2419 // .google.internal.federatedcompute.v1.TaskAssignment.AggregationInfo aggregation_info = 9;
2420 case 9:
2421 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 74)) {
2422 ptr = ctx->ParseMessage(_internal_mutable_aggregation_info(), ptr);
2423 CHK_(ptr);
2424 } else {
2425 goto handle_unusual;
2426 }
2427 continue;
2428 // .google.internal.federatedcompute.v1.TaskAssignment.SecureAggregationInfo secure_aggregation_info = 10;
2429 case 10:
2430 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 82)) {
2431 ptr = ctx->ParseMessage(_internal_mutable_secure_aggregation_info(), ptr);
2432 CHK_(ptr);
2433 } else {
2434 goto handle_unusual;
2435 }
2436 continue;
2437 default:
2438 goto handle_unusual;
2439 } // switch
2440 handle_unusual:
2441 if ((tag == 0) || ((tag & 7) == 4)) {
2442 CHK_(ptr);
2443 ctx->SetLastTag(tag);
2444 goto message_done;
2445 }
2446 ptr = UnknownFieldParse(
2447 tag,
2448 _internal_metadata_.mutable_unknown_fields<std::string>(),
2449 ptr, ctx);
2450 CHK_(ptr != nullptr);
2451 } // while
2452 message_done:
2453 return ptr;
2454 failure:
2455 ptr = nullptr;
2456 goto message_done;
2457 #undef CHK_
2458 }
2459
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const2460 ::uint8_t* TaskAssignment::_InternalSerialize(
2461 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
2462 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.TaskAssignment)
2463 ::uint32_t cached_has_bits = 0;
2464 (void) cached_has_bits;
2465
2466 // .google.internal.federatedcompute.v1.ForwardingInfo aggregation_data_forwarding_info = 1;
2467 if (this->_internal_has_aggregation_data_forwarding_info()) {
2468 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
2469 InternalWriteMessage(1, _Internal::aggregation_data_forwarding_info(this),
2470 _Internal::aggregation_data_forwarding_info(this).GetCachedSize(), target, stream);
2471 }
2472
2473 // string aggregation_id = 2;
2474 if (!this->_internal_aggregation_id().empty()) {
2475 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
2476 this->_internal_aggregation_id().data(), static_cast<int>(this->_internal_aggregation_id().length()),
2477 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
2478 "google.internal.federatedcompute.v1.TaskAssignment.aggregation_id");
2479 target = stream->WriteStringMaybeAliased(
2480 2, this->_internal_aggregation_id(), target);
2481 }
2482
2483 // .google.internal.federatedcompute.v1.Resource init_checkpoint = 3;
2484 if (this->_internal_has_init_checkpoint()) {
2485 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
2486 InternalWriteMessage(3, _Internal::init_checkpoint(this),
2487 _Internal::init_checkpoint(this).GetCachedSize(), target, stream);
2488 }
2489
2490 // .google.internal.federatedcompute.v1.Resource plan = 4;
2491 if (this->_internal_has_plan()) {
2492 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
2493 InternalWriteMessage(4, _Internal::plan(this),
2494 _Internal::plan(this).GetCachedSize(), target, stream);
2495 }
2496
2497 // string session_id = 5;
2498 if (!this->_internal_session_id().empty()) {
2499 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
2500 this->_internal_session_id().data(), static_cast<int>(this->_internal_session_id().length()),
2501 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
2502 "google.internal.federatedcompute.v1.TaskAssignment.session_id");
2503 target = stream->WriteStringMaybeAliased(
2504 5, this->_internal_session_id(), target);
2505 }
2506
2507 // string authorization_token = 6;
2508 if (!this->_internal_authorization_token().empty()) {
2509 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
2510 this->_internal_authorization_token().data(), static_cast<int>(this->_internal_authorization_token().length()),
2511 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
2512 "google.internal.federatedcompute.v1.TaskAssignment.authorization_token");
2513 target = stream->WriteStringMaybeAliased(
2514 6, this->_internal_authorization_token(), target);
2515 }
2516
2517 // string task_name = 7;
2518 if (!this->_internal_task_name().empty()) {
2519 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
2520 this->_internal_task_name().data(), static_cast<int>(this->_internal_task_name().length()),
2521 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
2522 "google.internal.federatedcompute.v1.TaskAssignment.task_name");
2523 target = stream->WriteStringMaybeAliased(
2524 7, this->_internal_task_name(), target);
2525 }
2526
2527 // .google.internal.federatedcompute.v1.FederatedSelectUriInfo federated_select_uri_info = 8;
2528 if (this->_internal_has_federated_select_uri_info()) {
2529 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
2530 InternalWriteMessage(8, _Internal::federated_select_uri_info(this),
2531 _Internal::federated_select_uri_info(this).GetCachedSize(), target, stream);
2532 }
2533
2534 // .google.internal.federatedcompute.v1.TaskAssignment.AggregationInfo aggregation_info = 9;
2535 if (_internal_has_aggregation_info()) {
2536 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
2537 InternalWriteMessage(9, _Internal::aggregation_info(this),
2538 _Internal::aggregation_info(this).GetCachedSize(), target, stream);
2539 }
2540
2541 // .google.internal.federatedcompute.v1.TaskAssignment.SecureAggregationInfo secure_aggregation_info = 10;
2542 if (_internal_has_secure_aggregation_info()) {
2543 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
2544 InternalWriteMessage(10, _Internal::secure_aggregation_info(this),
2545 _Internal::secure_aggregation_info(this).GetCachedSize(), target, stream);
2546 }
2547
2548 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
2549 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
2550 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
2551 }
2552 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.TaskAssignment)
2553 return target;
2554 }
2555
ByteSizeLong() const2556 size_t TaskAssignment::ByteSizeLong() const {
2557 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.TaskAssignment)
2558 size_t total_size = 0;
2559
2560 ::uint32_t cached_has_bits = 0;
2561 // Prevent compiler warnings about cached_has_bits being unused
2562 (void) cached_has_bits;
2563
2564 // string aggregation_id = 2;
2565 if (!this->_internal_aggregation_id().empty()) {
2566 total_size += 1 +
2567 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
2568 this->_internal_aggregation_id());
2569 }
2570
2571 // string session_id = 5;
2572 if (!this->_internal_session_id().empty()) {
2573 total_size += 1 +
2574 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
2575 this->_internal_session_id());
2576 }
2577
2578 // string authorization_token = 6;
2579 if (!this->_internal_authorization_token().empty()) {
2580 total_size += 1 +
2581 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
2582 this->_internal_authorization_token());
2583 }
2584
2585 // string task_name = 7;
2586 if (!this->_internal_task_name().empty()) {
2587 total_size += 1 +
2588 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
2589 this->_internal_task_name());
2590 }
2591
2592 // .google.internal.federatedcompute.v1.ForwardingInfo aggregation_data_forwarding_info = 1;
2593 if (this->_internal_has_aggregation_data_forwarding_info()) {
2594 total_size += 1 +
2595 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
2596 *_impl_.aggregation_data_forwarding_info_);
2597 }
2598
2599 // .google.internal.federatedcompute.v1.Resource init_checkpoint = 3;
2600 if (this->_internal_has_init_checkpoint()) {
2601 total_size += 1 +
2602 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
2603 *_impl_.init_checkpoint_);
2604 }
2605
2606 // .google.internal.federatedcompute.v1.Resource plan = 4;
2607 if (this->_internal_has_plan()) {
2608 total_size += 1 +
2609 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
2610 *_impl_.plan_);
2611 }
2612
2613 // .google.internal.federatedcompute.v1.FederatedSelectUriInfo federated_select_uri_info = 8;
2614 if (this->_internal_has_federated_select_uri_info()) {
2615 total_size += 1 +
2616 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
2617 *_impl_.federated_select_uri_info_);
2618 }
2619
2620 switch (aggregation_type_case()) {
2621 // .google.internal.federatedcompute.v1.TaskAssignment.AggregationInfo aggregation_info = 9;
2622 case kAggregationInfo: {
2623 total_size += 1 +
2624 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
2625 *_impl_.aggregation_type_.aggregation_info_);
2626 break;
2627 }
2628 // .google.internal.federatedcompute.v1.TaskAssignment.SecureAggregationInfo secure_aggregation_info = 10;
2629 case kSecureAggregationInfo: {
2630 total_size += 1 +
2631 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
2632 *_impl_.aggregation_type_.secure_aggregation_info_);
2633 break;
2634 }
2635 case AGGREGATION_TYPE_NOT_SET: {
2636 break;
2637 }
2638 }
2639 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
2640 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
2641 }
2642 int cached_size = ::_pbi::ToCachedSize(total_size);
2643 SetCachedSize(cached_size);
2644 return total_size;
2645 }
2646
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)2647 void TaskAssignment::CheckTypeAndMergeFrom(
2648 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
2649 MergeFrom(*::_pbi::DownCast<const TaskAssignment*>(
2650 &from));
2651 }
2652
MergeFrom(const TaskAssignment & from)2653 void TaskAssignment::MergeFrom(const TaskAssignment& from) {
2654 TaskAssignment* const _this = this;
2655 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.TaskAssignment)
2656 GOOGLE_DCHECK_NE(&from, _this);
2657 ::uint32_t cached_has_bits = 0;
2658 (void) cached_has_bits;
2659
2660 if (!from._internal_aggregation_id().empty()) {
2661 _this->_internal_set_aggregation_id(from._internal_aggregation_id());
2662 }
2663 if (!from._internal_session_id().empty()) {
2664 _this->_internal_set_session_id(from._internal_session_id());
2665 }
2666 if (!from._internal_authorization_token().empty()) {
2667 _this->_internal_set_authorization_token(from._internal_authorization_token());
2668 }
2669 if (!from._internal_task_name().empty()) {
2670 _this->_internal_set_task_name(from._internal_task_name());
2671 }
2672 if (from._internal_has_aggregation_data_forwarding_info()) {
2673 _this->_internal_mutable_aggregation_data_forwarding_info()->::google::internal::federatedcompute::v1::ForwardingInfo::MergeFrom(
2674 from._internal_aggregation_data_forwarding_info());
2675 }
2676 if (from._internal_has_init_checkpoint()) {
2677 _this->_internal_mutable_init_checkpoint()->::google::internal::federatedcompute::v1::Resource::MergeFrom(
2678 from._internal_init_checkpoint());
2679 }
2680 if (from._internal_has_plan()) {
2681 _this->_internal_mutable_plan()->::google::internal::federatedcompute::v1::Resource::MergeFrom(
2682 from._internal_plan());
2683 }
2684 if (from._internal_has_federated_select_uri_info()) {
2685 _this->_internal_mutable_federated_select_uri_info()->::google::internal::federatedcompute::v1::FederatedSelectUriInfo::MergeFrom(
2686 from._internal_federated_select_uri_info());
2687 }
2688 switch (from.aggregation_type_case()) {
2689 case kAggregationInfo: {
2690 _this->_internal_mutable_aggregation_info()->::google::internal::federatedcompute::v1::TaskAssignment_AggregationInfo::MergeFrom(
2691 from._internal_aggregation_info());
2692 break;
2693 }
2694 case kSecureAggregationInfo: {
2695 _this->_internal_mutable_secure_aggregation_info()->::google::internal::federatedcompute::v1::TaskAssignment_SecureAggregationInfo::MergeFrom(
2696 from._internal_secure_aggregation_info());
2697 break;
2698 }
2699 case AGGREGATION_TYPE_NOT_SET: {
2700 break;
2701 }
2702 }
2703 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
2704 }
2705
CopyFrom(const TaskAssignment & from)2706 void TaskAssignment::CopyFrom(const TaskAssignment& from) {
2707 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.TaskAssignment)
2708 if (&from == this) return;
2709 Clear();
2710 MergeFrom(from);
2711 }
2712
IsInitialized() const2713 bool TaskAssignment::IsInitialized() const {
2714 return true;
2715 }
2716
InternalSwap(TaskAssignment * other)2717 void TaskAssignment::InternalSwap(TaskAssignment* other) {
2718 using std::swap;
2719 auto* lhs_arena = GetArenaForAllocation();
2720 auto* rhs_arena = other->GetArenaForAllocation();
2721 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
2722 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
2723 &_impl_.aggregation_id_, lhs_arena,
2724 &other->_impl_.aggregation_id_, rhs_arena
2725 );
2726 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
2727 &_impl_.session_id_, lhs_arena,
2728 &other->_impl_.session_id_, rhs_arena
2729 );
2730 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
2731 &_impl_.authorization_token_, lhs_arena,
2732 &other->_impl_.authorization_token_, rhs_arena
2733 );
2734 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
2735 &_impl_.task_name_, lhs_arena,
2736 &other->_impl_.task_name_, rhs_arena
2737 );
2738 ::PROTOBUF_NAMESPACE_ID::internal::memswap<
2739 PROTOBUF_FIELD_OFFSET(TaskAssignment, _impl_.federated_select_uri_info_)
2740 + sizeof(TaskAssignment::_impl_.federated_select_uri_info_) // NOLINT
2741 - PROTOBUF_FIELD_OFFSET(TaskAssignment, _impl_.aggregation_data_forwarding_info_)>(
2742 reinterpret_cast<char*>(&_impl_.aggregation_data_forwarding_info_),
2743 reinterpret_cast<char*>(&other->_impl_.aggregation_data_forwarding_info_));
2744 swap(_impl_.aggregation_type_, other->_impl_.aggregation_type_);
2745 swap(_impl_._oneof_case_[0], other->_impl_._oneof_case_[0]);
2746 }
2747
GetTypeName() const2748 std::string TaskAssignment::GetTypeName() const {
2749 return "google.internal.federatedcompute.v1.TaskAssignment";
2750 }
2751
2752
2753 // ===================================================================
2754
2755 class FederatedSelectUriInfo::_Internal {
2756 public:
2757 };
2758
FederatedSelectUriInfo(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)2759 FederatedSelectUriInfo::FederatedSelectUriInfo(::PROTOBUF_NAMESPACE_ID::Arena* arena,
2760 bool is_message_owned)
2761 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
2762 SharedCtor(arena, is_message_owned);
2763 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.FederatedSelectUriInfo)
2764 }
FederatedSelectUriInfo(const FederatedSelectUriInfo & from)2765 FederatedSelectUriInfo::FederatedSelectUriInfo(const FederatedSelectUriInfo& from)
2766 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
2767 FederatedSelectUriInfo* const _this = this; (void)_this;
2768 new (&_impl_) Impl_{
2769 decltype(_impl_.uri_template_){}
2770 , /*decltype(_impl_._cached_size_)*/{}};
2771
2772 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
2773 _impl_.uri_template_.InitDefault();
2774 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2775 _impl_.uri_template_.Set("", GetArenaForAllocation());
2776 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2777 if (!from._internal_uri_template().empty()) {
2778 _this->_impl_.uri_template_.Set(from._internal_uri_template(),
2779 _this->GetArenaForAllocation());
2780 }
2781 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.FederatedSelectUriInfo)
2782 }
2783
SharedCtor(::_pb::Arena * arena,bool is_message_owned)2784 inline void FederatedSelectUriInfo::SharedCtor(
2785 ::_pb::Arena* arena, bool is_message_owned) {
2786 (void)arena;
2787 (void)is_message_owned;
2788 new (&_impl_) Impl_{
2789 decltype(_impl_.uri_template_){}
2790 , /*decltype(_impl_._cached_size_)*/{}
2791 };
2792 _impl_.uri_template_.InitDefault();
2793 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2794 _impl_.uri_template_.Set("", GetArenaForAllocation());
2795 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2796 }
2797
~FederatedSelectUriInfo()2798 FederatedSelectUriInfo::~FederatedSelectUriInfo() {
2799 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.FederatedSelectUriInfo)
2800 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
2801 (void)arena;
2802 return;
2803 }
2804 SharedDtor();
2805 }
2806
SharedDtor()2807 inline void FederatedSelectUriInfo::SharedDtor() {
2808 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
2809 _impl_.uri_template_.Destroy();
2810 }
2811
SetCachedSize(int size) const2812 void FederatedSelectUriInfo::SetCachedSize(int size) const {
2813 _impl_._cached_size_.Set(size);
2814 }
2815
Clear()2816 void FederatedSelectUriInfo::Clear() {
2817 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.FederatedSelectUriInfo)
2818 ::uint32_t cached_has_bits = 0;
2819 // Prevent compiler warnings about cached_has_bits being unused
2820 (void) cached_has_bits;
2821
2822 _impl_.uri_template_.ClearToEmpty();
2823 _internal_metadata_.Clear<std::string>();
2824 }
2825
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)2826 const char* FederatedSelectUriInfo::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
2827 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
2828 while (!ctx->Done(&ptr)) {
2829 ::uint32_t tag;
2830 ptr = ::_pbi::ReadTag(ptr, &tag);
2831 switch (tag >> 3) {
2832 // string uri_template = 1;
2833 case 1:
2834 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) {
2835 auto str = _internal_mutable_uri_template();
2836 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
2837 CHK_(ptr);
2838 CHK_(::_pbi::VerifyUTF8(str, nullptr));
2839 } else {
2840 goto handle_unusual;
2841 }
2842 continue;
2843 default:
2844 goto handle_unusual;
2845 } // switch
2846 handle_unusual:
2847 if ((tag == 0) || ((tag & 7) == 4)) {
2848 CHK_(ptr);
2849 ctx->SetLastTag(tag);
2850 goto message_done;
2851 }
2852 ptr = UnknownFieldParse(
2853 tag,
2854 _internal_metadata_.mutable_unknown_fields<std::string>(),
2855 ptr, ctx);
2856 CHK_(ptr != nullptr);
2857 } // while
2858 message_done:
2859 return ptr;
2860 failure:
2861 ptr = nullptr;
2862 goto message_done;
2863 #undef CHK_
2864 }
2865
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const2866 ::uint8_t* FederatedSelectUriInfo::_InternalSerialize(
2867 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
2868 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.FederatedSelectUriInfo)
2869 ::uint32_t cached_has_bits = 0;
2870 (void) cached_has_bits;
2871
2872 // string uri_template = 1;
2873 if (!this->_internal_uri_template().empty()) {
2874 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
2875 this->_internal_uri_template().data(), static_cast<int>(this->_internal_uri_template().length()),
2876 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
2877 "google.internal.federatedcompute.v1.FederatedSelectUriInfo.uri_template");
2878 target = stream->WriteStringMaybeAliased(
2879 1, this->_internal_uri_template(), target);
2880 }
2881
2882 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
2883 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
2884 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
2885 }
2886 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.FederatedSelectUriInfo)
2887 return target;
2888 }
2889
ByteSizeLong() const2890 size_t FederatedSelectUriInfo::ByteSizeLong() const {
2891 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.FederatedSelectUriInfo)
2892 size_t total_size = 0;
2893
2894 ::uint32_t cached_has_bits = 0;
2895 // Prevent compiler warnings about cached_has_bits being unused
2896 (void) cached_has_bits;
2897
2898 // string uri_template = 1;
2899 if (!this->_internal_uri_template().empty()) {
2900 total_size += 1 +
2901 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
2902 this->_internal_uri_template());
2903 }
2904
2905 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
2906 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
2907 }
2908 int cached_size = ::_pbi::ToCachedSize(total_size);
2909 SetCachedSize(cached_size);
2910 return total_size;
2911 }
2912
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)2913 void FederatedSelectUriInfo::CheckTypeAndMergeFrom(
2914 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
2915 MergeFrom(*::_pbi::DownCast<const FederatedSelectUriInfo*>(
2916 &from));
2917 }
2918
MergeFrom(const FederatedSelectUriInfo & from)2919 void FederatedSelectUriInfo::MergeFrom(const FederatedSelectUriInfo& from) {
2920 FederatedSelectUriInfo* const _this = this;
2921 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.FederatedSelectUriInfo)
2922 GOOGLE_DCHECK_NE(&from, _this);
2923 ::uint32_t cached_has_bits = 0;
2924 (void) cached_has_bits;
2925
2926 if (!from._internal_uri_template().empty()) {
2927 _this->_internal_set_uri_template(from._internal_uri_template());
2928 }
2929 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
2930 }
2931
CopyFrom(const FederatedSelectUriInfo & from)2932 void FederatedSelectUriInfo::CopyFrom(const FederatedSelectUriInfo& from) {
2933 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.FederatedSelectUriInfo)
2934 if (&from == this) return;
2935 Clear();
2936 MergeFrom(from);
2937 }
2938
IsInitialized() const2939 bool FederatedSelectUriInfo::IsInitialized() const {
2940 return true;
2941 }
2942
InternalSwap(FederatedSelectUriInfo * other)2943 void FederatedSelectUriInfo::InternalSwap(FederatedSelectUriInfo* other) {
2944 using std::swap;
2945 auto* lhs_arena = GetArenaForAllocation();
2946 auto* rhs_arena = other->GetArenaForAllocation();
2947 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
2948 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
2949 &_impl_.uri_template_, lhs_arena,
2950 &other->_impl_.uri_template_, rhs_arena
2951 );
2952 }
2953
GetTypeName() const2954 std::string FederatedSelectUriInfo::GetTypeName() const {
2955 return "google.internal.federatedcompute.v1.FederatedSelectUriInfo";
2956 }
2957
2958
2959 // ===================================================================
2960
2961 class ReportTaskResultRequest::_Internal {
2962 public:
2963 static const ::google::internal::federatedcompute::v1::ClientStats& client_stats(const ReportTaskResultRequest* msg);
2964 };
2965
2966 const ::google::internal::federatedcompute::v1::ClientStats&
client_stats(const ReportTaskResultRequest * msg)2967 ReportTaskResultRequest::_Internal::client_stats(const ReportTaskResultRequest* msg) {
2968 return *msg->_impl_.client_stats_;
2969 }
ReportTaskResultRequest(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)2970 ReportTaskResultRequest::ReportTaskResultRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
2971 bool is_message_owned)
2972 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
2973 SharedCtor(arena, is_message_owned);
2974 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.ReportTaskResultRequest)
2975 }
ReportTaskResultRequest(const ReportTaskResultRequest & from)2976 ReportTaskResultRequest::ReportTaskResultRequest(const ReportTaskResultRequest& from)
2977 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
2978 ReportTaskResultRequest* const _this = this; (void)_this;
2979 new (&_impl_) Impl_{
2980 decltype(_impl_.population_name_){}
2981 , decltype(_impl_.session_id_){}
2982 , decltype(_impl_.aggregation_id_){}
2983 , decltype(_impl_.task_name_){}
2984 , decltype(_impl_.client_stats_){nullptr}
2985 , decltype(_impl_.computation_status_code_){}
2986 , /*decltype(_impl_._cached_size_)*/{}};
2987
2988 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
2989 _impl_.population_name_.InitDefault();
2990 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2991 _impl_.population_name_.Set("", GetArenaForAllocation());
2992 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2993 if (!from._internal_population_name().empty()) {
2994 _this->_impl_.population_name_.Set(from._internal_population_name(),
2995 _this->GetArenaForAllocation());
2996 }
2997 _impl_.session_id_.InitDefault();
2998 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2999 _impl_.session_id_.Set("", GetArenaForAllocation());
3000 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
3001 if (!from._internal_session_id().empty()) {
3002 _this->_impl_.session_id_.Set(from._internal_session_id(),
3003 _this->GetArenaForAllocation());
3004 }
3005 _impl_.aggregation_id_.InitDefault();
3006 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
3007 _impl_.aggregation_id_.Set("", GetArenaForAllocation());
3008 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
3009 if (!from._internal_aggregation_id().empty()) {
3010 _this->_impl_.aggregation_id_.Set(from._internal_aggregation_id(),
3011 _this->GetArenaForAllocation());
3012 }
3013 _impl_.task_name_.InitDefault();
3014 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
3015 _impl_.task_name_.Set("", GetArenaForAllocation());
3016 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
3017 if (!from._internal_task_name().empty()) {
3018 _this->_impl_.task_name_.Set(from._internal_task_name(),
3019 _this->GetArenaForAllocation());
3020 }
3021 if (from._internal_has_client_stats()) {
3022 _this->_impl_.client_stats_ = new ::google::internal::federatedcompute::v1::ClientStats(*from._impl_.client_stats_);
3023 }
3024 _this->_impl_.computation_status_code_ = from._impl_.computation_status_code_;
3025 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.ReportTaskResultRequest)
3026 }
3027
SharedCtor(::_pb::Arena * arena,bool is_message_owned)3028 inline void ReportTaskResultRequest::SharedCtor(
3029 ::_pb::Arena* arena, bool is_message_owned) {
3030 (void)arena;
3031 (void)is_message_owned;
3032 new (&_impl_) Impl_{
3033 decltype(_impl_.population_name_){}
3034 , decltype(_impl_.session_id_){}
3035 , decltype(_impl_.aggregation_id_){}
3036 , decltype(_impl_.task_name_){}
3037 , decltype(_impl_.client_stats_){nullptr}
3038 , decltype(_impl_.computation_status_code_){0}
3039 , /*decltype(_impl_._cached_size_)*/{}
3040 };
3041 _impl_.population_name_.InitDefault();
3042 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
3043 _impl_.population_name_.Set("", GetArenaForAllocation());
3044 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
3045 _impl_.session_id_.InitDefault();
3046 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
3047 _impl_.session_id_.Set("", GetArenaForAllocation());
3048 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
3049 _impl_.aggregation_id_.InitDefault();
3050 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
3051 _impl_.aggregation_id_.Set("", GetArenaForAllocation());
3052 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
3053 _impl_.task_name_.InitDefault();
3054 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
3055 _impl_.task_name_.Set("", GetArenaForAllocation());
3056 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
3057 }
3058
~ReportTaskResultRequest()3059 ReportTaskResultRequest::~ReportTaskResultRequest() {
3060 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.ReportTaskResultRequest)
3061 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
3062 (void)arena;
3063 return;
3064 }
3065 SharedDtor();
3066 }
3067
SharedDtor()3068 inline void ReportTaskResultRequest::SharedDtor() {
3069 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
3070 _impl_.population_name_.Destroy();
3071 _impl_.session_id_.Destroy();
3072 _impl_.aggregation_id_.Destroy();
3073 _impl_.task_name_.Destroy();
3074 if (this != internal_default_instance()) delete _impl_.client_stats_;
3075 }
3076
SetCachedSize(int size) const3077 void ReportTaskResultRequest::SetCachedSize(int size) const {
3078 _impl_._cached_size_.Set(size);
3079 }
3080
Clear()3081 void ReportTaskResultRequest::Clear() {
3082 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.ReportTaskResultRequest)
3083 ::uint32_t cached_has_bits = 0;
3084 // Prevent compiler warnings about cached_has_bits being unused
3085 (void) cached_has_bits;
3086
3087 _impl_.population_name_.ClearToEmpty();
3088 _impl_.session_id_.ClearToEmpty();
3089 _impl_.aggregation_id_.ClearToEmpty();
3090 _impl_.task_name_.ClearToEmpty();
3091 if (GetArenaForAllocation() == nullptr && _impl_.client_stats_ != nullptr) {
3092 delete _impl_.client_stats_;
3093 }
3094 _impl_.client_stats_ = nullptr;
3095 _impl_.computation_status_code_ = 0;
3096 _internal_metadata_.Clear<std::string>();
3097 }
3098
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)3099 const char* ReportTaskResultRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
3100 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
3101 while (!ctx->Done(&ptr)) {
3102 ::uint32_t tag;
3103 ptr = ::_pbi::ReadTag(ptr, &tag);
3104 switch (tag >> 3) {
3105 // string population_name = 1;
3106 case 1:
3107 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) {
3108 auto str = _internal_mutable_population_name();
3109 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
3110 CHK_(ptr);
3111 CHK_(::_pbi::VerifyUTF8(str, nullptr));
3112 } else {
3113 goto handle_unusual;
3114 }
3115 continue;
3116 // string session_id = 2;
3117 case 2:
3118 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 18)) {
3119 auto str = _internal_mutable_session_id();
3120 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
3121 CHK_(ptr);
3122 CHK_(::_pbi::VerifyUTF8(str, nullptr));
3123 } else {
3124 goto handle_unusual;
3125 }
3126 continue;
3127 // int32 computation_status_code = 3;
3128 case 3:
3129 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 24)) {
3130 _impl_.computation_status_code_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint32(&ptr);
3131 CHK_(ptr);
3132 } else {
3133 goto handle_unusual;
3134 }
3135 continue;
3136 // .google.internal.federatedcompute.v1.ClientStats client_stats = 4;
3137 case 4:
3138 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 34)) {
3139 ptr = ctx->ParseMessage(_internal_mutable_client_stats(), ptr);
3140 CHK_(ptr);
3141 } else {
3142 goto handle_unusual;
3143 }
3144 continue;
3145 // string aggregation_id = 5;
3146 case 5:
3147 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 42)) {
3148 auto str = _internal_mutable_aggregation_id();
3149 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
3150 CHK_(ptr);
3151 CHK_(::_pbi::VerifyUTF8(str, nullptr));
3152 } else {
3153 goto handle_unusual;
3154 }
3155 continue;
3156 // string task_name = 6;
3157 case 6:
3158 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 50)) {
3159 auto str = _internal_mutable_task_name();
3160 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
3161 CHK_(ptr);
3162 CHK_(::_pbi::VerifyUTF8(str, nullptr));
3163 } else {
3164 goto handle_unusual;
3165 }
3166 continue;
3167 default:
3168 goto handle_unusual;
3169 } // switch
3170 handle_unusual:
3171 if ((tag == 0) || ((tag & 7) == 4)) {
3172 CHK_(ptr);
3173 ctx->SetLastTag(tag);
3174 goto message_done;
3175 }
3176 ptr = UnknownFieldParse(
3177 tag,
3178 _internal_metadata_.mutable_unknown_fields<std::string>(),
3179 ptr, ctx);
3180 CHK_(ptr != nullptr);
3181 } // while
3182 message_done:
3183 return ptr;
3184 failure:
3185 ptr = nullptr;
3186 goto message_done;
3187 #undef CHK_
3188 }
3189
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const3190 ::uint8_t* ReportTaskResultRequest::_InternalSerialize(
3191 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
3192 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.ReportTaskResultRequest)
3193 ::uint32_t cached_has_bits = 0;
3194 (void) cached_has_bits;
3195
3196 // string population_name = 1;
3197 if (!this->_internal_population_name().empty()) {
3198 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
3199 this->_internal_population_name().data(), static_cast<int>(this->_internal_population_name().length()),
3200 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
3201 "google.internal.federatedcompute.v1.ReportTaskResultRequest.population_name");
3202 target = stream->WriteStringMaybeAliased(
3203 1, this->_internal_population_name(), target);
3204 }
3205
3206 // string session_id = 2;
3207 if (!this->_internal_session_id().empty()) {
3208 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
3209 this->_internal_session_id().data(), static_cast<int>(this->_internal_session_id().length()),
3210 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
3211 "google.internal.federatedcompute.v1.ReportTaskResultRequest.session_id");
3212 target = stream->WriteStringMaybeAliased(
3213 2, this->_internal_session_id(), target);
3214 }
3215
3216 // int32 computation_status_code = 3;
3217 if (this->_internal_computation_status_code() != 0) {
3218 target = stream->EnsureSpace(target);
3219 target = ::_pbi::WireFormatLite::WriteInt32ToArray(3, this->_internal_computation_status_code(), target);
3220 }
3221
3222 // .google.internal.federatedcompute.v1.ClientStats client_stats = 4;
3223 if (this->_internal_has_client_stats()) {
3224 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
3225 InternalWriteMessage(4, _Internal::client_stats(this),
3226 _Internal::client_stats(this).GetCachedSize(), target, stream);
3227 }
3228
3229 // string aggregation_id = 5;
3230 if (!this->_internal_aggregation_id().empty()) {
3231 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
3232 this->_internal_aggregation_id().data(), static_cast<int>(this->_internal_aggregation_id().length()),
3233 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
3234 "google.internal.federatedcompute.v1.ReportTaskResultRequest.aggregation_id");
3235 target = stream->WriteStringMaybeAliased(
3236 5, this->_internal_aggregation_id(), target);
3237 }
3238
3239 // string task_name = 6;
3240 if (!this->_internal_task_name().empty()) {
3241 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
3242 this->_internal_task_name().data(), static_cast<int>(this->_internal_task_name().length()),
3243 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
3244 "google.internal.federatedcompute.v1.ReportTaskResultRequest.task_name");
3245 target = stream->WriteStringMaybeAliased(
3246 6, this->_internal_task_name(), target);
3247 }
3248
3249 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
3250 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
3251 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
3252 }
3253 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.ReportTaskResultRequest)
3254 return target;
3255 }
3256
ByteSizeLong() const3257 size_t ReportTaskResultRequest::ByteSizeLong() const {
3258 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.ReportTaskResultRequest)
3259 size_t total_size = 0;
3260
3261 ::uint32_t cached_has_bits = 0;
3262 // Prevent compiler warnings about cached_has_bits being unused
3263 (void) cached_has_bits;
3264
3265 // string population_name = 1;
3266 if (!this->_internal_population_name().empty()) {
3267 total_size += 1 +
3268 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
3269 this->_internal_population_name());
3270 }
3271
3272 // string session_id = 2;
3273 if (!this->_internal_session_id().empty()) {
3274 total_size += 1 +
3275 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
3276 this->_internal_session_id());
3277 }
3278
3279 // string aggregation_id = 5;
3280 if (!this->_internal_aggregation_id().empty()) {
3281 total_size += 1 +
3282 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
3283 this->_internal_aggregation_id());
3284 }
3285
3286 // string task_name = 6;
3287 if (!this->_internal_task_name().empty()) {
3288 total_size += 1 +
3289 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
3290 this->_internal_task_name());
3291 }
3292
3293 // .google.internal.federatedcompute.v1.ClientStats client_stats = 4;
3294 if (this->_internal_has_client_stats()) {
3295 total_size += 1 +
3296 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
3297 *_impl_.client_stats_);
3298 }
3299
3300 // int32 computation_status_code = 3;
3301 if (this->_internal_computation_status_code() != 0) {
3302 total_size += ::_pbi::WireFormatLite::Int32SizePlusOne(this->_internal_computation_status_code());
3303 }
3304
3305 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
3306 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
3307 }
3308 int cached_size = ::_pbi::ToCachedSize(total_size);
3309 SetCachedSize(cached_size);
3310 return total_size;
3311 }
3312
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)3313 void ReportTaskResultRequest::CheckTypeAndMergeFrom(
3314 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
3315 MergeFrom(*::_pbi::DownCast<const ReportTaskResultRequest*>(
3316 &from));
3317 }
3318
MergeFrom(const ReportTaskResultRequest & from)3319 void ReportTaskResultRequest::MergeFrom(const ReportTaskResultRequest& from) {
3320 ReportTaskResultRequest* const _this = this;
3321 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.ReportTaskResultRequest)
3322 GOOGLE_DCHECK_NE(&from, _this);
3323 ::uint32_t cached_has_bits = 0;
3324 (void) cached_has_bits;
3325
3326 if (!from._internal_population_name().empty()) {
3327 _this->_internal_set_population_name(from._internal_population_name());
3328 }
3329 if (!from._internal_session_id().empty()) {
3330 _this->_internal_set_session_id(from._internal_session_id());
3331 }
3332 if (!from._internal_aggregation_id().empty()) {
3333 _this->_internal_set_aggregation_id(from._internal_aggregation_id());
3334 }
3335 if (!from._internal_task_name().empty()) {
3336 _this->_internal_set_task_name(from._internal_task_name());
3337 }
3338 if (from._internal_has_client_stats()) {
3339 _this->_internal_mutable_client_stats()->::google::internal::federatedcompute::v1::ClientStats::MergeFrom(
3340 from._internal_client_stats());
3341 }
3342 if (from._internal_computation_status_code() != 0) {
3343 _this->_internal_set_computation_status_code(from._internal_computation_status_code());
3344 }
3345 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
3346 }
3347
CopyFrom(const ReportTaskResultRequest & from)3348 void ReportTaskResultRequest::CopyFrom(const ReportTaskResultRequest& from) {
3349 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.ReportTaskResultRequest)
3350 if (&from == this) return;
3351 Clear();
3352 MergeFrom(from);
3353 }
3354
IsInitialized() const3355 bool ReportTaskResultRequest::IsInitialized() const {
3356 return true;
3357 }
3358
InternalSwap(ReportTaskResultRequest * other)3359 void ReportTaskResultRequest::InternalSwap(ReportTaskResultRequest* other) {
3360 using std::swap;
3361 auto* lhs_arena = GetArenaForAllocation();
3362 auto* rhs_arena = other->GetArenaForAllocation();
3363 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
3364 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
3365 &_impl_.population_name_, lhs_arena,
3366 &other->_impl_.population_name_, rhs_arena
3367 );
3368 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
3369 &_impl_.session_id_, lhs_arena,
3370 &other->_impl_.session_id_, rhs_arena
3371 );
3372 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
3373 &_impl_.aggregation_id_, lhs_arena,
3374 &other->_impl_.aggregation_id_, rhs_arena
3375 );
3376 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
3377 &_impl_.task_name_, lhs_arena,
3378 &other->_impl_.task_name_, rhs_arena
3379 );
3380 ::PROTOBUF_NAMESPACE_ID::internal::memswap<
3381 PROTOBUF_FIELD_OFFSET(ReportTaskResultRequest, _impl_.computation_status_code_)
3382 + sizeof(ReportTaskResultRequest::_impl_.computation_status_code_) // NOLINT
3383 - PROTOBUF_FIELD_OFFSET(ReportTaskResultRequest, _impl_.client_stats_)>(
3384 reinterpret_cast<char*>(&_impl_.client_stats_),
3385 reinterpret_cast<char*>(&other->_impl_.client_stats_));
3386 }
3387
GetTypeName() const3388 std::string ReportTaskResultRequest::GetTypeName() const {
3389 return "google.internal.federatedcompute.v1.ReportTaskResultRequest";
3390 }
3391
3392
3393 // ===================================================================
3394
3395 class ClientStats::_Internal {
3396 public:
3397 static const ::PROTOBUF_NAMESPACE_ID::Duration& computation_execution_duration(const ClientStats* msg);
3398 };
3399
3400 const ::PROTOBUF_NAMESPACE_ID::Duration&
computation_execution_duration(const ClientStats * msg)3401 ClientStats::_Internal::computation_execution_duration(const ClientStats* msg) {
3402 return *msg->_impl_.computation_execution_duration_;
3403 }
clear_computation_execution_duration()3404 void ClientStats::clear_computation_execution_duration() {
3405 if (GetArenaForAllocation() == nullptr && _impl_.computation_execution_duration_ != nullptr) {
3406 delete _impl_.computation_execution_duration_;
3407 }
3408 _impl_.computation_execution_duration_ = nullptr;
3409 }
ClientStats(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)3410 ClientStats::ClientStats(::PROTOBUF_NAMESPACE_ID::Arena* arena,
3411 bool is_message_owned)
3412 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
3413 SharedCtor(arena, is_message_owned);
3414 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.ClientStats)
3415 }
ClientStats(const ClientStats & from)3416 ClientStats::ClientStats(const ClientStats& from)
3417 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
3418 ClientStats* const _this = this; (void)_this;
3419 new (&_impl_) Impl_{
3420 decltype(_impl_.computation_execution_duration_){nullptr}
3421 , /*decltype(_impl_._cached_size_)*/{}};
3422
3423 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
3424 if (from._internal_has_computation_execution_duration()) {
3425 _this->_impl_.computation_execution_duration_ = new ::PROTOBUF_NAMESPACE_ID::Duration(*from._impl_.computation_execution_duration_);
3426 }
3427 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.ClientStats)
3428 }
3429
SharedCtor(::_pb::Arena * arena,bool is_message_owned)3430 inline void ClientStats::SharedCtor(
3431 ::_pb::Arena* arena, bool is_message_owned) {
3432 (void)arena;
3433 (void)is_message_owned;
3434 new (&_impl_) Impl_{
3435 decltype(_impl_.computation_execution_duration_){nullptr}
3436 , /*decltype(_impl_._cached_size_)*/{}
3437 };
3438 }
3439
~ClientStats()3440 ClientStats::~ClientStats() {
3441 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.ClientStats)
3442 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
3443 (void)arena;
3444 return;
3445 }
3446 SharedDtor();
3447 }
3448
SharedDtor()3449 inline void ClientStats::SharedDtor() {
3450 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
3451 if (this != internal_default_instance()) delete _impl_.computation_execution_duration_;
3452 }
3453
SetCachedSize(int size) const3454 void ClientStats::SetCachedSize(int size) const {
3455 _impl_._cached_size_.Set(size);
3456 }
3457
Clear()3458 void ClientStats::Clear() {
3459 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.ClientStats)
3460 ::uint32_t cached_has_bits = 0;
3461 // Prevent compiler warnings about cached_has_bits being unused
3462 (void) cached_has_bits;
3463
3464 if (GetArenaForAllocation() == nullptr && _impl_.computation_execution_duration_ != nullptr) {
3465 delete _impl_.computation_execution_duration_;
3466 }
3467 _impl_.computation_execution_duration_ = nullptr;
3468 _internal_metadata_.Clear<std::string>();
3469 }
3470
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)3471 const char* ClientStats::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
3472 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
3473 while (!ctx->Done(&ptr)) {
3474 ::uint32_t tag;
3475 ptr = ::_pbi::ReadTag(ptr, &tag);
3476 switch (tag >> 3) {
3477 // .google.protobuf.Duration computation_execution_duration = 1;
3478 case 1:
3479 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) {
3480 ptr = ctx->ParseMessage(_internal_mutable_computation_execution_duration(), ptr);
3481 CHK_(ptr);
3482 } else {
3483 goto handle_unusual;
3484 }
3485 continue;
3486 default:
3487 goto handle_unusual;
3488 } // switch
3489 handle_unusual:
3490 if ((tag == 0) || ((tag & 7) == 4)) {
3491 CHK_(ptr);
3492 ctx->SetLastTag(tag);
3493 goto message_done;
3494 }
3495 ptr = UnknownFieldParse(
3496 tag,
3497 _internal_metadata_.mutable_unknown_fields<std::string>(),
3498 ptr, ctx);
3499 CHK_(ptr != nullptr);
3500 } // while
3501 message_done:
3502 return ptr;
3503 failure:
3504 ptr = nullptr;
3505 goto message_done;
3506 #undef CHK_
3507 }
3508
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const3509 ::uint8_t* ClientStats::_InternalSerialize(
3510 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
3511 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.ClientStats)
3512 ::uint32_t cached_has_bits = 0;
3513 (void) cached_has_bits;
3514
3515 // .google.protobuf.Duration computation_execution_duration = 1;
3516 if (this->_internal_has_computation_execution_duration()) {
3517 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
3518 InternalWriteMessage(1, _Internal::computation_execution_duration(this),
3519 _Internal::computation_execution_duration(this).GetCachedSize(), target, stream);
3520 }
3521
3522 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
3523 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
3524 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
3525 }
3526 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.ClientStats)
3527 return target;
3528 }
3529
ByteSizeLong() const3530 size_t ClientStats::ByteSizeLong() const {
3531 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.ClientStats)
3532 size_t total_size = 0;
3533
3534 ::uint32_t cached_has_bits = 0;
3535 // Prevent compiler warnings about cached_has_bits being unused
3536 (void) cached_has_bits;
3537
3538 // .google.protobuf.Duration computation_execution_duration = 1;
3539 if (this->_internal_has_computation_execution_duration()) {
3540 total_size += 1 +
3541 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
3542 *_impl_.computation_execution_duration_);
3543 }
3544
3545 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
3546 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
3547 }
3548 int cached_size = ::_pbi::ToCachedSize(total_size);
3549 SetCachedSize(cached_size);
3550 return total_size;
3551 }
3552
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)3553 void ClientStats::CheckTypeAndMergeFrom(
3554 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
3555 MergeFrom(*::_pbi::DownCast<const ClientStats*>(
3556 &from));
3557 }
3558
MergeFrom(const ClientStats & from)3559 void ClientStats::MergeFrom(const ClientStats& from) {
3560 ClientStats* const _this = this;
3561 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.ClientStats)
3562 GOOGLE_DCHECK_NE(&from, _this);
3563 ::uint32_t cached_has_bits = 0;
3564 (void) cached_has_bits;
3565
3566 if (from._internal_has_computation_execution_duration()) {
3567 _this->_internal_mutable_computation_execution_duration()->::PROTOBUF_NAMESPACE_ID::Duration::MergeFrom(
3568 from._internal_computation_execution_duration());
3569 }
3570 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
3571 }
3572
CopyFrom(const ClientStats & from)3573 void ClientStats::CopyFrom(const ClientStats& from) {
3574 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.ClientStats)
3575 if (&from == this) return;
3576 Clear();
3577 MergeFrom(from);
3578 }
3579
IsInitialized() const3580 bool ClientStats::IsInitialized() const {
3581 return true;
3582 }
3583
InternalSwap(ClientStats * other)3584 void ClientStats::InternalSwap(ClientStats* other) {
3585 using std::swap;
3586 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
3587 swap(_impl_.computation_execution_duration_, other->_impl_.computation_execution_duration_);
3588 }
3589
GetTypeName() const3590 std::string ClientStats::GetTypeName() const {
3591 return "google.internal.federatedcompute.v1.ClientStats";
3592 }
3593
3594
3595 // ===================================================================
3596
3597 class ReportTaskResultResponse::_Internal {
3598 public:
3599 };
3600
ReportTaskResultResponse(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)3601 ReportTaskResultResponse::ReportTaskResultResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena,
3602 bool is_message_owned)
3603 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
3604 SharedCtor(arena, is_message_owned);
3605 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.ReportTaskResultResponse)
3606 }
ReportTaskResultResponse(const ReportTaskResultResponse & from)3607 ReportTaskResultResponse::ReportTaskResultResponse(const ReportTaskResultResponse& from)
3608 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
3609 ReportTaskResultResponse* const _this = this; (void)_this;
3610 new (&_impl_) Impl_{
3611 /*decltype(_impl_._cached_size_)*/{}};
3612
3613 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
3614 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.ReportTaskResultResponse)
3615 }
3616
SharedCtor(::_pb::Arena * arena,bool is_message_owned)3617 inline void ReportTaskResultResponse::SharedCtor(
3618 ::_pb::Arena* arena, bool is_message_owned) {
3619 (void)arena;
3620 (void)is_message_owned;
3621 new (&_impl_) Impl_{
3622 /*decltype(_impl_._cached_size_)*/{}
3623 };
3624 }
3625
~ReportTaskResultResponse()3626 ReportTaskResultResponse::~ReportTaskResultResponse() {
3627 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.ReportTaskResultResponse)
3628 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
3629 (void)arena;
3630 return;
3631 }
3632 SharedDtor();
3633 }
3634
SharedDtor()3635 inline void ReportTaskResultResponse::SharedDtor() {
3636 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
3637 }
3638
SetCachedSize(int size) const3639 void ReportTaskResultResponse::SetCachedSize(int size) const {
3640 _impl_._cached_size_.Set(size);
3641 }
3642
Clear()3643 void ReportTaskResultResponse::Clear() {
3644 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.ReportTaskResultResponse)
3645 ::uint32_t cached_has_bits = 0;
3646 // Prevent compiler warnings about cached_has_bits being unused
3647 (void) cached_has_bits;
3648
3649 _internal_metadata_.Clear<std::string>();
3650 }
3651
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)3652 const char* ReportTaskResultResponse::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
3653 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
3654 while (!ctx->Done(&ptr)) {
3655 ::uint32_t tag;
3656 ptr = ::_pbi::ReadTag(ptr, &tag);
3657 if ((tag == 0) || ((tag & 7) == 4)) {
3658 CHK_(ptr);
3659 ctx->SetLastTag(tag);
3660 goto message_done;
3661 }
3662 ptr = UnknownFieldParse(
3663 tag,
3664 _internal_metadata_.mutable_unknown_fields<std::string>(),
3665 ptr, ctx);
3666 CHK_(ptr != nullptr);
3667 } // while
3668 message_done:
3669 return ptr;
3670 failure:
3671 ptr = nullptr;
3672 goto message_done;
3673 #undef CHK_
3674 }
3675
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const3676 ::uint8_t* ReportTaskResultResponse::_InternalSerialize(
3677 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
3678 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.ReportTaskResultResponse)
3679 ::uint32_t cached_has_bits = 0;
3680 (void) cached_has_bits;
3681
3682 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
3683 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
3684 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
3685 }
3686 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.ReportTaskResultResponse)
3687 return target;
3688 }
3689
ByteSizeLong() const3690 size_t ReportTaskResultResponse::ByteSizeLong() const {
3691 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.ReportTaskResultResponse)
3692 size_t total_size = 0;
3693
3694 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
3695 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
3696 }
3697 int cached_size = ::_pbi::ToCachedSize(total_size);
3698 SetCachedSize(cached_size);
3699 return total_size;
3700 }
3701
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)3702 void ReportTaskResultResponse::CheckTypeAndMergeFrom(
3703 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
3704 MergeFrom(*::_pbi::DownCast<const ReportTaskResultResponse*>(
3705 &from));
3706 }
3707
MergeFrom(const ReportTaskResultResponse & from)3708 void ReportTaskResultResponse::MergeFrom(const ReportTaskResultResponse& from) {
3709 ReportTaskResultResponse* const _this = this;
3710 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.ReportTaskResultResponse)
3711 GOOGLE_DCHECK_NE(&from, _this);
3712 ::uint32_t cached_has_bits = 0;
3713 (void) cached_has_bits;
3714
3715 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
3716 }
3717
CopyFrom(const ReportTaskResultResponse & from)3718 void ReportTaskResultResponse::CopyFrom(const ReportTaskResultResponse& from) {
3719 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.ReportTaskResultResponse)
3720 if (&from == this) return;
3721 Clear();
3722 MergeFrom(from);
3723 }
3724
IsInitialized() const3725 bool ReportTaskResultResponse::IsInitialized() const {
3726 return true;
3727 }
3728
InternalSwap(ReportTaskResultResponse * other)3729 void ReportTaskResultResponse::InternalSwap(ReportTaskResultResponse* other) {
3730 using std::swap;
3731 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
3732 }
3733
GetTypeName() const3734 std::string ReportTaskResultResponse::GetTypeName() const {
3735 return "google.internal.federatedcompute.v1.ReportTaskResultResponse";
3736 }
3737
3738
3739 // @@protoc_insertion_point(namespace_scope)
3740 } // namespace v1
3741 } // namespace federatedcompute
3742 } // namespace internal
3743 } // namespace google
3744 PROTOBUF_NAMESPACE_OPEN
3745 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::StartTaskAssignmentRequest*
CreateMaybeMessage(Arena * arena)3746 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::StartTaskAssignmentRequest >(Arena* arena) {
3747 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::StartTaskAssignmentRequest >(arena);
3748 }
3749 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::StartTaskAssignmentMetadata*
CreateMaybeMessage(Arena * arena)3750 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::StartTaskAssignmentMetadata >(Arena* arena) {
3751 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::StartTaskAssignmentMetadata >(arena);
3752 }
3753 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::StartTaskAssignmentResponse*
CreateMaybeMessage(Arena * arena)3754 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::StartTaskAssignmentResponse >(Arena* arena) {
3755 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::StartTaskAssignmentResponse >(arena);
3756 }
3757 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::PerformMultipleTaskAssignmentsRequest*
CreateMaybeMessage(Arena * arena)3758 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::PerformMultipleTaskAssignmentsRequest >(Arena* arena) {
3759 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::PerformMultipleTaskAssignmentsRequest >(arena);
3760 }
3761 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::PerformMultipleTaskAssignmentsResponse*
CreateMaybeMessage(Arena * arena)3762 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::PerformMultipleTaskAssignmentsResponse >(Arena* arena) {
3763 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::PerformMultipleTaskAssignmentsResponse >(arena);
3764 }
3765 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::TaskAssignment_AggregationInfo*
CreateMaybeMessage(Arena * arena)3766 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::TaskAssignment_AggregationInfo >(Arena* arena) {
3767 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::TaskAssignment_AggregationInfo >(arena);
3768 }
3769 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::TaskAssignment_SecureAggregationInfo*
CreateMaybeMessage(Arena * arena)3770 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::TaskAssignment_SecureAggregationInfo >(Arena* arena) {
3771 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::TaskAssignment_SecureAggregationInfo >(arena);
3772 }
3773 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::TaskAssignment*
CreateMaybeMessage(Arena * arena)3774 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::TaskAssignment >(Arena* arena) {
3775 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::TaskAssignment >(arena);
3776 }
3777 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::FederatedSelectUriInfo*
CreateMaybeMessage(Arena * arena)3778 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::FederatedSelectUriInfo >(Arena* arena) {
3779 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::FederatedSelectUriInfo >(arena);
3780 }
3781 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::ReportTaskResultRequest*
CreateMaybeMessage(Arena * arena)3782 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::ReportTaskResultRequest >(Arena* arena) {
3783 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::ReportTaskResultRequest >(arena);
3784 }
3785 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::ClientStats*
CreateMaybeMessage(Arena * arena)3786 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::ClientStats >(Arena* arena) {
3787 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::ClientStats >(arena);
3788 }
3789 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::ReportTaskResultResponse*
CreateMaybeMessage(Arena * arena)3790 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::ReportTaskResultResponse >(Arena* arena) {
3791 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::ReportTaskResultResponse >(arena);
3792 }
3793 PROTOBUF_NAMESPACE_CLOSE
3794
3795 // @@protoc_insertion_point(global_scope)
3796 #include <google/protobuf/port_undef.inc>
3797