/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/data/measurement/ |
D | MeasurementDaoTest.java | 226 mDatastoreManager.runInTransaction((dao) -> dao.insertSource(validSource)); in testInsertSource() 293 mDatastoreManager.runInTransaction((dao) -> dao.insertSource(validSource)); in testInsertSource_flexibleEventReport_equal() 447 mDatastoreManager.runInTransaction((dao) -> dao.insertSource(validSource)); in insertSourceReachingDbSizeLimit() 460 mDatastoreManager.runInTransaction((dao) -> dao.insertTrigger(validTrigger)); in testInsertTrigger() 520 mDatastoreManager.runInTransaction((dao) -> dao.insertTrigger(validTrigger)); in insertTriggerReachingDbSizeLimit() 533 mDatastoreManager.runInTransaction( in testGetNumSourcesPerPublisher_publisherTypeApp() 540 mDatastoreManager.runInTransaction( in testGetNumSourcesPerPublisher_publisherTypeApp() 547 mDatastoreManager.runInTransaction( in testGetNumSourcesPerPublisher_publisherTypeApp() 559 mDatastoreManager.runInTransaction( in testGetNumSourcesPerPublisher_publisherTypeWeb() 566 mDatastoreManager.runInTransaction( in testGetNumSourcesPerPublisher_publisherTypeWeb() [all …]
|
D | SQLDatastoreManagerTest.java | 165 () -> mSQLDatastoreManager.runInTransaction(mConsumer)); in runInTransaction_throwsException_logsDbVersion() 189 mSQLDatastoreManager.runInTransaction(mConsumer); in runInTransaction_throwsDataStoreExceptionExceptionDisable_logsDbVersion() 215 mSQLDatastoreManager.runInTransaction(mConsumer); in runInTransaction_throwsDataStoreExceptionSamplingDisabled_logsDbVersion() 242 mSQLDatastoreManager.runInTransaction(mConsumer); in runInTransaction_throwsDataStoreExceptionExceptionEnable_logsDbVersion()
|
D | DeleteExpiredIntegrationTest.java | 65 .runInTransaction( in runActionToTest()
|
D | DeleteExpiredDynamicIntegrationTest.java | 109 mDatastoreManager.runInTransaction( in runActionToTest()
|
/packages/modules/AdServices/adservices/libraries/cobalt/java/com/android/cobalt/data/ |
D | DataService.java | 82 mCobaltDatabase.runInTransaction( in loggerDisabled() 96 () -> mCobaltDatabase.runInTransaction(() -> loggerEnabledSync(currentTime)), in loggerEnabled() 127 mCobaltDatabase.runInTransaction( in generateObservations() 197 mCobaltDatabase.runInTransaction( in aggregateCount() 237 mCobaltDatabase.runInTransaction( in aggregateString() 261 mCobaltDatabase.runInTransaction( in cleanup()
|
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/registration/ |
D | EnqueueAsyncRegistration.java | 61 return datastoreManager.runInTransaction( in appSourceOrTriggerRegistrationRequest() 105 return datastoreManager.runInTransaction( 148 return datastoreManager.runInTransaction( 193 return datastoreManager.runInTransaction(
|
D | AsyncRegistrationQueueRunner.java | 260 mDatastoreManager.runInTransaction( in processSourceRegistration() 338 mDatastoreManager.runInTransaction( in processTriggerRegistration()
|
D | AsyncTriggerFetcher.java | 364 mDatastoreManager.runInTransaction( in parseTrigger()
|
D | AsyncSourceFetcher.java | 854 mDatastoreManager.runInTransaction( in parseSource()
|
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/reporting/ |
D | DebugReportingJobHandler.java | 117 mDatastoreManager.runInTransaction( in performScheduledPendingReports() 160 mDatastoreManager.runInTransaction( in performReport() 199 mDatastoreManager.runInTransaction(dao -> dao.deleteDebugReport(debugReportId)); in performReport()
|
D | EventReportingJobHandler.java | 168 mDatastoreManager.runInTransaction( in performScheduledPendingReportsInWindow() 242 mDatastoreManager.runInTransaction( in performReport() 289 mDatastoreManager.runInTransaction( in performReport()
|
D | AggregateReportingJobHandler.java | 178 mDatastoreManager.runInTransaction( in performScheduledPendingReportsInWindow() 263 mDatastoreManager.runInTransaction( in performReport() 309 mDatastoreManager.runInTransaction( in performReport()
|
D | ReportingJobService.java | 192 datastoreManager.runInTransaction(getSaveNextExecutionConsumer(latestReportTimeInBatch)); in saveNextExecution() 240 datastoreManager.runInTransaction(getSaveExecutionTimeConsumer()); in saveExecutionStartTime()
|
/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/measurement/ |
D | DeleteExpiredJobServiceTest.java | 388 verify(mMockDatastoreManager, never()).runInTransaction(any()); in onStartJob_killSwitchOn() 404 verify(mMockDatastoreManager, times(1)).runInTransaction(any()); in onStartJob_killSwitchOff() 425 verify(mMockDatastoreManager, never()).runInTransaction(any()); in onStartJob_shouldDisableJobTrue() 433 doReturn(true).when(mMockDatastoreManager).runInTransaction(any()); in runWithMocks()
|
D | MeasurementImplTest.java | 319 doReturn(false).when(mDatastoreManager).runInTransaction(any()); in testDeleteRegistrations_internalError() 573 doReturn(true).when(mDatastoreManager).runInTransaction(any()); in testDeletePackageRecords_success_recordsDeletionInSystemServer() 621 doReturn(true).when(mDatastoreManager).runInTransaction(any()); in testDeletePackageRecords_noDeletion_doesNotRecordDeletion() 730 doReturn(true).when(mDatastoreManager).runInTransaction(any()); in testDeleteAllUninstalledMeasurementData_success_recordsDeletionInSystemServer() 930 doReturn(true).when(mDatastoreManager).runInTransaction(any()); in testDeleteOnRollback_logsWipeout() 957 doReturn(false).when(mDatastoreManager).runInTransaction(any()); in testRegisterSources_ioError()
|
D | E2EInteropMockTest.java | 281 mDatastoreManager.runInTransaction( in insertSourceOrAssertUnparsable() 324 mDatastoreManager.runInTransaction( in insertTriggerOrAssertUnparsable()
|
D | E2EMockTest.java | 461 mDatastoreManager.runInTransaction( in processAction() 728 mDatastoreManager.runInTransaction( in runDeleteExpiredRecordsJob()
|
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/aggregation/ |
D | AggregateEncryptionKeyManager.java | 103 mDatastoreManager.runInTransaction((dao) -> in getAggregateEncryptionKeys() 107 mDatastoreManager.runInTransaction((dao) -> in getAggregateEncryptionKeys()
|
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/ |
D | MeasurementImpl.java | 152 mDatastoreManager.runInTransaction( in doInstallAttribution() 394 mDatastoreManager.runInTransaction( in deleteAllMeasurementData() 555 mDatastoreManager.runInTransaction( in deleteOnRollback()
|
D | DeleteExpiredJobService.java | 83 .runInTransaction( in onStartJob()
|
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/data/measurement/ |
D | DatastoreManager.java | 143 public final boolean runInTransaction(ThrowingCheckedConsumer execute) { in runInTransaction() method in DatastoreManager
|
/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/measurement/aggregation/ |
D | AggregateEncryptionKeyManagerTest.java | 162 verify(mDatastoreManager, times(1)).runInTransaction(any()); in getAggregateEncryptionKeys_localhostCoordinator_doesNotCacheKeys()
|
/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/measurement/reporting/ |
D | ReportingJobServiceTest.java | 574 doReturn(true).when(mMockDatastoreManager).runInTransaction(any()); in onStartJob_featureEnabled() 603 doReturn(true).when(mMockDatastoreManager).runInTransaction(any()); in onStartJob_shouldDisableJobTrue()
|
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/data/measurement/deletion/ |
D | MeasurementDataDeleter.java | 84 boolean result = mDatastoreManager.runInTransaction((dao) -> delete(dao, deletionParam)); in delete()
|
/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/measurement/registration/ |
D | EnqueueAsyncRegistrationTest.java | 679 when(mDatastoreManagerMock.runInTransaction(any())).thenReturn(false); in testRunInTransactionFail_invalid()
|