From da5b777ee7854e5138d2589e2e96256036995e33 Mon Sep 17 00:00:00 2001 From: Michael Vines Date: Sat, 9 Feb 2019 09:20:43 -0800 Subject: [PATCH] Purge Default::default() --- bench-tps/src/bench.rs | 2 +- benches/banking_stage.rs | 5 +++-- benches/bloom.rs | 4 ++-- programs/native/storage/src/lib.rs | 6 +++--- sdk/src/budget_transaction.rs | 4 ++-- sdk/src/system_transaction.rs | 2 +- sdk/src/transaction.rs | 10 +++++----- src/banking_stage.rs | 10 +++++----- src/bloom.rs | 2 +- src/fullnode.rs | 9 +++++---- src/leader_scheduler.rs | 2 +- src/packet.rs | 2 +- src/rpc_pubsub.rs | 16 +++++++++------- src/sigverify.rs | 2 +- src/status_cache.rs | 14 +++++++------- src/window_service.rs | 9 ++------- 16 files changed, 49 insertions(+), 50 deletions(-) diff --git a/bench-tps/src/bench.rs b/bench-tps/src/bench.rs index 143367e0e..3aa402b76 100644 --- a/bench-tps/src/bench.rs +++ b/bench-tps/src/bench.rs @@ -342,7 +342,7 @@ pub fn fund_keys(client: &mut ThinClient, source: &Keypair, dests: &[Keypair], t .map(|(k, m)| { ( k.clone(), - SystemTransaction::new_move_many(k, &m, Default::default(), 0), + SystemTransaction::new_move_many(k, &m, Hash::default(), 0), ) }) .collect(); diff --git a/benches/banking_stage.rs b/benches/banking_stage.rs index 75e6d0623..9d39cb8a4 100644 --- a/benches/banking_stage.rs +++ b/benches/banking_stage.rs @@ -10,6 +10,7 @@ use solana::entry::Entry; use solana::genesis_block::GenesisBlock; use solana::last_id_queue::MAX_ENTRY_IDS; use solana::packet::to_packets_chunked; +use solana::poh_service::PohServiceConfig; use solana_sdk::hash::hash; use solana_sdk::pubkey::Pubkey; use solana_sdk::signature::{KeypairUtil, Signature}; @@ -103,7 +104,7 @@ fn bench_banking_stage_multi_accounts(bencher: &mut Bencher) { let (_stage, signal_receiver) = BankingStage::new( &bank, verified_receiver, - Default::default(), + PohServiceConfig::default(), &genesis_block.last_id(), std::u64::MAX, genesis_block.bootstrap_leader_id, @@ -212,7 +213,7 @@ fn bench_banking_stage_multi_programs(bencher: &mut Bencher) { let (_stage, signal_receiver) = BankingStage::new( &bank, verified_receiver, - Default::default(), + PohServiceConfig::default(), &genesis_block.last_id(), std::u64::MAX, genesis_block.bootstrap_leader_id, diff --git a/benches/bloom.rs b/benches/bloom.rs index ab52b1334..851b9064d 100644 --- a/benches/bloom.rs +++ b/benches/bloom.rs @@ -15,7 +15,7 @@ use test::Bencher; #[ignore] fn bench_bits_set(bencher: &mut Bencher) { let mut bits: BitVec = BitVec::new_fill(false, 38_340_234 as u64); - let mut hasher: FnvHasher = Default::default(); + let mut hasher = FnvHasher::default(); bencher.iter(|| { let idx = hasher.finish() % bits.len(); @@ -30,7 +30,7 @@ fn bench_bits_set(bencher: &mut Bencher) { #[ignore] fn bench_bits_set_hasher(bencher: &mut Bencher) { let bits: BitVec = BitVec::new_fill(false, 38_340_234 as u64); - let mut hasher: FnvHasher = Default::default(); + let mut hasher = FnvHasher::default(); bencher.iter(|| { let idx = hasher.finish() % bits.len(); diff --git a/programs/native/storage/src/lib.rs b/programs/native/storage/src/lib.rs index e436b35ea..397956830 100644 --- a/programs/native/storage/src/lib.rs +++ b/programs/native/storage/src/lib.rs @@ -226,7 +226,7 @@ mod test { #[test] fn test_storage_tx() { let keypair = Keypair::new(); - let mut accounts = [(keypair.pubkey(), Default::default())]; + let mut accounts = [(keypair.pubkey(), Account::default())]; let mut keyed_accounts = create_keyed_accounts(&mut accounts); assert!(entrypoint(&id(), &mut keyed_accounts, &[], 42).is_err()); } @@ -258,7 +258,7 @@ mod test { #[test] fn test_invalid_accounts_len() { let keypair = Keypair::new(); - let mut accounts = [Default::default()]; + let mut accounts = [Account::default()]; let tx = StorageTransaction::new_mining_proof( &keypair, @@ -269,7 +269,7 @@ mod test { ); assert!(test_transaction(&tx, &mut accounts).is_err()); - let mut accounts = [Default::default(), Default::default(), Default::default()]; + let mut accounts = [Account::default(), Account::default(), Account::default()]; assert!(test_transaction(&tx, &mut accounts).is_err()); } diff --git a/sdk/src/budget_transaction.rs b/sdk/src/budget_transaction.rs index 7b5c9da04..3524c0165 100644 --- a/sdk/src/budget_transaction.rs +++ b/sdk/src/budget_transaction.rs @@ -232,13 +232,13 @@ mod tests { fn test_serialize_claim() { let expr = BudgetExpr::Pay(Payment { tokens: 0, - to: Default::default(), + to: Pubkey::default(), }); let instruction = Instruction::NewBudget(expr); let instructions = vec![transaction::Instruction::new(0, &instruction, vec![])]; let claim0 = Transaction { account_keys: vec![], - last_id: Default::default(), + last_id: Hash::default(), signatures: vec![], program_ids: vec![], instructions, diff --git a/sdk/src/system_transaction.rs b/sdk/src/system_transaction.rs index 1827f31ab..4ee52a4c8 100644 --- a/sdk/src/system_transaction.rs +++ b/sdk/src/system_transaction.rs @@ -133,7 +133,7 @@ mod tests { let t2 = Keypair::new(); let moves = vec![(t1.pubkey(), 1), (t2.pubkey(), 2)]; - let tx = SystemTransaction::new_move_many(&from, &moves, Default::default(), 0); + let tx = SystemTransaction::new_move_many(&from, &moves, Hash::default(), 0); assert_eq!(tx.account_keys[0], from.pubkey()); assert_eq!(tx.account_keys[1], t1.pubkey()); assert_eq!(tx.account_keys[2], t2.pubkey()); diff --git a/sdk/src/transaction.rs b/sdk/src/transaction.rs index dd33cb494..07bf0edcc 100644 --- a/sdk/src/transaction.rs +++ b/sdk/src/transaction.rs @@ -412,7 +412,7 @@ mod tests { let tx = Transaction::new_with_instructions( &[&key], &[key1, key2], - Default::default(), + Hash::default(), 0, vec![prog1, prog2], instructions, @@ -447,7 +447,7 @@ mod tests { let tx = Transaction::new_with_instructions( &[&key], &[], - Default::default(), + Hash::default(), 0, vec![], instructions, @@ -461,12 +461,12 @@ mod tests { let tx = Transaction::new_with_instructions( &[&key], &[], - Default::default(), + Hash::default(), 0, - vec![Default::default()], + vec![Pubkey::default()], instructions, ); - assert_eq!(*tx.program_id(0), Default::default()); + assert_eq!(*tx.program_id(0), Pubkey::default()); assert!(!tx.verify_refs()); } diff --git a/src/banking_stage.rs b/src/banking_stage.rs index bd0f1ff72..86cda6b51 100644 --- a/src/banking_stage.rs +++ b/src/banking_stage.rs @@ -293,7 +293,7 @@ mod tests { let (banking_stage, _entry_receiver) = BankingStage::new( &bank, verified_receiver, - Default::default(), + PohServiceConfig::default(), &bank.last_id(), std::u64::MAX, genesis_block.bootstrap_leader_id, @@ -315,7 +315,7 @@ mod tests { let (banking_stage, entry_receiver) = BankingStage::new( &bank, verified_receiver, - Default::default(), + PohServiceConfig::default(), &bank.last_id(), std::u64::MAX, genesis_block.bootstrap_leader_id, @@ -367,7 +367,7 @@ mod tests { let (banking_stage, entry_receiver) = BankingStage::new( &bank, verified_receiver, - Default::default(), + PohServiceConfig::default(), &bank.last_id(), std::u64::MAX, genesis_block.bootstrap_leader_id, @@ -425,7 +425,7 @@ mod tests { let (banking_stage, entry_receiver) = BankingStage::new( &bank, verified_receiver, - Default::default(), + PohServiceConfig::default(), &bank.last_id(), std::u64::MAX, genesis_block.bootstrap_leader_id, @@ -494,7 +494,7 @@ mod tests { let (banking_stage, _entry_receiver) = BankingStage::new( &bank, verified_receiver, - Default::default(), + PohServiceConfig::default(), &bank.last_id(), max_tick_height, genesis_block.bootstrap_leader_id, diff --git a/src/bloom.rs b/src/bloom.rs index c6b943b6b..b81c395f8 100644 --- a/src/bloom.rs +++ b/src/bloom.rs @@ -25,7 +25,7 @@ impl Bloom { Bloom { keys, bits, - _phantom: Default::default(), + _phantom: PhantomData::default(), } } /// create filter optimal for num size given the `false_rate` diff --git a/src/fullnode.rs b/src/fullnode.rs index 535b25148..b09ad1f4e 100644 --- a/src/fullnode.rs +++ b/src/fullnode.rs @@ -7,6 +7,7 @@ use crate::counter::Counter; use crate::genesis_block::GenesisBlock; use crate::gossip_service::GossipService; use crate::leader_scheduler::LeaderSchedulerConfig; +use crate::poh_service::PohServiceConfig; use crate::rpc::JsonRpcService; use crate::rpc_pubsub::PubSubService; use crate::service::Service; @@ -77,8 +78,8 @@ impl Default for FullnodeConfig { voting_disabled: false, entry_stream: None, storage_rotate_count: NUM_HASHES_FOR_STORAGE_ROTATE, - leader_scheduler_config: Default::default(), - ledger_config: Default::default(), + leader_scheduler_config: LeaderSchedulerConfig::default(), + ledger_config: BlocktreeConfig::default(), } } } @@ -271,7 +272,7 @@ impl Fullnode { ); let tpu = Tpu::new( &Arc::new(bank.copy_for_tpu()), - Default::default(), + PohServiceConfig::default(), node.sockets .tpu .iter() @@ -389,7 +390,7 @@ impl Fullnode { self.to_validator_receiver = to_validator_receiver; self.node_services.tpu.switch_to_leader( &Arc::new(self.bank.copy_for_tpu()), - Default::default(), + PohServiceConfig::default(), self.tpu_sockets .iter() .map(|s| s.try_clone().expect("Failed to clone TPU sockets")) diff --git a/src/leader_scheduler.rs b/src/leader_scheduler.rs index 2351c85d5..46b4a929a 100644 --- a/src/leader_scheduler.rs +++ b/src/leader_scheduler.rs @@ -399,7 +399,7 @@ impl LeaderScheduler { impl Default for LeaderScheduler { fn default() -> Self { - let config = Default::default(); + let config = LeaderSchedulerConfig::default(); Self::new(&config) } } diff --git a/src/packet.rs b/src/packet.rs index e502b09ea..682d98d87 100644 --- a/src/packet.rs +++ b/src/packet.rs @@ -224,7 +224,7 @@ pub fn to_packets_chunked(xs: &[T], chunks: usize) -> Vec>>>; +type RpcSignatureSubscriptions = + RwLock>>>; pub struct RpcSubscriptions { - account_subscriptions: RwLock>>>, - signature_subscriptions: - RwLock>>>, + account_subscriptions: RpcAccountSubscriptions, + signature_subscriptions: RpcSignatureSubscriptions, } impl Default for RpcSubscriptions { fn default() -> Self { RpcSubscriptions { - account_subscriptions: Default::default(), - signature_subscriptions: Default::default(), + account_subscriptions: RpcAccountSubscriptions::default(), + signature_subscriptions: RpcSignatureSubscriptions::default(), } } } @@ -260,9 +262,9 @@ struct RpcSolPubSubImpl { impl RpcSolPubSubImpl { fn new(bank: Arc>) -> Self { RpcSolPubSubImpl { - uid: Default::default(), + uid: Arc::new(atomic::AtomicUsize::default()), bank, - subscription: Arc::new(Default::default()), + subscription: Arc::new(RpcSubscriptions::default()), } } diff --git a/src/sigverify.rs b/src/sigverify.rs index 2dc0f277a..bad2e8300 100644 --- a/src/sigverify.rs +++ b/src/sigverify.rs @@ -442,7 +442,7 @@ mod tests { .write() .unwrap() .packets - .resize(0, Default::default()); + .resize(0, Packet::default()); for _ in 0..num_packets_per_batch { packets.write().unwrap().packets.push(packet.clone()); } diff --git a/src/status_cache.rs b/src/status_cache.rs index d182a6ffd..e1fa0e9a1 100644 --- a/src/status_cache.rs +++ b/src/status_cache.rs @@ -135,7 +135,7 @@ mod tests { #[test] fn test_has_signature() { - let sig = Default::default(); + let sig = Signature::default(); let last_id = hash(Hash::default().as_ref()); let mut status_cache = BankStatusCache::new(&last_id); assert_eq!(status_cache.has_signature(&sig), false); @@ -147,7 +147,7 @@ mod tests { #[test] fn test_has_signature_checkpoint() { - let sig = Default::default(); + let sig = Signature::default(); let last_id = hash(Hash::default().as_ref()); let mut first = BankStatusCache::new(&last_id); first.add(&sig); @@ -164,7 +164,7 @@ mod tests { #[test] fn test_has_signature_merged1() { - let sig = Default::default(); + let sig = Signature::default(); let last_id = hash(Hash::default().as_ref()); let mut first = BankStatusCache::new(&last_id); first.add(&sig); @@ -178,7 +178,7 @@ mod tests { #[test] fn test_has_signature_merged2() { - let sig = Default::default(); + let sig = Signature::default(); let last_id = hash(Hash::default().as_ref()); let mut first = BankStatusCache::new(&last_id); first.add(&sig); @@ -192,7 +192,7 @@ mod tests { #[test] fn test_failure_status() { - let sig = Default::default(); + let sig = Signature::default(); let last_id = hash(Hash::default().as_ref()); let mut first = StatusCache::new(&last_id); first.add(&sig); @@ -206,7 +206,7 @@ mod tests { #[test] fn test_clear_signatures() { - let sig = Default::default(); + let sig = Signature::default(); let last_id = hash(Hash::default().as_ref()); let mut first = StatusCache::new(&last_id); first.add(&sig); @@ -222,7 +222,7 @@ mod tests { } #[test] fn test_clear_signatures_all() { - let sig = Default::default(); + let sig = Signature::default(); let last_id = hash(Hash::default().as_ref()); let mut first = StatusCache::new(&last_id); first.add(&sig); diff --git a/src/window_service.rs b/src/window_service.rs index e77f719c9..b301192b9 100644 --- a/src/window_service.rs +++ b/src/window_service.rs @@ -290,13 +290,8 @@ mod test { leader_node.sockets.tvu.into_iter().map(Arc::new).collect(); let t_responder = responder("window_send_test", blob_sockets[0].clone(), r_responder); let mut msgs = Vec::new(); - let blobs = make_consecutive_blobs( - &me_id, - 14u64, - 0, - Default::default(), - &leader_node.info.gossip, - ); + let blobs = + make_consecutive_blobs(&me_id, 14u64, 0, Hash::default(), &leader_node.info.gossip); for v in 0..10 { let i = 9 - v;