Mercurial > hg > nginx-quic
comparison src/event/ngx_event_pipe.c @ 188:0061d1f0908d
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 |