Home
last modified time | relevance | path

Searched refs:asyncFetchStatus (Results 1 – 9 of 9) sorted by relevance

/packages/modules/AdServices/adservices/tests/unittest/service-core/measurement/src/com/android/adservices/service/measurement/registration/
DAsyncSourceFetcherTest.java300 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in testBasicSourceRequest() local
301 asyncFetchStatus.setRegistrationDelay(0L); in testBasicSourceRequest()
305 mFetcher.fetchSource(asyncRegistration, asyncFetchStatus, asyncRedirects); in testBasicSourceRequest()
307 assertEquals(AsyncFetchStatus.ResponseStatus.SUCCESS, asyncFetchStatus.getResponseStatus()); in testBasicSourceRequest()
326 asyncFetchStatus, in testBasicSourceRequest()
396 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in testBasicSourceRequest_skipSourceWhenNotEnrolled() local
400 appSourceRegistrationRequest(request), asyncFetchStatus, asyncRedirects); in testBasicSourceRequest_skipSourceWhenNotEnrolled()
405 assertEquals(AsyncFetchStatus.ResponseStatus.SUCCESS, asyncFetchStatus.getResponseStatus()); in testBasicSourceRequest_skipSourceWhenNotEnrolled()
413 asyncFetchStatus.getEntityStatus()); in testBasicSourceRequest_skipSourceWhenNotEnrolled()
442 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in fetchSource_multipleWebDestinations_success() local
[all …]
DAsyncTriggerFetcherTest.java344 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in testBasicTriggerRequest() local
345 asyncFetchStatus.setRegistrationDelay(0L); in testBasicTriggerRequest()
349 mFetcher.fetchTrigger(asyncRegistration, asyncFetchStatus, asyncRedirects); in testBasicTriggerRequest()
351 assertEquals(AsyncFetchStatus.ResponseStatus.SUCCESS, asyncFetchStatus.getResponseStatus()); in testBasicTriggerRequest()
365 asyncFetchStatus, in testBasicTriggerRequest()
433 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in testBasicTriggerRequest_withAggregateDeduplicationKey() local
434 asyncFetchStatus.setRegistrationDelay(0L); in testBasicTriggerRequest_withAggregateDeduplicationKey()
438 mFetcher.fetchTrigger(asyncRegistration, asyncFetchStatus, asyncRedirects); in testBasicTriggerRequest_withAggregateDeduplicationKey()
440 assertEquals(AsyncFetchStatus.ResponseStatus.SUCCESS, asyncFetchStatus.getResponseStatus()); in testBasicTriggerRequest_withAggregateDeduplicationKey()
457 asyncFetchStatus, in testBasicTriggerRequest_withAggregateDeduplicationKey()
[all …]
DAsyncRegistrationQueueRunnerTest.java338 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in test_runAsyncRegistrationQueueWorker_appSource_success()
339 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in test_runAsyncRegistrationQueueWorker_appSource_success()
405 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in test_runAsyncRegistrationQueueWorker_emptyNoisedState_sendsDebugReport()
406 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in test_runAsyncRegistrationQueueWorker_emptyNoisedState_sendsDebugReport()
468 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in test_runAsyncRegistrationQueueWorker_nullFakeReports_doesNotSendDebugReport()
469 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in test_runAsyncRegistrationQueueWorker_nullFakeReports_doesNotSendDebugReport()
523 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in test_runAsyncRegistrationQueueWorker_ThreadInterrupted()
524 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in test_runAsyncRegistrationQueueWorker_ThreadInterrupted()
571 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in testRecordsExceedMaxRegistrationsPerJob_returnSuccessWithPendingRecords()
572 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in testRecordsExceedMaxRegistrationsPerJob_returnSuccessWithPendingRecords()
[all …]
DFetcherUtilTest.java1484 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain() local
1485 asyncFetchStatus.setRegistrationDelay(0L); in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain()
1486 asyncFetchStatus.setResponseSize(FetcherUtil.calculateHeadersCharactersLength(headersMap)); in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain()
1489 maxAllowedHeadersSize, mLogger, asyncRegistration, asyncFetchStatus, ENROLLMENT_ID); in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain()
1535 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain() local
1536 asyncFetchStatus.setRegistrationDelay(0L); in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain()
1537 asyncFetchStatus.setResponseSize(FetcherUtil.calculateHeadersCharactersLength(headersMap)); in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain()
1540 maxAllowedHeadersSize, mLogger, asyncRegistration, asyncFetchStatus, ENROLLMENT_ID); in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain()
1589 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in emitHeaderMetrics_headersWithNullValues_success() local
1590 asyncFetchStatus.setRegistrationDelay(0L); in emitHeaderMetrics_headersWithNullValues_success()
[all …]
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/registration/
DFetcherUtil.java643 AsyncFetchStatus asyncFetchStatus, in emitHeaderMetrics() argument
645 long headerSize = asyncFetchStatus.getResponseSize(); in emitHeaderMetrics()
662 getStatus(asyncFetchStatus), in emitHeaderMetrics()
663 getFailureType(asyncFetchStatus), in emitHeaderMetrics()
664 asyncFetchStatus.getRegistrationDelay(), in emitHeaderMetrics()
666 asyncFetchStatus.getRetryCount(), in emitHeaderMetrics()
667 asyncFetchStatus.isRedirectOnly(), in emitHeaderMetrics()
668 asyncFetchStatus.isPARequest(), in emitHeaderMetrics()
669 asyncFetchStatus.getNumDeletedEntities(), in emitHeaderMetrics()
670 asyncFetchStatus.isEventLevelEpsilonConfigured(), in emitHeaderMetrics()
[all …]
DAsyncRegistrationQueueRunner.java270 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in processSourceRegistration() local
275 asyncRegistration, asyncFetchStatus, asyncRedirects); in processSourceRegistration()
277 asyncFetchStatus.setRegistrationDelay(endTime - startTime); in processSourceRegistration()
282 if (asyncFetchStatus.isRequestSuccess()) { in processSourceRegistration()
297 asyncFetchStatus); in processSourceRegistration()
300 asyncRegistration, asyncFetchStatus, asyncRedirects, dao); in processSourceRegistration()
303 asyncRegistration, asyncFetchStatus, failedOrigins, dao); in processSourceRegistration()
308 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.STORAGE_ERROR); in processSourceRegistration()
311 asyncFetchStatus.setRetryCount(Long.valueOf(asyncRegistration.getRetryCount()).intValue()); in processSourceRegistration()
316 asyncFetchStatus, in processSourceRegistration() local
[all …]
DAsyncTriggerFetcher.java129 AsyncFetchStatus asyncFetchStatus) { in parseTrigger() argument
178 asyncFetchStatus.setEntityStatus(EntityStatus.HEADER_ERROR); in parseTrigger()
208 asyncFetchStatus); in parseTrigger()
210 asyncFetchStatus.setEntityStatus(EntityStatus.VALIDATION_ERROR); in parseTrigger()
232 asyncFetchStatus.setEntityStatus(EntityStatus.SUCCESS); in parseTrigger()
235 asyncFetchStatus.setEntityStatus(EntityStatus.PARSING_ERROR); in parseTrigger()
256 asyncFetchStatus.setEntityStatus(EntityStatus.VALIDATION_ERROR); in parseTrigger()
351 AsyncFetchStatus asyncFetchStatus, in fetchTrigger() argument
360 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.INVALID_URL); in fetchTrigger()
392 asyncFetchStatus.setResponseStatus( in fetchTrigger()
[all …]
DAsyncSourceFetcher.java128 AsyncFetchStatus asyncFetchStatus) in parseValidateSource() argument
697 asyncFetchStatus.setIsEventLevelEpsilonConfigured(true); in parseValidateSource()
1077 AsyncFetchStatus asyncFetchStatus) { in parseSource() argument
1126 asyncFetchStatus.setEntityStatus(EntityStatus.HEADER_ERROR); in parseSource()
1158 asyncFetchStatus); in parseSource()
1160 asyncFetchStatus.setEntityStatus(EntityStatus.VALIDATION_ERROR); in parseSource()
1184 asyncFetchStatus.setEntityStatus(EntityStatus.SUCCESS); in parseSource()
1187 asyncFetchStatus.setEntityStatus(EntityStatus.PARSING_ERROR); in parseSource()
1208 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.VALIDATION_ERROR); in parseSource()
1246 AsyncFetchStatus asyncFetchStatus, in fetchSource() argument
[all …]
DSourceEligibilityChecker.java81 AsyncFetchStatus asyncFetchStatus, in isAllowedToInsert() argument
232 asyncFetchStatus); in isAllowedToInsert()
257 asyncFetchStatus); in isAllowedToInsert()
579 AsyncFetchStatus asyncFetchStatus) in deleteLowPriorityDestinationSourcesToAccommodateNewSource() argument
656 asyncFetchStatus.incrementNumDeletedEntities(sourceIdsToDelete.size()); in deleteLowPriorityDestinationSourcesToAccommodateNewSource()