diff --git a/src/accounts.rs b/src/accounts.rs index 6d913f0db4..b1f1791c77 100644 --- a/src/accounts.rs +++ b/src/accounts.rs @@ -12,7 +12,6 @@ use solana_sdk::pubkey::Pubkey; use solana_sdk::transaction::Transaction; use std::collections::BTreeMap; use std::ops::Deref; -use std::sync::atomic::AtomicUsize; use std::sync::{Mutex, RwLock}; pub type InstructionAccounts = Vec; diff --git a/src/banking_stage.rs b/src/banking_stage.rs index 55519a662d..e9fe93b8cd 100644 --- a/src/banking_stage.rs +++ b/src/banking_stage.rs @@ -19,7 +19,7 @@ use solana_sdk::hash::Hash; use solana_sdk::pubkey::Pubkey; use solana_sdk::timing; use solana_sdk::transaction::Transaction; -use std::sync::atomic::{AtomicUsize, Ordering}; +use std::sync::atomic::Ordering; use std::sync::mpsc::{channel, Receiver, RecvTimeoutError}; use std::sync::{Arc, Mutex}; use std::thread::{self, Builder, JoinHandle}; diff --git a/src/broadcast_service.rs b/src/broadcast_service.rs index d6ddbc74e0..b784cab20b 100644 --- a/src/broadcast_service.rs +++ b/src/broadcast_service.rs @@ -18,7 +18,7 @@ use solana_metrics::{influxdb, submit}; use solana_sdk::pubkey::Pubkey; use solana_sdk::timing::duration_as_ms; use std::net::UdpSocket; -use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering}; +use std::sync::atomic::{AtomicBool, Ordering}; use std::sync::mpsc::{Receiver, RecvTimeoutError}; use std::sync::{Arc, RwLock}; use std::thread::{self, Builder, JoinHandle}; diff --git a/src/cluster_info.rs b/src/cluster_info.rs index 98f23a96e9..edf409404f 100644 --- a/src/cluster_info.rs +++ b/src/cluster_info.rs @@ -41,7 +41,7 @@ use std::cmp::min; use std::fmt; use std::io; use std::net::{IpAddr, Ipv4Addr, SocketAddr, UdpSocket}; -use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering}; +use std::sync::atomic::{AtomicBool, Ordering}; use std::sync::{Arc, RwLock}; use std::thread::{sleep, Builder, JoinHandle}; use std::time::{Duration, Instant}; diff --git a/src/cluster_info_vote_listener.rs b/src/cluster_info_vote_listener.rs index 5f98297100..e083dfcfa2 100644 --- a/src/cluster_info_vote_listener.rs +++ b/src/cluster_info_vote_listener.rs @@ -5,7 +5,7 @@ use crate::result::Result; use crate::service::Service; use crate::streamer::PacketSender; use log::Level; -use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering}; +use std::sync::atomic::{AtomicBool, Ordering}; use std::sync::{Arc, RwLock}; use std::thread::{self, sleep, Builder, JoinHandle}; use std::time::Duration; diff --git a/src/counter.rs b/src/counter.rs index 3bd14e7048..d75e255911 100644 --- a/src/counter.rs +++ b/src/counter.rs @@ -20,10 +20,10 @@ macro_rules! create_counter { ($name:expr, $lograte:expr) => { Counter { name: $name, - counts: AtomicUsize::new(0), - times: AtomicUsize::new(0), - lastlog: AtomicUsize::new(0), - lograte: AtomicUsize::new($lograte), + counts: std::sync::atomic::AtomicUsize::new(0), + times: std::sync::atomic::AtomicUsize::new(0), + lastlog: std::sync::atomic::AtomicUsize::new(0), + lograte: std::sync::atomic::AtomicUsize::new($lograte), point: None, } }; @@ -116,7 +116,7 @@ mod tests { use crate::counter::{Counter, DEFAULT_LOG_RATE}; use log::Level; use std::env; - use std::sync::atomic::{AtomicUsize, Ordering}; + use std::sync::atomic::Ordering; use std::sync::{Once, RwLock, ONCE_INIT}; fn get_env_lock() -> &'static RwLock<()> { diff --git a/src/db_window.rs b/src/db_window.rs index 6a0b351ee6..07415ea02c 100644 --- a/src/db_window.rs +++ b/src/db_window.rs @@ -11,7 +11,6 @@ use log::Level; use solana_metrics::{influxdb, submit}; use solana_sdk::pubkey::Pubkey; use std::borrow::Borrow; -use std::sync::atomic::AtomicUsize; use std::sync::{Arc, RwLock}; pub const MAX_REPAIR_LENGTH: usize = 128; diff --git a/src/fullnode.rs b/src/fullnode.rs index ec3a306095..02cfd8907d 100644 --- a/src/fullnode.rs +++ b/src/fullnode.rs @@ -22,7 +22,7 @@ use solana_sdk::signature::{Keypair, KeypairUtil}; use solana_sdk::timing::{duration_as_ms, timestamp}; use std::net::UdpSocket; use std::net::{IpAddr, Ipv4Addr, SocketAddr}; -use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering}; +use std::sync::atomic::{AtomicBool, Ordering}; use std::sync::mpsc::{channel, Receiver, RecvTimeoutError, Sender, SyncSender}; use std::sync::{Arc, RwLock}; use std::thread::{sleep, spawn, Result}; diff --git a/src/packet.rs b/src/packet.rs index e2693c2aeb..3c57c66823 100644 --- a/src/packet.rs +++ b/src/packet.rs @@ -12,7 +12,6 @@ use std::fmt; use std::io; use std::mem::size_of; use std::net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddr, UdpSocket}; -use std::sync::atomic::AtomicUsize; use std::sync::{Arc, RwLock}; pub type SharedPackets = Arc>; diff --git a/src/replay_stage.rs b/src/replay_stage.rs index a873df3e0c..6303bae138 100644 --- a/src/replay_stage.rs +++ b/src/replay_stage.rs @@ -16,7 +16,7 @@ use solana_sdk::hash::Hash; use solana_sdk::pubkey::Pubkey; use solana_sdk::timing::duration_as_ms; use solana_sdk::vote_transaction::VoteTransaction; -use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering}; +use std::sync::atomic::{AtomicBool, Ordering}; use std::sync::mpsc::{channel, Receiver, SyncSender}; use std::sync::{Arc, RwLock}; #[cfg(test)] diff --git a/src/retransmit_stage.rs b/src/retransmit_stage.rs index ceaae0662d..dea926d90c 100644 --- a/src/retransmit_stage.rs +++ b/src/retransmit_stage.rs @@ -16,7 +16,7 @@ use core::cmp; use log::Level; use solana_metrics::{influxdb, submit}; use std::net::UdpSocket; -use std::sync::atomic::{AtomicBool, AtomicUsize}; +use std::sync::atomic::AtomicBool; use std::sync::mpsc::channel; use std::sync::mpsc::RecvTimeoutError; use std::sync::{Arc, RwLock}; diff --git a/src/sigverify.rs b/src/sigverify.rs index bad2e83008..b262358def 100644 --- a/src/sigverify.rs +++ b/src/sigverify.rs @@ -15,7 +15,6 @@ use solana_sdk::signature::Signature; use solana_sdk::transaction::Transaction; use std::io::Cursor; use std::mem::size_of; -use std::sync::atomic::AtomicUsize; pub const TX_OFFSET: usize = 0; diff --git a/src/sigverify_stage.rs b/src/sigverify_stage.rs index 23c1641eab..b435e2438f 100644 --- a/src/sigverify_stage.rs +++ b/src/sigverify_stage.rs @@ -16,7 +16,6 @@ use log::Level; use rand::{thread_rng, Rng}; use solana_metrics::{influxdb, submit}; use solana_sdk::timing; -use std::sync::atomic::AtomicUsize; use std::sync::mpsc::{channel, Receiver, RecvTimeoutError, Sender}; use std::sync::{Arc, Mutex}; use std::thread::{self, spawn, JoinHandle}; diff --git a/src/tpu_forwarder.rs b/src/tpu_forwarder.rs index 203e233679..4ec286ef94 100644 --- a/src/tpu_forwarder.rs +++ b/src/tpu_forwarder.rs @@ -11,7 +11,7 @@ use crate::streamer::{self, PacketReceiver}; use log::Level; use solana_sdk::pubkey::Pubkey; use std::net::{SocketAddr, UdpSocket}; -use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering}; +use std::sync::atomic::{AtomicBool, Ordering}; use std::sync::mpsc::channel; use std::sync::{Arc, RwLock}; use std::thread::{self, Builder, JoinHandle}; diff --git a/src/window_service.rs b/src/window_service.rs index c3dc69d465..1f8426242d 100644 --- a/src/window_service.rs +++ b/src/window_service.rs @@ -14,7 +14,7 @@ use solana_metrics::{influxdb, submit}; use solana_sdk::pubkey::Pubkey; use solana_sdk::timing::duration_as_ms; use std::net::UdpSocket; -use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering}; +use std::sync::atomic::{AtomicBool, Ordering}; use std::sync::mpsc::RecvTimeoutError; use std::sync::{Arc, RwLock}; use std::thread::{self, Builder, JoinHandle};