Mercurial > hg > nginx

comparison src/event/ngx_event_pipe.c @ 188:0061d1f0908d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.1-2003-11-18-11:04:34 import
author Igor Sysoev <igor@sysoev.ru>
date Tue, 18 Nov 2003 08:04:34 +0000
parents 5a9bbe99008b
children c966c09be66b
comparison
equal deleted inserted replaced
187:5a9bbe99008b 188:0061d1f0908d
51 51
52 if (rev->active) { 52 if (rev->active) {
53 ngx_add_timer(rev, p->read_timeout); 53 ngx_add_timer(rev, p->read_timeout);
54 } 54 }
55 } 55 }
56
57 ngx_log_debug(p->log, "DOWN: %d" _ p->downstream->fd);
56 58
57 if (p->downstream->fd != -1) { 59 if (p->downstream->fd != -1) {
58 wev = p->downstream->write; 60 wev = p->downstream->write;
59 61
60 if (ngx_handle_write_event(wev, p->send_lowat) == NGX_ERROR) { 62 if (ngx_handle_write_event(wev, p->send_lowat) == NGX_ERROR) {
671 ngx_chain_t *cl, *tl; 673 ngx_chain_t *cl, *tl;
672 674
673 for ( ;; ) { 675 for ( ;; ) {
674 if (p->busy) { 676 if (p->busy) {
675 cl = p->busy; 677 cl = p->busy;
678 p->busy = NULL;
676 679
677 } else if (p->out) { 680 } else if (p->out) {
678 cl = p->out; 681 cl = p->out;
682 p->out = NULL;
679 683
680 } else if (p->in) { 684 } else if (p->in) {
681 cl = p->in; 685 cl = p->in;
686 p->in = NULL;
682 687
683 } else { 688 } else {
684 return NGX_OK; 689 return NGX_OK;
685 } 690 }
686 691