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_source.h | |
| parent | 16cbf3c076a0aca6d47adaf3f719493674cf2363 (diff) | |
| download | unit-de532922d9ab42aa15b40d47c8db53ac2af38500.tar.gz unit-de532922d9ab42aa15b40d47c8db53ac2af38500.tar.bz2 | |
Introducing tasks.
Diffstat (limited to 'src/nxt_source.h')
| -rw-r--r-- | src/nxt_source.h | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/nxt_source.h b/src/nxt_source.h index 23bebb3c..976cc8f9 100644 --- a/src/nxt_source.h +++ b/src/nxt_source.h @@ -23,20 +23,20 @@ typedef void (*nxt_source_handler_t)(void *source_context, #define \ -nxt_source_filter(thr, wq, next, out) \ +nxt_source_filter(thr, wq, task, next, out) \ do { \ if (thr->engine->batch != 0) { \ nxt_thread_work_queue_add(thr, wq, nxt_source_filter_handler, \ - next, out, thr->log); \ + task, next, out); \ \ } else { \ - (next)->filter(thr, (next)->context, out); \ + (next)->filter(task, (next)->context, out); \ } \ \ } while (0) -NXT_EXPORT void nxt_source_filter_handler(nxt_thread_t *thr, void *obj, +NXT_EXPORT void nxt_source_filter_handler(nxt_task_t *task, void *obj, void *data); |