From e2528ad7ca5061e30636cba286bf157a8e983840 Mon Sep 17 00:00:00 2001 From: Zohaib Sibte Hassan Date: Thu, 28 Dec 2023 10:14:34 -0800 Subject: [PATCH] Fix --- db/change_log.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/db/change_log.go b/db/change_log.go index e4f28ba..526e343 100644 --- a/db/change_log.go +++ b/db/change_log.go @@ -263,6 +263,7 @@ func (conn *SqliteStreamDB) filterChangesTo(changed chan fsnotify.Event, watcher } if ev.Op == fsnotify.Chmod { + time.Sleep(1 * time.Millisecond) continue } @@ -285,7 +286,7 @@ func (conn *SqliteStreamDB) watchChanges(watcher *fsnotify.Watcher, path string) // Publish change logs for any residual change logs before starting watcher conn.publishChangeLog() - conn.filterChangesTo(dbChanged, watcher) + go conn.filterChangesTo(dbChanged, watcher) for { changeLogTicker.Reset()