Add sleep to trim_test to wait for all nodes to decide before trimming

Wkkkkk · Oct 25, 2023 · 71ec9a1 · 71ec9a1
1 parent 306c420
commit 71ec9a1
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/omnipaxos/tests/trim_test.rs b/omnipaxos/tests/trim_test.rs
@@ -40,12 +40,14 @@ fn trim_test() {
         });
     }
 
-    // wait until all nodes have decided last entry
+    // wait until nodes have decided last entry
     match FutureCollection::collect_with_timeout::<Vec<_>>(futures, cfg.wait_timeout) {
         Ok(_) => {}
         Err(e) => panic!("Error on collecting futures of decided proposals: {}", e),
     }
 
+    thread::sleep(cfg.wait_timeout); // wait a little longer so that ALL nodes decide
+
     elected_leader.on_definition(|x| {
         x.paxos.trim(Some(cfg.trim_idx)).expect("Failed to trim");
     });
@@ -99,12 +101,14 @@ fn double_trim_test() {
         });
     }
 
-    // wait until all nodes have decided last entry
+    // wait until nodes have decided last entry
     match FutureCollection::collect_with_timeout::<Vec<_>>(futures, cfg.wait_timeout) {
         Ok(_) => {}
         Err(e) => panic!("Error on collecting futures of decided proposals: {}", e),
     }
 
+    thread::sleep(cfg.wait_timeout); // wait a little longer so that ALL nodes decide
+
     let second_trim_idx = cfg.trim_idx + TRIM_INDEX_INCREMENT;
     elected_leader.on_definition(|x| {
         x.paxos