Home
last modified time | relevance | path

Searched refs:log_manager_ (Results 1 – 25 of 31) sorted by relevance

12

/external/federated-compute/fcp/client/cache/
Dfile_backed_resource_cache_test.cc88 testing::StrictMock<MockLogManager> log_manager_; member in fcp::client::cache::__anona45e61230111::FileBackedResourceCacheTest
98 log_manager_, in TEST_F()
101 FileBackedResourceCache::Create("/proc/0", root_cache_dir_, &log_manager_, in TEST_F()
107 EXPECT_CALL(log_manager_, in TEST_F()
110 FileBackedResourceCache::Create(root_files_dir_, "/proc/0", &log_manager_, in TEST_F()
116 EXPECT_CALL(log_manager_, in TEST_F()
119 &log_manager_, &clock_, in TEST_F()
126 log_manager_, in TEST_F()
129 &log_manager_, &clock_, in TEST_F()
136 &log_manager_, &clock_, in TEST_F()
[all …]
Dtemp_files_test.cc57 testing::StrictMock<MockLogManager> log_manager_; member in fcp::client::cache::__anon1c390cd80111::TempFilesTest
63 ASSERT_THAT(TempFiles::Create("/proc/0", &log_manager_), IsCode(INTERNAL)); in TEST_F()
67 ASSERT_THAT(TempFiles::Create("relative/cache", &log_manager_), in TEST_F()
72 ASSERT_OK(TempFiles::Create(root_dir_, &log_manager_)); in TEST_F()
76 auto temp_files = TempFiles::Create(root_dir_, &log_manager_); in TEST_F()
83 auto temp_files = TempFiles::Create(root_dir_, &log_manager_); in TEST_F()
109 auto temp_files = TempFiles::Create(root_dir_, &log_manager_); in TEST_F()
116 auto temp_files = TempFiles::Create(root_dir_, &log_manager_); in TEST_F()
127 EXPECT_CALL(log_manager_, in TEST_F()
Dfile_backed_resource_cache.cc63 log_manager_.LogDiag(ProdDiagCode::RESOURCE_CACHE_MANIFEST_READ_FAILED); in ReadInternal()
83 log_manager_.LogDiag(ProdDiagCode::RESOURCE_CACHE_MANIFEST_WRITE_FAILED); in WriteInternal()
193 log_manager_.LogDiag( in Put()
202 log_manager_.LogDiag(ProdDiagCode::RESOURCE_CACHE_RESOURCE_WRITE_FAILED); in Put()
217 log_manager_.LogDiag(diag_code); in Get()
241 log_manager_.LogDiag(ProdDiagCode::RESOURCE_CACHE_RESOURCE_READ_FAILED); in Get()
273 log_manager_.LogDiag( in Initialize()
283 log_manager_.LogDiag( in Initialize()
302 log_manager_.LogDiag(ProdDiagCode::RESOURCE_CACHE_INIT_FAILED_CLEANUP); in Initialize()
334 log_manager_.LogDiag( in CleanUp()
[all …]
Dtemp_files.h69 : temp_files_dir_(temp_files_dir), log_manager_(*log_manager) {} in TempFiles()
72 LogManager& log_manager_; variable
Dfile_backed_resource_cache.h102 log_manager_(*log_manager), in FileBackedResourceCache()
134 LogManager& log_manager_; variable
/external/federated-compute/fcp/client/opstats/
Dpds_backed_opstats_db_test.cc73 testing::StrictMock<MockLogManager> log_manager_; member in fcp::client::opstats::__anon0263debc0111::BasePdsBackedOpStatsDbTest
85 EXPECT_CALL(log_manager_, in TEST_F()
88 PdsBackedOpStatsDb::Create("/proc/0", ttl, log_manager_, size_limit), in TEST_F()
93 EXPECT_CALL(log_manager_, LogDiag(ProdDiagCode::OPSTATS_INVALID_FILE_PATH)); in TEST_F()
94 ASSERT_THAT(PdsBackedOpStatsDb::Create("relative/opstats", ttl, log_manager_, in TEST_F()
101 PdsBackedOpStatsDb::Create(base_dir_, ttl, log_manager_, size_limit); in TEST_F()
109 log_manager_, in TEST_F()
113 EXPECT_CALL(log_manager_, in TEST_F()
129 PdsBackedOpStatsDb::Create(base_dir_, ttl, log_manager_, size_limit); in TEST_F()
137 log_manager_, in TEST_F()
[all …]
Dopstats_logger_impl.cc41 : db_(std::move(db)), log_manager_(log_manager) { in OpStatsLoggerImpl()
42 log_manager_->LogDiag(DebugDiagCode::TRAINING_OPSTATS_ENABLED); in OpStatsLoggerImpl()
43 log_manager_->LogDiag(ProdDiagCode::OPSTATS_DB_COMMIT_EXPECTED); in OpStatsLoggerImpl()
112 log_manager_->LogDiag(ProdDiagCode::OPSTATS_DB_COMMIT_ATTEMPTED); in CommitToStorage()
133 log_manager_->LogToLongHistogram( in CommitToStorage()
Dpds_backed_opstats_db.cc261 auto data_or = ReadInternal(*db_, log_manager_); in Read()
264 auto reset_status = ResetInternal(*db_, log_manager_); in Read()
273 auto data_or = ReadInternal(*db_, log_manager_); in Transform()
276 FCP_RETURN_IF_ERROR(ResetInternal(*db_, log_manager_)); in Transform()
282 PruneOldDataUntilBelowSizeLimit(data, max_size_bytes_, log_manager_); in Transform()
290 log_manager_.LogDiag(ProdDiagCode::OPSTATS_WRITE_FAILED); in Transform()
Dopstats_example_store.h64 log_manager_(log_manager), in OpStatsExampleIteratorFactory()
79 LogManager* log_manager_; variable
Dopstats_example_store.cc183 log_manager_->LogDiag(ProdDiagCode::OPSTATS_INCORRECT_COLLECTION_URI); in CreateExampleIterator()
189 log_manager_->LogDiag( in CreateExampleIterator()
200 log_manager_->LogDiag(ProdDiagCode::OPSTATS_INVALID_SELECTION_CRITERIA); in CreateExampleIterator()
213 log_manager_->LogDiag(ProdDiagCode::OPSTATS_INVALID_SELECTION_CRITERIA); in CreateExampleIterator()
Dpds_backed_opstats_db.h73 log_manager_(log_manager), in PdsBackedOpStatsDb()
81 LogManager& log_manager_; variable
Dopstats_logger_impl.h104 LogManager* log_manager_; variable
/external/federated-compute/fcp/client/
Dfederated_select.cc61 : log_manager_(*log_manager) {} in DisabledFederatedSelectExampleIteratorFactory()
68 log_manager_.LogDiag( in CreateExampleIterator()
74 LogManager& log_manager_; member in fcp::client::__anonbf4d37310111::DisabledFederatedSelectExampleIteratorFactory
134 : log_manager_(*log_manager), in HttpFederatedSelectExampleIteratorFactory()
150 LogManager& log_manager_; member in fcp::client::__anonbf4d37310111::HttpFederatedSelectExampleIteratorFactory
171 log_manager_.LogDiag(ProdDiagCode::FEDSELECT_SLICE_HTTP_FETCH_REQUESTED); in CreateExampleIterator()
201 log_manager_.LogDiag(ProdDiagCode::FEDSELECT_SLICE_HTTP_FETCH_FAILED); in CreateExampleIterator()
206 log_manager_.LogDiag(ProdDiagCode::FEDSELECT_SLICE_HTTP_FETCH_SUCCEEDED); in CreateExampleIterator()
215 : log_manager_(*log_manager) {} in DisabledFederatedSelectManager()
221 &log_manager_); in CreateExampleIteratorFactoryForUriTemplate()
[all …]
Dinterruptible_runner.cc67 log_manager_->LogDiag(diagnostics_config_.interrupted); in Abort()
75 log_manager_->LogDiag(diagnostics_config_.interrupt_timeout); in Abort()
77 log_manager_->LogDiag(diagnostics_config_.interrupted_extended); in Abort()
89 log_manager_->LogDiag(diagnostics_config_.interrupt_timeout_extended); in Abort()
Dsecagg_runner.cc50 LogManager& log_manager_; member in fcp::client::SecAggStateTransitionListenerImpl
61 log_manager_(log_manager), in SecAggStateTransitionListenerImpl()
70 log_manager_.LogDiag(ProdDiagCode::SECAGG_CLIENT_NATIVE_ERROR_GENERIC); in Transition()
100 log_manager_(*log_manager), in SecAggRunnerImpl()
109 secagg_event_publisher_, log_manager_, *send_to_server_impl_, in Run()
197 log_manager_.LogDiag(ProdDiagCode::SECAGG_CLIENT_NATIVE_ERROR_GENERIC); in AbortInternal()
Dphase_logger_impl.cc54 log_manager_->SetModelIdentifier(std::string(model_identifier)); in SetModelIdentifier()
153 log_manager_->LogDiag( in LogEligibilityEvalCheckinInvalidPayloadError()
200 log_manager_->LogDiag( in LogEligibilityEvalComputationInvalidArgument()
261 log_manager_->LogToLongHistogram( in LogEligibilityEvalComputationCompleted()
264 log_manager_->LogToLongHistogram( in LogEligibilityEvalComputationCompleted()
330 log_manager_->LogDiag( in LogCheckinInvalidPayload()
379 log_manager_->LogDiag( in LogComputationInvalidArgument()
455 log_manager_->LogToLongHistogram( in LogComputationCompleted()
458 log_manager_->LogToLongHistogram( in LogComputationCompleted()
591 log_manager_->LogToLongHistogram(histogram_counter, in LogTimeSince()
Dinterruptible_runner.h63 : log_manager_(log_manager), in InterruptibleRunner()
85 LogManager* const log_manager_; variable
Dfederated_select.h100 LogManager& log_manager_;
124 LogManager& log_manager_;
Dgrpc_federated_protocol.cc149 log_manager_(log_manager), in GrpcFederatedProtocol()
289 log_manager_->LogDiag( in ReceiveCheckinRequestAck()
295 log_manager_->LogDiag( in ReceiveCheckinRequestAck()
804 log_manager_->LogDiag( in Report()
823 secagg_event_publisher, log_manager_, interruptible_runner_.get(), in Report()
971 log_manager_->LogDiag( in FetchTaskResources()
988 log_manager_->LogDiag( in FetchTaskResources()
997 log_manager_->LogDiag( in FetchTaskResources()
1020 log_manager_->LogDiag( in FetchTaskResources()
Dphase_logger_impl.h39 log_manager_(log_manager), in PhaseLoggerImpl()
207 LogManager* log_manager_; variable
/external/federated-compute/fcp/client/engine/
Dtflite_plan_engine.h51 log_manager_(log_manager), in TfLitePlanEngine()
70 LogManager* log_manager_; variable
Dtflite_plan_engine.cc79 log_manager_->LogDiag(ProdDiagCode::BACKGROUND_TRAINING_TFLITE_ENGINE_USED); in RunPlan()
136 TfLiteWrapper::Create(model, should_abort_, *timing_config_, log_manager_, in RunPlan()
Dsimple_plan_engine.cc50 log_manager_(log_manager), in SimplePlanEngine()
76 *timing_config_, log_manager_); in RunPlan()
/external/federated-compute/fcp/client/http/
Dhttp_federated_protocol.cc308 log_manager_(log_manager), in HttpFederatedProtocol()
511 log_manager_->LogDiag( in ReportEligibilityEvalError()
612 log_manager_->LogDiag( in PerformTaskAssignmentAndReportEligibilityEvalResultRequests()
819 log_manager_->LogDiag( in ReportViaSimpleAggregation()
875 log_manager_->LogDiag(ProdDiagCode::HTTP_REPORT_TASK_RESULT_REQUEST_FAILED); in PerformStartDataUploadRequestAndReportTaskResult()
1025 log_manager_, should_abort_, timing_config_, in AbortAggregation()
1064 this->log_manager_, this->should_abort_, this->timing_config_, in ReportViaSecureAggregation()
1077 log_manager_, should_abort_, timing_config_, in ReportViaSecureAggregation()
1089 secagg_event_publisher_, log_manager_, in ReportViaSecureAggregation()
1142 log_manager_->LogDiag(ProdDiagCode::HTTP_REPORT_TASK_RESULT_REQUEST_FAILED); in StartSecureAggregationAndReportTaskResult()
Din_memory_request_response_test.cc683 testing::StrictMock<MockLogManager> log_manager_; member in fcp::client::http::__anoncfb526e10111::PerformRequestsTest
1297 root_files_dir_, root_cache_dir_, &log_manager_, &clock_, in TEST_F()
1306 EXPECT_CALL(log_manager_, LogDiag(DebugDiagCode::RESOURCE_CACHE_HIT)); in TEST_F()
1334 root_files_dir_, root_cache_dir_, &log_manager_, &clock_, in TEST_F()
1343 EXPECT_CALL(log_manager_, LogDiag(DebugDiagCode::RESOURCE_CACHE_HIT)); in TEST_F()
1377 root_files_dir_, root_cache_dir_, &log_manager_, &clock_, in TEST_F()
1383 EXPECT_CALL(log_manager_, LogDiag(DebugDiagCode::RESOURCE_CACHE_MISS)); in TEST_F()
1396 EXPECT_CALL(log_manager_, LogDiag(DebugDiagCode::RESOURCE_CACHE_HIT)); in TEST_F()
1424 root_files_dir_, root_cache_dir_, &log_manager_, &clock_, in TEST_F()
1430 EXPECT_CALL(log_manager_, LogDiag(DebugDiagCode::RESOURCE_CACHE_MISS)); in TEST_F()
[all …]

12