Deleted Added
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

--- 80 unchanged lines hidden (view full) ---

89 }
90
91 /* n == -1 */
92
93 switch (err) {
94
95 case NXT_EAGAIN:
96 nxt_debug(ev->task, "sendmsg(%d) not ready", ev->fd);
97 break;
98
99 /*
100 * Returned (at least on OSX) when trying to send many small messages.
101 */
102 case NXT_ENOBUFS:
103 nxt_debug(ev->task, "sendmsg(%d) no buffers", ev->fd);
104 break;
105
106 case NXT_EINTR:
107 nxt_debug(ev->task, "sendmsg(%d) interrupted", ev->fd);
108 continue;
109
110 default:
111 nxt_alert(ev->task, "sendmsg(%d, %FD, %ui) failed %E",
112 ev->fd, fd, niob, err);
113
114 return NXT_ERROR;
115 }
116
117 ev->write_ready = 0;
118
119 return NXT_AGAIN;
120 }
121}
122
123
124ssize_t
125nxt_socketpair_recv(nxt_fd_event_t *ev, nxt_fd_t *fd, nxt_iobuf_t *iob,
126 nxt_uint_t niob)
127{

--- 182 unchanged lines hidden ---