pierre/heavy-files-server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix cargo clippy issues
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Pierre HUBERT
2025-07-03 08:11:36 +02:00
parent 0e263b211f
commit 3861400145
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main.rs
View File

@ -102,7 +102,7 @@ struct SendWrapper(mpsc::SyncSender<Vec<u8>>);
impl Write for SendWrapper { impl Write for SendWrapper {
fn write(&mut self, buf: &[u8]) -> std::io::Result<usize> { fn write(&mut self, buf: &[u8]) -> std::io::Result<usize> {
if let Err(e) = self.0.send(buf.to_vec()) { if let Err(e) = self.0.send(buf.to_vec()) {
log::error!("Failed to send a chunk of data! {}", e); log::error!("Failed to send a chunk of data! {e}");
return Err(std::io::Error::other( return Err(std::io::Error::other(
"Failed to send a chunk of data!", "Failed to send a chunk of data!",
)); ));
@ -127,7 +127,7 @@ impl FileStreamer {
for file in files_list() { for file in files_list() {
let file_path = &file.to_str().unwrap().replace(&ARGS.target_dir, "")[1..]; let file_path = &file.to_str().unwrap().replace(&ARGS.target_dir, "")[1..];
log::debug!("Add {} to archive", file_path); log::debug!("Add {file_path} to archive");
tar.append_file( tar.append_file(
file_path, file_path,
&mut File::open(&file).expect("Failed to open file"), &mut File::open(&file).expect("Failed to open file"),
@ -149,7 +149,7 @@ impl Stream for FileStreamer {
match self.receive.recv() { match self.receive.recv() {
Ok(d) => Poll::Ready(Some(Ok(Bytes::copy_from_slice(&d)))), Ok(d) => Poll::Ready(Some(Ok(Bytes::copy_from_slice(&d)))),
Err(e) => { Err(e) => {
log::error!("Recv error: {}", e); log::error!("Recv error: {e}");
Poll::Ready(None) Poll::Ready(None)
} }
} }