Lines Matching refs:nxt_conn_t

21     nxt_conn_t *source, nxt_conn_t *sink);
22 static void nxt_conn_proxy_write_add(nxt_conn_t *c, nxt_buf_t *b);
29 nxt_conn_t *sink, nxt_conn_t *source);
30 static void nxt_conn_proxy_read_add(nxt_conn_t *c, nxt_buf_t *b);
37 static nxt_msec_t nxt_conn_proxy_timeout_value(nxt_conn_t *c, uintptr_t data);
42 nxt_conn_t *source, nxt_conn_t *sink);
60 nxt_conn_proxy_create(nxt_conn_t *client) in nxt_conn_proxy_create()
62 nxt_conn_t *peer; in nxt_conn_proxy_create()
102 nxt_conn_t *peer; in nxt_conn_proxy()
147 nxt_conn_t *client; in nxt_conn_proxy_client_buffer_alloc()
207 nxt_conn_t *client; in nxt_conn_proxy_peer_connect()
245 nxt_conn_t *client, *peer; in nxt_conn_proxy_connected()
296 nxt_conn_t *peer; in nxt_conn_proxy_peer_read()
340 nxt_conn_t *client; in nxt_conn_proxy_client_read_ready()
364 nxt_conn_t *peer; in nxt_conn_proxy_peer_read_ready()
378 nxt_conn_t *source, nxt_conn_t *sink) in nxt_conn_proxy_read_process()
433 nxt_conn_proxy_write_add(nxt_conn_t *c, nxt_buf_t *b) in nxt_conn_proxy_write_add()
493 nxt_conn_t *source, *sink; in nxt_conn_proxy_read()
527 nxt_conn_t *client; in nxt_conn_proxy_client_write_ready()
555 nxt_conn_t *peer; in nxt_conn_proxy_peer_write_ready()
569 nxt_conn_t *sink, nxt_conn_t *source) in nxt_conn_proxy_write_process()
624 nxt_conn_proxy_read_add(nxt_conn_t *c, nxt_buf_t *b) in nxt_conn_proxy_read_add()
705 nxt_conn_t *source, *sink; in nxt_conn_proxy_close()
734 nxt_conn_t *c; in nxt_conn_proxy_error()
749 nxt_conn_t *c; in nxt_conn_proxy_read_timeout()
767 nxt_conn_t *c; in nxt_conn_proxy_write_timeout()
783 nxt_conn_proxy_timeout_value(nxt_conn_t *c, uintptr_t data) in nxt_conn_proxy_timeout_value()
792 nxt_conn_t *peer; in nxt_conn_proxy_refused()
823 nxt_conn_t *peer; in nxt_conn_proxy_reconnect_handler()
852 nxt_conn_t *source, nxt_conn_t *sink) in nxt_conn_proxy_shutdown()
893 nxt_conn_t *c; in nxt_conn_proxy_read_error()
908 nxt_conn_t *source, *sink; in nxt_conn_proxy_write_error()