diff options
| author | Igor Sysoev <igor@sysoev.ru> | 2017-01-23 19:56:03 +0300 |
|---|---|---|
| committer | Igor Sysoev <igor@sysoev.ru> | 2017-01-23 19:56:03 +0300 |
| commit | de532922d9ab42aa15b40d47c8db53ac2af38500 (patch) | |
| tree | d6b7c6b21c7a6e0e3620a3e0c7198e63454d05e3 /src/nxt_fastcgi_record_parse.c | |
| parent | 16cbf3c076a0aca6d47adaf3f719493674cf2363 (diff) | |
| download | unit-de532922d9ab42aa15b40d47c8db53ac2af38500.tar.gz unit-de532922d9ab42aa15b40d47c8db53ac2af38500.tar.bz2 | |
Introducing tasks.
Diffstat (limited to 'src/nxt_fastcgi_record_parse.c')
| -rw-r--r-- | src/nxt_fastcgi_record_parse.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/nxt_fastcgi_record_parse.c b/src/nxt_fastcgi_record_parse.c index 66b9d4c3..7d2ce32e 100644 --- a/src/nxt_fastcgi_record_parse.c +++ b/src/nxt_fastcgi_record_parse.c @@ -17,13 +17,13 @@ static nxt_int_t nxt_fastcgi_buffer(nxt_fastcgi_parse_t *fp, nxt_buf_t ***tail, void -nxt_fastcgi_record_parse(nxt_fastcgi_parse_t *fp, nxt_buf_t *in) +nxt_fastcgi_record_parse(nxt_task_t *task, nxt_fastcgi_parse_t *fp, + nxt_buf_t *in) { u_char ch; nxt_int_t ret, stream; nxt_buf_t *b, *nb, **tail[2]; const char *msg; - nxt_thread_t *thr; enum { sw_fastcgi_version = 0, sw_fastcgi_type, @@ -208,9 +208,9 @@ nxt_fastcgi_record_parse(nxt_fastcgi_parse_t *fp, nxt_buf_t *in) if (b->retain == 0) { /* No record 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); } next: |