Lines Matching refs:dsock_idx
826 static void ctrl_data_close(int dsock_idx) { in ctrl_data_close() argument
830 if (epoll_ctl(epollfd, EPOLL_CTL_DEL, data_sock[dsock_idx].sock, &epev) == -1) { in ctrl_data_close()
836 close(data_sock[dsock_idx].sock); in ctrl_data_close()
837 data_sock[dsock_idx].sock = -1; in ctrl_data_close()
840 static int ctrl_data_read(int dsock_idx, char *buf, size_t bufsz) { in ctrl_data_read() argument
843 ret = TEMP_FAILURE_RETRY(read(data_sock[dsock_idx].sock, buf, bufsz)); in ctrl_data_read()
855 static int ctrl_data_write(int dsock_idx, char *buf, size_t bufsz) { in ctrl_data_write() argument
858 ret = TEMP_FAILURE_RETRY(write(data_sock[dsock_idx].sock, buf, bufsz)); in ctrl_data_write()
870 static void ctrl_command_handler(int dsock_idx) { in ctrl_command_handler() argument
878 len = ctrl_data_read(dsock_idx, (char *)packet, CTRL_PACKET_MAX_SIZE); in ctrl_command_handler()
919 if (ctrl_data_write(dsock_idx, (char *)packet, len) != len) in ctrl_command_handler()