diff options
author | Igor Sysoev <igor@sysoev.ru> | 2004-09-07 19:29:22 +0400 |
---|---|---|
committer | Igor Sysoev <igor@sysoev.ru> | 2004-09-07 19:29:22 +0400 |
commit | 59cf56c5d975725be9e2adc84170ffe0c638fa48 (patch) | |
tree | d355ce8975bbcacc29cdf54ffac45c84b55649a0 /src/os/unix/ngx_send.c | |
parent | aab4d8c0c4aa068cc7ddcb1c5daee330d9dec47a (diff) |
nginx-0.0.10-2004-09-07-19:29:22 import
Diffstat (limited to 'src/os/unix/ngx_send.c')
-rw-r--r-- | src/os/unix/ngx_send.c | 63 |
1 files changed, 63 insertions, 0 deletions
diff --git a/src/os/unix/ngx_send.c b/src/os/unix/ngx_send.c new file mode 100644 index 000000000..5a1a0ff29 --- /dev/null +++ b/src/os/unix/ngx_send.c @@ -0,0 +1,63 @@ + +#include <ngx_config.h> +#include <ngx_core.h> +#include <ngx_event.h> + + +ssize_t ngx_unix_send(ngx_connection_t *c, u_char *buf, size_t size) +{ + ssize_t n; + ngx_err_t err; + ngx_event_t *wev; + + wev = c->write; + +#if (HAVE_KQUEUE) + + if ((ngx_event_flags & NGX_HAVE_KQUEUE_EVENT) && wev->pending_eof) { + ngx_log_error(NGX_LOG_INFO, c->log, wev->kq_errno, + "kevent() reported about an closed connection"); + + wev->error = 1; + return NGX_ERROR; + } + +#endif + + for ( ;; ) { + n = send(c->fd, buf, size, 0); + + ngx_log_debug3(NGX_LOG_DEBUG_EVENT, c->log, 0, + "send: fd:%d %d of %d", c->fd, n, size); + + if (n > 0) { + if (n < (ssize_t) size) { + wev->ready = 0; + } + + return n; + } + + err = ngx_socket_errno; + + if (n == 0) { + ngx_log_error(NGX_LOG_ALERT, c->log, err, "send() returned zero"); + } + + if (err == NGX_EAGAIN || err == NGX_EINTR) { + wev->ready = 0; + + ngx_log_debug0(NGX_LOG_DEBUG_EVENT, c->log, err, + "send() not ready"); + + if (err == NGX_EAGAIN) { + return NGX_AGAIN; + } + + } else { + wev->error = 1; + ngx_connection_error(c, err, "recv() failed"); + return NGX_ERROR; + } + } +} |