pipe.c File Reference

#include "uv.h"
#include "internal.h"
#include <assert.h>
#include <errno.h>
#include <string.h>
#include <sys/un.h>
#include <unistd.h>
#include <stdlib.h>

Go to the source code of this file.

Functions
int	uv_pipe_init (uv_loop_t *loop, uv_pipe_t *handle, int ipc)
int	uv_pipe_bind (uv_pipe_t *handle, const char *name)
int	uv_pipe_listen (uv_pipe_t *handle, int backlog, uv_connection_cb cb)
void	uv__pipe_close (uv_pipe_t *handle)
int	uv_pipe_open (uv_pipe_t *handle, uv_file fd)
void	uv_pipe_connect (uv_connect_t *req, uv_pipe_t *handle, const char *name, uv_connect_cb cb)
static int	uv__pipe_getsockpeername (const uv_pipe_t *handle, uv__peersockfunc func, char *buffer, size_t *size)
int	uv_pipe_getsockname (const uv_pipe_t *handle, char *buffer, size_t *size)
int	uv_pipe_getpeername (const uv_pipe_t *handle, char *buffer, size_t *size)
void	uv_pipe_pending_instances (uv_pipe_t *handle, int count)
int	uv_pipe_pending_count (uv_pipe_t *handle)
uv_handle_type	uv_pipe_pending_type (uv_pipe_t *handle)
int	uv_pipe_chmod (uv_pipe_t *handle, int mode)

Function Documentation

uv__pipe_close()

void uv__pipe_close

(

uv_pipe_t *

handle

)

Definition at line 120 of file pipe.c.

                                       {
  if (handle->pipe_fname) {
    /*
     * Unlink the file system entity before closing the file descriptor.
     * Doing it the other way around introduces a race where our process
     * unlinks a socket with the same name that's just been created by
     * another thread or process.
     */
    unlink(handle->pipe_fname);
    uv__free((void*)handle->pipe_fname);
    handle->pipe_fname = NULL;
  }
 
  uv__stream_close((uv_stream_t*)handle);
}

References handle, NULL, unlink, uv__free(), and uv__stream_close().

Referenced by uv_close().

uv__pipe_getsockpeername()

static int uv__pipe_getsockpeername ( const uv_pipe_t *  handle, uv__peersockfunc  func, char *  buffer, size_t *  size  )

static

Definition at line 240 of file pipe.c.

                                                  {
  struct sockaddr_un sa;
  socklen_t addrlen;
  int err;
 
  addrlen = sizeof(sa);
  memset(&sa, 0, addrlen);
  err = uv__getsockpeername((const uv_handle_t*) handle,
                            func,
                            (struct sockaddr*) &sa,
                            (int*) &addrlen);
  if (err < 0) {
    *size = 0;
    return err;
  }
 
#if defined(__linux__)
  if (sa.sun_path[0] == 0)
    /* Linux abstract namespace */
    addrlen -= offsetof(struct sockaddr_un, sun_path);
  else
#endif
    addrlen = strlen(sa.sun_path);
 
 
  if ((size_t)addrlen >= *size) {
    *size = addrlen + 1;
    return UV_ENOBUFS;
  }
 
  memcpy(buffer, sa.sun_path, addrlen);
  *size = addrlen;
 
  /* only null-terminate if it's not an abstract socket */
  if (buffer[0] != '\0')
    buffer[addrlen] = '\0';
 
  return 0;
}

References addrlen, err, handle, memcpy(), memset(), offsetof, sockaddr_un::sun_path, and uv__getsockpeername().

Referenced by uv_pipe_getpeername(), and uv_pipe_getsockname().

uv_pipe_bind()

int uv_pipe_bind	(	uv_pipe_t *	handle,
		const char *	name
	)

Definition at line 43 of file pipe.c.

                                                      {
  struct sockaddr_un saddr;
  const char* pipe_fname;
  int sockfd;
  int err;
 
  pipe_fname = NULL;
 
  /* Already bound? */
  if (uv__stream_fd(handle) >= 0)
    return UV_EINVAL;
 
  /* Make a copy of the file name, it outlives this function's scope. */
  pipe_fname = uv__strdup(name);
  if (pipe_fname == NULL)
    return UV_ENOMEM;
 
  /* We've got a copy, don't touch the original any more. */
  name = NULL;
 
  err = uv__socket(AF_UNIX, SOCK_STREAM, 0);
  if (err < 0)
    goto err_socket;
  sockfd = err;
 
  memset(&saddr, 0, sizeof saddr);
  uv__strscpy(saddr.sun_path, pipe_fname, sizeof(saddr.sun_path));
  saddr.sun_family = AF_UNIX;
 
  if (bind(sockfd, (struct sockaddr*)&saddr, sizeof saddr)) {
    err = UV__ERR(errno);
    /* Convert ENOENT to EACCES for compatibility with Windows. */
    if (err == UV_ENOENT)
      err = UV_EACCES;
 
    uv__close(sockfd);
    goto err_socket;
  }
 
  /* Success. */
  handle->flags |= UV_HANDLE_BOUND;
  handle->pipe_fname = pipe_fname; /* Is a strdup'ed copy. */
  handle->io_watcher.fd = sockfd;
  return 0;
 
err_socket:
  uv__free((void*)pipe_fname);
  return err;
}

uv_pipe_chmod()

int uv_pipe_chmod	(	uv_pipe_t *	handle,
		int	mode
	)

Definition at line 326 of file pipe.c.

                                               {
  unsigned desired_mode;
  struct stat pipe_stat;
  char* name_buffer;
  size_t name_len;
  int r;
 
  if (handle == NULL || uv__stream_fd(handle) == -1)
    return UV_EBADF;
 
  if (mode != UV_READABLE &&
      mode != UV_WRITABLE &&
      mode != (UV_WRITABLE | UV_READABLE))
    return UV_EINVAL;
 
  /* Unfortunately fchmod does not work on all platforms, we will use chmod. */
  name_len = 0;
  r = uv_pipe_getsockname(handle, NULL, &name_len);
  if (r != UV_ENOBUFS)
    return r;
 
  name_buffer = uv__malloc(name_len);
  if (name_buffer == NULL)
    return UV_ENOMEM;
 
  r = uv_pipe_getsockname(handle, name_buffer, &name_len);
  if (r != 0) {
    uv__free(name_buffer);
    return r;
  }
 
  /* stat must be used as fstat has a bug on Darwin */
  if (stat(name_buffer, &pipe_stat) == -1) {
    uv__free(name_buffer);
    return -errno;
  }
 
  desired_mode = 0;
  if (mode & UV_READABLE)
    desired_mode |= S_IRUSR | S_IRGRP | S_IROTH;
  if (mode & UV_WRITABLE)
    desired_mode |= S_IWUSR | S_IWGRP | S_IWOTH;
 
  /* Exit early if pipe already has desired mode. */
  if ((pipe_stat.st_mode & desired_mode) == desired_mode) {
    uv__free(name_buffer);
    return 0;
  }
 
  pipe_stat.st_mode |= desired_mode;
 
  r = chmod(name_buffer, pipe_stat.st_mode);
  uv__free(name_buffer);
 
  return r != -1 ? 0 : UV__ERR(errno);
}

uv_pipe_connect()

void uv_pipe_connect	(	uv_connect_t *	req,
		uv_pipe_t *	handle,
		const char *	name,
		uv_connect_cb	cb
	)

Definition at line 173 of file pipe.c.

                                      {
  struct sockaddr_un saddr;
  int new_sock;
  int err;
  int r;
 
  new_sock = (uv__stream_fd(handle) == -1);
 
  if (new_sock) {
    err = uv__socket(AF_UNIX, SOCK_STREAM, 0);
    if (err < 0)
      goto out;
    handle->io_watcher.fd = err;
  }
 
  memset(&saddr, 0, sizeof saddr);
  uv__strscpy(saddr.sun_path, name, sizeof(saddr.sun_path));
  saddr.sun_family = AF_UNIX;
 
  do {
    r = connect(uv__stream_fd(handle),
                (struct sockaddr*)&saddr, sizeof saddr);
  }
  while (r == -1 && errno == EINTR);
 
  if (r == -1 && errno != EINPROGRESS) {
    err = UV__ERR(errno);
#if defined(__CYGWIN__) || defined(__MSYS__)
    /* EBADF is supposed to mean that the socket fd is bad, but
       Cygwin reports EBADF instead of ENOTSOCK when the file is
       not a socket.  We do not expect to see a bad fd here
       (e.g. due to new_sock), so translate the error.  */
    if (err == UV_EBADF)
      err = UV_ENOTSOCK;
#endif
    goto out;
  }
 
  err = 0;
  if (new_sock) {
    err = uv__stream_open((uv_stream_t*)handle,
                          uv__stream_fd(handle),
                          UV_HANDLE_READABLE | UV_HANDLE_WRITABLE);
  }
 
  if (err == 0)
    uv__io_start(handle->loop, &handle->io_watcher, POLLOUT);
 
out:
  handle->delayed_error = err;
  handle->connect_req = req;
 
  uv__req_init(handle->loop, req, UV_CONNECT);
  req->handle = (uv_stream_t*)handle;
  req->cb = cb;
  QUEUE_INIT(&req->queue);
 
  /* Force callback to run on next tick in case of error. */
  if (err)
    uv__io_feed(handle->loop, &handle->io_watcher);
 
}

uv_pipe_getpeername()

int uv_pipe_getpeername	(	const uv_pipe_t *	handle,
		char *	buffer,
		size_t *	size
	)

Definition at line 289 of file pipe.c.

                                                                             {
  return uv__pipe_getsockpeername(handle, getpeername, buffer, size);
}

uv_pipe_getsockname()

int uv_pipe_getsockname	(	const uv_pipe_t *	handle,
		char *	buffer,
		size_t *	size
	)

Definition at line 284 of file pipe.c.

                                                                             {
  return uv__pipe_getsockpeername(handle, getsockname, buffer, size);
}

Referenced by uv_pipe_chmod().

uv_pipe_init()

int uv_pipe_init	(	uv_loop_t *	loop,
		uv_pipe_t *	handle,
		int	ipc
	)

Definition at line 33 of file pipe.c.

                                                              {
  uv__stream_init(loop, (uv_stream_t*)handle, UV_NAMED_PIPE);
  handle->shutdown_req = NULL;
  handle->connect_req = NULL;
  handle->pipe_fname = NULL;
  handle->ipc = ipc;
  return 0;
}

uv_pipe_listen()

int uv_pipe_listen	(	uv_pipe_t *	handle,
		int	backlog,
		uv_connection_cb	cb
	)

Definition at line 94 of file pipe.c.

                                                                        {
  if (uv__stream_fd(handle) == -1)
    return UV_EINVAL;
 
  if (handle->ipc)
    return UV_EINVAL;
 
#if defined(__MVS__) || defined(__PASE__)
  /* On zOS, backlog=0 has undefined behaviour */
  /* On IBMi PASE, backlog=0 leads to "Connection refused" error */
  if (backlog == 0)
    backlog = 1;
  else if (backlog < 0)
    backlog = SOMAXCONN;
#endif
 
  if (listen(uv__stream_fd(handle), backlog))
    return UV__ERR(errno);
 
  handle->connection_cb = cb;
  handle->io_watcher.cb = uv__server_io;
  uv__io_start(handle->loop, &handle->io_watcher, POLLIN);
  return 0;
}

uv_pipe_open()

int uv_pipe_open	(	uv_pipe_t *	handle,
		uv_file	fd
	)

Definition at line 137 of file pipe.c.

                                                {
  int flags;
  int mode;
  int err;
  flags = 0;
 
  if (uv__fd_exists(handle->loop, fd))
    return UV_EEXIST;
 
  do
    mode = fcntl(fd, F_GETFL);
  while (mode == -1 && errno == EINTR);
 
  if (mode == -1)
    return UV__ERR(errno); /* according to docs, must be EBADF */
 
  err = uv__nonblock(fd, 1);
  if (err)
    return err;
 
#if defined(__APPLE__)
  err = uv__stream_try_select((uv_stream_t*) handle, &fd);
  if (err)
    return err;
#endif /* defined(__APPLE__) */
 
  mode &= O_ACCMODE;
  if (mode != O_WRONLY)
    flags |= UV_HANDLE_READABLE;
  if (mode != O_RDONLY)
    flags |= UV_HANDLE_WRITABLE;
 
  return uv__stream_open((uv_stream_t*)handle, fd, flags);
}

uv_pipe_pending_count()

int uv_pipe_pending_count

(

uv_pipe_t *

handle

)

Definition at line 298 of file pipe.c.

                                             {
  uv__stream_queued_fds_t* queued_fds;
 
  if (!handle->ipc)
    return 0;
 
  if (handle->accepted_fd == -1)
    return 0;
 
  if (handle->queued_fds == NULL)
    return 1;
 
  queued_fds = handle->queued_fds;
  return queued_fds->offset + 1;
}

uv_pipe_pending_instances()

void uv_pipe_pending_instances	(	uv_pipe_t *	handle,
		int	count
	)

Definition at line 294 of file pipe.c.

                                                             {
}

uv_pipe_pending_type()

uv_handle_type uv_pipe_pending_type

(

uv_pipe_t *

handle

)

Definition at line 315 of file pipe.c.

                                                       {
  if (!handle->ipc)
    return UV_UNKNOWN_HANDLE;
 
  if (handle->accepted_fd == -1)
    return UV_UNKNOWN_HANDLE;
  else
    return uv__handle_type(handle->accepted_fd);
}