Lines Matching refs:sock_fd
1419 int sock_fd; member
1422 static int read_prog_test_msg(int sock_fd, struct msg *msg, enum msg_type type) in read_prog_test_msg() argument
1424 if (recv_message(sock_fd, msg) < 0) in read_prog_test_msg()
1435 static int dispatch_thread_read_log(int sock_fd, char **log_buf, size_t *log_cnt) in dispatch_thread_read_log() argument
1447 if (read_prog_test_msg(sock_fd, &msg, MSG_TEST_LOG)) { in dispatch_thread_read_log()
1463 static int dispatch_thread_send_subtests(int sock_fd, struct test_state *state) in dispatch_thread_send_subtests() argument
1476 if (read_prog_test_msg(sock_fd, &msg, MSG_SUBTEST_DONE)) in dispatch_thread_send_subtests()
1486 if (dispatch_thread_read_log(sock_fd, in dispatch_thread_send_subtests()
1498 int sock_fd; in dispatch_thread() local
1500 sock_fd = data->sock_fd; in dispatch_thread()
1533 if (send_message(sock_fd, &msg_do_test) < 0) { in dispatch_thread()
1544 if (read_prog_test_msg(sock_fd, &msg, MSG_TEST_DONE)) in dispatch_thread()
1558 if (dispatch_thread_read_log(sock_fd, in dispatch_thread()
1568 if (dispatch_thread_send_subtests(sock_fd, state)) in dispatch_thread()
1585 if (send_message(sock_fd, &msg_exit) < 0) { in dispatch_thread()
1689 data[i].sock_fd = env.worker_socks[i]; in server_main()