consensus: fix race

2023-07-11 12:02:15 +02:00 · 2023-07-11 12:02:15 +02:00 · ebf4034ec7
commit ebf4034ec7
parent 1a23081336
1 changed files with 2 additions and 0 deletions
--- a/consensus/consensusclient/client.go
+++ b/consensus/consensusclient/client.go
@ -212,6 +212,7 @@ func (s *service) streamReader() error {
 		if len(events) == 0 {
 			return s.stream.Err()
 		}
+		s.mu.Lock()
 		for _, e := range events {
 			if w, ok := s.watchers[e.LogId]; ok {
 				if e.Error == nil {
@ -223,6 +224,7 @@ func (s *service) streamReader() error {
 				log.Warn("received unexpected log id", zap.String("logId", e.LogId))
 			}
 		}
+		s.mu.Unlock()
 	}
 }