Merge pull request 'fix skip condition' (#6) from feature/fix-watch into develop
Reviewed-on: #6
This commit is contained in:
commit
cf1ad2ed4b
@ -54,10 +54,17 @@ func main() {
|
||||
// channel closed
|
||||
return
|
||||
}
|
||||
if event.Op&fsnotify.Write == fsnotify.Write {
|
||||
// 改成有變動就reload
|
||||
if event.Op&fsnotify.Write == fsnotify.Write || event.Op&fsnotify.Chmod == fsnotify.Chmod {
|
||||
// send reload channel
|
||||
reloadChan <- struct{}{}
|
||||
}
|
||||
if event.Op&fsnotify.Remove == fsnotify.Remove {
|
||||
watcher.Remove(cfgPath)
|
||||
if err := watcher.Add(cfgPath); err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
}
|
||||
case err, ok := <-watcher.Errors:
|
||||
if !ok {
|
||||
// channel closed
|
||||
@ -113,8 +120,8 @@ func runService(reload <-chan struct{}) {
|
||||
}
|
||||
return
|
||||
}
|
||||
if time.Since(lastReload).Seconds() < float64(2*time.Second) {
|
||||
break
|
||||
if time.Since(lastReload).Seconds() < (2 * time.Second).Seconds() {
|
||||
continue
|
||||
}
|
||||
|
||||
lastReload = time.Now()
|
||||
|
Loading…
Reference in New Issue
Block a user