diff options
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); } } |