diff --git a/metrics/testnet-monitor.json b/metrics/testnet-monitor.json index 9d01e07ac1..1e5133db17 100644 --- a/metrics/testnet-monitor.json +++ b/metrics/testnet-monitor.json @@ -15,8 +15,8 @@ "editable": true, "gnetId": null, "graphTooltip": 0, - "id": 3, - "iteration": 1543087985461, + "id": 74, + "iteration": 1544477352265, "links": [ { "asDropdown": true, @@ -1541,6 +1541,44 @@ ] ], "tags": [] + }, + { + "groupBy": [ + { + "params": [ + "$__interval" + ], + "type": "time" + }, + { + "params": [ + "null" + ], + "type": "fill" + } + ], + "hide": false, + "orderByTime": "ASC", + "policy": "default", + "query": "SELECT mean(\"count\") AS \"peers\" FROM \"$testnet\".\"autogen\".\"counter-broadcast_service-num_peers\" WHERE $timeFilter GROUP BY time(1s) FILL(0)", + "rawQuery": true, + "refId": "C", + "resultFormat": "time_series", + "select": [ + [ + { + "params": [ + "value" + ], + "type": "field" + }, + { + "params": [], + "type": "mean" + } + ] + ], + "tags": [] } ], "thresholds": [], @@ -5572,5 +5610,5 @@ "timezone": "", "title": "Testnet Monitor (edge)", "uid": "testnet-edge", - "version": 110 + "version": 111 } diff --git a/src/broadcast_service.rs b/src/broadcast_service.rs index a639c99611..8b73cba6c5 100644 --- a/src/broadcast_service.rs +++ b/src/broadcast_service.rs @@ -216,6 +216,7 @@ impl BroadcastService { let mut tick_height_ = tick_height; loop { let broadcast_table = cluster_info.read().unwrap().tvu_peers(); + inc_new_counter_info!("broadcast_service-num_peers", broadcast_table.len() + 1); let leader_id = cluster_info.read().unwrap().leader_id(); if let Err(e) = broadcast( max_tick_height,