From 2136eb411c9b99ffd65751bd13e10ce426be2492 Mon Sep 17 00:00:00 2001 From: Max Romanov Date: Wed, 12 Aug 2020 13:37:49 +0300 Subject: Fixing issues found by static analyzer. --- src/nxt_port_socket.c | 6 ++++-- 1 file 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; } -- cgit