diff options
Diffstat (limited to 'src/nxt_event_conn_write.c')
| -rw-r--r-- | src/nxt_event_conn_write.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/nxt_event_conn_write.c b/src/nxt_event_conn_write.c index d6c3d354..72d0731b 100644 --- a/src/nxt_event_conn_write.c +++ b/src/nxt_event_conn_write.c @@ -76,7 +76,7 @@ nxt_event_conn_io_write(nxt_task_t *task, void *obj, void *data) } if (b == NULL) { - nxt_event_fd_block_write(engine, &c->socket); + nxt_fd_event_block_write(engine, &c->socket); break; } @@ -129,7 +129,7 @@ nxt_event_conn_io_write(nxt_task_t *task, void *obj, void *data) } if (nxt_slow_path(ret == NXT_ERROR)) { - nxt_event_fd_block_write(engine, &c->socket); + nxt_fd_event_block_write(engine, &c->socket); nxt_event_conn_io_handle(task->thread, c->write_work_queue, c->write_state->error_handler, task, c, data); @@ -201,7 +201,7 @@ nxt_event_conn_write_delayed(nxt_event_engine_t *engine, nxt_event_conn_t *c, if (timer != 0) { c->delayed = 1; - nxt_event_fd_block_write(engine, &c->socket); + nxt_fd_event_block_write(engine, &c->socket); c->write_timer.handler = nxt_event_conn_write_timer_handler; nxt_timer_add(engine, &c->write_timer, timer); @@ -310,9 +310,9 @@ nxt_event_conn_io_write_chunk(nxt_event_conn_t *c, nxt_buf_t *b, size_t limit) ret = c->io->sendbuf(c, b, limit); if ((ret == NXT_AGAIN || !c->socket.write_ready) - && nxt_event_fd_is_disabled(c->socket.write)) + && nxt_fd_event_is_disabled(c->socket.write)) { - nxt_event_fd_enable_write(c->socket.task->thread->engine, &c->socket); + nxt_fd_event_enable_write(c->socket.task->thread->engine, &c->socket); } return ret; |