Merge pull request #357 from wonderflow/removedir

remove runner when dir not exist
qiniu · Mar 5, 2018 · 66b1620 · 66b1620
2 parents 4047ced + f18ad11
commit 66b1620
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/mgr/mgr.go b/mgr/mgr.go
@@ -322,6 +322,8 @@ func (m *Manager) handle(path string, watcher *fsnotify.Watcher) {
 					m.watcherMux.Lock()
 					delete(m.watchers, path)
 					m.watcherMux.Unlock()
+					// TODO 此处代表文件夹被删了，只移除一个runner可能不够，文件夹下会有其他runner没有被删除
+					m.Remove(ev.Name)
 					return
 				}
 				m.Remove(ev.Name)