Introducing tasks.

1 files changed, 7 insertions, 7 deletions

diff --git a/src/nxt_sendbuf.c b/src/nxt_sendbuf.c
index d473a29b..e8a4c190 100644
--- a/src/nxt_sendbuf.c
+++ b/src/nxt_sendbuf.c
@@ -12,7 +12,7 @@ static nxt_bool_t nxt_sendbuf_copy(nxt_buf_mem_t *bm, nxt_buf_t *b,
 
 
 nxt_uint_t
-nxt_sendbuf_mem_coalesce(nxt_sendbuf_coalesce_t *sb)
+nxt_sendbuf_mem_coalesce(nxt_task_t *task, nxt_sendbuf_coalesce_t *sb)
 {
     u_char      *last;
     size_t      size, total;
@@ -57,9 +57,9 @@ nxt_sendbuf_mem_coalesce(nxt_sendbuf_coalesce_t *sb)
                     nxt_iobuf_add(&sb->iobuf[n], size);
                 }
 
-                nxt_thread_log_debug("sendbuf: %ui, %p, %uz", n,
-                                     nxt_iobuf_data(&sb->iobuf[n]),
-                                     nxt_iobuf_size(&sb->iobuf[n]));
+                nxt_debug(task, "sendbuf: %ui, %p, %uz", n,
+                          nxt_iobuf_data(&sb->iobuf[n]),
+                          nxt_iobuf_size(&sb->iobuf[n]));
 
                 total += size;
                 last = b->mem.pos + size;
@@ -300,7 +300,7 @@ nxt_sendbuf_update(nxt_buf_t *b, size_t sent)
 
 
 nxt_buf_t *
-nxt_sendbuf_completion(nxt_thread_t *thr, 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,
     size_t sent)
 {
     size_t  size;
@@ -343,8 +343,8 @@ nxt_sendbuf_completion(nxt_thread_t *thr, nxt_work_queue_t *wq, nxt_buf_t *b,
             }
         }
 
-        nxt_thread_work_queue_add(thr, wq, b->completion_handler,
-                                  b, b->parent, thr->log);
+        nxt_thread_work_queue_add(task->thread, wq, b->completion_handler, task,
+                                  b, b->parent);
 
         b = b->next;
     }