From 6a494e2cbdd146bb13185d8220061322661a5f5a Mon Sep 17 00:00:00 2001 From: irungentoo Date: Tue, 3 Nov 2015 13:42:05 -0500 Subject: Astyle. --- auto_tests/toxav_many_test.c | 169 ++++++++++++++++++++++--------------------- 1 file changed, 86 insertions(+), 83 deletions(-) (limited to 'auto_tests/toxav_many_test.c') diff --git a/auto_tests/toxav_many_test.c b/auto_tests/toxav_many_test.c index 9819b694..ab496024 100644 --- a/auto_tests/toxav_many_test.c +++ b/auto_tests/toxav_many_test.c @@ -42,29 +42,29 @@ typedef struct { } CallControl; typedef struct { - ToxAV* AliceAV; - ToxAV* BobAV; - CallControl* AliceCC; - CallControl* BobCC; + ToxAV *AliceAV; + ToxAV *BobAV; + CallControl *AliceCC; + CallControl *BobCC; uint32_t friend_number; } thread_data; /** - * Callbacks + * Callbacks */ void t_toxav_call_cb(ToxAV *av, uint32_t friend_number, bool audio_enabled, bool video_enabled, void *user_data) { (void) av; (void) audio_enabled; (void) video_enabled; - + printf("Handling CALL callback\n"); - ((CallControl*)user_data)[friend_number].incoming = true; + ((CallControl *)user_data)[friend_number].incoming = true; } void t_toxav_call_state_cb(ToxAV *av, uint32_t friend_number, uint32_t state, void *user_data) { printf("Handling CALL STATE callback: %d %p\n", state, av); - ((CallControl*)user_data)[friend_number].state = state; + ((CallControl *)user_data)[friend_number].state = state; } void t_toxav_receive_video_frame_cb(ToxAV *av, uint32_t friend_number, uint16_t width, uint16_t height, @@ -102,6 +102,7 @@ void t_toxav_receive_audio_frame_cb(ToxAV *av, uint32_t friend_number, void t_accept_friend_request_cb(Tox *m, const uint8_t *public_key, const uint8_t *data, size_t length, void *userdata) { (void) userdata; + if (length == 7 && memcmp("gentoo", data, 7) == 0) { ck_assert(tox_friend_add_norequest(m, public_key, NULL) != (uint32_t) ~0); } @@ -111,92 +112,93 @@ void t_accept_friend_request_cb(Tox *m, const uint8_t *public_key, const uint8_t /** * Iterate helper */ -ToxAV* setup_av_instance(Tox* tox, CallControl *CC) +ToxAV *setup_av_instance(Tox *tox, CallControl *CC) { TOXAV_ERR_NEW error; - - ToxAV* av = toxav_new(tox, &error); + + ToxAV *av = toxav_new(tox, &error); ck_assert(error == TOXAV_ERR_NEW_OK); - + toxav_callback_call(av, t_toxav_call_cb, CC); toxav_callback_call_state(av, t_toxav_call_state_cb, CC); toxav_callback_video_receive_frame(av, t_toxav_receive_video_frame_cb, CC); toxav_callback_audio_receive_frame(av, t_toxav_receive_audio_frame_cb, CC); - + return av; } -void* call_thread(void* pd) +void *call_thread(void *pd) { - ToxAV* AliceAV = ((thread_data*) pd)->AliceAV; - ToxAV* BobAV = ((thread_data*) pd)->BobAV; - CallControl* AliceCC = ((thread_data*) pd)->AliceCC; - CallControl* BobCC = ((thread_data*) pd)->BobCC; - uint32_t friend_number = ((thread_data*) pd)->friend_number; - - + ToxAV *AliceAV = ((thread_data *) pd)->AliceAV; + ToxAV *BobAV = ((thread_data *) pd)->BobAV; + CallControl *AliceCC = ((thread_data *) pd)->AliceCC; + CallControl *BobCC = ((thread_data *) pd)->BobCC; + uint32_t friend_number = ((thread_data *) pd)->friend_number; + + memset(AliceCC, 0, sizeof(CallControl)); memset(BobCC, 0, sizeof(CallControl)); - + { /* Call */ TOXAV_ERR_CALL rc; toxav_call(AliceAV, friend_number, 48, 3000, &rc); - + if (rc != TOXAV_ERR_CALL_OK) { printf("toxav_call failed: %d\n", rc); ck_assert(0); } } - + while (!BobCC->incoming) c_sleep(10); - + { /* Answer */ TOXAV_ERR_ANSWER rc; toxav_answer(BobAV, 0, 8, 500, &rc); - + if (rc != TOXAV_ERR_ANSWER_OK) { printf("toxav_answer failed: %d\n", rc); ck_assert(0); } } - + c_sleep(30); - + int16_t PCM[960]; - uint8_t video_y[800*600]; - uint8_t video_u[800*600 / 2]; - uint8_t video_v[800*600 / 2]; - + uint8_t video_y[800 * 600]; + uint8_t video_u[800 * 600 / 2]; + uint8_t video_v[800 * 600 / 2]; + memset(PCM, 0, sizeof(PCM)); memset(video_y, 0, sizeof(video_y)); memset(video_u, 0, sizeof(video_u)); memset(video_v, 0, sizeof(video_v)); - + time_t start_time = time(NULL); - while(time(NULL) - start_time < 4) { + + while (time(NULL) - start_time < 4) { toxav_iterate(AliceAV); toxav_iterate(BobAV); - + toxav_audio_send_frame(AliceAV, friend_number, PCM, 960, 1, 48000, NULL); toxav_audio_send_frame(BobAV, 0, PCM, 960, 1, 48000, NULL); - + toxav_video_send_frame(AliceAV, friend_number, 800, 600, video_y, video_u, video_v, NULL); toxav_video_send_frame(BobAV, 0, 800, 600, video_y, video_u, video_v, NULL); - + c_sleep(10); } - + { /* Hangup */ TOXAV_ERR_CALL_CONTROL rc; toxav_call_control(AliceAV, friend_number, TOXAV_CALL_CONTROL_CANCEL, &rc); - + if (rc != TOXAV_ERR_CALL_CONTROL_OK) { printf("toxav_call_control failed: %d %p %p\n", rc, AliceAV, BobAV); } } - + c_sleep(30); - + printf ("Closing thread\n"); pthread_exit(NULL); } @@ -204,111 +206,112 @@ void* call_thread(void* pd) START_TEST(test_AV_three_calls) { - Tox* Alice, *bootstrap, *Bobs[3]; - ToxAV* AliceAV, *BobsAV[3]; - + Tox *Alice, *bootstrap, *Bobs[3]; + ToxAV *AliceAV, *BobsAV[3]; + CallControl AliceCC[3], BobsCC[3]; - + { TOX_ERR_NEW error; - + bootstrap = tox_new(NULL, &error); ck_assert(error == TOX_ERR_NEW_OK); - + Alice = tox_new(NULL, &error); ck_assert(error == TOX_ERR_NEW_OK); - + Bobs[0] = tox_new(NULL, &error); ck_assert(error == TOX_ERR_NEW_OK); - + Bobs[1] = tox_new(NULL, &error); ck_assert(error == TOX_ERR_NEW_OK); - + Bobs[2] = tox_new(NULL, &error); ck_assert(error == TOX_ERR_NEW_OK); } - + printf("Created 5 instances of Tox\n"); printf("Preparing network...\n"); long long unsigned int cur_time = time(NULL); - + uint32_t to_compare = 974536; uint8_t address[TOX_ADDRESS_SIZE]; - + tox_callback_friend_request(Alice, t_accept_friend_request_cb, &to_compare); tox_self_get_address(Alice, address); - - + + ck_assert(tox_friend_add(Bobs[0], address, (uint8_t *)"gentoo", 7, NULL) != (uint32_t) ~0); ck_assert(tox_friend_add(Bobs[1], address, (uint8_t *)"gentoo", 7, NULL) != (uint32_t) ~0); ck_assert(tox_friend_add(Bobs[2], address, (uint8_t *)"gentoo", 7, NULL) != (uint32_t) ~0); - + uint8_t off = 1; - + while (1) { tox_iterate(bootstrap); tox_iterate(Alice); tox_iterate(Bobs[0]); tox_iterate(Bobs[1]); tox_iterate(Bobs[2]); - - if (tox_self_get_connection_status(bootstrap) && - tox_self_get_connection_status(Alice) && - tox_self_get_connection_status(Bobs[0]) && - tox_self_get_connection_status(Bobs[1]) && - tox_self_get_connection_status(Bobs[2]) && off) { + + if (tox_self_get_connection_status(bootstrap) && + tox_self_get_connection_status(Alice) && + tox_self_get_connection_status(Bobs[0]) && + tox_self_get_connection_status(Bobs[1]) && + tox_self_get_connection_status(Bobs[2]) && off) { printf("Toxes are online, took %llu seconds\n", time(NULL) - cur_time); off = 0; } - + if (tox_friend_get_connection_status(Alice, 0, NULL) == TOX_CONNECTION_UDP && - tox_friend_get_connection_status(Alice, 1, NULL) == TOX_CONNECTION_UDP && - tox_friend_get_connection_status(Alice, 2, NULL) == TOX_CONNECTION_UDP && - tox_friend_get_connection_status(Bobs[0], 0, NULL) == TOX_CONNECTION_UDP && - tox_friend_get_connection_status(Bobs[1], 0, NULL) == TOX_CONNECTION_UDP && - tox_friend_get_connection_status(Bobs[2], 0, NULL) == TOX_CONNECTION_UDP) + tox_friend_get_connection_status(Alice, 1, NULL) == TOX_CONNECTION_UDP && + tox_friend_get_connection_status(Alice, 2, NULL) == TOX_CONNECTION_UDP && + tox_friend_get_connection_status(Bobs[0], 0, NULL) == TOX_CONNECTION_UDP && + tox_friend_get_connection_status(Bobs[1], 0, NULL) == TOX_CONNECTION_UDP && + tox_friend_get_connection_status(Bobs[2], 0, NULL) == TOX_CONNECTION_UDP) break; - + c_sleep(20); } - + AliceAV = setup_av_instance(Alice, AliceCC); BobsAV[0] = setup_av_instance(Bobs[0], BobsCC + 0); BobsAV[1] = setup_av_instance(Bobs[1], BobsCC + 1); BobsAV[2] = setup_av_instance(Bobs[2], BobsCC + 2); - + printf("Created 4 instances of ToxAV\n"); printf("All set after %llu seconds!\n", time(NULL) - cur_time); - + thread_data tds[3]; tds[0].AliceAV = AliceAV; tds[0].BobAV = BobsAV[0]; tds[0].AliceCC = AliceCC + 0; tds[0].BobCC = BobsCC + 0; tds[0].friend_number = 0; - + tds[1].AliceAV = AliceAV; tds[1].BobAV = BobsAV[1]; tds[1].AliceCC = AliceCC + 1; tds[1].BobCC = BobsCC + 1; tds[1].friend_number = 1; - + tds[2].AliceAV = AliceAV; tds[2].BobAV = BobsAV[2]; tds[2].AliceCC = AliceCC + 2; tds[2].BobCC = BobsCC + 2; tds[2].friend_number = 2; - + pthread_t tids[3]; (void) pthread_create(tids + 0, NULL, call_thread, tds + 0); (void) pthread_create(tids + 1, NULL, call_thread, tds + 1); (void) pthread_create(tids + 2, NULL, call_thread, tds + 2); - + (void) pthread_detach(tids[0]); (void) pthread_detach(tids[1]); (void) pthread_detach(tids[2]); - + time_t start_time = time(NULL); + while (time(NULL) - start_time < 5) { tox_iterate(Alice); tox_iterate(Bobs[0]); @@ -316,11 +319,11 @@ START_TEST(test_AV_three_calls) tox_iterate(Bobs[2]); c_sleep(20); } - + (void) pthread_join(tids[0], NULL); (void) pthread_join(tids[1], NULL); (void) pthread_join(tids[2], NULL); - + printf ("Killing all instances\n"); toxav_kill(BobsAV[0]); toxav_kill(BobsAV[1]); @@ -331,7 +334,7 @@ START_TEST(test_AV_three_calls) tox_kill(Bobs[2]); tox_kill(Alice); tox_kill(bootstrap); - + printf("\nTest successful!\n"); } END_TEST @@ -342,7 +345,7 @@ int main(int argc, char *argv[]) { (void) argc; (void) argv; - + test_AV_three_calls(); return 0; } @@ -363,7 +366,7 @@ int main(int argc, char *argv[]) { (void) argc; (void) argv; - + Suite *tox = tox_suite(); SRunner *test_runner = srunner_create(tox); -- cgit v1.2.3