1088 	int sock_fd;  member
1091 static int read_prog_test_msg(int sock_fd, struct msg *msg, enum msg_type type)  in read_prog_test_msg()  argument
1093 	if (recv_message(sock_fd, msg) < 0)  in read_prog_test_msg()
1104 static int dispatch_thread_read_log(int sock_fd, char **log_buf, size_t *log_cnt)  in dispatch_thread_read_log()  argument
1116 		if (read_prog_test_msg(sock_fd, &msg, MSG_TEST_LOG)) {  in dispatch_thread_read_log()
1132 static int dispatch_thread_send_subtests(int sock_fd, struct test_state *state)  in dispatch_thread_send_subtests()  argument
1145 		if (read_prog_test_msg(sock_fd, &msg, MSG_SUBTEST_DONE))  in dispatch_thread_send_subtests()
1155 			if (dispatch_thread_read_log(sock_fd,  in dispatch_thread_send_subtests()
1167 	int sock_fd;  in dispatch_thread()  local
1169 	sock_fd = data->sock_fd;  in dispatch_thread()
1202 			if (send_message(sock_fd, &msg_do_test) < 0) {  in dispatch_thread()
1213 			if (read_prog_test_msg(sock_fd, &msg, MSG_TEST_DONE))  in dispatch_thread()
1227 				if (dispatch_thread_read_log(sock_fd,  in dispatch_thread()
1237 			if (dispatch_thread_send_subtests(sock_fd, state))  in dispatch_thread()
1254 		if (send_message(sock_fd, &msg_exit) < 0) {  in dispatch_thread()
1332 		data[i].sock_fd = env.worker_socks[i];  in server_main()