diff options
| author | Igor Sysoev <igor@sysoev.ru> | 2017-01-27 11:35:11 +0300 |
|---|---|---|
| committer | Igor Sysoev <igor@sysoev.ru> | 2017-01-27 11:35:11 +0300 |
| commit | ba0391577b06446307fa073f856f57748557e0dd (patch) | |
| tree | b2b871a041edee242662c95197bed292531c3a9a /src/nxt_cycle.c | |
| parent | 6886b83c1f3bfdc514d58ad6e9ab40873cafcb54 (diff) | |
| download | unit-ba0391577b06446307fa073f856f57748557e0dd.tar.gz unit-ba0391577b06446307fa073f856f57748557e0dd.tar.bz2 | |
Work queues refactoring.
Diffstat (limited to 'src/nxt_cycle.c')
| -rw-r--r-- | src/nxt_cycle.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/nxt_cycle.c b/src/nxt_cycle.c index 4b6eeb40..4b19f9da 100644 --- a/src/nxt_cycle.c +++ b/src/nxt_cycle.c @@ -153,8 +153,8 @@ nxt_cycle_create(nxt_thread_t *thr, nxt_task_t *task, nxt_cycle_t *previous, nxt_log_debug(thr->log, "new cycle: %p", cycle); - nxt_thread_work_queue_add(thr, &thr->work_queue.main, nxt_cycle_start, - task, cycle, NULL); + nxt_work_queue_add(&thr->engine->fast_work_queue, nxt_cycle_start, + task, cycle, NULL); return NXT_OK; @@ -583,8 +583,8 @@ nxt_cycle_quit(nxt_task_t *task, nxt_cycle_t *cycle) nxt_cycle_close_idle_connections(thr, task); if (done) { - nxt_thread_work_queue_add(thr, &thr->work_queue.main, nxt_cycle_exit, - task, cycle, NULL); + nxt_work_queue_add(&thr->engine->fast_work_queue, nxt_cycle_exit, + task, cycle, NULL); } } |