nginx: src/os/unix/ngx_readv

annotate src/os/unix/ngx_readv_chain.c @ 4955:2e4e4084b562 stable-1.2

Merge of r4920, r4939: ngx_write_chain_to_file() fixes. *) Core: added debug logging of writev() in ngx_write_chain_to_file(). *) Core: fixed ngx_write_chain_to_file() with IOV_MAX reached. Catched by dav_chunked.t on Solaris. In released versions this might potentially result in corruption of complex protocol responses if they were written to disk and there were more distinct buffers than IOV_MAX in a single write.

author	Maxim Dounin <mdounin@mdounin.ru>
date	Mon, 10 Dec 2012 18:04:54 +0000
parents	4be36d5e78ae
children	13c006f0c40e

rev	line source
441 da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 375 diff changeset	1
da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 375 diff changeset	2 /*
444 42d11f017717 nginx-0.1.0-2004-09-29-20:00:49 import; remove years from copyright Igor Sysoev <igor@sysoev.ru> parents: 441 diff changeset	3 * Copyright (C) Igor Sysoev
4412 d620f497c50f Copyright updated. Maxim Konovalov <maxim@nginx.com> parents: 3642 diff changeset	4 * Copyright (C) Nginx, Inc.
441 da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 375 diff changeset	5 */
da8c5707af39 nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files Igor Sysoev <igor@sysoev.ru> parents: 375 diff changeset	6
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	7
4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	8 #include <ngx_config.h>
4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	9 #include <ngx_core.h>
103 6dfda4cf5200 nginx-0.0.1-2003-06-11-19:28:34 import Igor Sysoev <igor@sysoev.ru> parents: 93 diff changeset	10 #include <ngx_event.h>
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	11
4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	12
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	13 #define NGX_IOVS 16
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	14
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	15
469 2ff194b74f1e nginx-0.1.9-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 455 diff changeset	16 #if (NGX_HAVE_KQUEUE)
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	17
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	18 ssize_t
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	19 ngx_readv_chain(ngx_connection_t c, ngx_chain_t chain)
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	20 {
290 87e73f067470 nginx-0.0.2-2004-03-16-10:10:12 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	21 u_char *prev;
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 163 diff changeset	22 ssize_t n, size;
74 17ab1af8c3dd nginx-0.0.1-2003-04-11-20:01:14 import Igor Sysoev <igor@sysoev.ru> parents: 73 diff changeset	23 ngx_err_t err;
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	24 ngx_array_t vec;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	25 ngx_event_t *rev;
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	26 struct iovec *iov, iovs[NGX_IOVS];
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	27
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 561 diff changeset	28 rev = c->read;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	29
455 295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	30 if (ngx_event_flags & NGX_USE_KQUEUE_EVENT) {
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	31 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0,
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	32 "readv: eof:%d, avail:%d, err:%d",
375 744ccb59062d nginx-0.0.7-2004-07-02-19:54:34 import Igor Sysoev <igor@sysoev.ru> parents: 343 diff changeset	33 rev->pending_eof, rev->available, rev->kq_errno);
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	34
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	35 if (rev->available == 0) {
587 284cc140593b nginx-0.3.15-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	36 if (rev->pending_eof) {
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	37 rev->ready = 0;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	38 rev->eof = 1;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	39
587 284cc140593b nginx-0.3.15-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	40 ngx_log_error(NGX_LOG_INFO, c->log, rev->kq_errno,
284cc140593b nginx-0.3.15-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	41 "kevent() reported about an closed connection");
284cc140593b nginx-0.3.15-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	42
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	43 if (rev->kq_errno) {
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	44 rev->error = 1;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	45 ngx_set_socket_errno(rev->kq_errno);
587 284cc140593b nginx-0.3.15-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	46 return NGX_ERROR;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	47 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	48
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	49 return 0;
587 284cc140593b nginx-0.3.15-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	50
284cc140593b nginx-0.3.15-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	51 } else {
284cc140593b nginx-0.3.15-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	52 return NGX_AGAIN;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	53 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	54 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	55 }
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	56
163 fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	57 prev = NULL;
89 29bf798b583f nginx-0.0.1-2003-05-15-19:42:53 import Igor Sysoev <igor@sysoev.ru> parents: 83 diff changeset	58 iov = NULL;
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 163 diff changeset	59 size = 0;
89 29bf798b583f nginx-0.0.1-2003-05-15-19:42:53 import Igor Sysoev <igor@sysoev.ru> parents: 83 diff changeset	60
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	61 vec.elts = iovs;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	62 vec.nelts = 0;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	63 vec.size = sizeof(struct iovec);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	64 vec.nalloc = NGX_IOVS;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	65 vec.pool = c->pool;
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	66
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 328 diff changeset	67 /* coalesce the neighbouring bufs */
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 103 diff changeset	68
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	69 while (chain) {
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 328 diff changeset	70 if (prev == chain->buf->last) {
6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 328 diff changeset	71 iov->iov_len += chain->buf->end - chain->buf->last;
163 fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	72
fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	73 } else {
4597 4be36d5e78ae Fixed ngx_readv_chain() to honor IOV_MAX (ticket #14). Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	74 if (vec.nelts >= IOV_MAX) {
4be36d5e78ae Fixed ngx_readv_chain() to honor IOV_MAX (ticket #14). Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	75 break;
4be36d5e78ae Fixed ngx_readv_chain() to honor IOV_MAX (ticket #14). Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	76 }
4be36d5e78ae Fixed ngx_readv_chain() to honor IOV_MAX (ticket #14). Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	77
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	78 iov = ngx_array_push(&vec);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	79 if (iov == NULL) {
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	80 return NGX_ERROR;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	81 }
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	82
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 328 diff changeset	83 iov->iov_base = (void *) chain->buf->last;
6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 328 diff changeset	84 iov->iov_len = chain->buf->end - chain->buf->last;
163 fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	85 }
fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	86
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 328 diff changeset	87 size += chain->buf->end - chain->buf->last;
6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 328 diff changeset	88 prev = chain->buf->end;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	89 chain = chain->next;
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	90 }
4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	91
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	92 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0,
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	93 "readv: %d, last:%d", vec.nelts, iov->iov_len);
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: 74 diff changeset	94
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	95 rev = c->read;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	96
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	97 do {
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	98 n = readv(c->fd, (struct iovec *) vec.elts, vec.nelts);
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	99
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	100 if (n >= 0) {
455 295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	101 if (ngx_event_flags & NGX_USE_KQUEUE_EVENT) {
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	102 rev->available -= n;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	103
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	104 /*
587 284cc140593b nginx-0.3.15-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	105 * rev->available may be negative here because some additional
284cc140593b nginx-0.3.15-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	106 * bytes may be received between kevent() and recv()
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	107 */
163 fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	108
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	109 if (rev->available <= 0) {
375 744ccb59062d nginx-0.0.7-2004-07-02-19:54:34 import Igor Sysoev <igor@sysoev.ru> parents: 343 diff changeset	110 if (!rev->pending_eof) {
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	111 rev->ready = 0;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	112 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	113
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	114 if (rev->available < 0) {
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	115 rev->available = 0;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	116 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	117 }
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	118
605 5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	119 if (n == 0) {
5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	120
5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	121 /*
5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	122 * on FreeBSD recv() may return 0 on closed socket
5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	123 * even if kqueue reported about available data
5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	124 */
5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	125
627 387450de0b4d nginx-0.3.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 609 diff changeset	126 #if 0
605 5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	127 ngx_log_error(NGX_LOG_ALERT, c->log, 0,
609 608cf78b24ef nginx-0.3.26-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 605 diff changeset	128 "readv() returned 0 while kevent() reported "
605 5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	129 "%d available bytes", rev->available);
627 387450de0b4d nginx-0.3.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 609 diff changeset	130 #endif
605 5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	131
5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	132 rev->eof = 1;
5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	133 rev->available = 0;
5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	134 }
5dac8c7fb71b nginx-0.3.24-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	135
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	136 return n;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	137 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	138
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	139 if (n < size) {
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	140 rev->ready = 0;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	141 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	142
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	143 if (n == 0) {
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	144 rev->eof = 1;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	145 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	146
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	147 return n;
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	148 }
4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	149
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	150 err = ngx_socket_errno;
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	151
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	152 if (err == NGX_EAGAIN \|\| err == NGX_EINTR) {
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	153 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err,
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	154 "readv() not ready");
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	155 n = NGX_AGAIN;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	156
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	157 } else {
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	158 n = ngx_connection_error(c, err, "readv() failed");
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	159 break;
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	160 }
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	161
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	162 } while (err == NGX_EINTR);
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	163
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	164 rev->ready = 0;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	165
3642 ac33852faaac style fix Igor Sysoev <igor@sysoev.ru> parents: 627 diff changeset	166 if (n == NGX_ERROR) {
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 163 diff changeset	167 c->read->error = 1;
73 4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	168 }
4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	169
4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	170 return n;
4534060fde92 nginx-0.0.1-2003-04-10-19:08:54 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	171 }
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	172
469 2ff194b74f1e nginx-0.1.9-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 455 diff changeset	173 #else /* ! NGX_HAVE_KQUEUE */
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	174
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	175 ssize_t
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	176 ngx_readv_chain(ngx_connection_t c, ngx_chain_t chain)
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	177 {
305 4b1a3a4acc60 nginx-0.0.3-2004-04-02-19:13:20 import Igor Sysoev <igor@sysoev.ru> parents: 303 diff changeset	178 u_char *prev;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	179 ssize_t n, size;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	180 ngx_err_t err;
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	181 ngx_array_t vec;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	182 ngx_event_t *rev;
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	183 struct iovec *iov, iovs[NGX_IOVS];
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	184
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	185 prev = NULL;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	186 iov = NULL;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	187 size = 0;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	188
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	189 vec.elts = iovs;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	190 vec.nelts = 0;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	191 vec.size = sizeof(struct iovec);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	192 vec.nalloc = NGX_IOVS;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	193 vec.pool = c->pool;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	194
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 328 diff changeset	195 /* coalesce the neighbouring bufs */
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	196
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	197 while (chain) {
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 328 diff changeset	198 if (prev == chain->buf->last) {
6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 328 diff changeset	199 iov->iov_len += chain->buf->end - chain->buf->last;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	200
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	201 } else {
4597 4be36d5e78ae Fixed ngx_readv_chain() to honor IOV_MAX (ticket #14). Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	202 if (vec.nelts >= IOV_MAX) {
4be36d5e78ae Fixed ngx_readv_chain() to honor IOV_MAX (ticket #14). Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	203 break;
4be36d5e78ae Fixed ngx_readv_chain() to honor IOV_MAX (ticket #14). Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	204 }
4be36d5e78ae Fixed ngx_readv_chain() to honor IOV_MAX (ticket #14). Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	205
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	206 iov = ngx_array_push(&vec);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	207 if (iov == NULL) {
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	208 return NGX_ERROR;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	209 }
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	210
561 e48ebafc6939 nginx-0.3.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	211 iov->iov_base = (void *) chain->buf->last;
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 328 diff changeset	212 iov->iov_len = chain->buf->end - chain->buf->last;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	213 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	214
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 328 diff changeset	215 size += chain->buf->end - chain->buf->last;
6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 328 diff changeset	216 prev = chain->buf->end;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	217 chain = chain->next;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	218 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	219
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	220 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, c->log, 0,
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	221 "readv: %d:%d", vec.nelts, iov->iov_len);
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	222
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	223 rev = c->read;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	224
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	225 do {
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 469 diff changeset	226 n = readv(c->fd, (struct iovec *) vec.elts, vec.nelts);
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	227
328 fb4dfb2ac0fc nginx-0.0.3-2004-04-28-10:14:50 import Igor Sysoev <igor@sysoev.ru> parents: 305 diff changeset	228 if (n == 0) {
fb4dfb2ac0fc nginx-0.0.3-2004-04-28-10:14:50 import Igor Sysoev <igor@sysoev.ru> parents: 305 diff changeset	229 rev->ready = 0;
fb4dfb2ac0fc nginx-0.0.3-2004-04-28-10:14:50 import Igor Sysoev <igor@sysoev.ru> parents: 305 diff changeset	230 rev->eof = 1;
fb4dfb2ac0fc nginx-0.0.3-2004-04-28-10:14:50 import Igor Sysoev <igor@sysoev.ru> parents: 305 diff changeset	231
fb4dfb2ac0fc nginx-0.0.3-2004-04-28-10:14:50 import Igor Sysoev <igor@sysoev.ru> parents: 305 diff changeset	232 return n;
fb4dfb2ac0fc nginx-0.0.3-2004-04-28-10:14:50 import Igor Sysoev <igor@sysoev.ru> parents: 305 diff changeset	233
fb4dfb2ac0fc nginx-0.0.3-2004-04-28-10:14:50 import Igor Sysoev <igor@sysoev.ru> parents: 305 diff changeset	234 } else if (n > 0) {
fb4dfb2ac0fc nginx-0.0.3-2004-04-28-10:14:50 import Igor Sysoev <igor@sysoev.ru> parents: 305 diff changeset	235
455 295d97d70c69 nginx-0.1.2-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	236 if (n < size && !(ngx_event_flags & NGX_USE_GREEDY_EVENT)) {
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	237 rev->ready = 0;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	238 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	239
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	240 return n;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	241 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	242
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	243 err = ngx_socket_errno;
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	244
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	245 if (err == NGX_EAGAIN \|\| err == NGX_EINTR) {
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	246 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err,
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	247 "readv() not ready");
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	248 n = NGX_AGAIN;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	249
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	250 } else {
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	251 n = ngx_connection_error(c, err, "readv() failed");
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	252 break;
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	253 }
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	254
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	255 } while (err == NGX_EINTR);
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	256
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	257 rev->ready = 0;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	258
3642 ac33852faaac style fix Igor Sysoev <igor@sysoev.ru> parents: 627 diff changeset	259 if (n == NGX_ERROR) {
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	260 c->read->error = 1;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	261 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	262
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	263 return n;
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	264 }
0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	265
469 2ff194b74f1e nginx-0.1.9-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 455 diff changeset	266 #endif /* NGX_HAVE_KQUEUE */

Mercurial > hg > nginx

annotate src/os/unix/ngx_readv_chain.c @ 4955:2e4e4084b562 stable-1.2