Searched refs:failedOrigins (Results 1 – 3 of 3) sorted by relevance
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/registration/ |
| D | AsyncRegistrationQueueRunner.java | 181 Set<Uri> failedOrigins = new HashSet<>(); in runAsyncRegistrationQueueWorker() local
194 AsyncRegistration asyncRegistration = fetchNext(retryLimit, failedOrigins); in runAsyncRegistrationQueueWorker()
201 processAsyncRecord(asyncRegistration, failedOrigins); in runAsyncRegistrationQueueWorker()
204 return hasPendingRecords(retryLimit, failedOrigins); in runAsyncRegistrationQueueWorker()
207 private AsyncRegistration fetchNext(int retryLimit, Set<Uri> failedOrigins) { in fetchNext() argument
210 (dao) -> dao.fetchNextQueuedAsyncRegistration(retryLimit, failedOrigins)) in fetchNext()
214 private void processAsyncRecord(AsyncRegistration asyncRegistration, Set<Uri> failedOrigins) { in processAsyncRecord() argument
218 processSourceRegistration(asyncRegistration, failedOrigins); in processAsyncRecord()
222 processTriggerRegistration(asyncRegistration, failedOrigins); in processAsyncRecord()
226 private ProcessingResult hasPendingRecords(int retryLimit, Set<Uri> failedOrigins) { in hasPendingRecords() argument
[all …]
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/data/measurement/ |
| D | IMeasurementDao.java | 555 AsyncRegistration fetchNextQueuedAsyncRegistration(int retryLimit, Set<Uri> failedOrigins) in fetchNextQueuedAsyncRegistration() argument
|
| D | MeasurementDao.java | 3159 int retryLimit, Set<Uri> failedOrigins) throws DatastoreException {
3162 if (!failedOrigins.isEmpty()) {
3164 failedOrigins.forEach(
|