TransactionScheduler: detailed consume worker metrics (#33895)

solana-labs · Nov 20, 2023 · 8a298f1 · 8a298f1
1 parent c0a4fc8
commit 8a298f1
Show file tree

Hide file tree

Showing 4 changed files with 510 additions and 18 deletions.
diff --git a/core/src/banking_stage.rs b/core/src/banking_stage.rs
@@ -556,9 +556,11 @@ impl BankingStage {
         let (finished_work_sender, finished_work_receiver) = unbounded();
 
         // Spawn the worker threads
+        let mut worker_metrics = Vec::with_capacity(num_workers as usize);
         for (index, work_receiver) in work_receivers.into_iter().enumerate() {
             let id = (index as u32).saturating_add(NUM_VOTE_PROCESSING_THREADS);
             let consume_worker = ConsumeWorker::new(
+                id,
                 work_receiver,
                 Consumer::new(
                     committer.clone(),
@@ -570,6 +572,7 @@ impl BankingStage {
                 poh_recorder.read().unwrap().new_leader_bank_notifier(),
             );
 
+            worker_metrics.push(consume_worker.metrics_handle());
             bank_thread_hdls.push(
                 Builder::new()
                     .name(format!("solCoWorker{id:02}"))
@@ -590,6 +593,7 @@ impl BankingStage {
                 packet_deserializer,
                 bank_forks,
                 scheduler,
+                worker_metrics,
             );
             Builder::new()
                 .name("solBnkTxSched".to_string())