};
int black_box_group0_setup(void **state) {
+ (void)state;
+
const char *nodes[] = { "peer", "relay", "nut"};
int num_nodes = sizeof(nodes) / sizeof(nodes[0]);
}
int black_box_group0_teardown(void **state) {
+ (void)state;
+
PRINT_TEST_CASE_MSG("Destroying Containers\n");
destroy_containers();
}
int black_box_all_nodes_setup(void **state) {
+ (void)state;
+
const char *nodes[] = { "peer" };
int num_nodes = sizeof(nodes) / sizeof(nodes[0]);
static bool meta_conn01_closed;
static bool meta_conn01_reconn;
-static void meta_conn01_cb(mesh_event_payload_t payload) {
+static bool meta_conn01_cb(mesh_event_payload_t payload) {
char event_node_name[][10] = {"RELAY", "PEER", "NUT"};
fprintf(stderr, "%s : ", event_node_name[payload.client_id]);
case META_RECONN_SUCCESSFUL :
meta_conn01_reconn = true;
break;
+
+ default:
+ break;
}
+
+ return true;
}
/* Execute Meta-connections Test Case # 1 - re-connection to peer after disconnection when
*/
static bool test_steps_meta_conn_01(void) {
char *invite_peer, *invite_nut;
- bool result = false;
- int i;
char *import;
import = mesh_event_sock_create(eth_if_name);
PRINT_TEST_CASE_MSG("Waiting for peer to be re-connected\n");
wait_for_event(meta_conn01_cb, 60);
- assert_int_equal(meta_conn01_reconn, true);
-
+ mesh_event_destroy();
free(invite_peer);
free(invite_nut);
+ assert_int_equal(meta_conn01_reconn, true);
+
return true;
}
static bool meta_conn02_conn;
-static void meta_conn02_cb(mesh_event_payload_t payload) {
+static bool meta_conn02_cb(mesh_event_payload_t payload) {
char event_node_name[][10] = {"RELAY", "PEER", "NUT"};
fprintf(stderr, "%s : ", event_node_name[payload.client_id]);
case NODE_STARTED :
fprintf(stderr, "Node started\n");
break;
- }
- if(payload.payload_length) {
- fprintf(stderr, " %s\n", (char *)payload.payload);
+ default:
+ break;
}
+
+ return true;
}
/* Execute Meta-connections Test Case # 2 - re-connection to peer via third node
after changing IP of NUT and peer */
*/
static bool test_steps_meta_conn_02(void) {
char *invite_peer, *invite_nut;
- bool result = false;
- int i;
char *import;
import = mesh_event_sock_create(eth_if_name);
wait_for_event(meta_conn02_cb, 5);
PRINT_TEST_CASE_MSG("Waiting for peer to be connected with NUT\n");
+ wait_for_event(meta_conn02_cb, 60);
- if(!wait_for_event(meta_conn02_cb, 60)) {
- return false;
- }
-
- result = meta_conn02_conn;
-
+ mesh_event_destroy();
free(invite_peer);
free(invite_nut);
- return result;
+ assert_int_equal(meta_conn02_conn, true);
+
+ return true;
}
static bool meta_conn03_result;
static bool meta_conn03_conn;
-static void meta_conn03_cb(mesh_event_payload_t payload) {
+static bool meta_conn03_cb(mesh_event_payload_t payload) {
char event_node_name[][10] = {"RELAY", "PEER", "NUT"};
fprintf(stderr, "%s : ", event_node_name[payload.client_id]);
fprintf(stderr, "Reconnected\n");
meta_conn03_result = true;
break;
+
+ default:
+ break;
}
+
+ return true;
}
/* Execute Meta-connections Test Case # 3 - re-connection to peer via third node
after changing IP of peer */
*/
static bool test_steps_meta_conn_03(void) {
char *invite_peer, *invite_nut;
- bool result = false;
- int i;
char *import;
import = mesh_event_sock_create(eth_if_name);
PRINT_TEST_CASE_MSG("Changing IP address of PEER container\n");
change_ip(1);
+ sleep(3);
node_sim_in_container_event("peer", "1", NULL, PEER_ID, import);
wait_for_event(meta_conn03_cb, 5);
PRINT_TEST_CASE_MSG("Waiting for peer to be re-connected\n");
wait_for_event(meta_conn03_cb, 5);
- result = meta_conn03_result;
+
+ mesh_event_destroy();
free(invite_peer);
free(invite_nut);
- return result;
+ assert_int_equal(meta_conn03_result, true);
+
+ return true;
}
static char *invite_peer = NULL;
static bool meta_conn04 = false;
-static void meta_conn04_cb(mesh_event_payload_t payload) {
+static bool meta_conn04_cb(mesh_event_payload_t payload) {
char event_node_name[][10] = {"PEER", "NUT"};
fprintf(stderr, "%s : ", event_node_name[payload.client_id]);
case NODE_STARTED :
fprintf(stderr, "Node started\n");
break;
+
+ default :
+ fprintf(stderr, "Undefined mesh event\n");
+ break;
}
+
+ return true;
}
/* Execute Meta-connections Test Case # 4 - re-connection to peer after changing IP of
NUT is first disconnected from peer then automatically re-connected to peer
*/
static bool test_steps_meta_conn_04(void) {
- bool result = false;
char *import;
import = mesh_event_sock_create(eth_if_name);
PRINT_TEST_CASE_MSG("Waiting for NUT to generate invitation to PEER\n");
wait_for_event(meta_conn04_cb, 5);
- if(!invite_peer) {
- return false;
- }
+ assert(invite_peer);
PRINT_TEST_CASE_MSG("Running PEER node in the container\n");
+ fprintf(stderr, "inv: %s\n", invite_peer);
node_sim_in_container_event("peer", "1", invite_peer, "0", import);
wait_for_event(meta_conn04_cb, 5);
PRINT_TEST_CASE_MSG("Waiting for peer to be connected with NUT\n");
- if(!wait_for_event(meta_conn04_cb, 60)) {
- return false;
- }
+ assert(wait_for_event(meta_conn04_cb, 60));
PRINT_TEST_CASE_MSG("Changing IP address of NUT container\n");
change_ip(1);
PRINT_TEST_CASE_MSG("Waiting for peer to be re-connected\n");
wait_for_event(meta_conn04_cb, 5);
- result = meta_conn04;
+ mesh_event_destroy();
free(invite_peer);
free(import);
- return result;
+
+ assert_int_equal(meta_conn04, true);
+
+ return true;
}
static char *invitation = NULL;
static bool meta_conn05 = false;
-static void meta_conn05_cb(mesh_event_payload_t payload) {
+static bool meta_conn05_cb(mesh_event_payload_t payload) {
char event_node_name[][10] = {"PEER", "NUT"};
fprintf(stderr, "%s : ", event_node_name[payload.client_id]);
case NODE_STARTED :
fprintf(stderr, "Node started\n");
break;
+
+ default:
+ break;
}
+
+ return true;
}
/* Execute Meta-connections Test Case # 5 - re-connection to peer after changing IP of peer */
NUT is first disconnected from peer then automatically re-connected to peer
*/
static bool test_steps_meta_conn_05(void) {
- bool result = false;
char *import;
import = mesh_event_sock_create(eth_if_name);
wait_for_event(meta_conn05_cb, 5);
- if(!invitation) {
- return false;
- }
+ assert(invitation);
node_sim_in_container_event("peer", "1", invitation, "0", import);
wait_for_event(meta_conn05_cb, 5);
- if(!wait_for_event(meta_conn05_cb, 5)) {
- return false;
- }
+ assert(wait_for_event(meta_conn05_cb, 5));
change_ip(0);
meta_conn05 = false;
wait_for_event(meta_conn05_cb, 5);
PRINT_TEST_CASE_MSG("Waiting for peer to be re-connected\n");
wait_for_event(meta_conn05_cb, 5);
- result = meta_conn05;
+ mesh_event_destroy();
free(invitation);
free(import);
- return result;
+
+ assert_int_equal(meta_conn05, true);
+
+ return true;
}
int test_meta_conn(void) {