1 // Generated by the protocol buffer compiler. DO NOT EDIT!
2 // source: fcp/protos/federatedcompute/aggregations.proto
3
4 #include "fcp/protos/federatedcompute/aggregations.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 {
StartAggregationDataUploadRequest(::_pbi::ConstantInitialized)25 PROTOBUF_CONSTEXPR StartAggregationDataUploadRequest::StartAggregationDataUploadRequest(
26 ::_pbi::ConstantInitialized): _impl_{
27 /*decltype(_impl_.aggregation_id_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
28 , /*decltype(_impl_.authorization_token_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
29 , /*decltype(_impl_._cached_size_)*/{}} {}
30 struct StartAggregationDataUploadRequestDefaultTypeInternal {
StartAggregationDataUploadRequestDefaultTypeInternalgoogle::internal::federatedcompute::v1::StartAggregationDataUploadRequestDefaultTypeInternal31 PROTOBUF_CONSTEXPR StartAggregationDataUploadRequestDefaultTypeInternal()
32 : _instance(::_pbi::ConstantInitialized{}) {}
~StartAggregationDataUploadRequestDefaultTypeInternalgoogle::internal::federatedcompute::v1::StartAggregationDataUploadRequestDefaultTypeInternal33 ~StartAggregationDataUploadRequestDefaultTypeInternal() {}
34 union { // NOLINT(misc-non-private-member-variables-in-classes)
35 StartAggregationDataUploadRequest _instance;
36 };
37 };
38 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 StartAggregationDataUploadRequestDefaultTypeInternal _StartAggregationDataUploadRequest_default_instance_;
StartAggregationDataUploadMetadata(::_pbi::ConstantInitialized)39 PROTOBUF_CONSTEXPR StartAggregationDataUploadMetadata::StartAggregationDataUploadMetadata(
40 ::_pbi::ConstantInitialized): _impl_{
41 /*decltype(_impl_._cached_size_)*/{}} {}
42 struct StartAggregationDataUploadMetadataDefaultTypeInternal {
StartAggregationDataUploadMetadataDefaultTypeInternalgoogle::internal::federatedcompute::v1::StartAggregationDataUploadMetadataDefaultTypeInternal43 PROTOBUF_CONSTEXPR StartAggregationDataUploadMetadataDefaultTypeInternal()
44 : _instance(::_pbi::ConstantInitialized{}) {}
~StartAggregationDataUploadMetadataDefaultTypeInternalgoogle::internal::federatedcompute::v1::StartAggregationDataUploadMetadataDefaultTypeInternal45 ~StartAggregationDataUploadMetadataDefaultTypeInternal() {}
46 union { // NOLINT(misc-non-private-member-variables-in-classes)
47 StartAggregationDataUploadMetadata _instance;
48 };
49 };
50 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 StartAggregationDataUploadMetadataDefaultTypeInternal _StartAggregationDataUploadMetadata_default_instance_;
StartAggregationDataUploadResponse(::_pbi::ConstantInitialized)51 PROTOBUF_CONSTEXPR StartAggregationDataUploadResponse::StartAggregationDataUploadResponse(
52 ::_pbi::ConstantInitialized): _impl_{
53 /*decltype(_impl_.client_token_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
54 , /*decltype(_impl_.aggregation_protocol_forwarding_info_)*/nullptr
55 , /*decltype(_impl_.resource_)*/nullptr
56 , /*decltype(_impl_._cached_size_)*/{}} {}
57 struct StartAggregationDataUploadResponseDefaultTypeInternal {
StartAggregationDataUploadResponseDefaultTypeInternalgoogle::internal::federatedcompute::v1::StartAggregationDataUploadResponseDefaultTypeInternal58 PROTOBUF_CONSTEXPR StartAggregationDataUploadResponseDefaultTypeInternal()
59 : _instance(::_pbi::ConstantInitialized{}) {}
~StartAggregationDataUploadResponseDefaultTypeInternalgoogle::internal::federatedcompute::v1::StartAggregationDataUploadResponseDefaultTypeInternal60 ~StartAggregationDataUploadResponseDefaultTypeInternal() {}
61 union { // NOLINT(misc-non-private-member-variables-in-classes)
62 StartAggregationDataUploadResponse _instance;
63 };
64 };
65 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 StartAggregationDataUploadResponseDefaultTypeInternal _StartAggregationDataUploadResponse_default_instance_;
SubmitAggregationResultRequest(::_pbi::ConstantInitialized)66 PROTOBUF_CONSTEXPR SubmitAggregationResultRequest::SubmitAggregationResultRequest(
67 ::_pbi::ConstantInitialized): _impl_{
68 /*decltype(_impl_.aggregation_id_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
69 , /*decltype(_impl_.client_token_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
70 , /*decltype(_impl_.resource_name_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
71 , /*decltype(_impl_._cached_size_)*/{}} {}
72 struct SubmitAggregationResultRequestDefaultTypeInternal {
SubmitAggregationResultRequestDefaultTypeInternalgoogle::internal::federatedcompute::v1::SubmitAggregationResultRequestDefaultTypeInternal73 PROTOBUF_CONSTEXPR SubmitAggregationResultRequestDefaultTypeInternal()
74 : _instance(::_pbi::ConstantInitialized{}) {}
~SubmitAggregationResultRequestDefaultTypeInternalgoogle::internal::federatedcompute::v1::SubmitAggregationResultRequestDefaultTypeInternal75 ~SubmitAggregationResultRequestDefaultTypeInternal() {}
76 union { // NOLINT(misc-non-private-member-variables-in-classes)
77 SubmitAggregationResultRequest _instance;
78 };
79 };
80 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 SubmitAggregationResultRequestDefaultTypeInternal _SubmitAggregationResultRequest_default_instance_;
SubmitAggregationResultResponse(::_pbi::ConstantInitialized)81 PROTOBUF_CONSTEXPR SubmitAggregationResultResponse::SubmitAggregationResultResponse(
82 ::_pbi::ConstantInitialized): _impl_{
83 /*decltype(_impl_._cached_size_)*/{}} {}
84 struct SubmitAggregationResultResponseDefaultTypeInternal {
SubmitAggregationResultResponseDefaultTypeInternalgoogle::internal::federatedcompute::v1::SubmitAggregationResultResponseDefaultTypeInternal85 PROTOBUF_CONSTEXPR SubmitAggregationResultResponseDefaultTypeInternal()
86 : _instance(::_pbi::ConstantInitialized{}) {}
~SubmitAggregationResultResponseDefaultTypeInternalgoogle::internal::federatedcompute::v1::SubmitAggregationResultResponseDefaultTypeInternal87 ~SubmitAggregationResultResponseDefaultTypeInternal() {}
88 union { // NOLINT(misc-non-private-member-variables-in-classes)
89 SubmitAggregationResultResponse _instance;
90 };
91 };
92 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 SubmitAggregationResultResponseDefaultTypeInternal _SubmitAggregationResultResponse_default_instance_;
AbortAggregationRequest(::_pbi::ConstantInitialized)93 PROTOBUF_CONSTEXPR AbortAggregationRequest::AbortAggregationRequest(
94 ::_pbi::ConstantInitialized): _impl_{
95 /*decltype(_impl_.aggregation_id_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
96 , /*decltype(_impl_.client_token_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
97 , /*decltype(_impl_.status_)*/nullptr
98 , /*decltype(_impl_._cached_size_)*/{}} {}
99 struct AbortAggregationRequestDefaultTypeInternal {
AbortAggregationRequestDefaultTypeInternalgoogle::internal::federatedcompute::v1::AbortAggregationRequestDefaultTypeInternal100 PROTOBUF_CONSTEXPR AbortAggregationRequestDefaultTypeInternal()
101 : _instance(::_pbi::ConstantInitialized{}) {}
~AbortAggregationRequestDefaultTypeInternalgoogle::internal::federatedcompute::v1::AbortAggregationRequestDefaultTypeInternal102 ~AbortAggregationRequestDefaultTypeInternal() {}
103 union { // NOLINT(misc-non-private-member-variables-in-classes)
104 AbortAggregationRequest _instance;
105 };
106 };
107 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 AbortAggregationRequestDefaultTypeInternal _AbortAggregationRequest_default_instance_;
AbortAggregationResponse(::_pbi::ConstantInitialized)108 PROTOBUF_CONSTEXPR AbortAggregationResponse::AbortAggregationResponse(
109 ::_pbi::ConstantInitialized): _impl_{
110 /*decltype(_impl_._cached_size_)*/{}} {}
111 struct AbortAggregationResponseDefaultTypeInternal {
AbortAggregationResponseDefaultTypeInternalgoogle::internal::federatedcompute::v1::AbortAggregationResponseDefaultTypeInternal112 PROTOBUF_CONSTEXPR AbortAggregationResponseDefaultTypeInternal()
113 : _instance(::_pbi::ConstantInitialized{}) {}
~AbortAggregationResponseDefaultTypeInternalgoogle::internal::federatedcompute::v1::AbortAggregationResponseDefaultTypeInternal114 ~AbortAggregationResponseDefaultTypeInternal() {}
115 union { // NOLINT(misc-non-private-member-variables-in-classes)
116 AbortAggregationResponse _instance;
117 };
118 };
119 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 AbortAggregationResponseDefaultTypeInternal _AbortAggregationResponse_default_instance_;
120 } // namespace v1
121 } // namespace federatedcompute
122 } // namespace internal
123 } // namespace google
124 namespace google {
125 namespace internal {
126 namespace federatedcompute {
127 namespace v1 {
128
129 // ===================================================================
130
131 class StartAggregationDataUploadRequest::_Internal {
132 public:
133 };
134
StartAggregationDataUploadRequest(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)135 StartAggregationDataUploadRequest::StartAggregationDataUploadRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
136 bool is_message_owned)
137 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
138 SharedCtor(arena, is_message_owned);
139 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.StartAggregationDataUploadRequest)
140 }
StartAggregationDataUploadRequest(const StartAggregationDataUploadRequest & from)141 StartAggregationDataUploadRequest::StartAggregationDataUploadRequest(const StartAggregationDataUploadRequest& from)
142 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
143 StartAggregationDataUploadRequest* const _this = this; (void)_this;
144 new (&_impl_) Impl_{
145 decltype(_impl_.aggregation_id_){}
146 , decltype(_impl_.authorization_token_){}
147 , /*decltype(_impl_._cached_size_)*/{}};
148
149 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
150 _impl_.aggregation_id_.InitDefault();
151 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
152 _impl_.aggregation_id_.Set("", GetArenaForAllocation());
153 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
154 if (!from._internal_aggregation_id().empty()) {
155 _this->_impl_.aggregation_id_.Set(from._internal_aggregation_id(),
156 _this->GetArenaForAllocation());
157 }
158 _impl_.authorization_token_.InitDefault();
159 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
160 _impl_.authorization_token_.Set("", GetArenaForAllocation());
161 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
162 if (!from._internal_authorization_token().empty()) {
163 _this->_impl_.authorization_token_.Set(from._internal_authorization_token(),
164 _this->GetArenaForAllocation());
165 }
166 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.StartAggregationDataUploadRequest)
167 }
168
SharedCtor(::_pb::Arena * arena,bool is_message_owned)169 inline void StartAggregationDataUploadRequest::SharedCtor(
170 ::_pb::Arena* arena, bool is_message_owned) {
171 (void)arena;
172 (void)is_message_owned;
173 new (&_impl_) Impl_{
174 decltype(_impl_.aggregation_id_){}
175 , decltype(_impl_.authorization_token_){}
176 , /*decltype(_impl_._cached_size_)*/{}
177 };
178 _impl_.aggregation_id_.InitDefault();
179 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
180 _impl_.aggregation_id_.Set("", GetArenaForAllocation());
181 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
182 _impl_.authorization_token_.InitDefault();
183 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
184 _impl_.authorization_token_.Set("", GetArenaForAllocation());
185 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
186 }
187
~StartAggregationDataUploadRequest()188 StartAggregationDataUploadRequest::~StartAggregationDataUploadRequest() {
189 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.StartAggregationDataUploadRequest)
190 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
191 (void)arena;
192 return;
193 }
194 SharedDtor();
195 }
196
SharedDtor()197 inline void StartAggregationDataUploadRequest::SharedDtor() {
198 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
199 _impl_.aggregation_id_.Destroy();
200 _impl_.authorization_token_.Destroy();
201 }
202
SetCachedSize(int size) const203 void StartAggregationDataUploadRequest::SetCachedSize(int size) const {
204 _impl_._cached_size_.Set(size);
205 }
206
Clear()207 void StartAggregationDataUploadRequest::Clear() {
208 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.StartAggregationDataUploadRequest)
209 ::uint32_t cached_has_bits = 0;
210 // Prevent compiler warnings about cached_has_bits being unused
211 (void) cached_has_bits;
212
213 _impl_.aggregation_id_.ClearToEmpty();
214 _impl_.authorization_token_.ClearToEmpty();
215 _internal_metadata_.Clear<std::string>();
216 }
217
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)218 const char* StartAggregationDataUploadRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
219 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
220 while (!ctx->Done(&ptr)) {
221 ::uint32_t tag;
222 ptr = ::_pbi::ReadTag(ptr, &tag);
223 switch (tag >> 3) {
224 // string aggregation_id = 1;
225 case 1:
226 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) {
227 auto str = _internal_mutable_aggregation_id();
228 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
229 CHK_(ptr);
230 CHK_(::_pbi::VerifyUTF8(str, nullptr));
231 } else {
232 goto handle_unusual;
233 }
234 continue;
235 // string authorization_token = 2;
236 case 2:
237 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 18)) {
238 auto str = _internal_mutable_authorization_token();
239 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
240 CHK_(ptr);
241 CHK_(::_pbi::VerifyUTF8(str, nullptr));
242 } else {
243 goto handle_unusual;
244 }
245 continue;
246 default:
247 goto handle_unusual;
248 } // switch
249 handle_unusual:
250 if ((tag == 0) || ((tag & 7) == 4)) {
251 CHK_(ptr);
252 ctx->SetLastTag(tag);
253 goto message_done;
254 }
255 ptr = UnknownFieldParse(
256 tag,
257 _internal_metadata_.mutable_unknown_fields<std::string>(),
258 ptr, ctx);
259 CHK_(ptr != nullptr);
260 } // while
261 message_done:
262 return ptr;
263 failure:
264 ptr = nullptr;
265 goto message_done;
266 #undef CHK_
267 }
268
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const269 ::uint8_t* StartAggregationDataUploadRequest::_InternalSerialize(
270 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
271 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.StartAggregationDataUploadRequest)
272 ::uint32_t cached_has_bits = 0;
273 (void) cached_has_bits;
274
275 // string aggregation_id = 1;
276 if (!this->_internal_aggregation_id().empty()) {
277 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
278 this->_internal_aggregation_id().data(), static_cast<int>(this->_internal_aggregation_id().length()),
279 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
280 "google.internal.federatedcompute.v1.StartAggregationDataUploadRequest.aggregation_id");
281 target = stream->WriteStringMaybeAliased(
282 1, this->_internal_aggregation_id(), target);
283 }
284
285 // string authorization_token = 2;
286 if (!this->_internal_authorization_token().empty()) {
287 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
288 this->_internal_authorization_token().data(), static_cast<int>(this->_internal_authorization_token().length()),
289 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
290 "google.internal.federatedcompute.v1.StartAggregationDataUploadRequest.authorization_token");
291 target = stream->WriteStringMaybeAliased(
292 2, this->_internal_authorization_token(), target);
293 }
294
295 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
296 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
297 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
298 }
299 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.StartAggregationDataUploadRequest)
300 return target;
301 }
302
ByteSizeLong() const303 size_t StartAggregationDataUploadRequest::ByteSizeLong() const {
304 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.StartAggregationDataUploadRequest)
305 size_t total_size = 0;
306
307 ::uint32_t cached_has_bits = 0;
308 // Prevent compiler warnings about cached_has_bits being unused
309 (void) cached_has_bits;
310
311 // string aggregation_id = 1;
312 if (!this->_internal_aggregation_id().empty()) {
313 total_size += 1 +
314 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
315 this->_internal_aggregation_id());
316 }
317
318 // string authorization_token = 2;
319 if (!this->_internal_authorization_token().empty()) {
320 total_size += 1 +
321 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
322 this->_internal_authorization_token());
323 }
324
325 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
326 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
327 }
328 int cached_size = ::_pbi::ToCachedSize(total_size);
329 SetCachedSize(cached_size);
330 return total_size;
331 }
332
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)333 void StartAggregationDataUploadRequest::CheckTypeAndMergeFrom(
334 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
335 MergeFrom(*::_pbi::DownCast<const StartAggregationDataUploadRequest*>(
336 &from));
337 }
338
MergeFrom(const StartAggregationDataUploadRequest & from)339 void StartAggregationDataUploadRequest::MergeFrom(const StartAggregationDataUploadRequest& from) {
340 StartAggregationDataUploadRequest* const _this = this;
341 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.StartAggregationDataUploadRequest)
342 GOOGLE_DCHECK_NE(&from, _this);
343 ::uint32_t cached_has_bits = 0;
344 (void) cached_has_bits;
345
346 if (!from._internal_aggregation_id().empty()) {
347 _this->_internal_set_aggregation_id(from._internal_aggregation_id());
348 }
349 if (!from._internal_authorization_token().empty()) {
350 _this->_internal_set_authorization_token(from._internal_authorization_token());
351 }
352 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
353 }
354
CopyFrom(const StartAggregationDataUploadRequest & from)355 void StartAggregationDataUploadRequest::CopyFrom(const StartAggregationDataUploadRequest& from) {
356 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.StartAggregationDataUploadRequest)
357 if (&from == this) return;
358 Clear();
359 MergeFrom(from);
360 }
361
IsInitialized() const362 bool StartAggregationDataUploadRequest::IsInitialized() const {
363 return true;
364 }
365
InternalSwap(StartAggregationDataUploadRequest * other)366 void StartAggregationDataUploadRequest::InternalSwap(StartAggregationDataUploadRequest* other) {
367 using std::swap;
368 auto* lhs_arena = GetArenaForAllocation();
369 auto* rhs_arena = other->GetArenaForAllocation();
370 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
371 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
372 &_impl_.aggregation_id_, lhs_arena,
373 &other->_impl_.aggregation_id_, rhs_arena
374 );
375 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
376 &_impl_.authorization_token_, lhs_arena,
377 &other->_impl_.authorization_token_, rhs_arena
378 );
379 }
380
GetTypeName() const381 std::string StartAggregationDataUploadRequest::GetTypeName() const {
382 return "google.internal.federatedcompute.v1.StartAggregationDataUploadRequest";
383 }
384
385
386 // ===================================================================
387
388 class StartAggregationDataUploadMetadata::_Internal {
389 public:
390 };
391
StartAggregationDataUploadMetadata(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)392 StartAggregationDataUploadMetadata::StartAggregationDataUploadMetadata(::PROTOBUF_NAMESPACE_ID::Arena* arena,
393 bool is_message_owned)
394 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
395 SharedCtor(arena, is_message_owned);
396 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.StartAggregationDataUploadMetadata)
397 }
StartAggregationDataUploadMetadata(const StartAggregationDataUploadMetadata & from)398 StartAggregationDataUploadMetadata::StartAggregationDataUploadMetadata(const StartAggregationDataUploadMetadata& from)
399 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
400 StartAggregationDataUploadMetadata* const _this = this; (void)_this;
401 new (&_impl_) Impl_{
402 /*decltype(_impl_._cached_size_)*/{}};
403
404 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
405 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.StartAggregationDataUploadMetadata)
406 }
407
SharedCtor(::_pb::Arena * arena,bool is_message_owned)408 inline void StartAggregationDataUploadMetadata::SharedCtor(
409 ::_pb::Arena* arena, bool is_message_owned) {
410 (void)arena;
411 (void)is_message_owned;
412 new (&_impl_) Impl_{
413 /*decltype(_impl_._cached_size_)*/{}
414 };
415 }
416
~StartAggregationDataUploadMetadata()417 StartAggregationDataUploadMetadata::~StartAggregationDataUploadMetadata() {
418 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.StartAggregationDataUploadMetadata)
419 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
420 (void)arena;
421 return;
422 }
423 SharedDtor();
424 }
425
SharedDtor()426 inline void StartAggregationDataUploadMetadata::SharedDtor() {
427 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
428 }
429
SetCachedSize(int size) const430 void StartAggregationDataUploadMetadata::SetCachedSize(int size) const {
431 _impl_._cached_size_.Set(size);
432 }
433
Clear()434 void StartAggregationDataUploadMetadata::Clear() {
435 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.StartAggregationDataUploadMetadata)
436 ::uint32_t cached_has_bits = 0;
437 // Prevent compiler warnings about cached_has_bits being unused
438 (void) cached_has_bits;
439
440 _internal_metadata_.Clear<std::string>();
441 }
442
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)443 const char* StartAggregationDataUploadMetadata::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
444 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
445 while (!ctx->Done(&ptr)) {
446 ::uint32_t tag;
447 ptr = ::_pbi::ReadTag(ptr, &tag);
448 if ((tag == 0) || ((tag & 7) == 4)) {
449 CHK_(ptr);
450 ctx->SetLastTag(tag);
451 goto message_done;
452 }
453 ptr = UnknownFieldParse(
454 tag,
455 _internal_metadata_.mutable_unknown_fields<std::string>(),
456 ptr, ctx);
457 CHK_(ptr != nullptr);
458 } // while
459 message_done:
460 return ptr;
461 failure:
462 ptr = nullptr;
463 goto message_done;
464 #undef CHK_
465 }
466
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const467 ::uint8_t* StartAggregationDataUploadMetadata::_InternalSerialize(
468 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
469 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.StartAggregationDataUploadMetadata)
470 ::uint32_t cached_has_bits = 0;
471 (void) cached_has_bits;
472
473 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
474 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
475 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
476 }
477 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.StartAggregationDataUploadMetadata)
478 return target;
479 }
480
ByteSizeLong() const481 size_t StartAggregationDataUploadMetadata::ByteSizeLong() const {
482 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.StartAggregationDataUploadMetadata)
483 size_t total_size = 0;
484
485 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
486 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
487 }
488 int cached_size = ::_pbi::ToCachedSize(total_size);
489 SetCachedSize(cached_size);
490 return total_size;
491 }
492
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)493 void StartAggregationDataUploadMetadata::CheckTypeAndMergeFrom(
494 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
495 MergeFrom(*::_pbi::DownCast<const StartAggregationDataUploadMetadata*>(
496 &from));
497 }
498
MergeFrom(const StartAggregationDataUploadMetadata & from)499 void StartAggregationDataUploadMetadata::MergeFrom(const StartAggregationDataUploadMetadata& from) {
500 StartAggregationDataUploadMetadata* const _this = this;
501 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.StartAggregationDataUploadMetadata)
502 GOOGLE_DCHECK_NE(&from, _this);
503 ::uint32_t cached_has_bits = 0;
504 (void) cached_has_bits;
505
506 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
507 }
508
CopyFrom(const StartAggregationDataUploadMetadata & from)509 void StartAggregationDataUploadMetadata::CopyFrom(const StartAggregationDataUploadMetadata& from) {
510 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.StartAggregationDataUploadMetadata)
511 if (&from == this) return;
512 Clear();
513 MergeFrom(from);
514 }
515
IsInitialized() const516 bool StartAggregationDataUploadMetadata::IsInitialized() const {
517 return true;
518 }
519
InternalSwap(StartAggregationDataUploadMetadata * other)520 void StartAggregationDataUploadMetadata::InternalSwap(StartAggregationDataUploadMetadata* other) {
521 using std::swap;
522 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
523 }
524
GetTypeName() const525 std::string StartAggregationDataUploadMetadata::GetTypeName() const {
526 return "google.internal.federatedcompute.v1.StartAggregationDataUploadMetadata";
527 }
528
529
530 // ===================================================================
531
532 class StartAggregationDataUploadResponse::_Internal {
533 public:
534 static const ::google::internal::federatedcompute::v1::ForwardingInfo& aggregation_protocol_forwarding_info(const StartAggregationDataUploadResponse* msg);
535 static const ::google::internal::federatedcompute::v1::ByteStreamResource& resource(const StartAggregationDataUploadResponse* msg);
536 };
537
538 const ::google::internal::federatedcompute::v1::ForwardingInfo&
aggregation_protocol_forwarding_info(const StartAggregationDataUploadResponse * msg)539 StartAggregationDataUploadResponse::_Internal::aggregation_protocol_forwarding_info(const StartAggregationDataUploadResponse* msg) {
540 return *msg->_impl_.aggregation_protocol_forwarding_info_;
541 }
542 const ::google::internal::federatedcompute::v1::ByteStreamResource&
resource(const StartAggregationDataUploadResponse * msg)543 StartAggregationDataUploadResponse::_Internal::resource(const StartAggregationDataUploadResponse* msg) {
544 return *msg->_impl_.resource_;
545 }
clear_aggregation_protocol_forwarding_info()546 void StartAggregationDataUploadResponse::clear_aggregation_protocol_forwarding_info() {
547 if (GetArenaForAllocation() == nullptr && _impl_.aggregation_protocol_forwarding_info_ != nullptr) {
548 delete _impl_.aggregation_protocol_forwarding_info_;
549 }
550 _impl_.aggregation_protocol_forwarding_info_ = nullptr;
551 }
clear_resource()552 void StartAggregationDataUploadResponse::clear_resource() {
553 if (GetArenaForAllocation() == nullptr && _impl_.resource_ != nullptr) {
554 delete _impl_.resource_;
555 }
556 _impl_.resource_ = nullptr;
557 }
StartAggregationDataUploadResponse(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)558 StartAggregationDataUploadResponse::StartAggregationDataUploadResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena,
559 bool is_message_owned)
560 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
561 SharedCtor(arena, is_message_owned);
562 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.StartAggregationDataUploadResponse)
563 }
StartAggregationDataUploadResponse(const StartAggregationDataUploadResponse & from)564 StartAggregationDataUploadResponse::StartAggregationDataUploadResponse(const StartAggregationDataUploadResponse& from)
565 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
566 StartAggregationDataUploadResponse* const _this = this; (void)_this;
567 new (&_impl_) Impl_{
568 decltype(_impl_.client_token_){}
569 , decltype(_impl_.aggregation_protocol_forwarding_info_){nullptr}
570 , decltype(_impl_.resource_){nullptr}
571 , /*decltype(_impl_._cached_size_)*/{}};
572
573 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
574 _impl_.client_token_.InitDefault();
575 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
576 _impl_.client_token_.Set("", GetArenaForAllocation());
577 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
578 if (!from._internal_client_token().empty()) {
579 _this->_impl_.client_token_.Set(from._internal_client_token(),
580 _this->GetArenaForAllocation());
581 }
582 if (from._internal_has_aggregation_protocol_forwarding_info()) {
583 _this->_impl_.aggregation_protocol_forwarding_info_ = new ::google::internal::federatedcompute::v1::ForwardingInfo(*from._impl_.aggregation_protocol_forwarding_info_);
584 }
585 if (from._internal_has_resource()) {
586 _this->_impl_.resource_ = new ::google::internal::federatedcompute::v1::ByteStreamResource(*from._impl_.resource_);
587 }
588 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.StartAggregationDataUploadResponse)
589 }
590
SharedCtor(::_pb::Arena * arena,bool is_message_owned)591 inline void StartAggregationDataUploadResponse::SharedCtor(
592 ::_pb::Arena* arena, bool is_message_owned) {
593 (void)arena;
594 (void)is_message_owned;
595 new (&_impl_) Impl_{
596 decltype(_impl_.client_token_){}
597 , decltype(_impl_.aggregation_protocol_forwarding_info_){nullptr}
598 , decltype(_impl_.resource_){nullptr}
599 , /*decltype(_impl_._cached_size_)*/{}
600 };
601 _impl_.client_token_.InitDefault();
602 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
603 _impl_.client_token_.Set("", GetArenaForAllocation());
604 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
605 }
606
~StartAggregationDataUploadResponse()607 StartAggregationDataUploadResponse::~StartAggregationDataUploadResponse() {
608 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.StartAggregationDataUploadResponse)
609 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
610 (void)arena;
611 return;
612 }
613 SharedDtor();
614 }
615
SharedDtor()616 inline void StartAggregationDataUploadResponse::SharedDtor() {
617 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
618 _impl_.client_token_.Destroy();
619 if (this != internal_default_instance()) delete _impl_.aggregation_protocol_forwarding_info_;
620 if (this != internal_default_instance()) delete _impl_.resource_;
621 }
622
SetCachedSize(int size) const623 void StartAggregationDataUploadResponse::SetCachedSize(int size) const {
624 _impl_._cached_size_.Set(size);
625 }
626
Clear()627 void StartAggregationDataUploadResponse::Clear() {
628 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.StartAggregationDataUploadResponse)
629 ::uint32_t cached_has_bits = 0;
630 // Prevent compiler warnings about cached_has_bits being unused
631 (void) cached_has_bits;
632
633 _impl_.client_token_.ClearToEmpty();
634 if (GetArenaForAllocation() == nullptr && _impl_.aggregation_protocol_forwarding_info_ != nullptr) {
635 delete _impl_.aggregation_protocol_forwarding_info_;
636 }
637 _impl_.aggregation_protocol_forwarding_info_ = nullptr;
638 if (GetArenaForAllocation() == nullptr && _impl_.resource_ != nullptr) {
639 delete _impl_.resource_;
640 }
641 _impl_.resource_ = nullptr;
642 _internal_metadata_.Clear<std::string>();
643 }
644
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)645 const char* StartAggregationDataUploadResponse::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
646 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
647 while (!ctx->Done(&ptr)) {
648 ::uint32_t tag;
649 ptr = ::_pbi::ReadTag(ptr, &tag);
650 switch (tag >> 3) {
651 // .google.internal.federatedcompute.v1.ForwardingInfo aggregation_protocol_forwarding_info = 1;
652 case 1:
653 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) {
654 ptr = ctx->ParseMessage(_internal_mutable_aggregation_protocol_forwarding_info(), ptr);
655 CHK_(ptr);
656 } else {
657 goto handle_unusual;
658 }
659 continue;
660 // .google.internal.federatedcompute.v1.ByteStreamResource resource = 2;
661 case 2:
662 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 18)) {
663 ptr = ctx->ParseMessage(_internal_mutable_resource(), ptr);
664 CHK_(ptr);
665 } else {
666 goto handle_unusual;
667 }
668 continue;
669 // string client_token = 3;
670 case 3:
671 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 26)) {
672 auto str = _internal_mutable_client_token();
673 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
674 CHK_(ptr);
675 CHK_(::_pbi::VerifyUTF8(str, nullptr));
676 } else {
677 goto handle_unusual;
678 }
679 continue;
680 default:
681 goto handle_unusual;
682 } // switch
683 handle_unusual:
684 if ((tag == 0) || ((tag & 7) == 4)) {
685 CHK_(ptr);
686 ctx->SetLastTag(tag);
687 goto message_done;
688 }
689 ptr = UnknownFieldParse(
690 tag,
691 _internal_metadata_.mutable_unknown_fields<std::string>(),
692 ptr, ctx);
693 CHK_(ptr != nullptr);
694 } // while
695 message_done:
696 return ptr;
697 failure:
698 ptr = nullptr;
699 goto message_done;
700 #undef CHK_
701 }
702
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const703 ::uint8_t* StartAggregationDataUploadResponse::_InternalSerialize(
704 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
705 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.StartAggregationDataUploadResponse)
706 ::uint32_t cached_has_bits = 0;
707 (void) cached_has_bits;
708
709 // .google.internal.federatedcompute.v1.ForwardingInfo aggregation_protocol_forwarding_info = 1;
710 if (this->_internal_has_aggregation_protocol_forwarding_info()) {
711 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
712 InternalWriteMessage(1, _Internal::aggregation_protocol_forwarding_info(this),
713 _Internal::aggregation_protocol_forwarding_info(this).GetCachedSize(), target, stream);
714 }
715
716 // .google.internal.federatedcompute.v1.ByteStreamResource resource = 2;
717 if (this->_internal_has_resource()) {
718 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
719 InternalWriteMessage(2, _Internal::resource(this),
720 _Internal::resource(this).GetCachedSize(), target, stream);
721 }
722
723 // string client_token = 3;
724 if (!this->_internal_client_token().empty()) {
725 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
726 this->_internal_client_token().data(), static_cast<int>(this->_internal_client_token().length()),
727 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
728 "google.internal.federatedcompute.v1.StartAggregationDataUploadResponse.client_token");
729 target = stream->WriteStringMaybeAliased(
730 3, this->_internal_client_token(), target);
731 }
732
733 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
734 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
735 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
736 }
737 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.StartAggregationDataUploadResponse)
738 return target;
739 }
740
ByteSizeLong() const741 size_t StartAggregationDataUploadResponse::ByteSizeLong() const {
742 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.StartAggregationDataUploadResponse)
743 size_t total_size = 0;
744
745 ::uint32_t cached_has_bits = 0;
746 // Prevent compiler warnings about cached_has_bits being unused
747 (void) cached_has_bits;
748
749 // string client_token = 3;
750 if (!this->_internal_client_token().empty()) {
751 total_size += 1 +
752 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
753 this->_internal_client_token());
754 }
755
756 // .google.internal.federatedcompute.v1.ForwardingInfo aggregation_protocol_forwarding_info = 1;
757 if (this->_internal_has_aggregation_protocol_forwarding_info()) {
758 total_size += 1 +
759 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
760 *_impl_.aggregation_protocol_forwarding_info_);
761 }
762
763 // .google.internal.federatedcompute.v1.ByteStreamResource resource = 2;
764 if (this->_internal_has_resource()) {
765 total_size += 1 +
766 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
767 *_impl_.resource_);
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 StartAggregationDataUploadResponse::CheckTypeAndMergeFrom(
779 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
780 MergeFrom(*::_pbi::DownCast<const StartAggregationDataUploadResponse*>(
781 &from));
782 }
783
MergeFrom(const StartAggregationDataUploadResponse & from)784 void StartAggregationDataUploadResponse::MergeFrom(const StartAggregationDataUploadResponse& from) {
785 StartAggregationDataUploadResponse* const _this = this;
786 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.StartAggregationDataUploadResponse)
787 GOOGLE_DCHECK_NE(&from, _this);
788 ::uint32_t cached_has_bits = 0;
789 (void) cached_has_bits;
790
791 if (!from._internal_client_token().empty()) {
792 _this->_internal_set_client_token(from._internal_client_token());
793 }
794 if (from._internal_has_aggregation_protocol_forwarding_info()) {
795 _this->_internal_mutable_aggregation_protocol_forwarding_info()->::google::internal::federatedcompute::v1::ForwardingInfo::MergeFrom(
796 from._internal_aggregation_protocol_forwarding_info());
797 }
798 if (from._internal_has_resource()) {
799 _this->_internal_mutable_resource()->::google::internal::federatedcompute::v1::ByteStreamResource::MergeFrom(
800 from._internal_resource());
801 }
802 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
803 }
804
CopyFrom(const StartAggregationDataUploadResponse & from)805 void StartAggregationDataUploadResponse::CopyFrom(const StartAggregationDataUploadResponse& from) {
806 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.StartAggregationDataUploadResponse)
807 if (&from == this) return;
808 Clear();
809 MergeFrom(from);
810 }
811
IsInitialized() const812 bool StartAggregationDataUploadResponse::IsInitialized() const {
813 return true;
814 }
815
InternalSwap(StartAggregationDataUploadResponse * other)816 void StartAggregationDataUploadResponse::InternalSwap(StartAggregationDataUploadResponse* other) {
817 using std::swap;
818 auto* lhs_arena = GetArenaForAllocation();
819 auto* rhs_arena = other->GetArenaForAllocation();
820 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
821 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
822 &_impl_.client_token_, lhs_arena,
823 &other->_impl_.client_token_, rhs_arena
824 );
825 ::PROTOBUF_NAMESPACE_ID::internal::memswap<
826 PROTOBUF_FIELD_OFFSET(StartAggregationDataUploadResponse, _impl_.resource_)
827 + sizeof(StartAggregationDataUploadResponse::_impl_.resource_) // NOLINT
828 - PROTOBUF_FIELD_OFFSET(StartAggregationDataUploadResponse, _impl_.aggregation_protocol_forwarding_info_)>(
829 reinterpret_cast<char*>(&_impl_.aggregation_protocol_forwarding_info_),
830 reinterpret_cast<char*>(&other->_impl_.aggregation_protocol_forwarding_info_));
831 }
832
GetTypeName() const833 std::string StartAggregationDataUploadResponse::GetTypeName() const {
834 return "google.internal.federatedcompute.v1.StartAggregationDataUploadResponse";
835 }
836
837
838 // ===================================================================
839
840 class SubmitAggregationResultRequest::_Internal {
841 public:
842 };
843
SubmitAggregationResultRequest(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)844 SubmitAggregationResultRequest::SubmitAggregationResultRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
845 bool is_message_owned)
846 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
847 SharedCtor(arena, is_message_owned);
848 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.SubmitAggregationResultRequest)
849 }
SubmitAggregationResultRequest(const SubmitAggregationResultRequest & from)850 SubmitAggregationResultRequest::SubmitAggregationResultRequest(const SubmitAggregationResultRequest& from)
851 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
852 SubmitAggregationResultRequest* const _this = this; (void)_this;
853 new (&_impl_) Impl_{
854 decltype(_impl_.aggregation_id_){}
855 , decltype(_impl_.client_token_){}
856 , decltype(_impl_.resource_name_){}
857 , /*decltype(_impl_._cached_size_)*/{}};
858
859 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
860 _impl_.aggregation_id_.InitDefault();
861 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
862 _impl_.aggregation_id_.Set("", GetArenaForAllocation());
863 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
864 if (!from._internal_aggregation_id().empty()) {
865 _this->_impl_.aggregation_id_.Set(from._internal_aggregation_id(),
866 _this->GetArenaForAllocation());
867 }
868 _impl_.client_token_.InitDefault();
869 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
870 _impl_.client_token_.Set("", GetArenaForAllocation());
871 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
872 if (!from._internal_client_token().empty()) {
873 _this->_impl_.client_token_.Set(from._internal_client_token(),
874 _this->GetArenaForAllocation());
875 }
876 _impl_.resource_name_.InitDefault();
877 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
878 _impl_.resource_name_.Set("", GetArenaForAllocation());
879 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
880 if (!from._internal_resource_name().empty()) {
881 _this->_impl_.resource_name_.Set(from._internal_resource_name(),
882 _this->GetArenaForAllocation());
883 }
884 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.SubmitAggregationResultRequest)
885 }
886
SharedCtor(::_pb::Arena * arena,bool is_message_owned)887 inline void SubmitAggregationResultRequest::SharedCtor(
888 ::_pb::Arena* arena, bool is_message_owned) {
889 (void)arena;
890 (void)is_message_owned;
891 new (&_impl_) Impl_{
892 decltype(_impl_.aggregation_id_){}
893 , decltype(_impl_.client_token_){}
894 , decltype(_impl_.resource_name_){}
895 , /*decltype(_impl_._cached_size_)*/{}
896 };
897 _impl_.aggregation_id_.InitDefault();
898 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
899 _impl_.aggregation_id_.Set("", GetArenaForAllocation());
900 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
901 _impl_.client_token_.InitDefault();
902 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
903 _impl_.client_token_.Set("", GetArenaForAllocation());
904 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
905 _impl_.resource_name_.InitDefault();
906 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
907 _impl_.resource_name_.Set("", GetArenaForAllocation());
908 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
909 }
910
~SubmitAggregationResultRequest()911 SubmitAggregationResultRequest::~SubmitAggregationResultRequest() {
912 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.SubmitAggregationResultRequest)
913 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
914 (void)arena;
915 return;
916 }
917 SharedDtor();
918 }
919
SharedDtor()920 inline void SubmitAggregationResultRequest::SharedDtor() {
921 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
922 _impl_.aggregation_id_.Destroy();
923 _impl_.client_token_.Destroy();
924 _impl_.resource_name_.Destroy();
925 }
926
SetCachedSize(int size) const927 void SubmitAggregationResultRequest::SetCachedSize(int size) const {
928 _impl_._cached_size_.Set(size);
929 }
930
Clear()931 void SubmitAggregationResultRequest::Clear() {
932 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.SubmitAggregationResultRequest)
933 ::uint32_t cached_has_bits = 0;
934 // Prevent compiler warnings about cached_has_bits being unused
935 (void) cached_has_bits;
936
937 _impl_.aggregation_id_.ClearToEmpty();
938 _impl_.client_token_.ClearToEmpty();
939 _impl_.resource_name_.ClearToEmpty();
940 _internal_metadata_.Clear<std::string>();
941 }
942
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)943 const char* SubmitAggregationResultRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
944 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
945 while (!ctx->Done(&ptr)) {
946 ::uint32_t tag;
947 ptr = ::_pbi::ReadTag(ptr, &tag);
948 switch (tag >> 3) {
949 // string aggregation_id = 1;
950 case 1:
951 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) {
952 auto str = _internal_mutable_aggregation_id();
953 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
954 CHK_(ptr);
955 CHK_(::_pbi::VerifyUTF8(str, nullptr));
956 } else {
957 goto handle_unusual;
958 }
959 continue;
960 // string client_token = 2;
961 case 2:
962 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 18)) {
963 auto str = _internal_mutable_client_token();
964 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
965 CHK_(ptr);
966 CHK_(::_pbi::VerifyUTF8(str, nullptr));
967 } else {
968 goto handle_unusual;
969 }
970 continue;
971 // string resource_name = 3;
972 case 3:
973 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 26)) {
974 auto str = _internal_mutable_resource_name();
975 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
976 CHK_(ptr);
977 CHK_(::_pbi::VerifyUTF8(str, nullptr));
978 } else {
979 goto handle_unusual;
980 }
981 continue;
982 default:
983 goto handle_unusual;
984 } // switch
985 handle_unusual:
986 if ((tag == 0) || ((tag & 7) == 4)) {
987 CHK_(ptr);
988 ctx->SetLastTag(tag);
989 goto message_done;
990 }
991 ptr = UnknownFieldParse(
992 tag,
993 _internal_metadata_.mutable_unknown_fields<std::string>(),
994 ptr, ctx);
995 CHK_(ptr != nullptr);
996 } // while
997 message_done:
998 return ptr;
999 failure:
1000 ptr = nullptr;
1001 goto message_done;
1002 #undef CHK_
1003 }
1004
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const1005 ::uint8_t* SubmitAggregationResultRequest::_InternalSerialize(
1006 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
1007 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.SubmitAggregationResultRequest)
1008 ::uint32_t cached_has_bits = 0;
1009 (void) cached_has_bits;
1010
1011 // string aggregation_id = 1;
1012 if (!this->_internal_aggregation_id().empty()) {
1013 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
1014 this->_internal_aggregation_id().data(), static_cast<int>(this->_internal_aggregation_id().length()),
1015 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
1016 "google.internal.federatedcompute.v1.SubmitAggregationResultRequest.aggregation_id");
1017 target = stream->WriteStringMaybeAliased(
1018 1, this->_internal_aggregation_id(), target);
1019 }
1020
1021 // string client_token = 2;
1022 if (!this->_internal_client_token().empty()) {
1023 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
1024 this->_internal_client_token().data(), static_cast<int>(this->_internal_client_token().length()),
1025 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
1026 "google.internal.federatedcompute.v1.SubmitAggregationResultRequest.client_token");
1027 target = stream->WriteStringMaybeAliased(
1028 2, this->_internal_client_token(), target);
1029 }
1030
1031 // string resource_name = 3;
1032 if (!this->_internal_resource_name().empty()) {
1033 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
1034 this->_internal_resource_name().data(), static_cast<int>(this->_internal_resource_name().length()),
1035 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
1036 "google.internal.federatedcompute.v1.SubmitAggregationResultRequest.resource_name");
1037 target = stream->WriteStringMaybeAliased(
1038 3, this->_internal_resource_name(), target);
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.SubmitAggregationResultRequest)
1046 return target;
1047 }
1048
ByteSizeLong() const1049 size_t SubmitAggregationResultRequest::ByteSizeLong() const {
1050 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.SubmitAggregationResultRequest)
1051 size_t total_size = 0;
1052
1053 ::uint32_t cached_has_bits = 0;
1054 // Prevent compiler warnings about cached_has_bits being unused
1055 (void) cached_has_bits;
1056
1057 // string aggregation_id = 1;
1058 if (!this->_internal_aggregation_id().empty()) {
1059 total_size += 1 +
1060 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1061 this->_internal_aggregation_id());
1062 }
1063
1064 // string client_token = 2;
1065 if (!this->_internal_client_token().empty()) {
1066 total_size += 1 +
1067 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1068 this->_internal_client_token());
1069 }
1070
1071 // string resource_name = 3;
1072 if (!this->_internal_resource_name().empty()) {
1073 total_size += 1 +
1074 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1075 this->_internal_resource_name());
1076 }
1077
1078 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1079 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
1080 }
1081 int cached_size = ::_pbi::ToCachedSize(total_size);
1082 SetCachedSize(cached_size);
1083 return total_size;
1084 }
1085
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)1086 void SubmitAggregationResultRequest::CheckTypeAndMergeFrom(
1087 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
1088 MergeFrom(*::_pbi::DownCast<const SubmitAggregationResultRequest*>(
1089 &from));
1090 }
1091
MergeFrom(const SubmitAggregationResultRequest & from)1092 void SubmitAggregationResultRequest::MergeFrom(const SubmitAggregationResultRequest& from) {
1093 SubmitAggregationResultRequest* const _this = this;
1094 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.SubmitAggregationResultRequest)
1095 GOOGLE_DCHECK_NE(&from, _this);
1096 ::uint32_t cached_has_bits = 0;
1097 (void) cached_has_bits;
1098
1099 if (!from._internal_aggregation_id().empty()) {
1100 _this->_internal_set_aggregation_id(from._internal_aggregation_id());
1101 }
1102 if (!from._internal_client_token().empty()) {
1103 _this->_internal_set_client_token(from._internal_client_token());
1104 }
1105 if (!from._internal_resource_name().empty()) {
1106 _this->_internal_set_resource_name(from._internal_resource_name());
1107 }
1108 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1109 }
1110
CopyFrom(const SubmitAggregationResultRequest & from)1111 void SubmitAggregationResultRequest::CopyFrom(const SubmitAggregationResultRequest& from) {
1112 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.SubmitAggregationResultRequest)
1113 if (&from == this) return;
1114 Clear();
1115 MergeFrom(from);
1116 }
1117
IsInitialized() const1118 bool SubmitAggregationResultRequest::IsInitialized() const {
1119 return true;
1120 }
1121
InternalSwap(SubmitAggregationResultRequest * other)1122 void SubmitAggregationResultRequest::InternalSwap(SubmitAggregationResultRequest* other) {
1123 using std::swap;
1124 auto* lhs_arena = GetArenaForAllocation();
1125 auto* rhs_arena = other->GetArenaForAllocation();
1126 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
1127 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
1128 &_impl_.aggregation_id_, lhs_arena,
1129 &other->_impl_.aggregation_id_, rhs_arena
1130 );
1131 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
1132 &_impl_.client_token_, lhs_arena,
1133 &other->_impl_.client_token_, rhs_arena
1134 );
1135 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
1136 &_impl_.resource_name_, lhs_arena,
1137 &other->_impl_.resource_name_, rhs_arena
1138 );
1139 }
1140
GetTypeName() const1141 std::string SubmitAggregationResultRequest::GetTypeName() const {
1142 return "google.internal.federatedcompute.v1.SubmitAggregationResultRequest";
1143 }
1144
1145
1146 // ===================================================================
1147
1148 class SubmitAggregationResultResponse::_Internal {
1149 public:
1150 };
1151
SubmitAggregationResultResponse(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)1152 SubmitAggregationResultResponse::SubmitAggregationResultResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1153 bool is_message_owned)
1154 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
1155 SharedCtor(arena, is_message_owned);
1156 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.SubmitAggregationResultResponse)
1157 }
SubmitAggregationResultResponse(const SubmitAggregationResultResponse & from)1158 SubmitAggregationResultResponse::SubmitAggregationResultResponse(const SubmitAggregationResultResponse& from)
1159 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
1160 SubmitAggregationResultResponse* const _this = this; (void)_this;
1161 new (&_impl_) Impl_{
1162 /*decltype(_impl_._cached_size_)*/{}};
1163
1164 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1165 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.SubmitAggregationResultResponse)
1166 }
1167
SharedCtor(::_pb::Arena * arena,bool is_message_owned)1168 inline void SubmitAggregationResultResponse::SharedCtor(
1169 ::_pb::Arena* arena, bool is_message_owned) {
1170 (void)arena;
1171 (void)is_message_owned;
1172 new (&_impl_) Impl_{
1173 /*decltype(_impl_._cached_size_)*/{}
1174 };
1175 }
1176
~SubmitAggregationResultResponse()1177 SubmitAggregationResultResponse::~SubmitAggregationResultResponse() {
1178 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.SubmitAggregationResultResponse)
1179 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
1180 (void)arena;
1181 return;
1182 }
1183 SharedDtor();
1184 }
1185
SharedDtor()1186 inline void SubmitAggregationResultResponse::SharedDtor() {
1187 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
1188 }
1189
SetCachedSize(int size) const1190 void SubmitAggregationResultResponse::SetCachedSize(int size) const {
1191 _impl_._cached_size_.Set(size);
1192 }
1193
Clear()1194 void SubmitAggregationResultResponse::Clear() {
1195 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.SubmitAggregationResultResponse)
1196 ::uint32_t cached_has_bits = 0;
1197 // Prevent compiler warnings about cached_has_bits being unused
1198 (void) cached_has_bits;
1199
1200 _internal_metadata_.Clear<std::string>();
1201 }
1202
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)1203 const char* SubmitAggregationResultResponse::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
1204 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
1205 while (!ctx->Done(&ptr)) {
1206 ::uint32_t tag;
1207 ptr = ::_pbi::ReadTag(ptr, &tag);
1208 if ((tag == 0) || ((tag & 7) == 4)) {
1209 CHK_(ptr);
1210 ctx->SetLastTag(tag);
1211 goto message_done;
1212 }
1213 ptr = UnknownFieldParse(
1214 tag,
1215 _internal_metadata_.mutable_unknown_fields<std::string>(),
1216 ptr, ctx);
1217 CHK_(ptr != nullptr);
1218 } // while
1219 message_done:
1220 return ptr;
1221 failure:
1222 ptr = nullptr;
1223 goto message_done;
1224 #undef CHK_
1225 }
1226
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const1227 ::uint8_t* SubmitAggregationResultResponse::_InternalSerialize(
1228 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
1229 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.SubmitAggregationResultResponse)
1230 ::uint32_t cached_has_bits = 0;
1231 (void) cached_has_bits;
1232
1233 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1234 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
1235 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
1236 }
1237 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.SubmitAggregationResultResponse)
1238 return target;
1239 }
1240
ByteSizeLong() const1241 size_t SubmitAggregationResultResponse::ByteSizeLong() const {
1242 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.SubmitAggregationResultResponse)
1243 size_t total_size = 0;
1244
1245 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1246 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
1247 }
1248 int cached_size = ::_pbi::ToCachedSize(total_size);
1249 SetCachedSize(cached_size);
1250 return total_size;
1251 }
1252
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)1253 void SubmitAggregationResultResponse::CheckTypeAndMergeFrom(
1254 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
1255 MergeFrom(*::_pbi::DownCast<const SubmitAggregationResultResponse*>(
1256 &from));
1257 }
1258
MergeFrom(const SubmitAggregationResultResponse & from)1259 void SubmitAggregationResultResponse::MergeFrom(const SubmitAggregationResultResponse& from) {
1260 SubmitAggregationResultResponse* const _this = this;
1261 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.SubmitAggregationResultResponse)
1262 GOOGLE_DCHECK_NE(&from, _this);
1263 ::uint32_t cached_has_bits = 0;
1264 (void) cached_has_bits;
1265
1266 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1267 }
1268
CopyFrom(const SubmitAggregationResultResponse & from)1269 void SubmitAggregationResultResponse::CopyFrom(const SubmitAggregationResultResponse& from) {
1270 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.SubmitAggregationResultResponse)
1271 if (&from == this) return;
1272 Clear();
1273 MergeFrom(from);
1274 }
1275
IsInitialized() const1276 bool SubmitAggregationResultResponse::IsInitialized() const {
1277 return true;
1278 }
1279
InternalSwap(SubmitAggregationResultResponse * other)1280 void SubmitAggregationResultResponse::InternalSwap(SubmitAggregationResultResponse* other) {
1281 using std::swap;
1282 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
1283 }
1284
GetTypeName() const1285 std::string SubmitAggregationResultResponse::GetTypeName() const {
1286 return "google.internal.federatedcompute.v1.SubmitAggregationResultResponse";
1287 }
1288
1289
1290 // ===================================================================
1291
1292 class AbortAggregationRequest::_Internal {
1293 public:
1294 static const ::google::internal::federatedcompute::v1::Status& status(const AbortAggregationRequest* msg);
1295 };
1296
1297 const ::google::internal::federatedcompute::v1::Status&
status(const AbortAggregationRequest * msg)1298 AbortAggregationRequest::_Internal::status(const AbortAggregationRequest* msg) {
1299 return *msg->_impl_.status_;
1300 }
clear_status()1301 void AbortAggregationRequest::clear_status() {
1302 if (GetArenaForAllocation() == nullptr && _impl_.status_ != nullptr) {
1303 delete _impl_.status_;
1304 }
1305 _impl_.status_ = nullptr;
1306 }
AbortAggregationRequest(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)1307 AbortAggregationRequest::AbortAggregationRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1308 bool is_message_owned)
1309 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
1310 SharedCtor(arena, is_message_owned);
1311 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.AbortAggregationRequest)
1312 }
AbortAggregationRequest(const AbortAggregationRequest & from)1313 AbortAggregationRequest::AbortAggregationRequest(const AbortAggregationRequest& from)
1314 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
1315 AbortAggregationRequest* const _this = this; (void)_this;
1316 new (&_impl_) Impl_{
1317 decltype(_impl_.aggregation_id_){}
1318 , decltype(_impl_.client_token_){}
1319 , decltype(_impl_.status_){nullptr}
1320 , /*decltype(_impl_._cached_size_)*/{}};
1321
1322 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1323 _impl_.aggregation_id_.InitDefault();
1324 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1325 _impl_.aggregation_id_.Set("", GetArenaForAllocation());
1326 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1327 if (!from._internal_aggregation_id().empty()) {
1328 _this->_impl_.aggregation_id_.Set(from._internal_aggregation_id(),
1329 _this->GetArenaForAllocation());
1330 }
1331 _impl_.client_token_.InitDefault();
1332 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1333 _impl_.client_token_.Set("", GetArenaForAllocation());
1334 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1335 if (!from._internal_client_token().empty()) {
1336 _this->_impl_.client_token_.Set(from._internal_client_token(),
1337 _this->GetArenaForAllocation());
1338 }
1339 if (from._internal_has_status()) {
1340 _this->_impl_.status_ = new ::google::internal::federatedcompute::v1::Status(*from._impl_.status_);
1341 }
1342 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.AbortAggregationRequest)
1343 }
1344
SharedCtor(::_pb::Arena * arena,bool is_message_owned)1345 inline void AbortAggregationRequest::SharedCtor(
1346 ::_pb::Arena* arena, bool is_message_owned) {
1347 (void)arena;
1348 (void)is_message_owned;
1349 new (&_impl_) Impl_{
1350 decltype(_impl_.aggregation_id_){}
1351 , decltype(_impl_.client_token_){}
1352 , decltype(_impl_.status_){nullptr}
1353 , /*decltype(_impl_._cached_size_)*/{}
1354 };
1355 _impl_.aggregation_id_.InitDefault();
1356 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1357 _impl_.aggregation_id_.Set("", GetArenaForAllocation());
1358 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1359 _impl_.client_token_.InitDefault();
1360 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1361 _impl_.client_token_.Set("", GetArenaForAllocation());
1362 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1363 }
1364
~AbortAggregationRequest()1365 AbortAggregationRequest::~AbortAggregationRequest() {
1366 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.AbortAggregationRequest)
1367 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
1368 (void)arena;
1369 return;
1370 }
1371 SharedDtor();
1372 }
1373
SharedDtor()1374 inline void AbortAggregationRequest::SharedDtor() {
1375 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
1376 _impl_.aggregation_id_.Destroy();
1377 _impl_.client_token_.Destroy();
1378 if (this != internal_default_instance()) delete _impl_.status_;
1379 }
1380
SetCachedSize(int size) const1381 void AbortAggregationRequest::SetCachedSize(int size) const {
1382 _impl_._cached_size_.Set(size);
1383 }
1384
Clear()1385 void AbortAggregationRequest::Clear() {
1386 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.AbortAggregationRequest)
1387 ::uint32_t cached_has_bits = 0;
1388 // Prevent compiler warnings about cached_has_bits being unused
1389 (void) cached_has_bits;
1390
1391 _impl_.aggregation_id_.ClearToEmpty();
1392 _impl_.client_token_.ClearToEmpty();
1393 if (GetArenaForAllocation() == nullptr && _impl_.status_ != nullptr) {
1394 delete _impl_.status_;
1395 }
1396 _impl_.status_ = nullptr;
1397 _internal_metadata_.Clear<std::string>();
1398 }
1399
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)1400 const char* AbortAggregationRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
1401 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
1402 while (!ctx->Done(&ptr)) {
1403 ::uint32_t tag;
1404 ptr = ::_pbi::ReadTag(ptr, &tag);
1405 switch (tag >> 3) {
1406 // string aggregation_id = 1;
1407 case 1:
1408 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 10)) {
1409 auto str = _internal_mutable_aggregation_id();
1410 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
1411 CHK_(ptr);
1412 CHK_(::_pbi::VerifyUTF8(str, nullptr));
1413 } else {
1414 goto handle_unusual;
1415 }
1416 continue;
1417 // string client_token = 2;
1418 case 2:
1419 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 18)) {
1420 auto str = _internal_mutable_client_token();
1421 ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
1422 CHK_(ptr);
1423 CHK_(::_pbi::VerifyUTF8(str, nullptr));
1424 } else {
1425 goto handle_unusual;
1426 }
1427 continue;
1428 // .google.internal.federatedcompute.v1.Status status = 3;
1429 case 3:
1430 if (PROTOBUF_PREDICT_TRUE(static_cast<::uint8_t>(tag) == 26)) {
1431 ptr = ctx->ParseMessage(_internal_mutable_status(), ptr);
1432 CHK_(ptr);
1433 } else {
1434 goto handle_unusual;
1435 }
1436 continue;
1437 default:
1438 goto handle_unusual;
1439 } // switch
1440 handle_unusual:
1441 if ((tag == 0) || ((tag & 7) == 4)) {
1442 CHK_(ptr);
1443 ctx->SetLastTag(tag);
1444 goto message_done;
1445 }
1446 ptr = UnknownFieldParse(
1447 tag,
1448 _internal_metadata_.mutable_unknown_fields<std::string>(),
1449 ptr, ctx);
1450 CHK_(ptr != nullptr);
1451 } // while
1452 message_done:
1453 return ptr;
1454 failure:
1455 ptr = nullptr;
1456 goto message_done;
1457 #undef CHK_
1458 }
1459
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const1460 ::uint8_t* AbortAggregationRequest::_InternalSerialize(
1461 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
1462 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.AbortAggregationRequest)
1463 ::uint32_t cached_has_bits = 0;
1464 (void) cached_has_bits;
1465
1466 // string aggregation_id = 1;
1467 if (!this->_internal_aggregation_id().empty()) {
1468 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
1469 this->_internal_aggregation_id().data(), static_cast<int>(this->_internal_aggregation_id().length()),
1470 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
1471 "google.internal.federatedcompute.v1.AbortAggregationRequest.aggregation_id");
1472 target = stream->WriteStringMaybeAliased(
1473 1, this->_internal_aggregation_id(), target);
1474 }
1475
1476 // string client_token = 2;
1477 if (!this->_internal_client_token().empty()) {
1478 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
1479 this->_internal_client_token().data(), static_cast<int>(this->_internal_client_token().length()),
1480 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
1481 "google.internal.federatedcompute.v1.AbortAggregationRequest.client_token");
1482 target = stream->WriteStringMaybeAliased(
1483 2, this->_internal_client_token(), target);
1484 }
1485
1486 // .google.internal.federatedcompute.v1.Status status = 3;
1487 if (this->_internal_has_status()) {
1488 target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
1489 InternalWriteMessage(3, _Internal::status(this),
1490 _Internal::status(this).GetCachedSize(), target, stream);
1491 }
1492
1493 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1494 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
1495 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
1496 }
1497 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.AbortAggregationRequest)
1498 return target;
1499 }
1500
ByteSizeLong() const1501 size_t AbortAggregationRequest::ByteSizeLong() const {
1502 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.AbortAggregationRequest)
1503 size_t total_size = 0;
1504
1505 ::uint32_t cached_has_bits = 0;
1506 // Prevent compiler warnings about cached_has_bits being unused
1507 (void) cached_has_bits;
1508
1509 // string aggregation_id = 1;
1510 if (!this->_internal_aggregation_id().empty()) {
1511 total_size += 1 +
1512 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1513 this->_internal_aggregation_id());
1514 }
1515
1516 // string client_token = 2;
1517 if (!this->_internal_client_token().empty()) {
1518 total_size += 1 +
1519 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1520 this->_internal_client_token());
1521 }
1522
1523 // .google.internal.federatedcompute.v1.Status status = 3;
1524 if (this->_internal_has_status()) {
1525 total_size += 1 +
1526 ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
1527 *_impl_.status_);
1528 }
1529
1530 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1531 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
1532 }
1533 int cached_size = ::_pbi::ToCachedSize(total_size);
1534 SetCachedSize(cached_size);
1535 return total_size;
1536 }
1537
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)1538 void AbortAggregationRequest::CheckTypeAndMergeFrom(
1539 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
1540 MergeFrom(*::_pbi::DownCast<const AbortAggregationRequest*>(
1541 &from));
1542 }
1543
MergeFrom(const AbortAggregationRequest & from)1544 void AbortAggregationRequest::MergeFrom(const AbortAggregationRequest& from) {
1545 AbortAggregationRequest* const _this = this;
1546 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.AbortAggregationRequest)
1547 GOOGLE_DCHECK_NE(&from, _this);
1548 ::uint32_t cached_has_bits = 0;
1549 (void) cached_has_bits;
1550
1551 if (!from._internal_aggregation_id().empty()) {
1552 _this->_internal_set_aggregation_id(from._internal_aggregation_id());
1553 }
1554 if (!from._internal_client_token().empty()) {
1555 _this->_internal_set_client_token(from._internal_client_token());
1556 }
1557 if (from._internal_has_status()) {
1558 _this->_internal_mutable_status()->::google::internal::federatedcompute::v1::Status::MergeFrom(
1559 from._internal_status());
1560 }
1561 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1562 }
1563
CopyFrom(const AbortAggregationRequest & from)1564 void AbortAggregationRequest::CopyFrom(const AbortAggregationRequest& from) {
1565 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.AbortAggregationRequest)
1566 if (&from == this) return;
1567 Clear();
1568 MergeFrom(from);
1569 }
1570
IsInitialized() const1571 bool AbortAggregationRequest::IsInitialized() const {
1572 return true;
1573 }
1574
InternalSwap(AbortAggregationRequest * other)1575 void AbortAggregationRequest::InternalSwap(AbortAggregationRequest* other) {
1576 using std::swap;
1577 auto* lhs_arena = GetArenaForAllocation();
1578 auto* rhs_arena = other->GetArenaForAllocation();
1579 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
1580 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
1581 &_impl_.aggregation_id_, lhs_arena,
1582 &other->_impl_.aggregation_id_, rhs_arena
1583 );
1584 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
1585 &_impl_.client_token_, lhs_arena,
1586 &other->_impl_.client_token_, rhs_arena
1587 );
1588 swap(_impl_.status_, other->_impl_.status_);
1589 }
1590
GetTypeName() const1591 std::string AbortAggregationRequest::GetTypeName() const {
1592 return "google.internal.federatedcompute.v1.AbortAggregationRequest";
1593 }
1594
1595
1596 // ===================================================================
1597
1598 class AbortAggregationResponse::_Internal {
1599 public:
1600 };
1601
AbortAggregationResponse(::PROTOBUF_NAMESPACE_ID::Arena * arena,bool is_message_owned)1602 AbortAggregationResponse::AbortAggregationResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1603 bool is_message_owned)
1604 : ::PROTOBUF_NAMESPACE_ID::MessageLite(arena, is_message_owned) {
1605 SharedCtor(arena, is_message_owned);
1606 // @@protoc_insertion_point(arena_constructor:google.internal.federatedcompute.v1.AbortAggregationResponse)
1607 }
AbortAggregationResponse(const AbortAggregationResponse & from)1608 AbortAggregationResponse::AbortAggregationResponse(const AbortAggregationResponse& from)
1609 : ::PROTOBUF_NAMESPACE_ID::MessageLite() {
1610 AbortAggregationResponse* const _this = this; (void)_this;
1611 new (&_impl_) Impl_{
1612 /*decltype(_impl_._cached_size_)*/{}};
1613
1614 _internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1615 // @@protoc_insertion_point(copy_constructor:google.internal.federatedcompute.v1.AbortAggregationResponse)
1616 }
1617
SharedCtor(::_pb::Arena * arena,bool is_message_owned)1618 inline void AbortAggregationResponse::SharedCtor(
1619 ::_pb::Arena* arena, bool is_message_owned) {
1620 (void)arena;
1621 (void)is_message_owned;
1622 new (&_impl_) Impl_{
1623 /*decltype(_impl_._cached_size_)*/{}
1624 };
1625 }
1626
~AbortAggregationResponse()1627 AbortAggregationResponse::~AbortAggregationResponse() {
1628 // @@protoc_insertion_point(destructor:google.internal.federatedcompute.v1.AbortAggregationResponse)
1629 if (auto *arena = _internal_metadata_.DeleteReturnArena<std::string>()) {
1630 (void)arena;
1631 return;
1632 }
1633 SharedDtor();
1634 }
1635
SharedDtor()1636 inline void AbortAggregationResponse::SharedDtor() {
1637 GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
1638 }
1639
SetCachedSize(int size) const1640 void AbortAggregationResponse::SetCachedSize(int size) const {
1641 _impl_._cached_size_.Set(size);
1642 }
1643
Clear()1644 void AbortAggregationResponse::Clear() {
1645 // @@protoc_insertion_point(message_clear_start:google.internal.federatedcompute.v1.AbortAggregationResponse)
1646 ::uint32_t cached_has_bits = 0;
1647 // Prevent compiler warnings about cached_has_bits being unused
1648 (void) cached_has_bits;
1649
1650 _internal_metadata_.Clear<std::string>();
1651 }
1652
_InternalParse(const char * ptr,::_pbi::ParseContext * ctx)1653 const char* AbortAggregationResponse::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
1654 #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
1655 while (!ctx->Done(&ptr)) {
1656 ::uint32_t tag;
1657 ptr = ::_pbi::ReadTag(ptr, &tag);
1658 if ((tag == 0) || ((tag & 7) == 4)) {
1659 CHK_(ptr);
1660 ctx->SetLastTag(tag);
1661 goto message_done;
1662 }
1663 ptr = UnknownFieldParse(
1664 tag,
1665 _internal_metadata_.mutable_unknown_fields<std::string>(),
1666 ptr, ctx);
1667 CHK_(ptr != nullptr);
1668 } // while
1669 message_done:
1670 return ptr;
1671 failure:
1672 ptr = nullptr;
1673 goto message_done;
1674 #undef CHK_
1675 }
1676
_InternalSerialize(::uint8_t * target,::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream * stream) const1677 ::uint8_t* AbortAggregationResponse::_InternalSerialize(
1678 ::uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
1679 // @@protoc_insertion_point(serialize_to_array_start:google.internal.federatedcompute.v1.AbortAggregationResponse)
1680 ::uint32_t cached_has_bits = 0;
1681 (void) cached_has_bits;
1682
1683 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1684 target = stream->WriteRaw(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).data(),
1685 static_cast<int>(_internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size()), target);
1686 }
1687 // @@protoc_insertion_point(serialize_to_array_end:google.internal.federatedcompute.v1.AbortAggregationResponse)
1688 return target;
1689 }
1690
ByteSizeLong() const1691 size_t AbortAggregationResponse::ByteSizeLong() const {
1692 // @@protoc_insertion_point(message_byte_size_start:google.internal.federatedcompute.v1.AbortAggregationResponse)
1693 size_t total_size = 0;
1694
1695 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1696 total_size += _internal_metadata_.unknown_fields<std::string>(::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString).size();
1697 }
1698 int cached_size = ::_pbi::ToCachedSize(total_size);
1699 SetCachedSize(cached_size);
1700 return total_size;
1701 }
1702
CheckTypeAndMergeFrom(const::PROTOBUF_NAMESPACE_ID::MessageLite & from)1703 void AbortAggregationResponse::CheckTypeAndMergeFrom(
1704 const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
1705 MergeFrom(*::_pbi::DownCast<const AbortAggregationResponse*>(
1706 &from));
1707 }
1708
MergeFrom(const AbortAggregationResponse & from)1709 void AbortAggregationResponse::MergeFrom(const AbortAggregationResponse& from) {
1710 AbortAggregationResponse* const _this = this;
1711 // @@protoc_insertion_point(class_specific_merge_from_start:google.internal.federatedcompute.v1.AbortAggregationResponse)
1712 GOOGLE_DCHECK_NE(&from, _this);
1713 ::uint32_t cached_has_bits = 0;
1714 (void) cached_has_bits;
1715
1716 _this->_internal_metadata_.MergeFrom<std::string>(from._internal_metadata_);
1717 }
1718
CopyFrom(const AbortAggregationResponse & from)1719 void AbortAggregationResponse::CopyFrom(const AbortAggregationResponse& from) {
1720 // @@protoc_insertion_point(class_specific_copy_from_start:google.internal.federatedcompute.v1.AbortAggregationResponse)
1721 if (&from == this) return;
1722 Clear();
1723 MergeFrom(from);
1724 }
1725
IsInitialized() const1726 bool AbortAggregationResponse::IsInitialized() const {
1727 return true;
1728 }
1729
InternalSwap(AbortAggregationResponse * other)1730 void AbortAggregationResponse::InternalSwap(AbortAggregationResponse* other) {
1731 using std::swap;
1732 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
1733 }
1734
GetTypeName() const1735 std::string AbortAggregationResponse::GetTypeName() const {
1736 return "google.internal.federatedcompute.v1.AbortAggregationResponse";
1737 }
1738
1739
1740 // @@protoc_insertion_point(namespace_scope)
1741 } // namespace v1
1742 } // namespace federatedcompute
1743 } // namespace internal
1744 } // namespace google
1745 PROTOBUF_NAMESPACE_OPEN
1746 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::StartAggregationDataUploadRequest*
CreateMaybeMessage(Arena * arena)1747 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::StartAggregationDataUploadRequest >(Arena* arena) {
1748 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::StartAggregationDataUploadRequest >(arena);
1749 }
1750 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::StartAggregationDataUploadMetadata*
CreateMaybeMessage(Arena * arena)1751 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::StartAggregationDataUploadMetadata >(Arena* arena) {
1752 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::StartAggregationDataUploadMetadata >(arena);
1753 }
1754 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::StartAggregationDataUploadResponse*
CreateMaybeMessage(Arena * arena)1755 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::StartAggregationDataUploadResponse >(Arena* arena) {
1756 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::StartAggregationDataUploadResponse >(arena);
1757 }
1758 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::SubmitAggregationResultRequest*
CreateMaybeMessage(Arena * arena)1759 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::SubmitAggregationResultRequest >(Arena* arena) {
1760 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::SubmitAggregationResultRequest >(arena);
1761 }
1762 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::SubmitAggregationResultResponse*
CreateMaybeMessage(Arena * arena)1763 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::SubmitAggregationResultResponse >(Arena* arena) {
1764 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::SubmitAggregationResultResponse >(arena);
1765 }
1766 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::AbortAggregationRequest*
CreateMaybeMessage(Arena * arena)1767 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::AbortAggregationRequest >(Arena* arena) {
1768 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::AbortAggregationRequest >(arena);
1769 }
1770 template<> PROTOBUF_NOINLINE ::google::internal::federatedcompute::v1::AbortAggregationResponse*
CreateMaybeMessage(Arena * arena)1771 Arena::CreateMaybeMessage< ::google::internal::federatedcompute::v1::AbortAggregationResponse >(Arena* arena) {
1772 return Arena::CreateMessageInternal< ::google::internal::federatedcompute::v1::AbortAggregationResponse >(arena);
1773 }
1774 PROTOBUF_NAMESPACE_CLOSE
1775
1776 // @@protoc_insertion_point(global_scope)
1777 #include <google/protobuf/port_undef.inc>
1778