Mercurial > hg > nginx-quic

comparison src/http/ngx_http_request.c @ 257:70e1c7d2b83d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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 }