Add debug log for fsnotify remove and rename

ansible · Nov 14, 2024 · 9555da8 · 9555da8
1 parent 25ff7aa
commit 9555da8
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/pkg/workceptor/workunitbase.go b/pkg/workceptor/workunitbase.go
@@ -439,6 +439,16 @@ loop:
 				if err != nil {
 					bwu.w.nc.GetLogger().Error("Watcher Events Error reading %s: %s", statusFile, err)
 				}
+			} else if event.Op&fsnotify.Remove == fsnotify.Remove {
+				err = bwu.Load()
+				if err != nil {
+					bwu.w.nc.GetLogger().Error("Watcher Events Remove reading %s: %s", statusFile, err)
+				}
+			} else if event.Op&fsnotify.Rename == fsnotify.Rename {
+				err = bwu.Load()
+				if err != nil {
+					bwu.w.nc.GetLogger().Error("Watcher Events Rename reading %s: %s", statusFile, err)
+				}
 			}
 		case <-time.After(time.Second):
 			newFi, err := bwu.fs.Stat(statusFile)