Home
last modified time | relevance | path

Searched refs:nxt_task_t (Results 76 – 100 of 123) sorted by last modified time

12345

/unit/src/
H A Dnxt_fd_event.h106 nxt_task_t *task;
H A Dnxt_http_chunk_parse.c23 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 Dnxt_buf.h217 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 Dnxt_cert.c42 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 Dnxt_external.c12 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 Dnxt_socketpair.c24 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 Dnxt_main_process.h22 nxt_int_t nxt_main_process_start(nxt_thread_t *thr, nxt_task_t *task,
H A Dnxt_java.c32 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 Dnxt_tls.h36 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 Dnxt_h1proto_websocket.c20 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 Dnxt_upstream.c12 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 Dnxt_event_engine.c27 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 Dnxt_buf.c10 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 Dnxt_http_proxy.c18 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 Dnxt_work_queue.c161 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 Dnxt_sendbuf.c12 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 Dnxt_timer.c27 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 Dnxt_upstream.h17 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 Dnxt_upstream_round_robin.c32 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 Dnxt_thread_pool.c11 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 Dnxt_thread_pool.h24 nxt_task_t task;
H A Dnxt_timer.h39 nxt_task_t *task;
H A Dnxt_select_engine.c21 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 Dnxt_clone_test.c31 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 Dnxt_cq_test.c347 nxt_task_t task; in main()

12345