Home
last modified time | relevance | path

Searched defs:task (Results 51 – 75 of 98) sorted by last modified time

1234

/unit/src/
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_mp.c1042 nxt_task_t *task, void *obj, void *data) in nxt_mp_cleanup()
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_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_fiber.c124 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 Dnxt_fd_event.h106 nxt_task_t *task; member
H A Dnxt_http_chunk_parse.c28 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.h264 nxt_buf_dummy_completion(nxt_task_t *task, void *obj, void *data) in nxt_buf_dummy_completion()
H A Dnxt_cert.c58 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 Dnxt_external.c31 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_java.c78 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_h1proto_websocket.c117 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 Dnxt_upstream.c17 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.c42 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 Dnxt_buf.c57 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.c104 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 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()
/unit/src/test/
H A Dnxt_clone_test.c432 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()

1234