diff options
Diffstat (limited to 'src/nxt_sendbuf.c')
| -rw-r--r-- | src/nxt_sendbuf.c | 14 |
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; } |