diff options
| author | Igor Sysoev <igor@sysoev.ru> | 2017-02-22 15:09:59 +0300 |
|---|---|---|
| committer | Igor Sysoev <igor@sysoev.ru> | 2017-02-22 15:09:59 +0300 |
| commit | 029942f4eb7196c2cff0d0e26bc6ff274138f7d8 (patch) | |
| tree | f4686c4d7b9cd574fe94c6f4918479a580fecf75 /src/nxt_worker_process.c | |
| parent | 059a8642898a6bd4b47d13a1c1d599cd44af7e1c (diff) | |
| download | unit-029942f4eb7196c2cff0d0e26bc6ff274138f7d8.tar.gz unit-029942f4eb7196c2cff0d0e26bc6ff274138f7d8.tar.bz2 | |
I/O operations refactoring.
Diffstat (limited to 'src/nxt_worker_process.c')
| -rw-r--r-- | src/nxt_worker_process.c | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/nxt_worker_process.c b/src/nxt_worker_process.c index 0f5f6eb6..01304f65 100644 --- a/src/nxt_worker_process.c +++ b/src/nxt_worker_process.c @@ -86,11 +86,9 @@ nxt_worker_process_start(void *data) goto fail; } -#if 0 - if (nxt_cycle_listen_sockets_enable(thr, cycle) != NXT_OK) { + if (nxt_cycle_listen_sockets_enable(&thr->engine->task, cycle) != NXT_OK) { goto fail; } -#endif proc = cycle->processes->elts; @@ -159,7 +157,7 @@ nxt_worker_process_quit(nxt_task_t *task) n = cycle->listen_sockets->nelts; while (n != 0) { - nxt_socket_close(ls->socket); + nxt_socket_close(task, ls->socket); ls->socket = -1; ls++; |