From faa9330a838b6ba88b8ce7701ff4f3e7f9543acd Mon Sep 17 00:00:00 2001 From: ksolana <110843012+ksolana@users.noreply.github.com> Date: Fri, 1 Nov 2024 10:43:04 -0700 Subject: [PATCH] Rename commit_count to num_batches_processed --- core/src/banking_stage/consume_worker.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/core/src/banking_stage/consume_worker.rs b/core/src/banking_stage/consume_worker.rs index 971e5abb2682fe..d1476d329835c3 100644 --- a/core/src/banking_stage/consume_worker.rs +++ b/core/src/banking_stage/consume_worker.rs @@ -317,7 +317,7 @@ impl ConsumeWorkerMetrics { .find_and_send_votes_us .fetch_add(*find_and_send_votes_us, Ordering::Relaxed); self.timing_metrics - .commit_count + .num_batches_processed .fetch_add(1, Ordering::Relaxed); } @@ -522,7 +522,7 @@ struct ConsumeWorkerTimingMetrics { find_and_send_votes_us: AtomicU64, wait_for_bank_success_us: AtomicU64, wait_for_bank_failure_us: AtomicU64, - commit_count: AtomicU64, + num_batches_processed: AtomicU64, } impl ConsumeWorkerTimingMetrics { @@ -556,8 +556,8 @@ impl ConsumeWorkerTimingMetrics { i64 ), ( - "commit_count", - self.commit_count.swap(0, Ordering::Relaxed), + "num_batches_processed", + self.num_batches_processed.swap(0, Ordering::Relaxed), i64 ), (