nginx: src/event/ngx_event

annotate src/event/ngx_event_pipe.c @ 5746:35990c69b3ac

Upstream: p->downstream_error instead of closing connection. Previously, nginx closed client connection in cases when a response body from upstream was needed to be cached or stored but shouldn't be sent to the client. While this is normal for HTTP, it is unacceptable for SPDY. Fix is to use instead the p->downstream_error flag to prevent nginx from sending anything downstream. To make this work, the event pipe code was modified to properly cache empty responses with the flag set.

author	Maxim Dounin <mdounin@mdounin.ru>
date	Fri, 04 Jul 2014 20:47:16 +0400
parents	e7b3b9855be8
children	ec81934727a1

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: 442 diff changeset	3 * Copyright (C) Igor Sysoev
4412 d620f497c50f Copyright updated. Maxim Konovalov <maxim@nginx.com> parents: 4233 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
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	7
139 54307053f185 nginx-0.0.1-2003-10-07-19:30:05 import Igor Sysoev <igor@sysoev.ru> parents: 89 diff changeset	8 #include <ngx_config.h>
54307053f185 nginx-0.0.1-2003-10-07-19:30:05 import Igor Sysoev <igor@sysoev.ru> parents: 89 diff changeset	9 #include <ngx_core.h>
54307053f185 nginx-0.0.1-2003-10-07-19:30:05 import Igor Sysoev <igor@sysoev.ru> parents: 89 diff changeset	10 #include <ngx_event.h>
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	11 #include <ngx_event_pipe.h>
c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	12
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	13
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: 304 diff changeset	14 static ngx_int_t ngx_event_pipe_read_upstream(ngx_event_pipe_t *p);
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: 304 diff changeset	15 static ngx_int_t ngx_event_pipe_write_to_downstream(ngx_event_pipe_t *p);
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	16
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: 304 diff changeset	17 static ngx_int_t ngx_event_pipe_write_chain_to_temp_file(ngx_event_pipe_t *p);
467 bbd6b0b4a2b1 nginx-0.1.8-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 461 diff changeset	18 static ngx_inline void ngx_event_pipe_remove_shadow_links(ngx_buf_t *buf);
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: 304 diff changeset	19 static ngx_int_t ngx_event_pipe_drain_chains(ngx_event_pipe_t *p);
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	20
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	21
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	22 ngx_int_t
1599 51b401063046 64-bit update lost in r1355 Igor Sysoev <igor@sysoev.ru> parents: 1565 diff changeset	23 ngx_event_pipe(ngx_event_pipe_t *p, ngx_int_t do_write)
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	24 {
194 2357fa41738a nginx-0.0.1-2003-11-21-09:30:49 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	25 u_int flags;
3052 6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	26 ngx_int_t rc;
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 163 diff changeset	27 ngx_event_t rev, wev;
84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 163 diff changeset	28
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	29 for ( ;; ) {
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	30 if (do_write) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	31 p->log->action = "sending to client";
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	32
3052 6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	33 rc = ngx_event_pipe_write_to_downstream(p);
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	34
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	35 if (rc == NGX_ABORT) {
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	36 return NGX_ABORT;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	37 }
3052 6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	38
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	39 if (rc == NGX_BUSY) {
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	40 return NGX_OK;
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	41 }
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	42 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	43
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	44 p->read = 0;
154 eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	45 p->upstream_blocked = 0;
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	46
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	47 p->log->action = "reading upstream";
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	48
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	49 if (ngx_event_pipe_read_upstream(p) == NGX_ABORT) {
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	50 return NGX_ABORT;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	51 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	52
154 eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	53 if (!p->read && !p->upstream_blocked) {
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	54 break;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	55 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	56
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	57 do_write = 1;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	58 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	59
5360 3d2d3e1cf427 Win32: MinGW GCC compatibility. Maxim Dounin <mdounin@mdounin.ru> parents: 5347 diff changeset	60 if (p->upstream->fd != (ngx_socket_t) -1) {
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	61 rev = p->upstream->read;
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 163 diff changeset	62
189 c966c09be66b nginx-0.0.1-2003-11-18-19:49:00 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	63 flags = (rev->eof \|\| rev->error) ? NGX_CLOSE_EVENT : 0;
c966c09be66b nginx-0.0.1-2003-11-18-19:49:00 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	64
2388 722b5aff05ae use "!= NGX_OK" instead of "== NGX_ERROR" Igor Sysoev <igor@sysoev.ru> parents: 2024 diff changeset	65 if (ngx_handle_read_event(rev, flags) != NGX_OK) {
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	66 return NGX_ABORT;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	67 }
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	68
613 c73c5c58c619 nginx-0.3.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	69 if (rev->active && !rev->ready) {
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	70 ngx_add_timer(rev, p->read_timeout);
613 c73c5c58c619 nginx-0.3.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	71
c73c5c58c619 nginx-0.3.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	72 } else if (rev->timer_set) {
c73c5c58c619 nginx-0.3.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	73 ngx_del_timer(rev);
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	74 }
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	75 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	76
5360 3d2d3e1cf427 Win32: MinGW GCC compatibility. Maxim Dounin <mdounin@mdounin.ru> parents: 5347 diff changeset	77 if (p->downstream->fd != (ngx_socket_t) -1
3d2d3e1cf427 Win32: MinGW GCC compatibility. Maxim Dounin <mdounin@mdounin.ru> parents: 5347 diff changeset	78 && p->downstream->data == p->output_ctx)
3d2d3e1cf427 Win32: MinGW GCC compatibility. Maxim Dounin <mdounin@mdounin.ru> parents: 5347 diff changeset	79 {
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	80 wev = p->downstream->write;
2388 722b5aff05ae use "!= NGX_OK" instead of "== NGX_ERROR" Igor Sysoev <igor@sysoev.ru> parents: 2024 diff changeset	81 if (ngx_handle_write_event(wev, p->send_lowat) != NGX_OK) {
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	82 return NGX_ABORT;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	83 }
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	84
613 c73c5c58c619 nginx-0.3.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	85 if (!wev->delayed) {
c73c5c58c619 nginx-0.3.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	86 if (wev->active && !wev->ready) {
c73c5c58c619 nginx-0.3.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	87 ngx_add_timer(wev, p->send_timeout);
c73c5c58c619 nginx-0.3.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	88
c73c5c58c619 nginx-0.3.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	89 } else if (wev->timer_set) {
c73c5c58c619 nginx-0.3.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	90 ngx_del_timer(wev);
c73c5c58c619 nginx-0.3.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 587 diff changeset	91 }
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	92 }
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 163 diff changeset	93 }
84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 163 diff changeset	94
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	95 return NGX_OK;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	96 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	97
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	98
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	99 static ngx_int_t
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	100 ngx_event_pipe_read_upstream(ngx_event_pipe_t *p)
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	101 {
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	102 ssize_t n, size;
a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	103 ngx_int_t rc;
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: 304 diff changeset	104 ngx_buf_t *b;
507 cd3117ad9aab nginx-0.1.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	105 ngx_chain_t chain, cl, *ln;
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	106
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	107 if (p->upstream_eof \|\| p->upstream_error \|\| p->upstream_done) {
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	108 return NGX_OK;
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	109 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	110
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	111 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, p->log, 0,
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	112 "pipe read upstream: %d", p->upstream->read->ready);
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	113
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	114 for ( ;; ) {
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	115
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	116 if (p->upstream_eof \|\| p->upstream_error \|\| p->upstream_done) {
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	117 break;
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	118 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	119
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: 304 diff changeset	120 if (p->preread_bufs == NULL && !p->upstream->read->ready) {
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	121 break;
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	122 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	123
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: 304 diff changeset	124 if (p->preread_bufs) {
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	125
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: 304 diff changeset	126 /* use the pre-read bufs if they exist */
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	127
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: 304 diff changeset	128 chain = p->preread_bufs;
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: 304 diff changeset	129 p->preread_bufs = NULL;
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	130 n = p->preread_size;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	131
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	132 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, p->log, 0,
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	133 "pipe preread: %z", n);
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	134
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	135 if (n) {
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	136 p->read = 1;
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	137 }
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	138
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	139 } else {
57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	140
581 326634fb9d47 nginx-0.3.12-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	141 #if (NGX_HAVE_KQUEUE)
326634fb9d47 nginx-0.3.12-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	142
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	143 /*
58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	144 * kqueue notifies about the end of file or a pending error.
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: 304 diff changeset	145 * This test allows not to allocate a buf on these conditions
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	146 * and not to call c->recv_chain().
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	147 */
79 eacfdd1c31b9 nginx-0.0.1-2003-04-22-19:02:58 import Igor Sysoev <igor@sysoev.ru> parents: 78 diff changeset	148
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	149 if (p->upstream->read->available == 0
587 284cc140593b nginx-0.3.15-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 583 diff changeset	150 && p->upstream->read->pending_eof)
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	151 {
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	152 p->upstream->read->ready = 0;
4065 227a819b46db Proper setting of read->eof in pipe code. Maxim Dounin <mdounin@mdounin.ru> parents: 3052 diff changeset	153 p->upstream->read->eof = 1;
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	154 p->upstream_eof = 1;
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	155 p->read = 1;
163 fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	156
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	157 if (p->upstream->read->kq_errno) {
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	158 p->upstream->read->error = 1;
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	159 p->upstream_error = 1;
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	160 p->upstream_eof = 0;
163 fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	161
fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	162 ngx_log_error(NGX_LOG_ERR, p->log,
fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	163 p->upstream->read->kq_errno,
581 326634fb9d47 nginx-0.3.12-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	164 "kevent() reported that upstream "
326634fb9d47 nginx-0.3.12-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	165 "closed connection");
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	166 }
163 fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	167
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	168 break;
79 eacfdd1c31b9 nginx-0.0.1-2003-04-22-19:02:58 import Igor Sysoev <igor@sysoev.ru> parents: 78 diff changeset	169 }
581 326634fb9d47 nginx-0.3.12-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 577 diff changeset	170 #endif
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	171
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: 304 diff changeset	172 if (p->free_raw_bufs) {
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	173
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: 304 diff changeset	174 /* use the free bufs if they exist */
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	175
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: 304 diff changeset	176 chain = p->free_raw_bufs;
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	177 if (p->single_buf) {
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: 304 diff changeset	178 p->free_raw_bufs = p->free_raw_bufs->next;
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	179 chain->next = NULL;
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	180 } else {
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: 304 diff changeset	181 p->free_raw_bufs = NULL;
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	182 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	183
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: 304 diff changeset	184 } else if (p->allocated < p->bufs.num) {
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	185
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: 304 diff changeset	186 /* allocate a new buf if it's still allowed */
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	187
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	188 b = ngx_create_temp_buf(p->pool, p->bufs.size);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	189 if (b == NULL) {
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: 304 diff changeset	190 return NGX_ABORT;
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: 304 diff changeset	191 }
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	192
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: 304 diff changeset	193 p->allocated++;
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: 304 diff changeset	194
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	195 chain = ngx_alloc_chain_link(p->pool);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	196 if (chain == NULL) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	197 return NGX_ABORT;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	198 }
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	199
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	200 chain->buf = b;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	201 chain->next = NULL;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	202
1565 4c43e25d11ea fix English grammar Igor Sysoev <igor@sysoev.ru> parents: 1102 diff changeset	203 } else if (!p->cacheable
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	204 && p->downstream->data == p->output_ctx
527 7fa11e5c6e96 nginx-0.1.38-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 521 diff changeset	205 && p->downstream->write->ready
7fa11e5c6e96 nginx-0.1.38-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 521 diff changeset	206 && !p->downstream->write->delayed)
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	207 {
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	208 /*
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: 304 diff changeset	209 * if the bufs are not needed to be saved in a cache and
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: 304 diff changeset	210 * a downstream is ready then write the bufs to a downstream
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	211 */
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	212
154 eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	213 p->upstream_blocked = 1;
eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	214
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	215 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, p->log, 0,
70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	216 "pipe downstream ready");
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	217
78 9f81437e0ad3 nginx-0.0.1-2003-04-21-18:55:47 import Igor Sysoev <igor@sysoev.ru> parents: 77 diff changeset	218 break;
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	219
1565 4c43e25d11ea fix English grammar Igor Sysoev <igor@sysoev.ru> parents: 1102 diff changeset	220 } else if (p->cacheable
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	221 \|\| p->temp_file->offset < p->max_temp_file_size)
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	222 {
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	223
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	224 /*
5347 011d72dea802 Typo fixed. Maxim Dounin <mdounin@mdounin.ru> parents: 5290 diff changeset	225 * if it is allowed, then save some bufs from p->in
011d72dea802 Typo fixed. Maxim Dounin <mdounin@mdounin.ru> parents: 5290 diff changeset	226 * to a temporary file, and add them to a p->out chain
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	227 */
58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	228
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	229 rc = ngx_event_pipe_write_chain_to_temp_file(p);
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	230
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	231 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, p->log, 0,
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	232 "pipe temp offset: %O", p->temp_file->offset);
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	233
521 6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	234 if (rc == NGX_BUSY) {
6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	235 break;
6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	236 }
6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	237
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	238 if (rc == NGX_AGAIN) {
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	239 if (ngx_event_flags & NGX_USE_LEVEL_EVENT
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	240 && p->upstream->read->active
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	241 && p->upstream->read->ready)
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	242 {
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	243 if (ngx_del_event(p->upstream->read, NGX_READ_EVENT, 0)
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	244 == NGX_ERROR)
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	245 {
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	246 return NGX_ABORT;
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	247 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	248 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	249 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	250
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	251 if (rc != NGX_OK) {
57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	252 return rc;
57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	253 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	254
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: 304 diff changeset	255 chain = p->free_raw_bufs;
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	256 if (p->single_buf) {
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: 304 diff changeset	257 p->free_raw_bufs = p->free_raw_bufs->next;
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	258 chain->next = NULL;
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	259 } else {
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: 304 diff changeset	260 p->free_raw_bufs = NULL;
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	261 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	262
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	263 } else {
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	264
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	265 /* there are no bufs to read in */
78 9f81437e0ad3 nginx-0.0.1-2003-04-21-18:55:47 import Igor Sysoev <igor@sysoev.ru> parents: 77 diff changeset	266
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	267 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, p->log, 0,
344 e366ba5db8f8 nginx-0.0.3-2004-06-01-10:04:46 import Igor Sysoev <igor@sysoev.ru> parents: 343 diff changeset	268 "no pipe bufs to read in");
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	269
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	270 break;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	271 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	272
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	273 n = p->upstream->recv_chain(p->upstream, chain);
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	274
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	275 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, p->log, 0,
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	276 "pipe recv chain: %z", n);
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	277
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: 304 diff changeset	278 if (p->free_raw_bufs) {
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: 304 diff changeset	279 chain->next = p->free_raw_bufs;
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	280 }
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: 304 diff changeset	281 p->free_raw_bufs = chain;
151 2d9e4a8b6d11 nginx-0.0.1-2003-10-20-21:14:07 import Igor Sysoev <igor@sysoev.ru> parents: 150 diff changeset	282
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	283 if (n == NGX_ERROR) {
58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	284 p->upstream_error = 1;
58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	285 return NGX_ERROR;
58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	286 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	287
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	288 if (n == NGX_AGAIN) {
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	289 if (p->single_buf) {
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: 304 diff changeset	290 ngx_event_pipe_remove_shadow_links(chain->buf);
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	291 }
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	292
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	293 break;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	294 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	295
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	296 p->read = 1;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	297
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	298 if (n == 0) {
58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	299 p->upstream_eof = 1;
58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	300 break;
58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	301 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	302 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	303
175 e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	304 p->read_length += n;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	305 cl = chain;
858 4766f61a8221 fix endless loop when too many FastCGI sent too many to stderr Igor Sysoev <igor@sysoev.ru> parents: 840 diff changeset	306 p->free_raw_bufs = NULL;
151 2d9e4a8b6d11 nginx-0.0.1-2003-10-20-21:14:07 import Igor Sysoev <igor@sysoev.ru> parents: 150 diff changeset	307
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	308 while (cl && n > 0) {
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	309
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: 304 diff changeset	310 ngx_event_pipe_remove_shadow_links(cl->buf);
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	311
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: 304 diff changeset	312 size = cl->buf->end - cl->buf->last;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	313
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	314 if (n >= size) {
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: 304 diff changeset	315 cl->buf->last = cl->buf->end;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	316
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: 304 diff changeset	317 /* STUB */ cl->buf->num = p->num++;
154 eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	318
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: 304 diff changeset	319 if (p->input_filter(p, cl->buf) == NGX_ERROR) {
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	320 return NGX_ABORT;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	321 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	322
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	323 n -= size;
507 cd3117ad9aab nginx-0.1.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	324 ln = cl;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	325 cl = cl->next;
507 cd3117ad9aab nginx-0.1.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	326 ngx_free_chain(p->pool, ln);
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	327
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	328 } else {
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: 304 diff changeset	329 cl->buf->last += n;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	330 n = 0;
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	331 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	332 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	333
858 4766f61a8221 fix endless loop when too many FastCGI sent too many to stderr Igor Sysoev <igor@sysoev.ru> parents: 840 diff changeset	334 if (cl) {
859 d1e8c59a50ee fix the previous commit Igor Sysoev <igor@sysoev.ru> parents: 858 diff changeset	335 for (ln = cl; ln->next; ln = ln->next) { /* void */ }
858 4766f61a8221 fix endless loop when too many FastCGI sent too many to stderr Igor Sysoev <igor@sysoev.ru> parents: 840 diff changeset	336
859 d1e8c59a50ee fix the previous commit Igor Sysoev <igor@sysoev.ru> parents: 858 diff changeset	337 ln->next = p->free_raw_bufs;
858 4766f61a8221 fix endless loop when too many FastCGI sent too many to stderr Igor Sysoev <igor@sysoev.ru> parents: 840 diff changeset	338 p->free_raw_bufs = cl;
4766f61a8221 fix endless loop when too many FastCGI sent too many to stderr Igor Sysoev <igor@sysoev.ru> parents: 840 diff changeset	339 }
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	340 }
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	341
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: 304 diff changeset	342 #if (NGX_DEBUG)
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	343
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	344 for (cl = p->busy; cl; cl = cl->next) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	345 ngx_log_debug8(NGX_LOG_DEBUG_EVENT, p->log, 0,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	346 "pipe buf busy s:%d t:%d f:%d "
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	347 "%p, pos %p, size: %z "
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	348 "file: %O, size: %z",
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	349 (cl->buf->shadow ? 1 : 0),
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	350 cl->buf->temporary, cl->buf->in_file,
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: 304 diff changeset	351 cl->buf->start, cl->buf->pos,
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	352 cl->buf->last - cl->buf->pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	353 cl->buf->file_pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	354 cl->buf->file_last - cl->buf->file_pos);
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	355 }
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	356
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	357 for (cl = p->out; cl; cl = cl->next) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	358 ngx_log_debug8(NGX_LOG_DEBUG_EVENT, p->log, 0,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	359 "pipe buf out s:%d t:%d f:%d "
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	360 "%p, pos %p, size: %z "
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	361 "file: %O, size: %z",
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	362 (cl->buf->shadow ? 1 : 0),
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	363 cl->buf->temporary, cl->buf->in_file,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	364 cl->buf->start, cl->buf->pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	365 cl->buf->last - cl->buf->pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	366 cl->buf->file_pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	367 cl->buf->file_last - cl->buf->file_pos);
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	368 }
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	369
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	370 for (cl = p->in; cl; cl = cl->next) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	371 ngx_log_debug8(NGX_LOG_DEBUG_EVENT, p->log, 0,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	372 "pipe buf in s:%d t:%d f:%d "
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	373 "%p, pos %p, size: %z "
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	374 "file: %O, size: %z",
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	375 (cl->buf->shadow ? 1 : 0),
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	376 cl->buf->temporary, cl->buf->in_file,
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: 304 diff changeset	377 cl->buf->start, cl->buf->pos,
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	378 cl->buf->last - cl->buf->pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	379 cl->buf->file_pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	380 cl->buf->file_last - cl->buf->file_pos);
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	381 }
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	382
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: 304 diff changeset	383 for (cl = p->free_raw_bufs; cl; cl = cl->next) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	384 ngx_log_debug8(NGX_LOG_DEBUG_EVENT, p->log, 0,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	385 "pipe buf free s:%d t:%d f:%d "
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	386 "%p, pos %p, size: %z "
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	387 "file: %O, size: %z",
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	388 (cl->buf->shadow ? 1 : 0),
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	389 cl->buf->temporary, cl->buf->in_file,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	390 cl->buf->start, cl->buf->pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	391 cl->buf->last - cl->buf->pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	392 cl->buf->file_pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	393 cl->buf->file_last - cl->buf->file_pos);
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	394 }
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	395
4119 b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	396 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, p->log, 0,
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	397 "pipe length: %O", p->length);
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	398
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	399 #endif
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	400
4119 b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	401 if (p->free_raw_bufs && p->length != -1) {
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	402 cl = p->free_raw_bufs;
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	403
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	404 if (cl->buf->last - cl->buf->pos >= p->length) {
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	405
4489 9806bf07d119 Event pipe: fixed buffer loss in p->length case. Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	406 p->free_raw_bufs = cl->next;
9806bf07d119 Event pipe: fixed buffer loss in p->length case. Maxim Dounin <mdounin@mdounin.ru> parents: 4412 diff changeset	407
4119 b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	408 /* STUB */ cl->buf->num = p->num++;
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	409
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	410 if (p->input_filter(p, cl->buf) == NGX_ERROR) {
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	411 return NGX_ABORT;
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	412 }
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	413
4137 6b9b7e7ac4a9 Fixed loss of chain links in ngx_event_pipe_read_upstream(). Maxim Dounin <mdounin@mdounin.ru> parents: 4135 diff changeset	414 ngx_free_chain(p->pool, cl);
4119 b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	415 }
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	416 }
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	417
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	418 if (p->length == 0) {
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	419 p->upstream_done = 1;
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	420 p->read = 1;
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	421 }
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	422
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: 304 diff changeset	423 if ((p->upstream_eof \|\| p->upstream_error) && p->free_raw_bufs) {
293 ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	424
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: 304 diff changeset	425 /* STUB */ p->free_raw_bufs->buf->num = p->num++;
293 ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	426
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: 304 diff changeset	427 if (p->input_filter(p, p->free_raw_bufs->buf) == NGX_ERROR) {
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	428 return NGX_ABORT;
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	429 }
6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	430
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: 304 diff changeset	431 p->free_raw_bufs = p->free_raw_bufs->next;
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	432
2797 90422d071d3f do not free buffer with cache header before it would be written, Igor Sysoev <igor@sysoev.ru> parents: 2592 diff changeset	433 if (p->free_bufs && p->buf_to_file == NULL) {
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: 304 diff changeset	434 for (cl = p->free_raw_bufs; cl; cl = cl->next) {
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	435 if (cl->buf->shadow == NULL) {
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	436 ngx_pfree(p->pool, cl->buf->start);
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	437 }
168 ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	438 }
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	439 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	440 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	441
5746 35990c69b3ac Upstream: p->downstream_error instead of closing connection. Maxim Dounin <mdounin@mdounin.ru> parents: 5466 diff changeset	442 if (p->cacheable && (p->in \|\| p->buf_to_file)) {
35990c69b3ac Upstream: p->downstream_error instead of closing connection. Maxim Dounin <mdounin@mdounin.ru> parents: 5466 diff changeset	443
35990c69b3ac Upstream: p->downstream_error instead of closing connection. Maxim Dounin <mdounin@mdounin.ru> parents: 5466 diff changeset	444 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, p->log, 0,
35990c69b3ac Upstream: p->downstream_error instead of closing connection. Maxim Dounin <mdounin@mdounin.ru> parents: 5466 diff changeset	445 "pipe write chain");
35990c69b3ac Upstream: p->downstream_error instead of closing connection. Maxim Dounin <mdounin@mdounin.ru> parents: 5466 diff changeset	446
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	447 if (ngx_event_pipe_write_chain_to_temp_file(p) == NGX_ABORT) {
143 5526213be452 nginx-0.0.1-2003-10-10-19:10:50 import Igor Sysoev <igor@sysoev.ru> parents: 140 diff changeset	448 return NGX_ABORT;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	449 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	450 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	451
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	452 return NGX_OK;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	453 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	454
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	455
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	456 static ngx_int_t
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	457 ngx_event_pipe_write_to_downstream(ngx_event_pipe_t *p)
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	458 {
1099 04a8b485447d fix segfault when a large FastCGI response was written to a temporary file Igor Sysoev <igor@sysoev.ru> parents: 1045 diff changeset	459 u_char *prev;
583 4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	460 size_t bsize;
1625 91c08c1f4654 fix segfaults Igor Sysoev <igor@sysoev.ru> parents: 1599 diff changeset	461 ngx_int_t rc;
3052 6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	462 ngx_uint_t flush, flushed, prev_last_shadow;
5290 355779f81491 Event pipe: fixed writing cache header to a temp file. Maxim Dounin <mdounin@mdounin.ru> parents: 4895 diff changeset	463 ngx_chain_t out, ll, cl;
583 4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	464 ngx_connection_t *downstream;
4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	465
4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	466 downstream = p->downstream;
146 5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	467
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	468 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, p->log, 0,
583 4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	469 "pipe write downstream: %d", downstream->write->ready);
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	470
3052 6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	471 flushed = 0;
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	472
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	473 for ( ;; ) {
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	474 if (p->downstream_error) {
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	475 return ngx_event_pipe_drain_chains(p);
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	476 }
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	477
293 ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	478 if (p->upstream_eof \|\| p->upstream_error \|\| p->upstream_done) {
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	479
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	480 /* pass the p->out and p->in chains to the output filter */
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	481
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	482 for (cl = p->busy; cl; cl = cl->next) {
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	483 cl->buf->recycled = 0;
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	484 }
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	485
293 ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	486 if (p->out) {
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	487 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, p->log, 0,
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	488 "pipe write downstream flush out");
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	489
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	490 for (cl = p->out; cl; cl = cl->next) {
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	491 cl->buf->recycled = 0;
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	492 }
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	493
1625 91c08c1f4654 fix segfaults Igor Sysoev <igor@sysoev.ru> parents: 1599 diff changeset	494 rc = p->output_filter(p->output_ctx, p->out);
91c08c1f4654 fix segfaults Igor Sysoev <igor@sysoev.ru> parents: 1599 diff changeset	495
91c08c1f4654 fix segfaults Igor Sysoev <igor@sysoev.ru> parents: 1599 diff changeset	496 if (rc == NGX_ERROR) {
293 ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	497 p->downstream_error = 1;
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	498 return ngx_event_pipe_drain_chains(p);
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	499 }
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	500
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	501 p->out = NULL;
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	502 }
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	503
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	504 if (p->in) {
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	505 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, p->log, 0,
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	506 "pipe write downstream flush in");
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	507
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	508 for (cl = p->in; cl; cl = cl->next) {
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	509 cl->buf->recycled = 0;
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	510 }
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	511
1625 91c08c1f4654 fix segfaults Igor Sysoev <igor@sysoev.ru> parents: 1599 diff changeset	512 rc = p->output_filter(p->output_ctx, p->in);
583 4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	513
1625 91c08c1f4654 fix segfaults Igor Sysoev <igor@sysoev.ru> parents: 1599 diff changeset	514 if (rc == NGX_ERROR) {
293 ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	515 p->downstream_error = 1;
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	516 return ngx_event_pipe_drain_chains(p);
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	517 }
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	518
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	519 p->in = NULL;
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	520 }
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	521
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	522 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, p->log, 0,
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	523 "pipe write downstream done");
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	524
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: 304 diff changeset	525 /* TODO: free unused bufs */
293 ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	526
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	527 p->downstream_done = 1;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	528 break;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	529 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	530
583 4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	531 if (downstream->data != p->output_ctx
4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	532 \|\| !downstream->write->ready
4e296b7d25bf nginx-0.3.13-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 581 diff changeset	533 \|\| downstream->write->delayed)
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	534 {
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	535 break;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	536 }
146 5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	537
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	538 /* bsize is the size of the busy recycled bufs */
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	539
1099 04a8b485447d fix segfault when a large FastCGI response was written to a temporary file Igor Sysoev <igor@sysoev.ru> parents: 1045 diff changeset	540 prev = NULL;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	541 bsize = 0;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	542
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	543 for (cl = p->busy; cl; cl = cl->next) {
1099 04a8b485447d fix segfault when a large FastCGI response was written to a temporary file Igor Sysoev <igor@sysoev.ru> parents: 1045 diff changeset	544
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	545 if (cl->buf->recycled) {
1102 37c3b4e62b03 correct r1100 Igor Sysoev <igor@sysoev.ru> parents: 1099 diff changeset	546 if (prev == cl->buf->start) {
37c3b4e62b03 correct r1100 Igor Sysoev <igor@sysoev.ru> parents: 1099 diff changeset	547 continue;
37c3b4e62b03 correct r1100 Igor Sysoev <igor@sysoev.ru> parents: 1099 diff changeset	548 }
37c3b4e62b03 correct r1100 Igor Sysoev <igor@sysoev.ru> parents: 1099 diff changeset	549
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	550 bsize += cl->buf->end - cl->buf->start;
1099 04a8b485447d fix segfault when a large FastCGI response was written to a temporary file Igor Sysoev <igor@sysoev.ru> parents: 1045 diff changeset	551 prev = cl->buf->start;
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	552 }
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	553 }
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	554
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	555 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, p->log, 0,
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	556 "pipe write busy: %uz", bsize);
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	557
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	558 out = NULL;
1099 04a8b485447d fix segfault when a large FastCGI response was written to a temporary file Igor Sysoev <igor@sysoev.ru> parents: 1045 diff changeset	559
04a8b485447d fix segfault when a large FastCGI response was written to a temporary file Igor Sysoev <igor@sysoev.ru> parents: 1045 diff changeset	560 if (bsize >= (size_t) p->busy_size) {
04a8b485447d fix segfault when a large FastCGI response was written to a temporary file Igor Sysoev <igor@sysoev.ru> parents: 1045 diff changeset	561 flush = 1;
04a8b485447d fix segfault when a large FastCGI response was written to a temporary file Igor Sysoev <igor@sysoev.ru> parents: 1045 diff changeset	562 goto flush;
04a8b485447d fix segfault when a large FastCGI response was written to a temporary file Igor Sysoev <igor@sysoev.ru> parents: 1045 diff changeset	563 }
04a8b485447d fix segfault when a large FastCGI response was written to a temporary file Igor Sysoev <igor@sysoev.ru> parents: 1045 diff changeset	564
04a8b485447d fix segfault when a large FastCGI response was written to a temporary file Igor Sysoev <igor@sysoev.ru> parents: 1045 diff changeset	565 flush = 0;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	566 ll = NULL;
1039 73f18b6ad6ba fix FastCGI "zero size buf" alert, Igor Sysoev <igor@sysoev.ru> parents: 1030 diff changeset	567 prev_last_shadow = 1;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	568
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	569 for ( ;; ) {
c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	570 if (p->out) {
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	571 cl = p->out;
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	572
4232 487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	573 if (cl->buf->recycled) {
487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	574 ngx_log_error(NGX_LOG_ALERT, p->log, 0,
487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	575 "recycled buffer in pipe out chain");
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	576 }
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	577
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	578 p->out = p->out->next;
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	579
1565 4c43e25d11ea fix English grammar Igor Sysoev <igor@sysoev.ru> parents: 1102 diff changeset	580 } else if (!p->cacheable && p->in) {
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	581 cl = p->in;
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	582
1030 5a86fcc480c6 add debug logging for FastCGI zero size buf alert Igor Sysoev <igor@sysoev.ru> parents: 859 diff changeset	583 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, p->log, 0,
5a86fcc480c6 add debug logging for FastCGI zero size buf alert Igor Sysoev <igor@sysoev.ru> parents: 859 diff changeset	584 "pipe write buf ls:%d %p %z",
5a86fcc480c6 add debug logging for FastCGI zero size buf alert Igor Sysoev <igor@sysoev.ru> parents: 859 diff changeset	585 cl->buf->last_shadow,
5a86fcc480c6 add debug logging for FastCGI zero size buf alert Igor Sysoev <igor@sysoev.ru> parents: 859 diff changeset	586 cl->buf->pos,
5a86fcc480c6 add debug logging for FastCGI zero size buf alert Igor Sysoev <igor@sysoev.ru> parents: 859 diff changeset	587 cl->buf->last - cl->buf->pos);
5a86fcc480c6 add debug logging for FastCGI zero size buf alert Igor Sysoev <igor@sysoev.ru> parents: 859 diff changeset	588
4232 487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	589 if (cl->buf->recycled && prev_last_shadow) {
487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	590 if (bsize + cl->buf->end - cl->buf->start > p->busy_size) {
487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	591 flush = 1;
487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	592 break;
1039 73f18b6ad6ba fix FastCGI "zero size buf" alert, Igor Sysoev <igor@sysoev.ru> parents: 1030 diff changeset	593 }
73f18b6ad6ba fix FastCGI "zero size buf" alert, Igor Sysoev <igor@sysoev.ru> parents: 1030 diff changeset	594
4232 487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	595 bsize += cl->buf->end - cl->buf->start;
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	596 }
c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	597
1039 73f18b6ad6ba fix FastCGI "zero size buf" alert, Igor Sysoev <igor@sysoev.ru> parents: 1030 diff changeset	598 prev_last_shadow = cl->buf->last_shadow;
73f18b6ad6ba fix FastCGI "zero size buf" alert, Igor Sysoev <igor@sysoev.ru> parents: 1030 diff changeset	599
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	600 p->in = p->in->next;
c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	601
c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	602 } else {
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	603 break;
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	604 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	605
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	606 cl->next = NULL;
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	607
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	608 if (out) {
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	609 *ll = cl;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	610 } else {
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	611 out = cl;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	612 }
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	613 ll = &cl->next;
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	614 }
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	615
1099 04a8b485447d fix segfault when a large FastCGI response was written to a temporary file Igor Sysoev <igor@sysoev.ru> parents: 1045 diff changeset	616 flush:
04a8b485447d fix segfault when a large FastCGI response was written to a temporary file Igor Sysoev <igor@sysoev.ru> parents: 1045 diff changeset	617
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	618 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, p->log, 0,
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	619 "pipe write: out:%p, f:%d", out, flush);
154 eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	620
3052 6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	621 if (out == NULL) {
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	622
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	623 if (!flush) {
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	624 break;
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	625 }
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	626
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	627 /* a workaround for AIO */
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	628 if (flushed++ > 10) {
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	629 return NGX_BUSY;
6060225e9261 FreeBSD and Linux AIO support Igor Sysoev <igor@sysoev.ru> parents: 3050 diff changeset	630 }
146 5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	631 }
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	632
1625 91c08c1f4654 fix segfaults Igor Sysoev <igor@sysoev.ru> parents: 1599 diff changeset	633 rc = p->output_filter(p->output_ctx, out);
91c08c1f4654 fix segfaults Igor Sysoev <igor@sysoev.ru> parents: 1599 diff changeset	634
4135 d8e24515176e Fix of cpu hog in event pipe. Maxim Dounin <mdounin@mdounin.ru> parents: 4119 diff changeset	635 ngx_chain_update_chains(p->pool, &p->free, &p->busy, &out, p->tag);
d8e24515176e Fix of cpu hog in event pipe. Maxim Dounin <mdounin@mdounin.ru> parents: 4119 diff changeset	636
1625 91c08c1f4654 fix segfaults Igor Sysoev <igor@sysoev.ru> parents: 1599 diff changeset	637 if (rc == NGX_ERROR) {
151 2d9e4a8b6d11 nginx-0.0.1-2003-10-20-21:14:07 import Igor Sysoev <igor@sysoev.ru> parents: 150 diff changeset	638 p->downstream_error = 1;
293 ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	639 return ngx_event_pipe_drain_chains(p);
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	640 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	641
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	642 for (cl = p->free; cl; cl = cl->next) {
154 eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	643
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: 304 diff changeset	644 if (cl->buf->temp_file) {
1565 4c43e25d11ea fix English grammar Igor Sysoev <igor@sysoev.ru> parents: 1102 diff changeset	645 if (p->cacheable \|\| !p->cyclic_temp_file) {
175 e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	646 continue;
e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	647 }
e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	648
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: 304 diff changeset	649 /* reset p->temp_offset if all bufs had been sent */
175 e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	650
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: 304 diff changeset	651 if (cl->buf->file_last == p->temp_file->offset) {
175 e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	652 p->temp_file->offset = 0;
e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	653 }
e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	654 }
e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	655
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: 304 diff changeset	656 /* TODO: free buf if p->free_bufs && upstream done */
176 c0552e5ab567 nginx-0.0.1-2003-11-09-23:03:38 import; separate building Igor Sysoev <igor@sysoev.ru> parents: 175 diff changeset	657
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: 304 diff changeset	658 /* add the free shadow raw buf to p->free_raw_bufs */
154 eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	659
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: 304 diff changeset	660 if (cl->buf->last_shadow) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	661 if (ngx_event_pipe_add_free_buf(p, cl->buf->shadow) != NGX_OK) {
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	662 return NGX_ABORT;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	663 }
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	664
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: 304 diff changeset	665 cl->buf->last_shadow = 0;
146 5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	666 }
154 eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	667
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: 304 diff changeset	668 cl->buf->shadow = NULL;
146 5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	669 }
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	670 }
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	671
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	672 return NGX_OK;
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	673 }
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	674
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	675
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	676 static ngx_int_t
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	677 ngx_event_pipe_write_chain_to_temp_file(ngx_event_pipe_t *p)
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	678 {
4233 aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	679 ssize_t size, bsize, n;
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: 304 diff changeset	680 ngx_buf_t *b;
4232 487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	681 ngx_uint_t prev_last_shadow;
4233 aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	682 ngx_chain_t cl, tl, next, out, ll, last_out, **last_free, fl;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	683
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: 304 diff changeset	684 if (p->buf_to_file) {
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: 304 diff changeset	685 fl.buf = p->buf_to_file;
187 5a9bbe99008b nginx-0.0.1-2003-11-17-19:15:03 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	686 fl.next = p->in;
5a9bbe99008b nginx-0.0.1-2003-11-17-19:15:03 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	687 out = &fl;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	688
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	689 } else {
187 5a9bbe99008b nginx-0.0.1-2003-11-17-19:15:03 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	690 out = p->in;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	691 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	692
1565 4c43e25d11ea fix English grammar Igor Sysoev <igor@sysoev.ru> parents: 1102 diff changeset	693 if (!p->cacheable) {
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	694
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	695 size = 0;
187 5a9bbe99008b nginx-0.0.1-2003-11-17-19:15:03 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	696 cl = out;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	697 ll = NULL;
4232 487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	698 prev_last_shadow = 1;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	699
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	700 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, p->log, 0,
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	701 "pipe offset: %O", p->temp_file->offset);
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	702
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	703 do {
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: 304 diff changeset	704 bsize = cl->buf->last - cl->buf->pos;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	705
4232 487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	706 ngx_log_debug4(NGX_LOG_DEBUG_EVENT, p->log, 0,
487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	707 "pipe buf ls:%d %p, pos %p, size: %z",
487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	708 cl->buf->last_shadow, cl->buf->start,
487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	709 cl->buf->pos, bsize);
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	710
4232 487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	711 if (prev_last_shadow
487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	712 && ((size + bsize > p->temp_file_write_size)
487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	713 \|\| (p->temp_file->offset + size + bsize
487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	714 > p->max_temp_file_size)))
151 2d9e4a8b6d11 nginx-0.0.1-2003-10-20-21:14:07 import Igor Sysoev <igor@sysoev.ru> parents: 150 diff changeset	715 {
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	716 break;
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	717 }
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	718
4232 487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	719 prev_last_shadow = cl->buf->last_shadow;
487ab473f393 Event pipe: fixes for complex protocols. Maxim Dounin <mdounin@mdounin.ru> parents: 4137 diff changeset	720
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: 304 diff changeset	721 size += bsize;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	722 ll = &cl->next;
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	723 cl = cl->next;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	724
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	725 } while (cl);
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	726
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	727 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, p->log, 0, "size: %z", size);
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	728
521 6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	729 if (ll == NULL) {
6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	730 return NGX_BUSY;
6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	731 }
6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	732
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	733 if (cl) {
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	734 p->in = cl;
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	735 *ll = NULL;
151 2d9e4a8b6d11 nginx-0.0.1-2003-10-20-21:14:07 import Igor Sysoev <igor@sysoev.ru> parents: 150 diff changeset	736
2d9e4a8b6d11 nginx-0.0.1-2003-10-20-21:14:07 import Igor Sysoev <igor@sysoev.ru> parents: 150 diff changeset	737 } else {
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	738 p->in = NULL;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	739 p->last_in = &p->in;
151 2d9e4a8b6d11 nginx-0.0.1-2003-10-20-21:14:07 import Igor Sysoev <igor@sysoev.ru> parents: 150 diff changeset	740 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	741
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	742 } else {
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	743 p->in = NULL;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	744 p->last_in = &p->in;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	745 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	746
4233 aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	747 n = ngx_write_chain_to_temp_file(p->temp_file, out);
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	748
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	749 if (n == NGX_ERROR) {
143 5526213be452 nginx-0.0.1-2003-10-10-19:10:50 import Igor Sysoev <igor@sysoev.ru> parents: 140 diff changeset	750 return NGX_ABORT;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	751 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	752
4233 aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	753 if (p->buf_to_file) {
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	754 p->temp_file->offset = p->buf_to_file->last - p->buf_to_file->pos;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	755 n -= p->buf_to_file->last - p->buf_to_file->pos;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	756 p->buf_to_file = NULL;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	757 out = out->next;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	758 }
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	759
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	760 if (n > 0) {
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	761 /* update previous buffer or add new buffer */
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	762
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	763 if (p->out) {
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	764 for (cl = p->out; cl->next; cl = cl->next) { /* void */ }
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	765
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	766 b = cl->buf;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	767
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	768 if (b->file_last == p->temp_file->offset) {
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	769 p->temp_file->offset += n;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	770 b->file_last = p->temp_file->offset;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	771 goto free;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	772 }
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	773
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	774 last_out = &cl->next;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	775
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	776 } else {
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	777 last_out = &p->out;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	778 }
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	779
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	780 cl = ngx_chain_get_free_buf(p->pool, &p->free);
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	781 if (cl == NULL) {
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	782 return NGX_ABORT;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	783 }
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	784
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	785 b = cl->buf;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	786
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	787 ngx_memzero(b, sizeof(ngx_buf_t));
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	788
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	789 b->tag = p->tag;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	790
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	791 b->file = &p->temp_file->file;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	792 b->file_pos = p->temp_file->offset;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	793 p->temp_file->offset += n;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	794 b->file_last = p->temp_file->offset;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	795
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	796 b->in_file = 1;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	797 b->temp_file = 1;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	798
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	799 *last_out = cl;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	800 }
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	801
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	802 free:
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	803
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: 304 diff changeset	804 for (last_free = &p->free_raw_bufs;
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	805 *last_free != NULL;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	806 last_free = &(*last_free)->next)
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	807 {
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	808 /* void */
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	809 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	810
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	811 for (cl = out; cl; cl = next) {
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	812 next = cl->next;
4233 aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	813
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	814 cl->next = p->free;
aae172db7ac8 Event pipe: reduced number of file buffers used. Maxim Dounin <mdounin@mdounin.ru> parents: 4232 diff changeset	815 p->free = cl;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	816
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: 304 diff changeset	817 b = cl->buf;
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	818
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: 304 diff changeset	819 if (b->last_shadow) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	820
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	821 tl = ngx_alloc_chain_link(p->pool);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	822 if (tl == NULL) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	823 return NGX_ABORT;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	824 }
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	825
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	826 tl->buf = b->shadow;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	827 tl->next = NULL;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	828
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	829 *last_free = tl;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	830 last_free = &tl->next;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	831
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	832 b->shadow->pos = b->shadow->start;
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	833 b->shadow->last = b->shadow->start;
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	834
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	835 ngx_event_pipe_remove_shadow_links(b->shadow);
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	836 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	837 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	838
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	839 return NGX_OK;
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	840 }
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	841
78 9f81437e0ad3 nginx-0.0.1-2003-04-21-18:55:47 import Igor Sysoev <igor@sysoev.ru> parents: 77 diff changeset	842
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	843 /* the copy input filter */
6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	844
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	845 ngx_int_t
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	846 ngx_event_pipe_copy_input_filter(ngx_event_pipe_t p, ngx_buf_t buf)
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	847 {
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: 304 diff changeset	848 ngx_buf_t *b;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	849 ngx_chain_t *cl;
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	850
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: 304 diff changeset	851 if (buf->pos == buf->last) {
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	852 return NGX_OK;
6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	853 }
6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	854
5466 e7b3b9855be8 Use ngx_chain_get_free_buf() in pipe input filters. Valentin Bartenev <vbart@nginx.com> parents: 5360 diff changeset	855 cl = ngx_chain_get_free_buf(p->pool, &p->free);
e7b3b9855be8 Use ngx_chain_get_free_buf() in pipe input filters. Valentin Bartenev <vbart@nginx.com> parents: 5360 diff changeset	856 if (cl == NULL) {
e7b3b9855be8 Use ngx_chain_get_free_buf() in pipe input filters. Valentin Bartenev <vbart@nginx.com> parents: 5360 diff changeset	857 return NGX_ERROR;
e7b3b9855be8 Use ngx_chain_get_free_buf() in pipe input filters. Valentin Bartenev <vbart@nginx.com> parents: 5360 diff changeset	858 }
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	859
5466 e7b3b9855be8 Use ngx_chain_get_free_buf() in pipe input filters. Valentin Bartenev <vbart@nginx.com> parents: 5360 diff changeset	860 b = cl->buf;
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	861
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: 304 diff changeset	862 ngx_memcpy(b, buf, sizeof(ngx_buf_t));
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: 304 diff changeset	863 b->shadow = buf;
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: 304 diff changeset	864 b->tag = p->tag;
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: 304 diff changeset	865 b->last_shadow = 1;
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: 304 diff changeset	866 b->recycled = 1;
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: 304 diff changeset	867 buf->shadow = b;
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	868
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	869 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, p->log, 0, "input buf #%d", b->num);
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	870
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	871 if (p->in) {
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	872 *p->last_in = cl;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	873 } else {
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	874 p->in = cl;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	875 }
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	876 p->last_in = &cl->next;
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	877
4119 b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	878 if (p->length == -1) {
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	879 return NGX_OK;
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	880 }
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	881
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	882 p->length -= b->last - b->pos;
b66712cde67d Upstream: pipe length and input_filter_init in buffered mode. Maxim Dounin <mdounin@mdounin.ru> parents: 4114 diff changeset	883
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	884 return NGX_OK;
6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	885 }
6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	886
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	887
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	888 static ngx_inline void
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	889 ngx_event_pipe_remove_shadow_links(ngx_buf_t *buf)
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	890 {
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: 304 diff changeset	891 ngx_buf_t b, next;
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	892
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	893 b = buf->shadow;
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	894
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	895 if (b == NULL) {
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	896 return;
5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	897 }
5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	898
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: 304 diff changeset	899 while (!b->last_shadow) {
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: 304 diff changeset	900 next = b->shadow;
442 464aaa791e2b nginx-0.1.0-2004-09-28-19:44:42 import Igor Sysoev <igor@sysoev.ru> parents: 441 diff changeset	901
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	902 b->temporary = 0;
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	903 b->recycled = 0;
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	904
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: 304 diff changeset	905 b->shadow = NULL;
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: 304 diff changeset	906 b = next;
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	907 }
5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	908
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	909 b->temporary = 0;
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	910 b->recycled = 0;
442 464aaa791e2b nginx-0.1.0-2004-09-28-19:44:42 import Igor Sysoev <igor@sysoev.ru> parents: 441 diff changeset	911 b->last_shadow = 0;
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: 304 diff changeset	912
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: 304 diff changeset	913 b->shadow = NULL;
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: 304 diff changeset	914
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: 304 diff changeset	915 buf->shadow = NULL;
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	916 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	917
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	918
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	919 ngx_int_t
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	920 ngx_event_pipe_add_free_buf(ngx_event_pipe_t p, ngx_buf_t b)
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	921 {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	922 ngx_chain_t *cl;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	923
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	924 cl = ngx_alloc_chain_link(p->pool);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	925 if (cl == NULL) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	926 return NGX_ERROR;
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	927 }
5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	928
4895 508e61393b6c Event pipe: fixed handling of buf_to_file data. Maxim Dounin <mdounin@mdounin.ru> parents: 4499 diff changeset	929 if (p->buf_to_file && b->start == p->buf_to_file->start) {
508e61393b6c Event pipe: fixed handling of buf_to_file data. Maxim Dounin <mdounin@mdounin.ru> parents: 4499 diff changeset	930 b->pos = p->buf_to_file->last;
508e61393b6c Event pipe: fixed handling of buf_to_file data. Maxim Dounin <mdounin@mdounin.ru> parents: 4499 diff changeset	931 b->last = p->buf_to_file->last;
508e61393b6c Event pipe: fixed handling of buf_to_file data. Maxim Dounin <mdounin@mdounin.ru> parents: 4499 diff changeset	932
508e61393b6c Event pipe: fixed handling of buf_to_file data. Maxim Dounin <mdounin@mdounin.ru> parents: 4499 diff changeset	933 } else {
508e61393b6c Event pipe: fixed handling of buf_to_file data. Maxim Dounin <mdounin@mdounin.ru> parents: 4499 diff changeset	934 b->pos = b->start;
508e61393b6c Event pipe: fixed handling of buf_to_file data. Maxim Dounin <mdounin@mdounin.ru> parents: 4499 diff changeset	935 b->last = b->start;
508e61393b6c Event pipe: fixed handling of buf_to_file data. Maxim Dounin <mdounin@mdounin.ru> parents: 4499 diff changeset	936 }
508e61393b6c Event pipe: fixed handling of buf_to_file data. Maxim Dounin <mdounin@mdounin.ru> parents: 4499 diff changeset	937
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	938 b->shadow = NULL;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	939
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	940 cl->buf = b;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	941
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	942 if (p->free_raw_bufs == NULL) {
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	943 p->free_raw_bufs = cl;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	944 cl->next = NULL;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	945
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	946 return NGX_OK;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	947 }
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	948
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	949 if (p->free_raw_bufs->buf->pos == p->free_raw_bufs->buf->last) {
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	950
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	951 /* add the free buf to the list start */
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	952
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	953 cl->next = p->free_raw_bufs;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	954 p->free_raw_bufs = cl;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	955
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	956 return NGX_OK;
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	957 }
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	958
4499 778ef9c3fd2d Fixed spelling in single-line comments. Ruslan Ermilov <ru@nginx.com> parents: 4489 diff changeset	959 /* the first free buf is partially filled, thus add the free buf after it */
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	960
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	961 cl->next = p->free_raw_bufs->next;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	962 p->free_raw_bufs->next = cl;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	963
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	964 return NGX_OK;
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	965 }
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	966
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	967
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	968 static ngx_int_t
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	969 ngx_event_pipe_drain_chains(ngx_event_pipe_t *p)
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	970 {
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	971 ngx_chain_t cl, tl;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	972
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	973 for ( ;; ) {
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	974 if (p->busy) {
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	975 cl = p->busy;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 187 diff changeset	976 p->busy = NULL;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	977
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	978 } else if (p->out) {
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	979 cl = p->out;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 187 diff changeset	980 p->out = NULL;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	981
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	982 } else if (p->in) {
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	983 cl = p->in;
188 0061d1f0908d nginx-0.0.1-2003-11-18-11:04:34 import Igor Sysoev <igor@sysoev.ru> parents: 187 diff changeset	984 p->in = NULL;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	985
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	986 } else {
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	987 return NGX_OK;
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	988 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	989
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	990 while (cl) {
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: 304 diff changeset	991 if (cl->buf->last_shadow) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	992 if (ngx_event_pipe_add_free_buf(p, cl->buf->shadow) != NGX_OK) {
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	993 return NGX_ABORT;
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	994 }
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	995
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: 304 diff changeset	996 cl->buf->last_shadow = 0;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	997 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	998
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: 304 diff changeset	999 cl->buf->shadow = NULL;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	1000 tl = cl->next;
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	1001 cl->next = p->free;
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	1002 p->free = cl;
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	1003 cl = tl;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	1004 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	1005 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	1006 }

Mercurial > hg > nginx

annotate src/event/ngx_event_pipe.c @ 5746:35990c69b3ac