Deleted
Added
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 --- |