Mercurial > hg > nginx-quic

comparison src/http/ngx_http_request.c @ 194:2357fa41738a

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.1-2003-11-21-09:30:49 import
author Igor Sysoev <igor@sysoev.ru>
date Fri, 21 Nov 2003 06:30:49 +0000
parents 31824be1fc66
children abeaebe0a33c
comparison
equal deleted inserted replaced
193:dd66383796a5 194:2357fa41738a
1114 h->pos = h->last = h->start; 1114 h->pos = h->last = h->start;
1115 rev->event_handler = ngx_http_keepalive_handler; 1115 rev->event_handler = ngx_http_keepalive_handler;
1116 wev = c->write; 1116 wev = c->write;
1117 wev->event_handler = ngx_http_empty_handler; 1117 wev->event_handler = ngx_http_empty_handler;
1118 1118
1119 if ((ngx_event_flags & NGX_USE_LEVEL_EVENT) && wev->active) { 1119 if (wev->active) {
1120 if (ngx_del_event(wev, NGX_WRITE_EVENT, 0) == NGX_ERROR) { 1120 if (ngx_event_flags & NGX_HAVE_KQUEUE_EVENT) {
1121 ngx_http_close_connection(c); 1121 if (ngx_del_event(wev, NGX_WRITE_EVENT, NGX_DISABLE_EVENT)
1122 return; 1122 == NGX_ERROR)
1123 {
1124 ngx_http_close_connection(c);
1125 return;
1126 }
1127
1128 } else if (ngx_event_flags & NGX_USE_LEVEL_EVENT) {
1129 if (ngx_del_event(wev, NGX_WRITE_EVENT, 0) == NGX_ERROR) {
1130 ngx_http_close_connection(c);
1131 return;
1132 }
1123 } 1133 }
1124 } 1134 }
1125 1135
1126 ctx->action = "keepalive"; 1136 ctx->action = "keepalive";
1127 1137
1216 } 1226 }
1217 1227
1218 wev = c->write; 1228 wev = c->write;
1219 wev->event_handler = ngx_http_empty_handler; 1229 wev->event_handler = ngx_http_empty_handler;
1220 1230
1221 if ((ngx_event_flags & NGX_USE_LEVEL_EVENT) && wev->active) { 1231 if (wev->active) {
1222 if (ngx_del_event(wev, NGX_WRITE_EVENT, 0) == NGX_ERROR) { 1232 if (ngx_event_flags & NGX_HAVE_KQUEUE_EVENT) {
1223 ngx_http_close_request(r, 0); 1233 if (ngx_del_event(wev, NGX_WRITE_EVENT, NGX_DISABLE_EVENT)
1224 ngx_http_close_connection(c); 1234 == NGX_ERROR)
1225 return; 1235 {
1236 ngx_http_close_connection(c);
1237 return;
1238 }
1239
1240 } else if (ngx_event_flags & NGX_USE_LEVEL_EVENT) {
1241 if (ngx_del_event(wev, NGX_WRITE_EVENT, 0) == NGX_ERROR) {
1242 ngx_http_close_connection(c);
1243 return;
1244 }
1226 } 1245 }
1227 } 1246 }
1228 1247
1229 if (ngx_shutdown_socket(c->fd, NGX_WRITE_SHUTDOWN) == -1) { 1248 if (ngx_shutdown_socket(c->fd, NGX_WRITE_SHUTDOWN) == -1) {
1230 ngx_log_error(NGX_LOG_CRIT, c->log, ngx_socket_errno, 1249 ngx_log_error(NGX_LOG_CRIT, c->log, ngx_socket_errno,