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.java229 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in testBasicSourceRequest() local
230 asyncFetchStatus.setRegistrationDelay(0L); in testBasicSourceRequest()
234 mFetcher.fetchSource(asyncRegistration, asyncFetchStatus, asyncRedirect); in testBasicSourceRequest()
236 assertEquals(AsyncFetchStatus.ResponseStatus.SUCCESS, asyncFetchStatus.getResponseStatus()); in testBasicSourceRequest()
251 FetcherUtil.emitHeaderMetrics(mFlags, mLogger, asyncRegistration, asyncFetchStatus); in testBasicSourceRequest()
304 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in testBasicSourceRequest_skipSourceWhenNotEnrolled() local
308 appSourceRegistrationRequest(request), asyncFetchStatus, asyncRedirect); in testBasicSourceRequest_skipSourceWhenNotEnrolled()
313 assertEquals(AsyncFetchStatus.ResponseStatus.SUCCESS, asyncFetchStatus.getResponseStatus()); in testBasicSourceRequest_skipSourceWhenNotEnrolled()
320 asyncFetchStatus.getEntityStatus()); in testBasicSourceRequest_skipSourceWhenNotEnrolled()
345 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in fetchSource_multipleWebDestinations_success() local
[all …]
DAsyncTriggerFetcherTest.java228 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in testBasicTriggerRequest() local
229 asyncFetchStatus.setRegistrationDelay(0L); in testBasicTriggerRequest()
233 mFetcher.fetchTrigger(asyncRegistration, asyncFetchStatus, asyncRedirect); in testBasicTriggerRequest()
235 assertEquals(AsyncFetchStatus.ResponseStatus.SUCCESS, asyncFetchStatus.getResponseStatus()); in testBasicTriggerRequest()
245 FetcherUtil.emitHeaderMetrics(mFlags, mLogger, asyncRegistration, asyncFetchStatus); in testBasicTriggerRequest()
302 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in testBasicTriggerRequest_withAggregateDeduplicationKey() local
303 asyncFetchStatus.setRegistrationDelay(0L); in testBasicTriggerRequest_withAggregateDeduplicationKey()
307 mFetcher.fetchTrigger(asyncRegistration, asyncFetchStatus, asyncRedirect); in testBasicTriggerRequest_withAggregateDeduplicationKey()
309 assertEquals(AsyncFetchStatus.ResponseStatus.SUCCESS, asyncFetchStatus.getResponseStatus()); in testBasicTriggerRequest_withAggregateDeduplicationKey()
322 FetcherUtil.emitHeaderMetrics(mFlags, mLogger, asyncRegistration, asyncFetchStatus); in testBasicTriggerRequest_withAggregateDeduplicationKey()
[all …]
DAsyncRegistrationQueueRunnerTest.java246 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in test_runAsyncRegistrationQueueWorker_appSource_success()
247 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in test_runAsyncRegistrationQueueWorker_appSource_success()
307 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in runAsyncRegistrationQueueWorker_appSource_defaultRegistration_redirectTypeList()
308 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in runAsyncRegistrationQueueWorker_appSource_defaultRegistration_redirectTypeList()
381 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in runAsyncRegistrationQueueWorker_appSource_defaultRegistration_redirectTypeLocation()
382 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in runAsyncRegistrationQueueWorker_appSource_defaultRegistration_redirectTypeLocation()
445 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in runAsyncRegistrationQueueWorker_appSource_middleRegistration_redirectTypeLocation()
446 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in runAsyncRegistrationQueueWorker_appSource_middleRegistration_redirectTypeLocation()
510 AsyncFetchStatus asyncFetchStatus = invocation.getArgument(1); in runAsyncRegistrationQueueWorker_appTrigger_defaultRegistration_redirectTypeList()
511 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in runAsyncRegistrationQueueWorker_appTrigger_defaultRegistration_redirectTypeList()
[all …]
DFetcherUtilTest.java373 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain() local
374 asyncFetchStatus.setRegistrationDelay(0L); in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain()
375 asyncFetchStatus.setResponseSize(FetcherUtil.calculateHeadersCharactersLength(headersMap)); in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain()
377 FetcherUtil.emitHeaderMetrics(mFlags, mLogger, asyncRegistration, asyncFetchStatus); in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain()
415 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain() local
416 asyncFetchStatus.setRegistrationDelay(0L); in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain()
417 asyncFetchStatus.setResponseSize(FetcherUtil.calculateHeadersCharactersLength(headersMap)); in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain()
419 FetcherUtil.emitHeaderMetrics(mFlags, mLogger, asyncRegistration, asyncFetchStatus); in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain()
460 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in emitHeaderMetrics_headersWithNullValues_success() local
461 asyncFetchStatus.setRegistrationDelay(0L); in emitHeaderMetrics_headersWithNullValues_success()
[all …]
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/registration/
DFetcherUtil.java164 AsyncFetchStatus asyncFetchStatus) { in emitHeaderMetrics() argument
166 if (asyncFetchStatus.getResponseSize().isPresent()) { in emitHeaderMetrics()
167 headerSize = asyncFetchStatus.getResponseSize().get(); in emitHeaderMetrics()
186 getStatus(asyncFetchStatus), in emitHeaderMetrics()
187 getFailureType(asyncFetchStatus), in emitHeaderMetrics()
188 asyncFetchStatus.getRegistrationDelay().get()) in emitHeaderMetrics()
280 private static int getStatus(AsyncFetchStatus asyncFetchStatus) { in getStatus() argument
281 if (asyncFetchStatus.getEntityStatus() == AsyncFetchStatus.EntityStatus.SUCCESS in getStatus()
282 || (asyncFetchStatus.getResponseStatus() == AsyncFetchStatus.ResponseStatus.SUCCESS in getStatus()
283 && (asyncFetchStatus.getEntityStatus() in getStatus()
[all …]
DAsyncRegistrationQueueRunner.java140 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in processSourceRegistration() local
144 mAsyncSourceFetcher.fetchSource(asyncRegistration, asyncFetchStatus, asyncRedirect); in processSourceRegistration()
146 asyncFetchStatus.setRegistrationDelay(endTime - startTime); in processSourceRegistration()
151 if (asyncFetchStatus.isRequestSuccess()) { in processSourceRegistration()
156 asyncRegistration, asyncFetchStatus, asyncRedirect, dao); in processSourceRegistration()
159 asyncRegistration, asyncFetchStatus, failedOrigins, dao); in processSourceRegistration()
164 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.STORAGE_ERROR); in processSourceRegistration()
171 asyncFetchStatus); in processSourceRegistration() local
196 AsyncFetchStatus asyncFetchStatus = new AsyncFetchStatus(); in processTriggerRegistration() local
200 asyncRegistration, asyncFetchStatus, asyncRedirect); in processTriggerRegistration()
[all …]
DAsyncTriggerFetcher.java100 AsyncFetchStatus asyncFetchStatus) { in parseTrigger() argument
136 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.HEADER_ERROR); in parseTrigger()
147 asyncFetchStatus.setEntityStatus( in parseTrigger()
159 asyncFetchStatus.setEntityStatus( in parseTrigger()
168 asyncFetchStatus.setEntityStatus( in parseTrigger()
182 asyncFetchStatus.setEntityStatus( in parseTrigger()
192 asyncFetchStatus.setEntityStatus( in parseTrigger()
203 asyncFetchStatus.setEntityStatus( in parseTrigger()
258 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.SUCCESS); in parseTrigger()
262 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.PARSING_ERROR); in parseTrigger()
[all …]
DAsyncSourceFetcher.java316 AsyncFetchStatus asyncFetchStatus) { in parseSource() argument
351 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.HEADER_ERROR); in parseSource()
359 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.VALIDATION_ERROR); in parseSource()
365 asyncFetchStatus.setEntityStatus( in parseSource()
378 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.SUCCESS); in parseSource()
382 asyncFetchStatus.setEntityStatus(AsyncFetchStatus.EntityStatus.PARSING_ERROR); in parseSource()
407 AsyncFetchStatus asyncFetchStatus, in fetchSource() argument
422 asyncFetchStatus.setResponseSize(FetcherUtil.calculateHeadersCharactersLength(headers)); in fetchSource()
426 asyncFetchStatus.setResponseStatus( in fetchSource()
430 asyncFetchStatus.setResponseStatus(AsyncFetchStatus.ResponseStatus.SUCCESS); in fetchSource()
[all …]