mirror/nginx
1
0
Fork 0
mirror of https://github.com/nginx/nginx.git synced 2024-11-24 13:49:05 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

nginx-0.0.1-2003-10-08-08:34:07 import

Browse Source
This commit is contained in:
Igor Sysoev 2003-10-08 04:34:07 +00:00
parent 931a400cf1
commit fd3e374a02
3 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/event/ngx_event_connect.c
View File

@ -161,6 +161,7 @@ int ngx_event_connect_peer(ngx_peer_connection_t *pc)
rev->data = wev->data = c;
c->read = rev;
c->write = wev;
wev->write = 1;
rev->instance = wev->instance = !instance;

6
src/event/ngx_event_proxy.c
View File

@ -9,7 +9,7 @@
#if (NGX_EVENT_COPY_FILTER)
static int ngx_event_proxy_copy_input_filter(ngx_event_proxy_t *p,
ngx_chain_t *chain);
ngx_chain_t *chain);
#endif
@ -109,7 +109,7 @@ ngx_log_debug(p->log, "new hunk: %08X" _ chain->hunk);
ngx_log_debug(p->log, "file hunk: %08X" _ chain->hunk _
chain->hunk->end - chain->hunk->last);
/* if the hunks is not needed to be saved in a cache and
/* if the hunks are not needed to be saved in a cache and
a downstream is ready then write the hunks to a downstream */
} else if (p->cachable == 0 && p->downstream->write->ready) {
@ -709,7 +709,7 @@ ngx_log_debug(p->log, "event proxy file hunk: %08X:%08X" _ h _ h->shadow);
/* the copy input filter */
static int ngx_event_proxy_copy_input_filter(ngx_event_proxy_t *p,
ngx_chain_t *chain)
ngx_chain_t *chain)
{
ngx_hunk_t *h;
ngx_chain_t *entry, *temp;

17
src/http/modules/proxy/ngx_http_proxy_handler.c
View File

@ -779,12 +779,25 @@ static void ngx_http_proxy_process_upstream_body(ngx_event_t *rev)
ngx_log_debug(rev->log, "http proxy process upstream body");
if (rev->timedout) {
ngx_http_proxy_next_upstream(p);
ngx_http_proxy_close_connection(p->upstream.connection);
p->upstream.connection = NULL;
return;
}
ngx_event_proxy_read_upstream(p->event_proxy);
if (p->event_proxy->upstream_eof) {
ngx_http_proxy_close_connection(p->upstream.connection);
p->upstream.connection = NULL;
return;
}
if (p->event_proxy->upstream_error) {
ngx_http_proxy_close_connection(p->upstream.connection);
p->upstream.connection = NULL;
return;
}
return;
}
@ -1043,6 +1056,8 @@ static void ngx_http_proxy_close_connection(ngx_connection_t *c)
c->write->timer_set = 0;
}
/* TODO: move connection to the connection pool */
if (ngx_del_conn) {
ngx_del_conn(c);