diff options
Diffstat (limited to '')
| -rw-r--r-- | src/nxt_event_conn_accept.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/nxt_event_conn_accept.c b/src/nxt_event_conn_accept.c index a1339235..27b5ac27 100644 --- a/src/nxt_event_conn_accept.c +++ b/src/nxt_event_conn_accept.c @@ -50,7 +50,7 @@ nxt_event_conn_listen(nxt_task_t *task, nxt_listen_socket_t *ls) cls->socket.read_work_queue = &engine->accept_work_queue; } else { - cls->socket.read_work_queue = &task->thread->work_queue.main; + cls->socket.read_work_queue = &engine->fast_work_queue; cls->batch = 1; } @@ -62,7 +62,7 @@ nxt_event_conn_listen(nxt_task_t *task, nxt_listen_socket_t *ls) cls->listen = ls; - cls->timer.work_queue = &task->thread->work_queue.main; + cls->timer.work_queue = &engine->fast_work_queue; cls->timer.handler = nxt_event_conn_listen_timer_handler; cls->timer.log = &nxt_main_log; @@ -221,15 +221,15 @@ nxt_event_conn_accept(nxt_task_t *task, nxt_event_conn_listen_t *cls, c->listen->handler(task, c, NULL); } else { - nxt_thread_work_queue_add(task->thread, c->write_work_queue, - c->listen->handler, task, c, NULL); + nxt_work_queue_add(c->write_work_queue, c->listen->handler, + task, c, NULL); } next = nxt_event_conn_accept_next(task, cls); if (next != NULL && cls->socket.read_ready) { - nxt_thread_work_queue_add(task->thread, cls->socket.read_work_queue, - cls->accept, task, cls, next); + nxt_work_queue_add(cls->socket.read_work_queue, + cls->accept, task, cls, next); } } |