Lines Matching refs:nxt_conn_proxy_t

20 static void nxt_conn_proxy_read_process(nxt_task_t *task, nxt_conn_proxy_t *p,
28 static void nxt_conn_proxy_write_process(nxt_task_t *task, nxt_conn_proxy_t *p,
41 static void nxt_conn_proxy_shutdown(nxt_task_t *task, nxt_conn_proxy_t *p,
45 static void nxt_conn_proxy_complete(nxt_task_t *task, nxt_conn_proxy_t *p);
59 nxt_conn_proxy_t *
64 nxt_conn_proxy_t *p; in nxt_conn_proxy_create()
66 p = nxt_mp_zget(client->mem_pool, sizeof(nxt_conn_proxy_t)); in nxt_conn_proxy_create()
100 nxt_conn_proxy(nxt_task_t *task, nxt_conn_proxy_t *p) in nxt_conn_proxy()
139 .timer_data = offsetof(nxt_conn_proxy_t, client_wait_timeout),
148 nxt_conn_proxy_t *p; in nxt_conn_proxy_client_buffer_alloc()
199 .timer_data = offsetof(nxt_conn_proxy_t, client_wait_timeout),
208 nxt_conn_proxy_t *p; in nxt_conn_proxy_peer_connect()
237 .timer_data = offsetof(nxt_conn_proxy_t, connect_timeout),
246 nxt_conn_proxy_t *p; in nxt_conn_proxy_connected()
288 .timer_data = offsetof(nxt_conn_proxy_t, peer_wait_timeout),
297 nxt_conn_proxy_t *p; in nxt_conn_proxy_peer_read()
341 nxt_conn_proxy_t *p; in nxt_conn_proxy_client_read_ready()
365 nxt_conn_proxy_t *p; in nxt_conn_proxy_peer_read_ready()
377 nxt_conn_proxy_read_process(nxt_task_t *task, nxt_conn_proxy_t *p, in nxt_conn_proxy_read_process()
494 nxt_conn_proxy_t *p; in nxt_conn_proxy_read()
519 .timer_data = offsetof(nxt_conn_proxy_t, client_write_timeout),
528 nxt_conn_proxy_t *p; in nxt_conn_proxy_client_write_ready()
547 .timer_data = offsetof(nxt_conn_proxy_t, peer_write_timeout),
556 nxt_conn_proxy_t *p; in nxt_conn_proxy_peer_write_ready()
568 nxt_conn_proxy_write_process(nxt_task_t *task, nxt_conn_proxy_t *p, in nxt_conn_proxy_write_process()
706 nxt_conn_proxy_t *p; in nxt_conn_proxy_close()
735 nxt_conn_proxy_t *p; in nxt_conn_proxy_error()
793 nxt_conn_proxy_t *p; in nxt_conn_proxy_refused()
825 nxt_conn_proxy_t *p; in nxt_conn_proxy_reconnect_handler()
851 nxt_conn_proxy_shutdown(nxt_task_t *task, nxt_conn_proxy_t *p, in nxt_conn_proxy_shutdown()
894 nxt_conn_proxy_t *p; in nxt_conn_proxy_read_error()
909 nxt_conn_proxy_t *p; in nxt_conn_proxy_write_error()
941 nxt_conn_proxy_complete(nxt_task_t *task, nxt_conn_proxy_t *p) in nxt_conn_proxy_complete()
972 nxt_conn_proxy_t *p; in nxt_conn_proxy_completion()