oops

internal/consensus/reactor.go

@@ -349,6 +349,7 @@ func (r *Reactor) broadcastHasVoteMessage(ctx context.Context, vote *types.Vote)
 // upon receiving.
 func (r *Reactor) subscribeToBroadcastEvents() {
 	onStopCh := r.state.getOnStopCh()
+
 	err := r.state.evsw.AddListenerForEvent(
 		listenerIDConsensus,
 		types.EventNewRoundStepValue,

internal/consensus/state.go

@@ -497,7 +497,7 @@ func (cs *State) getOnStopCh() chan *cstypes.RoundState {
 	cs.mtx.RLock()
 	defer cs.mtx.RUnlock()
 
-	return r.state.onStopCh
+	return cs.onStopCh
 }
 
 // OnStop implements service.Service.