comparison src/http/modules/proxy/ngx_http_proxy_handler.c @ 375:744ccb59062d

nginx-0.0.7-2004-07-02-19:54:34 import
author Igor Sysoev <igor@sysoev.ru>
date Fri, 02 Jul 2004 15:54:34 +0000
parents 54f76b0b8dca
children 41437e4fd9b4
comparison
equal deleted inserted replaced
374:213f17e9f776 375:744ccb59062d
383 383
384 #if (HAVE_KQUEUE) 384 #if (HAVE_KQUEUE)
385 385
386 if (ngx_event_flags & NGX_HAVE_KQUEUE_EVENT) { 386 if (ngx_event_flags & NGX_HAVE_KQUEUE_EVENT) {
387 387
388 if (!ev->kq_eof) { 388 if (!ev->pending_eof) {
389 return; 389 return;
390 } 390 }
391 391
392 c = ev->data; 392 c = ev->data;
393 r = c->data; 393 r = c->data;
639 639
640 if (ngx_del_conn) { 640 if (ngx_del_conn) {
641 ngx_del_conn(c, NGX_CLOSE_EVENT); 641 ngx_del_conn(c, NGX_CLOSE_EVENT);
642 642
643 } else { 643 } else {
644 if (c->read->active || c->read->posted) { 644 if (c->read->active || c->read->disabled) {
645 ngx_del_event(c->read, NGX_READ_EVENT, NGX_CLOSE_EVENT); 645 ngx_del_event(c->read, NGX_READ_EVENT, NGX_CLOSE_EVENT);
646 } 646 }
647 647
648 if (c->write->active || c->read->posted) { 648 if (c->write->active || c->read->disabled) {
649 ngx_del_event(c->write, NGX_WRITE_EVENT, NGX_CLOSE_EVENT); 649 ngx_del_event(c->write, NGX_WRITE_EVENT, NGX_CLOSE_EVENT);
650 } 650 }
651 } 651 }
652 652
653 if (ngx_close_socket(c->fd) == -1) { 653 if (ngx_close_socket(c->fd) == -1) {