From e5fe254e1e741f24d53f5199cc4f187efd6a9924 Mon Sep 17 00:00:00 2001 From: Max Romanov Date: Fri, 23 Jun 2017 19:19:41 +0300 Subject: nxt_port_create() use task instead of thread. Write socket close() call moved out from nxt_port_create(). --- src/nxt_port.c | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) (limited to 'src/nxt_port.c') diff --git a/src/nxt_port.c b/src/nxt_port.c index e23db689..fb4d65a6 100644 --- a/src/nxt_port.c +++ b/src/nxt_port.c @@ -15,16 +15,15 @@ static void nxt_port_new_port_buf_completion(nxt_task_t *task, void *obj, void -nxt_port_create(nxt_thread_t *thread, nxt_port_t *port, +nxt_port_create(nxt_task_t *task, nxt_port_t *port, nxt_port_handler_t *handlers) { port->pid = nxt_pid; - port->engine = thread->engine->id; + port->engine = task->thread->engine->id; port->handler = nxt_port_handler; port->data = handlers; - nxt_port_write_close(port); - nxt_port_read_enable(&thread->engine->task, port); + nxt_port_read_enable(task, port); } -- cgit