diff --git a/turbine/src/retransmit_stage.rs b/turbine/src/retransmit_stage.rs index e1feb5c47166c4..88cd3730e9b74f 100644 --- a/turbine/src/retransmit_stage.rs +++ b/turbine/src/retransmit_stage.rs @@ -133,7 +133,7 @@ impl RetransmitStats { } } -struct ShredDeduper { +struct ShredDeduper { deduper: Deduper, shred_id_filter: Deduper, } @@ -189,7 +189,7 @@ fn retransmit( quic_endpoint_sender: &AsyncSender<(SocketAddr, Bytes)>, stats: &mut RetransmitStats, cluster_nodes_cache: &ClusterNodesCache, - shred_deduper: &mut ShredDeduper<2>, + shred_deduper: &mut ShredDeduper, max_slots: &MaxSlots, rpc_subscriptions: Option<&RpcSubscriptions>, slot_status_notifier: Option<&SlotStatusNotifier>, @@ -302,7 +302,7 @@ fn retransmit( fn retransmit_shred( shred: Vec, root_bank: &Bank, - shred_deduper: &ShredDeduper<2>, + shred_deduper: &ShredDeduper, cache: &HashMap>)>, socket_addr_space: &SocketAddrSpace, socket: &UdpSocket, @@ -391,7 +391,7 @@ pub fn retransmitter( CLUSTER_NODES_CACHE_TTL, ); let mut rng = rand::thread_rng(); - let mut shred_deduper = ShredDeduper::<2>::new(&mut rng, DEDUPER_NUM_BITS); + let mut shred_deduper = ShredDeduper::new(&mut rng, DEDUPER_NUM_BITS); let mut stats = RetransmitStats::new(Instant::now()); #[allow(clippy::manual_clamp)] let num_threads = get_thread_count().min(8).max(sockets.len());