Lines Matching refs:socket

16     nxt_debug(c->socket.task, "conn wait fd:%d rdy:%d",  in nxt_conn_wait()
17 c->socket.fd, c->socket.read_ready); in nxt_conn_wait()
19 engine = c->socket.task->thread->engine; in nxt_conn_wait()
22 if (c->socket.read_ready) { in nxt_conn_wait()
24 c->socket.task, c, c->socket.data); in nxt_conn_wait()
28 c->socket.read_handler = state->ready_handler; in nxt_conn_wait()
29 c->socket.error_handler = state->error_handler; in nxt_conn_wait()
33 nxt_fd_event_enable_read(engine, &c->socket); in nxt_conn_wait()
49 c->socket.fd, c->socket.read_ready, c->socket.closed, in nxt_conn_io_read()
50 c->socket.error, c->block_read); in nxt_conn_io_read()
52 if (c->socket.error != 0 || c->block_read) { in nxt_conn_io_read()
62 c->socket.read_handler = c->io->read; in nxt_conn_io_read()
64 c->socket.error_handler = state->error_handler; in nxt_conn_io_read()
66 if (c->socket.read_ready) { in nxt_conn_io_read()
82 nxt_fd_event_block_read(engine, &c->socket); in nxt_conn_io_read()
97 nxt_fd_event_block_read(engine, &c->socket); in nxt_conn_io_read()
107 if (c->socket.read_ready) { in nxt_conn_io_read()
121 if (nxt_fd_event_is_disabled(c->socket.read)) { in nxt_conn_io_read()
122 nxt_fd_event_enable_read(engine, &c->socket); in nxt_conn_io_read()
153 n = readv(c->socket.fd, iov, niov); 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()
161 c->socket.read_ready = 0; in nxt_conn_io_recvbuf()
168 c->socket.closed = 1; in nxt_conn_io_recvbuf()
169 c->socket.read_ready = 0; in nxt_conn_io_recvbuf()
178 nxt_debug(c->socket.task, "readv() %E", err); in nxt_conn_io_recvbuf()
179 c->socket.read_ready = 0; in nxt_conn_io_recvbuf()
183 nxt_debug(c->socket.task, "readv() %E", err); in nxt_conn_io_recvbuf()
187 c->socket.error = err; in nxt_conn_io_recvbuf()
188 nxt_log(c->socket.task, nxt_socket_error_level(err), in nxt_conn_io_recvbuf()
189 "readv(%d, %ui) failed %E", c->socket.fd, niov, err); in nxt_conn_io_recvbuf()
204 n = recv(c->socket.fd, buf, size, flags); in nxt_conn_io_recv()
208 nxt_debug(c->socket.task, "recv(%d, %p, %uz, 0x%ui): %z", in nxt_conn_io_recv()
209 c->socket.fd, buf, size, flags, n); in nxt_conn_io_recv()
213 c->socket.read_ready = 0; in nxt_conn_io_recv()
220 c->socket.closed = 1; in nxt_conn_io_recv()
223 c->socket.read_ready = 0; in nxt_conn_io_recv()
234 nxt_debug(c->socket.task, "recv() %E", err); in nxt_conn_io_recv()
235 c->socket.read_ready = 0; in nxt_conn_io_recv()
240 nxt_debug(c->socket.task, "recv() %E", err); in nxt_conn_io_recv()
244 c->socket.error = err; in nxt_conn_io_recv()
245 nxt_log(c->socket.task, nxt_socket_error_level(err), in nxt_conn_io_recv()
247 c->socket.fd, buf, size, flags, err); in nxt_conn_io_recv()