berkus
/
actix-web
mirror of https://github.com/fafhrd91/actix-web
1
0
Fork 0
Code Issues Releases Wiki Activity

Merge 8a33464182 into 90c19a835d

This commit is contained in:
Joel Wurtz 2025-03-25 17:05:57 +00:00 committed by GitHub
parent 90c19a835d 8a33464182
commit b7ee2ee9e9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 9 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
actix-files/CHANGES.md
View File

@ -3,6 +3,7 @@
## Unreleased ## Unreleased
- Minimum supported Rust version (MSRV) is now 1.75. - Minimum supported Rust version (MSRV) is now 1.75.
- Avoid spawning a thread for each file which does more harm than good
## 0.6.6 ## 0.6.6

21
actix-files/src/chunked.rs
View File

@ -80,22 +80,17 @@ async fn chunked_read_file_callback(
) -> Result<(File, Bytes), Error> { ) -> Result<(File, Bytes), Error> {
use io::{Read as _, Seek as _}; use io::{Read as _, Seek as _};
let res = actix_web::web::block(move || { let mut buf = Vec::with_capacity(max_bytes);
let mut buf = Vec::with_capacity(max_bytes);
file.seek(io::SeekFrom::Start(offset))?; file.seek(io::SeekFrom::Start(offset))?;
let n_bytes = file.by_ref().take(max_bytes as u64).read_to_end(&mut buf)?; let n_bytes = file.by_ref().take(max_bytes as u64).read_to_end(&mut buf)?;
if n_bytes == 0 { if n_bytes == 0 {
Err(io::Error::from(io::ErrorKind::UnexpectedEof)) Err(Error::from(io::Error::from(io::ErrorKind::UnexpectedEof)))
} else { } else {
Ok((file, Bytes::from(buf))) Ok((file, Bytes::from(buf)))
} }
})
.await??;
Ok(res)
} }
#[cfg(feature = "experimental-io-uring")] #[cfg(feature = "experimental-io-uring")]