Lines Matching full:groups
205 let mut groups = get_test_groups( in test_empty_commits() localVariable
215 for i in 0..groups.len() { in test_empty_commits()
217 let commit_output = groups[i].commit(Vec::new()).await.unwrap(); in test_empty_commits()
221 let index = groups[i].current_member_index() as usize; in test_empty_commits()
222 all_process_message(&mut groups, &commit_output.commit_message, index, true).await; in test_empty_commits()
224 for other_group in groups.iter() { in test_empty_commits()
225 assert!(Group::equal_group_state(other_group, &groups[i])); in test_empty_commits()
243 let mut groups = get_test_groups( in test_update_proposals() localVariable
252 for i in 0..groups.len() - 1 { in test_update_proposals()
253 let update_proposal_msg = groups[i].propose_update(Vec::new()).await.unwrap(); in test_update_proposals()
255 let sender = groups[i].current_member_index() as usize; in test_update_proposals()
256 all_process_message(&mut groups, &update_proposal_msg, sender, false).await; in test_update_proposals()
261 let commit_output = groups[committer_index].commit(Vec::new()).await.unwrap(); in test_update_proposals()
267 all_process_message(&mut groups, &commit, committer_index, true).await; in test_update_proposals()
269 groups in test_update_proposals()
271 .for_each(|g| assert!(Group::equal_group_state(g, &groups[0]))); in test_update_proposals()
288 let mut groups = get_test_groups( in test_remove_proposals() localVariable
297 while groups.len() > 1 { in test_remove_proposals()
298 let removed_and_committer = (0..groups.len()).choose_multiple(&mut rand::thread_rng(), 2); in test_remove_proposals()
302 let to_remove_index = groups[to_remove].current_member_index(); in test_remove_proposals()
304 let epoch_before_remove = groups[committer].current_epoch(); in test_remove_proposals()
306 let commit_output = groups[committer] in test_remove_proposals()
317 let committer_index = groups[committer].current_member_index() as usize; in test_remove_proposals()
318 all_process_message(&mut groups, &commit, committer_index, true).await; in test_remove_proposals()
321 for (i, group) in groups.iter().enumerate() { in test_remove_proposals()
330 groups.retain(|group| group.current_member_index() != to_remove_index); in test_remove_proposals()
332 for one_group in groups.iter() { in test_remove_proposals()
333 assert!(Group::equal_group_state(one_group, &groups[0])) in test_remove_proposals()
353 let mut groups = get_test_groups( in test_application_messages() localVariable
362 for i in 0..groups.len() { in test_application_messages()
368 let ciphertext = groups[i] in test_application_messages()
373 let sender_index = groups[i].current_member_index(); in test_application_messages()
375 for g in groups.iter_mut() { in test_application_messages()
392 let mut groups = in test_out_of_order_application_messages() localVariable
395 let mut alice_group = groups[0].clone(); in test_out_of_order_application_messages()
396 let bob_group = &mut groups[1]; in test_out_of_order_application_messages()
505 let mut groups = vec![creator_group]; in external_commits_work() localVariable
508 let existing_group = groups.choose_mut(&mut rand::thread_rng()).unwrap(); in external_commits_work()
522 for group in groups.iter_mut() { in external_commits_work()
529 groups.push(new_group); in external_commits_work()
532 assert!(groups in external_commits_work()
536 for i in 0..groups.len() { in external_commits_work()
537 let message = groups[i].propose_remove(0, Vec::new()).await.unwrap(); in external_commits_work()
539 for (_, group) in groups.iter_mut().enumerate().filter(|&(j, _)| i != j) { in external_commits_work()
566 let mut groups = in test_remove_nonexisting_leaf() localVariable
569 groups[0] in test_remove_nonexisting_leaf()
576 groups[0].apply_pending_commit().await.unwrap(); in test_remove_nonexisting_leaf()
579 assert!(groups[0].commit_builder().remove_member(13).is_err()); in test_remove_nonexisting_leaf()
582 assert!(groups[0].commit_builder().remove_member(5).is_err()); in test_remove_nonexisting_leaf()
732 let mut groups = in external_joiner_can_process_siblings_update() localVariable
736 let c = groups[0] in external_joiner_can_process_siblings_update()
744 all_process_message(&mut groups, &c.commit_message, 0, true).await; in external_joiner_can_process_siblings_update()
746 let info = groups[0] in external_joiner_can_process_siblings_update()
762 all_process_message(&mut groups, &commit, 1, false).await; in external_joiner_can_process_siblings_update()
763 groups.remove(1); in external_joiner_can_process_siblings_update()
766 let p = groups[0].propose_update(Vec::new()).await.unwrap(); in external_joiner_can_process_siblings_update()
767 all_process_message(&mut groups, &p, 0, false).await; in external_joiner_can_process_siblings_update()
771 let c = groups[1].commit(Vec::new()).await.unwrap().commit_message; in external_joiner_can_process_siblings_update()
772 all_process_message(&mut groups, &c, 2, true).await; in external_joiner_can_process_siblings_update()
778 let mut groups = in weird_tree_scenario() localVariable
783 let mut builder = groups[14].commit_builder(); in weird_tree_scenario()
792 groups.remove(idx as usize); in weird_tree_scenario()
795 all_process_message(&mut groups, &commit.commit_message, 14, true).await; in weird_tree_scenario()
797 let mut builder = groups.last_mut().unwrap().commit_builder(); in weird_tree_scenario()
807 let idx = groups.last().unwrap().current_member_index() as usize; in weird_tree_scenario()
809 all_process_message(&mut groups, &commit.commit_message, idx, true).await; in weird_tree_scenario()