fix race condition

5 years ago · 4afe8428c8
2 changed files with 3 additions and 3 deletions
--- a/path.go
+++ b/path.go
@ -59,7 +59,7 @@ func (pa *path) log(format string, args ...interface{}) {
 func (pa *path) onInit() {
 	if pa.source != nil {
-		go pa.source.run()
+		go pa.source.run(pa.source.state)
 	}
 	if pa.confp.RunOnInit != "" {
--- a/source.go
+++ b/source.go
@ -66,8 +66,8 @@ func newSource(p *program, path *path, confp *confPath) *source {
 func (s *source) isPublisher() {}
-func (s *source) run() {
+func (s *source) run(initialState sourceState) {
-	s.applyState(s.state)
+	s.applyState(initialState)
 outer:
 	for {