gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

clear out old blobs in find_next_missing

Browse Source
This commit is contained in:
Rob Walker
2018-07-31 15:45:03 -07:00
committed by Grimes
parent c9bb5c1f5b
commit 5dd2f737a3
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/streamer.rs
View File

@ -179,10 +179,17 @@ fn find_next_missing(
if received <= consumed { if received <= consumed {
Err(WindowError::GenericError)?; Err(WindowError::GenericError)?;
} }
let window = window.read().unwrap(); let mut window = window.write().unwrap();
let reqs: Vec<_> = (consumed..received) let reqs: Vec<_> = (consumed..received)
.filter_map(|pix| { .filter_map(|pix| {
let i = (pix % WINDOW_SIZE) as usize; let i = (pix % WINDOW_SIZE) as usize;
if let Some(blob) = mem::replace(&mut window[i].data, None) {
let blob_idx = blob.read().unwrap().get_index().unwrap();
if blob_idx == pix {
mem::replace(&mut window[i].data, Some(blob));
}
}
if window[i].data.is_none() { if window[i].data.is_none() {
let val = crdt.read().unwrap().window_index_request(pix as u64); let val = crdt.read().unwrap().window_index_request(pix as u64);
if let Ok((to, req)) = val { if let Ok((to, req)) = val {