Compare commits
2 Commits
2555de637f
...
07c2721307
Author | SHA1 | Date | |
---|---|---|---|
07c2721307 | |||
3861400145 |
17
Cargo.lock
generated
17
Cargo.lock
generated
@ -997,6 +997,17 @@ dependencies = [
|
||||
"hashbrown",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "io-uring"
|
||||
version = "0.7.8"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "b86e202f00093dcba4275d4636b93ef9dd75d025ae560d2521b45ea28ab49013"
|
||||
dependencies = [
|
||||
"bitflags",
|
||||
"cfg-if",
|
||||
"libc",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "is_terminal_polyfill"
|
||||
version = "1.70.1"
|
||||
@ -1565,17 +1576,19 @@ dependencies = [
|
||||
|
||||
[[package]]
|
||||
name = "tokio"
|
||||
version = "1.45.1"
|
||||
version = "1.46.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "75ef51a33ef1da925cea3e4eb122833cb377c61439ca401b770f54902b806779"
|
||||
checksum = "1140bb80481756a8cbe10541f37433b459c5aa1e727b4c020fbfebdc25bf3ec4"
|
||||
dependencies = [
|
||||
"backtrace",
|
||||
"bytes",
|
||||
"io-uring",
|
||||
"libc",
|
||||
"mio",
|
||||
"parking_lot",
|
||||
"pin-project-lite",
|
||||
"signal-hook-registry",
|
||||
"slab",
|
||||
"socket2",
|
||||
"windows-sys 0.52.0",
|
||||
]
|
||||
|
@ -15,4 +15,4 @@ log = "0.4.27"
|
||||
env_logger = "0.11.8"
|
||||
actix-web-httpauth = "0.8.2"
|
||||
askama = "0.14.0"
|
||||
tokio = "1.45.1"
|
||||
tokio = "1.46.0"
|
||||
|
@ -102,7 +102,7 @@ struct SendWrapper(mpsc::SyncSender<Vec<u8>>);
|
||||
impl Write for SendWrapper {
|
||||
fn write(&mut self, buf: &[u8]) -> std::io::Result<usize> {
|
||||
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(
|
||||
"Failed to send a chunk of data!",
|
||||
));
|
||||
@ -127,7 +127,7 @@ impl FileStreamer {
|
||||
|
||||
for file in files_list() {
|
||||
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(
|
||||
file_path,
|
||||
&mut File::open(&file).expect("Failed to open file"),
|
||||
@ -149,7 +149,7 @@ impl Stream for FileStreamer {
|
||||
match self.receive.recv() {
|
||||
Ok(d) => Poll::Ready(Some(Ok(Bytes::copy_from_slice(&d)))),
|
||||
Err(e) => {
|
||||
log::error!("Recv error: {}", e);
|
||||
log::error!("Recv error: {e}");
|
||||
Poll::Ready(None)
|
||||
}
|
||||
}
|
||||
|
Reference in New Issue
Block a user