| /packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/data/kanon/ |
| D | KAnonMessageDaoTest.java | 35 private KAnonMessageDao mKAnonMessageDao; field in KAnonMessageDaoTest
53 mKAnonMessageDao = in setup()
62 mKAnonMessageDao.getNLatestKAnonMessagesWithStatus( in testGetNKAnonMessageWithStatus_withNoMessage_returnsEmptyList()
78 mKAnonMessageDao.insertAllKAnonMessages(List.of(message1, message2)); in testGetNKAnonMessageWithStatus_fetchesMessagesWithStatus()
81 mKAnonMessageDao.getNLatestKAnonMessagesWithStatus( in testGetNKAnonMessageWithStatus_fetchesMessagesWithStatus()
97 mKAnonMessageDao.insertAllKAnonMessages(List.of(message1, message2)); in testGetNKAnonMessageWithStatus_withDifferentStatus_fetchesCorrectMessages()
100 mKAnonMessageDao.getNLatestKAnonMessagesWithStatus( in testGetNKAnonMessageWithStatus_withDifferentStatus_fetchesCorrectMessages()
120 mKAnonMessageDao.insertAllKAnonMessages(List.of(message1, message2)); in testDeleteKAnonMessagesWithIds_deletesMessagesWithGivenIdList()
122 mKAnonMessageDao.deleteKAnonMessagesWithIds(List.of(messageIdToDelete, messageIdToDelete2)); in testDeleteKAnonMessagesWithIds_deletesMessagesWithGivenIdList()
125 mKAnonMessageDao.getNLatestKAnonMessagesWithStatus( in testDeleteKAnonMessagesWithIds_deletesMessagesWithGivenIdList()
[all …]
|
| /packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/kanon/ |
| D | KAnonMessageManagerTest.java | 49 private KAnonMessageDao mKAnonMessageDao; field in KAnonMessageManagerTest
113 mKAnonMessageDao = in setup()
118 mKAnonMessageManager = new KAnonMessageManager(mKAnonMessageDao, mockFlags, mockClock); in setup()
127 mKAnonMessageManager = new KAnonMessageManager(mKAnonMessageDao, mockFlags, mockClock); in testPersistNewAnonMessageEntities_shouldPersistSuccessfully()
131 mKAnonMessageDao.getNLatestKAnonMessagesWithStatus( in testPersistNewAnonMessageEntities_shouldPersistSuccessfully()
143 mKAnonMessageDao.insertAllKAnonMessages( in testFetchNKAnonMessagesWithStatus_shouldFetchListOfCorrectMessages()
160 mKAnonMessageDao.insertAllKAnonMessages( in testFetchKAnonMessagesWithMessage_shouldFetchCorrectMessage()
172 mKAnonMessageDao.insertAllKAnonMessages( in testFetchNKAnonMessagesWithStatus_withNoCorrectMessage_shouldReturnEmptyList()
185 mKAnonMessageDao.insertAllKAnonMessages( in testFetchKAnonMessagesWithMessage_withNoMessagePresent_shouldReturnNull()
200 mKAnonMessageDao.getNLatestKAnonMessagesWithStatus( in testPersistNewAnonMessageEntities_messageWithUnsetId_shouldHaveIdGenerated()
[all …]
|
| D | KAnonSignJoinBackgroundJobWorkerTest.java | 56 private KAnonMessageDao mKAnonMessageDao; field in KAnonSignJoinBackgroundJobWorkerTest
77 mKAnonMessageDao = in setup()
83 mKAnonMessageManager = new KAnonMessageManager(mKAnonMessageDao, mFlags, mockClock); in setup()
102 mKAnonMessageDao.insertKAnonMessage(dbkAnonMessage); in makeSignJoinCalls_nonZeroBackgroundCallBatchSize_makesSignJoinCalls()
136 mKAnonMessageDao.insertKAnonMessage(dbkAnonMessage); in makeSignJoinCalls_zeroBackgroundCallBatchSize_doesNotMakeSignJoinCalls()
|
| D | KAnonSignJoinManagerTest.java | 69 private KAnonMessageDao mKAnonMessageDao; field in KAnonSignJoinManagerTest
108 mKAnonMessageDao = in setup()
114 mKAnonMessageManager = new KAnonMessageManager(mKAnonMessageDao, mFlags, mockClock); in setup()
198 mKAnonMessageDao.insertKAnonMessage(dbkAnonMessageAlreadyJoined); in processNewMessage_messageSignedWithActiveClientParams_shouldNotProcessMessage()
235 mKAnonMessageDao.insertKAnonMessage(dbkAnonMessageAlreadyJoined); in processNewMessage_messageSignedWithExpiredClientParams_shouldProcessMessage()
|
| D | KAnonCallerImplFullIntegrationTests.java | 112 private KAnonMessageDao mKAnonMessageDao; field in KAnonCallerImplFullIntegrationTests
160 mKAnonMessageDao = kAnonDatabase.kAnonMessageDao(); in setup()
162 mKAnonMessageManager = new KAnonMessageManager(mKAnonMessageDao, mFlags, mockClock); in setup()
199 new KAnonMessageManager(mKAnonMessageDao, mFlags, mockClock); in testKAnonCallerImpl_runsSuccessfully_joinsMessagesCorrectly()
298 mKAnonMessageDao.insertAllKAnonMessages(List.of(dbKAnonMessage, dbKAnonMessageSecond)); in createAndPersistKAnonMessages()
|
| D | KAnonCallerImplTest.java | 127 private KAnonMessageDao mKAnonMessageDao; field in KAnonCallerImplTest
176 mKAnonMessageDao = kAnonDatabase.kAnonMessageDao(); in setup()
178 mKAnonMessageManager = new KAnonMessageManager(mKAnonMessageDao, mFlags, mockClock); in setup()
569 mKAnonMessageDao.insertKAnonMessage(dbKAnonMessage); in test_signedJoinedSuccessfully_shouldCaptureBackgroundJobStats()
723 mKAnonMessageDao.insertAllKAnonMessages(List.of(dbKAnonMessage, dbKAnonMessageSecond)); in createAndPersistKAnonMessages()
|
| D | KAnonE2ETest.java | 320 private KAnonMessageDao mKAnonMessageDao; field in KAnonE2ETest
441 mKAnonMessageDao = kAnonDatabase.kAnonMessageDao(); in setUp()
2253 mKAnonMessageManager = new KAnonMessageManager(mKAnonMessageDao, mFlags, mockClock);
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/kanon/ |
| D | KAnonMessageManager.java | 35 @NonNull private final KAnonMessageDao mKAnonMessageDao; field in KAnonMessageManager
45 mKAnonMessageDao = kAnonMessageDao; in KAnonMessageManager()
60 long[] ids = mKAnonMessageDao.insertAllKAnonMessages(dbkAnonMessages); in persistNewAnonMessageEntities()
84 return mKAnonMessageDao.getNLatestKAnonMessagesWithStatus(numberOfMessages, status).stream() in fetchNKAnonMessagesWithStatus()
94 return mKAnonMessageDao.getKAnonMessagesWithMessage(hashSetToSearch).stream() in fetchKAnonMessageEntityWithMessage()
104 return mKAnonMessageDao.getNumberOfMessagesWithStatus( in getNumberOfUnprocessedMessagesInDB()
117 mKAnonMessageDao.updateMessagesStatus( in updateMessagesStatus()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/common/ |
| D | FledgeMaintenanceTasksWorker.java | 57 @NonNull private final KAnonMessageDao mKAnonMessageDao; field in FledgeMaintenanceTasksWorker
90 mKAnonMessageDao = kAnonMessageDao; in FledgeMaintenanceTasksWorker()
106 mKAnonMessageDao = KAnonDatabase.getInstance(context).kAnonMessageDao(); in FledgeMaintenanceTasksWorker()
233 mKAnonMessageDao.removeExpiredEntities(mClock.instant()); in clearExpiredKAnonMessageEntities()
|