Type grooming

This commit is contained in:
Michael Vines
2020-01-23 10:20:34 -07:00
parent 1269a79a4d
commit 6f5e0cd161
4 changed files with 26 additions and 22 deletions

View File

@ -1,16 +1,23 @@
use solana_ledger::snapshot_package::{SnapshotPackage, SnapshotPackageReceiver}; use solana_ledger::{
use solana_ledger::snapshot_utils::{ snapshot_package::{SnapshotPackage, SnapshotPackageReceiver},
serialize_status_cache, SnapshotError, TAR_ACCOUNTS_DIR, TAR_SNAPSHOTS_DIR, TAR_VERSION_FILE, snapshot_utils::{
serialize_status_cache, SnapshotError, TAR_ACCOUNTS_DIR, TAR_SNAPSHOTS_DIR,
TAR_VERSION_FILE,
},
}; };
use solana_measure::measure::Measure; use solana_measure::measure::Measure;
use solana_metrics::datapoint_info; use solana_metrics::datapoint_info;
use std::fs; use std::{
use std::process::ExitStatus; fs,
use std::sync::atomic::{AtomicBool, Ordering}; process::ExitStatus,
use std::sync::mpsc::RecvTimeoutError; sync::{
use std::sync::Arc; atomic::{AtomicBool, Ordering},
use std::thread::{self, Builder, JoinHandle}; mpsc::RecvTimeoutError,
use std::time::Duration; Arc,
},
thread::{self, Builder, JoinHandle},
time::Duration,
};
use symlink; use symlink;
use tempfile::TempDir; use tempfile::TempDir;
use thiserror::Error; use thiserror::Error;
@ -284,7 +291,7 @@ mod tests {
// before we compare, stick an empty status_cache in this dir so that the package comparision works // before we compare, stick an empty status_cache in this dir so that the package comparision works
// This is needed since the status_cache is added by the packager and is not collected from // This is needed since the status_cache is added by the packager and is not collected from
// the source dir for snapshots // the source dir for snapshots
let dummy_slot_deltas: Vec<SlotDelta<TransactionResult<()>>> = vec![]; let dummy_slot_deltas: Vec<SlotDelta<transaction::Result<()>>> = vec![];
snapshot_utils::serialize_snapshot_data_file( snapshot_utils::serialize_snapshot_data_file(
&snapshots_dir.join(SNAPSHOT_STATUS_CACHE_FILE_NAME), &snapshots_dir.join(SNAPSHOT_STATUS_CACHE_FILE_NAME),
MAX_SNAPSHOT_DATA_FILE_SIZE, MAX_SNAPSHOT_DATA_FILE_SIZE,

View File

@ -22,8 +22,7 @@ mod tests {
hash::hashv, hash::hashv,
pubkey::Pubkey, pubkey::Pubkey,
signature::{Keypair, KeypairUtil}, signature::{Keypair, KeypairUtil},
system_transaction, system_transaction, transaction,
transaction::Result as TransactionResult,
}; };
use std::{fs, path::PathBuf, sync::atomic::AtomicBool, sync::mpsc::channel, sync::Arc}; use std::{fs, path::PathBuf, sync::atomic::AtomicBool, sync::mpsc::channel, sync::Arc};
use tempfile::TempDir; use tempfile::TempDir;
@ -310,7 +309,7 @@ mod tests {
// before we compare, stick an empty status_cache in this dir so that the package comparision works // before we compare, stick an empty status_cache in this dir so that the package comparision works
// This is needed since the status_cache is added by the packager and is not collected from // This is needed since the status_cache is added by the packager and is not collected from
// the source dir for snapshots // the source dir for snapshots
let dummy_slot_deltas: Vec<SlotDelta<TransactionResult<()>>> = vec![]; let dummy_slot_deltas: Vec<SlotDelta<transaction::Result<()>>> = vec![];
snapshot_utils::serialize_snapshot_data_file( snapshot_utils::serialize_snapshot_data_file(
&saved_snapshots_dir &saved_snapshots_dir
.path() .path()

View File

@ -3,13 +3,11 @@ use clap::{
}; };
use histogram; use histogram;
use serde_json::json; use serde_json::json;
use solana_ledger::blockstore_db::Database;
use solana_ledger::{ use solana_ledger::{
bank_forks::{BankForks, SnapshotConfig}, bank_forks::{BankForks, SnapshotConfig},
bank_forks_utils, bank_forks_utils,
blockstore::Blockstore, blockstore::Blockstore,
blockstore_db, blockstore_db::{self, Column, Database},
blockstore_db::Column,
blockstore_processor, blockstore_processor,
rooted_slot_iterator::RootedSlotIterator, rooted_slot_iterator::RootedSlotIterator,
}; };

View File

@ -1,6 +1,6 @@
use solana_runtime::accounts_db::AccountStorageEntry; use solana_runtime::accounts_db::AccountStorageEntry;
use solana_runtime::status_cache::SlotDelta; use solana_runtime::status_cache::SlotDelta;
use solana_sdk::transaction::Result as TransactionResult; use solana_sdk::{clock::Slot, transaction};
use std::path::PathBuf; use std::path::PathBuf;
use std::sync::mpsc::{Receiver, SendError, Sender}; use std::sync::mpsc::{Receiver, SendError, Sender};
use std::sync::Arc; use std::sync::Arc;
@ -12,8 +12,8 @@ pub type SnapshotPackageSendError = SendError<SnapshotPackage>;
#[derive(Debug)] #[derive(Debug)]
pub struct SnapshotPackage { pub struct SnapshotPackage {
pub root: u64, pub root: Slot,
pub slot_deltas: Vec<SlotDelta<TransactionResult<()>>>, pub slot_deltas: Vec<SlotDelta<transaction::Result<()>>>,
pub snapshot_links: TempDir, pub snapshot_links: TempDir,
pub storage_entries: Vec<Arc<AccountStorageEntry>>, pub storage_entries: Vec<Arc<AccountStorageEntry>>,
pub tar_output_file: PathBuf, pub tar_output_file: PathBuf,
@ -21,8 +21,8 @@ pub struct SnapshotPackage {
impl SnapshotPackage { impl SnapshotPackage {
pub fn new( pub fn new(
root: u64, root: Slot,
slot_deltas: Vec<SlotDelta<TransactionResult<()>>>, slot_deltas: Vec<SlotDelta<transaction::Result<()>>>,
snapshot_links: TempDir, snapshot_links: TempDir,
storage_entries: Vec<Arc<AccountStorageEntry>>, storage_entries: Vec<Arc<AccountStorageEntry>>,
tar_output_file: PathBuf, tar_output_file: PathBuf,