Skip to content

Commit

Permalink
Wait on blob fetch before window, Seems to fix instability (#1304)
Browse files Browse the repository at this point in the history
also cleanup ledger.
  • Loading branch information
sakridge authored Sep 22, 2018
1 parent e87cac0 commit 54b407b
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion src/replicator.rs
Original file line number Diff line number Diff line change
Expand Up @@ -83,8 +83,8 @@ impl Replicator {

pub fn join(self) {
self.ncp.join().unwrap();
self.t_window.join().unwrap();
self.fetch_stage.join().unwrap();
self.t_window.join().unwrap();
self.store_ledger_stage.join().unwrap();
}
}
Expand All @@ -98,6 +98,7 @@ mod tests {
use logger;
use replicator::Replicator;
use signature::{Keypair, KeypairUtil};
use std::fs::remove_dir_all;
use std::sync::atomic::{AtomicBool, Ordering};
use std::sync::Arc;
use std::thread::sleep;
Expand Down Expand Up @@ -177,5 +178,7 @@ mod tests {
exit.store(true, Ordering::Relaxed);
replicator.join();
leader.exit();
let _ignored = remove_dir_all(&leader_ledger_path);
let _ignored = remove_dir_all(&replicator_ledger_path);
}
}

0 comments on commit 54b407b

Please sign in to comment.