diff --git a/core/src/sigverify_stage.rs b/core/src/sigverify_stage.rs index 9438327d8..8edadebe2 100644 --- a/core/src/sigverify_stage.rs +++ b/core/src/sigverify_stage.rs @@ -6,7 +6,7 @@ //! if perf-libs are available use { - crate::{find_packet_sender_stake_stage, sigverify}, + crate::{find_packet_sender_stake_stage::FindPacketSenderStakeReceiver, sigverify}, core::time::Duration, crossbeam_channel::{RecvTimeoutError, SendError}, itertools::Itertools, @@ -235,7 +235,7 @@ impl SigVerifier for DisabledSigVerifier { impl SigVerifyStage { #[allow(clippy::new_ret_no_self)] pub fn new( - packet_receiver: find_packet_sender_stake_stage::FindPacketSenderStakeReceiver, + packet_receiver: FindPacketSenderStakeReceiver, verifier: T, name: &'static str, ) -> Self { @@ -291,7 +291,7 @@ impl SigVerifyStage { fn verifier( deduper: &Deduper, - recvr: &find_packet_sender_stake_stage::FindPacketSenderStakeReceiver, + recvr: &FindPacketSenderStakeReceiver, verifier: &mut T, stats: &mut SigVerifierStats, ) -> Result<(), T::SendType> { @@ -403,7 +403,7 @@ impl SigVerifyStage { } fn verifier_service( - packet_receiver: find_packet_sender_stake_stage::FindPacketSenderStakeReceiver, + packet_receiver: FindPacketSenderStakeReceiver, mut verifier: T, name: &'static str, ) -> JoinHandle<()> { @@ -444,7 +444,7 @@ impl SigVerifyStage { } fn verifier_services( - packet_receiver: find_packet_sender_stake_stage::FindPacketSenderStakeReceiver, + packet_receiver: FindPacketSenderStakeReceiver, verifier: T, name: &'static str, ) -> JoinHandle<()> {