nginx: src/event/ngx_event

annotate src/event/ngx_event_pipe.c @ 577:4d9ea73a627a release-0.3.10

nginx-0.3.10-RELEASE import *) Change: the "valid_referers" directive and the "$invalid_referer" variable were moved to the new ngx_http_referer_module from the ngx_http_rewrite_module. *) Change: the "$apache_bytes_sent" variable name was changed to "$body_bytes_sent". *) Feature: the "$sent_http_..." variables. *) Feature: the "if" directive supports the "=" and "!=" operations. *) Feature: the "proxy_pass" directive supports the HTTPS protocol. *) Feature: the "proxy_set_body" directive. *) Feature: the "post_action" directive. *) Feature: the ngx_http_empty_gif_module. *) Feature: the "worker_cpu_affinity" directive for Linux. *) Bugfix: the "rewrite" directive did not unescape URI part in redirect, now it is unescaped except the %00-%25 and %7F-%FF characters. *) Bugfix: nginx could not be built by the icc 9.0 compiler. *) Bugfix: if the SSI was enabled for zero size static file, then the chunked response was encoded incorrectly.

author	Igor Sysoev <igor@sysoev.ru>
date	Tue, 15 Nov 2005 13:30:52 +0000
parents	7fa11e5c6e96
children	326634fb9d47

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
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	4 */
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
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	6
139 54307053f185 nginx-0.0.1-2003-10-07-19:30:05 import Igor Sysoev <igor@sysoev.ru> parents: 89 diff changeset	7 #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	8 #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	9 #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	10 #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	11
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	12
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	13 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	14 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	15
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	16 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	17 static ngx_inline void ngx_event_pipe_remove_shadow_links(ngx_buf_t *buf);
bbd6b0b4a2b1 nginx-0.1.8-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 461 diff changeset	18 static ngx_inline void ngx_event_pipe_free_shadow_raw_buf(ngx_chain_t **free,
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 ngx_buf_t *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	20 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	21
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	22
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	23 ngx_int_t
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	24 ngx_event_pipe(ngx_event_pipe_t *p, int do_write)
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	25 {
194 2357fa41738a nginx-0.0.1-2003-11-21-09:30:49 import Igor Sysoev <igor@sysoev.ru> parents: 189 diff changeset	26 u_int 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
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	33 if (ngx_event_pipe_write_to_downstream(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	34 return NGX_ABORT;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	35 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	36 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	37
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	38 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	39 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	40
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	41 p->log->action = "reading upstream";
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	42
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	43 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	44 return NGX_ABORT;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	45 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	46
154 eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	47 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	48 break;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	49 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	50
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	51 do_write = 1;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	52 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	53
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	54 if (p->upstream->fd != -1) {
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	55 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	56
189 c966c09be66b nginx-0.0.1-2003-11-18-19:49:00 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	57 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	58
c966c09be66b nginx-0.0.1-2003-11-18-19:49:00 import Igor Sysoev <igor@sysoev.ru> parents: 188 diff changeset	59 if (ngx_handle_read_event(rev, flags) == NGX_ERROR) {
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	60 return NGX_ABORT;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	61 }
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	62
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	63 if (rev->active) {
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	64 ngx_add_timer(rev, p->read_timeout);
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	65 }
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	66 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	67
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	68 if (p->downstream->fd != -1 && p->downstream->data == p->output_ctx) {
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	69 wev = p->downstream->write;
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	70 if (ngx_handle_write_event(wev, p->send_lowat) == NGX_ERROR) {
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	71 return NGX_ABORT;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	72 }
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	73
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	74 if (wev->active && !wev->ready && !wev->delayed) {
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	75 ngx_add_timer(wev, p->send_timeout);
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	76 }
164 84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 163 diff changeset	77 }
84036764e215 nginx-0.0.1-2003-10-29-11:30:44 import Igor Sysoev <igor@sysoev.ru> parents: 163 diff changeset	78
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	79 return NGX_OK;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	80 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	81
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	82
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	83 static ngx_int_t
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	84 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	85 {
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	86 ssize_t n, size;
a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	87 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	88 ngx_buf_t *b;
507 cd3117ad9aab nginx-0.1.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	89 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	90
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	91 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	92 return NGX_OK;
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	93 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	94
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	95 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	96 "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	97
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	98 for ( ;; ) {
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	99
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	100 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	101 break;
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	102 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	103
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 304 diff changeset	104 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	105 break;
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	106 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	107
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	108 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	109
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	110 /* 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	111
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	112 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	113 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	114 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	115
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	116 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	117 "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	118
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	119 if (n) {
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	120 p->read = 1;
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	121 }
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	122
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	123 } else {
57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	124
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	125 /*
58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	126 * 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	127 * 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	128 * 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	129 */
79 eacfdd1c31b9 nginx-0.0.1-2003-04-22-19:02:58 import Igor Sysoev <igor@sysoev.ru> parents: 78 diff changeset	130
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	131 if (p->upstream->read->available == 0
375 744ccb59062d nginx-0.0.7-2004-07-02-19:54:34 import Igor Sysoev <igor@sysoev.ru> parents: 359 diff changeset	132 && 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	133 {
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	134 p->upstream->read->ready = 0;
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	135 p->upstream->read->eof = 0;
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	136 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	137 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	138
469 2ff194b74f1e nginx-0.1.9-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 467 diff changeset	139 #if (NGX_HAVE_KQUEUE)
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	140 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	141 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	142 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	143 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	144
fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	145 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	146 p->upstream->read->kq_errno,
79 eacfdd1c31b9 nginx-0.0.1-2003-04-22-19:02:58 import Igor Sysoev <igor@sysoev.ru> parents: 78 diff changeset	147 "readv() failed");
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	148 }
163 fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	149 #endif
fb61ba77beba nginx-0.0.1-2003-10-28-18:45:41 import Igor Sysoev <igor@sysoev.ru> parents: 155 diff changeset	150
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	151 break;
79 eacfdd1c31b9 nginx-0.0.1-2003-04-22-19:02:58 import Igor Sysoev <igor@sysoev.ru> parents: 78 diff changeset	152 }
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	153
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	154 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	155
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	156 /* 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	157
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	158 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	159 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	160 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	161 chain->next = NULL;
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	162 } 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	163 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	164 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	165
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	166 } 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	167
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	168 /* 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	169
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	170 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	171 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	172 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	173 }
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	174
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	175 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	176
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	177 chain = ngx_alloc_chain_link(p->pool);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	178 if (chain == NULL) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	179 return NGX_ABORT;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	180 }
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	181
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	182 chain->buf = b;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	183 chain->next = NULL;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	184
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	185 } else if (!p->cachable
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	186 && p->downstream->data == p->output_ctx
527 7fa11e5c6e96 nginx-0.1.38-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 521 diff changeset	187 && p->downstream->write->ready
7fa11e5c6e96 nginx-0.1.38-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 521 diff changeset	188 && !p->downstream->write->delayed)
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	189 {
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	190 /*
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	191 * 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	192 * 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	193 */
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	194
154 eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	195 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	196
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	197 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	198 "pipe downstream ready");
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	199
78 9f81437e0ad3 nginx-0.0.1-2003-04-21-18:55:47 import Igor Sysoev <igor@sysoev.ru> parents: 77 diff changeset	200 break;
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	201
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	202 } else if (p->cachable
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	203 \|\| 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	204 {
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	205
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	206 /*
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	207 * if it is allowed, then save some bufs from r->in
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	208 * to a temporary file, and add them to a r->out chain
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	209 */
58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	210
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	211 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	212
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	213 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	214 "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	215
521 6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	216 if (rc == NGX_BUSY) {
6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	217 break;
6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	218 }
6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	219
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	220 if (rc == NGX_AGAIN) {
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	221 if (ngx_event_flags & NGX_USE_LEVEL_EVENT
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	222 && p->upstream->read->active
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	223 && p->upstream->read->ready)
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	224 {
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	225 if (ngx_del_event(p->upstream->read, NGX_READ_EVENT, 0)
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	226 == NGX_ERROR)
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	227 {
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	228 return NGX_ABORT;
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	229 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	230 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	231 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	232
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	233 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	234 return rc;
57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	235 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	236
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	237 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	238 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	239 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	240 chain->next = NULL;
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	241 } 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	242 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	243 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	244
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	245 } else {
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	246
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	247 /* 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	248
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	249 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	250 "no pipe bufs to read in");
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	251
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	252 break;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	253 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	254
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	255 n = p->upstream->recv_chain(p->upstream, chain);
77 57c2e18d3572 nginx-0.0.1-2003-04-17-21:59:35 import Igor Sysoev <igor@sysoev.ru> parents: 76 diff changeset	256
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	257 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	258 "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	259
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 304 diff changeset	260 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	261 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	262 }
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	263 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	264
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	265 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	266 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	267 return NGX_ERROR;
58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	268 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	269
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	270 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	271 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	272 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	273 }
389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	274
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	275 break;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	276 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	277
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	278 p->read = 1;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	279
145 58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	280 if (n == 0) {
58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	281 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	282 break;
58557d0cccd1 nginx-0.0.1-2003-10-13-20:32:29 import Igor Sysoev <igor@sysoev.ru> parents: 144 diff changeset	283 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	284 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	285
175 e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	286 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	287 cl = chain;
151 2d9e4a8b6d11 nginx-0.0.1-2003-10-20-21:14:07 import Igor Sysoev <igor@sysoev.ru> parents: 150 diff changeset	288
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	289 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	290
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	291 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	292
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	293 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	294
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	295 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	296 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	297
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	298 /* 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	299
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	300 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	301 return NGX_ABORT;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	302 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	303
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	304 n -= size;
507 cd3117ad9aab nginx-0.1.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	305 ln = cl;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	306 cl = cl->next;
507 cd3117ad9aab nginx-0.1.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	307 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	308
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	309 } 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	310 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	311 n = 0;
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 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	314
343 6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 304 diff changeset	315 p->free_raw_bufs = cl;
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	316 }
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	317
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	318 #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	319
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	320 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	321 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	322 "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	323 "%p, pos %p, size: %z "
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	324 "file: %O, size: %z",
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	325 (cl->buf->shadow ? 1 : 0),
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	326 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	327 cl->buf->start, cl->buf->pos,
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	328 cl->buf->last - cl->buf->pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	329 cl->buf->file_pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	330 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	331 }
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	332
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	333 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	334 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	335 "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	336 "%p, pos %p, size: %z "
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	337 "file: %O, size: %z",
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	338 (cl->buf->shadow ? 1 : 0),
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	339 cl->buf->temporary, cl->buf->in_file,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	340 cl->buf->start, cl->buf->pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	341 cl->buf->last - cl->buf->pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	342 cl->buf->file_pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	343 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	344 }
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	345
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	346 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	347 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	348 "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	349 "%p, pos %p, size: %z "
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	350 "file: %O, size: %z",
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	351 (cl->buf->shadow ? 1 : 0),
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	352 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	353 cl->buf->start, cl->buf->pos,
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	354 cl->buf->last - cl->buf->pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	355 cl->buf->file_pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	356 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	357 }
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	358
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	359 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	360 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	361 "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	362 "%p, pos %p, size: %z "
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	363 "file: %O, size: %z",
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	364 (cl->buf->shadow ? 1 : 0),
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	365 cl->buf->temporary, cl->buf->in_file,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	366 cl->buf->start, cl->buf->pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	367 cl->buf->last - cl->buf->pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	368 cl->buf->file_pos,
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	369 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	370 }
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	371
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	372 #endif
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	373
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	374 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	375
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	376 /* 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	377
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	378 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	379 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	380 }
6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	381
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	382 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	383
168 ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	384 if (p->free_bufs) {
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	385 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	386 if (cl->buf->shadow == NULL) {
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	387 ngx_pfree(p->pool, cl->buf->start);
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	388 }
168 ba5dbb949603 nginx-0.0.1-2003-10-31-10:10:36 import Igor Sysoev <igor@sysoev.ru> parents: 166 diff changeset	389 }
166 389d7ee9fa60 nginx-0.0.1-2003-10-30-11:51:06 import Igor Sysoev <igor@sysoev.ru> parents: 164 diff changeset	390 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	391 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	392
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	393 if (p->cachable && p->in) {
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	394 if (ngx_event_pipe_write_chain_to_temp_file(p) == NGX_ABORT) {
143 5526213be452 nginx-0.0.1-2003-10-10-19:10:50 import Igor Sysoev <igor@sysoev.ru> parents: 140 diff changeset	395 return NGX_ABORT;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	396 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	397 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	398
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	399 return NGX_OK;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	400 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	401
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	402
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	403 static ngx_int_t
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	404 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	405 {
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	406 size_t bsize;
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	407 ngx_uint_t flush;
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	408 ngx_chain_t out, ll, cl;
146 5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	409
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	410 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	411 "pipe write downstream: %d", p->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	412
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	413 for ( ;; ) {
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	414 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	415 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	416 }
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	417
293 ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	418 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	419
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	420 /* 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	421
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	422 for (cl = p->busy; cl; cl = cl->next) {
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	423 cl->buf->recycled = 0;
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	424 }
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	425
293 ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	426 if (p->out) {
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	427 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	428 "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	429
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	430 for (cl = p->out; cl; cl = cl->next) {
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	431 cl->buf->recycled = 0;
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	432 }
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	433
293 ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	434 if (p->output_filter(p->output_ctx, p->out) == NGX_ERROR) {
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	435 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	436 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	437 }
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	438
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	439 p->out = NULL;
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	440 }
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	441
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	442 if (p->in) {
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	443 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	444 "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	445
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	446 for (cl = p->in; cl; cl = cl->next) {
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	447 cl->buf->recycled = 0;
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	448 }
9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	449
293 ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	450 if (p->output_filter(p->output_ctx, p->in) == NGX_ERROR) {
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	451 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	452 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	453 }
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	454
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	455 p->in = NULL;
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	456 }
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	457
ec3c049681fd nginx-0.0.3-2004-03-19-08:25:53 import Igor Sysoev <igor@sysoev.ru> parents: 257 diff changeset	458 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	459 "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	460
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	461 /* 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	462
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	463 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	464 break;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	465 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	466
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	467 if (p->downstream->data != p->output_ctx
527 7fa11e5c6e96 nginx-0.1.38-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 521 diff changeset	468 \|\| !p->downstream->write->ready
7fa11e5c6e96 nginx-0.1.38-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 521 diff changeset	469 \|\| p->downstream->write->delayed)
509 9b8c906f6e63 nginx-0.1.29-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 507 diff changeset	470 {
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	471 break;
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	472 }
146 5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	473
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	474 /* 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	475
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	476 bsize = 0;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	477
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	478 for (cl = p->busy; cl; cl = cl->next) {
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	479 if (cl->buf->recycled) {
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	480 bsize += cl->buf->end - cl->buf->start;
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	481 }
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	482 }
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	483
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	484 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	485 "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	486
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	487 out = NULL;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	488 ll = NULL;
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	489 flush = 0;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	490
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	491 for ( ;; ) {
c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	492 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	493 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	494
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	495 if (cl->buf->recycled
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	496 && bsize + cl->buf->last - cl->buf->pos > p->busy_size)
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	497 {
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	498 flush = 1;
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	499 break;
c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	500 }
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	501
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	502 p->out = p->out->next;
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	503
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	504 ngx_event_pipe_free_shadow_raw_buf(&p->free_raw_bufs, cl->buf);
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	505
c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	506 } else if (!p->cachable && p->in) {
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	507 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	508
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	509 if (cl->buf->recycled
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	510 && bsize + cl->buf->last - cl->buf->pos > p->busy_size)
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	511 {
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	512 flush = 1;
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	513 break;
c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	514 }
c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	515
c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	516 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	517
c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	518 } else {
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	519 break;
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	520 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	521
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	522 if (cl->buf->recycled) {
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	523 bsize += cl->buf->last - cl->buf->pos;
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	524 }
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	525
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	526 cl->next = NULL;
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	527
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	528 if (out) {
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	529 *ll = cl;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	530 } else {
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	531 out = cl;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	532 }
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	533 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	534 }
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	535
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	536 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	537 "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	538
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	539 if (out == NULL && !flush) {
bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	540 break;
146 5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	541 }
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	542
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	543 if (p->output_filter(p->output_ctx, out) == NGX_ERROR) {
151 2d9e4a8b6d11 nginx-0.0.1-2003-10-20-21:14:07 import Igor Sysoev <igor@sysoev.ru> parents: 150 diff changeset	544 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	545 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	546 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	547
154 eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	548 ngx_chain_update_chains(&p->free, &p->busy, &out, p->tag);
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	549
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	550 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	551
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	552 if (cl->buf->temp_file) {
175 e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	553 if (p->cachable \|\| !p->cyclic_temp_file) {
e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	554 continue;
e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	555 }
e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	556
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	557 /* 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	558
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	559 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	560 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	561 }
e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	562 }
e92c2c647c57 nginx-0.0.1-2003-11-05-20:03:41 import Igor Sysoev <igor@sysoev.ru> parents: 172 diff changeset	563
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	564 /* 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	565
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	566 /* 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	567
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	568 if (cl->buf->last_shadow) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	569 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	570 return NGX_ABORT;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	571 }
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	572
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	573 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	574 }
154 eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	575
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	576 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	577 }
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	578 }
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	579
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	580 return NGX_OK;
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	581 }
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	582
5ac79e574285 nginx-0.0.1-2003-10-14-09:26:00 import Igor Sysoev <igor@sysoev.ru> parents: 145 diff changeset	583
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	584 static ngx_int_t
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	585 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	586 {
359 a3e622ab7ee7 nginx-0.0.7-2004-06-18-10:09:25 import Igor Sysoev <igor@sysoev.ru> parents: 344 diff changeset	587 ssize_t size, bsize;
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	588 ngx_buf_t *b;
187 5a9bbe99008b nginx-0.0.1-2003-11-17-19:15:03 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	589 ngx_chain_t cl, tl, next, out, ll, last_free, fl;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	590
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	591 if (p->buf_to_file) {
6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 304 diff changeset	592 fl.buf = p->buf_to_file;
187 5a9bbe99008b nginx-0.0.1-2003-11-17-19:15:03 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	593 fl.next = p->in;
5a9bbe99008b nginx-0.0.1-2003-11-17-19:15:03 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	594 out = &fl;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	595
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	596 } else {
187 5a9bbe99008b nginx-0.0.1-2003-11-17-19:15:03 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	597 out = p->in;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	598 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	599
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	600 if (!p->cachable) {
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	601
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	602 size = 0;
187 5a9bbe99008b nginx-0.0.1-2003-11-17-19:15:03 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	603 cl = out;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	604 ll = NULL;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	605
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	606 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	607 "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	608
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	609 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	610 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	611
304 bcbe876f4262 nginx-0.0.3-2004-04-02-09:14:40 import Igor Sysoev <igor@sysoev.ru> parents: 294 diff changeset	612 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, p->log, 0,
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	613 "pipe buf %p, pos %p, size: %z",
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	614 cl->buf->start, 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	615
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	616 if ((size + bsize > p->temp_file_write_size)
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	617 \|\| (p->temp_file->offset + size + bsize > 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	618 {
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	619 break;
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	620 }
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	621
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	622 size += bsize;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	623 ll = &cl->next;
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	624 cl = cl->next;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	625
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	626 } while (cl);
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	627
461 a88a3e4e158f nginx-0.1.5-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 457 diff changeset	628 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	629
521 6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	630 if (ll == NULL) {
6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	631 return NGX_BUSY;
6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	632 }
6f00349b98e5 nginx-0.1.35-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 509 diff changeset	633
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	634 if (cl) {
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	635 p->in = cl;
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	636 *ll = NULL;
151 2d9e4a8b6d11 nginx-0.0.1-2003-10-20-21:14:07 import Igor Sysoev <igor@sysoev.ru> parents: 150 diff changeset	637
2d9e4a8b6d11 nginx-0.0.1-2003-10-20-21:14:07 import Igor Sysoev <igor@sysoev.ru> parents: 150 diff changeset	638 } else {
153 c71aeb75c071 nginx-0.0.1-2003-10-21-20:49:56 import Igor Sysoev <igor@sysoev.ru> parents: 152 diff changeset	639 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	640 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	641 }
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	642
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	643 } else {
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 = NULL;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	645 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	646 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	647
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	648 if (ngx_write_chain_to_temp_file(p->temp_file, out) == NGX_ERROR) {
143 5526213be452 nginx-0.0.1-2003-10-10-19:10:50 import Igor Sysoev <igor@sysoev.ru> parents: 140 diff changeset	649 return NGX_ABORT;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	650 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	651
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	652 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	653 *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	654 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	655 {
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	656 /* void */
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	657 }
ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	658
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	659 if (p->buf_to_file) {
6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 304 diff changeset	660 p->temp_file->offset = p->buf_to_file->last - p->buf_to_file->pos;
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	661 p->buf_to_file = NULL;
187 5a9bbe99008b nginx-0.0.1-2003-11-17-19:15:03 import Igor Sysoev <igor@sysoev.ru> parents: 186 diff changeset	662 out = out->next;
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	663 }
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: 168 diff changeset	664
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	665 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	666 next = cl->next;
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	667 cl->next = NULL;
75 869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	668
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	669 b = cl->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	670 b->file = &p->temp_file->file;
6bdf858bff8c nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t Igor Sysoev <igor@sysoev.ru> parents: 304 diff changeset	671 b->file_pos = p->temp_file->offset;
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	672 p->temp_file->offset += b->last - b->pos;
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	673 b->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	674
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	675 b->in_file = 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	676 b->temp_file = 1;
154 eac26585476e nginx-0.0.1-2003-10-22-11:05:29 import Igor Sysoev <igor@sysoev.ru> parents: 153 diff changeset	677
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	678 if (p->out) {
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	679 *p->last_out = cl;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	680 } else {
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	681 p->out = cl;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	682 }
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	683 p->last_out = &cl->next;
150 ad5f382c9e7d nginx-0.0.1-2003-10-19-23:57:23 import Igor Sysoev <igor@sysoev.ru> parents: 149 diff changeset	684
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	685 if (b->last_shadow) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	686
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	687 tl = ngx_alloc_chain_link(p->pool);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	688 if (tl == NULL) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	689 return NGX_ABORT;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	690 }
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	691
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	692 tl->buf = b->shadow;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	693 tl->next = NULL;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	694
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	695 *last_free = tl;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	696 last_free = &tl->next;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	697
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	698 b->shadow->pos = b->shadow->start;
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	699 b->shadow->last = b->shadow->start;
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	700
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	701 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	702 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	703 }
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	704
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	705 return NGX_OK;
869b10be682f nginx-0.0.1-2003-04-14-21:04:58 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	706 }
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	707
78 9f81437e0ad3 nginx-0.0.1-2003-04-21-18:55:47 import Igor Sysoev <igor@sysoev.ru> parents: 77 diff changeset	708
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	709 /* 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	710
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	711 ngx_int_t
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	712 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	713 {
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	714 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	715 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	716
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	717 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	718 return NGX_OK;
6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	719 }
6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	720
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	721 if (p->free) {
507 cd3117ad9aab nginx-0.1.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	722 cl = p->free;
cd3117ad9aab nginx-0.1.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	723 b = cl->buf;
cd3117ad9aab nginx-0.1.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	724 p->free = cl->next;
cd3117ad9aab nginx-0.1.28-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 501 diff changeset	725 ngx_free_chain(p->pool, cl);
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	726
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	727 } else {
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	728 b = ngx_alloc_buf(p->pool);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	729 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	730 return NGX_ERROR;
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	731 }
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	732 }
76 6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	733
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	734 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	735 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	736 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	737 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	738 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	739 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	740
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	741 cl = ngx_alloc_chain_link(p->pool);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	742 if (cl == NULL) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	743 return NGX_ERROR;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	744 }
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	745
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	746 cl->buf = b;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	747 cl->next = NULL;
257 70e1c7d2b83d nginx-0.0.2-2004-02-11-20:08:49 import Igor Sysoev <igor@sysoev.ru> parents: 194 diff changeset	748
479 c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	749 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	750
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	751 if (p->in) {
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	752 *p->last_in = cl;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	753 } else {
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	754 p->in = cl;
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	755 }
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	756 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	757
6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	758 return NGX_OK;
6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	759 }
6127d7075471 nginx-0.0.1-2003-04-15-19:06:52 import Igor Sysoev <igor@sysoev.ru> parents: 75 diff changeset	760
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	761
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	762 static ngx_inline void
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	763 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	764 {
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	765 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	766
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	767 b = buf->shadow;
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	768
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	769 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	770 return;
5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	771 }
5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	772
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	773 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	774 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	775
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	776 b->temporary = 0;
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	777 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	778
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	779 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	780 b = next;
148 5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	781 }
5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	782
452 23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	783 b->temporary = 0;
23fb87bddda1 nginx-0.1.1-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 444 diff changeset	784 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	785 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	786
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	787 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	788
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	789 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	790 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	791
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	792
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	793 static ngx_inline void
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	794 ngx_event_pipe_free_shadow_raw_buf(ngx_chain_t *free, 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	795 {
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	796 ngx_buf_t *s;
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	797 ngx_chain_t cl, *ll;
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	798
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	799 if (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	800 return;
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	801 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	802
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	803 for (s = buf->shadow; !s->last_shadow; s = s->shadow) { /* void */ }
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	804
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	805 ll = free;
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	806
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	807 for (cl = *free ; cl; cl = cl->next) {
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	808 if (cl->buf == s) {
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	809 *ll = cl->next;
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	810 break;
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	811 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	812
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	813 if (cl->buf->shadow) {
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	814 break;
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	815 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	816
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	817 ll = &cl->next;
147 be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	818 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	819 }
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	820
be71fca7f9d7 nginx-0.0.1-2003-10-14-19:06:38 import Igor Sysoev <igor@sysoev.ru> parents: 146 diff changeset	821
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	822 ngx_int_t
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	823 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	824 {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	825 ngx_chain_t *cl;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	826
501 d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	827 cl = ngx_alloc_chain_link(p->pool);
d4ea69372b94 nginx-0.1.25-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 483 diff changeset	828 if (cl == NULL) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	829 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	830 }
5afee0074707 nginx-0.0.1-2003-10-17-00:19:16 import Igor Sysoev <igor@sysoev.ru> parents: 147 diff changeset	831
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	832 b->pos = b->start;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	833 b->last = b->start;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	834 b->shadow = NULL;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	835
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	836 cl->buf = b;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	837
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	838 if (p->free_raw_bufs == NULL) {
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	839 p->free_raw_bufs = cl;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	840 cl->next = NULL;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	841
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	842 return NGX_OK;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	843 }
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	844
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	845 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	846
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	847 /* add the free buf to the list start */
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	848
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	849 cl->next = p->free_raw_bufs;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	850 p->free_raw_bufs = cl;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	851
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	852 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	853 }
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	854
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	855 /* the first free buf is partialy filled, thus add the free buf after it */
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	856
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	857 cl->next = p->free_raw_bufs->next;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	858 p->free_raw_bufs->next = cl;
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	859
621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	860 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	861 }
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	862
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	863
577 4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	864 static ngx_int_t
4d9ea73a627a nginx-0.3.10-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 527 diff changeset	865 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	866 {
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	867 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	868
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	869 for ( ;; ) {
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	870 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	871 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	872 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	873
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	874 } 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	875 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	876 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	877
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	878 } 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	879 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	880 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	881
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	882 } else {
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	883 return NGX_OK;
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	884 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	885
155 46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	886 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	887 if (cl->buf->last_shadow) {
483 621229427cba nginx-0.1.16-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 479 diff changeset	888 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	889 return NGX_ABORT;
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	890 }
c52408583801 nginx-0.1.14-RELEASE import Igor Sysoev <igor@sysoev.ru> parents: 473 diff changeset	891
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	892 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	893 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	894
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	895 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	896 tl = cl->next;
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	897 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	898 p->free = cl;
46eb23d9471d nginx-0.0.1-2003-10-22-20:38:26 import Igor Sysoev <igor@sysoev.ru> parents: 154 diff changeset	899 cl = tl;
152 fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	900 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	901 }
fb48bf4fea1c nginx-0.0.1-2003-10-21-11:47:21 import Igor Sysoev <igor@sysoev.ru> parents: 151 diff changeset	902 }

Mercurial > hg > nginx

annotate src/event/ngx_event_pipe.c @ 577:4d9ea73a627a release-0.3.10