X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=test%2Fblackbox%2Frun_blackbox_tests%2Ftest_cases_channel_conn.c;h=4d497e66da669c8cff4d1dc160ff79da65752923;hb=cdb3dada645394bb1e0d0bf7816291fbd9a2a4a0;hp=4bccf884280c39a8a612e6aa822213758c9d19f3;hpb=de40dd736a1b048e5e0f856184f832fa4db184d3;p=meshlink diff --git a/test/blackbox/run_blackbox_tests/test_cases_channel_conn.c b/test/blackbox/run_blackbox_tests/test_cases_channel_conn.c index 4bccf884..4d497e66 100644 --- a/test/blackbox/run_blackbox_tests/test_cases_channel_conn.c +++ b/test/blackbox/run_blackbox_tests/test_cases_channel_conn.c @@ -105,7 +105,7 @@ static bool node_reachable; static bool node_unreachable; /* Callback function for handling channel connection test cases mesh events */ -static void channel_conn_cb(mesh_event_payload_t payload) { +static bool channel_conn_cb(mesh_event_payload_t payload) { switch(payload.mesh_event) { case NODE_JOINED : joined = true; @@ -139,7 +139,7 @@ static void channel_conn_cb(mesh_event_payload_t payload) { PRINT_TEST_CASE_MSG("Undefined event occurred\n"); } - return; + return true; } /* Execute channel connections Test Case # 1 - simulate a temporary network @@ -205,10 +205,13 @@ static bool test_steps_channel_conn_01(void) { // Wait for peer node to receive data via channel from NUT wait_for_event(channel_conn_cb, 60); - assert_int_equal(channel_received, true); + mesh_event_destroy(); free(invite_nut); free(import); + + assert_int_equal(channel_received, true); + return true; } @@ -275,10 +278,13 @@ static bool test_steps_channel_conn_02(void) { // Wait for peer node to send the event about the channel error occurred with length = 0 wait_for_event(channel_conn_cb, 90); - assert_int_equal(received_error, true); + mesh_event_destroy(); free(invite_nut); free(import); + + assert_int_equal(received_error, true); + return true; } @@ -356,10 +362,13 @@ static bool test_steps_channel_conn_03(void) { // Wait for data to be received at peer via channel from NUT after restoring n/w wait_for_event(channel_conn_cb, 90); - assert_int_equal(channel_received, true); + mesh_event_destroy(); free(invite_nut); free(import); + + assert_int_equal(channel_received, true); + return true; } @@ -414,6 +423,12 @@ static bool test_steps_channel_conn_04(void) { // After 1 min the channel between NUT and peer should result in error wait_for_event(channel_conn_cb, 10); + + + mesh_event_destroy(); + free(invite_nut); + free(import); + assert_int_equal(received_error, true); return true; @@ -485,11 +500,14 @@ static bool test_steps_channel_conn_05(void) { // Wait for peer to get data from NUT node via channel after restoring network in < 60 secs wait_for_event(channel_conn_cb, 60); - assert_int_equal(channel_received, true); - free(invite_nut); + mesh_event_destroy(); free(invite_peer); + free(invite_nut); free(import); + + assert_int_equal(channel_received, true); + return true; } @@ -560,11 +578,14 @@ static bool test_steps_channel_conn_06(void) { // Wait for channel to receive error and receive the event wait_for_event(channel_conn_cb, 90); - assert_int_equal(received_error, true); - free(invite_nut); + mesh_event_destroy(); free(invite_peer); + free(invite_nut); free(import); + + assert_int_equal(received_error, true); + return true; } @@ -646,11 +667,14 @@ static bool test_steps_channel_conn_07(void) { // Wait for peer node to receive data via channel without any error wait_for_event(channel_conn_cb, 90); - assert_int_equal(channel_received, true); - free(invite_nut); + mesh_event_destroy(); free(invite_peer); + free(invite_nut); free(import); + + assert_int_equal(channel_received, true); + return true; } @@ -716,15 +740,20 @@ static bool test_steps_channel_conn_08(void) { // Wait for peer to receive channel error wait_for_event(channel_conn_cb, 10); - assert_int_equal(received_error, true); - free(invite_nut); + mesh_event_destroy(); free(invite_peer); + free(invite_nut); free(import); + + assert_int_equal(received_error, true); + return true; } static int black_box_group_setup(void **state) { + (void)state; + const char *nodes[] = { "peer", "nut", "relay" }; int num_nodes = sizeof(nodes) / sizeof(nodes[0]); @@ -736,6 +765,8 @@ static int black_box_group_setup(void **state) { } static int black_box_group_teardown(void **state) { + (void)state; + printf("Destroying Containers\n"); destroy_containers(); @@ -745,21 +776,21 @@ static int black_box_group_teardown(void **state) { int test_meshlink_channel_conn(void) { const struct CMUnitTest blackbox_group0_tests[] = { cmocka_unit_test_prestate_setup_teardown(test_case_channel_conn_01, setup_test, teardown_test, - (void *)&test_case_channel_conn_01_state), + (void *)&test_case_channel_conn_01_state), cmocka_unit_test_prestate_setup_teardown(test_case_channel_conn_02, setup_test, teardown_test, - (void *)&test_case_channel_conn_02_state), + (void *)&test_case_channel_conn_02_state), cmocka_unit_test_prestate_setup_teardown(test_case_channel_conn_03, setup_test, teardown_test, - (void *)&test_case_channel_conn_03_state), + (void *)&test_case_channel_conn_03_state), cmocka_unit_test_prestate_setup_teardown(test_case_channel_conn_04, setup_test, teardown_test, - (void *)&test_case_channel_conn_04_state), + (void *)&test_case_channel_conn_04_state), cmocka_unit_test_prestate_setup_teardown(test_case_channel_conn_05, setup_test, teardown_test, - (void *)&test_case_channel_conn_05_state), + (void *)&test_case_channel_conn_05_state), cmocka_unit_test_prestate_setup_teardown(test_case_channel_conn_06, setup_test, teardown_test, - (void *)&test_case_channel_conn_06_state), + (void *)&test_case_channel_conn_06_state), cmocka_unit_test_prestate_setup_teardown(test_case_channel_conn_07, setup_test, teardown_test, - (void *)&test_case_channel_conn_07_state), + (void *)&test_case_channel_conn_07_state), cmocka_unit_test_prestate_setup_teardown(test_case_channel_conn_08, setup_test, teardown_test, - (void *)&test_case_channel_conn_08_state) + (void *)&test_case_channel_conn_08_state), }; total_tests += sizeof(blackbox_group0_tests) / sizeof(blackbox_group0_tests[0]);