Mercurial > hg > nginx
annotate src/os/unix/ngx_udp_sendmsg_chain.c @ 7690:8253424d1aff
Added size check to ngx_http_alloc_large_header_buffer().
This ensures that copying won't write more than the buffer size
even if the buffer comes from hc->free and it is smaller than the large
client header buffer size in the virtual host configuration. This might
happen if size of large client header buffers is different in name-based
virtual hosts, similarly to the problem with number of buffers fixed
in 6926:e662cbf1b932.
| author | Maxim Dounin <mdounin@mdounin.ru> |
|---|---|
| date | Thu, 06 Aug 2020 05:02:22 +0300 |
| parents | d127837c714f |
| children | cfe1284e5d1d 2dfd313f22f2 |
| rev | line source |
|---|---|
| 6692 | 1 |
| 2 /* | |
| 3 * Copyright (C) Igor Sysoev | |
| 4 * Copyright (C) Nginx, Inc. | |
| 5 */ | |
| 6 | |
| 7 | |
| 8 #include <ngx_config.h> | |
| 9 #include <ngx_core.h> | |
| 10 #include <ngx_event.h> | |
| 11 | |
| 12 | |
| 13 static ngx_chain_t *ngx_udp_output_chain_to_iovec(ngx_iovec_t *vec, | |
| 14 ngx_chain_t *in, ngx_log_t *log); | |
| 15 static ssize_t ngx_sendmsg(ngx_connection_t *c, ngx_iovec_t *vec); | |
| 16 | |
| 17 | |
| 18 ngx_chain_t * | |
| 19 ngx_udp_unix_sendmsg_chain(ngx_connection_t *c, ngx_chain_t *in, off_t limit) | |
| 20 { | |
| 21 ssize_t n; | |
| 22 off_t send; | |
| 23 ngx_chain_t *cl; | |
| 24 ngx_event_t *wev; | |
| 25 ngx_iovec_t vec; | |
| 26 struct iovec iovs[NGX_IOVS_PREALLOCATE]; | |
| 27 | |
| 28 wev = c->write; | |
| 29 | |
| 30 if (!wev->ready) { | |
| 31 return in; | |
| 32 } | |
| 33 | |
| 34 #if (NGX_HAVE_KQUEUE) | |
| 35 | |
| 36 if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) { | |
| 37 (void) ngx_connection_error(c, wev->kq_errno, | |
| 38 "kevent() reported about an closed connection"); | |
| 39 wev->error = 1; | |
| 40 return NGX_CHAIN_ERROR; | |
| 41 } | |
| 42 | |
| 43 #endif | |
| 44 | |
| 45 /* the maximum limit size is the maximum size_t value - the page size */ | |
| 46 | |
| 47 if (limit == 0 || limit > (off_t) (NGX_MAX_SIZE_T_VALUE - ngx_pagesize)) { | |
| 48 limit = NGX_MAX_SIZE_T_VALUE - ngx_pagesize; | |
| 49 } | |
| 50 | |
| 51 send = 0; | |
| 52 | |
| 53 vec.iovs = iovs; | |
| 54 vec.nalloc = NGX_IOVS_PREALLOCATE; | |
| 55 | |
| 56 for ( ;; ) { | |
| 57 | |
| 58 /* create the iovec and coalesce the neighbouring bufs */ | |
| 59 | |
| 60 cl = ngx_udp_output_chain_to_iovec(&vec, in, c->log); | |
| 61 | |
| 62 if (cl == NGX_CHAIN_ERROR) { | |
| 63 return NGX_CHAIN_ERROR; | |
| 64 } | |
| 65 | |
| 66 if (cl && cl->buf->in_file) { | |
| 67 ngx_log_error(NGX_LOG_ALERT, c->log, 0, | |
| 68 "file buf in sendmsg " | |
| 69 "t:%d r:%d f:%d %p %p-%p %p %O-%O", | |
| 70 cl->buf->temporary, | |
| 71 cl->buf->recycled, | |
| 72 cl->buf->in_file, | |
| 73 cl->buf->start, | |
| 74 cl->buf->pos, | |
| 75 cl->buf->last, | |
| 76 cl->buf->file, | |
| 77 cl->buf->file_pos, | |
| 78 cl->buf->file_last); | |
| 79 | |
| 80 ngx_debug_point(); | |
| 81 | |
| 82 return NGX_CHAIN_ERROR; | |
| 83 } | |
| 84 | |
| 85 if (cl == in) { | |
| 86 return in; | |
| 87 } | |
| 88 | |
| 89 send += vec.size; | |
| 90 | |
| 91 n = ngx_sendmsg(c, &vec); | |
| 92 | |
| 93 if (n == NGX_ERROR) { | |
| 94 return NGX_CHAIN_ERROR; | |
| 95 } | |
| 96 | |
| 97 if (n == NGX_AGAIN) { | |
| 98 wev->ready = 0; | |
| 99 return in; | |
| 100 } | |
| 101 | |
| 102 c->sent += n; | |
| 103 | |
| 104 in = ngx_chain_update_sent(in, n); | |
| 105 | |
| 106 if (send >= limit || in == NULL) { | |
| 107 return in; | |
| 108 } | |
| 109 } | |
| 110 } | |
| 111 | |
| 112 | |
| 113 static ngx_chain_t * | |
| 114 ngx_udp_output_chain_to_iovec(ngx_iovec_t *vec, ngx_chain_t *in, ngx_log_t *log) | |
| 115 { | |
| 116 size_t total, size; | |
| 117 u_char *prev; | |
| 118 ngx_uint_t n, flush; | |
| 119 ngx_chain_t *cl; | |
| 120 struct iovec *iov; | |
| 121 | |
| 122 cl = in; | |
| 123 iov = NULL; | |
| 124 prev = NULL; | |
| 125 total = 0; | |
| 126 n = 0; | |
| 127 flush = 0; | |
| 128 | |
| 129 for ( /* void */ ; in && !flush; in = in->next) { | |
| 130 | |
| 131 if (in->buf->flush || in->buf->last_buf) { | |
| 132 flush = 1; | |
| 133 } | |
| 134 | |
| 135 if (ngx_buf_special(in->buf)) { | |
| 136 continue; | |
| 137 } | |
| 138 | |
| 139 if (in->buf->in_file) { | |
| 140 break; | |
| 141 } | |
| 142 | |
| 143 if (!ngx_buf_in_memory(in->buf)) { | |
| 144 ngx_log_error(NGX_LOG_ALERT, log, 0, | |
| 145 "bad buf in output chain " | |
| 146 "t:%d r:%d f:%d %p %p-%p %p %O-%O", | |
| 147 in->buf->temporary, | |
| 148 in->buf->recycled, | |
| 149 in->buf->in_file, | |
| 150 in->buf->start, | |
| 151 in->buf->pos, | |
| 152 in->buf->last, | |
| 153 in->buf->file, | |
| 154 in->buf->file_pos, | |
| 155 in->buf->file_last); | |
| 156 | |
| 157 ngx_debug_point(); | |
| 158 | |
| 159 return NGX_CHAIN_ERROR; | |
| 160 } | |
| 161 | |
| 162 size = in->buf->last - in->buf->pos; | |
| 163 | |
| 164 if (prev == in->buf->pos) { | |
| 165 iov->iov_len += size; | |
| 166 | |
| 167 } else { | |
| 168 if (n == vec->nalloc) { | |
| 169 ngx_log_error(NGX_LOG_ALERT, log, 0, | |
| 170 "too many parts in a datagram"); | |
| 171 return NGX_CHAIN_ERROR; | |
| 172 } | |
| 173 | |
| 174 iov = &vec->iovs[n++]; | |
| 175 | |
| 176 iov->iov_base = (void *) in->buf->pos; | |
| 177 iov->iov_len = size; | |
| 178 } | |
| 179 | |
| 180 prev = in->buf->pos + size; | |
| 181 total += size; | |
| 182 } | |
| 183 | |
| 184 if (!flush) { | |
| 185 #if (NGX_SUPPRESS_WARN) | |
| 186 vec->size = 0; | |
| 187 vec->count = 0; | |
| 188 #endif | |
| 189 return cl; | |
| 190 } | |
| 191 | |
|
7665
d127837c714f
Stream: fixed processing of zero length UDP packets (ticket #1982).
Vladimir Homutov <vl@nginx.com>
parents:
7019
diff
changeset
|
192 /* zero-sized datagram; pretend to have at least 1 iov */ |
|
d127837c714f
Stream: fixed processing of zero length UDP packets (ticket #1982).
Vladimir Homutov <vl@nginx.com>
parents:
7019
diff
changeset
|
193 if (n == 0) { |
|
d127837c714f
Stream: fixed processing of zero length UDP packets (ticket #1982).
Vladimir Homutov <vl@nginx.com>
parents:
7019
diff
changeset
|
194 iov = &vec->iovs[n++]; |
|
d127837c714f
Stream: fixed processing of zero length UDP packets (ticket #1982).
Vladimir Homutov <vl@nginx.com>
parents:
7019
diff
changeset
|
195 iov->iov_base = NULL; |
|
d127837c714f
Stream: fixed processing of zero length UDP packets (ticket #1982).
Vladimir Homutov <vl@nginx.com>
parents:
7019
diff
changeset
|
196 iov->iov_len = 0; |
|
d127837c714f
Stream: fixed processing of zero length UDP packets (ticket #1982).
Vladimir Homutov <vl@nginx.com>
parents:
7019
diff
changeset
|
197 } |
|
d127837c714f
Stream: fixed processing of zero length UDP packets (ticket #1982).
Vladimir Homutov <vl@nginx.com>
parents:
7019
diff
changeset
|
198 |
| 6692 | 199 vec->count = n; |
| 200 vec->size = total; | |
| 201 | |
| 202 return in; | |
| 203 } | |
| 204 | |
| 205 | |
| 206 static ssize_t | |
| 207 ngx_sendmsg(ngx_connection_t *c, ngx_iovec_t *vec) | |
| 208 { | |
| 209 ssize_t n; | |
| 210 ngx_err_t err; | |
| 211 struct msghdr msg; | |
| 212 | |
|
6980
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
213 #if (NGX_HAVE_MSGHDR_MSG_CONTROL) |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
214 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
215 #if (NGX_HAVE_IP_SENDSRCADDR) |
| 7019 | 216 u_char msg_control[CMSG_SPACE(sizeof(struct in_addr))]; |
|
6980
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
217 #elif (NGX_HAVE_IP_PKTINFO) |
| 7019 | 218 u_char msg_control[CMSG_SPACE(sizeof(struct in_pktinfo))]; |
|
6980
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
219 #endif |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
220 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
221 #if (NGX_HAVE_INET6 && NGX_HAVE_IPV6_RECVPKTINFO) |
| 7019 | 222 u_char msg_control6[CMSG_SPACE(sizeof(struct in6_pktinfo))]; |
|
6980
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
223 #endif |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
224 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
225 #endif |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
226 |
| 6692 | 227 ngx_memzero(&msg, sizeof(struct msghdr)); |
| 228 | |
| 229 if (c->socklen) { | |
| 230 msg.msg_name = c->sockaddr; | |
| 231 msg.msg_namelen = c->socklen; | |
| 232 } | |
| 233 | |
| 234 msg.msg_iov = vec->iovs; | |
| 235 msg.msg_iovlen = vec->count; | |
| 236 | |
|
6980
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
237 #if (NGX_HAVE_MSGHDR_MSG_CONTROL) |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
238 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
239 if (c->listening && c->listening->wildcard && c->local_sockaddr) { |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
240 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
241 #if (NGX_HAVE_IP_SENDSRCADDR) |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
242 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
243 if (c->local_sockaddr->sa_family == AF_INET) { |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
244 struct cmsghdr *cmsg; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
245 struct in_addr *addr; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
246 struct sockaddr_in *sin; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
247 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
248 msg.msg_control = &msg_control; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
249 msg.msg_controllen = sizeof(msg_control); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
250 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
251 cmsg = CMSG_FIRSTHDR(&msg); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
252 cmsg->cmsg_level = IPPROTO_IP; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
253 cmsg->cmsg_type = IP_SENDSRCADDR; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
254 cmsg->cmsg_len = CMSG_LEN(sizeof(struct in_addr)); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
255 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
256 sin = (struct sockaddr_in *) c->local_sockaddr; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
257 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
258 addr = (struct in_addr *) CMSG_DATA(cmsg); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
259 *addr = sin->sin_addr; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
260 } |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
261 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
262 #elif (NGX_HAVE_IP_PKTINFO) |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
263 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
264 if (c->local_sockaddr->sa_family == AF_INET) { |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
265 struct cmsghdr *cmsg; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
266 struct in_pktinfo *pkt; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
267 struct sockaddr_in *sin; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
268 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
269 msg.msg_control = &msg_control; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
270 msg.msg_controllen = sizeof(msg_control); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
271 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
272 cmsg = CMSG_FIRSTHDR(&msg); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
273 cmsg->cmsg_level = IPPROTO_IP; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
274 cmsg->cmsg_type = IP_PKTINFO; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
275 cmsg->cmsg_len = CMSG_LEN(sizeof(struct in_pktinfo)); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
276 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
277 sin = (struct sockaddr_in *) c->local_sockaddr; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
278 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
279 pkt = (struct in_pktinfo *) CMSG_DATA(cmsg); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
280 ngx_memzero(pkt, sizeof(struct in_pktinfo)); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
281 pkt->ipi_spec_dst = sin->sin_addr; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
282 } |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
283 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
284 #endif |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
285 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
286 #if (NGX_HAVE_INET6 && NGX_HAVE_IPV6_RECVPKTINFO) |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
287 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
288 if (c->local_sockaddr->sa_family == AF_INET6) { |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
289 struct cmsghdr *cmsg; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
290 struct in6_pktinfo *pkt6; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
291 struct sockaddr_in6 *sin6; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
292 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
293 msg.msg_control = &msg_control6; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
294 msg.msg_controllen = sizeof(msg_control6); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
295 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
296 cmsg = CMSG_FIRSTHDR(&msg); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
297 cmsg->cmsg_level = IPPROTO_IPV6; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
298 cmsg->cmsg_type = IPV6_PKTINFO; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
299 cmsg->cmsg_len = CMSG_LEN(sizeof(struct in6_pktinfo)); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
300 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
301 sin6 = (struct sockaddr_in6 *) c->local_sockaddr; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
302 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
303 pkt6 = (struct in6_pktinfo *) CMSG_DATA(cmsg); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
304 ngx_memzero(pkt6, sizeof(struct in6_pktinfo)); |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
305 pkt6->ipi6_addr = sin6->sin6_addr; |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
306 } |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
307 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
308 #endif |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
309 } |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
310 |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
311 #endif |
|
dbb0c854e308
Set UDP datagram source address (ticket #1239).
Roman Arutyunyan <arut@nginx.com>
parents:
6692
diff
changeset
|
312 |
| 6692 | 313 eintr: |
| 314 | |
| 315 n = sendmsg(c->fd, &msg, 0); | |
| 316 | |
| 317 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0, | |
| 318 "sendmsg: %z of %uz", n, vec->size); | |
| 319 | |
| 320 if (n == -1) { | |
| 321 err = ngx_errno; | |
| 322 | |
| 323 switch (err) { | |
| 324 case NGX_EAGAIN: | |
| 325 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, | |
| 326 "sendmsg() not ready"); | |
| 327 return NGX_AGAIN; | |
| 328 | |
| 329 case NGX_EINTR: | |
| 330 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, | |
| 331 "sendmsg() was interrupted"); | |
| 332 goto eintr; | |
| 333 | |
| 334 default: | |
| 335 c->write->error = 1; | |
| 336 ngx_connection_error(c, err, "sendmsg() failed"); | |
| 337 return NGX_ERROR; | |
| 338 } | |
| 339 } | |
| 340 | |
| 341 return n; | |
| 342 } |