Mercurial > hg > nginx

comparison src/http/modules/proxy/ngx_http_proxy_upstream.c @ 191:71ce40b3c37b

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.1-2003-11-19-19:26:41 import
author Igor Sysoev <igor@sysoev.ru>
date Wed, 19 Nov 2003 16:26:41 +0000
parents 02a715e85df1
children 2357fa41738a
comparison
equal deleted inserted replaced
190:02a715e85df1 191:71ce40b3c37b
208 208
209 static void ngx_http_proxy_init_upstream(void *data) 209 static void ngx_http_proxy_init_upstream(void *data)
210 { 210 {
211 ngx_http_proxy_ctx_t *p = data; 211 ngx_http_proxy_ctx_t *p = data;
212 212
213 ngx_chain_t *cl; 213 ngx_chain_t *cl;
214 ngx_http_request_t *r; 214 ngx_http_request_t *r;
215 ngx_output_chain_ctx_t *octx; 215 ngx_output_chain_ctx_t *octx;
216 ngx_chain_writer_ctx_t *wctx; 216 ngx_chain_writer_ctx_t *wctx;
217 ngx_http_proxy_log_ctx_t *lctx;
217 218
218 r = p->request; 219 r = p->request;
219 220
220 ngx_log_debug(r->connection->log, "timer_set: %d" _ 221 ngx_log_debug(r->connection->log, "timer_set: %d" _
221 r->connection->read->timer_set); 222 r->connection->read->timer_set);
250 cl->next = r->request_hunks; 251 cl->next = r->request_hunks;
251 } 252 }
252 253
253 r->request_hunks = cl; 254 r->request_hunks = cl;
254 255
256 if (!(lctx = ngx_pcalloc(r->pool, sizeof(ngx_http_proxy_log_ctx_t)))) {
257 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);
258 return;
259 }
260 lctx->connection = r->connection->number;
261 lctx->proxy = p;
262
255 p->upstream->peer.log = r->connection->log; 263 p->upstream->peer.log = r->connection->log;
256 p->saved_ctx = r->connection->log->data; 264 p->saved_ctx = r->connection->log->data;
257 p->saved_handler = r->connection->log->handler; 265 p->saved_handler = r->connection->log->handler;
258 r->connection->log->data = p; 266 r->connection->log->data = lctx;
259 r->connection->log->handler = ngx_http_proxy_log_error; 267 r->connection->log->handler = ngx_http_proxy_log_error;
260 p->action = "connecting to upstream"; 268 p->action = "connecting to upstream";
261 269
262 if (!(octx = ngx_pcalloc(r->pool, sizeof(ngx_output_chain_ctx_t)))) { 270 if (!(octx = ngx_pcalloc(r->pool, sizeof(ngx_output_chain_ctx_t)))) {
263 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR); 271 ngx_http_proxy_finalize_request(p, NGX_HTTP_INTERNAL_SERVER_ERROR);