document 'accounts' hash (#23907)

This commit is contained in:
Jeff Washington (jwash)
2022-03-24 15:58:52 -05:00
committed by GitHub
parent fedf4e984f
commit 55d61023f7
2 changed files with 12 additions and 12 deletions

View File

@ -109,7 +109,7 @@ impl AccountsHashVerifier {
fn verify_accounts_package_hash(accounts_package: &AccountsPackage) { fn verify_accounts_package_hash(accounts_package: &AccountsPackage) {
let mut measure_hash = Measure::start("hash"); let mut measure_hash = Measure::start("hash");
if let Some(expected_hash) = accounts_package.hash_for_testing { if let Some(expected_hash) = accounts_package.accounts_hash_for_testing {
let sorted_storages = SortedStorages::new(&accounts_package.snapshot_storages); let sorted_storages = SortedStorages::new(&accounts_package.snapshot_storages);
let (hash, lamports) = accounts_package let (hash, lamports) = accounts_package
.accounts .accounts
@ -144,7 +144,7 @@ impl AccountsHashVerifier {
exit: &Arc<AtomicBool>, exit: &Arc<AtomicBool>,
fault_injection_rate_slots: u64, fault_injection_rate_slots: u64,
) { ) {
let hash = accounts_package.hash; let hash = accounts_package.accounts_hash;
if fault_injection_rate_slots != 0 if fault_injection_rate_slots != 0
&& accounts_package.slot % fault_injection_rate_slots == 0 && accounts_package.slot % fault_injection_rate_slots == 0
{ {
@ -345,12 +345,12 @@ mod tests {
slot_deltas: vec![], slot_deltas: vec![],
snapshot_links: TempDir::new().unwrap(), snapshot_links: TempDir::new().unwrap(),
snapshot_storages: vec![], snapshot_storages: vec![],
hash: hash(&[i as u8]), accounts_hash: hash(&[i as u8]),
archive_format: ArchiveFormat::TarBzip2, archive_format: ArchiveFormat::TarBzip2,
snapshot_version: SnapshotVersion::default(), snapshot_version: SnapshotVersion::default(),
snapshot_archives_dir: PathBuf::default(), snapshot_archives_dir: PathBuf::default(),
expected_capitalization: 0, expected_capitalization: 0,
hash_for_testing: None, accounts_hash_for_testing: None,
cluster_type: ClusterType::MainnetBeta, cluster_type: ClusterType::MainnetBeta,
snapshot_type: None, snapshot_type: None,
accounts: Arc::clone(&accounts), accounts: Arc::clone(&accounts),

View File

@ -40,12 +40,12 @@ pub struct AccountsPackage {
pub slot_deltas: Vec<BankSlotDelta>, pub slot_deltas: Vec<BankSlotDelta>,
pub snapshot_links: TempDir, pub snapshot_links: TempDir,
pub snapshot_storages: SnapshotStorages, pub snapshot_storages: SnapshotStorages,
pub hash: Hash, // temporarily here while we still have to calculate hash before serializing bank pub accounts_hash: Hash, // temporarily here while we still have to calculate hash before serializing bank
pub archive_format: ArchiveFormat, pub archive_format: ArchiveFormat,
pub snapshot_version: SnapshotVersion, pub snapshot_version: SnapshotVersion,
pub snapshot_archives_dir: PathBuf, pub snapshot_archives_dir: PathBuf,
pub expected_capitalization: u64, pub expected_capitalization: u64,
pub hash_for_testing: Option<Hash>, pub accounts_hash_for_testing: Option<Hash>,
pub cluster_type: ClusterType, pub cluster_type: ClusterType,
pub snapshot_type: Option<SnapshotType>, pub snapshot_type: Option<SnapshotType>,
pub accounts: Arc<Accounts>, pub accounts: Arc<Accounts>,
@ -63,7 +63,7 @@ impl AccountsPackage {
snapshot_storages: SnapshotStorages, snapshot_storages: SnapshotStorages,
archive_format: ArchiveFormat, archive_format: ArchiveFormat,
snapshot_version: SnapshotVersion, snapshot_version: SnapshotVersion,
hash_for_testing: Option<Hash>, accounts_hash_for_testing: Option<Hash>,
snapshot_type: Option<SnapshotType>, snapshot_type: Option<SnapshotType>,
) -> Result<Self> { ) -> Result<Self> {
info!( info!(
@ -103,12 +103,12 @@ impl AccountsPackage {
slot_deltas, slot_deltas,
snapshot_links, snapshot_links,
snapshot_storages, snapshot_storages,
hash: bank.get_accounts_hash(), accounts_hash: bank.get_accounts_hash(),
archive_format, archive_format,
snapshot_version, snapshot_version,
snapshot_archives_dir: snapshot_archives_dir.as_ref().to_path_buf(), snapshot_archives_dir: snapshot_archives_dir.as_ref().to_path_buf(),
expected_capitalization: bank.capitalization(), expected_capitalization: bank.capitalization(),
hash_for_testing, accounts_hash_for_testing,
cluster_type: bank.cluster_type(), cluster_type: bank.cluster_type(),
snapshot_type, snapshot_type,
accounts: bank.accounts(), accounts: bank.accounts(),
@ -138,7 +138,7 @@ impl From<AccountsPackage> for SnapshotPackage {
SnapshotType::FullSnapshot => snapshot_utils::build_full_snapshot_archive_path( SnapshotType::FullSnapshot => snapshot_utils::build_full_snapshot_archive_path(
accounts_package.snapshot_archives_dir, accounts_package.snapshot_archives_dir,
accounts_package.slot, accounts_package.slot,
&accounts_package.hash, &accounts_package.accounts_hash,
accounts_package.archive_format, accounts_package.archive_format,
), ),
SnapshotType::IncrementalSnapshot(incremental_snapshot_base_slot) => { SnapshotType::IncrementalSnapshot(incremental_snapshot_base_slot) => {
@ -158,7 +158,7 @@ impl From<AccountsPackage> for SnapshotPackage {
accounts_package.snapshot_archives_dir, accounts_package.snapshot_archives_dir,
incremental_snapshot_base_slot, incremental_snapshot_base_slot,
accounts_package.slot, accounts_package.slot,
&accounts_package.hash, &accounts_package.accounts_hash,
accounts_package.archive_format, accounts_package.archive_format,
) )
} }
@ -168,7 +168,7 @@ impl From<AccountsPackage> for SnapshotPackage {
snapshot_archive_info: SnapshotArchiveInfo { snapshot_archive_info: SnapshotArchiveInfo {
path: snapshot_archive_path, path: snapshot_archive_path,
slot: accounts_package.slot, slot: accounts_package.slot,
hash: accounts_package.hash, hash: accounts_package.accounts_hash,
archive_format: accounts_package.archive_format, archive_format: accounts_package.archive_format,
}, },
block_height: accounts_package.block_height, block_height: accounts_package.block_height,