733 static void ctrl_data_close(int dsock_idx) {  in ctrl_data_close()  argument
737     if (epoll_ctl(epollfd, EPOLL_CTL_DEL, data_sock[dsock_idx].sock, &epev) == -1) {  in ctrl_data_close()
743     close(data_sock[dsock_idx].sock);  in ctrl_data_close()
744     data_sock[dsock_idx].sock = -1;  in ctrl_data_close()
747     remove_claims(data_sock[dsock_idx].pid);  in ctrl_data_close()
750 static ssize_t ctrl_data_read(int dsock_idx, char* buf, size_t bufsz, struct ucred* sender_cred) {  in ctrl_data_read()  argument
757     ret = TEMP_FAILURE_RETRY(recvmsg(data_sock[dsock_idx].sock, &hdr, 0));  in ctrl_data_read()
780         ctrl_data_close(dsock_idx);  in ctrl_data_read()
787     data_sock[dsock_idx].pid = cred->pid;  in ctrl_data_read()
792 static int ctrl_data_write(int dsock_idx, char* buf, size_t bufsz) {  in ctrl_data_write()  argument
795     ret = TEMP_FAILURE_RETRY(write(data_sock[dsock_idx].sock, buf, bufsz));  in ctrl_data_write()
1345 static void cmd_subscribe(int dsock_idx, LMKD_CTRL_PACKET packet) {  in cmd_subscribe()  argument
1349     data_sock[dsock_idx].async_event_mask |= 1 << params.evt_type;  in cmd_subscribe()
1679 static void ctrl_command_handler(int dsock_idx) {  in ctrl_command_handler()  argument
1689     len = ctrl_data_read(dsock_idx, (char *)packet, CTRL_PACKET_MAX_SIZE, &cred);  in ctrl_command_handler()
1732         if (ctrl_data_write(dsock_idx, (char *)packet, len) != len)  in ctrl_command_handler()
1738         cmd_subscribe(dsock_idx, packet);  in ctrl_command_handler()
1766         if (ctrl_data_write(dsock_idx, (char *)packet, len) != len) {  in ctrl_command_handler()
1823         if (ctrl_data_write(dsock_idx, (char*)packet, len) != len) {  in ctrl_command_handler()