blockworks-foundation
/
solana
mirror of https://github.com/blockworks-foundation/solana.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

AHV uses metrics names like SPS's (#30584)

This commit is contained in:
Brooks 2023-03-03 16:38:35 -07:00 committed by GitHub
parent eb4e7584b9
commit cd652a7e20
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
core/src/accounts_hash_verifier.rs
View File

@ -7,7 +7,7 @@
use { use {
crossbeam_channel::{Receiver, Sender}, crossbeam_channel::{Receiver, Sender},
solana_gossip::cluster_info::{ClusterInfo, MAX_SNAPSHOT_HASHES}, solana_gossip::cluster_info::{ClusterInfo, MAX_SNAPSHOT_HASHES},
solana_measure::{measure, measure::Measure}, solana_measure::{measure::Measure, measure_us},
solana_runtime::{ solana_runtime::{
accounts_hash::{AccountsHashEnum, CalcAccountsHashConfig, HashStats}, accounts_hash::{AccountsHashEnum, CalcAccountsHashConfig, HashStats},
snapshot_config::SnapshotConfig, snapshot_config::SnapshotConfig,
@ -72,7 +72,7 @@ impl AccountsHashVerifier {
info!("handling accounts package: {accounts_package:?}"); info!("handling accounts package: {accounts_package:?}");
let enqueued_time = accounts_package.enqueued.elapsed(); let enqueued_time = accounts_package.enqueued.elapsed();
let (_, measure) = measure!(Self::process_accounts_package( let (_, handling_time_us) = measure_us!(Self::process_accounts_package(
accounts_package, accounts_package,
&cluster_info, &cluster_info,
known_validators.as_ref(), known_validators.as_ref(),
@ -88,16 +88,16 @@ impl AccountsHashVerifier {
"accounts_hash_verifier", "accounts_hash_verifier",
( (
"num-outstanding-accounts-packages", "num-outstanding-accounts-packages",
num_outstanding_accounts_packages as i64, num_outstanding_accounts_packages,
i64 i64
), ),
( (
"num-re-enqueued-accounts-packages", "num-re-enqueued-accounts-packages",
num_re_enqueued_accounts_packages as i64, num_re_enqueued_accounts_packages,
i64 i64
), ),
("enqueued-time-us", enqueued_time.as_micros() as i64, i64), ("enqueued-time-us", enqueued_time.as_micros(), i64),
("total-processing-time-us", measure.as_us() as i64, i64), ("handling-time-us", handling_time_us, i64),
); );
} else { } else {
std::thread::sleep(LOOP_LIMITER); std::thread::sleep(LOOP_LIMITER);