This commit is contained in:
William Banfield
2022-03-17 15:32:51 -04:00
parent 3cd2453c79
commit 04d4744ff0
2 changed files with 5 additions and 5 deletions
+4 -4
View File
@@ -472,10 +472,10 @@ func (r *Reactor) updateRoundStateRoutine() {
} }
} }
func (conR *Reactor) getRoundState() *cstypes.RoundState { func (r *Reactor) getRoundState() *cstypes.RoundState {
conR.mtx.RLock() r.mtx.RLock()
defer conR.mtx.RUnlock() defer r.mtx.RUnlock()
return conR.rs return r.rs
} }
func (r *Reactor) gossipDataForCatchup(rs *cstypes.RoundState, prs *cstypes.PeerRoundState, ps *PeerState) { func (r *Reactor) gossipDataForCatchup(rs *cstypes.RoundState, prs *cstypes.PeerRoundState, ps *PeerState) {
+1 -1
View File
@@ -884,7 +884,7 @@ func (cs *State) handleMsg(mi msgInfo) {
// We unlock here to yield to any routines that need to read the the RoundState. // We unlock here to yield to any routines that need to read the the RoundState.
// Previously, this code held the lock from the point at which the final block // Previously, this code held the lock from the point at which the final block
// part was recieved until the block executed against the application. // part was received until the block executed against the application.
// This prevented the reactor from being able to retrieve the most updated // This prevented the reactor from being able to retrieve the most updated
// version of the RoundState. The reactor needs the updated RoundState to // version of the RoundState. The reactor needs the updated RoundState to
// gossip the now completed block. // gossip the now completed block.