| /external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/internal/ |
| D | MobileDataDownloadManager.java | 116 private final Executor sequentialControlExecutor; field in MobileDataDownloadManager
137 @SequentialControlExecutor Executor sequentialControlExecutor, in MobileDataDownloadManager() argument
153 this.sequentialControlExecutor = sequentialControlExecutor; in MobileDataDownloadManager()
189 sequentialControlExecutor); in init()
193 sequentialControlExecutor) in init()
207 sequentialControlExecutor), in init()
208 sequentialControlExecutor) in init()
221 sequentialControlExecutor), in init()
222 sequentialControlExecutor) in init()
223 .transformAsync(voidArg -> fileGroupsMetadata.init(), sequentialControlExecutor) in init()
[all …]
|
| D | ExpirationHandler.java | 73 private final Executor sequentialControlExecutor; field in ExpirationHandler
87 @SequentialControlExecutor Executor sequentialControlExecutor, in ExpirationHandler() argument
98 this.sequentialControlExecutor = sequentialControlExecutor; in ExpirationHandler()
109 sequentialControlExecutor), in updateExpiration()
110 sequentialControlExecutor); in updateExpiration()
155 sequentialControlExecutor); in removeExpiredFreshGroups()
157 sequentialControlExecutor); in removeExpiredFreshGroups()
205 sequentialControlExecutor),
206 sequentialControlExecutor);
208 sequentialControlExecutor);
[all …]
|
| D | SharedFileManager.java | 123 private final Executor sequentialControlExecutor; field in SharedFileManager
138 @SequentialControlExecutor Executor sequentialControlExecutor) { in SharedFileManager() argument
150 this.sequentialControlExecutor = sequentialControlExecutor; in SharedFileManager()
230 sequentialControlExecutor); in reserveFileEntry()
232 sequentialControlExecutor); in reserveFileEntry()
299 sequentialControlExecutor);
301 sequentialControlExecutor);
335 sequentialControlExecutor)
351 sequentialControlExecutor);
364 sequentialControlExecutor);
[all …]
|
| D | FileGroupManager.java | 143 private final Executor sequentialControlExecutor; field in FileGroupManager
161 @SequentialControlExecutor Executor sequentialControlExecutor, in FileGroupManager() argument
173 this.sequentialControlExecutor = sequentialControlExecutor; in FileGroupManager()
243 voidArg -> isAddedGroupDuplicate(groupKey, receivedGroup), sequentialControlExecutor) in addGroupForDownload()
294 sequentialControlExecutor); in addGroupForDownload()
310 sequentialControlExecutor)
320 sequentialControlExecutor)
323 sequentialControlExecutor)
337 sequentialControlExecutor);
462 .call(() -> null, sequentialControlExecutor);
[all …]
|
| D | SharedPreferencesFileGroupsMetadata.java | 70 private final Executor sequentialControlExecutor; field in SharedPreferencesFileGroupsMetadata
78 @SequentialControlExecutor Executor sequentialControlExecutor) { in SharedPreferencesFileGroupsMetadata() argument
83 this.sequentialControlExecutor = sequentialControlExecutor; in SharedPreferencesFileGroupsMetadata()
202 sequentialControlExecutor); in getAllFreshGroups() field in SharedPreferencesFileGroupsMetadata
204 sequentialControlExecutor); in getAllFreshGroups()
|
| /external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/internal/util/ |
| D | DownloadFutureMap.java | 49 private final Executor sequentialControlExecutor; field in DownloadFutureMap
57 private DownloadFutureMap(Executor sequentialControlExecutor, StateChangeCallbacks callbacks) { in DownloadFutureMap() argument
58 this.sequentialControlExecutor = sequentialControlExecutor; in DownloadFutureMap()
63 public static <T> DownloadFutureMap<T> create(Executor sequentialControlExecutor) { in create() argument
64 return create(sequentialControlExecutor, new StateChangeCallbacks() {}); in create()
69 Executor sequentialControlExecutor, StateChangeCallbacks callbacks) { in create() argument
70 return new DownloadFutureMap<T>(sequentialControlExecutor, callbacks); in create()
95 sequentialControlExecutor); in add()
113 sequentialControlExecutor);
119 () -> Optional.fromNullable(keyToDownloadFutureMap.get(key)), sequentialControlExecutor);
[all …]
|
| /external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/ |
| D | MobileDataDownloadImpl.java | 123 private final Executor sequentialControlExecutor; field in MobileDataDownloadImpl
142 Executor sequentialControlExecutor, in MobileDataDownloadImpl() argument
156 this.sequentialControlExecutor = sequentialControlExecutor; in MobileDataDownloadImpl()
167 sequentialControlExecutor, in MobileDataDownloadImpl()
169 this.downloadFutureMap = DownloadFutureMap.create(sequentialControlExecutor); in MobileDataDownloadImpl()
172 sequentialControlExecutor, in MobileDataDownloadImpl()
299 sequentialControlExecutor); in attachMddApiLogging()
310 () -> addFileGroupHelper(addFileGroupRequest), sequentialControlExecutor); in addFileGroup()
414 sequentialControlExecutor); in removeFileGroup()
416 sequentialControlExecutor); in removeFileGroup() field in MobileDataDownloadImpl
[all …]
|
| D | MobileDataDownloadBuilder.java | 307 Executor sequentialControlExecutor = MoreExecutors.newSequentialExecutor(controlExecutor); in build() local
313 () -> configurator.get().commitToFlagSnapshot(), sequentialControlExecutor); in build()
333 componentBuilder.executorsModule(new ExecutorsModule(sequentialControlExecutor)); in build()
381 .setControlExecutor(sequentialControlExecutor) in build()
398 sequentialControlExecutor, in build()
|
| /external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/lite/ |
| D | DownloaderImpl.java | 49 private final Executor sequentialControlExecutor; field in DownloaderImpl
59 Executor sequentialControlExecutor, in DownloaderImpl() argument
63 this.sequentialControlExecutor = sequentialControlExecutor; in DownloaderImpl()
67 this.downloadFutureMap = DownloadFutureMap.create(sequentialControlExecutor); in DownloaderImpl()
70 sequentialControlExecutor, in DownloaderImpl()
109 startTask, unused -> startDownload(downloadRequest), sequentialControlExecutor); in download()
148 sequentialControlExecutor); in download()
182 sequentialControlExecutor); in download()
184 sequentialControlExecutor); in download()
256 startTask, unused -> startDownload(downloadRequest), sequentialControlExecutor);
[all …]
|
| D | Downloader.java | 99 private Executor sequentialControlExecutor; field in Downloader.Builder
117 this.sequentialControlExecutor = MoreExecutors.newSequentialExecutor(controlExecutor); in setControlExecutor()
167 sequentialControlExecutor, in build()
|
| D | DownloadProgressMonitor.java | 38 private final Executor sequentialControlExecutor; field in DownloadProgressMonitor
46 this.sequentialControlExecutor = MoreExecutors.newSequentialExecutor(controlExecutor); in DownloadProgressMonitor()
156 sequentialControlExecutor.execute(() -> downloadListener.onProgress(byteCounter.get())); in notifyProgress()
|
| /external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/internal/dagger/ |
| D | ExecutorsModule.java | 29 private final Executor sequentialControlExecutor; field in ExecutorsModule
31 public ExecutorsModule(Executor sequentialControlExecutor) { in ExecutorsModule() argument
32 this.sequentialControlExecutor = sequentialControlExecutor; in ExecutorsModule()
39 return sequentialControlExecutor; in provideSequentialControlExecutor()
|
| /external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/internal/downloader/ |
| D | DownloaderCallbackImpl.java | 75 private final Executor sequentialControlExecutor; field in DownloaderCallbackImpl
88 Executor sequentialControlExecutor) { in DownloaderCallbackImpl() argument
100 this.sequentialControlExecutor = sequentialControlExecutor; in DownloaderCallbackImpl()
136 sequentialControlExecutor)) in onDownloadComplete()
147 sequentialControlExecutor) in onDownloadComplete()
148 .transformAsync(unused -> immediateFailedFuture(exception), sequentialControlExecutor); in onDownloadComplete()
158 sequentialControlExecutor); in onDownloadComplete()
172 sequentialControlExecutor); in onDownloadFailed()
179 sequentialControlExecutor); in onDownloadFailed()
348 Executor sequentialControlExecutor) { in getSharedFileOrFail() argument
[all …]
|
| D | DeltaFileDownloaderCallbackImpl.java | 73 private final Executor sequentialControlExecutor; field in DeltaFileDownloaderCallbackImpl
91 Executor sequentialControlExecutor) { in DeltaFileDownloaderCallbackImpl() argument
107 this.sequentialControlExecutor = sequentialControlExecutor; in DeltaFileDownloaderCallbackImpl()
134 sequentialControlExecutor)) in onDownloadComplete()
145 sequentialControlExecutor) in onDownloadComplete()
146 .transformAsync(unused -> immediateFailedFuture(exception), sequentialControlExecutor); in onDownloadComplete()
168 sequentialControlExecutor); in onDownloadComplete()
170 sequentialControlExecutor); in onDownloadComplete()
184 sequentialControlExecutor);
191 sequentialControlExecutor);
[all …]
|
| D | MddFileDownloader.java | 86 private final Executor sequentialControlExecutor; field in MddFileDownloader
113 @SequentialControlExecutor Executor sequentialControlExecutor, in MddFileDownloader() argument
121 this.sequentialControlExecutor = sequentialControlExecutor; in MddFileDownloader()
123 this.downloadOrCopyFutureMap = DownloadFutureMap.create(sequentialControlExecutor); in MddFileDownloader()
179 sequentialControlExecutor); in startDownloading()
211 .transformAsync(downloadOrCopyFunction, sequentialControlExecutor)
214 sequentialControlExecutor /*Run callbacks on @SequentialControlExecutor*/)
224 sequentialControlExecutor),
225 sequentialControlExecutor /*Run callbacks on @SequentialControlExecutor*/);
236 sequentialControlExecutor);
[all …]
|
| /external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/internal/logging/ |
| D | FileGroupStatsLogger.java | 49 private final Executor sequentialControlExecutor; field in FileGroupStatsLogger
56 @SequentialControlExecutor Executor sequentialControlExecutor) { in FileGroupStatsLogger() argument
60 this.sequentialControlExecutor = sequentialControlExecutor; in FileGroupStatsLogger()
100 sequentialControlExecutor)); in buildFileGroupStatusList() local
104 sequentialControlExecutor); in buildFileGroupStatusList() field in FileGroupStatsLogger
142 sequentialControlExecutor); in buildFileGroupStatus()
|
| D | StorageLogger.java | 73 private final Executor sequentialControlExecutor; field in StorageLogger
105 @SequentialControlExecutor Executor sequentialControlExecutor) { in StorageLogger() argument
113 this.sequentialControlExecutor = sequentialControlExecutor; in StorageLogger()
141 sequentialControlExecutor), in buildStorageStatsLogData()
142 sequentialControlExecutor); in buildStorageStatsLogData()
239 sequentialControlExecutor)); in buildStorageStatsInternal()
304 sequentialControlExecutor); in buildStorageStatsInternal() field in StorageLogger
337 SharedFileMissingException.class, e -> immediateFuture(null), sequentialControlExecutor) in computeFileSize()
349 sequentialControlExecutor); in computeFileSize()
|
| /external/mobile-data-download/javatests/com/google/android/libraries/mobiledatadownload/testing/ |
| D | FakeMobileDataDownload.java | 92 private final Executor sequentialControlExecutor; field in FakeMobileDataDownload
106 this.sequentialControlExecutor = MoreExecutors.newSequentialExecutor(executor); in FakeMobileDataDownload()
301 sequentialControlExecutor); in addFileGroup() field in FakeMobileDataDownload
367 () -> Futures.immediateFuture(true), sequentialControlExecutor); in removeFileGroup()
377 sequentialControlExecutor); in removeFileGroupsByFilter()
416 sequentialControlExecutor); in getFileGroup()
443 sequentialControlExecutor);
499 sequentialControlExecutor);
508 () -> downloadFileGroupInternal(downloadFileGroupRequest), sequentialControlExecutor);
517 () -> downloadFileGroupInternal(downloadFileGroupRequest), sequentialControlExecutor);
[all …]
|
| /external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/monitor/ |
| D | DownloadProgressMonitor.java | 49 private final Executor sequentialControlExecutor; field in DownloadProgressMonitor
59 this.sequentialControlExecutor = MoreExecutors.newSequentialExecutor(controlExecutor); in DownloadProgressMonitor()
248 sequentialControlExecutor.execute(() -> downloadListener.onProgress(byteCounter.get())); in flushCounter()
|