fix: data race

celestiaorg · Nov 8, 2024 · 701eacf · 701eacf
1 parent 0f4bb48
commit 701eacf
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/rpc/grpc/api.go b/rpc/grpc/api.go
@@ -151,6 +151,8 @@ func (blockAPI *BlockAPI) retryNewBlocksSubscription(ctx context.Context) (bool,
 }
 
 func (blockAPI *BlockAPI) broadcastToListeners(ctx context.Context, height int64, hash []byte) {
+	blockAPI.Lock()
+	defer blockAPI.Unlock()
 	defer func() {
 		if r := recover(); r != nil {
 			core.GetEnvironment().Logger.Debug("failed to write to heights listener", "err", r)