Home
last modified time | relevance | path

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

/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/measurement/registration/
DAsyncSourceFetcherTest.java291 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in testBasicSourceRequest() local
292 asyncFetchStatus.setRegistrationDelay(0L); in testBasicSourceRequest()
296 mFetcher.fetchSource(asyncRegistration, asyncFetchStatus, asyncRedirects); in testBasicSourceRequest()
298 assertEquals(AsyncFetchStatus.ResponseStatus.SUCCESS, asyncFetchStatus.getResponseStatus()); in testBasicSourceRequest()
317 asyncFetchStatus); in testBasicSourceRequest()
379 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in testBasicSourceRequest_skipSourceWhenNotEnrolled() local
383 appSourceRegistrationRequest(request), asyncFetchStatus, asyncRedirects); in testBasicSourceRequest_skipSourceWhenNotEnrolled()
388 assertEquals(AsyncFetchStatus.ResponseStatus.SUCCESS, asyncFetchStatus.getResponseStatus()); in testBasicSourceRequest_skipSourceWhenNotEnrolled()
396 asyncFetchStatus.getEntityStatus()); in testBasicSourceRequest_skipSourceWhenNotEnrolled()
424 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in fetchSource_multipleWebDestinations_success() local
[all …]
DAsyncTriggerFetcherTest.java311 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in testBasicTriggerRequest() local
312 asyncFetchStatus.setRegistrationDelay(0L); in testBasicTriggerRequest()
316 mFetcher.fetchTrigger(asyncRegistration, asyncFetchStatus, asyncRedirects); in testBasicTriggerRequest()
318 assertEquals(AsyncFetchStatus.ResponseStatus.SUCCESS, asyncFetchStatus.getResponseStatus()); in testBasicTriggerRequest()
332 asyncFetchStatus); in testBasicTriggerRequest()
392 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in testBasicTriggerRequest_withAggregateDeduplicationKey() local
393 asyncFetchStatus.setRegistrationDelay(0L); in testBasicTriggerRequest_withAggregateDeduplicationKey()
397 mFetcher.fetchTrigger(asyncRegistration, asyncFetchStatus, asyncRedirects); in testBasicTriggerRequest_withAggregateDeduplicationKey()
399 assertEquals(AsyncFetchStatus.ResponseStatus.SUCCESS, asyncFetchStatus.getResponseStatus()); in testBasicTriggerRequest_withAggregateDeduplicationKey()
416 asyncFetchStatus); in testBasicTriggerRequest_withAggregateDeduplicationKey()
[all …]
DAsyncRegistrationQueueRunnerTest.java328 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in test_runAsyncRegistrationQueueWorker_appSource_success()
329 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in test_runAsyncRegistrationQueueWorker_appSource_success()
382 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in test_runAsyncRegistrationQueueWorker_emptyNoisedState_sendsDebugReport()
383 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in test_runAsyncRegistrationQueueWorker_emptyNoisedState_sendsDebugReport()
434 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in test_runAsyncRegistrationQueueWorker_nullFakeReports_doesNotSendDebugReport()
435 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in test_runAsyncRegistrationQueueWorker_nullFakeReports_doesNotSendDebugReport()
485 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in test_runAsyncRegistrationQueueWorker_ThreadInterrupted()
486 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in test_runAsyncRegistrationQueueWorker_ThreadInterrupted()
533 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in testRecordsExceedMaxRegistrationsPerJob_returnSuccessWithPendingRecords()
534 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in testRecordsExceedMaxRegistrationsPerJob_returnSuccessWithPendingRecords()
[all …]
DFetcherUtilTest.java1018 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain() local
1019 asyncFetchStatus.setRegistrationDelay(0L); in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain()
1020 asyncFetchStatus.setResponseSize(FetcherUtil.calculateHeadersCharactersLength(headersMap)); in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain()
1023 maxAllowedHeadersSize, mLogger, asyncRegistration, asyncFetchStatus); in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain()
1063 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain() local
1064 asyncFetchStatus.setRegistrationDelay(0L); in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain()
1065 asyncFetchStatus.setResponseSize(FetcherUtil.calculateHeadersCharactersLength(headersMap)); in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain()
1068 maxAllowedHeadersSize, mLogger, asyncRegistration, asyncFetchStatus); in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain()
1111 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in emitHeaderMetrics_headersWithNullValues_success() local
1112 asyncFetchStatus.setRegistrationDelay(0L); in emitHeaderMetrics_headersWithNullValues_success()
[all …]
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/registration/
DFetcherUtil.java376 AsyncFetchStatus asyncFetchStatus) { in emitHeaderMetrics() argument
377 long headerSize = asyncFetchStatus.getResponseSize(); in emitHeaderMetrics()
394 getStatus(asyncFetchStatus), in emitHeaderMetrics()
395 getFailureType(asyncFetchStatus), in emitHeaderMetrics()
396 asyncFetchStatus.getRegistrationDelay(), in emitHeaderMetrics()
398 asyncFetchStatus.getRetryCount(), in emitHeaderMetrics()
399 asyncFetchStatus.isRedirectOnly(), in emitHeaderMetrics()
400 asyncFetchStatus.isPARequest()) in emitHeaderMetrics()
477 private static int getStatus(AsyncFetchStatus asyncFetchStatus) { in getStatus() argument
478 if (asyncFetchStatus.getEntityStatus() == AsyncFetchStatus.EntityStatus.SUCCESS in getStatus()
[all …]
DAsyncTriggerFetcher.java120 AsyncFetchStatus asyncFetchStatus) { in parseTrigger() argument
159 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.HEADER_ERROR); in parseTrigger()
176 asyncFetchStatus.setEntityStatus( in parseTrigger()
188 asyncFetchStatus.setEntityStatus( in parseTrigger()
197 asyncFetchStatus.setEntityStatus( in parseTrigger()
212 asyncFetchStatus.setEntityStatus( in parseTrigger()
224 asyncFetchStatus.setEntityStatus( in parseTrigger()
237 asyncFetchStatus.setEntityStatus( in parseTrigger()
282 asyncFetchStatus.setEntityStatus( in parseTrigger()
323 asyncFetchStatus.setEntityStatus( in parseTrigger()
[all …]
DAsyncRegistrationQueueRunner.java250 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in processSourceRegistration() local
255 asyncRegistration, asyncFetchStatus, asyncRedirects); in processSourceRegistration()
257 asyncFetchStatus.setRegistrationDelay(endTime - startTime); in processSourceRegistration()
262 if (asyncFetchStatus.isRequestSuccess()) { in processSourceRegistration()
267 asyncRegistration, asyncFetchStatus, asyncRedirects, dao); in processSourceRegistration()
270 asyncRegistration, asyncFetchStatus, failedOrigins, dao); in processSourceRegistration()
275 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.STORAGE_ERROR); in processSourceRegistration()
278 asyncFetchStatus.setRetryCount(Long.valueOf(asyncRegistration.getRetryCount()).intValue()); in processSourceRegistration()
283 asyncFetchStatus); in processSourceRegistration() local
328 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in processTriggerRegistration() local
[all …]
DAsyncSourceFetcher.java765 AsyncFetchStatus asyncFetchStatus) { in parseSource() argument
802 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.HEADER_ERROR); in parseSource()
816 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.VALIDATION_ERROR); in parseSource()
822 asyncFetchStatus.setEntityStatus( in parseSource()
847 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.SUCCESS); in parseSource()
852 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.PARSING_ERROR); in parseSource()
871 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.VALIDATION_ERROR); in parseSource()
892 AsyncFetchStatus asyncFetchStatus, in fetchSource() argument
898 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.INVALID_URL); in fetchSource()
913 asyncFetchStatus.setPARequestStatus(true); in fetchSource()
[all …]