Home
last modified time | relevance | path

Searched refs:messageEntities (Results 1 – 6 of 6) sorted by relevance

/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/kanon/
DKAnonCallerImpl.java238 List<KAnonMessageEntity> messageEntities, KAnonCallerSource source) { in signAndJoinMessages() argument
239 Preconditions.checkArgument(messageEntities.size() > 0); in signAndJoinMessages()
245 ignoredVoid -> performSignAndJoinInBatches(messageEntities), in signAndJoinMessages()
256 latency, messageEntities.size(), KANON_JOB_RESULT_SUCCESS); in signAndJoinMessages()
260 latency, messageEntities.size(), KANON_JOB_RESULT_SUCCESS); in signAndJoinMessages()
278 logBackgroundJobStats(latency, messageEntities.size(), result); in signAndJoinMessages()
281 logImmediateJoinStats(latency, messageEntities.size(), result); in signAndJoinMessages()
399 private ListenableFuture<TokensSet> signRequest(List<KAnonMessageEntity> messageEntities) { in signRequest() argument
400 sLogger.v("Starting sign process for batch with " + messageEntities.size() + " messages"); in signRequest()
402 return FluentFuture.from(performSignRequest(messageEntities)) in signRequest()
[all …]
DKAnonSignJoinManager.java166 List<KAnonMessageEntity> messageEntities = in processMessagesFromDatabase() local
169 if (messageEntities.isEmpty()) { in processMessagesFromDatabase()
172 sLogger.v("Processing " + messageEntities.size() + " messages from database"); in processMessagesFromDatabase()
174 messageEntities, KAnonCaller.KAnonCallerSource.BACKGROUND_JOB); in processMessagesFromDatabase()
DKAnonMessageManager.java110 List<KAnonMessageEntity> messageEntities, in updateMessagesStatus() argument
113 messageEntities.stream() in updateMessagesStatus()
/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/kanon/
DKAnonCallerImplFullIntegrationTests.java200 List<KAnonMessageEntity> messageEntities = in testKAnonCallerImpl_runsSuccessfully_joinsMessagesCorrectly() local
221 messageEntities, KAnonCaller.KAnonCallerSource.IMMEDIATE_SIGN_JOIN); in testKAnonCallerImpl_runsSuccessfully_joinsMessagesCorrectly()
229 assertThat(messageEntitiesAfterProcessing.size()).isEqualTo(messageEntities.size()); in testKAnonCallerImpl_runsSuccessfully_joinsMessagesCorrectly()
241 List<KAnonMessageEntity> messageEntities = in testKAnonCallerImpl_clientParamsAlreadyPresent_doesntFetchClientParams() local
263 messageEntities, KAnonCaller.KAnonCallerSource.IMMEDIATE_SIGN_JOIN); in testKAnonCallerImpl_clientParamsAlreadyPresent_doesntFetchClientParams()
274 assertThat(messageEntitiesAfterProcessing.size()).isEqualTo(messageEntities.size()); in testKAnonCallerImpl_clientParamsAlreadyPresent_doesntFetchClientParams()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/adselection/
DAdSelectionRunner.java465 List<KAnonMessageEntity> messageEntities = in makeSignJoinCall()
470 kAnonSignJoinManager.processNewMessages(messageEntities); in makeSignJoinCall()
DPersistAdSelectionResultRunner.java292 List<KAnonMessageEntity> messageEntities = in makeKAnonSignJoin()
297 kAnonSignJoinManager.processNewMessages(messageEntities); in makeKAnonSignJoin()