mirror of
https://github.com/navidrome/navidrome.git
synced 2025-12-23 23:18:05 -05:00
fix(scanner): reset watcher trigger timer for debounce on notification receipt
Signed-off-by: Deluan <deluan@navidrome.org>
This commit is contained in:
@@ -122,6 +122,9 @@ func (w *watcher) Run(ctx context.Context) error {
|
|||||||
w.mu.Unlock()
|
w.mu.Unlock()
|
||||||
return nil
|
return nil
|
||||||
case notification := <-w.watcherNotify:
|
case notification := <-w.watcherNotify:
|
||||||
|
// Reset the trigger timer for debounce
|
||||||
|
trigger.Reset(w.triggerWait)
|
||||||
|
|
||||||
lib := notification.Library
|
lib := notification.Library
|
||||||
folderPath := notification.FolderPath
|
folderPath := notification.FolderPath
|
||||||
|
|
||||||
@@ -131,7 +134,6 @@ func (w *watcher) Run(ctx context.Context) error {
|
|||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
targets[target] = struct{}{}
|
targets[target] = struct{}{}
|
||||||
trigger.Reset(w.triggerWait)
|
|
||||||
|
|
||||||
log.Debug(ctx, "Watcher: Detected changes. Waiting for more changes before triggering scan",
|
log.Debug(ctx, "Watcher: Detected changes. Waiting for more changes before triggering scan",
|
||||||
"libraryID", lib.ID, "name", lib.Name, "path", lib.Path, "folderPath", folderPath)
|
"libraryID", lib.ID, "name", lib.Name, "path", lib.Path, "folderPath", folderPath)
|
||||||
|
|||||||
Reference in New Issue
Block a user