fix ref issue

projecteru2 · Oct 31, 2022 · 120ff45 · 120ff45
1 parent 6f0c51a
commit 120ff45
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/Makefile b/Makefile
@@ -22,7 +22,7 @@ binary:
 
 unit-test:
 	go vet `go list ./... | grep -v '/vendor/'`
-	go test -count=1 -timeout 240s -cover ./logs/... \
+	go test -race -count=1 -timeout 240s -cover ./logs/... \
 	./manager/node/... \
 	./manager/workload/... \
 	./types/... \

diff --git a/manager/workload/log.go b/manager/workload/log.go
@@ -48,8 +48,8 @@ func newLogBroadcaster() *logBroadcaster {
 func (l *logBroadcaster) getSubscribers(app string) map[string]*subscriber {
 	subs, ok := l.subscribersMap.Get(app)
 	if !ok {
-		l.subscribersMap.Set(app, map[string]*subscriber{})
 		subs = map[string]*subscriber{}
+		l.subscribersMap.Set(app, subs)
 	}
 	return subs
 }