Browse Source

more locking gpt

pull/8091/head
tycho garen 3 years ago
parent
commit
987036bf30
1 changed files with 11 additions and 2 deletions
  1. +11
    -2
      internal/consensus/state.go

+ 11
- 2
internal/consensus/state.go View File

@ -1406,7 +1406,11 @@ func (cs *State) createProposalBlock(ctx context.Context) (block *types.Block, b
return
}
proposerAddr := cs.privValidatorPubKey.Address()
proposerAddr := func() []byte {
cs.mtx.RLock()
defer cs.mtx.RUnlock()
return cs.privValidatorPubKey.Address()
}()
return cs.blockExec.CreateProposalBlock(ctx, cs.Height, cs.state, commit, proposerAddr, votes)
}
@ -2613,7 +2617,12 @@ func (cs *State) updatePrivValidatorPubKey(rctx context.Context) error {
if err != nil {
return err
}
cs.privValidatorPubKey = pubKey
func() {
cs.mtx.Lock()
defer cs.mtx.Unlock()
cs.privValidatorPubKey = pubKey
}()
return nil
}


Loading…
Cancel
Save