Lines Matching refs:n
40 ssize_t n; in nxt_conn_io_read() local
69 n = c->io->recvbuf(c, c->read); in nxt_conn_io_read()
72 n = state->io_read_handler(task, c); in nxt_conn_io_read()
77 if (n > 0) { in nxt_conn_io_read()
78 c->nbytes = n; in nxt_conn_io_read()
80 nxt_recvbuf_update(c->read, n); in nxt_conn_io_read()
93 if (n != NXT_AGAIN) { in nxt_conn_io_read()
95 handler = (n == 0) ? state->close_handler : state->error_handler; in nxt_conn_io_read()
134 ssize_t n; in nxt_conn_io_recvbuf() local
153 n = readv(c->socket.fd, iov, niov); in nxt_conn_io_recvbuf()
155 err = (n == -1) ? nxt_socket_errno : 0; in nxt_conn_io_recvbuf()
157 nxt_debug(c->socket.task, "readv(%d, %ui): %z", c->socket.fd, niov, n); in nxt_conn_io_recvbuf()
159 if (n > 0) { in nxt_conn_io_recvbuf()
160 if ((size_t) n < rb.size) { in nxt_conn_io_recvbuf()
164 return n; in nxt_conn_io_recvbuf()
167 if (n == 0) { in nxt_conn_io_recvbuf()
170 return n; in nxt_conn_io_recvbuf()
200 ssize_t n; in nxt_conn_io_recv() local
204 n = recv(c->socket.fd, buf, size, flags); in nxt_conn_io_recv()
206 err = (n == -1) ? nxt_socket_errno : 0; in nxt_conn_io_recv()
209 c->socket.fd, buf, size, flags, n); in nxt_conn_io_recv()
211 if (n > 0) { in nxt_conn_io_recv()
212 if ((size_t) n < size && (flags & MSG_PEEK) == 0) { in nxt_conn_io_recv()
216 return n; in nxt_conn_io_recv()
219 if (n == 0) { in nxt_conn_io_recv()
226 return n; in nxt_conn_io_recv()