Home
last modified time | relevance | path

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

/packages/modules/AdServices/adservices/libraries/cobalt/tests/src/com/android/cobalt/data/
DDataServiceTest.java106 private DataService mDataService; field in DataServiceTest
115 mDataService = new DataService(EXECUTOR, mCobaltDatabase); in setup()
159 assertThat(mDataService.loggerEnabled(TIME).get()).isEqualTo(TIME); in loggerEnabled_oneTime_stored()
167 mDataService.loggerEnabled(TIME).get(); in loggerEnabled_multipleTimes_firstIsStored()
168 assertThat(mDataService.loggerEnabled(timePlusHours(1)).get()).isEqualTo(TIME); in loggerEnabled_multipleTimes_firstIsStored()
171 assertThat(mDataService.loggerEnabled(TIME).get()).isEqualTo(TIME); in loggerEnabled_multipleTimes_firstIsStored()
179 mDataService.loggerDisabled(TIME).get(); in loggerDisabled_notYetEnabled_stored()
190 mDataService.loggerEnabled(enabledTime).get(); in loggerDisabled_afterEnabled_stored()
193 mDataService.loggerDisabled(TIME).get(); in loggerDisabled_afterEnabled_stored()
206 mDataService.loggerEnabled(enabledTime).get(); in loggerDisabled_multipleTimesAfterEnabled_stored()
[all …]
/packages/modules/AdServices/adservices/libraries/cobalt/tests/src/com/android/cobalt/impl/
DCobaltPeriodicJobImplTest.java264 private DataService mDataService; field in CobaltPeriodicJobImplTest
308 mDataService = new DataService(EXECUTOR, mCobaltDatabase);
319 mDataService,
333 mDataService.loggerEnabled(ENABLED_TIME).get();
391 mDataService
438 mDataService
447 mDataService
456 mDataService
527 mDataService
536 mDataService
[all …]
DCobaltLoggerImplTest.java169 private DataService mDataService; field in CobaltLoggerImplTest
178 mDataService = new DataService(sExecutor, mCobaltDatabase); in createDb()
186 mDataService, in createDb()
447 mDataService, in logOccurrence_loggerDisabled_loggedDataNotStoredInDb()
489 mDataService, in logOccurrence_oneLogForMetricInLaterReleaseStage_dropped()
530 mDataService, in logOccurrence_oneLogForReportInLaterReleaseStage_dropped()
807 mDataService, in logString_loggerDisabled_loggedDataNotStoredInDb()
849 mDataService, in logString_oneLogForMetricInLaterReleaseStage_dropped()
891 mDataService, in logString_oneLogForReportInLaterReleaseStage_dropped()
/packages/modules/AdServices/adservices/libraries/cobalt/java/com/android/cobalt/impl/
DCobaltLoggerImpl.java55 private final DataService mDataService; field in CobaltLoggerImpl
71 mDataService = Objects.requireNonNull(dataService); in CobaltLoggerImpl()
83 return mDataService.loggerDisabled(Instant.ofEpochMilli(currentTimeMillis)); in logOccurrence()
90 mDataService.loggerEnabled(Instant.ofEpochMilli(currentTimeMillis))) in logOccurrence()
110 return mDataService.loggerDisabled(Instant.ofEpochMilli(currentTimeMillis)); in logString()
117 mDataService.loggerEnabled(Instant.ofEpochMilli(currentTimeMillis))) in logString()
211 mDataService.aggregateCount( in logNumberToReports()
248 mDataService.aggregateString( in logStringToReports()
DCobaltPeriodicJobImpl.java84 private final DataService mDataService; field in CobaltPeriodicJobImpl
112 mDataService = Objects.requireNonNull(dataService); in CobaltPeriodicJobImpl()
126 mDataService.getDaoBuildingBlocks(), in CobaltPeriodicJobImpl()
143 return mDataService.loggerDisabled(currentTime); in generateAggregatedObservations()
147 return FluentFuture.from(mDataService.loggerEnabled(currentTime)) in generateAggregatedObservations()
150 .transform(unused -> mDataService.getOldestObservationsToSend(), mExecutor) in generateAggregatedObservations()
201 mDataService.generateObservations( in generateAndSaveObservations()
216 unused -> mDataService.cleanup(relevantReports.build(), oldestDayIndex), in generateAndSaveObservations()
270 mDataService.removeSentObservations(observationStoreIds); in uploadAndRemoveObservationBatches()
/packages/modules/OnDevicePersonalization/framework/java/android/adservices/ondevicepersonalization/
DModelManager.java44 @NonNull private final IDataAccessService mDataService; field in ModelManager
51 mDataService = dataService; in ModelManager()
71 bundle.putBinder(Constants.EXTRA_DATA_ACCESS_SERVICE_BINDER, mDataService.asBinder()); in run()
127 mDataService.logApiCallStats(apiName, duration, responseCode); in logApiCallStats()