xref: /aosp_15_r20/external/federated-compute/fcp/client/simple_task_environment.cc (revision 14675a029014e728ec732f129a32e299b2da0601)
1*14675a02SAndroid Build Coastguard Worker /*
2*14675a02SAndroid Build Coastguard Worker  * Copyright 2020 Google LLC
3*14675a02SAndroid Build Coastguard Worker  *
4*14675a02SAndroid Build Coastguard Worker  * Licensed under the Apache License, Version 2.0 (the "License");
5*14675a02SAndroid Build Coastguard Worker  * you may not use this file except in compliance with the License.
6*14675a02SAndroid Build Coastguard Worker  * You may obtain a copy of the License at
7*14675a02SAndroid Build Coastguard Worker  *
8*14675a02SAndroid Build Coastguard Worker  *      http://www.apache.org/licenses/LICENSE-2.0
9*14675a02SAndroid Build Coastguard Worker  *
10*14675a02SAndroid Build Coastguard Worker  * Unless required by applicable law or agreed to in writing, software
11*14675a02SAndroid Build Coastguard Worker  * distributed under the License is distributed on an "AS IS" BASIS,
12*14675a02SAndroid Build Coastguard Worker  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13*14675a02SAndroid Build Coastguard Worker  * See the License for the specific language governing permissions and
14*14675a02SAndroid Build Coastguard Worker  * limitations under the License.
15*14675a02SAndroid Build Coastguard Worker  */
16*14675a02SAndroid Build Coastguard Worker #include "fcp/client/simple_task_environment.h"
17*14675a02SAndroid Build Coastguard Worker 
18*14675a02SAndroid Build Coastguard Worker namespace fcp {
19*14675a02SAndroid Build Coastguard Worker namespace client {
20*14675a02SAndroid Build Coastguard Worker 
ShouldAbort(absl::Time current_time,absl::Duration condition_polling_period)21*14675a02SAndroid Build Coastguard Worker bool SimpleTaskEnvironment::ShouldAbort(
22*14675a02SAndroid Build Coastguard Worker     absl::Time current_time, absl::Duration condition_polling_period) {
23*14675a02SAndroid Build Coastguard Worker   if (current_time - last_training_conditions_fetch_timestamp_ <
24*14675a02SAndroid Build Coastguard Worker       condition_polling_period) {
25*14675a02SAndroid Build Coastguard Worker     return false;
26*14675a02SAndroid Build Coastguard Worker   } else {
27*14675a02SAndroid Build Coastguard Worker     last_training_conditions_fetch_timestamp_ = current_time;
28*14675a02SAndroid Build Coastguard Worker   }
29*14675a02SAndroid Build Coastguard Worker   return !TrainingConditionsSatisfied();
30*14675a02SAndroid Build Coastguard Worker }
31*14675a02SAndroid Build Coastguard Worker 
32*14675a02SAndroid Build Coastguard Worker }  // namespace client
33*14675a02SAndroid Build Coastguard Worker }  // namespace fcp
34