Mercurial > hg > nginx-quic
comparison src/http/ngx_http_request.c @ 257:70e1c7d2b83d
nginx-0.0.2-2004-02-11-20:08:49 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Wed, 11 Feb 2004 17:08:49 +0000 |
parents | 8e39cab6abd5 |
children | 733dffa1fe97 |
comparison
equal
deleted
inserted
replaced
256:8e39cab6abd5 | 257:70e1c7d2b83d |
---|---|
82 c->log_error = NGX_ERROR_INFO; | 82 c->log_error = NGX_ERROR_INFO; |
83 | 83 |
84 rev = c->read; | 84 rev = c->read; |
85 rev->event_handler = ngx_http_init_request; | 85 rev->event_handler = ngx_http_init_request; |
86 | 86 |
87 /* STUB: epoll */ c->write->event_handler = ngx_http_empty_handler; | 87 /* STUB: epoll edge */ c->write->event_handler = ngx_http_empty_handler; |
88 | 88 |
89 if (rev->ready) { | 89 if (rev->ready) { |
90 /* deferred accept, aio, iocp, epoll */ | 90 /* deferred accept, aio, iocp, epoll */ |
91 ngx_http_init_request(rev); | 91 ngx_http_init_request(rev); |
92 return; | 92 return; |
1178 ngx_http_close_connection(c); | 1178 ngx_http_close_connection(c); |
1179 return; | 1179 return; |
1180 } | 1180 } |
1181 | 1181 |
1182 h = c->buffer; | 1182 h = c->buffer; |
1183 wev = c->write; | |
1184 wev->event_handler = ngx_http_empty_handler; | |
1183 | 1185 |
1184 if (h->pos < h->last) { | 1186 if (h->pos < h->last) { |
1185 | 1187 |
1186 /* | 1188 /* |
1187 * Pipelined request. | 1189 * Pipelined request. |
1212 | 1214 |
1213 c->pipeline = 0; | 1215 c->pipeline = 0; |
1214 | 1216 |
1215 h->pos = h->last = h->start; | 1217 h->pos = h->last = h->start; |
1216 rev->event_handler = ngx_http_keepalive_handler; | 1218 rev->event_handler = ngx_http_keepalive_handler; |
1217 wev = c->write; | |
1218 wev->event_handler = ngx_http_empty_handler; | |
1219 | 1219 |
1220 if (wev->active) { | 1220 if (wev->active) { |
1221 if (ngx_event_flags & NGX_HAVE_KQUEUE_EVENT) { | 1221 if (ngx_event_flags & NGX_HAVE_KQUEUE_EVENT) { |
1222 if (ngx_del_event(wev, NGX_WRITE_EVENT, NGX_DISABLE_EVENT) | 1222 if (ngx_del_event(wev, NGX_WRITE_EVENT, NGX_DISABLE_EVENT) |
1223 == NGX_ERROR) | 1223 == NGX_ERROR) |
1520 | 1520 |
1521 | 1521 |
1522 void ngx_http_close_connection(ngx_connection_t *c) | 1522 void ngx_http_close_connection(ngx_connection_t *c) |
1523 { | 1523 { |
1524 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, | 1524 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, |
1525 "close connection: %d", c->fd); | 1525 "close http connection: %d", c->fd); |
1526 | 1526 |
1527 if (c->pool == NULL) { | 1527 if (c->pool == NULL) { |
1528 ngx_log_error(NGX_LOG_ALERT, c->log, 0, "connection already closed"); | 1528 ngx_log_error(NGX_LOG_ALERT, c->log, 0, "connection already closed"); |
1529 return; | 1529 return; |
1530 } | 1530 } |