nginx: src/http/modules/proxy/ngx_http_proxy

annotate src/http/modules/proxy/ngx_http_proxy_upstream.c @ 171:aff0e5d32af8

nginx-0.0.1-2003-11-03-20:33:31 import

author	Igor Sysoev <igor@sysoev.ru>
date	Mon, 03 Nov 2003 17:33:31 +0000
parents	c42be4185301
children	caa57ddf6d77

rev	line source
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	1
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	2 #include <ngx_config.h>
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	3 #include <ngx_core.h>
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	4 #include <ngx_event.h>
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	5 #include <ngx_event_connect.h>
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	6 #include <ngx_event_pipe.h>
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	7 #include <ngx_http.h>
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	8 #include <ngx_http_proxy_handler.h>
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	9
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	10
171 aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	11 static ngx_chain_t ngx_http_proxy_create_request(ngx_http_proxy_ctx_t p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	12 static void ngx_http_proxy_init_upstream(void *data);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	13 static void ngx_http_proxy_reinit_upstream(ngx_http_proxy_ctx_t *p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	14 static void ngx_http_proxy_connect(ngx_http_proxy_ctx_t *p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	15 static void ngx_http_proxy_send_request(ngx_http_proxy_ctx_t *p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	16 static void ngx_http_proxy_send_request_handler(ngx_event_t *wev);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	17 static void ngx_http_proxy_dummy_handler(ngx_event_t *wev);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	18 static void ngx_http_proxy_process_upstream_status_line(ngx_event_t *rev);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	19 static void ngx_http_proxy_process_upstream_headers(ngx_event_t *rev);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	20 static void ngx_http_proxy_process_upstream_header(ngx_http_proxy_ctx_t *p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	21 static ssize_t ngx_http_proxy_read_upstream_header(ngx_http_proxy_ctx_t *);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	22 static void ngx_http_proxy_send_response(ngx_http_proxy_ctx_t *p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	23 static void ngx_http_proxy_process_body(ngx_event_t *ev);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	24 static void ngx_http_proxy_next_upstream(ngx_http_proxy_ctx_t *p, int ft_type);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	25
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	26
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	27 static ngx_str_t http_methods[] = {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	28 ngx_string("GET "),
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	29 ngx_string("HEAD "),
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	30 ngx_string("POST ")
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	31 };
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	32
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	33
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	34 static char *upstream_header_errors[] = {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	35 "upstream sent invalid header",
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	36 "upstream sent too long header line"
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	37 };
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	38
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	39
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	40 static char http_version[] = " HTTP/1.0" CRLF;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	41 static char host_header[] = "Host: ";
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	42 static char connection_close_header[] = "Connection: close" CRLF;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	43
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	44
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	45 int ngx_http_proxy_request_upstream(ngx_http_proxy_ctx_t *p)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	46 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	47 int rc;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	48 ngx_http_request_t *r;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	49 ngx_http_proxy_upstream_t *u;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	50
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	51 r = p->request;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	52
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	53 if (!(u = ngx_pcalloc(r->pool, sizeof(ngx_http_proxy_upstream_t)))) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	54 return NGX_HTTP_INTERNAL_SERVER_ERROR;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	55 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	56
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	57 p->upstream = u;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	58
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	59 u->peer.peers = p->lcf->peers;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	60 u->peer.tries = p->lcf->peers->number;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	61
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	62 ngx_init_array(p->states, r->pool, u->peer.tries,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	63 sizeof(ngx_http_proxy_state_t),
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	64 NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	65
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	66 u->method = r->method;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	67
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	68 /* STUB */ p->cachable = p->lcf->cache;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	69
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	70 if (r->headers_in.content_length_n > 0) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	71 if (!(r->temp_file = ngx_pcalloc(r->pool, sizeof(ngx_temp_file_t)))) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	72 return NGX_HTTP_INTERNAL_SERVER_ERROR;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	73 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	74
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	75 r->temp_file->file.fd = NGX_INVALID_FILE;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	76 r->temp_file->file.log = r->connection->log;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	77 r->temp_file->path = p->lcf->temp_path;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	78 r->temp_file->pool = r->pool;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	79 r->temp_file->warn = "a client request body is buffered "
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	80 "to a temporary file";
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	81 /* r->temp_file->persistent = 0; */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	82
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	83 r->request_body_handler = ngx_http_proxy_init_upstream;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	84 r->data = p;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	85
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	86 rc = ngx_http_read_client_request_body(r, p->lcf->request_buffer_size);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	87
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	88 if (rc == NGX_AGAIN) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	89 return NGX_DONE;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	90 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	91
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	92 if (rc == NGX_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	93 return NGX_HTTP_INTERNAL_SERVER_ERROR;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	94 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	95 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	96
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	97 ngx_http_proxy_init_upstream(p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	98
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	99 return NGX_DONE;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	100 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	101
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	102
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	103 static ngx_chain_t ngx_http_proxy_create_request(ngx_http_proxy_ctx_t p)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	104 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	105 int i;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	106 size_t len;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	107 ngx_hunk_t *h;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	108 ngx_chain_t *chain;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	109 ngx_table_elt_t *header;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	110 ngx_http_request_t *r;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	111 ngx_http_proxy_upstream_conf_t *uc;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	112
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	113 r = p->request;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	114 uc = p->lcf->upstream;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	115
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	116 len = http_methods[p->upstream->method - 1].len
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	117 + uc->uri.len
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	118 + r->uri.len - uc->location->len
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	119 + 1 + r->args.len /* 1 is for "?" */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	120 + sizeof(http_version) - 1
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	121 + sizeof(host_header) - 1 + uc->host_header.len + 2
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	122 /* 2 is for "\r\n" */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	123 + sizeof(connection_close_header) - 1
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	124 + 2; /* 2 is for "\r\n" at the header end */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	125
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	126 header = (ngx_table_elt_t *) r->headers_in.headers->elts;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	127 for (i = 0; i < r->headers_in.headers->nelts; i++) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	128
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	129 if (&header[i] == r->headers_in.host) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	130 continue;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	131 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	132
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	133 if (&header[i] == r->headers_in.connection) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	134 continue;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	135 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	136
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	137 /* 2 is for ": " and 2 is for "\r\n" */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	138 len += header[i].key.len + 2 + header[i].value.len + 2;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	139 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	140
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	141 /* STUB */ len++;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	142
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	143 ngx_test_null(h, ngx_create_temp_hunk(r->pool, len), NULL);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	144 ngx_alloc_link_and_set_hunk(chain, h, r->pool, NULL);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	145
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	146
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	147 /* the request line */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	148
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	149 h->last = ngx_cpymem(h->last, http_methods[p->upstream->method - 1].data,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	150 http_methods[p->upstream->method - 1].len);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	151
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	152 h->last = ngx_cpymem(h->last, uc->uri.data, uc->uri.len);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	153
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	154 h->last = ngx_cpymem(h->last,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	155 r->uri.data + uc->location->len,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	156 r->uri.len - uc->location->len);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	157
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	158 if (r->args.len > 0) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	159 *(h->last++) = '?';
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	160 h->last = ngx_cpymem(h->last, r->args.data, r->args.len);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	161 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	162
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	163 h->last = ngx_cpymem(h->last, http_version, sizeof(http_version) - 1);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	164
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	165
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	166 /* "Host" header */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	167
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	168 h->last = ngx_cpymem(h->last, host_header, sizeof(host_header) - 1);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	169 h->last = ngx_cpymem(h->last, uc->host_header.data, uc->host_header.len);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	170 (h->last++) = CR; (h->last++) = LF;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	171
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	172
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	173 /* "Connection: close" header */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	174
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	175 h->last = ngx_cpymem(h->last, connection_close_header,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	176 sizeof(connection_close_header) - 1);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	177
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	178
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	179 for (i = 0; i < r->headers_in.headers->nelts; i++) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	180
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	181 if (&header[i] == r->headers_in.host) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	182 continue;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	183 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	184
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	185 if (&header[i] == r->headers_in.connection) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	186 continue;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	187 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	188
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	189 if (&header[i] == r->headers_in.keep_alive) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	190 continue;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	191 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	192
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	193 h->last = ngx_cpymem(h->last, header[i].key.data, header[i].key.len);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	194
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	195 (h->last++) = ':'; (h->last++) = ' ';
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	196
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	197 h->last = ngx_cpymem(h->last, header[i].value.data,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	198 header[i].value.len);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	199
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	200 (h->last++) = CR; (h->last++) = LF;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	201
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	202 ngx_log_debug(r->connection->log, "proxy: '%s: %s'" _
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	203 header[i].key.data _ header[i].value.data);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	204 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	205
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	206 /* add "\r\n" at the header end */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	207 (h->last++) = CR; (h->last++) = LF;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	208
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	209 /* STUB / (h->last) = '\0';
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	210 ngx_log_debug(r->connection->log, "PROXY:\n'%s'" _ h->pos);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	211
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	212 return chain;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	213 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	214
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	215
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	216 static void ngx_http_proxy_init_upstream(void *data)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	217 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	218 ngx_http_proxy_ctx_t *p = data;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	219
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	220 ngx_chain_t *cl;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	221 ngx_http_request_t *r;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	222 ngx_output_chain_ctx_t *octx;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	223 ngx_chain_writer_ctx_t *wctx;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	224
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	225 r = p->request;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	226
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	227 ngx_log_debug(r->connection->log, "timer_set: %d" _
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	228 r->connection->read->timer_set);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	229
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	230 if (r->connection->read->timer_set) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	231 ngx_del_timer(r->connection->read);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	232 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	233
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	234 if (!(cl = ngx_http_proxy_create_request(p))) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	235 ngx_http_finalize_request(r, NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	236 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	237 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	238
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	239 if (r->request_hunks) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	240 cl->next = r->request_hunks;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	241 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	242
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	243 r->request_hunks = cl;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	244
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	245 p->upstream->peer.log = r->connection->log;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	246 p->saved_ctx = r->connection->log->data;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	247 p->saved_handler = r->connection->log->handler;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	248 r->connection->log->data = p;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	249 r->connection->log->handler = ngx_http_proxy_log_error;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	250 p->action = "connecting to upstream";
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	251
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	252 if (!(octx = ngx_pcalloc(r->pool, sizeof(ngx_output_chain_ctx_t)))) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	253 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	254 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	255 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	256
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	257 p->upstream->output_chain_ctx = octx;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	258
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	259 octx->sendfile = r->sendfile;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	260 octx->pool = r->pool;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	261 octx->bufs.num = 1;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	262 octx->tag = (ngx_hunk_tag_t) &ngx_http_proxy_module;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	263 octx->output_filter = (ngx_output_chain_filter_pt) ngx_chain_writer;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	264
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	265 if (!(wctx = ngx_palloc(r->pool, sizeof(ngx_chain_writer_ctx_t)))) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	266 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	267 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	268 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	269
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	270 octx->output_ctx = wctx;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	271
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	272 wctx->pool = r->pool;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	273
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	274 ngx_http_proxy_connect(p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	275 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	276
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	277
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	278 static void ngx_http_proxy_reinit_upstream(ngx_http_proxy_ctx_t *p)
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	279 {
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	280 ngx_chain_t *cl;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	281 ngx_output_chain_ctx_t *octx;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	282
171 aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	283 octx = p->upstream->output_chain_ctx;
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	284
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	285 /* reinit the request chain */
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	286
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	287 for (cl = p->request->request_hunks; cl; cl = cl->next) {
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	288 cl->hunk->pos = cl->hunk->start;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	289 }
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	290
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	291 /* reinit ngx_output_chain() context */
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	292
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	293 octx->hunk = NULL;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	294 octx->in = NULL;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	295 octx->free = NULL;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	296 octx->busy = NULL;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	297
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	298 /* reinit r->header_in buffer */
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	299
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	300 if (p->header_in) {
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	301 if (p->cache) {
171 aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	302 p->header_in->pos = p->header_in->start + p->cache->ctx.header_size;
170 c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	303 p->header_in->last = p->header_in->pos;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	304
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	305 } else {
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	306 p->header_in->pos = p->header_in->start;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	307 p->header_in->last = p->header_in->start;
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	308 }
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	309 }
c42be4185301 nginx-0.0.1-2003-11-03-01:56:18 import Igor Sysoev <igor@sysoev.ru> parents: diff changeset	310 }
171 aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	311
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	312
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	313 static void ngx_http_proxy_connect(ngx_http_proxy_ctx_t *p)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	314 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	315 int rc;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	316 ngx_chain_t *cl;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	317 ngx_connection_t *c;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	318 ngx_http_request_t *r;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	319 ngx_output_chain_ctx_t *octx;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	320
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	321 p->action = "connecting to upstream";
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	322
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	323 rc = ngx_event_connect_peer(&p->upstream->peer);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	324
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	325 if (rc == NGX_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	326 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	327 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	328 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	329
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	330 if (rc == NGX_CONNECT_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	331 ngx_http_proxy_next_upstream(p, NGX_HTTP_PROXY_FT_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	332 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	333 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	334
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	335 p->upstream->peer.connection->data = p;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	336 p->upstream->peer.connection->write->event_handler =
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	337 ngx_http_proxy_send_request_handler;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	338 p->upstream->peer.connection->read->event_handler =
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	339 ngx_http_proxy_process_upstream_status_line;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	340
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	341 r = p->request;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	342 c = p->upstream->peer.connection;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	343 c->pool = r->pool;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	344 c->read->log = c->write->log = c->log = r->connection->log;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	345
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	346 octx = p->upstream->output_chain_ctx;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	347
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	348 if (p->upstream->peer.tries > 1 && p->request_sent) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	349 ngx_http_proxy_reinit_upstream(p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	350 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	351
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	352 /* init or reinit ngx_output_chain() context */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	353
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	354 if (r->request_body_hunk) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	355 if (!(octx->free = ngx_alloc_chain_link(r->pool))) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	356 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	357 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	358 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	359
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	360 octx->free->hunk = r->request_body_hunk;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	361 octx->free->next = NULL;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	362 octx->hunks = 1;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	363
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	364 r->request_body_hunk->pos = r->request_body_hunk->start;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	365 r->request_body_hunk->last = r->request_body_hunk->start;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	366 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	367
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	368 p->request_sent = 0;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	369
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	370 if (rc == NGX_AGAIN) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	371 ngx_add_timer(c->write, p->lcf->connect_timeout);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	372 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	373 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	374
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	375 /* rc == NGX_OK */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	376
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	377 #if 1 /* test only */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	378
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	379 if (c->read->ready) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	380 /* post aio operation */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	381 ngx_http_proxy_process_upstream_status_line(c->read);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	382 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	383 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	384 #endif
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	385
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	386 ngx_http_proxy_send_request(p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	387 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	388
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	389
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	390 static void ngx_http_proxy_send_request(ngx_http_proxy_ctx_t *p)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	391 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	392 int rc;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	393 ngx_connection_t *c;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	394 ngx_chain_writer_ctx_t *wctx;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	395
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	396 c = p->upstream->peer.connection;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	397
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	398 #if (HAVE_KQUEUE)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	399
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	400 if ((ngx_event_flags & NGX_HAVE_KQUEUE_EVENT)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	401 && !p->request_sent
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	402 && c->write->kq_eof)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	403 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	404 ngx_log_error(NGX_LOG_ERR, c->log, c->write->kq_errno,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	405 "connect() failed");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	406
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	407 ngx_http_proxy_next_upstream(p, NGX_HTTP_PROXY_FT_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	408 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	409 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	410
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	411 #endif
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	412
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	413 p->action = "sending request to upstream";
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	414
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	415 wctx = p->upstream->output_chain_ctx->output_ctx;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	416 wctx->out = NULL;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	417 wctx->last = &wctx->out;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	418 wctx->connection = c;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	419
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	420 rc = ngx_output_chain(p->upstream->output_chain_ctx,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	421 p->request_sent ? NULL : p->request->request_hunks);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	422
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	423 if (rc == NGX_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	424 ngx_http_proxy_next_upstream(p, NGX_HTTP_PROXY_FT_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	425 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	426 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	427
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	428 p->request_sent = 1;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	429
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	430 if (c->write->timer_set) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	431 ngx_del_timer(c->write);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	432 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	433
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	434 if (rc == NGX_AGAIN) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	435 ngx_add_timer(c->write, p->lcf->send_timeout);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	436
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	437 if (ngx_handle_write_event(c->write, /* STUB: lowat */ 0) == NGX_ERROR)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	438 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	439 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	440 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	441 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	442
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	443 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	444 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	445
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	446 /* rc == NGX_OK */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	447
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	448 if (c->tcp_nopush) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	449 if (ngx_tcp_push(c->fd) == NGX_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	450 ngx_log_error(NGX_LOG_CRIT, c->log,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	451 ngx_socket_errno,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	452 ngx_tcp_push_n " failed");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	453 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	454 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	455 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	456
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	457 c->tcp_nopush = 0;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	458 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	459 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	460
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	461 #if 0
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	462 if (c->read->ready) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	463
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	464 /* post aio operation */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	465
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	466 /*
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	467 * although we can post aio operation just in the end
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	468 * of ngx_http_proxy_connect() CHECK IT !!!
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	469 * it's better to do here because we postpone header buffer allocation
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	470 */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	471
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	472 ngx_http_proxy_process_upstream_status_line(c->read);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	473 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	474 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	475 #endif
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	476
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	477 p->upstream->peer.connection->write->event_handler =
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	478 ngx_http_proxy_dummy_handler;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	479
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	480 if (ngx_handle_level_write_event(c->write) == NGX_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	481 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	482 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	483 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	484 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	485
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	486
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	487 static void ngx_http_proxy_send_request_handler(ngx_event_t *wev)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	488 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	489 ngx_connection_t *c;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	490 ngx_http_proxy_ctx_t *p;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	491
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	492 c = wev->data;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	493 p = c->data;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	494
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	495 if (wev->timedout) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	496 p->action = "sending request to upstream";
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	497 ngx_http_proxy_next_upstream(p, NGX_HTTP_PROXY_FT_TIMEOUT);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	498 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	499 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	500
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	501 ngx_http_proxy_send_request(p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	502 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	503
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	504
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	505 static void ngx_http_proxy_dummy_handler(ngx_event_t *wev)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	506 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	507 ngx_log_debug(wev->log, "dummy handler");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	508 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	509
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	510
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	511 static void ngx_http_proxy_process_upstream_status_line(ngx_event_t *rev)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	512 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	513 int rc;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	514 ssize_t n;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	515 ngx_connection_t *c;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	516 ngx_http_proxy_ctx_t *p;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	517
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	518 c = rev->data;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	519 p = c->data;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	520 p->action = "reading upstream status line";
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	521
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	522 ngx_log_debug(rev->log, "http proxy process status line");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	523
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	524 if (rev->timedout) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	525 ngx_http_proxy_next_upstream(p, NGX_HTTP_PROXY_FT_TIMEOUT);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	526 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	527 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	528
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	529 if (p->header_in == NULL) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	530 p->header_in = ngx_create_temp_hunk(p->request->pool,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	531 p->lcf->header_buffer_size);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	532 if (p->header_in == NULL) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	533 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	534 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	535 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	536 p->header_in->tag = (ngx_hunk_tag_t) &ngx_http_proxy_module;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	537
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	538 if (p->cache) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	539 p->header_in->pos += p->cache->ctx.header_size;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	540 p->header_in->last = p->header_in->pos;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	541 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	542 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	543
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	544 n = ngx_http_proxy_read_upstream_header(p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	545
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	546 if (n == NGX_AGAIN) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	547 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	548 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	549
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	550 if (n == 0) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	551 ngx_log_error(NGX_LOG_ERR, rev->log, 0,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	552 "upstream prematurely closed connection");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	553 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	554
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	555 if (n == NGX_ERROR \|\| n == 0) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	556 ngx_http_proxy_next_upstream(p, NGX_HTTP_PROXY_FT_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	557 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	558 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	559
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	560 p->upstream->peer.cached = 0;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	561
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	562 rc = ngx_http_proxy_parse_status_line(p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	563
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	564 if (rc == NGX_AGAIN) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	565 if (p->header_in->pos == p->header_in->last) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	566 ngx_log_error(NGX_LOG_ERR, rev->log, 0,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	567 "upstream sent too long status line");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	568 ngx_http_proxy_next_upstream(p, NGX_HTTP_PROXY_FT_INVALID_HEADER);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	569 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	570 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	571 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	572
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	573 if (rc == NGX_HTTP_PROXY_PARSE_NO_HEADER) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	574 ngx_log_error(NGX_LOG_ERR, rev->log, 0,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	575 "upstream sent no valid HTTP/1.0 header");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	576
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	577 if (p->accel) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	578 ngx_http_proxy_next_upstream(p, NGX_HTTP_PROXY_FT_INVALID_HEADER);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	579
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	580 } else {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	581 p->request->http_version = NGX_HTTP_VERSION_9;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	582 p->upstream->status = NGX_HTTP_OK;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	583 ngx_http_proxy_send_response(p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	584 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	585
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	586 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	587 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	588
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	589 /* rc == NGX_OK */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	590
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	591 p->upstream->status = p->status;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	592
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	593 if (p->status == NGX_HTTP_INTERNAL_SERVER_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	594
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	595 if (p->upstream->peer.tries > 1
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	596 && (p->lcf->next_upstream & NGX_HTTP_PROXY_FT_HTTP_500))
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	597 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	598 ngx_http_proxy_next_upstream(p, NGX_HTTP_PROXY_FT_HTTP_500);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	599 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	600 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	601
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	602 if (p->upstream->peer.tries == 0
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	603 && p->stale
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	604 && (p->lcf->use_stale & NGX_HTTP_PROXY_FT_HTTP_500))
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	605 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	606 ngx_http_proxy_finalize_request(p,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	607 ngx_http_proxy_send_cached_response(p));
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	608
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	609 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	610 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	611 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	612
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	613 p->upstream->status_line.len = p->status_end - p->status_start;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	614 p->upstream->status_line.data = ngx_palloc(p->request->pool,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	615 p->upstream->status_line.len + 1);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	616 if (p->upstream->status_line.data == NULL) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	617 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	618 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	619 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	620 ngx_cpystrn(p->upstream->status_line.data, p->status_start,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	621 p->upstream->status_line.len + 1);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	622
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	623 ngx_log_debug(rev->log, "http proxy status %d '%s'" _
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	624 p->upstream->status _ p->upstream->status_line.data);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	625
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	626 if (p->upstream->headers_in.headers) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	627 p->upstream->headers_in.headers->nelts = 0;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	628 } else {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	629 p->upstream->headers_in.headers = ngx_create_table(p->request->pool,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	630 20);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	631 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	632
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	633 c->read->event_handler = ngx_http_proxy_process_upstream_headers;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	634 ngx_http_proxy_process_upstream_headers(rev);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	635 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	636
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	637
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	638 static void ngx_http_proxy_process_upstream_headers(ngx_event_t *rev)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	639 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	640 int i, rc;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	641 ssize_t n;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	642 ngx_table_elt_t *h;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	643 ngx_connection_t *c;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	644 ngx_http_request_t *r;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	645 ngx_http_proxy_ctx_t *p;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	646
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	647 c = rev->data;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	648 p = c->data;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	649 r = p->request;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	650 p->action = "reading upstream headers";
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	651
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	652 ngx_log_debug(rev->log, "http proxy process header line");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	653
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	654 if (rev->timedout) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	655 ngx_http_proxy_next_upstream(p, NGX_HTTP_PROXY_FT_TIMEOUT);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	656 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	657 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	658
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	659 rc = NGX_AGAIN;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	660
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	661 for ( ;; ) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	662 if (rc == NGX_AGAIN) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	663 n = ngx_http_proxy_read_upstream_header(p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	664
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	665 if (n == 0) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	666 ngx_log_error(NGX_LOG_ERR, rev->log, 0,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	667 "upstream prematurely closed connection");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	668 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	669
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	670 if (n == NGX_ERROR \|\| n == 0) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	671 ngx_http_proxy_next_upstream(p, NGX_HTTP_PROXY_FT_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	672 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	673 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	674
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	675 if (n == NGX_AGAIN) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	676 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	677 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	678 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	679
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	680 rc = ngx_http_parse_header_line(p->request, p->header_in);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	681
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	682 if (rc == NGX_OK) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	683
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	684 /* a header line has been parsed successfully */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	685
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	686 h = ngx_http_add_header(&p->upstream->headers_in,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	687 ngx_http_proxy_headers_in);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	688 if (h == NULL) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	689 ngx_http_proxy_finalize_request(p,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	690 NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	691 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	692 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	693
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	694 h->key.len = r->header_name_end - r->header_name_start;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	695 h->value.len = r->header_end - r->header_start;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	696
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	697 h->key.data = ngx_palloc(p->request->pool,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	698 h->key.len + 1 + h->value.len + 1);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	699 if (h->key.data == NULL) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	700 ngx_http_proxy_finalize_request(p,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	701 NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	702 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	703 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	704
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	705 h->value.data = h->key.data + h->key.len + 1;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	706 ngx_cpystrn(h->key.data, r->header_name_start, h->key.len + 1);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	707 ngx_cpystrn(h->value.data, r->header_start, h->value.len + 1);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	708
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	709 for (i = 0; ngx_http_proxy_headers_in[i].name.len != 0; i++) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	710 if (ngx_http_proxy_headers_in[i].name.len != h->key.len) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	711 continue;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	712 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	713
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	714 if (ngx_strcasecmp(ngx_http_proxy_headers_in[i].name.data,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	715 h->key.data) == 0)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	716 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	717 ((ngx_table_elt_t ) ((char ) &p->upstream->headers_in
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	718 + ngx_http_proxy_headers_in[i].offset)) = h;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	719 break;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	720 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	721 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	722
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	723 ngx_log_debug(c->log, "HTTP proxy header: '%s: %s'" _
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	724 h->key.data _ h->value.data);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	725
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	726 continue;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	727
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	728 } else if (rc == NGX_HTTP_PARSE_HEADER_DONE) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	729
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	730 /* a whole header has been parsed successfully */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	731
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	732 ngx_log_debug(c->log, "HTTP header done");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	733
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	734 ngx_http_proxy_process_upstream_header(p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	735 ngx_http_proxy_send_response(p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	736 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	737
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	738 } else if (rc != NGX_AGAIN) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	739
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	740 /* there was error while a header line parsing */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	741
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	742 ngx_log_error(NGX_LOG_ERR, rev->log, 0,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	743 upstream_header_errors[rc - NGX_HTTP_PARSE_HEADER_ERROR]);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	744
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	745 ngx_http_proxy_next_upstream(p, NGX_HTTP_PROXY_FT_INVALID_HEADER);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	746 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	747 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	748
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	749 /* rc == NGX_AGAIN: a header line parsing is still not complete */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	750
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	751 if (p->header_in->last == p->header_in->end) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	752 ngx_log_error(NGX_LOG_ERR, rev->log, 0,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	753 "upstream sent too big header");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	754
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	755 ngx_http_proxy_next_upstream(p, NGX_HTTP_PROXY_FT_INVALID_HEADER);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	756 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	757 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	758 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	759 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	760
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	761
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	762 static void ngx_http_proxy_process_upstream_header(ngx_http_proxy_ctx_t *p)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	763 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	764 time_t expires;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	765
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	766 expires = ngx_http_parse_time(p->upstream->headers_in.expires->value.data,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	767 p->upstream->headers_in.expires->value.len);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	768
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	769 p->cache->ctx.header.expires = expires;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	770 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	771
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	772
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	773 static ssize_t ngx_http_proxy_read_upstream_header(ngx_http_proxy_ctx_t *p)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	774 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	775 ssize_t n;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	776 ngx_event_t *rev;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	777
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	778 rev = p->upstream->peer.connection->read;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	779
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	780 n = p->header_in->last - p->header_in->pos;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	781
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	782 if (n > 0) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	783 return n;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	784 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	785
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	786 n = ngx_recv(p->upstream->peer.connection, p->header_in->last,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	787 p->header_in->end - p->header_in->last);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	788
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	789 if (n == NGX_AGAIN) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	790 ngx_add_timer(rev, p->lcf->read_timeout);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	791
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	792 if (ngx_handle_read_event(rev, 0) == NGX_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	793 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	794 return NGX_ERROR;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	795 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	796
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	797 return NGX_AGAIN;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	798 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	799
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	800 if (n == 0) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	801 ngx_log_error(NGX_LOG_ERR, rev->log, 0,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	802 "upstream closed prematurely connection");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	803 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	804
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	805 if (n == 0 \|\| n == NGX_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	806 return NGX_ERROR;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	807 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	808
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	809 p->header_in->last += n;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	810
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	811 return n;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	812 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	813
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	814
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	815 static void ngx_http_proxy_send_response(ngx_http_proxy_ctx_t *p)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	816 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	817 int rc, i;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	818 ngx_table_elt_t ho, h;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	819 ngx_event_pipe_t *ep;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	820 ngx_http_request_t *r;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	821 ngx_http_cache_file_t *header;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	822 ngx_http_core_loc_conf_t *clcf;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	823
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	824 r = p->request;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	825
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	826 r->headers_out.status = p->upstream->status;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	827
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	828 #if 0
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	829 r->headers_out.content_length_n = -1;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	830 r->headers_out.content_length = NULL;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	831 #endif
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	832
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	833 /* copy an upstream header to r->headers_out */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	834
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	835 if (ngx_http_proxy_copy_header(p, &p->upstream->headers_in) == NGX_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	836 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	837 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	838 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	839
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	840 /* TODO: preallocate event_pipe hunks, look "Content-Length" */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	841
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	842 rc = ngx_http_send_header(r);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	843
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	844 p->header_sent = 1;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	845
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	846 if (p->cache) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	847 header = (ngx_http_cache_file_t *) p->header_in->start;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	848
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	849 /* STUB */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	850 header->header.expires = 0;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	851 header->header.last_modified = 0;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	852
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	853 header->header.length = r->headers_out.content_length_n;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	854 header->key_len = p->cache->ctx.key.len;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	855 ngx_memcpy(&header->key, p->cache->ctx.key.data, header->key_len);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	856 header->key[header->key_len] = LF;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	857 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	858
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	859 ep = ngx_pcalloc(r->pool, sizeof(ngx_event_pipe_t));
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	860 if (ep == NULL) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	861 ngx_http_proxy_finalize_request(p, 0);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	862 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	863 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	864
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	865 p->upstream->event_pipe = ep;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	866
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	867 ep->input_filter = ngx_event_pipe_copy_input_filter;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	868 ep->output_filter = (ngx_event_pipe_output_filter_pt)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	869 ngx_http_output_filter;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	870 ep->output_ctx = r;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	871 ep->tag = (ngx_hunk_tag_t) &ngx_http_proxy_module;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	872 ep->bufs = p->lcf->bufs;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	873 ep->busy_size = p->lcf->busy_buffers_size;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	874 ep->upstream = p->upstream->peer.connection;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	875 ep->downstream = r->connection;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	876 ep->pool = r->pool;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	877 ep->log = r->connection->log;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	878
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	879 if (!(ep->temp_file = ngx_pcalloc(r->pool, sizeof(ngx_temp_file_t)))) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	880 ngx_http_proxy_finalize_request(p, 0);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	881 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	882 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	883
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	884 ep->temp_file->file.fd = NGX_INVALID_FILE;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	885 ep->temp_file->file.log = r->connection->log;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	886 ep->temp_file->path = p->lcf->temp_path;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	887 ep->temp_file->pool = r->pool;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	888 ep->temp_file->warn = "an upstream response is buffered "
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	889 "to a temporary file";
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	890
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	891 ep->max_temp_file_size = p->lcf->max_temp_file_size;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	892 ep->temp_file_write_size = p->lcf->temp_file_write_size;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	893
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	894 ep->preread_hunks = ngx_alloc_chain_link(r->pool);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	895 if (ep->preread_hunks == NULL) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	896 ngx_http_proxy_finalize_request(p, 0);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	897 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	898 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	899 ep->preread_hunks->hunk = p->header_in;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	900 ep->preread_hunks->next = NULL;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	901 p->header_in->type \|= NGX_HUNK_PREREAD;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	902
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	903 ep->preread_size = p->header_in->last - p->header_in->pos;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	904
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	905 if (ngx_event_flags & NGX_USE_AIO_EVENT) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	906
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	907 /* the posted aio operation can currupt shadow buf */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	908 ep->single_buf = 1;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	909 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	910
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	911 /* TODO: ep->free_bufs = 0 if use ngx_create_chain_of_hunks() */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	912 ep->free_bufs = 1;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	913
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	914 /*
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	915 * event_pipe would do p->header_in->last += ep->preread_size
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	916 * as though these bytes were read.
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	917 */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	918 p->header_in->last = p->header_in->pos;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	919
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	920 ep->cachable = p->cachable;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	921
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	922 if (p->lcf->cyclic_temp_file) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	923
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	924 /*
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	925 * we need to disable the use of sendfile() if we use cyclic temp file
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	926 * because the writing a new data can interfere with sendfile()
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	927 * that uses the same kernel file pages (at least on FreeBSD)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	928 */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	929
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	930 ep->cyclic_temp_file = 1;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	931 r->sendfile = 0;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	932
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	933 } else {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	934 ep->cyclic_temp_file = 0;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	935 r->sendfile = 1;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	936 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	937
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	938 clcf = ngx_http_get_module_loc_conf(r, ngx_http_core_module);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	939
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	940 ep->read_timeout = p->lcf->read_timeout;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	941 ep->send_timeout = clcf->send_timeout;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	942 ep->send_lowat = clcf->send_lowat;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	943
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	944 p->upstream->peer.connection->read->event_handler =
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	945 ngx_http_proxy_process_body;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	946 r->connection->write->event_handler = ngx_http_proxy_process_body;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	947
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	948 ngx_http_proxy_process_body(p->upstream->peer.connection->read);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	949
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	950 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	951 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	952
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	953
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	954 static void ngx_http_proxy_process_body(ngx_event_t *ev)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	955 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	956 ngx_connection_t *c;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	957 ngx_http_request_t *r;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	958 ngx_http_proxy_ctx_t *p;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	959 ngx_event_pipe_t *ep;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	960
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	961 c = ev->data;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	962
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	963 if (ev->write) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	964 ngx_log_debug(ev->log, "http proxy process downstream");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	965 r = c->data;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	966 p = ngx_http_get_module_ctx(r, ngx_http_proxy_module);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	967 p->action = "sending to client";
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	968
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	969 } else {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	970 ngx_log_debug(ev->log, "http proxy process upstream");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	971 p = c->data;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	972 r = p->request;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	973 p->action = "reading upstream body";
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	974 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	975
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	976 ep = p->upstream->event_pipe;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	977
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	978 if (ev->timedout) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	979 if (ev->write) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	980 ep->downstream_error = 1;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	981 ngx_log_error(NGX_LOG_ERR, c->log, NGX_ETIMEDOUT,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	982 "client timed out");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	983
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	984 } else {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	985 ep->upstream_error = 1;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	986 ngx_log_error(NGX_LOG_ERR, c->log, NGX_ETIMEDOUT,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	987 "upstream timed out");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	988 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	989
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	990 } else {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	991 if (ngx_event_pipe(ep, ev->write) == NGX_ABORT) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	992 ngx_http_proxy_finalize_request(p, 0);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	993 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	994 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	995 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	996
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	997 if (p->upstream->peer.connection) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	998 if (ep->upstream_done) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	999 if (ngx_http_proxy_update_cache(p) == NGX_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1000 ngx_http_proxy_finalize_request(p, 0);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1001 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1002 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1003
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1004 } else if (ep->upstream_eof) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1005
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1006 /* TODO: check length & update cache */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1007
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1008 if (ngx_http_proxy_update_cache(p) == NGX_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1009 ngx_http_proxy_finalize_request(p, 0);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1010 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1011 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1012 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1013
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1014 if (ep->upstream_done \|\| ep->upstream_eof \|\| ep->upstream_error) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1015 ngx_http_proxy_close_connection(p->upstream->peer.connection);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1016 p->upstream->peer.connection = NULL;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1017 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1018 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1019
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1020 if (ep->downstream_done) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1021 ngx_log_debug(ev->log, "http proxy downstream done");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1022 ngx_http_proxy_finalize_request(p, r->main ? 0 : ngx_http_send_last(r));
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1023 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1024 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1025
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1026 if (ep->downstream_error) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1027 if (!p->cachable && p->upstream->peer.connection) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1028 ngx_http_proxy_close_connection(p->upstream->peer.connection);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1029 p->upstream->peer.connection = NULL;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1030 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1031
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1032 if (p->upstream->peer.connection == NULL) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1033 ngx_http_close_connection(c);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1034 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1035 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1036
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1037 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1038 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1039
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1040
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1041 static void ngx_http_proxy_next_upstream(ngx_http_proxy_ctx_t *p, int ft_type)
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1042 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1043 int status;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1044
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1045 ngx_log_debug(p->request->connection->log, "next upstream: %d" _ ft_type);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1046
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1047 if (ft_type != NGX_HTTP_PROXY_FT_HTTP_404) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1048 ngx_event_connect_peer_failed(&p->upstream->peer);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1049 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1050
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1051 if (ft_type == NGX_HTTP_PROXY_FT_TIMEOUT) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1052 ngx_log_error(NGX_LOG_ERR, p->request->connection->log, NGX_ETIMEDOUT,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1053 "upstream timed out");
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1054 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1055
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1056 if (p->upstream->peer.cached && ft_type == NGX_HTTP_PROXY_FT_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1057 status = 0;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1058
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1059 } else {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1060 switch(ft_type) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1061 case NGX_HTTP_PROXY_FT_TIMEOUT:
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1062 status = NGX_HTTP_GATEWAY_TIME_OUT;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1063 break;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1064
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1065 case NGX_HTTP_PROXY_FT_HTTP_500:
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1066 status = NGX_HTTP_INTERNAL_SERVER_ERROR;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1067 break;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1068
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1069 case NGX_HTTP_PROXY_FT_HTTP_404:
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1070 status = NGX_HTTP_NOT_FOUND;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1071 break;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1072
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1073 /*
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1074 * NGX_HTTP_PROXY_FT_BUSY_LOCK and NGX_HTTP_PROXY_FT_MAX_WAITING
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1075 * never reach here
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1076 */
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1077
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1078 default:
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1079 status = NGX_HTTP_BAD_GATEWAY;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1080 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1081 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1082
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1083 if (p->upstream->peer.connection) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1084 ngx_http_proxy_close_connection(p->upstream->peer.connection);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1085 p->upstream->peer.connection = NULL;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1086 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1087
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1088 if (status) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1089 if (ngx_http_proxy_log_state(p, status) == NGX_ERROR) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1090 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1091 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1092 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1093
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1094 if (p->upstream->peer.tries == 0 \|\| !(p->lcf->next_upstream & ft_type))
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1095 {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1096 if (p->stale && (p->lcf->use_stale & ft_type)) {
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1097 ngx_http_proxy_finalize_request(p,
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1098 ngx_http_proxy_send_cached_response(p));
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1099 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1100 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1101
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1102 ngx_http_proxy_finalize_request(p, status);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1103 return;
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1104 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1105 }
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1106
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1107 ngx_http_proxy_connect(p);
aff0e5d32af8 nginx-0.0.1-2003-11-03-20:33:31 import Igor Sysoev <igor@sysoev.ru> parents: 170 diff changeset	1108 }

Mercurial > hg > nginx

annotate src/http/modules/proxy/ngx_http_proxy_upstream.c @ 171:aff0e5d32af8