Lines Matching refs:data
11 void *data);
13 void *data);
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);
17 void *data);
19 void *data);
23 static void nxt_conn_proxy_read(nxt_task_t *task, void *obj, void *data);
25 void *data);
27 void *data);
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);
34 void *data);
36 void *data);
37 static nxt_msec_t nxt_conn_proxy_timeout_value(nxt_conn_t *c, uintptr_t data);
38 static void nxt_conn_proxy_refused(nxt_task_t *task, void *obj, void *data);
40 void *data);
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);
46 static void nxt_conn_proxy_completion(nxt_task_t *task, void *obj, void *data);
85 peer->socket.data = client->socket.data; in nxt_conn_proxy_create()
144 nxt_conn_proxy_client_buffer_alloc(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_client_buffer_alloc() argument
151 p = 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() argument
211 p = 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() argument
249 p = 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() argument
300 p = 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() argument
344 p = 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() argument
368 p = data; in nxt_conn_proxy_peer_read_ready()
386 nxt_conn_proxy_write_error(task, sink, sink->socket.data); in nxt_conn_proxy_read_process()
418 task, source, source->socket.data); in nxt_conn_proxy_read_process()
491 nxt_conn_proxy_read(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_read() argument
497 p = 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() argument
531 p = 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() argument
559 p = data; in nxt_conn_proxy_peer_write_ready()
619 task, source, source->socket.data); in nxt_conn_proxy_write_process()
702 nxt_conn_proxy_close(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_close() argument
709 p = data; in nxt_conn_proxy_close()
732 nxt_conn_proxy_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_error() argument
738 p = 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() argument
760 nxt_conn_proxy_close(task, c, c->socket.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() argument
778 nxt_conn_proxy_close(task, c, c->socket.data); 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() argument
785 return nxt_value_at(nxt_msec_t, c->socket.data, data); in nxt_conn_proxy_timeout_value()
790 nxt_conn_proxy_refused(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_refused() argument
796 p = 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() argument
832 p = peer->socket.data; in nxt_conn_proxy_reconnect_handler()
891 nxt_conn_proxy_read_error(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_read_error() argument
897 p = 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() argument
912 p = data; in nxt_conn_proxy_write_error()
970 nxt_conn_proxy_completion(nxt_task_t *task, void *obj, void *data) in nxt_conn_proxy_completion() argument
974 p = data; in nxt_conn_proxy_completion()