diff --git a/src/api/router/snapshot_raw_blob.rs b/src/api/router/snapshot_raw_blob.rs index 016310cd..fa8fa3c7 100644 --- a/src/api/router/snapshot_raw_blob.rs +++ b/src/api/router/snapshot_raw_blob.rs @@ -377,10 +377,10 @@ impl RawBlobReader { "fixed-view raw stream failed", ) })?; - if part.as_ref().is_some_and(|bytes| !bytes.is_empty()) { - if let Some(map) = self.map.as_ref() { - map.record_progress().await?; - } + if part.as_ref().is_some_and(|bytes| !bytes.is_empty()) + && let Some(map) = self.map.as_ref() + { + map.record_progress().await?; } Ok(part) } diff --git a/src/jupiter/storage/native_chunk_map/retention.rs b/src/jupiter/storage/native_chunk_map/retention.rs index 82a74da2..235ec86f 100644 --- a/src/jupiter/storage/native_chunk_map/retention.rs +++ b/src/jupiter/storage/native_chunk_map/retention.rs @@ -409,14 +409,14 @@ impl ChunkMapInstall { impl Drop for ChunkMapInstall { fn drop(&mut self) { - if let Ok(mut cancelled) = self.repository.cancelled_installs.lock() { - if cancelled.len() < 64 { - cancelled.push(CancelledInstall { - owner: self.owner, - key: self.key.key.clone(), - generation: self.generation, - }); - } + if let Ok(mut cancelled) = self.repository.cancelled_installs.lock() + && cancelled.len() < 64 + { + cancelled.push(CancelledInstall { + owner: self.owner, + key: self.key.key.clone(), + generation: self.generation, + }); } let Ok(runtime) = tokio::runtime::Handle::try_current() else { return;