1108 	int sock_fd;  member
1111 static int read_prog_test_msg(int sock_fd, struct msg *msg, enum msg_type type)  in read_prog_test_msg()  argument
1113 	if (recv_message(sock_fd, msg) < 0)  in read_prog_test_msg()
1124 static int dispatch_thread_read_log(int sock_fd, char **log_buf, size_t *log_cnt)  in dispatch_thread_read_log()  argument
1136 		if (read_prog_test_msg(sock_fd, &msg, MSG_TEST_LOG)) {  in dispatch_thread_read_log()
1152 static int dispatch_thread_send_subtests(int sock_fd, struct test_state *state)  in dispatch_thread_send_subtests()  argument
1165 		if (read_prog_test_msg(sock_fd, &msg, MSG_SUBTEST_DONE))  in dispatch_thread_send_subtests()
1175 			if (dispatch_thread_read_log(sock_fd,  in dispatch_thread_send_subtests()
1187 	int sock_fd;  in dispatch_thread()  local
1189 	sock_fd = data->sock_fd;  in dispatch_thread()
1222 			if (send_message(sock_fd, &msg_do_test) < 0) {  in dispatch_thread()
1233 			if (read_prog_test_msg(sock_fd, &msg, MSG_TEST_DONE))  in dispatch_thread()
1247 				if (dispatch_thread_read_log(sock_fd,  in dispatch_thread()
1257 			if (dispatch_thread_send_subtests(sock_fd, state))  in dispatch_thread()
1274 		if (send_message(sock_fd, &msg_exit) < 0) {  in dispatch_thread()
1378 		data[i].sock_fd = env.worker_socks[i];  in server_main()