From e2a0a37abfb5d1437d3187bf58d0b75533648ade Mon Sep 17 00:00:00 2001 From: Zlatin Balevsky Date: Thu, 26 Mar 2020 15:40:53 +0000 Subject: [PATCH] ui force sync event --- .../core/files/directories/UISyncDirectoryEvent.groovy | 7 +++++++ .../files/directories/WatchedDirectoryManager.groovy | 9 +++++++++ 2 files changed, 16 insertions(+) create mode 100644 core/src/main/groovy/com/muwire/core/files/directories/UISyncDirectoryEvent.groovy diff --git a/core/src/main/groovy/com/muwire/core/files/directories/UISyncDirectoryEvent.groovy b/core/src/main/groovy/com/muwire/core/files/directories/UISyncDirectoryEvent.groovy new file mode 100644 index 00000000..2721db26 --- /dev/null +++ b/core/src/main/groovy/com/muwire/core/files/directories/UISyncDirectoryEvent.groovy @@ -0,0 +1,7 @@ +package com.muwire.core.files.directories + +import com.muwire.core.Event + +class UISyncDirectoryEvent extends Event { + File directory +} diff --git a/core/src/main/groovy/com/muwire/core/files/directories/WatchedDirectoryManager.groovy b/core/src/main/groovy/com/muwire/core/files/directories/WatchedDirectoryManager.groovy index 5bf8f983..6b10864a 100644 --- a/core/src/main/groovy/com/muwire/core/files/directories/WatchedDirectoryManager.groovy +++ b/core/src/main/groovy/com/muwire/core/files/directories/WatchedDirectoryManager.groovy @@ -54,6 +54,15 @@ class WatchedDirectoryManager { timer.cancel() } + void onUISyncDirectoryEvent(UISyncDirectoryEvent e) { + def wd = watchedDirs.get(e.directory) + if (wd == null) { + log.warning("Got a sync event for non-watched dir ${e.directory}") + return + } + diskIO.submit({sync(wd, System.currentTimeMillis())} as Runnable) + } + void onWatchedDirectoryConfigurationEvent(WatchedDirectoryConfigurationEvent e) { if (converting) { def newDir = new WatchedDirectory(e.directory)