fix metric

This commit is contained in:
William Banfield
2021-10-13 16:01:29 -04:00
parent e80807a07e
commit 90dd875c11
-1
View File
@@ -259,7 +259,6 @@ func (s *pqScheduler) process() {
"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: