#include "uv.h"
#include "internal.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <assert.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/uio.h>
#include <sys/un.h>
#include <unistd.h>
#include <limits.h>

Include dependency graph for unix/stream.c:

Macros
#define	IS_TRANSIENT_WRITE_ERROR(errno, send_handle) (errno == EAGAIN \|\| errno == EWOULDBLOCK \|\| errno == ENOBUFS)

#define	RETRY_ON_WRITE_ERROR(errno) (errno == EINTR)

#define	UV__CMSG_FD_COUNT 64

#define	UV__CMSG_FD_SIZE (UV__CMSG_FD_COUNT * sizeof(int))

#define	UV_DEC_BACKLOG(w) /* no-op */

Functions
static void	uv__drain (uv_stream_t *stream)

static int	uv__emfile_trick (uv_loop_t *loop, int accept_fd)

static int	uv__handle_fd (uv_handle_t *handle)

uv_handle_type	uv__handle_type (int fd)

static void	uv__read (uv_stream_t *stream)

void	uv__server_io (uv_loop_t loop, uv__io_t w, unsigned int events)

void	uv__stream_close (uv_stream_t *handle)

static void	uv__stream_connect (uv_stream_t *)

void	uv__stream_destroy (uv_stream_t *stream)

static void	uv__stream_eof (uv_stream_t stream, const uv_buf_t buf)

void	uv__stream_flush_write_queue (uv_stream_t *stream, int error)

void	uv__stream_init (uv_loop_t loop, uv_stream_t stream, uv_handle_type type)

static void	uv__stream_io (uv_loop_t loop, uv__io_t w, unsigned int events)

int	uv__stream_open (uv_stream_t *stream, int fd, int flags)

static void	uv__stream_osx_interrupt_select (uv_stream_t *stream)

static int	uv__stream_queue_fd (uv_stream_t *stream, int fd)

static int	uv__stream_recv_cmsg (uv_stream_t stream, struct msghdr msg)

static void	uv__write (uv_stream_t *stream)

static void	uv__write_callbacks (uv_stream_t *stream)

static void	uv__write_req_finish (uv_write_t *req)

static size_t	uv__write_req_size (uv_write_t *req)

static int	uv__write_req_update (uv_stream_t stream, uv_write_t req, size_t n)

static ssize_t	uv__writev (int fd, struct iovec *vec, size_t n)

int	uv_accept (uv_stream_t server, uv_stream_t client)

int	uv_is_readable (const uv_stream_t *stream)

int	uv_is_writable (const uv_stream_t *stream)

int	uv_listen (uv_stream_t *stream, int backlog, uv_connection_cb cb)

int	uv_read_start (uv_stream_t *stream, uv_alloc_cb alloc_cb, uv_read_cb read_cb)

int	uv_read_stop (uv_stream_t *stream)

int	uv_shutdown (uv_shutdown_t req, uv_stream_t stream, uv_shutdown_cb cb)

int	uv_stream_set_blocking (uv_stream_t *handle, int blocking)

int	uv_try_write (uv_stream_t *stream, const uv_buf_t bufs[], unsigned int nbufs)

void	uv_try_write_cb (uv_write_t *req, int status)

int	uv_write (uv_write_t req, uv_stream_t handle, const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb)

int	uv_write2 (uv_write_t req, uv_stream_t stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t *send_handle, uv_write_cb cb)

Macro Definition Documentation

◆ IS_TRANSIENT_WRITE_ERROR

#define IS_TRANSIENT_WRITE_ERROR	(	errno,
		send_handle
	)	(errno == EAGAIN \|\| errno == EWOULDBLOCK \|\| errno == ENOBUFS)

Definition at line 73 of file unix/stream.c.

◆ RETRY_ON_WRITE_ERROR

#define RETRY_ON_WRITE_ERROR ( errno ) (errno == EINTR)

Definition at line 72 of file unix/stream.c.

◆ UV__CMSG_FD_COUNT

#define UV__CMSG_FD_COUNT 64

Definition at line 1055 of file unix/stream.c.

◆ UV__CMSG_FD_SIZE

#define UV__CMSG_FD_SIZE (UV__CMSG_FD_COUNT * sizeof(int))

Definition at line 1057 of file unix/stream.c.

◆ UV_DEC_BACKLOG

#define UV_DEC_BACKLOG ( w ) /* no-op */

Definition at line 524 of file unix/stream.c.

Function Documentation

◆ uv__drain()

static void uv__drain ( uv_stream_t * stream )

static

Definition at line 679 of file unix/stream.c.

◆ uv__emfile_trick()

static int uv__emfile_trick	(	uv_loop_t *	loop,
		int	accept_fd
	)

static

Definition at line 497 of file unix/stream.c.

◆ uv__handle_fd()

static int uv__handle_fd ( uv_handle_t * handle )

static

Definition at line 788 of file unix/stream.c.

◆ uv__handle_type()

uv_handle_type uv__handle_type ( int fd )

Definition at line 958 of file unix/stream.c.

◆ uv__read()

static void uv__read ( uv_stream_t * stream )

static

Definition at line 1116 of file unix/stream.c.

◆ uv__server_io()

void uv__server_io	(	uv_loop_t *	loop,
		uv__io_t *	w,
		unsigned int	events
	)

Definition at line 528 of file unix/stream.c.

◆ uv__stream_close()

void uv__stream_close ( uv_stream_t * handle )

Definition at line 1633 of file unix/stream.c.

◆ uv__stream_connect()

static void uv__stream_connect ( uv_stream_t * stream )

static

We get called here from directly following a call to connect(2). In order to determine if we've errored out or succeeded must call getsockopt.

Definition at line 1344 of file unix/stream.c.

◆ uv__stream_destroy()

void uv__stream_destroy ( uv_stream_t * stream )

Definition at line 458 of file unix/stream.c.

◆ uv__stream_eof()

static void uv__stream_eof	(	uv_stream_t *	stream,
		const uv_buf_t *	buf
	)

static

Definition at line 1001 of file unix/stream.c.

◆ uv__stream_flush_write_queue()

void uv__stream_flush_write_queue	(	uv_stream_t *	stream,
		int	error
	)

Definition at line 443 of file unix/stream.c.

◆ uv__stream_init()

void uv__stream_init	(	uv_loop_t *	loop,
		uv_stream_t *	stream,
		uv_handle_type	type
	)

Definition at line 85 of file unix/stream.c.

◆ uv__stream_io()

static void uv__stream_io	(	uv_loop_t *	loop,
		uv__io_t *	w,
		unsigned int	events
	)

static

Definition at line 1287 of file unix/stream.c.

◆ uv__stream_open()

int uv__stream_open	(	uv_stream_t *	stream,
		int	fd,
		int	flags
	)

Definition at line 406 of file unix/stream.c.

◆ uv__stream_osx_interrupt_select()

static void uv__stream_osx_interrupt_select ( uv_stream_t * stream )

static

Definition at line 123 of file unix/stream.c.

◆ uv__stream_queue_fd()

static int uv__stream_queue_fd	(	uv_stream_t *	stream,
		int	fd
	)

static

Definition at line 1012 of file unix/stream.c.

◆ uv__stream_recv_cmsg()

static int uv__stream_recv_cmsg	(	uv_stream_t *	stream,
		struct msghdr *	msg
	)

static

Definition at line 1060 of file unix/stream.c.

◆ uv__write()

static void uv__write ( uv_stream_t * stream )

static

Definition at line 802 of file unix/stream.c.

◆ uv__write_callbacks()

static void uv__write_callbacks ( uv_stream_t * stream )

static

Definition at line 927 of file unix/stream.c.

◆ uv__write_req_finish()

static void uv__write_req_finish ( uv_write_t * req )

static

Definition at line 762 of file unix/stream.c.

◆ uv__write_req_size()

static size_t uv__write_req_size ( uv_write_t * req )

static

Definition at line 719 of file unix/stream.c.

◆ uv__write_req_update()

static int uv__write_req_update	(	uv_stream_t *	stream,
		uv_write_t *	req,
		size_t	n
	)

