nxt_port_socket.c (1832:7618b95f9cd2) nxt_port_socket.c (1907:75ddb2d89b42)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_port_queue.h>

--- 510 unchanged lines hidden (view full) ---

519 }
520
521 if (data != NULL) {
522 goto cleanup;
523 }
524
525 } else {
526 if (nxt_slow_path(n == NXT_ERROR)) {
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_port_queue.h>

--- 510 unchanged lines hidden (view full) ---

519 }
520
521 if (data != NULL) {
522 goto cleanup;
523 }
524
525 } else {
526 if (nxt_slow_path(n == NXT_ERROR)) {
527 if (msg->link.next == NULL) {
528 if (msg->close_fd) {
529 if (msg->fd[0] != -1) {
530 nxt_fd_close(msg->fd[0]);
531
532 msg->fd[0] = -1;
533 }
534
535 if (msg->fd[1] != -1) {
536 nxt_fd_close(msg->fd[1]);
537
538 msg->fd[1] = -1;
539 }
540 }
541
542 nxt_port_release_send_msg(msg);
543 }
544
527 goto fail;
528 }
529
530 if (msg->link.next == NULL) {
531 msg = nxt_port_msg_insert_tail(port, msg);
532 if (nxt_slow_path(msg == NULL)) {
533 goto fail;
534 }

--- 821 unchanged lines hidden --- 		545 goto fail;
546 }
547
548 if (msg->link.next == NULL) {
549 msg = nxt_port_msg_insert_tail(port, msg);
550 if (nxt_slow_path(msg == NULL)) {
551 goto fail;
552 }

--- 821 unchanged lines hidden ---