Home
last modified time | relevance | path

Searched defs:task (Results 1 – 25 of 99) sorted by last modified time

1234

/unit/src/
H A Dnxt_sockaddr.c188 nxt_getsockname(nxt_task_t *task, nxt_mp_t *mp, nxt_socket_t s) in nxt_getsockname()
H A Dnxt_port_socket.c42 nxt_port_socket_init(nxt_task_t *task, nxt_port_t *port, size_t max_size) in nxt_port_socket_init()
128 nxt_port_write_enable(nxt_task_t *task, nxt_port_t *port) in nxt_port_write_enable()
269 nxt_port_enqueue_buf(nxt_task_t *task, nxt_port_msg_t *pm, void *qbuf, in nxt_port_enqueue_buf()
303 nxt_port_msg_chk_insert(nxt_task_t *task, nxt_port_t *port, in nxt_port_msg_chk_insert()
367 nxt_port_write_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_write_handler()
703 nxt_port_read_enable(nxt_task_t *task, nxt_port_t *port) in nxt_port_read_enable()
731 nxt_port_read_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_read_handler()
812 nxt_port_queue_read_handler(nxt_task_t *task, void *obj, void *data) in nxt_port_queue_read_handler()
1076 nxt_port_frag_start(nxt_task_t *task, nxt_port_t *port, in nxt_port_frag_start()
1171 nxt_port_read_msg_process(nxt_task_t *task, nxt_port_t *port, in nxt_port_read_msg_process()
[all …]
H A Dnxt_http_static.c74 nxt_http_static_init(nxt_task_t *task, nxt_router_temp_conf_t *tmcf, in nxt_http_static_init()
186 nxt_http_static(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_static()
225 nxt_http_static_iterate(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_static_iterate()
294 nxt_http_static_send_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_static_send_ready()
658 nxt_http_static_var_error(nxt_task_t *task, void *obj, void *data) in nxt_http_static_var_error()
669 nxt_http_static_next(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_static_next()
780 nxt_http_static_body_handler(nxt_task_t *task, void *obj, void *data) in nxt_http_static_body_handler()
842 nxt_http_static_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_http_static_buf_completion()
H A Dnxt_http_request.c66 nxt_http_init(nxt_task_t *task) in nxt_http_init()
244 nxt_http_request_create(nxt_task_t *task) in nxt_http_request_create()
300 nxt_http_request_start(nxt_task_t *task, void *obj, void *data) in nxt_http_request_start()
336 nxt_http_request_forward(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_request_forward()
536 nxt_http_request_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_request_ready()
549 nxt_http_request_action(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_request_action()
573 nxt_http_application_handler(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_application_handler()
598 nxt_http_request_proto_info(nxt_task_t *task, nxt_http_request_t *r) in nxt_http_request_proto_info()
607 nxt_http_request_read_body(nxt_task_t *task, nxt_http_request_t *r) in nxt_http_request_read_body()
616 nxt_http_request_header_send(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_request_header_send()
[all …]
H A Dnxt_mp.c1042 nxt_task_t *task, void *obj, void *data) in nxt_mp_cleanup()
H A Dnxt_http.h165 nxt_task_t task; member
H A Dnxt_router.c336 nxt_router_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_router_start()
507 nxt_router_start_app_process(nxt_task_t *task, nxt_app_t *app) in nxt_router_start_app_process()
602 nxt_request_rpc_data_unlink(nxt_task_t *task, in nxt_request_rpc_data_unlink()
989 nxt_router_temp_conf(nxt_task_t *task) in nxt_router_temp_conf()
2578 nxt_router_listen_socket_rpc_create(nxt_task_t *task, in nxt_router_listen_socket_rpc_create()
2807 nxt_router_app_rpc_create(nxt_task_t *task, in nxt_router_app_rpc_create()
3367 nxt_task_t *task; in nxt_router_thread_start() local
4359 nxt_router_req_headers_ack_handler(nxt_task_t *task, in nxt_router_req_headers_ack_handler()
4789 nxt_router_app_unlink(nxt_task_t *task, nxt_app_t *app) in nxt_router_app_unlink()
5222 nxt_router_app_port_get(nxt_task_t *task, nxt_app_t *app, in nxt_router_app_port_get()
[all …]
H A Dnxt_router.h91 nxt_task_t task; member
H A Dnxt_http_route.c684 nxt_http_route_table_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_table_create()
723 nxt_http_route_ruleset_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_ruleset_create()
771 nxt_http_route_rule_name_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_rule_name_create()
799 nxt_http_route_rule_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_rule_create()
841 nxt_http_route_addr_rule_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_addr_rule_create()
882 nxt_http_route_types_rule_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_types_rule_create()
923 nxt_http_route_pattern_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_http_route_pattern_create()
1291 nxt_http_pass_var(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_pass_var()
1331 nxt_http_pass_var_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_pass_var_ready()
1532 nxt_http_route_handler(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_route_handler()
[all …]
H A Dnxt_h1proto.c194 nxt_h1p_init(nxt_task_t *task) in nxt_h1p_init()
212 nxt_http_conn_init(nxt_task_t *task, void *obj, void *data) in nxt_http_conn_init()
309 nxt_http_conn_test(nxt_task_t *task, void *obj, void *data) in nxt_http_conn_test()
638 nxt_h1p_header_process(nxt_task_t *task, nxt_h1proto_t *h1p, in nxt_h1p_header_process()
1714 nxt_h1p_conn_sent(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_sent()
1892 nxt_h1p_idle_response(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_idle_response()
2000 nxt_h1p_shutdown(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_shutdown()
2047 nxt_h1p_closing(nxt_task_t *task, nxt_conn_t *c) in nxt_h1p_closing()
2104 nxt_h1p_conn_free(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_free()
2626 nxt_h1p_peer_read(nxt_task_t *task, nxt_http_peer_t *peer) in nxt_h1p_peer_read()
[all …]
H A Dnxt_var.c452 nxt_var_query(nxt_task_t *task, nxt_var_query_t *query, nxt_var_t *var, in nxt_var_query()
524 nxt_var_query_resolve(nxt_task_t *task, nxt_var_query_t *query, void *data, in nxt_var_query_resolve()
538 nxt_var_query_handle(nxt_task_t *task, nxt_var_query_t *query, in nxt_var_query_handle()
550 nxt_var_query_finish(nxt_task_t *task, nxt_var_query_t *query) in nxt_var_query_finish()
H A Dnxt_port_rpc.c92 nxt_port_rpc_register_handler(nxt_task_t *task, nxt_port_t *port, in nxt_port_rpc_register_handler()
121 nxt_port_rpc_register_handler_ex(nxt_task_t *task, nxt_port_t *port, in nxt_port_rpc_register_handler_ex()
188 nxt_port_rpc_ex_set_peer(nxt_task_t *task, nxt_port_t *port, in nxt_port_rpc_ex_set_peer()
254 nxt_port_rpc_remove_from_peers(nxt_task_t *task, nxt_port_t *port, in nxt_port_rpc_remove_from_peers()
307 nxt_port_rpc_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_rpc_handler()
367 nxt_port_rpc_remove_peer(nxt_task_t *task, nxt_port_t *port, nxt_pid_t peer) in nxt_port_rpc_remove_peer()
460 nxt_port_rpc_cancel(nxt_task_t *task, nxt_port_t *port, uint32_t stream) in nxt_port_rpc_cancel()
493 nxt_port_rpc_close(nxt_task_t *task, nxt_port_t *port) in nxt_port_rpc_close()
H A Dnxt_port_memory.c118 nxt_port_mmap_buf_completion(nxt_task_t *task, void *obj, void *data) in nxt_port_mmap_buf_completion()
204 nxt_port_incoming_port_mmap(nxt_task_t *task, nxt_process_t *process, in nxt_port_incoming_port_mmap()
287 nxt_port_new_port_mmap(nxt_task_t *task, nxt_port_mmaps_t *mmaps, in nxt_port_new_port_mmap()
368 nxt_shm_open(nxt_task_t *task, size_t size) in nxt_shm_open()
598 nxt_port_mmap_increase_buf(nxt_task_t *task, nxt_buf_t *b, size_t size, in nxt_port_mmap_increase_buf()
664 nxt_port_mmap_get_incoming_buf(nxt_task_t *task, nxt_port_t *port, in nxt_port_mmap_get_incoming_buf()
711 nxt_port_mmap_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_mmap_write()
765 nxt_port_mmap_read(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_mmap_read()
804 nxt_port_mmap_get_method(nxt_task_t *task, nxt_port_t *port, nxt_buf_t *b) in nxt_port_mmap_get_method()
854 nxt_process_broadcast_shm_ack(nxt_task_t *task, nxt_process_t *process) in nxt_process_broadcast_shm_ack()
[all …]
H A Dnxt_port.h327 nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_socket_write()
H A Dnxt_http_variables.c45 nxt_http_var_method(nxt_task_t *task, nxt_str_t *str, void *ctx) in nxt_http_var_method()
58 nxt_http_var_request_uri(nxt_task_t *task, nxt_str_t *str, void *ctx) in nxt_http_var_request_uri()
71 nxt_http_var_uri(nxt_task_t *task, nxt_str_t *str, void *ctx) in nxt_http_var_uri()
84 nxt_http_var_host(nxt_task_t *task, nxt_str_t *str, void *ctx) in nxt_http_var_host()
H A Dnxt_http_return.c72 nxt_http_return(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_return()
170 nxt_http_return_send_ready(nxt_task_t *task, void *obj, void *data) in nxt_http_return_send_ready()
213 nxt_http_return_var_error(nxt_task_t *task, void *obj, void *data) in nxt_http_return_var_error()
H A Dnxt_openssl.c133 nxt_openssl_library_init(nxt_task_t *task) in nxt_openssl_library_init()
208 nxt_openssl_library_free(nxt_task_t *task) in nxt_openssl_library_free()
268 nxt_openssl_library_free(nxt_task_t *task) in nxt_openssl_library_free()
294 nxt_openssl_server_init(nxt_task_t *task, nxt_mp_t *mp, in nxt_openssl_server_init()
976 nxt_openssl_bundle_hash_insert(nxt_task_t *task, nxt_lvlhsh_t *lvlhsh,
1136 nxt_openssl_server_free(nxt_task_t *task, nxt_tls_conf_t *conf)
1221 nxt_openssl_conn_free(nxt_task_t *task, nxt_conn_t *c)
1238 nxt_openssl_conn_handshake(nxt_task_t *task, void *obj, void *data)
1367 nxt_openssl_conn_io_sendbuf(nxt_task_t *task, nxt_sendbuf_t *sb)
1423 nxt_openssl_conn_io_shutdown(nxt_task_t *task, void *obj, void *data)
[all …]
H A Dnxt_work_queue.h41 nxt_task_t *task; member
H A Dnxt_thread.h138 nxt_task_t *task; member
H A Dnxt_socket.h121 #define nxt_socket_nonblocking(task, fd) \ argument
124 #define nxt_socket_blocking(task, fd) \ argument
H A Dnxt_source.h25 #define nxt_source_filter(thr, wq, task, next, out) \ argument
H A Dnxt_log.h48 #define nxt_alert(task, ...) \ argument
56 #define nxt_log(task, _level, ...) \ argument
67 #define nxt_trace(task, ...) \ argument
98 #define nxt_debug(task, ...) \ argument
H A Dnxt_job.h36 nxt_task_t *task; member
H A Dnxt_fastcgi_source.c121 nxt_fastcgi_source_handler(nxt_task_t *task, nxt_upstream_source_t *us, in nxt_fastcgi_source_handler()
386 nxt_fastcgi_source_record_filter(nxt_task_t *task, void *obj, void *data) in nxt_fastcgi_source_record_filter()
452 nxt_fastcgi_source_record_error(nxt_task_t *task, void *obj, void *data) in nxt_fastcgi_source_record_error()
463 nxt_fastcgi_source_header_filter(nxt_task_t *task, void *obj, void *data) in nxt_fastcgi_source_header_filter()
524 nxt_fastcgi_source_sync_buffer(nxt_task_t *task, nxt_fastcgi_source_t *fs, in nxt_fastcgi_source_sync_buffer()
543 nxt_fastcgi_source_header_process(nxt_task_t *task, nxt_fastcgi_source_t *fs) in nxt_fastcgi_source_header_process()
682 nxt_fastcgi_source_body_filter(nxt_task_t *task, void *obj, void *data) in nxt_fastcgi_source_body_filter()
730 nxt_fastcgi_source_error(nxt_task_t *task, nxt_stream_source_t *stream) in nxt_fastcgi_source_error()
743 nxt_fastcgi_source_fail(nxt_task_t *task, nxt_fastcgi_source_t *fs) in nxt_fastcgi_source_fail()
/unit/src/ruby/
H A Dnxt_ruby.c23 nxt_task_t *task; member
261 nxt_ruby_start(nxt_task_t *task, nxt_process_data_t *data) in nxt_ruby_start()

1234