1 files changed, 4 insertions, 2 deletions
diff --git a/src/nxt_port_socket.c b/src/nxt_port_socket.c
index 5ca2eb38..9d8096b2 100644
--- a/src/nxt_port_socket.c
+++ b/src/nxt_port_socket.c
@@ -208,6 +208,10 @@ nxt_port_socket_write2(nxt_task_t *task, nxt_port_t *port, nxt_uint_t type,
             nxt_debug(task, "port{%d,%d} %d: enqueue 1 notify %d, %d",
                       (int) port->pid, (int) port->id, port->socket.fd,
                       notify, res);
+
+            if (nxt_slow_path(res == NXT_AGAIN)) {
+                return NXT_AGAIN;
+            }
         }
     }
 
@@ -738,8 +742,6 @@ nxt_port_queue_read_handler(nxt_task_t *task, void *obj, void *data)
                           (int) port->pid, (int) port->id, port->socket.fd,
                           port->from_socket);
 
-                n = -1;
-
                 continue;
             }