Lines Matching refs:write
437 first = c->write; in nxt_conn_proxy_write_add()
440 c->write = b; in nxt_conn_proxy_write_add()
573 while (sink->write != NULL) { in nxt_conn_proxy_write_process()
575 wb = sink->write; in nxt_conn_proxy_write_process()
581 sink->write = NULL; in nxt_conn_proxy_write_process()
614 sink->write = wb->next; in nxt_conn_proxy_write_process()
715 if (sink->write == NULL) { in nxt_conn_proxy_close()
727 nxt_buf_chain_add(&sink->write, b); in nxt_conn_proxy_close()
875 || (sink->socket.closed && source->write == NULL)) in nxt_conn_proxy_shutdown()
917 sink->write = NULL; in nxt_conn_proxy_write_error()
923 if (source->write == NULL) { in nxt_conn_proxy_write_error()