From 0a9a5edd13fd4f7fd28c0465664ddc427f00b9a2 Mon Sep 17 00:00:00 2001 From: chanderlud Date: Wed, 29 Nov 2023 21:47:01 -0800 Subject: [PATCH] it compiles now --- src/receiver/mod.rs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/receiver/mod.rs b/src/receiver/mod.rs index 82b517c..b4a14e9 100644 --- a/src/receiver/mod.rs +++ b/src/receiver/mod.rs @@ -16,7 +16,10 @@ use tokio::{io, select}; use crate::receiver::metadata::Metadata; use crate::receiver::writer::writer; -use crate::{socket_factory, LimitedQueue, Options, Result, TransferStats, UnlimitedQueue, INDEX_SIZE, MAX_RETRIES, TRANSFER_BUFFER_SIZE, RECEIVE_TIMEOUT}; +use crate::{ + socket_factory, LimitedQueue, Options, Result, TransferStats, UnlimitedQueue, INDEX_SIZE, + MAX_RETRIES, RECEIVE_TIMEOUT, TRANSFER_BUFFER_SIZE, +}; mod metadata; mod writer; @@ -129,10 +132,7 @@ async fn receiver(queue: WriterQueue, socket: UdpSocket) { queue.push(Job { data, index, len }).await; } Ok(Ok(_)) => warn!("0 byte read?"), - Ok(Err(error)) | Err(error) => { - error!("failed to receive data {}", error); - retries += 1; - } + Ok(Err(_)) | Err(_) => retries += 1, } } }