From 0ad767c759786e9e982238f060e19a710842e0bb Mon Sep 17 00:00:00 2001
From: mstmdev <mstmdev@gmail.com>
Date: Thu, 23 Dec 2021 00:14:51 +0800
Subject: [PATCH] Reduce writing the file or directory that does not exist

---
 monitor/base_monitor.go | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/monitor/base_monitor.go b/monitor/base_monitor.go
index f604a243..c7ddaf09 100644
--- a/monitor/base_monitor.go
+++ b/monitor/base_monitor.go
@@ -5,6 +5,7 @@ import (
 	"github.com/no-src/gofs/retry"
 	"github.com/no-src/gofs/sync"
 	"github.com/no-src/log"
+	"os"
 	"sort"
 	goSync "sync"
 	"time"
@@ -86,7 +87,13 @@ func (m *baseMonitor) startSyncWrite() {
 		name := <-m.writeChan
 		if m.retry != nil {
 			m.retry.Do(func() error {
-				return m.syncer.Write(name)
+				err := m.syncer.Write(name)
+				// if file or directory is not exist, ignore it and warning
+				if os.IsNotExist(err) {
+					log.Warn("write file failed => [%s]", err.Error())
+					return nil
+				}
+				return err
 			}, fmt.Sprintf("write file => %s", name))
 		} else {
 			if err := m.syncer.Write(name); err != nil {