mirror of
https://github.com/rustfs/rustfs.git
synced 2026-08-27 15:37:02 +00:00
fix: use option writer when disk is none
This commit is contained in:
@@ -46,7 +46,7 @@ impl Erasure {
|
|||||||
pub async fn encode<S>(
|
pub async fn encode<S>(
|
||||||
&self,
|
&self,
|
||||||
body: S,
|
body: S,
|
||||||
writers: &mut [FileWriter],
|
writers: &mut [Option<FileWriter>],
|
||||||
// block_size: usize,
|
// block_size: usize,
|
||||||
total_size: usize,
|
total_size: usize,
|
||||||
_write_quorum: usize,
|
_write_quorum: usize,
|
||||||
@@ -84,7 +84,10 @@ impl Erasure {
|
|||||||
let mut errs = Vec::new();
|
let mut errs = Vec::new();
|
||||||
|
|
||||||
for (i, w) in writers.iter_mut().enumerate() {
|
for (i, w) in writers.iter_mut().enumerate() {
|
||||||
match w.write(blocks[i].as_ref()).await {
|
if w.is_none() {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
match w.as_mut().unwrap().write(blocks[i].as_ref()).await {
|
||||||
Ok(_) => errs.push(None),
|
Ok(_) => errs.push(None),
|
||||||
Err(e) => errs.push(Some(e)),
|
Err(e) => errs.push(Some(e)),
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user