diff --git a/harness/tests/bootstrap.rs b/harness/tests/bootstrap.rs index 724c152..a33561b 100644 --- a/harness/tests/bootstrap.rs +++ b/harness/tests/bootstrap.rs @@ -77,42 +77,3 @@ pub async fn test_dynamic_bootstrap() { exit(0); } -// #[tokio::test] -// pub async fn test_dynamic_bootstrap_using_joint_consensus() { -// kill_previous_raft_processes(); -// let (tx_raft, rx_raft) = mpsc::channel::<(u64, Raft)>(); - -// let peers = load_peers(ONE_NODE_EXAMPLE).await.unwrap(); -// let _raft_tasks = tokio::spawn(build_raft_cluster(tx_raft.clone(), peers.clone())); - -// let mut rafts = wait_until_rafts_ready(None, rx_raft, 1).await; -// sleep(Duration::from_secs(1)).await; - -// tokio::spawn(spawn_extra_node(tx_raft.clone(), 2, "127.0.0.1:60062")) -// .await -// .unwrap() -// .unwrap(); - -// tokio::spawn(spawn_extra_node(tx_raft.clone(), 3, "127.0.0.1:60063")) -// .await -// .unwrap() -// .unwrap(); - -// join_nodes( -// vec![rafts.get(&2).unwrap(), rafts.get(&3).unwrap()], -// vec!["127.0.0.1:60062", "127.0.0.1:60063"], -// RAFT_ADDRS[0], -// ) -// .await; - -// let (tx_raft, rx_raft) = mpsc::channel::<(u64, Raft)>(); -// let mut rafts = wait_until_rafts_ready(Some(rafts), rx_raft, 3).await; - -// let raft_1 = rafts.get(&1).unwrap(); - -// wait_for_until_cluster_size_increase(raft_1.clone(), 3).await; - -// for (_, raft) in rafts.iter_mut() { -// raft.quit().await; -// } -// }