sdgoij/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-01-17 01:30:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

tmp2

Browse Source 
Signed-off-by: junxiang Mu <1948535941@qq.com>
This commit is contained in:
junxiang Mu
2025-04-29 03:41:45 +00:00
parent e346d20228
commit 1dde7015de
2 changed files with 23 additions and 39 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
ecstore/src/erasure.rs
View File

@@ -619,35 +619,34 @@ impl ShardReader {
#[cfg(test)]
mod test {
use super::*;
// use super::*;
#[test]
fn test_erasure() {
let data_shards = 3;
let parity_shards = 2;
let data: &[u8] = &[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11];
let ec = Erasure::new(data_shards, parity_shards, 1);
let shards = Arc::new(ec).encode_data(data).unwrap();
println!("shards:{:?}", shards);
// #[test]
// fn test_erasure() {
// let data_shards = 3;
// let parity_shards = 2;
// let data: &[u8] = &[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11];
// let ec = Erasure::new(data_shards, parity_shards, 1);
// let mut shards = SmallVec::new();
// Arc::new(ec).encode_data(data, &mut shards).unwrap();
// println!("shards:{:?}", shards);
let mut s: Vec<_> = shards
.iter()
.map(|d| if d.is_empty() { None } else { Some(d.to_vec()) })
.collect();
// let mut s: Vec<_> = shards
// .iter()
// .map(|d| if d.is_empty() { None } else { Some(d.to_vec()) })
// .collect();
// let mut s = shards_to_option_shards(&shards);
// // let mut s = shards_to_option_shards(&shards);
// s[0] = None;
s[4] = None;
s[3] = None;
// // s[0] = None;
// s[4] = None;
// s[3] = None;
println!("sss:{:?}", &s);
// println!("sss:{:?}", &s);
let ec = Erasure::new(data_shards, parity_shards, 1);
ec.decode_data(&mut s).unwrap();
// ec.encoder.reconstruct(&mut s).unwrap();
// ec.decode_data(&mut s).unwrap();
// // ec.encoder.reconstruct(&mut s).unwrap();
// println!("sss:{:?}", &s);
// }
println!("sss:{:?}", &s);
}
}

15
ecstore/src/io.rs
View File

@@ -194,20 +194,5 @@ impl<R: AsyncRead + Unpin> AsyncRead for EtagReader<R> {
return Poll::Ready(Ok(()));
}
}
// let poll = Pin::new(&mut self.inner).poll_read(cx, buf);
// if let Poll::Ready(Ok(())) = &poll {
// if buf.remaining() == 0 {
// let bytes = buf.filled();
// let bytes = Bytes::copy_from_slice(bytes);
// let tx = self.bytes_tx.clone();
// tokio::spawn(async move {
// if let Err(e) = tx.send(bytes).await {
// warn!("EtagReader send error: {:?}", e);
// }
// });
// }
// }
// poll
}
}