Lines Matching refs:nxt_task_t

10 static void nxt_conn_proxy_client_buffer_alloc(nxt_task_t *task, void *obj,
12 static void nxt_conn_proxy_peer_connect(nxt_task_t *task, void *obj,
14 static void nxt_conn_proxy_connected(nxt_task_t *task, void *obj, void *data);
15 static void nxt_conn_proxy_peer_read(nxt_task_t *task, void *obj, void *data);
16 static void nxt_conn_proxy_client_read_ready(nxt_task_t *task, void *obj,
18 static void nxt_conn_proxy_peer_read_ready(nxt_task_t *task, void *obj,
20 static void nxt_conn_proxy_read_process(nxt_task_t *task, nxt_conn_proxy_t *p,
23 static void nxt_conn_proxy_read(nxt_task_t *task, void *obj, void *data);
24 static void nxt_conn_proxy_client_write_ready(nxt_task_t *task, void *obj,
26 static void nxt_conn_proxy_peer_write_ready(nxt_task_t *task, void *obj,
28 static void nxt_conn_proxy_write_process(nxt_task_t *task, nxt_conn_proxy_t *p,
31 static void nxt_conn_proxy_close(nxt_task_t *task, void *obj, void *data);
32 static void nxt_conn_proxy_error(nxt_task_t *task, void *obj, void *data);
33 static void nxt_conn_proxy_read_timeout(nxt_task_t *task, void *obj,
35 static void nxt_conn_proxy_write_timeout(nxt_task_t *task, void *obj,
38 static void nxt_conn_proxy_refused(nxt_task_t *task, void *obj, void *data);
39 static void nxt_conn_proxy_reconnect_handler(nxt_task_t *task, void *obj,
41 static void nxt_conn_proxy_shutdown(nxt_task_t *task, nxt_conn_proxy_t *p,
43 static void nxt_conn_proxy_read_error(nxt_task_t *task, void *obj, void *data);
44 static void nxt_conn_proxy_write_error(nxt_task_t *task, void *obj, void *data);
45 static void nxt_conn_proxy_complete(nxt_task_t *task, nxt_conn_proxy_t *p);
46 static void nxt_conn_proxy_completion(nxt_task_t *task, void *obj, void *data);
100 nxt_conn_proxy(nxt_task_t *task, nxt_conn_proxy_t *p) in nxt_conn_proxy()
144 nxt_conn_proxy_client_buffer_alloc(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_client_buffer_alloc()
205 nxt_conn_proxy_peer_connect(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_peer_connect()
243 nxt_conn_proxy_connected(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_connected()
293 nxt_conn_proxy_peer_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_peer_read()
338 nxt_conn_proxy_client_read_ready(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_client_read_ready()
362 nxt_conn_proxy_peer_read_ready(nxt_task_t *task, void *obj, void *data) 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()
491 nxt_conn_proxy_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_read()
525 nxt_conn_proxy_client_write_ready(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_client_write_ready()
553 nxt_conn_proxy_peer_write_ready(nxt_task_t *task, void *obj, void *data) 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()
702 nxt_conn_proxy_close(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_close()
732 nxt_conn_proxy_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_error()
747 nxt_conn_proxy_read_timeout(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_read_timeout()
765 nxt_conn_proxy_write_timeout(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_write_timeout()
790 nxt_conn_proxy_refused(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_refused()
821 nxt_conn_proxy_reconnect_handler(nxt_task_t *task, void *obj, void *data) 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()
891 nxt_conn_proxy_read_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_read_error()
906 nxt_conn_proxy_write_error(nxt_task_t *task, void *obj, void *data) 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()
970 nxt_conn_proxy_completion(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_completion()