Skip to content

Commit

Permalink
Update callers to handle the Result
Browse files Browse the repository at this point in the history
  • Loading branch information
Steven Czabaniuk committed Jan 18, 2024
1 parent ffd7853 commit 3982309
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 5 deletions.
8 changes: 5 additions & 3 deletions core/src/validator.rs
Original file line number Diff line number Diff line change
Expand Up @@ -565,9 +565,10 @@ impl Validator {
"ledger directory does not exist or is not accessible: {ledger_path:?}"
));
}

let genesis_config =
open_genesis_config(ledger_path, config.max_genesis_archive_unpacked_size);
open_genesis_config(ledger_path, config.max_genesis_archive_unpacked_size)
.map_err(|err| format!("Failed to open genesis config: {err}"))?;

metrics_config_sanity_check(genesis_config.cluster_type)?;

if let Some(expected_shred_version) = config.expected_shred_version {
Expand Down Expand Up @@ -1760,7 +1761,8 @@ fn load_blockstore(
> {
info!("loading ledger from {:?}...", ledger_path);
*start_progress.write().unwrap() = ValidatorStartProgress::LoadingLedger;
let genesis_config = open_genesis_config(ledger_path, config.max_genesis_archive_unpacked_size);
let genesis_config = open_genesis_config(ledger_path, config.max_genesis_archive_unpacked_size)
.map_err(|err| format!("Failed to open genesis config: {err}"))?;

// This needs to be limited otherwise the state in the VoteAccount data
// grows too large
Expand Down
6 changes: 5 additions & 1 deletion ledger-tool/src/ledger_utils.rs
Original file line number Diff line number Diff line change
Expand Up @@ -553,7 +553,11 @@ fn open_blockstore_with_temporary_primary_access(
pub fn open_genesis_config_by(ledger_path: &Path, matches: &ArgMatches<'_>) -> GenesisConfig {
let max_genesis_archive_unpacked_size =
value_t_or_exit!(matches, "max_genesis_archive_unpacked_size", u64);
open_genesis_config(ledger_path, max_genesis_archive_unpacked_size)

open_genesis_config(ledger_path, max_genesis_archive_unpacked_size).unwrap_or_else(|err| {
eprintln!("Exiting. Failed to open genesis config: {err}");
exit(1);
})
}

pub fn get_program_ids(tx: &VersionedTransaction) -> impl Iterator<Item = &Pubkey> + '_ {
Expand Down
2 changes: 1 addition & 1 deletion local-cluster/tests/local_cluster.rs
Original file line number Diff line number Diff line change
Expand Up @@ -2196,7 +2196,7 @@ fn create_snapshot_to_hard_fork(
..ProcessOptions::default()
};
let ledger_path = blockstore.ledger_path();
let genesis_config = open_genesis_config(ledger_path, u64::max_value());
let genesis_config = open_genesis_config(ledger_path, u64::max_value()).unwrap();
let snapshot_config = create_simple_snapshot_config(ledger_path);
let (bank_forks, ..) = bank_forks_utils::load(
&genesis_config,
Expand Down

0 comments on commit 3982309

Please sign in to comment.