gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-08-27 15:37:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix zero size object bug

Browse Source 
Signed-off-by: junxiang Mu <1948535941@qq.com>
This commit is contained in:
junxiang Mu
2025-05-08 19:34:58 +08:00
parent 7a94363b38
commit 5cb040f863
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/utils/src/net.rs
+1
View File
@@ -0,0 +1 @@
ecstore/src/erasure.rs
+4 -5
View File
@@ -67,7 +67,7 @@ impl Erasure {
{ {
let (tx, mut rx) = mpsc::channel(5); let (tx, mut rx) = mpsc::channel(5);
let task = tokio::spawn(async move { let task = tokio::spawn(async move {
let mut buf = Vec::new(); let mut buf = vec![0u8; self.block_size];
let mut total: usize = 0; let mut total: usize = 0;
loop { loop {
if total_size > 0 { if total_size > 0 {
@@ -99,6 +99,9 @@ impl Erasure {
} }
let blocks = Arc::new(Box::pin(self.clone().encode_data(&buf)?)); let blocks = Arc::new(Box::pin(self.clone().encode_data(&buf)?));
let _ = tx.send(blocks).await; let _ = tx.send(blocks).await;
if total_size == 0 {
break;
}
} }
let etag = reader.etag().await; let etag = reader.etag().await;
Ok((total, etag)) Ok((total, etag))
@@ -129,10 +132,6 @@ impl Erasure {
warn!("Erasure encode errs {:?}", &errs); warn!("Erasure encode errs {:?}", &errs);
return Err(err); return Err(err);
} }
if total_size == 0 {
break;
}
} }
task.await? task.await?
} }