/unit/src/ |
H A D | nxt_fd_event.h | 106 nxt_task_t *task;
|
H A D | nxt_http_chunk_parse.c | 23 static void nxt_http_chunk_buf_completion(nxt_task_t *task, void *obj, 28 nxt_http_chunk_parse(nxt_task_t *task, nxt_http_chunk_parse_t *hcp, in nxt_http_chunk_parse() 249 nxt_http_chunk_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_http_chunk_buf_completion()
|
H A D | nxt_buf.h | 217 NXT_EXPORT nxt_buf_t *nxt_buf_mem_ts_alloc(nxt_task_t *task, nxt_mp_t *mp, 224 NXT_EXPORT nxt_int_t nxt_buf_ts_handle(nxt_task_t *task, void *obj, void *data); 226 NXT_EXPORT void nxt_buf_parent_completion(nxt_task_t *task, nxt_buf_t *parent); 264 nxt_buf_dummy_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_dummy_completion()
|
H A D | nxt_cert.c | 42 static nxt_cert_t *nxt_cert_fd(nxt_task_t *task, nxt_fd_t fd); 43 static nxt_cert_t *nxt_cert_bio(nxt_task_t *task, BIO *bio); 51 static void nxt_cert_buf_completion(nxt_task_t *task, void *obj, void *data); 58 nxt_cert_mem(nxt_task_t *task, nxt_buf_mem_t *mbuf) in nxt_cert_mem() 78 nxt_cert_fd(nxt_task_t *task, nxt_fd_t fd) in nxt_cert_fd() 98 nxt_cert_bio(nxt_task_t *task, BIO *bio) in nxt_cert_bio() 345 nxt_cert_info_init(nxt_task_t *task, nxt_array_t *certs) in nxt_cert_info_init() 814 nxt_cert_store_load(nxt_task_t *task, nxt_mp_t *mp) in nxt_cert_store_load() 1062 nxt_cert_store_get(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp, in nxt_cert_store_get() 1109 nxt_cert_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_cert_buf_completion() [all …]
|
H A D | nxt_external.c | 12 static nxt_int_t nxt_external_start(nxt_task_t *task, nxt_process_data_t *data); 31 nxt_external_fd_no_cloexec(nxt_task_t *task, nxt_socket_t fd) in nxt_external_fd_no_cloexec() 60 nxt_external_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_external_start()
|
H A D | nxt_socketpair.c | 24 nxt_socketpair_create(nxt_task_t *task, nxt_socket_t *pair) in nxt_socketpair_create() 78 nxt_socketpair_close(nxt_task_t *task, nxt_socket_t *pair) in nxt_socketpair_close()
|
H A D | nxt_main_process.h | 22 nxt_int_t nxt_main_process_start(nxt_thread_t *thr, nxt_task_t *task,
|
H A D | nxt_java.c | 32 static nxt_int_t nxt_java_setup(nxt_task_t *task, nxt_process_t *process, 34 static nxt_int_t nxt_java_start(nxt_task_t *task, 78 nxt_java_setup(nxt_task_t *task, nxt_process_t *process, in nxt_java_setup() 189 nxt_java_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_java_start()
|
H A D | nxt_tls.h | 36 nxt_int_t (*library_init)(nxt_task_t *task); 37 void (*library_free)(nxt_task_t *task); 39 nxt_int_t (*server_init)(nxt_task_t *task, nxt_mp_t *mp, 42 void (*server_free)(nxt_task_t *task, 70 void (*conn_init)(nxt_task_t *task, 98 void nxt_cdecl nxt_openssl_log_error(nxt_task_t *task, nxt_uint_t level,
|
H A D | nxt_h1proto_websocket.c | 20 static void nxt_h1p_conn_ws_frame_header_read(nxt_task_t *task, void *obj, 22 static void nxt_h1p_conn_ws_keepalive_disable(nxt_task_t *task, 24 static void nxt_h1p_conn_ws_keepalive_enable(nxt_task_t *task, 26 static void nxt_h1p_conn_ws_frame_process(nxt_task_t *task, nxt_conn_t *c, 161 nxt_h1p_conn_ws_keepalive(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_keepalive() 399 nxt_h1p_conn_ws_frame_process(nxt_task_t *task, nxt_conn_t *c, in nxt_h1p_conn_ws_frame_process() 442 nxt_h1p_conn_ws_error(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_error() 462 nxt_h1p_ws_io_read_handler(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_ws_io_read_handler() 496 nxt_h1p_conn_ws_timeout(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_timeout() 578 hxt_h1p_send_ws_error(nxt_task_t *task, nxt_http_request_t *r, in hxt_h1p_send_ws_error() [all …]
|
H A D | nxt_upstream.c | 12 static nxt_http_action_t *nxt_upstream_handler(nxt_task_t *task, 17 nxt_upstreams_create(nxt_task_t *task, nxt_router_temp_conf_t *tmcf, in nxt_upstreams_create() 141 nxt_upstream_handler(nxt_task_t *task, nxt_http_request_t *r, in nxt_upstream_handler()
|
H A D | nxt_event_engine.c | 27 static void nxt_event_engine_signal_pipe_close(nxt_task_t *task, void *obj, 29 static void nxt_event_engine_signal_pipe(nxt_task_t *task, void *obj, 31 static void nxt_event_engine_post_handler(nxt_task_t *task, void *obj, 33 static void nxt_event_engine_signal_pipe_error(nxt_task_t *task, void *obj, 35 static void nxt_event_engine_signal_handler(nxt_task_t *task, void *obj, 38 nxt_task_t **task, void **obj, void **data); 42 nxt_event_engine_create(nxt_task_t *task, in nxt_event_engine_create() 289 nxt_event_engine_signal_pipe(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_signal_pipe() 330 nxt_event_engine_post_handler(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_post_handler() 361 nxt_event_engine_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_signal_handler() [all …]
|
H A D | nxt_buf.c | 10 static void nxt_buf_completion(nxt_task_t *task, void *obj, void *data); 11 static void nxt_buf_ts_completion(nxt_task_t *task, void *obj, void *data); 57 nxt_buf_mem_ts_alloc(nxt_task_t *task, nxt_mp_t *mp, size_t size) in nxt_buf_mem_ts_alloc() 198 nxt_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_completion() 224 nxt_buf_parent_completion(nxt_task_t *task, nxt_buf_t *parent) in nxt_buf_parent_completion() 241 nxt_buf_ts_handle(nxt_task_t *task, void *obj, void *data) in nxt_buf_ts_handle() 271 nxt_buf_ts_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_ts_completion()
|
H A D | nxt_http_proxy.c | 18 static void nxt_http_proxy_server_get(nxt_task_t *task, 20 static void nxt_http_proxy_upstream_ready(nxt_task_t *task, 22 static void nxt_http_proxy_upstream_error(nxt_task_t *task, 24 static nxt_http_action_t *nxt_http_proxy(nxt_task_t *task, 104 nxt_http_proxy(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_proxy() 118 nxt_upstream_proxy_handler(nxt_task_t *task, nxt_http_request_t *r, in nxt_upstream_proxy_handler() 203 nxt_http_proxy_header_send(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_send() 225 nxt_http_proxy_header_sent(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_sent() 247 nxt_http_proxy_header_read(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_header_read() 293 nxt_http_proxy_send_body(nxt_task_t *task, void *obj, void *data) in nxt_http_proxy_send_body() [all …]
|
H A D | nxt_work_queue.c | 161 nxt_task_t *task, void *obj, void *data) in nxt_work_queue_add() 197 nxt_work_queue_pop(nxt_work_queue_t *wq, nxt_task_t **task, void **obj, in nxt_work_queue_pop() 250 nxt_locked_work_queue_pop(nxt_locked_work_queue_t *lwq, nxt_task_t **task, in nxt_locked_work_queue_pop()
|
H A D | nxt_sendbuf.c | 12 static nxt_buf_t *nxt_sendbuf_coalesce_completion(nxt_task_t *task, 17 nxt_sendbuf_mem_coalesce0(nxt_task_t *task, nxt_sendbuf_t *sb, in nxt_sendbuf_mem_coalesce0() 88 nxt_sendbuf_mem_coalesce(nxt_task_t *task, nxt_sendbuf_coalesce_t *sb) in nxt_sendbuf_mem_coalesce() 381 nxt_sendbuf_completion(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b) in nxt_sendbuf_completion() 397 nxt_sendbuf_drain(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b) in nxt_sendbuf_drain() 406 nxt_sendbuf_coalesce_completion(nxt_task_t *task, nxt_work_queue_t *wq, in nxt_sendbuf_coalesce_completion()
|
H A D | nxt_timer.c | 27 static void nxt_timer_handler(nxt_task_t *task, void *obj, void *data); 331 nxt_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_timer_handler()
|
H A D | nxt_upstream.h | 17 typedef void (*nxt_upstream_peer_ready_t)(nxt_task_t *task, 19 typedef void (*nxt_upstream_peer_error_t)(nxt_task_t *task, 31 typedef void (*nxt_upstream_server_get_t)(nxt_task_t *task, 76 nxt_int_t nxt_upstream_round_robin_create(nxt_task_t *task,
|
H A D | nxt_upstream_round_robin.c | 32 static void nxt_upstream_round_robin_server_get(nxt_task_t *task, 43 nxt_upstream_round_robin_create(nxt_task_t *task, nxt_router_temp_conf_t *tmcf, in nxt_upstream_round_robin_create() 165 nxt_upstream_round_robin_server_get(nxt_task_t *task, nxt_upstream_server_t *us) in nxt_upstream_round_robin_server_get()
|
H A D | nxt_thread_pool.c | 11 static void nxt_thread_pool_exit(nxt_task_t *task, void *obj, void *data); 134 nxt_task_t *task; in nxt_thread_pool_loop() 267 nxt_thread_pool_exit(nxt_task_t *task, void *obj, void *data) in nxt_thread_pool_exit()
|
H A D | nxt_thread_pool.h | 24 nxt_task_t task;
|
H A D | nxt_timer.h | 39 nxt_task_t *task;
|
H A D | nxt_select_engine.c | 21 static void nxt_select_error_handler(nxt_task_t *task, void *obj, void *data); 182 nxt_select_error_handler(nxt_task_t *task, void *obj, void *data) in nxt_select_error_handler()
|
/unit/src/test/ |
H A D | nxt_clone_test.c | 31 nxt_int_t nxt_clone_test_mappings(nxt_task_t *task, nxt_mp_t *mp, 35 nxt_int_t nxt_clone_test_map_assert(nxt_task_t *task, 37 static nxt_int_t nxt_clone_test_parse_map(nxt_task_t *task, 432 nxt_task_t *task; in nxt_clone_creds_test() 484 nxt_clone_test_mappings(nxt_task_t *task, nxt_mp_t *mp, in nxt_clone_test_mappings() 532 nxt_clone_test_map_assert(nxt_task_t *task, nxt_clone_creds_testcase_t *tc, in nxt_clone_test_map_assert() 556 nxt_clone_test_parse_map(nxt_task_t *task, nxt_str_t *map_str, in nxt_clone_test_parse_map()
|
H A D | nxt_cq_test.c | 347 nxt_task_t task; in main()
|