ensure lock is obtained when getting values channel

infobloxopen · Aug 14, 2023 · 6aeae4f · 6aeae4f
1 parent cf5d56b
commit 6aeae4f
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/fsnotify/filewatcher.go b/fsnotify/filewatcher.go
@@ -2,14 +2,14 @@ package fsnotify
 
 import (
 	"context"
-	rfsnotify "github.com/fsnotify/fsnotify"
 	"io/ioutil"
 	"log"
 	"net/url"
 	"strings"
 	"sync"
 	"time"
 
+	rfsnotify "github.com/fsnotify/fsnotify"
 	"github.com/infobloxopen/hotload"
 )
 
@@ -98,8 +98,9 @@ func (s *Strategy) setVal(pth string, val string) {
 	s.mu.Lock()
 	defer s.mu.Unlock()
 	s.paths[pth].value = val
+	values := s.paths[pth].values
 	go func() {
-		s.paths[pth].values <- val
+		values <- val
 	}()
 }