nxt_port_buf_completion() and nxt_sendbuf_completion().

nxt_sendbuf_completion() has been renamed to nxt_port_buf_completion()
and moved to src/nxt_port_socket.c.  nxt_sendbuf_completion0() has been
renamed to nxt_sendbuf_completion().

1 files changed, 1 insertions, 62 deletions

diff --git a/src/nxt_sendbuf.c b/src/nxt_sendbuf.c
index 704236ca..ed6fca36 100644
--- a/src/nxt_sendbuf.c
+++ b/src/nxt_sendbuf.c
@@ -376,68 +376,7 @@ nxt_sendbuf_update(nxt_buf_t *b, size_t sent)
 
 
 nxt_buf_t *
-nxt_sendbuf_completion(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b,
-    size_t sent, nxt_bool_t mmap_mode)
-{
-    size_t  size;
-
-    while (b != NULL) {
-
-        nxt_prefetch(b->next);
-
-        if (!nxt_buf_is_sync(b)) {
-
-            size = nxt_buf_used_size(b);
-
-            if (size != 0) {
-
-                if (sent == 0) {
-                    break;
-                }
-
-                if (nxt_buf_is_port_mmap(b) && mmap_mode) {
-                    /*
-                     * buffer has been sent to other side which is now
-                     * responsible for shared memory bucket release
-                     */
-                    b->is_port_mmap_sent = 1;
-                }
-
-                if (sent < size) {
-
-                    if (nxt_buf_is_mem(b)) {
-                        b->mem.pos += sent;
-                    }
-
-                    if (nxt_buf_is_file(b)) {
-                        b->file_pos += sent;
-                    }
-
-                    break;
-                }
-
-                /* b->mem.free is NULL in file-only buffer. */
-                b->mem.pos = b->mem.free;
-
-                if (nxt_buf_is_file(b)) {
-                    b->file_pos = b->file_end;
-                }
-
-                sent -= size;
-            }
-        }
-
-        nxt_work_queue_add(wq, b->completion_handler, task, b, b->parent);
-
-        b = b->next;
-    }
-
-    return b;
-}
-
-
-nxt_buf_t *
-nxt_sendbuf_completion0(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b)
+nxt_sendbuf_completion(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b)
 {
     while (b != NULL) {