static

Definition at line 737 of file unix/stream.c.

◆ uv__writev()

static ssize_t uv__writev	(	int	fd,
		struct iovec *	vec,
		size_t	n
	)

static

Definition at line 711 of file unix/stream.c.

◆ uv_accept()

int uv_accept	(	uv_stream_t *	server,
		uv_stream_t *	client
	)

Definition at line 591 of file unix/stream.c.

◆ uv_is_readable()

int uv_is_readable ( const uv_stream_t * stream )

Definition at line 1606 of file unix/stream.c.

◆ uv_is_writable()

int uv_is_writable ( const uv_stream_t * stream )

Definition at line 1611 of file unix/stream.c.

◆ uv_listen()

int uv_listen	(	uv_stream_t *	stream,
		int	backlog,
		uv_connection_cb	cb
	)

Definition at line 656 of file unix/stream.c.

◆ uv_read_start()

int uv_read_start	(	uv_stream_t *	stream,
		uv_alloc_cb	alloc_cb,
		uv_read_cb	read_cb
	)

Definition at line 1555 of file unix/stream.c.

◆ uv_read_stop()

int uv_read_stop ( uv_stream_t * stream )

Definition at line 1590 of file unix/stream.c.

◆ uv_shutdown()

int uv_shutdown	(	uv_shutdown_t *	req,
		uv_stream_t *	stream,
		uv_shutdown_cb	cb
	)

Definition at line 1259 of file unix/stream.c.

◆ uv_stream_set_blocking()

int uv_stream_set_blocking	(	uv_stream_t *	handle,
		int	blocking
	)

Definition at line 1688 of file unix/stream.c.

◆ uv_try_write()

int uv_try_write	(	uv_stream_t *	stream,
		const uv_buf_t	bufs[],
		unsigned int	nbufs
	)

Definition at line 1507 of file unix/stream.c.

◆ uv_try_write_cb()

void uv_try_write_cb	(	uv_write_t *	req,
		int	status
	)

Definition at line 1501 of file unix/stream.c.

◆ uv_write()

int uv_write	(	uv_write_t *	req,
		uv_stream_t *	handle,
		const uv_buf_t	bufs[],
		unsigned int	nbufs,
		uv_write_cb	cb
	)

Definition at line 1492 of file unix/stream.c.

◆ uv_write2()

int uv_write2	(	uv_write_t *	req,
		uv_stream_t *	stream,
		const uv_buf_t	bufs[],
		unsigned int	nbufs,
		uv_stream_t *	send_handle,
		uv_write_cb	cb
	)

Definition at line 1393 of file unix/stream.c.

Macros

Functions

Macro Definition Documentation

◆ IS_TRANSIENT_WRITE_ERROR

◆ RETRY_ON_WRITE_ERROR

◆ UV__CMSG_FD_COUNT

◆ UV__CMSG_FD_SIZE

◆ UV_DEC_BACKLOG

Function Documentation

◆ uv__drain()

◆ uv__emfile_trick()

◆ uv__handle_fd()

◆ uv__handle_type()

◆ uv__read()

◆ uv__server_io()

◆ uv__stream_close()

◆ uv__stream_connect()

◆ uv__stream_destroy()

◆ uv__stream_eof()

◆ uv__stream_flush_write_queue()

◆ uv__stream_init()

◆ uv__stream_io()

◆ uv__stream_open()

◆ uv__stream_osx_interrupt_select()

◆ uv__stream_queue_fd()

◆ uv__stream_recv_cmsg()

◆ uv__write()

◆ uv__write_callbacks()

◆ uv__write_req_finish()

◆ uv__write_req_size()

◆ uv__write_req_update()

◆ uv__writev()

◆ uv_accept()

◆ uv_is_readable()

◆ uv_is_writable()

◆ uv_listen()

◆ uv_read_start()

◆ uv_read_stop()

◆ uv_shutdown()

◆ uv_stream_set_blocking()

◆ uv_try_write()

◆ uv_try_write_cb()

◆ uv_write()

◆ uv_write2()