nginx: src/os/unix/ngx_udp_sendmsg

annotate src/os/unix/ngx_udp_sendmsg_chain.c @ 7665:d127837c714f

Stream: fixed processing of zero length UDP packets (ticket #1982).

author	Vladimir Homutov <vl@nginx.com>
date	Mon, 08 Jun 2020 11:40:34 +0300
parents	8ce1a34f160b
children	cfe1284e5d1d 2dfd313f22f2

rev	line source
6692 56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	1
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	2 /*
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	3 * Copyright (C) Igor Sysoev
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	4 * Copyright (C) Nginx, Inc.
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	5 */
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	6
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	7
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	8 #include <ngx_config.h>
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	9 #include <ngx_core.h>
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	10 #include <ngx_event.h>
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	11
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	12
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	13 static ngx_chain_t ngx_udp_output_chain_to_iovec(ngx_iovec_t vec,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	14 ngx_chain_t in, ngx_log_t log);
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	15 static ssize_t ngx_sendmsg(ngx_connection_t c, ngx_iovec_t vec);
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	16
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	17
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	18 ngx_chain_t *
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	19 ngx_udp_unix_sendmsg_chain(ngx_connection_t c, ngx_chain_t in, off_t limit)
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	20 {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	21 ssize_t n;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	22 off_t send;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	23 ngx_chain_t *cl;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	24 ngx_event_t *wev;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	25 ngx_iovec_t vec;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	26 struct iovec iovs[NGX_IOVS_PREALLOCATE];
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	27
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	28 wev = c->write;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	29
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	30 if (!wev->ready) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	31 return in;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	32 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	33
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	34 #if (NGX_HAVE_KQUEUE)
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	35
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	36 if ((ngx_event_flags & NGX_USE_KQUEUE_EVENT) && wev->pending_eof) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	37 (void) ngx_connection_error(c, wev->kq_errno,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	38 "kevent() reported about an closed connection");
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	39 wev->error = 1;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	40 return NGX_CHAIN_ERROR;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	41 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	42
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	43 #endif
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	44
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	45 /* the maximum limit size is the maximum size_t value - the page size */
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	46
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	47 if (limit == 0 \|\| limit > (off_t) (NGX_MAX_SIZE_T_VALUE - ngx_pagesize)) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	48 limit = NGX_MAX_SIZE_T_VALUE - ngx_pagesize;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	49 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	50
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	51 send = 0;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	52
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	53 vec.iovs = iovs;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	54 vec.nalloc = NGX_IOVS_PREALLOCATE;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	55
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	56 for ( ;; ) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	57
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	58 /* create the iovec and coalesce the neighbouring bufs */
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	59
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	60 cl = ngx_udp_output_chain_to_iovec(&vec, in, c->log);
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	61
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	62 if (cl == NGX_CHAIN_ERROR) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	63 return NGX_CHAIN_ERROR;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	64 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	65
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	66 if (cl && cl->buf->in_file) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	67 ngx_log_error(NGX_LOG_ALERT, c->log, 0,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	68 "file buf in sendmsg "
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	69 "t:%d r:%d f:%d %p %p-%p %p %O-%O",
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	70 cl->buf->temporary,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	71 cl->buf->recycled,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	72 cl->buf->in_file,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	73 cl->buf->start,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	74 cl->buf->pos,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	75 cl->buf->last,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	76 cl->buf->file,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	77 cl->buf->file_pos,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	78 cl->buf->file_last);
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	79
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	80 ngx_debug_point();
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	81
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	82 return NGX_CHAIN_ERROR;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	83 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	84
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	85 if (cl == in) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	86 return in;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	87 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	88
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	89 send += vec.size;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	90
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	91 n = ngx_sendmsg(c, &vec);
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	92
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	93 if (n == NGX_ERROR) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	94 return NGX_CHAIN_ERROR;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	95 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	96
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	97 if (n == NGX_AGAIN) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	98 wev->ready = 0;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	99 return in;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	100 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	101
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	102 c->sent += n;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	103
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	104 in = ngx_chain_update_sent(in, n);
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	105
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	106 if (send >= limit \|\| in == NULL) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	107 return in;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	108 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	109 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	110 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	111
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	112
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	113 static ngx_chain_t *
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	114 ngx_udp_output_chain_to_iovec(ngx_iovec_t vec, ngx_chain_t in, ngx_log_t *log)
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	115 {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	116 size_t total, size;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	117 u_char *prev;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	118 ngx_uint_t n, flush;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	119 ngx_chain_t *cl;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	120 struct iovec *iov;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	121
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	122 cl = in;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	123 iov = NULL;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	124 prev = NULL;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	125 total = 0;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	126 n = 0;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	127 flush = 0;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	128
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	129 for ( /* void */ ; in && !flush; in = in->next) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	130
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	131 if (in->buf->flush \|\| in->buf->last_buf) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	132 flush = 1;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	133 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	134
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	135 if (ngx_buf_special(in->buf)) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	136 continue;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	137 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	138
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	139 if (in->buf->in_file) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	140 break;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	141 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	142
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	143 if (!ngx_buf_in_memory(in->buf)) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	144 ngx_log_error(NGX_LOG_ALERT, log, 0,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	145 "bad buf in output chain "
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	146 "t:%d r:%d f:%d %p %p-%p %p %O-%O",
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	147 in->buf->temporary,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	148 in->buf->recycled,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	149 in->buf->in_file,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	150 in->buf->start,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	151 in->buf->pos,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	152 in->buf->last,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	153 in->buf->file,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	154 in->buf->file_pos,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	155 in->buf->file_last);
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	156
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	157 ngx_debug_point();
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	158
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	159 return NGX_CHAIN_ERROR;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	160 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	161
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	162 size = in->buf->last - in->buf->pos;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	163
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	164 if (prev == in->buf->pos) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	165 iov->iov_len += size;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	166
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	167 } else {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	168 if (n == vec->nalloc) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	169 ngx_log_error(NGX_LOG_ALERT, log, 0,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	170 "too many parts in a datagram");
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	171 return NGX_CHAIN_ERROR;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	172 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	173
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	174 iov = &vec->iovs[n++];
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	175
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	176 iov->iov_base = (void *) in->buf->pos;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	177 iov->iov_len = size;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	178 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	179
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	180 prev = in->buf->pos + size;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	181 total += size;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	182 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	183
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	184 if (!flush) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	185 #if (NGX_SUPPRESS_WARN)
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	186 vec->size = 0;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	187 vec->count = 0;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	188 #endif
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	189 return cl;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	190 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	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 56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	199 vec->count = n;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	200 vec->size = total;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	201
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	202 return in;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	203 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	204
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	205
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	206 static ssize_t
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	207 ngx_sendmsg(ngx_connection_t c, ngx_iovec_t vec)
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	208 {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	209 ssize_t n;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	210 ngx_err_t err;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	211 struct msghdr msg;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	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 8ce1a34f160b Style. Maxim Dounin <mdounin@mdounin.ru> parents: 6980 diff changeset	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 8ce1a34f160b Style. Maxim Dounin <mdounin@mdounin.ru> parents: 6980 diff changeset	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 8ce1a34f160b Style. Maxim Dounin <mdounin@mdounin.ru> parents: 6980 diff changeset	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 56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	227 ngx_memzero(&msg, sizeof(struct msghdr));
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	228
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	229 if (c->socklen) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	230 msg.msg_name = c->sockaddr;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	231 msg.msg_namelen = c->socklen;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	232 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	233
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	234 msg.msg_iov = vec->iovs;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	235 msg.msg_iovlen = vec->count;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	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 56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	313 eintr:
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	314
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	315 n = sendmsg(c->fd, &msg, 0);
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	316
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	317 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	318 "sendmsg: %z of %uz", n, vec->size);
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	319
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	320 if (n == -1) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	321 err = ngx_errno;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	322
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	323 switch (err) {
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	324 case NGX_EAGAIN:
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	325 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	326 "sendmsg() not ready");
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	327 return NGX_AGAIN;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	328
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	329 case NGX_EINTR:
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	330 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err,
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	331 "sendmsg() was interrupted");
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	332 goto eintr;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	333
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	334 default:
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	335 c->write->error = 1;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	336 ngx_connection_error(c, err, "sendmsg() failed");
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	337 return NGX_ERROR;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	338 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	339 }
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	340
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	341 return n;
56fc55e32f23 Stream: filters. Roman Arutyunyan <arut@nginx.com> parents: diff changeset	342 }

Mercurial > hg > nginx

annotate src/os/unix/ngx_udp_sendmsg_chain.c @ 7665:d127837c714f