Event engines refactoring.

1 files changed, 5 insertions, 5 deletions

diff --git a/src/nxt_event_conn_read.c b/src/nxt_event_conn_read.c
index f17b60d0..20e4d39b 100644
--- a/src/nxt_event_conn_read.c
+++ b/src/nxt_event_conn_read.c
@@ -85,7 +85,7 @@ nxt_event_conn_io_read(nxt_task_t *task, void *obj, void *data)
         }
 
         if (n != NXT_AGAIN) {
-            nxt_event_fd_block_read(engine, &c->socket);
+            nxt_fd_event_block_read(engine, &c->socket);
             nxt_timer_disable(engine, &c->read_timer);
 
             if (n == 0) {
@@ -108,13 +108,13 @@ nxt_event_conn_io_read(nxt_task_t *task, void *obj, void *data)
     c->socket.error_handler = state->error_handler;
 
     if (c->read_timer.state == NXT_TIMER_DISABLED
-        || nxt_event_fd_is_disabled(c->socket.read))
+        || nxt_fd_event_is_disabled(c->socket.read))
     {
         /* Timer may be set or reset. */
         nxt_event_conn_timer(engine, c, state, &c->read_timer);
 
-        if (nxt_event_fd_is_disabled(c->socket.read)) {
-            nxt_event_fd_enable_read(engine, &c->socket);
+        if (nxt_fd_event_is_disabled(c->socket.read)) {
+            nxt_fd_event_enable_read(engine, &c->socket);
         }
     }
 
@@ -122,7 +122,7 @@ nxt_event_conn_io_read(nxt_task_t *task, void *obj, void *data)
 
 ready:
 
-    nxt_event_fd_block_read(engine, &c->socket);
+    nxt_fd_event_block_read(engine, &c->socket);
 
     if (state->autoreset_timer) {
         nxt_timer_disable(engine, &c->read_timer);