Lines Matching full:await
51 .await in generate_client()
69 .await in get_test_groups()
93 test(version, cs, 10, encrypt_controls).await; in test_on_all_params()
121 test_on_all_params_plaintext(test).await; in test_on_all_params()
141 test(version, cs, 10, false).await; in test_on_all_params_plaintext()
165 let alice = generate_client(cipher_suite, protocol_version, 0, encrypt_controls).await; in test_create()
166 let bob = generate_client(cipher_suite, protocol_version, 1, encrypt_controls).await; in test_create()
167 let bob_key_pkg = bob.generate_key_package_message().await.unwrap(); in test_create()
172 .await in test_create()
180 .await in test_create()
185 alice_group.apply_pending_commit().await.unwrap(); in test_create()
188 let (bob_group, _) = bob.join_group(None, welcome).await.unwrap(); in test_create()
195 test_on_all_params(test_create).await; in test_create_group()
211 .await; in test_empty_commits()
217 let commit_output = groups[i].commit(Vec::new()).await.unwrap(); in test_empty_commits()
222 all_process_message(&mut groups, &commit_output.commit_message, index, true).await; in test_empty_commits()
232 test_on_all_params(test_empty_commits).await; in test_group_path_updates()
249 .await; in test_update_proposals()
253 let update_proposal_msg = groups[i].propose_update(Vec::new()).await.unwrap(); 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()
278 test_on_all_params(test_update_proposals).await; in test_group_update_proposals()
294 .await; in test_remove_proposals()
311 .await in test_remove_proposals()
318 all_process_message(&mut groups, &commit, committer_index, true).await; in test_remove_proposals()
340 test_on_all_params(test_remove_proposals).await; in test_group_remove_proposals()
359 .await; in test_application_messages()
370 .await in test_application_messages()
379 .await in test_application_messages()
393 get_test_groups(ProtocolVersion::MLS_10, CipherSuite::P256_AES128, 2, false).await; in test_out_of_order_application_messages()
400 .await in test_out_of_order_application_messages()
408 .await in test_out_of_order_application_messages()
412 let commit = alice_group.commit(Vec::new()).await.unwrap().commit_message; in test_out_of_order_application_messages()
414 alice_group.apply_pending_commit().await.unwrap(); in test_out_of_order_application_messages()
416 bob_group.process_incoming_message(commit).await.unwrap(); in test_out_of_order_application_messages()
421 .await in test_out_of_order_application_messages()
428 .await in test_out_of_order_application_messages()
435 .await in test_out_of_order_application_messages()
448 test_on_all_params(test_application_messages).await in test_group_application_messages()
460 get_test_groups(protocol_version, cipher_suite, 1, encrypt_controls).await; in processing_message_from_self_returns_error()
465 .await in processing_message_from_self_returns_error()
470 .await in processing_message_from_self_returns_error()
479 test_on_all_params(processing_message_from_self_returns_error).await; in test_processing_message_from_self_returns_error()
490 let creator = generate_client(cipher_suite, protocol_version, 0, false).await; in external_commits_work()
494 .await in external_commits_work()
502 others.push(generate_client(cipher_suite, protocol_version, i, Default::default()).await) in external_commits_work()
512 .await in external_commits_work()
519 .await in external_commits_work()
525 .await in external_commits_work()
537 let message = groups[i].propose_remove(0, Vec::new()).await.unwrap(); in external_commits_work()
542 .await in external_commits_work()
561 test_on_all_params_plaintext(external_commits_work).await in test_external_commits()
567 get_test_groups(ProtocolVersion::MLS_10, CipherSuite::P256_AES128, 10, false).await; in test_remove_nonexisting_leaf()
574 .await in test_remove_nonexisting_leaf()
576 groups[0].apply_pending_commit().await.unwrap(); in test_remove_nonexisting_leaf()
598 let alice1 = generate_client(suite1, version, 1, Default::default()).await; in reinit_works()
599 let bob1 = generate_client(suite1, version, 2, Default::default()).await; in reinit_works()
602 let mut alice_group = alice1.create_group(ExtensionList::new()).await.unwrap(); in reinit_works()
603 let kp = bob1.generate_key_package_message().await.unwrap(); in reinit_works()
610 .await in reinit_works()
614 alice_group.apply_pending_commit().await.unwrap(); in reinit_works()
616 let (mut bob_group, _) = bob1.join_group(None, welcome).await.unwrap(); in reinit_works()
627 .await in reinit_works()
633 .await in reinit_works()
636 let commit = bob_group.commit(Vec::new()).await.unwrap().commit_message; in reinit_works()
642 let state_update = bob_group.apply_pending_commit().await.unwrap().state_update; in reinit_works()
647 bob_group.apply_pending_commit().await.unwrap(); in reinit_works()
649 let message = alice_group.process_incoming_message(commit).await.unwrap(); in reinit_works()
663 let res = alice_group.commit(Vec::new()).await; in reinit_works()
666 let res = bob_group.commit(Vec::new()).await; in reinit_works()
674 .await in reinit_works()
687 .await in reinit_works()
697 let kp = bob2.generate_key_package().await.unwrap(); in reinit_works()
698 let (mut alice_group, welcome) = alice2.commit(vec![kp]).await.unwrap(); in reinit_works()
699 let (mut bob_group, _) = bob2.join(&welcome[0], None).await.unwrap(); in reinit_works()
704 let carol = generate_client(suite2, version, 3, Default::default()).await; in reinit_works()
706 let kp = carol.generate_key_package_message().await.unwrap(); in reinit_works()
713 .await in reinit_works()
716 alice_group.apply_pending_commit().await.unwrap(); in reinit_works()
720 .await in reinit_works()
725 .await in reinit_works()
733 get_test_groups(ProtocolVersion::MLS_10, CipherSuite::P256_AES128, 3, false).await; in external_joiner_can_process_siblings_update()
741 .await 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()
748 .await in external_joiner_can_process_siblings_update()
758 .await; in external_joiner_can_process_siblings_update()
760 let (mut group, commit) = new_client.commit_external(info).await.unwrap(); in external_joiner_can_process_siblings_update()
762 all_process_message(&mut groups, &commit, 1, false).await; 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()
768 group.process_incoming_message(p).await.unwrap(); 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()
773 group.process_incoming_message(c).await.unwrap(); in external_joiner_can_process_siblings_update()
779 get_test_groups(ProtocolVersion::MLS_10, CipherSuite::P256_AES128, 17, false).await; in weird_tree_scenario()
789 let commit = builder.build().await.unwrap(); in weird_tree_scenario()
795 all_process_message(&mut groups, &commit.commit_message, 14, true).await; in weird_tree_scenario()
801 .add_member(fake_key_package(5555555 + idx).await) in weird_tree_scenario()
805 let commit = builder.remove_member(1).unwrap().build().await.unwrap(); in weird_tree_scenario()
809 all_process_message(&mut groups, &commit.commit_message, idx, true).await; in weird_tree_scenario()
815 .await in fake_key_package()
817 .await in fake_key_package()
834 .await in external_info_from_commit_allows_to_join()
837 let commit = alice.commit(vec![]).await.unwrap(); in external_info_from_commit_allows_to_join()
838 alice.apply_pending_commit().await.unwrap(); in external_info_from_commit_allows_to_join()
839 let bob = generate_client(cs, version, 0xdead, false).await; in external_info_from_commit_allows_to_join()
843 .await in external_info_from_commit_allows_to_join()
846 alice.process_incoming_message(commit).await.unwrap(); in external_info_from_commit_allows_to_join()