aboutsummaryrefslogtreecommitdiff
path: root/src/mail/ngx_mail_handler.c
diff options
context:
space:
mode:
authorMaxim Dounin <mdounin@mdounin.ru>2014-03-31 21:38:27 +0400
committerMaxim Dounin <mdounin@mdounin.ru>2014-03-31 21:38:27 +0400
commite042fc903883341806366b39a526711b77f5c34b (patch)
tree69107e61ff42079816292b2270bb2dfca7fcd303 /src/mail/ngx_mail_handler.c
parent3183d7e17bdb9784096448168a8f89eeb5658438 (diff)
downloadnginx-e042fc903883341806366b39a526711b77f5c34b.tar.gz
nginx-e042fc903883341806366b39a526711b77f5c34b.zip
Mail: fixed ngx_mail_send() (ticket #519).
Diffstat (limited to 'src/mail/ngx_mail_handler.c')
-rw-r--r--src/mail/ngx_mail_handler.c7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/mail/ngx_mail_handler.c b/src/mail/ngx_mail_handler.c
index 9212a121c..47ddb0dcf 100644
--- a/src/mail/ngx_mail_handler.c
+++ b/src/mail/ngx_mail_handler.c
@@ -559,8 +559,13 @@ ngx_mail_send(ngx_event_t *wev)
n = c->send(c, s->out.data, s->out.len);
if (n > 0) {
+ s->out.data += n;
s->out.len -= n;
+ if (s->out.len != 0) {
+ goto again;
+ }
+
if (wev->timer_set) {
ngx_del_timer(wev);
}
@@ -584,6 +589,8 @@ ngx_mail_send(ngx_event_t *wev)
/* n == NGX_AGAIN */
+again:
+
cscf = ngx_mail_get_module_srv_conf(s, ngx_mail_core_module);
ngx_add_timer(c->write, cscf->timeout);