mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-04-24 17:50:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

add metric to all places

Browse Source
This commit is contained in:
William Banfield
2022-11-23 11:18:53 -05:00
parent 7a141c0225
commit d5dc6fca3c
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
consensus/reactor.go
View File

@@ -755,6 +755,7 @@ OUTER_LOOP:
// If peer is lagging by height 1, send LastCommit.
if prs.Height != 0 && rs.Height == prs.Height+1 {
if ps.PickSendVote(rs.LastCommit) {
conR.Metrics.VoteSent.With("type", "precommit").Add(1)
logger.Debug("Picked rs.LastCommit to send", "height", prs.Height)
continue OUTER_LOOP
}
@@ -768,6 +769,7 @@ OUTER_LOOP:
// which contains precommit signatures for prs.Height.
if commit := conR.conS.blockStore.LoadBlockCommit(prs.Height); commit != nil {
if ps.PickSendVote(commit) {
conR.Metrics.VoteSent.With("type", "precommit").Add(1)
logger.Debug("Picked Catchup commit to send", "height", prs.Height)
continue OUTER_LOOP
}
@@ -800,6 +802,7 @@ func (conR *Reactor) gossipVotesForHeight(
// If there are lastCommits to send...
if prs.Step == cstypes.RoundStepNewHeight {
if ps.PickSendVote(rs.LastCommit) {
conR.Metrics.VoteSent.With("type", "precommit").Add(1)
logger.Debug("Picked rs.LastCommit to send")
return true
}