Home
last modified time | relevance | path

Searched refs:getBlockingExecutor (Results 1 – 25 of 64) sorted by relevance

123

/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/adselection/
DMultiCloudSupportStrategyFactory.java79 AdServicesExecutors.getBlockingExecutor(), in getProtectedServersEncryptionConfigManager()
126 AdServicesExecutors.getBlockingExecutor(), in getProtectedServersEncryptionConfigManager()
DDebugReportSenderWorker.java96 AdServicesExecutors.getBlockingExecutor(), in getInstance()
181 .call(() -> null, AdServicesExecutors.getBlockingExecutor());
DDebugReportSenderStrategyNoOp.java60 }, AdServicesExecutors.getBlockingExecutor()); in flush()
DDebugReportSenderStrategyHttpImpl.java80 AdServicesExecutors.getBlockingExecutor()); in flush()
/packages/modules/OnDevicePersonalization/federatedcompute/src/com/android/federatedcompute/services/http/
DHttpClient.java19 … static com.android.federatedcompute.services.common.FederatedComputeExecutors.getBlockingExecutor;
76 return getBlockingExecutor().submit(() -> performRequestWithRetry(request)); in performRequestAsyncWithRetry()
/packages/modules/OnDevicePersonalization/src/com/android/ondevicepersonalization/services/download/mdd/
DOnDevicePersonalizationFileDownloader.java98 .withIOExecutor(OnDevicePersonalizationExecutors.getBlockingExecutor()) in getOffroad2FileDownloader()
134 OnDevicePersonalizationExecutors.getBlockingExecutor(), in getUrlEngine()
/packages/modules/AdServices/adservices/tests/unittest/framework/src/android/adservices/common/
DAssetFileDescriptorUtilTests.java34 AdServicesExecutors.getBlockingExecutor();
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/adselection/encryption/
DObliviousHttpEncryptorFactory.java39 AdServicesExecutors.getBlockingExecutor(), in getKAnonObliviousHttpEncryptor()
/packages/modules/OnDevicePersonalization/tests/servicetests/src/com/android/ondevicepersonalization/services/
DOnDevicePersonalizationExecutorsTests.java65 OnDevicePersonalizationExecutors.getBlockingExecutor().submit(task).get(); in testBlockingExecutorSettings()
/packages/modules/OnDevicePersonalization/tests/federatedcomputetests/src/com/android/federatedcompute/services/common/
DFederatedComputeExecutorsTest.java74 FederatedComputeExecutors.getBlockingExecutor().submit(task).get(); in testBlockingExecutorSettings()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/kanon/
DKAnonSignJoinFactory.java56 AdServicesExecutors.getBlockingExecutor(), in getKAnonSignJoinManager()
/packages/modules/OnDevicePersonalization/federatedcompute/src/com/android/federatedcompute/services/common/
DFederatedComputeExecutors.java93 public static ListeningExecutorService getBlockingExecutor() { in getBlockingExecutor() method in FederatedComputeExecutors
/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/concurrency/
DAdServicesExecutorTest.java77 runTaskAndAssertResult(AdServicesExecutors.getBlockingExecutor(), expectedResult); in testCreateBlockingThreadSuccess()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/concurrency/
DAdServicesExecutors.java189 public static ListeningExecutorService getBlockingExecutor() {
/packages/modules/OnDevicePersonalization/src/com/android/ondevicepersonalization/services/
DOnDevicePersonalizationExecutors.java127 public static ListeningExecutorService getBlockingExecutor() { in getBlockingExecutor() method in OnDevicePersonalizationExecutors
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/registration/
DAsyncRegistrationFallbackJob.java65 AdServicesExecutors.getBlockingExecutor()); in getExecutionFuture()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/encryptionkey/
DEncryptionKeyJobService.java47 AdServicesExecutors.getBlockingExecutor();
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/reporting/
DVerboseDebugReportingJobService.java52 AdServicesExecutors.getBlockingExecutor();
DEventFallbackReportingJobService.java57 AdServicesExecutors.getBlockingExecutor();
DDebugReportingJobService.java53 AdServicesExecutors.getBlockingExecutor();
DVerboseDebugReportingFallbackJobService.java60 AdServicesExecutors.getBlockingExecutor();
DEventReportingJobService.java55 AdServicesExecutors.getBlockingExecutor();
/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/common/
DSingletonRunnerTest.java34 AdServicesExecutors.getBlockingExecutor();
/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/adselection/
DAdOutcomeSelectorImplTest.java120 mBlockingExecutorService = AdServicesExecutors.getBlockingExecutor(); in setup()
124 AdServicesExecutors.getBlockingExecutor(), in setup()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/download/
DMobileDataDownloadFactory.java196 AdServicesExecutors.getBlockingExecutor(), in getUrlEngine()
211 .withIOExecutor(AdServicesExecutors.getBlockingExecutor()) in getFileDownloader()

123