From ebf4034ec770bf70b45bc1e332ee26ad35e1432a Mon Sep 17 00:00:00 2001
From: Sergey Cherepanov <cheggaaa@gmail.com>
Date: Tue, 11 Jul 2023 12:02:15 +0200
Subject: [PATCH] consensus: fix race

---
 consensus/consensusclient/client.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/consensus/consensusclient/client.go b/consensus/consensusclient/client.go
index a17c7a83..d745bef6 100644
--- 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()
 	}
 }