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

AHV loop uses let-else (#30583)

This commit is contained in:
Brooks 2023-03-03 18:59:29 -07:00 committed by GitHub
parent 7a8563f2c8
commit 6972f92c29
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 34 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
core/src/accounts_hash_verifier.rs
View File

@ -61,47 +61,47 @@ impl AccountsHashVerifier {
break;
}
if let Some((
let Some((
accounts_package,
num_outstanding_accounts_packages,
num_re_enqueued_accounts_packages,
)) = Self::get_next_accounts_package(
&accounts_package_sender,
&accounts_package_receiver,
) {
info!("handling accounts package: {accounts_package:?}");
let enqueued_time = accounts_package.enqueued.elapsed();
let (_, handling_time_us) = measure_us!(Self::process_accounts_package(
accounts_package,
&cluster_info,
known_validators.as_ref(),
halt_on_known_validators_accounts_hash_mismatch,
snapshot_package_sender.as_ref(),
&mut hashes,
&exit,
fault_injection_rate_slots,
&snapshot_config,
));
datapoint_info!(
"accounts_hash_verifier",
(
"num-outstanding-accounts-packages",
num_outstanding_accounts_packages,
i64
),
(
"num-re-enqueued-accounts-packages",
num_re_enqueued_accounts_packages,
i64
),
("enqueued-time-us", enqueued_time.as_micros(), i64),
("handling-time-us", handling_time_us, i64),
);
} else {
) else {
std::thread::sleep(LOOP_LIMITER);
}
continue;
};
info!("handling accounts package: {accounts_package:?}");
let enqueued_time = accounts_package.enqueued.elapsed();
let (_, handling_time_us) = measure_us!(Self::process_accounts_package(
accounts_package,
&cluster_info,
known_validators.as_ref(),
halt_on_known_validators_accounts_hash_mismatch,
snapshot_package_sender.as_ref(),
&mut hashes,
&exit,
fault_injection_rate_slots,
&snapshot_config,
));
datapoint_info!(
"accounts_hash_verifier",
(
"num-outstanding-accounts-packages",
num_outstanding_accounts_packages,
i64
),
(
"num-re-enqueued-accounts-packages",
num_re_enqueued_accounts_packages,
i64
),
("enqueued-time-us", enqueued_time.as_micros(), i64),
("handling-time-us", handling_time_us, i64),
);
}
info!("Accounts Hash Verifier has stopped");
})