nxt_unit.c (1623:7cdddbe0fb45) nxt_unit.c (1631:73a1935e3899)
1
2/*
3 * Copyright (C) NGINX, Inc.
4 */
5
6#include <stdlib.h>
7
8#include "nxt_main.h"

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

5759 }
5760
5761 read = 1;
5762
5763 if (nxt_unit_is_read_queue(rbuf)) {
5764 nxt_unit_debug(ctx, "port{%d,%d} recv %d read_queue",
5765 (int) port->id.pid, (int) port->id.id, (int) rbuf->size);
5766
1
2/*
3 * Copyright (C) NGINX, Inc.
4 */
5
6#include <stdlib.h>
7
8#include "nxt_main.h"

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

5759 }
5760
5761 read = 1;
5762
5763 if (nxt_unit_is_read_queue(rbuf)) {
5764 nxt_unit_debug(ctx, "port{%d,%d} recv %d read_queue",
5765 (int) port->id.pid, (int) port->id.id, (int) rbuf->size);
5766
5767 if (port_impl->from_socket) {
5768 nxt_unit_warn(ctx, "port protocol warning: READ_QUEUE after READ_SOCKET");
5769 }
5770
5771 goto retry;
5772 }
5773
5774 nxt_unit_debug(ctx, "port{%d,%d} recvmsg %d",
5775 (int) port->id.pid, (int) port->id.id,
5776 (int) rbuf->size);
5777
5778 if (res == NXT_UNIT_AGAIN) {

--- 662 unchanged lines hidden ---
5767 goto retry;
5768 }
5769
5770 nxt_unit_debug(ctx, "port{%d,%d} recvmsg %d",
5771 (int) port->id.pid, (int) port->id.id,
5772 (int) rbuf->size);
5773
5774 if (res == NXT_UNIT_AGAIN) {

--- 662 unchanged lines hidden ---