Lines Matching refs:ch

188   memset(&uipc.ch, 0, sizeof(uipc.ch));  in uipc_main_init()
199 tUIPC_CHAN* p = &uipc.ch[i]; in uipc_main_init()
226 if (uipc.ch[i].task_evt_flags & UIPC_TASK_FLAG_DISCONNECT_CHAN) { in uipc_check_task_flags_locked()
227 uipc.ch[i].task_evt_flags &= ~UIPC_TASK_FLAG_DISCONNECT_CHAN; in uipc_check_task_flags_locked()
238 if (SAFE_FD_ISSET(uipc.ch[ch_id].srvfd, &uipc.read_set)) { in uipc_check_fd_locked()
242 if (uipc.ch[ch_id].fd != UIPC_DISCONNECTED) { in uipc_check_fd_locked()
243 log::debug("CLOSE CONNECTION (FD {})", uipc.ch[ch_id].fd); in uipc_check_fd_locked()
244 close(uipc.ch[ch_id].fd); in uipc_check_fd_locked()
245 FD_CLR(uipc.ch[ch_id].fd, &uipc.active_set); in uipc_check_fd_locked()
246 uipc.ch[ch_id].fd = UIPC_DISCONNECTED; in uipc_check_fd_locked()
249 uipc.ch[ch_id].fd = accept_server_socket(uipc.ch[ch_id].srvfd); in uipc_check_fd_locked()
251 log::debug("NEW FD {}", uipc.ch[ch_id].fd); in uipc_check_fd_locked()
253 if ((uipc.ch[ch_id].fd >= 0) && uipc.ch[ch_id].cback) { in uipc_check_fd_locked()
256 log::debug("ADD FD {} TO ACTIVE SET", uipc.ch[ch_id].fd); in uipc_check_fd_locked()
257 FD_SET(uipc.ch[ch_id].fd, &uipc.active_set); in uipc_check_fd_locked()
258 uipc.max_fd = MAX(uipc.max_fd, uipc.ch[ch_id].fd); in uipc_check_fd_locked()
261 if (uipc.ch[ch_id].fd < 0) { in uipc_check_fd_locked()
266 if (uipc.ch[ch_id].cback) uipc.ch[ch_id].cback(ch_id, UIPC_OPEN_EVT); in uipc_check_fd_locked()
269 if (SAFE_FD_ISSET(uipc.ch[ch_id].fd, &uipc.read_set)) { in uipc_check_fd_locked()
271 if (uipc.ch[ch_id].cback) in uipc_check_fd_locked()
272 uipc.ch[ch_id].cback(ch_id, UIPC_RX_DATA_READY_EVT); in uipc_check_fd_locked()
313 uipc.ch[ch_id].srvfd = fd; in uipc_setup_server_locked()
314 uipc.ch[ch_id].cback = cback; in uipc_setup_server_locked()
315 uipc.ch[ch_id].read_poll_tmo_ms = DEFAULT_READ_POLL_TMO_MS; in uipc_setup_server_locked()
328 pfd.fd = uipc.ch[ch_id].fd; in uipc_flush_ch_locked()
330 if (uipc.ch[ch_id].fd == UIPC_DISCONNECTED) { in uipc_flush_ch_locked()
381 if (uipc.ch[ch_id].srvfd != UIPC_DISCONNECTED) { in uipc_close_ch_locked()
382 log::debug("CLOSE SERVER (FD {})", uipc.ch[ch_id].srvfd); in uipc_close_ch_locked()
383 close(uipc.ch[ch_id].srvfd); in uipc_close_ch_locked()
384 FD_CLR(uipc.ch[ch_id].srvfd, &uipc.active_set); in uipc_close_ch_locked()
385 uipc.ch[ch_id].srvfd = UIPC_DISCONNECTED; in uipc_close_ch_locked()
389 if (uipc.ch[ch_id].fd != UIPC_DISCONNECTED) { in uipc_close_ch_locked()
390 log::debug("CLOSE CONNECTION (FD {})", uipc.ch[ch_id].fd); in uipc_close_ch_locked()
391 close(uipc.ch[ch_id].fd); in uipc_close_ch_locked()
392 FD_CLR(uipc.ch[ch_id].fd, &uipc.active_set); in uipc_close_ch_locked()
393 uipc.ch[ch_id].fd = UIPC_DISCONNECTED; in uipc_close_ch_locked()
398 if (uipc.ch[ch_id].cback) uipc.ch[ch_id].cback(ch_id, UIPC_CLOSE_EVT); in uipc_close_ch_locked()
407 if (uipc.ch[ch_id].srvfd == UIPC_DISCONNECTED) { in uipc_close_locked()
413 uipc.ch[ch_id].task_evt_flags |= UIPC_TASK_FLAG_DISCONNECT_CHAN; in uipc_close_locked()
538 if (uipc.ch[ch_id].srvfd != UIPC_DISCONNECTED) { in UIPC_Open()
588 OSI_NO_INTR(ret = write(uipc.ch[ch_id].fd, p_buf, msglen)); in UIPC_Send()
615 int fd = uipc.ch[ch_id].fd; in UIPC_Read()
631 OSI_NO_INTR(poll_ret = poll(&pfd, 1, uipc.ch[ch_id].read_poll_tmo_ms)); in UIPC_Read()
633 log::warn("poll timeout ({} ms)", uipc.ch[ch_id].read_poll_tmo_ms); in UIPC_Read()
692 if (uipc.ch[ch_id].fd != UIPC_DISCONNECTED) { in UIPC_Ioctl()
694 FD_CLR(uipc.ch[ch_id].fd, &uipc.active_set); in UIPC_Ioctl()
702 uipc.ch[ch_id].read_poll_tmo_ms = (intptr_t)param; in UIPC_Ioctl()
704 uipc.ch[ch_id].read_poll_tmo_ms); in UIPC_Ioctl()