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()
203 n = nxt_sendfile(b->file->fd, sb->socket, b->file_pos, size); in nxt_conn_io_sendfile()
208 b->file->fd, sb->socket, b->file_pos, size, n); in nxt_conn_io_sendfile()
243 b->file->fd, sb->socket, b->file_pos, size, err); in nxt_conn_io_sendfile()
316 n = writev(sb->socket, iov, niov); in nxt_conn_io_writev()
320 nxt_debug(task, "writev(%d, %ui): %z", sb->socket, niov, n); in nxt_conn_io_writev()
343 "writev(%d, %ui) failed %E", sb->socket, niov, err); in nxt_conn_io_writev()
358 n = send(sb->socket, buf, size, 0); in nxt_conn_io_send()
362 nxt_debug(task, "send(%d, %p, %uz): %z", sb->socket, buf, size, n); in nxt_conn_io_send()
385 "send(%d, %p, %uz) failed %E", sb->socket, buf, size, err); in nxt_conn_io_send()
410 nxt_debug(c->socket.task, "event conn correction:%z average:%0.3f", in nxt_event_conn_write_limit()
450 niob = nxt_sendbuf_mem_coalesce(c->socket.task, &sb); in nxt_event_conn_io_sendbuf()
472 n = writev(c->socket.fd, iob, niob); in nxt_event_conn_io_writev()
476 nxt_debug(c->socket.task, "writev(%d, %ui): %z", c->socket.fd, niob, n); in nxt_event_conn_io_writev()
487 nxt_debug(c->socket.task, "writev() %E", err); in nxt_event_conn_io_writev()
488 c->socket.write_ready = 0; in nxt_event_conn_io_writev()
492 nxt_debug(c->socket.task, "writev() %E", err); in nxt_event_conn_io_writev()
496 c->socket.error = err; in nxt_event_conn_io_writev()
497 nxt_log(c->socket.task, nxt_socket_error_level(err), in nxt_event_conn_io_writev()
498 "writev(%d, %ui) failed %E", c->socket.fd, niob, err); in nxt_event_conn_io_writev()
512 n = send(c->socket.fd, buf, size, 0); in nxt_event_conn_io_send()
516 nxt_debug(c->socket.task, "send(%d, %p, %uz): %z", in nxt_event_conn_io_send()
517 c->socket.fd, buf, size, n); in nxt_event_conn_io_send()
528 nxt_debug(c->socket.task, "send() %E", err); in nxt_event_conn_io_send()
529 c->socket.write_ready = 0; in nxt_event_conn_io_send()
533 nxt_debug(c->socket.task, "send() %E", err); in nxt_event_conn_io_send()
537 c->socket.error = err; in nxt_event_conn_io_send()
538 nxt_log(c->socket.task, nxt_socket_error_level(err), in nxt_event_conn_io_send()
540 c->socket.fd, buf, size, err); in nxt_event_conn_io_send()