Lines Matching refs:fd
55 int fd; member
151 int fd; in uv__stream_osx_select() local
157 fd = s->fd; in uv__stream_osx_select()
159 if (fd > s->int_fd) in uv__stream_osx_select()
160 max_fd = fd; in uv__stream_osx_select()
174 FD_SET(fd, s->sread); in uv__stream_osx_select()
176 FD_SET(fd, s->swrite); in uv__stream_osx_select()
215 if (FD_ISSET(fd, s->sread)) in uv__stream_osx_select()
217 if (FD_ISSET(fd, s->swrite)) in uv__stream_osx_select()
274 int uv__stream_try_select(uv_stream_t* stream, int* fd) { in uv__stream_try_select() argument
299 EV_SET(&filter[0], *fd, EVFILT_READ, EV_ADD | EV_ENABLE, 0, 0, 0); in uv__stream_try_select()
326 max_fd = *fd; in uv__stream_try_select()
340 s->fd = *fd; in uv__stream_try_select()
364 old_fd = *fd; in uv__stream_try_select()
367 *fd = s->fake_fd; in uv__stream_try_select()
378 *fd = old_fd; in uv__stream_try_select()
403 int uv__stream_open(uv_stream_t* stream, int fd, int flags) { in uv__stream_open() argument
408 if (!(stream->io_watcher.fd == -1 || stream->io_watcher.fd == fd)) in uv__stream_open()
411 assert(fd >= 0); in uv__stream_open()
415 if ((stream->flags & UV_HANDLE_TCP_NODELAY) && uv__tcp_nodelay(fd, 1)) in uv__stream_open()
420 uv__tcp_keepalive(fd, 1, 60)) { in uv__stream_open()
427 if (setsockopt(fd, SOL_SOCKET, SO_OOBINLINE, &enable, sizeof(enable)) && in uv__stream_open()
434 stream->io_watcher.fd = fd; in uv__stream_open()
511 int fd; in uv__server_io() local
518 fd = uv__stream_fd(stream); in uv__server_io()
519 err = uv__accept(fd); in uv__server_io()
522 err = uv__emfile_trick(loop, fd); /* Shed load. */ in uv__server_io()
662 static ssize_t uv__writev(int fd, struct iovec* vec, size_t n) { in uv__writev() argument
664 return write(fd, vec->iov_base, vec->iov_len); in uv__writev()
666 return writev(fd, vec, n); in uv__writev()
743 return ((uv_stream_t*) handle)->io_watcher.fd; in uv__handle_fd()
746 return ((uv_udp_t*) handle)->io_watcher.fd; in uv__handle_fd()
941 static int uv__stream_queue_fd(uv_stream_t* stream, int fd) { in uv__stream_queue_fd() argument
974 queued_fds->fds[queued_fds->offset++] = fd; in uv__stream_queue_fd()
984 int fd; in uv__stream_recv_cmsg() local
998 assert(count % sizeof(fd) == 0); in uv__stream_recv_cmsg()
999 count /= sizeof(fd); in uv__stream_recv_cmsg()
1002 pe = p + count * sizeof(fd); in uv__stream_recv_cmsg()
1005 memcpy(&fd, p, sizeof(fd)); in uv__stream_recv_cmsg()
1006 p += sizeof(fd); in uv__stream_recv_cmsg()
1010 stream->accepted_fd = fd; in uv__stream_recv_cmsg()
1012 err = uv__stream_queue_fd(stream, fd); in uv__stream_recv_cmsg()
1016 uv__close(fd); in uv__stream_recv_cmsg()
1499 return s->fd; in uv___stream_fd()
1501 return handle->io_watcher.fd; in uv___stream_fd()
1536 if (handle->io_watcher.fd != -1) { in uv__stream_close()
1538 if (handle->io_watcher.fd > STDERR_FILENO) in uv__stream_close()
1539 uv__close(handle->io_watcher.fd); in uv__stream_close()
1540 handle->io_watcher.fd = -1; in uv__stream_close()
