Pacify clippy
This commit is contained in:
parent
b801ca477d
commit
5216a723b1
|
@ -126,12 +126,12 @@ pub struct BroadcastStage {
|
||||||
|
|
||||||
impl BroadcastStage {
|
impl BroadcastStage {
|
||||||
fn run(
|
fn run(
|
||||||
sock: UdpSocket,
|
sock: &UdpSocket,
|
||||||
crdt: Arc<RwLock<Crdt>>,
|
crdt: &Arc<RwLock<Crdt>>,
|
||||||
window: SharedWindow,
|
window: &SharedWindow,
|
||||||
entry_height: u64,
|
entry_height: u64,
|
||||||
recycler: BlobRecycler,
|
recycler: &BlobRecycler,
|
||||||
receiver: BlobReceiver,
|
receiver: &BlobReceiver,
|
||||||
) {
|
) {
|
||||||
let mut transmit_index = WindowIndex {
|
let mut transmit_index = WindowIndex {
|
||||||
data: entry_height,
|
data: entry_height,
|
||||||
|
@ -184,7 +184,7 @@ impl BroadcastStage {
|
||||||
let thread_hdl = Builder::new()
|
let thread_hdl = Builder::new()
|
||||||
.name("solana-broadcaster".to_string())
|
.name("solana-broadcaster".to_string())
|
||||||
.spawn(move || {
|
.spawn(move || {
|
||||||
Self::run(sock, crdt, window, entry_height, recycler, receiver);
|
Self::run(&sock, &crdt, &window, entry_height, &recycler, &receiver);
|
||||||
})
|
})
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue