59 # define fd_read(fd, buf, len) read(fd, buf, len)  argument
81 fd_read(sock_T fd, char *buf, size_t len)  in fd_read()  argument
83     HANDLE h = (HANDLE)fd;  in fd_read()
92 fd_write(sock_T fd, char *buf, size_t len)  in fd_write()  argument
95     HANDLE	h = (HANDLE)fd;  in fd_write()
130 fd_close(sock_T fd)  in fd_close()  argument
132     HANDLE h = (HANDLE)fd;  in fd_close()
522 channel_fd2channel(sock_T fd, ch_part_T *partp)  in channel_fd2channel()  argument
527     if (fd != INVALID_FD)  in channel_fd2channel()
531 		if (channel->ch_part[part].ch_fd == fd)  in channel_fd2channel()
541 channel_read_fd(int fd)  in channel_read_fd()  argument
546     channel = channel_fd2channel(fd, &part);  in channel_read_fd()
548 	ch_error(NULL, "Channel for fd %d not found", fd);  in channel_read_fd()
1386     sock_T *fd = &channel->ch_part[part].ch_fd;  in ch_close_part()  local
1388     if (*fd != INVALID_FD)  in ch_close_part()
1391 	    sock_close(*fd);  in ch_close_part()
1396 	    if ((part == PART_IN || channel->CH_IN_FD != *fd)  in ch_close_part()
1397 		    && (part == PART_OUT || channel->CH_OUT_FD != *fd)  in ch_close_part()
1398 		    && (part == PART_ERR || channel->CH_ERR_FD != *fd))  in ch_close_part()
1402 		    DisconnectNamedPipe((HANDLE)fd);  in ch_close_part()
1404 		fd_close(*fd);  in ch_close_part()
1407 	*fd = INVALID_FD;  in ch_close_part()
1601 	fds.fd = in_part->ch_fd;  in can_write_buf_line()
3357 	    fds[nfd].fd = in_part->ch_fd;  in channel_fill_poll_write()
3381 channel_wait(channel_T *channel, sock_T fd, int timeout)  in channel_wait()  argument
3387     if (fd != channel->CH_SOCK_FD)  in channel_wait()
3397 	    int r = PeekNamedPipe((HANDLE)fd, NULL, 0, NULL, &nread, NULL);  in channel_wait()
3404 		DisconnectNamedPipe((HANDLE)fd);  in channel_wait()
3405 		ConnectNamedPipe((HANDLE)fd, NULL);  in channel_wait()
3441 	    FD_SET((int)fd, &rfds);  in channel_wait()
3445 	    maxfd = (int)fd + 1;  in channel_wait()
3457 		if (FD_ISSET(fd, &rfds))  in channel_wait()
3470 	    fds[0].fd = fd;  in channel_wait()
3552     sock_T		fd;  in channel_read()  local
3555     fd = channel->ch_part[part].ch_fd;  in channel_read()
3556     if (fd == INVALID_FD)  in channel_read()
3562     use_socket = fd == channel->CH_SOCK_FD;  in channel_read()
3577 	if (channel_wait(channel, fd, 0) != CW_READY)  in channel_read()
3580 	    len = sock_read(fd, (char *)buf, MAXMSGSIZE);  in channel_read()
3582 	    len = fd_read(fd, (char *)buf, MAXMSGSIZE);  in channel_read()
3621     sock_T	fd = channel->ch_part[part].ch_fd;  in channel_read_block()  local
3641 	    if (raw || fd == INVALID_FD)  in channel_read_block()
3646 	if (fd == INVALID_FD)  in channel_read_block()
3648 	if (channel_wait(channel, fd, timeout) != CW_READY)  in channel_read_block()
3725     sock_T	fd;  in channel_read_json_block()  local
3784 	    fd = chanpart->ch_fd;  in channel_read_json_block()
3785 	    if (fd == INVALID_FD  in channel_read_json_block()
3786 			    || channel_wait(channel, fd, timeout) != CW_READY)  in channel_read_json_block()
3790 		    if (fd != INVALID_FD)  in channel_read_json_block()
3945     sock_T	fd;  in channel_handle_events()  local
3955 	    fd = channel->ch_part[part].ch_fd;  in channel_handle_events()
3956 	    if (fd != INVALID_FD)  in channel_handle_events()
3958 		int r = channel_wait(channel, fd, 0);  in channel_handle_events()
4009     int		fd = ch_part->ch_fd;  in channel_set_nonblock()  local
4011     if (fd != INVALID_FD)  in channel_set_nonblock()
4016 	ioctlsocket(fd, FIONBIO, &val);  in channel_set_nonblock()
4018 	(void)fcntl(fd, F_SETFL, O_NONBLOCK);  in channel_set_nonblock()
4038     sock_T	fd;  in channel_send()  local
4042     fd = ch_part->ch_fd;  in channel_send()
4043     if (fd == INVALID_FD)  in channel_send()
4090 	    res = sock_write(fd, (char *)buf, len);  in channel_send()
4093 	    res = fd_write(fd, (char *)buf, len);  in channel_send()
4097 		DisconnectNamedPipe((HANDLE)fd);  in channel_send()
4098 		ConnectNamedPipe((HANDLE)fd, NULL);  in channel_send()
4404 		    fds[nfd].fd = ch_part->ch_fd;  in channel_poll_setup()
4487 	    sock_T fd = channel->ch_part[part].ch_fd;  in channel_select_setup()  local
4489 	    if (fd != INVALID_FD)  in channel_select_setup()
4506 		    FD_SET((int)fd, rfds);  in channel_select_setup()
4507 		    if (maxfd < (int)fd)  in channel_select_setup()
4508 			maxfd = (int)fd;  in channel_select_setup()
4536 	    sock_T fd = channel->ch_part[part].ch_fd;  in channel_select_check()  local
4538 	    if (ret > 0 && fd != INVALID_FD && FD_ISSET(fd, rfds))  in channel_select_check()
4541 		FD_CLR(fd, rfds);  in channel_select_check()
4544 	    else if (fd != INVALID_FD && channel->ch_keep_open)  in channel_select_check()