Lines Matching refs:socket

28               c->socket.fd, c->socket.error, c->block_write);  in nxt_conn_io_write()
30 if (c->socket.error != 0 || c->block_write) { in nxt_conn_io_write()
34 if (!c->socket.write_ready || c->write == NULL) { in nxt_conn_io_write()
40 c->socket.write_handler = nxt_conn_io_write; in nxt_conn_io_write()
41 c->socket.error_handler = c->write_state->error_handler; in nxt_conn_io_write()
45 sb.socket = c->socket.fd; in nxt_conn_io_write()
60 c->socket.write_ready = sb.ready; in nxt_conn_io_write()
61 c->socket.error = sb.error; in nxt_conn_io_write()
74 nxt_fd_event_block_write(engine, &c->socket); in nxt_conn_io_write()
80 if (!c->socket.write_ready) { in nxt_conn_io_write()
115 if (nxt_fd_event_is_disabled(c->socket.write)) { in nxt_conn_io_write()
116 nxt_fd_event_enable_write(engine, &c->socket); in nxt_conn_io_write()
137 nxt_fd_event_block_write(engine, &c->socket); in nxt_conn_io_write()
159 c->io->write(task, c, c->socket.data); in nxt_conn_write_timer_handler()
196 n = nxt_sendfile(b->file->fd, sb->socket, b->file_pos, size); in nxt_conn_io_sendfile()
201 b->file->fd, sb->socket, b->file_pos, size, n); in nxt_conn_io_sendfile()
236 b->file->fd, sb->socket, b->file_pos, size, err); in nxt_conn_io_sendfile()
309 n = writev(sb->socket, iov, niov); in nxt_conn_io_writev()
313 nxt_debug(task, "writev(%d, %ui): %z", sb->socket, niov, n); in nxt_conn_io_writev()
336 "writev(%d, %ui) failed %E", sb->socket, niov, err); in nxt_conn_io_writev()
351 n = send(sb->socket, buf, size, 0); in nxt_conn_io_send()
355 nxt_debug(task, "send(%d, %p, %uz): %z", sb->socket, buf, size, n); in nxt_conn_io_send()
378 "send(%d, %p, %uz) failed %E", sb->socket, buf, size, err); in nxt_conn_io_send()
403 nxt_debug(c->socket.task, "event conn correction:%z average:%0.3f", in nxt_event_conn_write_limit()
443 niob = nxt_sendbuf_mem_coalesce(c->socket.task, &sb); in nxt_event_conn_io_sendbuf()
465 n = writev(c->socket.fd, iob, niob); in nxt_event_conn_io_writev()
469 nxt_debug(c->socket.task, "writev(%d, %ui): %z", c->socket.fd, niob, n); in nxt_event_conn_io_writev()
480 nxt_debug(c->socket.task, "writev() %E", err); in nxt_event_conn_io_writev()
481 c->socket.write_ready = 0; in nxt_event_conn_io_writev()
485 nxt_debug(c->socket.task, "writev() %E", err); in nxt_event_conn_io_writev()
489 c->socket.error = err; in nxt_event_conn_io_writev()
490 nxt_log(c->socket.task, nxt_socket_error_level(err), in nxt_event_conn_io_writev()
491 "writev(%d, %ui) failed %E", c->socket.fd, niob, err); in nxt_event_conn_io_writev()
505 n = send(c->socket.fd, buf, size, 0); in nxt_event_conn_io_send()
509 nxt_debug(c->socket.task, "send(%d, %p, %uz): %z", in nxt_event_conn_io_send()
510 c->socket.fd, buf, size, n); in nxt_event_conn_io_send()
521 nxt_debug(c->socket.task, "send() %E", err); in nxt_event_conn_io_send()
522 c->socket.write_ready = 0; in nxt_event_conn_io_send()
526 nxt_debug(c->socket.task, "send() %E", err); in nxt_event_conn_io_send()
530 c->socket.error = err; in nxt_event_conn_io_send()
531 nxt_log(c->socket.task, nxt_socket_error_level(err), in nxt_event_conn_io_send()
533 c->socket.fd, buf, size, err); in nxt_event_conn_io_send()