diff options
Diffstat (limited to '')
| -rw-r--r-- | src/nxt_event_conn.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/nxt_event_conn.c b/src/nxt_event_conn.c index b78a9251..079901f3 100644 --- a/src/nxt_event_conn.c +++ b/src/nxt_event_conn.c @@ -21,7 +21,7 @@ nxt_event_conn_io_t nxt_unix_event_conn_io = { nxt_event_conn_io_recvbuf, nxt_event_conn_io_recv, - nxt_event_conn_io_write, + nxt_conn_io_write, nxt_event_conn_io_write_chunk, #if (NXT_HAVE_LINUX_SENDFILE) @@ -48,7 +48,7 @@ nxt_event_conn_io_t nxt_unix_event_conn_io = { nxt_event_conn_t * -nxt_event_conn_create(nxt_mem_pool_t *mp, nxt_log_t *log) +nxt_event_conn_create(nxt_mem_pool_t *mp, nxt_task_t *task) { nxt_thread_t *thr; nxt_event_conn_t *c; @@ -63,7 +63,7 @@ nxt_event_conn_create(nxt_mem_pool_t *mp, nxt_log_t *log) c->socket.fd = -1; c->socket.log = &c->log; - c->log = *log; + c->log = *task->log; /* The while loop skips possible uint32_t overflow. */ @@ -185,7 +185,7 @@ nxt_conn_shutdown_handler(nxt_task_t *task, void *obj, void *data) c->socket.shutdown = 1; - nxt_socket_shutdown(c->socket.fd, SHUT_RDWR); + nxt_socket_shutdown(task, c->socket.fd, SHUT_RDWR); nxt_work_queue_add(&engine->close_work_queue, nxt_conn_close_handler, task, c, engine); @@ -210,7 +210,7 @@ nxt_conn_close_handler(nxt_task_t *task, void *obj, void *data) events_pending = nxt_fd_event_close(engine, &c->socket); if (events_pending == 0) { - nxt_socket_close(c->socket.fd); + nxt_socket_close(task, c->socket.fd); c->socket.fd = -1; if (timers_pending == 0) { @@ -242,7 +242,7 @@ nxt_conn_close_timer_handler(nxt_task_t *task, void *obj, void *data) nxt_debug(task, "event conn close handler fd:%d", c->socket.fd); if (c->socket.fd != -1) { - nxt_socket_close(c->socket.fd); + nxt_socket_close(task, c->socket.fd); c->socket.fd = -1; } |