From ba0391577b06446307fa073f856f57748557e0dd Mon Sep 17 00:00:00 2001 From: Igor Sysoev Date: Fri, 27 Jan 2017 11:35:11 +0300 Subject: Work queues refactoring. --- src/nxt_cycle.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'src/nxt_cycle.c') 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); } } -- cgit