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;
PRINT_TEST_CASE_MSG("Undefined event occurred\n");
}
- return;
+ return true;
}
/* Execute channel connections Test Case # 1 - simulate a temporary network
// 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;
}
// 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;
}
// 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;
}
// 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;
// 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;
}
// 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;
}
// 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;
}
// 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]);
}
static int black_box_group_teardown(void **state) {
+ (void)state;
+
printf("Destroying Containers\n");
destroy_containers();
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]);