Home
last modified time | relevance | path

Searched refs:nxt_event_engine_t (Results 1 – 25 of 43) sorted by last modified time

12

/unit/src/
H A Dnxt_router.c170 nxt_event_engine_t *engine);
939 nxt_event_engine_t *engine; in nxt_router_remove_pid_handler()
2852 nxt_event_engine_t *engine; in nxt_router_app_prefork_ready()
3215 nxt_event_engine_t *engine) in nxt_router_thread_create()
3327 nxt_event_engine_t *engine; in nxt_router_thread_start()
3479 nxt_event_engine_t *engine; in nxt_router_listen_socket_update()
3543 nxt_event_engine_t *engine; in nxt_router_worker_thread_quit()
3622 nxt_event_engine_t *engine; in nxt_router_listen_event_release()
3718 nxt_event_engine_t *engine; in nxt_router_thread_exit_handler()
4594 nxt_event_engine_t *engine; in nxt_router_adjust_idle_timer()
[all …]
H A Dnxt_router.h61 nxt_event_engine_t *engine;
84 nxt_event_engine_t *engine;
115 nxt_event_engine_t *engine;
214 nxt_event_engine_t *engine;
H A Dnxt_sockaddr.c24 nxt_sockaddr_cache_alloc(nxt_event_engine_t *engine, nxt_listen_socket_t *ls) in nxt_sockaddr_cache_alloc()
57 nxt_sockaddr_cache_free(nxt_event_engine_t *engine, nxt_conn_t *c) in nxt_sockaddr_cache_free()
H A Dnxt_process.c368 nxt_event_engine_t *engine; in nxt_process_setup()
H A Dnxt_http.h182 nxt_event_engine_t *engine;
H A Dnxt_controller.c676 nxt_event_engine_t *engine; in nxt_controller_conn_init()
H A Dnxt_h1proto.c216 nxt_event_engine_t *engine; in nxt_http_conn_init()
315 nxt_event_engine_t *engine; in nxt_http_conn_test()
1023 nxt_event_engine_t *engine; in nxt_h1p_conn_request_body_read()
1717 nxt_event_engine_t *engine; in nxt_h1p_conn_sent()
1787 nxt_event_engine_t *engine; in nxt_h1p_keepalive()
2108 nxt_event_engine_t *engine; in nxt_h1p_conn_free()
2379 nxt_event_engine_t *engine; in nxt_h1p_peer_header_sent()
2498 nxt_event_engine_t *engine; in nxt_h1p_peer_header_read_done()
H A Dnxt_port.h250 nxt_event_engine_t *engine;
H A Dnxt_thread.h84 nxt_event_engine_t *engine;
148 nxt_event_engine_t *engine;
H A Dnxt_signal.h46 NXT_EXPORT nxt_int_t nxt_signal_thread_start(nxt_event_engine_t *engine);
47 NXT_EXPORT void nxt_signal_thread_stop(nxt_event_engine_t *engine);
H A Dnxt_job.h47 nxt_event_engine_t *engine;
H A Dnxt_fiber.c23 nxt_fiber_main_create(nxt_event_engine_t *engine) in nxt_fiber_main_create()
H A Dnxt_event_engine.h34 nxt_int_t (*create)(nxt_event_engine_t *engine,
38 void (*free)(nxt_event_engine_t *engine);
45 void (*enable)(nxt_event_engine_t *engine,
49 void (*disable)(nxt_event_engine_t *engine,
56 void (*delete)(nxt_event_engine_t *engine,
67 nxt_bool_t (*close)(nxt_event_engine_t *engine,
156 void (*poll)(nxt_event_engine_t *engine,
497 NXT_EXPORT void nxt_event_engine_free(nxt_event_engine_t *engine);
498 NXT_EXPORT void nxt_event_engine_start(nxt_event_engine_t *engine);
500 NXT_EXPORT void nxt_event_engine_post(nxt_event_engine_t *engine,
[all …]
H A Dnxt_runtime.c24 static void nxt_runtime_close_idle_connections(nxt_event_engine_t *engine);
282 nxt_event_engine_t *engine; in nxt_runtime_event_engines()
435 nxt_event_engine_t *engine; in nxt_runtime_quit()
469 nxt_runtime_close_idle_connections(nxt_event_engine_t *engine) in nxt_runtime_close_idle_connections()
548 nxt_event_engine_t *engine; in nxt_runtime_exit()
594 nxt_queue_each(engine, &rt->engines, nxt_event_engine_t, link) { in nxt_runtime_exit()
620 nxt_event_engine_t *engine; in nxt_runtime_event_engine_change()
645 nxt_event_engine_t *engine; in nxt_runtime_event_engine_free()
650 engine = nxt_queue_link_data(link, nxt_event_engine_t, link); in nxt_runtime_event_engine_free()
H A Dnxt_h1proto_websocket.c224 nxt_event_engine_t *engine; in nxt_h1p_conn_ws_frame_header_read()
547 nxt_event_engine_t *engine; in nxt_h1p_conn_ws_frame_payload_read()
H A Dnxt_sockaddr.h70 nxt_sockaddr_t *nxt_sockaddr_cache_alloc(nxt_event_engine_t *engine,
72 void nxt_sockaddr_cache_free(nxt_event_engine_t *engine, nxt_conn_t *c);
H A Dnxt_event_engine.c26 nxt_event_engine_t *engine);
41 nxt_event_engine_t *
48 nxt_event_engine_t *engine; in nxt_event_engine_create()
50 engine = nxt_zalloc(sizeof(nxt_event_engine_t)); in nxt_event_engine_create()
168 nxt_event_engine_post_init(nxt_event_engine_t *engine) in nxt_event_engine_post_init()
333 nxt_event_engine_t *engine; in nxt_event_engine_post_handler()
346 nxt_event_engine_t *engine; in nxt_event_engine_signal_pipe_error()
383 nxt_event_engine_change(nxt_event_engine_t *engine, in nxt_event_engine_change()
448 nxt_event_engine_free(nxt_event_engine_t *engine) in nxt_event_engine_free()
509 nxt_event_engine_start(nxt_event_engine_t *engine) in nxt_event_engine_start()
[all …]
H A Dnxt_buf.c16 nxt_event_engine_t *engine;
H A Dnxt_thread.c186 nxt_event_engine_t *engine; in nxt_thread_exit()
200 engine = nxt_container_of(link->work.task, nxt_event_engine_t, task); in nxt_thread_exit()
H A Dnxt_timer.c24 static void nxt_timer_change(nxt_event_engine_t *engine, nxt_timer_t *timer,
26 static void nxt_timer_changes_commit(nxt_event_engine_t *engine);
70 nxt_timer_add(nxt_event_engine_t *engine, nxt_timer_t *timer, in nxt_timer_add()
105 nxt_timer_delete(nxt_event_engine_t *engine, nxt_timer_t *timer) in nxt_timer_delete()
126 nxt_timer_change(nxt_event_engine_t *engine, nxt_timer_t *timer, in nxt_timer_change()
160 nxt_timer_changes_commit(nxt_event_engine_t *engine) in nxt_timer_changes_commit()
229 nxt_timer_find(nxt_event_engine_t *engine) in nxt_timer_find()
281 nxt_timer_expire(nxt_event_engine_t *engine, nxt_msec_t now) in nxt_timer_expire()
H A Dnxt_stream_module.c92 nxt_event_engine_t *engine; in nxt_stream_connection_peer()
H A Dnxt_thread_pool.c19 nxt_thread_pool_init_t init, nxt_event_engine_t *engine, in nxt_thread_pool_create()
H A Dnxt_thread_pool.h30 nxt_event_engine_t *engine;
38 nxt_event_engine_t *engine, nxt_work_handler_t exit);
H A Dnxt_timer.h96 nxt_msec_t nxt_timer_find(nxt_event_engine_t *engine);
97 void nxt_timer_expire(nxt_event_engine_t *engine, nxt_msec_t now);
99 NXT_EXPORT void nxt_timer_add(nxt_event_engine_t *engine, nxt_timer_t *timer,
101 NXT_EXPORT nxt_bool_t nxt_timer_delete(nxt_event_engine_t *engine,
105 nxt_timer_disable(nxt_event_engine_t *engine, nxt_timer_t *timer) in nxt_timer_disable()
H A Dnxt_select_engine.c10 static nxt_int_t nxt_select_create(nxt_event_engine_t *engine,
12 static void nxt_select_free(nxt_event_engine_t *engine);
15 static nxt_bool_t nxt_select_close(nxt_event_engine_t *engine,
17 static void nxt_select_enable_read(nxt_event_engine_t *engine,
19 static void nxt_select_enable_write(nxt_event_engine_t *engine,
22 static void nxt_select_disable_read(nxt_event_engine_t *engine,
24 static void nxt_select_disable_write(nxt_event_engine_t *engine,
26 static void nxt_select_block_read(nxt_event_engine_t *engine,
28 static void nxt_select_block_write(nxt_event_engine_t *engine,
30 static void nxt_select_oneshot_read(nxt_event_engine_t *engine,
[all …]

12