mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-05-23 23:51:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

p2p: fix priority queue bytes pending metric

Browse Source
This commit is contained in:
William Banfield
2021-10-13 15:42:46 -04:00
parent 4fe0f262d4
commit c9521c9e2d
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
internal/p2p/pqueue.go
View File

@@ -257,6 +257,9 @@ func (s *pqScheduler) process() {
s.metrics.PeerSendBytesTotal.With(
"chID", chIDStr,
"peer_id", string(pqEnv.envelope.To)).Add(float64(pqEnv.size))
s.metrics.PeerPendingSendBytes.With(
"chID", chIDStr,
"peer_id", string(pqEnv.envelope.To)).Add(float64(-pqEnv.size))
select {
case s.dequeueCh <- pqEnv.envelope:
case <-s.closer.Done():