From 70624e8d27420d9c11cbd5537596d340b9dc423f Mon Sep 17 00:00:00 2001 From: William Banfield Date: Wed, 3 Aug 2022 18:20:12 -0400 Subject: [PATCH] more lock instrumentation --- internal/consensus/state.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/internal/consensus/state.go b/internal/consensus/state.go index 81f676a83..48489cf62 100644 --- a/internal/consensus/state.go +++ b/internal/consensus/state.go @@ -2070,6 +2070,8 @@ func (cs *State) tryAddVote(vote *types.Vote, peerID types.NodeID) (bool, error) } func (cs *State) addVote(vote *types.Vote, peerID types.NodeID) (added bool, err error) { + cs.metrics.Locks.With("function", "addvote").Add(float64(1)) + defer cs.metrics.Locks.With("function", "addvote").Add(float64(-1)) cs.Logger.Debug( "adding vote", "vote_height", vote.Height, @@ -2123,10 +2125,15 @@ func (cs *State) addVote(vote *types.Vote, peerID types.NodeID) (added bool, err return } + cs.metrics.Locks.With("function", "addvote").Add(float64(1)) if err := cs.eventBus.PublishEventVote(types.EventDataVote{Vote: vote}); err != nil { + cs.metrics.Locks.With("function", "publisheventvote").Add(float64(-1)) return added, err } + cs.metrics.Locks.With("function", "publisheventvote").Add(float64(-1)) + cs.metrics.Locks.With("function", "fireeventvote").Add(float64(1)) cs.evsw.FireEvent(types.EventVoteValue, vote) + cs.metrics.Locks.With("function", "fireeventvote").Add(float64(-1)) switch vote.Type { case tmproto.PrevoteType: