From c9521c9e2d728801fee245a9892da99cec86f953 Mon Sep 17 00:00:00 2001
From: William Banfield <wbanfield@gmail.com>
Date: Wed, 13 Oct 2021 15:42:46 -0400
Subject: [PATCH] p2p: fix priority queue bytes pending metric

---
 internal/p2p/pqueue.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/internal/p2p/pqueue.go b/internal/p2p/pqueue.go
index e4560c7bd..7dc195884 100644
--- a/internal/p2p/pqueue.go
+++ b/internal/p2p/pqueue.go
@@ -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():