1 files changed, 18 insertions, 0 deletions
diff --git a/src/nxt_port_socket.c b/src/nxt_port_socket.c
index 3cf2e79a..843728a4 100644
--- a/src/nxt_port_socket.c
+++ b/src/nxt_port_socket.c
@@ -524,6 +524,24 @@ next_fragment:
 
         } else {
             if (nxt_slow_path(n == NXT_ERROR)) {
+                if (msg->link.next == NULL) {
+                    if (msg->close_fd) {
+                        if (msg->fd[0] != -1) {
+                            nxt_fd_close(msg->fd[0]);
+
+                            msg->fd[0] = -1;
+                        }
+
+                        if (msg->fd[1] != -1) {
+                            nxt_fd_close(msg->fd[1]);
+
+                            msg->fd[1] = -1;
+                        }
+                    }
+
+                    nxt_port_release_send_msg(msg);
+                }
+
                 goto fail;
             }