Home
last modified time | relevance | path

Searched refs:nxt_event_engine_t (Results 1 – 25 of 41) sorted by relevance

12

/unit/src/
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,
502 NXT_EXPORT void nxt_event_engine_free(nxt_event_engine_t *engine);
503 NXT_EXPORT void nxt_event_engine_start(nxt_event_engine_t *engine);
505 NXT_EXPORT void nxt_event_engine_post(nxt_event_engine_t *engine,
[all …]
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 …]
H A Dnxt_poll_engine.c29 static nxt_int_t nxt_poll_create(nxt_event_engine_t *engine,
31 static void nxt_poll_free(nxt_event_engine_t *engine);
33 static void nxt_poll_disable(nxt_event_engine_t *engine,
35 static nxt_bool_t nxt_poll_close(nxt_event_engine_t *engine,
37 static void nxt_poll_enable_read(nxt_event_engine_t *engine,
39 static void nxt_poll_enable_write(nxt_event_engine_t *engine,
41 static void nxt_poll_disable_read(nxt_event_engine_t *engine,
46 static void nxt_poll_block_write(nxt_event_engine_t *engine,
124 nxt_poll_free(nxt_event_engine_t *engine) in nxt_poll_free()
322 nxt_poll_commit_changes(nxt_event_engine_t *engine) in nxt_poll_commit_changes()
[all …]
H A Dnxt_eventport_engine.c17 static nxt_int_t nxt_eventport_create(nxt_event_engine_t *engine,
19 static void nxt_eventport_free(nxt_event_engine_t *engine);
20 static void nxt_eventport_enable(nxt_event_engine_t *engine,
22 static void nxt_eventport_disable(nxt_event_engine_t *engine,
24 static nxt_bool_t nxt_eventport_close(nxt_event_engine_t *engine,
26 static void nxt_eventport_enable_read(nxt_event_engine_t *engine,
41 static void nxt_eventport_block_read(nxt_event_engine_t *engine,
54 static void nxt_eventport_poll(nxt_event_engine_t *engine,
133 nxt_eventport_free(nxt_event_engine_t *engine) in nxt_eventport_free()
297 nxt_eventport_commit_changes(nxt_event_engine_t *engine) in nxt_eventport_commit_changes()
[all …]
H A Dnxt_pollset_engine.c25 static nxt_int_t nxt_pollset_create(nxt_event_engine_t *engine,
27 static void nxt_pollset_free(nxt_event_engine_t *engine);
30 static nxt_bool_t nxt_pollset_close(nxt_event_engine_t *engine,
32 static void nxt_pollset_enable_read(nxt_event_engine_t *engine,
34 static void nxt_pollset_enable_write(nxt_event_engine_t *engine,
36 static void nxt_pollset_disable_read(nxt_event_engine_t *engine,
40 static void nxt_pollset_block_read(nxt_event_engine_t *engine,
42 static void nxt_pollset_block_write(nxt_event_engine_t *engine,
54 static nxt_int_t nxt_pollset_write(nxt_event_engine_t *engine,
142 nxt_pollset_free(nxt_event_engine_t *engine) in nxt_pollset_free()
[all …]
H A Dnxt_devpoll_engine.c30 static nxt_int_t nxt_devpoll_create(nxt_event_engine_t *engine,
32 static void nxt_devpoll_free(nxt_event_engine_t *engine);
35 static nxt_bool_t nxt_devpoll_close(nxt_event_engine_t *engine,
37 static void nxt_devpoll_enable_read(nxt_event_engine_t *engine,
39 static void nxt_devpoll_enable_write(nxt_event_engine_t *engine,
45 static void nxt_devpoll_block_read(nxt_event_engine_t *engine,
47 static void nxt_devpoll_block_write(nxt_event_engine_t *engine,
59 static nxt_int_t nxt_devpoll_write(nxt_event_engine_t *engine,
61 static void nxt_devpoll_poll(nxt_event_engine_t *engine,
148 nxt_devpoll_free(nxt_event_engine_t *engine) in nxt_devpoll_free()
[all …]
H A Dnxt_kqueue_engine.c54 static nxt_int_t nxt_kqueue_create(nxt_event_engine_t *engine,
56 static void nxt_kqueue_free(nxt_event_engine_t *engine);
60 static nxt_bool_t nxt_kqueue_close(nxt_event_engine_t *engine,
62 static void nxt_kqueue_enable_read(nxt_event_engine_t *engine,
70 static void nxt_kqueue_block_read(nxt_event_engine_t *engine,
82 static void nxt_kqueue_close_file(nxt_event_engine_t *engine,
87 static void nxt_kqueue_error(nxt_event_engine_t *engine);
220 nxt_kqueue_free(nxt_event_engine_t *engine) in nxt_kqueue_free()
464 nxt_kqueue_get_kevent(nxt_event_engine_t *engine) in nxt_kqueue_get_kevent()
493 nxt_kqueue_error(nxt_event_engine_t *engine) in nxt_kqueue_error()
[all …]
H A Dnxt_epoll_engine.c40 static nxt_int_t nxt_epoll_create(nxt_event_engine_t *engine,
42 static void nxt_epoll_test_accept4(nxt_event_engine_t *engine,
44 static void nxt_epoll_free(nxt_event_engine_t *engine);
48 static nxt_bool_t nxt_epoll_close(nxt_event_engine_t *engine,
50 static void nxt_epoll_enable_read(nxt_event_engine_t *engine,
58 static void nxt_epoll_block_read(nxt_event_engine_t *engine,
315 nxt_epoll_free(nxt_event_engine_t *engine) in nxt_epoll_free()
609 nxt_epoll_commit_changes(nxt_event_engine_t *engine) in nxt_epoll_commit_changes()
666 nxt_epoll_add_signal(nxt_event_engine_t *engine) in nxt_epoll_add_signal()
813 nxt_event_engine_t *engine; in nxt_epoll_eventfd_handler()
[all …]
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_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_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_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_thread_pool.h30 nxt_event_engine_t *engine;
38 nxt_event_engine_t *engine, nxt_work_handler_t exit);
H A Dnxt_fiber.h42 nxt_event_engine_t *engine;
48 nxt_fiber_main_t *nxt_fiber_main_create(nxt_event_engine_t *engine);
H A Dnxt_conn.h224 NXT_EXPORT void nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c);
226 NXT_EXPORT void nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c,
261 nxt_bool_t nxt_event_conn_write_delayed(nxt_event_engine_t *engine,
278 nxt_event_engine_t *e = engine; \
289 nxt_event_engine_t *e = engine; \
300 nxt_event_engine_t *e = engine; \
311 nxt_event_engine_t *e = engine; \
H A Dnxt_conn_close.c19 nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c) in nxt_conn_close()
78 nxt_event_engine_t *engine; in nxt_conn_shutdown_handler()
99 nxt_event_engine_t *engine; in nxt_conn_close_handler()
146 nxt_event_engine_t *engine; in nxt_conn_close_timer_handler()
H A Dnxt_signal.c111 nxt_signal_thread_start(nxt_event_engine_t *engine) in nxt_signal_thread_start()
158 nxt_event_engine_t *engine; in nxt_signal_thread()
184 nxt_signal_thread_stop(nxt_event_engine_t *engine) in nxt_signal_thread_stop()
H A Dnxt_router.h61 nxt_event_engine_t *engine;
88 nxt_event_engine_t *engine;
119 nxt_event_engine_t *engine;
222 nxt_event_engine_t *engine;
H A Dnxt_thread.h84 nxt_event_engine_t *engine;
148 nxt_event_engine_t *engine;
H A Dnxt_sockaddr.h61 nxt_sockaddr_t *nxt_sockaddr_cache_alloc(nxt_event_engine_t *engine,
63 void nxt_sockaddr_cache_free(nxt_event_engine_t *engine, nxt_conn_t *c);
H A Dnxt_conn_accept.c41 nxt_event_engine_t *engine; in nxt_listen_event()
90 nxt_event_engine_t *engine; in nxt_conn_accept_alloc()
191 nxt_event_engine_t *engine; in nxt_conn_accept()
256 nxt_event_engine_t *engine; in nxt_conn_accept_close_idle()
278 nxt_event_engine_t *engine; in nxt_conn_accept_close_idle_handler()
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_job.h47 nxt_event_engine_t *engine;
H A Dnxt_main.h26 typedef struct nxt_event_engine_s nxt_event_engine_t; typedef
H A Dnxt_conn_read.c13 nxt_event_engine_t *engine; in nxt_conn_wait()
42 nxt_event_engine_t *engine; in nxt_conn_io_read()

12