Skip to content

Commit

Permalink
it compiles now
Browse files Browse the repository at this point in the history
  • Loading branch information
chanderlud committed Nov 30, 2023
1 parent b3fabf1 commit 0a9a5ed
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions src/receiver/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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,
}
}
}
Expand Down

0 comments on commit 0a9a5ed

Please sign in to comment.