Lines Matching defs:msg

1314 static inline const char *str_msg(const struct msg *msg, char *buf)
1316 	switch (msg->type) {
1318 		sprintf(buf, "MSG_DO_TEST %d", msg->do_test.num);
1322 			msg->test_done.num,
1323 			msg->test_done.have_log);
1327 			msg->subtest_done.num,
1328 			msg->subtest_done.have_log);
1332 			strlen(msg->test_log.log_buf),
1333 			msg->test_log.is_last);
1346 static int send_message(int sock, const struct msg *msg)
1351 		fprintf(stderr, "Sending msg: %s\n", str_msg(msg, buf));
1352 	return send(sock, msg, sizeof(*msg), 0);
1355 static int recv_message(int sock, struct msg *msg)
1360 	memset(msg, 0, sizeof(*msg));
1361 	ret = recv(sock, msg, sizeof(*msg), 0);
1364 			fprintf(stderr, "Received msg: %s\n", str_msg(msg, buf));
1424 static int read_prog_test_msg(int sock_fd, struct msg *msg, enum msg_type type)
1426 	if (recv_message(sock_fd, msg) < 0)
1429 	if (msg->type != type) {
1430 		printf("%s: unexpected message type %d. expected %d\n", __func__, msg->type, type);
1447 		struct msg msg;
1449 		if (read_prog_test_msg(sock_fd, &msg, MSG_TEST_LOG)) {
1454 		fprintf(log_fp, "%s", msg.test_log.log_buf);
1455 		if (msg.test_log.is_last)
1467 	struct msg msg;
1478 		if (read_prog_test_msg(sock_fd, &msg, MSG_SUBTEST_DONE))
1481 		subtest_state->name = strdup(msg.subtest_done.name);
1482 		subtest_state->error_cnt = msg.subtest_done.error_cnt;
1483 		subtest_state->skipped = msg.subtest_done.skipped;
1484 		subtest_state->filtered = msg.subtest_done.filtered;
1487 		if (msg.subtest_done.have_log)
1530 			struct msg msg_do_test;
1544 			struct msg msg;
1546 			if (read_prog_test_msg(sock_fd, &msg, MSG_TEST_DONE))
1548 			if (test_to_run != msg.test_done.num)
1553 			state->error_cnt = msg.test_done.error_cnt;
1554 			state->skip_cnt = msg.test_done.skip_cnt;
1555 			state->sub_succ_cnt = msg.test_done.sub_succ_cnt;
1556 			state->subtest_num = msg.test_done.subtest_num;
1559 			if (msg.test_done.have_log) {
1584 		struct msg msg_exit;
1758 		struct msg msg_log;
1791 	struct msg msg;
1794 	memset(&msg, 0, sizeof(msg));
1795 	msg.type = MSG_SUBTEST_DONE;
1800 		msg.subtest_done.num = i;
1802 		strncpy(msg.subtest_done.name, subtest_state->name, MAX_SUBTEST_NAME);
1804 		msg.subtest_done.error_cnt = subtest_state->error_cnt;
1805 		msg.subtest_done.skipped = subtest_state->skipped;
1806 		msg.subtest_done.filtered = subtest_state->filtered;
1807 		msg.subtest_done.have_log = false;
1811 				msg.subtest_done.have_log = true;
1814 		if (send_message(sock, &msg) < 0) {
1821 		if (msg.subtest_done.have_log)
1842 		struct msg msg;
1844 		if (recv_message(sock, &msg) < 0)
1847 		switch (msg.type) {
1854 			int test_to_run = msg.do_test.num;
1857 			struct msg msg;
1867 			memset(&msg, 0, sizeof(msg));
1868 			msg.type = MSG_TEST_DONE;
1869 			msg.test_done.num = test_to_run;
1870 			msg.test_done.error_cnt = state->error_cnt;
1871 			msg.test_done.skip_cnt = state->skip_cnt;
1872 			msg.test_done.sub_succ_cnt = state->sub_succ_cnt;
1873 			msg.test_done.subtest_num = state->subtest_num;
1874 			msg.test_done.have_log = false;
1878 					msg.test_done.have_log = true;
1880 			if (send_message(sock, &msg) < 0) {
1886 			if (msg.test_done.have_log)