metrics at a better position

andyzhang2023 · Sep 11, 2024 · a5648fb · a5648fb
1 parent 524c366
commit a5648fb
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/eth/protocols/eth/broadcast.go b/eth/protocols/eth/broadcast.go
@@ -105,8 +105,6 @@ func (p *Peer) broadcastTransactions() {
 			}
 			queue = queue[:copy(queue, queue[hashesCount:])]
 
-			txP2PBroadQueueGauge.Update(int64(len(queue)))
-
 			// If there's anything available to transfer, fire up an async writer
 			if len(txs) > 0 {
 				done = make(chan struct{})
@@ -137,6 +135,8 @@ func (p *Peer) broadcastTransactions() {
 				queue = queue[:copy(queue, queue[len(queue)-maxQueuedTxs:])]
 			}
 
+			txP2PBroadQueueGauge.Update(int64(len(queue)))
+
 		case <-done:
 			done = nil
 
@@ -181,8 +181,6 @@ func (p *Peer) announceTransactions() {
 			// Shift and trim queue
 			queue = queue[:copy(queue, queue[count:])]
 
-			txP2PAnnQueueGauge.Update(int64(len(queue)))
-
 			// If there's anything available to transfer, fire up an async writer
 			if len(pending) > 0 {
 				done = make(chan struct{})
@@ -214,6 +212,8 @@ func (p *Peer) announceTransactions() {
 				queue = queue[:copy(queue, queue[len(queue)-maxQueuedTxAnns:])]
 			}
 
+			txP2PAnnQueueGauge.Update(int64(len(queue)))
+
 		case <-done:
 			done = nil