Home
last modified time | relevance | path

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

12

/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/data/measurement/
DMeasurementDaoTest.java226 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 …]
DSQLDatastoreManagerTest.java165 () -> 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()
DDeleteExpiredIntegrationTest.java65 .runInTransaction( in runActionToTest()
DDeleteExpiredDynamicIntegrationTest.java109 mDatastoreManager.runInTransaction( in runActionToTest()
/packages/modules/AdServices/adservices/libraries/cobalt/java/com/android/cobalt/data/
DDataService.java82 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/
DEnqueueAsyncRegistration.java61 return datastoreManager.runInTransaction( in appSourceOrTriggerRegistrationRequest()
105 return datastoreManager.runInTransaction(
148 return datastoreManager.runInTransaction(
193 return datastoreManager.runInTransaction(
DAsyncRegistrationQueueRunner.java260 mDatastoreManager.runInTransaction( in processSourceRegistration()
338 mDatastoreManager.runInTransaction( in processTriggerRegistration()
DAsyncTriggerFetcher.java364 mDatastoreManager.runInTransaction( in parseTrigger()
DAsyncSourceFetcher.java854 mDatastoreManager.runInTransaction( in parseSource()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/reporting/
DDebugReportingJobHandler.java117 mDatastoreManager.runInTransaction( in performScheduledPendingReports()
160 mDatastoreManager.runInTransaction( in performReport()
199 mDatastoreManager.runInTransaction(dao -> dao.deleteDebugReport(debugReportId)); in performReport()
DEventReportingJobHandler.java168 mDatastoreManager.runInTransaction( in performScheduledPendingReportsInWindow()
242 mDatastoreManager.runInTransaction( in performReport()
289 mDatastoreManager.runInTransaction( in performReport()
DAggregateReportingJobHandler.java178 mDatastoreManager.runInTransaction( in performScheduledPendingReportsInWindow()
263 mDatastoreManager.runInTransaction( in performReport()
309 mDatastoreManager.runInTransaction( in performReport()
DReportingJobService.java192 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/
DDeleteExpiredJobServiceTest.java388 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()
DMeasurementImplTest.java319 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()
DE2EInteropMockTest.java281 mDatastoreManager.runInTransaction( in insertSourceOrAssertUnparsable()
324 mDatastoreManager.runInTransaction( in insertTriggerOrAssertUnparsable()
DE2EMockTest.java461 mDatastoreManager.runInTransaction( in processAction()
728 mDatastoreManager.runInTransaction( in runDeleteExpiredRecordsJob()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/aggregation/
DAggregateEncryptionKeyManager.java103 mDatastoreManager.runInTransaction((dao) -> in getAggregateEncryptionKeys()
107 mDatastoreManager.runInTransaction((dao) -> in getAggregateEncryptionKeys()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/
DMeasurementImpl.java152 mDatastoreManager.runInTransaction( in doInstallAttribution()
394 mDatastoreManager.runInTransaction( in deleteAllMeasurementData()
555 mDatastoreManager.runInTransaction( in deleteOnRollback()
DDeleteExpiredJobService.java83 .runInTransaction( in onStartJob()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/data/measurement/
DDatastoreManager.java143 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/
DAggregateEncryptionKeyManagerTest.java162 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/
DReportingJobServiceTest.java574 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/
DMeasurementDataDeleter.java84 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/
DEnqueueAsyncRegistrationTest.java679 when(mDatastoreManagerMock.runInTransaction(any())).thenReturn(false); in testRunInTransactionFail_invalid()

12