LemmyNet/pict-rs
2
0
Fork 0
mirror of https://git.asonix.dog/asonix/pict-rs synced 2024-12-22 11:21:24 +00:00
Code Releases Activity

Lower priority of some object storage spans

Browse source
This commit is contained in:
asonix 2023-12-22 13:58:05 -06:00
parent 045a91a7bf
commit df88660b9e
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/store/object_store.rs
View file

@ -167,7 +167,7 @@ fn payload_to_io_error(e: reqwest::Error) -> std::io::Error {
std::io::Error::new(std::io::ErrorKind::Other, e.to_string()) std::io::Error::new(std::io::ErrorKind::Other, e.to_string())
} }
#[tracing::instrument(skip(stream))] #[tracing::instrument(level = "debug", skip(stream))]
async fn read_chunk<S>(stream: &mut S) -> Result<BytesStream, ObjectError> async fn read_chunk<S>(stream: &mut S) -> Result<BytesStream, ObjectError>
where where
S: Stream<Item = std::io::Result<Bytes>> + Unpin + 'static, S: Stream<Item = std::io::Result<Bytes>> + Unpin + 'static,
@ -177,8 +177,8 @@ where
let mut stream = stream.into_streamer(); let mut stream = stream.into_streamer();
while buf.len() < CHUNK_SIZE { while buf.len() < CHUNK_SIZE {
if let Some(res) = stream.next().await { if let Some(bytes) = stream.try_next().await? {
buf.add_bytes(res?) buf.add_bytes(bytes)
} else { } else {
break; break;
} }
@ -603,7 +603,7 @@ impl ObjectStore {
let length = buf.len(); let length = buf.len();
let hashing_span = tracing::info_span!("Hashing request body"); let hashing_span = tracing::debug_span!("Hashing request body");
let hash_string = actix_web::web::block(move || { let hash_string = actix_web::web::block(move || {
let guard = hashing_span.enter(); let guard = hashing_span.enter();
let mut hasher = md5::Md5::new(); let mut hasher = md5::Md5::new();