/unit/src/ |
H A D | nxt_port_socket.c | 42 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 D | nxt_mp.c | 1042 nxt_task_t *task, void *obj, void *data) in nxt_mp_cleanup()
|
H A D | nxt_port_rpc.c | 92 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 D | nxt_port_memory.c | 118 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 D | nxt_work_queue.h | 41 nxt_task_t *task; member
|
H A D | nxt_thread.h | 138 nxt_task_t *task; member
|
H A D | nxt_socket.h | 121 #define nxt_socket_nonblocking(task, fd) \ argument 124 #define nxt_socket_blocking(task, fd) \ argument
|
H A D | nxt_source.h | 25 #define nxt_source_filter(thr, wq, task, next, out) \ argument
|
H A D | nxt_log.h | 48 #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 D | nxt_job.h | 36 nxt_task_t *task; member
|
H A D | nxt_fiber.c | 124 nxt_fiber_create_stack(nxt_task_t *task, nxt_fiber_t *fib) in nxt_fiber_create_stack() 159 nxt_fiber_create_stack(nxt_task_t *task, nxt_fiber_t *fib) in nxt_fiber_create_stack() 235 nxt_task_t *task; in nxt_fiber_trampoline() local 300 nxt_task_t *task; in nxt_fiber_trampoline() local 331 nxt_fiber_switch_handler(nxt_task_t *task, void *obj, void *data) in nxt_fiber_switch_handler() 343 nxt_fiber_switch(nxt_task_t *task, nxt_fiber_t *fib) in nxt_fiber_switch() 363 nxt_fiber_yield(nxt_task_t *task) in nxt_fiber_yield() 385 nxt_fiber_sleep(nxt_task_t *task, nxt_msec_t timeout) in nxt_fiber_sleep() 413 nxt_fiber_timer_handler(nxt_task_t *task, void *obj, void *data) in nxt_fiber_timer_handler() 431 nxt_fiber_wait(nxt_task_t *task) in nxt_fiber_wait() [all …]
|
H A D | nxt_fd_event.h | 106 nxt_task_t *task; member
|
H A D | nxt_http_chunk_parse.c | 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 | 264 nxt_buf_dummy_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_dummy_completion()
|
H A D | nxt_cert.c | 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() 1124 nxt_cert_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_cert_store_get_handler() 1192 nxt_cert_store_delete(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp) in nxt_cert_store_delete() 1214 nxt_cert_store_delete_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_cert_store_delete_handler()
|
H A D | nxt_external.c | 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_java.c | 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_h1proto_websocket.c | 117 nxt_h1p_websocket_frame_start(nxt_task_t *task, nxt_http_request_t *r, in nxt_h1p_websocket_frame_start() 161 nxt_h1p_conn_ws_keepalive(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_keepalive() 358 nxt_h1p_conn_ws_keepalive_disable(nxt_task_t *task, nxt_h1proto_t *h1p) in nxt_h1p_conn_ws_keepalive_disable() 378 nxt_h1p_conn_ws_keepalive_enable(nxt_task_t *task, nxt_h1proto_t *h1p) in nxt_h1p_conn_ws_keepalive_enable() 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() 633 nxt_h1p_conn_ws_error_sent(nxt_task_t *task, void *obj, void *data) in nxt_h1p_conn_ws_error_sent() [all …]
|
H A D | nxt_upstream.c | 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 | 42 nxt_event_engine_create(nxt_task_t *task, in nxt_event_engine_create() 238 nxt_event_engine_signal_pipe_close(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_signal_pipe_close() 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() 344 nxt_event_engine_signal_pipe_error(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_signal_pipe_error() 361 nxt_event_engine_signal_handler(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_signal_handler() 466 nxt_event_engine_queue_pop(nxt_event_engine_t *engine, nxt_task_t **task, in nxt_event_engine_queue_pop() 512 nxt_task_t *task; in nxt_event_engine_start() local 721 nxt_event_engine_buf_mem_completion(nxt_task_t *task, void *obj, void *data) in nxt_event_engine_buf_mem_completion()
|
H A D | nxt_buf.c | 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 | 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() 153 nxt_http_proxy_server_get(nxt_task_t *task, nxt_upstream_server_t *us) in nxt_http_proxy_server_get() 167 nxt_http_proxy_upstream_ready(nxt_task_t *task, nxt_upstream_server_t *us) in nxt_http_proxy_upstream_ready() 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() 320 nxt_http_proxy_buf_mem_alloc(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_proxy_buf_mem_alloc() 366 nxt_http_proxy_buf_mem_free(nxt_task_t *task, nxt_http_request_t *r, in nxt_http_proxy_buf_mem_free() [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()
|
/unit/src/test/ |
H A D | nxt_clone_test.c | 432 nxt_task_t *task; in nxt_clone_creds_test() local 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()
|