diff options
| author | Max Romanov <max.romanov@nginx.com> | 2017-06-23 19:19:41 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2017-06-23 19:19:41 +0300 |
| commit | e5fe254e1e741f24d53f5199cc4f187efd6a9924 (patch) | |
| tree | 181f9da2aa94db48c665868fa3291b2fa1de2b03 /src/nxt_port.c | |
| parent | 89ab9a9d054f6bca745cbd91cffa9572672a7110 (diff) | |
| download | unit-e5fe254e1e741f24d53f5199cc4f187efd6a9924.tar.gz unit-e5fe254e1e741f24d53f5199cc4f187efd6a9924.tar.bz2 | |
nxt_port_create() use task instead of thread.
Write socket close() call moved out from nxt_port_create().
Diffstat (limited to '')
| -rw-r--r-- | src/nxt_port.c | 7 |
1 files changed, 3 insertions, 4 deletions
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); } |