Searched refs:syncTracker (Results 1 – 3 of 3) sorted by relevance
35 SyncTracker syncTracker = new SyncTracker(); in testCreateSyncFuture() local36 syncTracker.createSyncFuture(PLACEHOLDER_UUID); in testCreateSyncFuture()38 Collection<CompletableFuture<Object>> futures = syncTracker.pendingSyncFutures(); in testCreateSyncFuture()44 SyncTracker syncTracker = new SyncTracker(); in testMarkSyncAsComplete() local45 syncTracker.createSyncFuture(PLACEHOLDER_UUID); in testMarkSyncAsComplete()46 syncTracker.markSyncCompleted(PLACEHOLDER_UUID); in testMarkSyncAsComplete()48 Collection<CompletableFuture<Object>> futures = syncTracker.pendingSyncFutures(); in testMarkSyncAsComplete()55 SyncTracker syncTracker = new SyncTracker(); in testCompleteOnTimeoutSyncFuture() local56 syncTracker.createSyncFuture(PLACEHOLDER_UUID, 100L, TimeUnit.MILLISECONDS); in testCompleteOnTimeoutSyncFuture()58 Collection<CompletableFuture<Object>> pendingSyncFutures = syncTracker.pendingSyncFutures(); in testCompleteOnTimeoutSyncFuture()[all …]
43 @NonNull SyncTracker syncTracker, in waitForSync() argument48 syncTracker.pendingSyncFutures().toArray(new CompletableFuture[0])); in waitForSync()95 @NonNull SyncTracker syncTracker, in waitForSyncWithTimeout()100 syncTracker.pendingSyncFutures().toArray(new CompletableFuture[0])); in waitForSyncWithTimeout()
45 public static void setLocalSyncTracker(SyncTracker syncTracker) { in setLocalSyncTracker() argument46 sLocalSyncTracker = syncTracker; in setLocalSyncTracker()