From b9512c9e93a6f8b1bfdb9406dbacf89515672b68 Mon Sep 17 00:00:00 2001 From: Armin Schrenk Date: Fri, 21 Mar 2025 15:37:04 +0100 Subject: [PATCH] cleanup --- .../java/org/cryptomator/common/vaults/Vault.java | 2 +- .../cryptomator/event/FileSystemEventAggregator.java | 4 ++-- .../java/org/cryptomator/ui/fxapp/FxFSEventList.java | 11 +++++------ 3 files changed, 8 insertions(+), 9 deletions(-) diff --git a/src/main/java/org/cryptomator/common/vaults/Vault.java b/src/main/java/org/cryptomator/common/vaults/Vault.java index 89e1d5002..a1ad1aa42 100644 --- a/src/main/java/org/cryptomator/common/vaults/Vault.java +++ b/src/main/java/org/cryptomator/common/vaults/Vault.java @@ -259,7 +259,7 @@ public class Vault { private void consumeVaultEvent(FilesystemEvent e) { - fileSystemEventAggregator.enqueue(this, e); + fileSystemEventAggregator.put(this, e); } // ****************************************************************************** diff --git a/src/main/java/org/cryptomator/event/FileSystemEventAggregator.java b/src/main/java/org/cryptomator/event/FileSystemEventAggregator.java index c2b787daa..3acc38fe6 100644 --- a/src/main/java/org/cryptomator/event/FileSystemEventAggregator.java +++ b/src/main/java/org/cryptomator/event/FileSystemEventAggregator.java @@ -29,12 +29,12 @@ public class FileSystemEventAggregator { } /** - * Enques the given event to be inserted into the map. + * Adds the given event to the map. If a bucket for this event already exists, only the count is updated and the event set as the most recent one. * * @param v Vault where the event occurred * @param e Actual {@link FilesystemEvent} */ - public void enqueue(Vault v, FilesystemEvent e) { + public void put(Vault v, FilesystemEvent e) { var key = computeKey(v, e); hasUpdates.set(true); map.compute(key, (k, val) -> { diff --git a/src/main/java/org/cryptomator/ui/fxapp/FxFSEventList.java b/src/main/java/org/cryptomator/ui/fxapp/FxFSEventList.java index 1af084970..22cf81714 100644 --- a/src/main/java/org/cryptomator/ui/fxapp/FxFSEventList.java +++ b/src/main/java/org/cryptomator/ui/fxapp/FxFSEventList.java @@ -34,15 +34,10 @@ public class FxFSEventList { flush(); } }, 1000, 1000, TimeUnit.MILLISECONDS); - //TODO: allow the task to be canceled (to enable ui actions, e.g. when the contextMenu is open, the list should not be updated - } - - public ObservableList> getObservableList() { - return events; } /** - * Clones the aggregator into the observable list + * Starts the clone task on the FX thread and wait till it is completed */ private void flush() { var latch = new CountDownLatch(1); @@ -58,6 +53,10 @@ public class FxFSEventList { } } + public ObservableList> getObservableList() { + return events; + } + public BooleanProperty unreadEventsProperty() { return unreadEvents; }