@@ -77,42 +77,3 @@ pub async fn test_dynamic_bootstrap() {
7777 exit ( 0 ) ;
7878}
7979
80- // #[tokio::test]
81- // pub async fn test_dynamic_bootstrap_using_joint_consensus() {
82- // kill_previous_raft_processes();
83- // let (tx_raft, rx_raft) = mpsc::channel::<(u64, Raft)>();
84-
85- // let peers = load_peers(ONE_NODE_EXAMPLE).await.unwrap();
86- // let _raft_tasks = tokio::spawn(build_raft_cluster(tx_raft.clone(), peers.clone()));
87-
88- // let mut rafts = wait_until_rafts_ready(None, rx_raft, 1).await;
89- // sleep(Duration::from_secs(1)).await;
90-
91- // tokio::spawn(spawn_extra_node(tx_raft.clone(), 2, "127.0.0.1:60062"))
92- // .await
93- // .unwrap()
94- // .unwrap();
95-
96- // tokio::spawn(spawn_extra_node(tx_raft.clone(), 3, "127.0.0.1:60063"))
97- // .await
98- // .unwrap()
99- // .unwrap();
100-
101- // join_nodes(
102- // vec![rafts.get(&2).unwrap(), rafts.get(&3).unwrap()],
103- // vec!["127.0.0.1:60062", "127.0.0.1:60063"],
104- // RAFT_ADDRS[0],
105- // )
106- // .await;
107-
108- // let (tx_raft, rx_raft) = mpsc::channel::<(u64, Raft)>();
109- // let mut rafts = wait_until_rafts_ready(Some(rafts), rx_raft, 3).await;
110-
111- // let raft_1 = rafts.get(&1).unwrap();
112-
113- // wait_for_until_cluster_size_increase(raft_1.clone(), 3).await;
114-
115- // for (_, raft) in rafts.iter_mut() {
116- // raft.quit().await;
117- // }
118- // }
0 commit comments