nginx: src/event/ngx_event

annotate src/event/ngx_event_pipe.c @ 6443:fc72784b1f52

Threads: writing via threads pools in event pipe. The "aio_write" directive is introduced, which enables use of aio for writing. Currently it is meaningful only with "aio threads". Note that aio operations can be done by both event pipe and output chain, so proper mapping between r->aio and p->aio is provided when calling ngx_event_pipe() and in output filter. In collaboration with Valentin Bartenev.

author	Maxim Dounin <mdounin@mdounin.ru>
date	Fri, 18 Mar 2016 06:44:49 +0300
parents	d811f22033ad
children	2cd019520210

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

Mercurial > hg > nginx

annotate src/event/ngx_event_pipe.c @ 6443:fc72784b1f52