Home
last modified time | relevance | path

Searched refs:TaskAssignment (Results 1 – 25 of 32) sorted by relevance

12

/aosp_15_r20/out/soong/.intermediates/external/federated-compute/federated-compute-cc-proto-lite/android_arm64_armv8-2a_cortex-a55_static_apex33/gen/proto/fcp/protos/ondevicepersonalization/
Dtask_assignments.pb.h69 class TaskAssignment; variable
82 …edcompute::proto::TaskAssignment* Arena::CreateMaybeMessage<::google::ondevicepersonalization::fed…
402 …const ::google::ondevicepersonalization::federatedcompute::proto::TaskAssignment& task_assignment(… in Swap()
403 …PROTOBUF_NODISCARD ::google::ondevicepersonalization::federatedcompute::proto::TaskAssignment* rel… in Swap()
404 …::google::ondevicepersonalization::federatedcompute::proto::TaskAssignment* mutable_task_assignmen… in Swap()
405 …signment(::google::ondevicepersonalization::federatedcompute::proto::TaskAssignment* task_assignme… in Swap()
407 …const ::google::ondevicepersonalization::federatedcompute::proto::TaskAssignment& _internal_task_a… in Swap()
408 …::google::ondevicepersonalization::federatedcompute::proto::TaskAssignment* _internal_mutable_task… in Swap()
411 ::google::ondevicepersonalization::federatedcompute::proto::TaskAssignment* task_assignment); in Swap()
412 …::google::ondevicepersonalization::federatedcompute::proto::TaskAssignment* unsafe_arena_release_t… in Swap()
[all …]
Dtask_assignments.pb.cc53 PROTOBUF_CONSTEXPR TaskAssignment::TaskAssignment( in TaskAssignment() function in google::ondevicepersonalization::federatedcompute::proto::TaskAssignment
72 TaskAssignment _instance;
467 …static const ::google::ondevicepersonalization::federatedcompute::proto::TaskAssignment& task_assi…
471 const ::google::ondevicepersonalization::federatedcompute::proto::TaskAssignment&
479 …signment(::google::ondevicepersonalization::federatedcompute::proto::TaskAssignment* task_assignme… in set_allocated_task_assignment()
536 …ssignment()->::google::ondevicepersonalization::federatedcompute::proto::TaskAssignment::MergeFrom( in CreateTaskAssignmentResponse()
738 …ssignment()->::google::ondevicepersonalization::federatedcompute::proto::TaskAssignment::MergeFrom( in MergeFrom()
779 class TaskAssignment::_Internal {
781 …nst ::google::internal::federatedcompute::v1::Resource& init_checkpoint(const TaskAssignment* msg);
782 static const ::google::internal::federatedcompute::v1::Resource& plan(const TaskAssignment* msg);
[all …]
/aosp_15_r20/out/soong/.intermediates/external/federated-compute/federated-compute-cc-proto-lite/android_arm64_armv8-2a_cortex-a55_static_apex33/gen/proto/fcp/protos/federatedcompute/
Dtask_assignments.pb.h79 class TaskAssignment; variable
102 …nal::federatedcompute::v1::TaskAssignment* Arena::CreateMaybeMessage<::google::internal::federated…
593 const ::google::internal::federatedcompute::v1::TaskAssignment& task_assignment() const; in Swap()
594 …PROTOBUF_NODISCARD ::google::internal::federatedcompute::v1::TaskAssignment* release_task_assignme… in Swap()
595 ::google::internal::federatedcompute::v1::TaskAssignment* mutable_task_assignment(); in Swap()
596 …void set_allocated_task_assignment(::google::internal::federatedcompute::v1::TaskAssignment* task_… in Swap()
598 const ::google::internal::federatedcompute::v1::TaskAssignment& _internal_task_assignment() const; in Swap()
599 ::google::internal::federatedcompute::v1::TaskAssignment* _internal_mutable_task_assignment(); in Swap()
602 ::google::internal::federatedcompute::v1::TaskAssignment* task_assignment); in Swap()
603 ::google::internal::federatedcompute::v1::TaskAssignment* unsafe_arena_release_task_assignment(); in Swap()
[all …]
Dtask_assignments.pb.cc124 PROTOBUF_CONSTEXPR TaskAssignment::TaskAssignment( in TaskAssignment() function in google::internal::federatedcompute::v1::TaskAssignment
142 TaskAssignment _instance;
824 …static const ::google::internal::federatedcompute::v1::TaskAssignment& task_assignment(const Start…
828 const ::google::internal::federatedcompute::v1::TaskAssignment&
836 …_allocated_task_assignment(::google::internal::federatedcompute::v1::TaskAssignment* task_assignme… in set_allocated_task_assignment()
893 …nal_mutable_task_assignment()->::google::internal::federatedcompute::v1::TaskAssignment::MergeFrom( in StartTaskAssignmentResponse()
1095 …nal_mutable_task_assignment()->::google::internal::federatedcompute::v1::TaskAssignment::MergeFrom( in MergeFrom()
2048 class TaskAssignment::_Internal {
2050 …:federatedcompute::v1::ForwardingInfo& aggregation_data_forwarding_info(const TaskAssignment* msg);
2051 …:federatedcompute::v1::TaskAssignment_AggregationInfo& aggregation_info(const TaskAssignment* msg);
[all …]
/aosp_15_r20/external/federated-compute/fcp/demo/
H A Dtask_assignments_test.py143 task_assignment=task_assignments_pb2.TaskAssignment(
146 task_assignments_pb2.TaskAssignment.AggregationInfo()
209 task_assignment=task_assignments_pb2.TaskAssignment(
212 task_assignments_pb2.TaskAssignment.AggregationInfo()
239 task_assignment=task_assignments_pb2.TaskAssignment(
242 task_assignments_pb2.TaskAssignment.AggregationInfo()
346 task_assignments_pb2.TaskAssignment(
349 task_assignments_pb2.TaskAssignment.AggregationInfo()
363 task_assignments_pb2.TaskAssignment(
366 task_assignments_pb2.TaskAssignment.AggregationInfo()
H A Dtask_assignments.py137 task_assignment=task_assignments_pb2.TaskAssignment(
140 task_assignments_pb2.TaskAssignment.AggregationInfo()
194 task_assignments_pb2.TaskAssignment(
197 task_assignments_pb2.TaskAssignment.AggregationInfo()
H A Dserver_test.py165 async def wait_for_task(self) -> task_assignments_pb2.TaskAssignment:
/aosp_15_r20/packages/modules/OnDevicePersonalization/federatedcompute/src/com/android/federatedcompute/services/http/
DCheckinResult.java25 import com.google.ondevicepersonalization.federatedcompute.proto.TaskAssignment;
33 private final TaskAssignment mTaskAssignment;
37 String inputCheckpoint, ClientOnlyPlan planData, TaskAssignment taskAssignment) { in CheckinResult()
65 public TaskAssignment getTaskAssignment() { in getTaskAssignment()
DHttpFederatedProtocol.java72 import com.google.ondevicepersonalization.federatedcompute.proto.TaskAssignment;
149 public ListenableFuture<CheckinResult> downloadTaskAssignment(TaskAssignment taskAssignment) { in downloadTaskAssignment()
268 TaskAssignment taskAssignment = getTaskAssignment(taskAssignmentResponse);
308 private TaskAssignment getTaskAssignment(CreateTaskAssignmentResponse taskAssignmentResponse) {
317 TaskAssignment taskAssignment = taskAssignmentResponse.getTaskAssignment();
326 private void validateTaskAssignment(TaskAssignment taskAssignment) {
345 TaskAssignment taskAssignment,
/aosp_15_r20/external/federated-compute/fcp/client/
H A Dfederated_protocol.h178 struct TaskAssignment { struct
187 using CheckinResult = std::variant<TaskAssignment, Rejection>;
227 std::function<void(const TaskAssignment&)>
234 std::vector<absl::StatusOr<TaskAssignment>> task_assignments;
H A Dgrpc_federated_protocol.h100 std::function<void(const TaskAssignment&)> payload_uris_received_callback)
169 absl::Time start_time, std::function<void(const TaskAssignment&)>
H A Dgrpc_federated_protocol_test.cc500 const ::fcp::client::FederatedProtocol::TaskAssignment&)>>
1267 VariantWith<FederatedProtocol::TaskAssignment>(FieldsAre( in TEST_P()
1281 VariantWith<FederatedProtocol::TaskAssignment>(FieldsAre( in TEST_P()
1390 VariantWith<FederatedProtocol::TaskAssignment>(FieldsAre( in TEST_P()
1549 VariantWith<FederatedProtocol::TaskAssignment>(FieldsAre( in TEST_P()
1556 VariantWith<FederatedProtocol::TaskAssignment>( in TEST_P()
H A Dgrpc_federated_protocol.cc417 std::function<void(const TaskAssignment&)> payload_uris_received_callback) { in ReceiveCheckinResponse()
457 TaskAssignment result{ in ReceiveCheckinResponse()
548 std::function<void(const TaskAssignment&)> payload_uris_received_callback) { in Checkin()
H A Dtest_helpers.h393 std::function<void(const FederatedProtocol::TaskAssignment&)> in Checkin()
397 std::holds_alternative<FederatedProtocol::TaskAssignment>(*result)) { in Checkin()
400 std::get<FederatedProtocol::TaskAssignment>(*result)); in Checkin()
H A Dfl_runner.cc1046 std::function<void(const FederatedProtocol::TaskAssignment&)> in IssueCheckin()
1052 const FederatedProtocol::TaskAssignment& task_assignment) { in IssueCheckin()
1088 std::holds_alternative<FederatedProtocol::TaskAssignment>( in IssueCheckin()
1135 absl::get<FederatedProtocol::TaskAssignment>(*checkin_result); in IssueCheckin()
/aosp_15_r20/external/federated-compute/fcp/client/http/
H A Dhttp_federated_protocol.h89 std::function<void(const TaskAssignment&)> payload_uris_received_callback)
163 std::function<void(const TaskAssignment&)>
173 std::function<void(const TaskAssignment&)>
H A Dhttp_federated_protocol.cc528 std::function<void(const TaskAssignment&)> payload_uris_received_callback) { in Checkin()
621 std::function<void(const TaskAssignment&)> payload_uris_received_callback) { in HandleTaskAssignmentOperationResponse()
695 std::function<void(const TaskAssignment&)> payload_uris_received_callback) { in HandleTaskAssignmentInnerResponse()
716 TaskAssignment result = { in HandleTaskAssignmentInnerResponse()
H A Dhttp_federated_protocol_test.cc99 using ::google::internal::federatedcompute::v1::TaskAssignment;
387 TaskAssignment* task_assignment = response.mutable_task_assignment(); in GetFakeTaskAssignmentResponse()
729 const ::fcp::client::FederatedProtocol::TaskAssignment&)>>
1956 VariantWith<FederatedProtocol::TaskAssignment>(FieldsAre( in TEST_F()
2043 VariantWith<FederatedProtocol::TaskAssignment>(FieldsAre( in TEST_F()
/aosp_15_r20/external/federated-compute/fcp/protos/federatedcompute/
H A Deligibility_eval_tasks.proto123 // StartTaskAssignmentResponse with a TaskAssignment. This will not be set if
129 // receives a StartTaskAssignmentResponse without a TaskAssignment.
154 // Also see the similar `TaskAssignment.execution_phase_id`.
H A Dtask_assignments.proto128 TaskAssignment task_assignment = 1;
164 repeated TaskAssignment task_assignments = 1;
169 message TaskAssignment { message
/aosp_15_r20/external/federated-compute/fcp/protos/ondevicepersonalization/
H A Dtask_assignments.proto47 TaskAssignment task_assignment = 1;
57 message TaskAssignment { message
/aosp_15_r20/packages/modules/OnDevicePersonalization/tests/federatedcomputetests/src/com/android/federatedcompute/services/training/
DFederatedComputeWorkerTest.java130 import com.google.ondevicepersonalization.federatedcompute.proto.TaskAssignment;
205 private static final TaskAssignment TASK_ASSIGNMENT =
206 TaskAssignment.newBuilder()
929 TaskAssignment.newBuilder() in testRunFLComputation_emptyTfliteGraph_returns()
997 TaskAssignment.newBuilder() in testRunFLComputation_withDataAvailability_returnsSuccess()
/aosp_15_r20/packages/modules/OnDevicePersonalization/federatedcompute/src/com/android/federatedcompute/services/scheduling/
DFederatedComputeJobManager.java54 import com.google.ondevicepersonalization.federatedcompute.proto.TaskAssignment;
384 int jobId, String populationName, TaskAssignment taskAssignment) { in recordSuccessContribution()
/aosp_15_r20/packages/modules/OnDevicePersonalization/tests/federatedcomputetests/src/com/android/federatedcompute/services/http/
DHttpFederatedProtocolTest.java95 import com.google.ondevicepersonalization.federatedcompute.proto.TaskAssignment;
1319 TaskAssignment taskAssignment = in createCreateTaskAssignmentResponse()
1320 TaskAssignment.newBuilder() in createCreateTaskAssignmentResponse()
/aosp_15_r20/packages/modules/OnDevicePersonalization/tests/federatedcomputetests/src/com/android/federatedcompute/services/scheduling/
DFederatedComputeJobManagerTest.java63 import com.google.ondevicepersonalization.federatedcompute.proto.TaskAssignment;
108 private static final TaskAssignment TASK_ASSIGNMENT =
109 TaskAssignment.newBuilder()

12