nginx-0.0.1-2003-02-26-23:21:43 import

1 files changed, 92 insertions, 0 deletions

diff --git a/src/os/unix/ngx_aio_write_chain.c b/src/os/unix/ngx_aio_write_chain.c
new file mode 100644
index 000000000..34c4f4016
--- /dev/null
+++ b/src/os/unix/ngx_aio_write_chain.c
@@ -0,0 +1,92 @@
+
+#include <ngx_config.h>
+
+#include <ngx_core.h>
+#include <ngx_types.h>
+#include <ngx_alloc.h>
+#include <ngx_array.h>
+#include <ngx_hunk.h>
+#include <ngx_connection.h>
+#include <ngx_sendv.h>
+#include <ngx_sendfile.h>
+
+
+ngx_chain_t *ngx_aio_write_chain(ngx_connection_t *c, ngx_chain_t *in)
+{
+    int              rc;
+    char            *buf, *prev;
+    off_t            sent;
+    size_t           size;
+    ngx_err_t        err;
+    ngx_chain_t     *ce;
+
+    sent = 0;
+    ce = in;
+
+    while (ce) {
+
+ngx_log_debug(c->log, "aio_write ce: %x" _ ce->hunk->pos.mem);
+
+        buf = prev = ce->hunk->pos.mem;
+        size = 0;
+
+        /* coalesce the neighbouring chain entries */
+        while (ce && prev == ce->hunk->pos.mem) {
+            size += ce->hunk->last.mem - ce->hunk->pos.mem;
+            prev = ce->hunk->last.mem;
+            ce = ce->next;
+        }
+
+        rc = ngx_event_aio_write(c, buf, size);
+
+ngx_log_debug(c->log, "aio_write rc: %d" _ rc);
+
+        if (rc > 0) {
+            sent += rc;
+            c->sent += rc;
+
+        } else if (rc == NGX_ERROR) {
+            return NGX_CHAIN_ERROR;
+
+        } else if (rc == NGX_AGAIN) {
+            break;
+        }
+    }
+
+#if (NGX_DEBUG_WRITE_CHAIN)
+    ngx_log_debug(c->log, "aio_write sent: " OFF_FMT _ c->sent);
+#endif
+
+    for (ce = in; ce; ce = ce->next) {
+
+#if (NGX_DEBUG_WRITE_CHAIN)
+        ngx_log_debug(c->log, "write chain: %x %qx %qd" _
+                      ce->hunk->type _
+                      ce->hunk->pos.file _
+                      ce->hunk->last.file - ce->hunk->pos.file);
+#endif
+
+        if (sent >= ce->hunk->last.file - ce->hunk->pos.file) {
+            sent -= ce->hunk->last.file - ce->hunk->pos.file;
+            ce->hunk->pos.file = ce->hunk->last.file;
+
+#if (NGX_DEBUG_WRITE_CHAIN)
+            ngx_log_debug(c->log, "write chain done: %qx %qd" _
+                          ce->hunk->pos.file _ sent);
+#endif
+            continue;
+        }
+
+        ce->hunk->pos.file += sent;
+
+#if (NGX_DEBUG_WRITE_CHAIN)
+        ngx_log_debug(c->log, "write chain rest: %qx %qd" _
+                      ce->hunk->pos.file _
+                      ce->hunk->last.file - ce->hunk->pos.file);
+#endif
+
+        break;
+    }
+
+    return ce;
+}