nginx-0.0.1-2002-09-07-14:14:25 import

1 files changed, 16 insertions, 6 deletions

diff --git a/src/os/unix/ngx_sendv.c b/src/os/unix/ngx_sendv.c
index dec16a1bc..409456890 100644
--- a/src/os/unix/ngx_sendv.c
+++ b/src/os/unix/ngx_sendv.c
@@ -1,18 +1,28 @@
 
 #include <ngx_core.h>
 #include <ngx_types.h>
-#include <ngx_socket.h>
+#include <ngx_errno.h>
+#include <ngx_connection.h>
+#include <ngx_log.h>
 #include <ngx_sendv.h>
 
-ssize_t ngx_sendv(ngx_socket_t s, ngx_iovec_t *iovec, int n, size_t *sent)
+ssize_t ngx_sendv(ngx_connection_t *c, ngx_iovec_t *iovec, int n)
 {
      ssize_t rc;
+     ngx_err_t err;
 
-     rc = writev(s, iovec, n);
+     rc = writev(c->fd, iovec, n);
 
-     if (rc == -1)
+     if (rc == -1) {
+         err = ngx_socket_errno;
+         if (err == NGX_EAGAIN) {
+             ngx_log_error(NGX_LOG_INFO, c->log, err, "sendv() eagain");
+             return NGX_AGAIN;
+         }
+
+         ngx_log_error(NGX_LOG_ERR, c->log, err, "sendv() failed");
          return NGX_ERROR;
+     }
 
-     *sent = rc;
-     return NGX_OK;
+     return rc;
 }