Skip to content
Snippets Groups Projects
Commit 69b92342 authored by Georgy Moshkin's avatar Georgy Moshkin :speech_balloon: Committed by Yaroslav Dynnikov
Browse files

fix(governor): used to wait infinitely in call_all with no requests

parent ca20f2c9
No related branches found
No related tags found
No related merge requests found
Pipeline #13616 passed
...@@ -1542,6 +1542,9 @@ fn raft_conf_change_loop(status: Rc<Cell<Status>>, storage: Storage) { ...@@ -1542,6 +1542,9 @@ fn raft_conf_change_loop(status: Rc<Cell<Status>>, storage: Storage) {
// //
// Those things aren't implemented yet, so this is what we do // Those things aren't implemented yet, so this is what we do
let reqs = reqs.into_iter().collect::<Vec<_>>(); let reqs = reqs.into_iter().collect::<Vec<_>>();
if reqs.is_empty() {
return Ok(vec![]);
}
static mut SENT_COUNT: usize = 0; static mut SENT_COUNT: usize = 0;
unsafe { SENT_COUNT = 0 }; unsafe { SENT_COUNT = 0 };
let (cond_rx, cond_tx) = Rc::new(fiber::Cond::new()).into_clones(); let (cond_rx, cond_tx) = Rc::new(fiber::Cond::new()).into_clones();
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment