Home
last modified time | relevance | path

Searched refs:asyncRegistration (Results 1 – 25 of 28) sorted by relevance

12

/packages/modules/AdServices/adservices/tests/unittest/service-core/measurement/src/com/android/adservices/service/measurement/registration/
DEnqueueAsyncRegistrationTest.java213 AsyncRegistration asyncRegistration = in testAppSourceRegistrationRequest_event_isValid() local
215 Assert.assertNotNull(asyncRegistration); in testAppSourceRegistrationRequest_event_isValid()
216 Assert.assertNotNull(asyncRegistration.getRegistrationUri()); in testAppSourceRegistrationRequest_event_isValid()
219 asyncRegistration.getRegistrationUri()); in testAppSourceRegistrationRequest_event_isValid()
221 Uri.parse("android-app://test.destination"), asyncRegistration.getTopOrigin()); in testAppSourceRegistrationRequest_event_isValid()
222 Assert.assertNotNull(asyncRegistration.getRegistrationUri()); in testAppSourceRegistrationRequest_event_isValid()
223 Assert.assertNotNull(asyncRegistration.getRegistrant()); in testAppSourceRegistrationRequest_event_isValid()
225 Uri.parse("android-app://test.destination"), asyncRegistration.getRegistrant()); in testAppSourceRegistrationRequest_event_isValid()
226 Assert.assertNotNull(asyncRegistration.getSourceType()); in testAppSourceRegistrationRequest_event_isValid()
227 Assert.assertEquals(Source.SourceType.EVENT, asyncRegistration.getSourceType()); in testAppSourceRegistrationRequest_event_isValid()
[all …]
DAsyncTriggerFetcherTest.java346 AsyncRegistration asyncRegistration = appTriggerRegistrationRequest(request); in testBasicTriggerRequest() local
349 mFetcher.fetchTrigger(asyncRegistration, asyncFetchStatus, asyncRedirects); in testBasicTriggerRequest()
355 asyncRegistration.getTopOrigin().toString(), in testBasicTriggerRequest()
364 asyncRegistration, in testBasicTriggerRequest()
435 AsyncRegistration asyncRegistration = appTriggerRegistrationRequest(request); in testBasicTriggerRequest_withAggregateDeduplicationKey() local
438 mFetcher.fetchTrigger(asyncRegistration, asyncFetchStatus, asyncRedirects); in testBasicTriggerRequest_withAggregateDeduplicationKey()
444 asyncRegistration.getTopOrigin().toString(), in testBasicTriggerRequest_withAggregateDeduplicationKey()
456 asyncRegistration, in testBasicTriggerRequest_withAggregateDeduplicationKey()
500 AsyncRegistration asyncRegistration = appTriggerRegistrationRequest(request); in triggerRequest_aggregateDeduplicationKey_dedupKeyNotAString_fails() local
503 mFetcher.fetchTrigger(asyncRegistration, asyncFetchStatus, asyncRedirects); in triggerRequest_aggregateDeduplicationKey_dedupKeyNotAString_fails()
[all …]
DFetcherUtilTest.java1476 AsyncRegistration asyncRegistration = in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain() local
1489 maxAllowedHeadersSize, mLogger, asyncRegistration, asyncFetchStatus, ENROLLMENT_ID); in emitHeaderMetrics_headersSizeLessThanMaxAllowed_doesNotLogAdTechDomain()
1527 AsyncRegistration asyncRegistration = in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain() local
1540 maxAllowedHeadersSize, mLogger, asyncRegistration, asyncFetchStatus, ENROLLMENT_ID); in emitHeaderMetrics_headersSizeExceedsMaxAllowed_logsAdTechDomain()
1581 AsyncRegistration asyncRegistration = in emitHeaderMetrics_headersWithNullValues_success() local
1594 maxAllowedHeadersSize, mLogger, asyncRegistration, asyncFetchStatus, ENROLLMENT_ID); in emitHeaderMetrics_headersWithNullValues_success()
/packages/modules/AdServices/adservices/tests/unittest/service-core/measurement/src/com/android/adservices/service/measurement/countunique/
DCountUniqueRegistrarTest.java97 AsyncRegistration asyncRegistration = in registerCountUniqueEvent_forIgnoreIfPresentAsTrue_doesNotUpdateMetadata() local
115 asyncRegistration, List.of(metadataHeader)); in registerCountUniqueEvent_forIgnoreIfPresentAsTrue_doesNotUpdateMetadata()
119 asyncRegistration, in registerCountUniqueEvent_forIgnoreIfPresentAsTrue_doesNotUpdateMetadata()
153 .isEqualTo(asyncRegistration.getRequestTime()); in registerCountUniqueEvent_forIgnoreIfPresentAsTrue_doesNotUpdateMetadata()
173 .isEqualTo(asyncRegistration.getRequestTime()); in registerCountUniqueEvent_forIgnoreIfPresentAsTrue_doesNotUpdateMetadata()
181 AsyncRegistration asyncRegistration = in registerCountUniqueEvent_forIgnoreIfPresentAsFalse_forceUpdatesMetadata() local
202 asyncRegistration, List.of(metadataHeader)); in registerCountUniqueEvent_forIgnoreIfPresentAsFalse_forceUpdatesMetadata()
206 asyncRegistration, in registerCountUniqueEvent_forIgnoreIfPresentAsFalse_forceUpdatesMetadata()
240 .isEqualTo(asyncRegistration.getRequestTime()); in registerCountUniqueEvent_forIgnoreIfPresentAsFalse_forceUpdatesMetadata()
256 .isEqualTo(asyncRegistration.getRequestTime()); in registerCountUniqueEvent_forIgnoreIfPresentAsFalse_forceUpdatesMetadata()
[all …]
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/registration/
DAsyncRegistrationQueueRunner.java224 AsyncRegistration asyncRegistration = fetchNext(retryLimit, failedOrigins); in runAsyncRegistrationQueueWorker() local
225 if (null == asyncRegistration) { in runAsyncRegistrationQueueWorker()
231 processAsyncRecord(asyncRegistration, failedOrigins); in runAsyncRegistrationQueueWorker()
245 private void processAsyncRecord(AsyncRegistration asyncRegistration, Set<Uri> failedOrigins) { in processAsyncRecord() argument
246 if (asyncRegistration.isSourceRequest()) { in processAsyncRecord()
249 processSourceRegistration(asyncRegistration, failedOrigins); in processAsyncRecord()
253 processTriggerRegistration(asyncRegistration, failedOrigins); in processAsyncRecord()
258 AsyncRegistration asyncRegistration = fetchNext(retryLimit, failedOrigins); in hasPendingRecords() local
259 if (null == asyncRegistration) { in hasPendingRecords()
269 AsyncRegistration asyncRegistration, Set<Uri> failedOrigins) { in processSourceRegistration() argument
[all …]
DAsyncSourceFetcher.java124 AsyncRegistration asyncRegistration, in parseValidateSource() argument
140 long sourceEventTime = asyncRegistration.getRequestTime(); in parseValidateSource()
175 if (asyncRegistration.getSourceType() == Source.SourceType.EVENT) { in parseValidateSource()
347 if (asyncRegistration.isWebRequest() in parseValidateSource()
349 && asyncRegistration.getOsDestination() != null in parseValidateSource()
350 && !asyncRegistration.getOsDestination().equals(appUri)) { in parseValidateSource()
364 asyncRegistration.isWebRequest() && asyncRegistration.getWebDestination() != null; in parseValidateSource()
399 && asyncRegistration.getWebDestination().equals(destination)) { in parseValidateSource()
577 asyncRegistration.getSourceType(), maxEventLevelReports, mFlags); in parseValidateSource()
584 asyncRegistration.getSourceType(), in parseValidateSource()
[all …]
DAsyncTriggerFetcher.java126 AsyncRegistration asyncRegistration, in parseTrigger() argument
130 boolean arDebugPermission = asyncRegistration.getDebugKeyAllowed(); in parseTrigger()
139 asyncRegistration.getTopOrigin(), asyncRegistration.getType())); in parseTrigger()
140 builder.setRegistrant(asyncRegistration.getRegistrant()); in parseTrigger()
141 builder.setAdIdPermission(asyncRegistration.hasAdIdPermission()); in parseTrigger()
144 asyncRegistration.isWebRequest() ? EventSurfaceType.WEB : EventSurfaceType.APP); in parseTrigger()
145 builder.setTriggerTime(asyncRegistration.getRequestTime()); in parseTrigger()
147 WebAddresses.originAndScheme(asyncRegistration.getRegistrationUri()); in parseTrigger()
157 asyncRegistration.getRegistrationUri().getHost(), in parseTrigger()
163 builder.setPlatformAdId(asyncRegistration.getPlatformAdId()); in parseTrigger()
[all …]
DFetcherUtil.java631 static String getSourceRegistrantToLog(AsyncRegistration asyncRegistration) { in getSourceRegistrantToLog() argument
632 if (asyncRegistration.isSourceRequest()) { in getSourceRegistrantToLog()
633 return asyncRegistration.getRegistrant().toString(); in getSourceRegistrantToLog()
642 AsyncRegistration asyncRegistration, in emitHeaderMetrics() argument
650 WebAddresses.topPrivateDomainAndScheme(asyncRegistration.getRegistrationUri()) in emitHeaderMetrics()
658 getRegistrationType(asyncRegistration), in emitHeaderMetrics()
660 getSourceType(asyncRegistration), in emitHeaderMetrics()
661 getSurfaceType(asyncRegistration), in emitHeaderMetrics()
665 getSourceRegistrantToLog(asyncRegistration), in emitHeaderMetrics()
721 private static int getRegistrationType(AsyncRegistration asyncRegistration) { in getRegistrationType() argument
[all …]
DEnqueueAsyncRegistration.java240 AsyncRegistration asyncRegistration =
261 dao.insertAsyncRegistration(asyncRegistration);
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/countunique/
DCountUniqueRegistrar.java54 AsyncRegistration asyncRegistration, List<String> eventHeader, String enrollmentId) { in registerCountUniqueEvent() argument
55 if (asyncRegistration == null || eventHeader == null) { in registerCountUniqueEvent()
86 asyncRegistration, in registerCountUniqueEvent()
116 AsyncRegistration asyncRegistration, List<String> metadataHeader) { in registerCountUniqueMetadata() argument
117 if (asyncRegistration == null || metadataHeader == null) { in registerCountUniqueMetadata()
146 createCountUniqueMetadata(operation, asyncRegistration); in registerCountUniqueMetadata()
178 MetadataOperation operation, AsyncRegistration asyncRegistration) { in createCountUniqueMetadata() argument
188 asyncRegistration.getRequestTime() + METADATA_EXPIRY_WINDOW_MILLS); in createCountUniqueMetadata()
191 WebAddresses.originAndScheme(asyncRegistration.getRegistrationUri()); in createCountUniqueMetadata()
197 + asyncRegistration.getRegistrationUri()); in createCountUniqueMetadata()
[all …]
DICountUniqueRegistrar.java32 AsyncRegistration asyncRegistration, List<String> eventHeader, String enrollmentId); in registerCountUniqueEvent() argument
41 AsyncRegistration asyncRegistration, List<String> metadataHeader); in registerCountUniqueMetadata() argument
/packages/modules/AdServices/adservices/tests/unittest/service-core/measurement/src/com/android/adservices/service/measurement/ondevicepersonalization/
DOdpDelegationWrapperImplTest.java109 AsyncRegistration asyncRegistration = in registerOdpTrigger_validParameters_success() local
132 odpDelegationWrapperImpl.registerOdpTrigger(asyncRegistration, header, true); in registerOdpTrigger_validParameters_success()
139 assertEquals(asyncRegistration.getTopOrigin(), params.getDestinationUrl()); in registerOdpTrigger_validParameters_success()
140 assertEquals(asyncRegistration.getRegistrant().toString(), params.getAppPackageName()); in registerOdpTrigger_validParameters_success()
165 AsyncRegistration asyncRegistration = in registerOdpTrigger_invalidEnrollment_fail() local
188 odpDelegationWrapperImpl.registerOdpTrigger(asyncRegistration, header, false); in registerOdpTrigger_invalidEnrollment_fail()
209 AsyncRegistration asyncRegistration = in registerOdpTrigger_headerSizeLimitExceeded_fail() local
232 odpDelegationWrapperImpl.registerOdpTrigger(asyncRegistration, header, true); in registerOdpTrigger_headerSizeLimitExceeded_fail()
255 AsyncRegistration asyncRegistration = in registerOdpTrigger_invalidHeaderFormat_fail() local
281 odpDelegationWrapperImpl.registerOdpTrigger(asyncRegistration, header, true); in registerOdpTrigger_invalidHeaderFormat_fail()
[all …]
DNoOdpDelegationWrapperTest.java57 AsyncRegistration asyncRegistration = in registerOdpTrigger_logMetrics() local
80 noOdpDelegationWrapper.registerOdpTrigger(asyncRegistration, header, false); in registerOdpTrigger_logMetrics()
/packages/modules/AdServices/adservices/tests/unittest/service-core/measurement/src/com/android/adservices/data/measurement/migration/
DContentValueFixtures.java444 ContentValues asyncRegistration = new ContentValues(); in generateAsyncRegistrationContentValuesV1() local
446 asyncRegistration.put( in generateAsyncRegistrationContentValuesV1()
448 asyncRegistration.put( in generateAsyncRegistrationContentValuesV1()
451 asyncRegistration.put( in generateAsyncRegistrationContentValuesV1()
454 asyncRegistration.put( in generateAsyncRegistrationContentValuesV1()
457 asyncRegistration.put( in generateAsyncRegistrationContentValuesV1()
460 asyncRegistration.put( in generateAsyncRegistrationContentValuesV1()
463 asyncRegistration.put( in generateAsyncRegistrationContentValuesV1()
466 asyncRegistration.put( in generateAsyncRegistrationContentValuesV1()
469 asyncRegistration.put( in generateAsyncRegistrationContentValuesV1()
[all …]
DMeasurementDbMigratorV31Test.java89 ContentValues asyncRegistration = in createFakeDataV30() local
91 asyncRegistration.put( in createFakeDataV30()
93 asyncRegistrationRows.add(asyncRegistration); in createFakeDataV30()
DMeasurementDbMigratorV24Test.java93 ContentValues asyncRegistration = in createFakeDataV23() local
95 asyncRegistration.put( in createFakeDataV23()
97 asyncRegistrationRows.add(asyncRegistration); in createFakeDataV23()
DMeasurementDbMigratorV13Test.java110 ContentValues asyncRegistration = in createFakeDataV12() local
112 asyncRegistration.put( in createFakeDataV12()
114 asyncRegistrationRows.add(asyncRegistration); in createFakeDataV12()
/packages/modules/AdServices/adservices/tests/unittest/service-core/measurement/src/com/android/adservices/data/measurement/
DAbstractDbIntegrationTest.java667 private static void insertToDb(AsyncRegistration asyncRegistration, SQLiteDatabase db) in insertToDb() argument
670 values.put(MeasurementTables.AsyncRegistrationContract.ID, asyncRegistration.getId()); in insertToDb()
673 asyncRegistration.getRegistrationUri().toString()); in insertToDb()
676 getNullableUriString(asyncRegistration.getWebDestination())); in insertToDb()
679 getNullableUriString(asyncRegistration.getVerifiedDestination())); in insertToDb()
682 getNullableUriString(asyncRegistration.getOsDestination())); in insertToDb()
685 getNullableUriString(asyncRegistration.getRegistrant())); in insertToDb()
688 getNullableUriString(asyncRegistration.getTopOrigin())); in insertToDb()
691 asyncRegistration.getSourceType() == null in insertToDb()
693 : asyncRegistration.getSourceType().ordinal()); in insertToDb()
[all …]
DMeasurementDaoTest.java6648 asyncRegistration -> { in testDeleteExpiredRecordsForAsyncRegistrations()
6650 values.put(AsyncRegistrationContract.ID, asyncRegistration.getId()); in testDeleteExpiredRecordsForAsyncRegistrations()
6653 asyncRegistration.getRegistrant().toString()); in testDeleteExpiredRecordsForAsyncRegistrations()
6656 asyncRegistration.getTopOrigin().toString()); in testDeleteExpiredRecordsForAsyncRegistrations()
6659 asyncRegistration.getOsDestination().toString()); in testDeleteExpiredRecordsForAsyncRegistrations()
6662 asyncRegistration.getDebugKeyAllowed()); in testDeleteExpiredRecordsForAsyncRegistrations()
6664 AsyncRegistrationContract.TYPE, asyncRegistration.getType().toString()); in testDeleteExpiredRecordsForAsyncRegistrations()
6667 asyncRegistration.getRequestTime()); in testDeleteExpiredRecordsForAsyncRegistrations()
6670 asyncRegistration.getRetryCount()); in testDeleteExpiredRecordsForAsyncRegistrations()
6673 asyncRegistration.getRegistrationId()); in testDeleteExpiredRecordsForAsyncRegistrations()
[all …]
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/ondevicepersonalization/
DOdpDelegationWrapperImpl.java88 AsyncRegistration asyncRegistration, in registerOdpTrigger() argument
91 Objects.requireNonNull(asyncRegistration); in registerOdpTrigger()
156 asyncRegistration.getTopOrigin(), in registerOdpTrigger()
157 asyncRegistration.getRegistrant().toString(), in registerOdpTrigger()
DIOdpDelegationWrapper.java28 AsyncRegistration asyncRegistration, in registerOdpTrigger() argument
DNoOdpDelegationWrapper.java45 AsyncRegistration asyncRegistration, in registerOdpTrigger() argument
/packages/modules/AdServices/adservices/tests/unittest/service-core/measurement/src/com/android/adservices/service/measurement/
DE2EInteropMockTest.java435 AsyncRegistration asyncRegistration = in insertSourceOrAssertUnparsable() local
452 mAsyncSourceFetcher.parseSource(asyncRegistration, enrollmentId, headers, status); in insertSourceOrAssertUnparsable()
461 asyncRegistration, in insertSourceOrAssertUnparsable()
485 AsyncRegistration asyncRegistration = in insertTriggerOrAssertUnparsable() local
499 mAsyncTriggerFetcher.parseTrigger(asyncRegistration, enrollmentId, headers, status); in insertTriggerOrAssertUnparsable()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/data/measurement/
DMeasurementDao.java3523 public void insertAsyncRegistration(@NonNull AsyncRegistration asyncRegistration)
3526 values.put(AsyncRegistrationContract.ID, asyncRegistration.getId());
3529 asyncRegistration.getRegistrationUri().toString());
3532 getNullableUriString(asyncRegistration.getWebDestination()));
3535 getNullableUriString(asyncRegistration.getVerifiedDestination()));
3538 getNullableUriString(asyncRegistration.getOsDestination()));
3541 getNullableUriString(asyncRegistration.getRegistrant()));
3543 AsyncRegistrationContract.TOP_ORIGIN, asyncRegistration.getTopOrigin().toString());
3546 asyncRegistration.getSourceType() == null
3548 : asyncRegistration.getSourceType().ordinal());
[all …]
DIMeasurementDao.java601 void insertAsyncRegistration(@NonNull AsyncRegistration asyncRegistration) in insertAsyncRegistration() argument
658 void updateRetryCount(@NonNull AsyncRegistration asyncRegistration) throws DatastoreException; in updateRetryCount() argument

12