diff --git a/tests/coordinator/src/tests/batch.rs b/tests/coordinator/src/tests/batch.rs index 0160afb3..e0257dc3 100644 --- a/tests/coordinator/src/tests/batch.rs +++ b/tests/coordinator/src/tests/batch.rs @@ -1,4 +1,5 @@ use std::{ + sync::Mutex, time::Duration, collections::{HashSet, HashMap}, }; @@ -235,6 +236,7 @@ pub async fn batch( #[tokio::test] async fn batch_test() { + let _one_at_a_time = ONE_AT_A_TIME.get_or_init(|| Mutex::new(())).lock(); let (processors, test) = new_test(); test diff --git a/tests/coordinator/src/tests/key_gen.rs b/tests/coordinator/src/tests/key_gen.rs index f650c14f..ce4993a6 100644 --- a/tests/coordinator/src/tests/key_gen.rs +++ b/tests/coordinator/src/tests/key_gen.rs @@ -1,4 +1,5 @@ use std::{ + sync::Mutex, time::{Duration, SystemTime}, collections::HashMap, }; @@ -172,6 +173,7 @@ pub async fn key_gen( #[tokio::test] async fn key_gen_test() { + let _one_at_a_time = ONE_AT_A_TIME.get_or_init(|| Mutex::new(())).lock(); let (processors, test) = new_test(); test diff --git a/tests/coordinator/src/tests/mod.rs b/tests/coordinator/src/tests/mod.rs index 0e07d835..3ef9a050 100644 --- a/tests/coordinator/src/tests/mod.rs +++ b/tests/coordinator/src/tests/mod.rs @@ -1,3 +1,5 @@ +use std::sync::OnceLock; + use ciphersuite::Ristretto; use dockertest::DockerTest; @@ -16,6 +18,8 @@ pub use sign::sign; pub(crate) const COORDINATORS: usize = 4; pub(crate) const THRESHOLD: usize = ((COORDINATORS * 2) / 3) + 1; +pub(crate) static ONE_AT_A_TIME: OnceLock> = OnceLock::new(); + pub(crate) fn new_test() -> (Vec<(Handles, ::F)>, DockerTest) { let mut coordinators = vec![]; let mut test = DockerTest::new(); diff --git a/tests/coordinator/src/tests/sign.rs b/tests/coordinator/src/tests/sign.rs index 98cd02a3..816caf87 100644 --- a/tests/coordinator/src/tests/sign.rs +++ b/tests/coordinator/src/tests/sign.rs @@ -1,4 +1,5 @@ use std::{ + sync::Mutex, time::Duration, collections::{HashSet, HashMap}, }; @@ -177,6 +178,7 @@ pub async fn sign( #[tokio::test] async fn sign_test() { + let _one_at_a_time = ONE_AT_A_TIME.get_or_init(|| Mutex::new(())).lock(); let (processors, test) = new_test(); test