From de532922d9ab42aa15b40d47c8db53ac2af38500 Mon Sep 17 00:00:00 2001 From: Igor Sysoev Date: Mon, 23 Jan 2017 19:56:03 +0300 Subject: Introducing tasks. --- src/nxt_http_chunk_parse.c | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'src/nxt_http_chunk_parse.c') diff --git a/src/nxt_http_chunk_parse.c b/src/nxt_http_chunk_parse.c index c0402605..1c9cd190 100644 --- a/src/nxt_http_chunk_parse.c +++ b/src/nxt_http_chunk_parse.c @@ -22,12 +22,12 @@ static nxt_int_t nxt_http_chunk_buffer(nxt_http_chunk_parse_t *hcp, nxt_buf_t * -nxt_http_chunk_parse(nxt_http_chunk_parse_t *hcp, nxt_buf_t *in) +nxt_http_chunk_parse(nxt_task_t *task, nxt_http_chunk_parse_t *hcp, + nxt_buf_t *in) { u_char c, ch; nxt_int_t ret; nxt_buf_t *b, *out, *nb, **tail; - nxt_thread_t *thr; enum { sw_start = 0, sw_chunk_size, @@ -168,9 +168,9 @@ nxt_http_chunk_parse(nxt_http_chunk_parse_t *hcp, nxt_buf_t *in) if (b->retain == 0) { /* No chunk data was found in a buffer. */ - thr = nxt_thread(); - nxt_thread_current_work_queue_add(thr, b->completion_handler, - b, b->parent, thr->log); + nxt_thread_current_work_queue_add(task->thread, + b->completion_handler, + task, b, b->parent); } -- cgit