26 #include <errno.h>
35   handle->shutdown_req = NULL;  in uv_pipe_init()
36   handle->connect_req = NULL;  in uv_pipe_init()
37   handle->pipe_fname = NULL;  in uv_pipe_init()
38   handle->ipc = ipc;  in uv_pipe_init()
73     err = UV__ERR(errno);  in uv_pipe_bind()
83   handle->flags |= UV_HANDLE_BOUND;  in uv_pipe_bind()
84   handle->pipe_fname = pipe_fname; /* Is a strdup'ed copy. */  in uv_pipe_bind()
85   handle->io_watcher.fd = sockfd;  in uv_pipe_bind()
95   if (uv__stream_fd(handle) == -1)  in uv__pipe_listen()
98   if (handle->ipc)  in uv__pipe_listen()
111     return UV__ERR(errno);  in uv__pipe_listen()
113   handle->connection_cb = cb;  in uv__pipe_listen()
114   handle->io_watcher.cb = uv__server_io;  in uv__pipe_listen()
115   uv__io_start(handle->loop, &handle->io_watcher, POLLIN);  in uv__pipe_listen()
121   if (handle->pipe_fname) {  in uv__pipe_close()
128     unlink(handle->pipe_fname);  in uv__pipe_close()
129     uv__free((void*)handle->pipe_fname);  in uv__pipe_close()
130     handle->pipe_fname = NULL;  in uv__pipe_close()
143   if (uv__fd_exists(handle->loop, fd))  in uv_pipe_open()
148   while (mode == -1 && errno == EINTR);  in uv_pipe_open()
150   if (mode == -1)  in uv_pipe_open()
151     return UV__ERR(errno); /* according to docs, must be EBADF */  in uv_pipe_open()
182   new_sock = (uv__stream_fd(handle) == -1);  in uv_pipe_connect()
188     handle->io_watcher.fd = err;  in uv_pipe_connect()
199   while (r == -1 && errno == EINTR);  in uv_pipe_connect()
201   if (r == -1 && errno != EINPROGRESS) {  in uv_pipe_connect()
202     err = UV__ERR(errno);  in uv_pipe_connect()
207        (e.g. due to new_sock), so translate the error.  */  in uv_pipe_connect()
222     uv__io_start(handle->loop, &handle->io_watcher, POLLOUT);  in uv_pipe_connect()
225   handle->delayed_error = err;  in uv_pipe_connect()
226   handle->connect_req = req;  in uv_pipe_connect()
228   uv__req_init(handle->loop, req, UV_CONNECT);  in uv_pipe_connect()
229   req->handle = (uv_stream_t*)handle;  in uv_pipe_connect()
230   req->cb = cb;  in uv_pipe_connect()
231   QUEUE_INIT(&req->queue);  in uv_pipe_connect()
235     uv__io_feed(handle->loop, &handle->io_watcher);  in uv_pipe_connect()
262     addrlen -= offsetof(struct sockaddr_un, sun_path);  in uv__pipe_getsockpeername()
276   /* only null-terminate if it's not an abstract socket */  in uv__pipe_getsockpeername()
301   if (!handle->ipc)  in uv_pipe_pending_count()
304   if (handle->accepted_fd == -1)  in uv_pipe_pending_count()
307   if (handle->queued_fds == NULL)  in uv_pipe_pending_count()
310   queued_fds = handle->queued_fds;  in uv_pipe_pending_count()
311   return queued_fds->offset + 1;  in uv_pipe_pending_count()
316   if (!handle->ipc)  in uv_pipe_pending_type()
319   if (handle->accepted_fd == -1)  in uv_pipe_pending_type()
322     return uv__handle_type(handle->accepted_fd);  in uv_pipe_pending_type()
333   if (handle == NULL || uv__stream_fd(handle) == -1)  in uv_pipe_chmod()
358   if (stat(name_buffer, &pipe_stat) == -1) {  in uv_pipe_chmod()
360     return -errno;  in uv_pipe_chmod()
380   return r != -1 ? 0 : UV__ERR(errno);  in uv_pipe_chmod()
394     return UV__ERR(errno);  in uv_pipe()
403     return UV__ERR(errno);  in uv_pipe()