Home
last modified time | relevance | path

Searched defs:log_manager (Results 1 – 25 of 25) sorted by relevance

/aosp_15_r20/external/federated-compute/fcp/client/opstats/
H A Dpds_backed_opstats_db.cc53 LogManager& log_manager) { in AcquireFileLock()
104 protostore::ProtoDataStore<OpStatsSequence>& db, LogManager& log_manager) { in ReadInternal()
118 LogManager& log_manager) { in ResetInternal()
171 LogManager& log_manager) { in PruneOldDataUntilBelowSizeLimit()
208 const std::string& base_dir, absl::Duration ttl, LogManager& log_manager, in Create()
H A Dpds_backed_opstats_db.h68 LogManager& log_manager, int64_t max_size_bytes, in PdsBackedOpStatsDb()
H A Dopstats_example_store.h61 OpStatsLogger* op_stats_logger, LogManager* log_manager, in OpStatsExampleIteratorFactory()
H A Dopstats_logger_impl.cc37 LogManager* log_manager, in OpStatsLoggerImpl()
/aosp_15_r20/external/federated-compute/fcp/client/
H A Dfederated_select.cc60 LogManager* log_manager) in DisabledFederatedSelectExampleIteratorFactory()
129 LogManager* log_manager, Files* files, HttpClient* http_client, in HttpFederatedSelectExampleIteratorFactory()
214 LogManager* log_manager) in DisabledFederatedSelectManager()
225 LogManager* log_manager, Files* files, in HttpFederatedSelectManager()
H A Dfl_runner.cc291 std::function<bool()> should_abort, LogManager* log_manager, in RunEligibilityEvalPlanWithTensorflowSpec()
432 std::function<bool()> should_abort, LogManager* log_manager, in RunPlanWithTensorflowSpec()
744 LogManager* log_manager, OpStatsLogger* opstats_logger, const Flags* flags, in RunEligibilityEvalPlan()
851 LogManager* log_manager, OpStatsLogger* opstats_logger, const Flags* flags, in IssueEligibilityEvalCheckinAndRunPlan()
1018 PhaseLogger& phase_logger, LogManager* log_manager, Files* files, in IssueCheckin()
1206 Files* files, LogManager* log_manager, const Flags* flags, in RunFederatedComputation()
1323 EventPublisher* event_publisher, Files* files, LogManager* log_manager, in RunFederatedComputation()
1546 Files* files, LogManager* log_manager, const Flags* flags, in RunPlanWithTensorflowSpecForTesting()
H A Dsecagg_runner.cc57 SecAggEventPublisher& secagg_event_publisher, LogManager& log_manager, in SecAggStateTransitionListenerImpl()
93 SecAggEventPublisher* secagg_event_publisher, LogManager* log_manager, in SecAggRunnerImpl()
213 SecAggEventPublisher* secagg_event_publisher, LogManager* log_manager, in CreateSecAggRunner()
H A Dlc_runner.cc188 std::function<bool()> should_abort, LogManager* log_manager, in RunPlanWithTensorflowSpec()
270 LogManager* log_manager, const Flags* flags, in RunLocalComputation()
297 LogManager* log_manager, OpStatsLogger* opstats_logger, const Flags* flags, in RunLocalComputation()
H A Dinterruptible_runner_test.cc163 StrictMock<MockLogManager> log_manager; in TEST() local
209 StrictMock<MockLogManager> log_manager; in TEST() local
H A Dfcp_runner.cc165 std::function<bool()> should_abort, LogManager* log_manager, in RunPlanWithTensorflowSpec()
217 SimpleTaskEnvironment* env_deps, LogManager* log_manager, in RunFederatedComputation()
H A Dgrpc_federated_protocol.cc117 EventPublisher* event_publisher, LogManager* log_manager, in GrpcFederatedProtocol()
138 EventPublisher* event_publisher, LogManager* log_manager, in GrpcFederatedProtocol()
H A Dphase_logger_impl.h36 LogManager* log_manager, const Flags* flags) in PhaseLoggerImpl()
H A Dfederated_protocol_util.cc102 LogManager& log_manager) { in ExtractTaskNameFromAggregationSessionId()
H A Dinterruptible_runner.h59 InterruptibleRunner(LogManager* log_manager, in InterruptibleRunner()
/aosp_15_r20/external/federated-compute/fcp/client/http/
H A Dhttp_federated_protocol.cc275 LogManager* log_manager, std::function<bool()> should_abort, in CreateDelayedInterruptibleRunner()
296 Clock* clock, LogManager* log_manager, const Flags* flags, in HttpFederatedProtocol()
/aosp_15_r20/external/federated-compute/fcp/client/cache/
H A Dtemp_files.h68 TempFiles(std::filesystem::path temp_files_dir, LogManager* log_manager) in TempFiles()
H A Dfile_backed_resource_cache.h97 LogManager* log_manager, Clock* clock, const int64_t max_cache_size_bytes) in FileBackedResourceCache()
H A Dtemp_files.cc61 const std::string& cache_dir, LogManager* log_manager) { in Create()
H A Dfile_backed_resource_cache.cc102 LogManager* log_manager, fcp::Clock* clock, in Create()
/aosp_15_r20/external/federated-compute/fcp/client/engine/
H A Dtf_wrapper.h80 LogManager* log_manager) in TensorFlowWrapper()
H A Dtflite_plan_engine.h46 std::function<bool()> should_abort, LogManager* log_manager, in TfLitePlanEngine()
H A Dtf_wrapper.cc87 LogManager* log_manager) { in Create()
H A Dtflite_wrapper.cc62 LogManager* log_manager, in Create()
H A Dsimple_plan_engine.cc44 std::function<bool()> should_abort, LogManager* log_manager, in SimplePlanEngine()
H A Dplan_engine_helpers.cc229 const std::string& base_dir, const Flags* flags, LogManager* log_manager, in CreateOpStatsLogger()