@@ -77,42 +77,3 @@ pub async fn test_dynamic_bootstrap() {
77
77
exit ( 0 ) ;
78
78
}
79
79
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