Method liveReloadWorker

daemon/rule/loader.go:457–494

()

}

func (l *Loader) liveReloadWorker() {
	l.setLiveReloadRunning(true)
	defer l.setLiveReloadRunning(false)

	log.Debug("Rules watcher started on path %s ...", l.Path)
	if err := l.watcher.Add(l.Path); err != nil {
		log.Error("Could not watch path: %s", err)
		return
	}

	for {
		select {
		case <-l.stopLiveReload:
			goto Exit
		case event := <-l.watcher.Events:
			// a new rule json file has been created or updated
			if event.Op&fsnotify.Write == fsnotify.Write {
				if strings.HasSuffix(event.Name, ".json") {
					log.Important("Ruleset changed due to %s, reloading ...", path.Base(event.Name))
					if err := l.loadRule(event.Name); err != nil {
						log.Warning("%s", err)
					}
				}
			} else if event.Op&fsnotify.Remove == fsnotify.Remove {
				if strings.HasSuffix(event.Name, ".json") {
					log.Important("Rule deleted %s", path.Base(event.Name))
					// we only need to delete from memory rules of type Always,
					// because the Remove event is of a file, i.e.: Duration == Always
					l.deleteRule(event.Name)
				}
			}
		case err := <-l.watcher.Errors:
			log.Error("File system watcher error: %s", err)
		}
	}
Exit:
	log.Debug("[rules] liveReloadWorker() exited")
}

// FindFirstMatch will try match the connection against the existing rule set.
func (l *Loader) FindFirstMatch(con *conman.Connection) (match *Rule) {