Home
last modified time | relevance | path

Searched defs:engine (Results 1 – 25 of 43) sorted by relevance

12

/unit/src/
H A Dnxt_eventport_engine.c89 nxt_eventport_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_eventport_create()
133 nxt_eventport_free(nxt_event_engine_t *engine) in nxt_eventport_free()
153 nxt_eventport_enable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_eventport_enable()
163 nxt_eventport_disable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_eventport_disable()
182 nxt_eventport_close(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_eventport_close()
192 nxt_eventport_enable_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_eventport_enable_read()
297 nxt_eventport_commit_changes(nxt_event_engine_t *engine) in nxt_eventport_commit_changes()
377 nxt_eventport_block_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_eventport_block_read()
426 nxt_eventport_enable_post(nxt_event_engine_t *engine, in nxt_eventport_enable_post()
436 nxt_eventport_signal(nxt_event_engine_t *engine, nxt_uint_t signo) in nxt_eventport_signal()
[all …]
H A Dnxt_select_engine.c68 nxt_select_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_select_create()
87 nxt_select_free(nxt_event_engine_t *engine) in nxt_select_free()
98 nxt_select_enable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_enable()
106 nxt_select_disable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_disable()
119 nxt_select_close(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_close()
128 nxt_select_enable_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_enable_read()
155 nxt_select_enable_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_enable_write()
196 nxt_select_disable_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_disable_read()
244 nxt_select_block_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_block_read()
253 nxt_select_block_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_block_write()
[all …]
H A Dnxt_pollset_engine.c90 nxt_pollset_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_pollset_create()
142 nxt_pollset_free(nxt_event_engine_t *engine) in nxt_pollset_free()
165 nxt_pollset_enable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_pollset_enable()
175 nxt_pollset_disable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_pollset_disable()
203 nxt_pollset_close(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_pollset_close()
212 nxt_pollset_enable_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_pollset_enable_read()
310 nxt_pollset_block_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_pollset_block_read()
357 nxt_pollset_change(nxt_event_engine_t *engine, nxt_fd_event_t *ev, in nxt_pollset_change()
380 nxt_pollset_commit_changes(nxt_event_engine_t *engine) in nxt_pollset_commit_changes()
482 nxt_pollset_remove(nxt_event_engine_t *engine, nxt_fd_t fd) in nxt_pollset_remove()
[all …]
H A Dnxt_devpoll_engine.c96 nxt_devpoll_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_devpoll_create()
148 nxt_devpoll_free(nxt_event_engine_t *engine) in nxt_devpoll_free()
170 nxt_devpoll_enable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_devpoll_enable()
180 nxt_devpoll_disable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_devpoll_disable()
218 nxt_devpoll_close(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_devpoll_close()
238 nxt_devpoll_enable_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_devpoll_enable_read()
336 nxt_devpoll_block_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_devpoll_block_read()
372 nxt_devpoll_change(nxt_event_engine_t *engine, nxt_fd_event_t *ev, in nxt_devpoll_change()
394 nxt_devpoll_commit_changes(nxt_event_engine_t *engine) in nxt_devpoll_commit_changes()
496 nxt_devpoll_remove(nxt_event_engine_t *engine, nxt_fd_t fd) in nxt_devpoll_remove()
[all …]
H A Dnxt_poll_engine.c108 nxt_poll_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_poll_create()
124 nxt_poll_free(nxt_event_engine_t *engine) in nxt_poll_free()
137 nxt_poll_enable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_poll_enable()
147 nxt_poll_disable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_poll_disable()
159 nxt_poll_close(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_poll_close()
248 nxt_poll_block_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_poll_block_read()
322 nxt_poll_commit_changes(nxt_event_engine_t *engine) in nxt_poll_commit_changes()
460 nxt_poll_set_delete(nxt_event_engine_t *engine, nxt_fd_t fd) in nxt_poll_set_delete()
500 nxt_poll(nxt_event_engine_t *engine, nxt_msec_t timeout) in nxt_poll()
637 nxt_poll_fd_hash_get(nxt_event_engine_t *engine, nxt_fd_t fd) in nxt_poll_fd_hash_get()
[all …]
H A Dnxt_epoll_engine.c234 nxt_epoll_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_epoll_create()
315 nxt_epoll_free(nxt_event_engine_t *engine) in nxt_epoll_free()
355 nxt_epoll_enable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_epoll_enable()
379 nxt_epoll_delete(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_epoll_delete()
401 nxt_epoll_close(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_epoll_close()
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() local
847 nxt_epoll_signal(nxt_event_engine_t *engine, nxt_uint_t signo) in nxt_epoll_signal()
871 nxt_epoll_poll(nxt_event_engine_t *engine, nxt_msec_t timeout) in nxt_epoll_poll()
[all …]
H A Dnxt_kqueue_engine.c173 nxt_kqueue_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_kqueue_create()
220 nxt_kqueue_free(nxt_event_engine_t *engine) in nxt_kqueue_free()
245 nxt_kqueue_enable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_kqueue_enable()
273 nxt_kqueue_delete(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_kqueue_delete()
297 nxt_kqueue_close(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_kqueue_close()
444 nxt_kqueue_fd_set(nxt_event_engine_t *engine, nxt_fd_event_t *ev, in nxt_kqueue_fd_set()
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()
637 nxt_kqueue_signal(nxt_event_engine_t *engine, nxt_uint_t signo) in nxt_kqueue_signal()
663 nxt_kqueue_poll(nxt_event_engine_t *engine, nxt_msec_t timeout) in nxt_kqueue_poll()
[all …]
H A Dnxt_event_engine.c48 nxt_event_engine_t *engine; in nxt_event_engine_create() local
168 nxt_event_engine_post_init(nxt_event_engine_t *engine) in nxt_event_engine_post_init()
183 nxt_event_engine_signal_pipe_create(nxt_event_engine_t *engine) in nxt_event_engine_signal_pipe_create()
219 nxt_event_engine_signal_pipe_free(nxt_event_engine_t *engine) in nxt_event_engine_signal_pipe_free()
333 nxt_event_engine_t *engine; in nxt_event_engine_post_handler() local
346 nxt_event_engine_t *engine; in nxt_event_engine_signal_pipe_error() local
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()
724 nxt_event_engine_t *engine; in nxt_event_engine_buf_mem_completion() local
[all …]
H A Dnxt_timer.c70 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_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() local
99 nxt_event_engine_t *engine; in nxt_conn_close_handler() local
146 nxt_event_engine_t *engine; in nxt_conn_close_timer_handler() local
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() local
184 nxt_signal_thread_stop(nxt_event_engine_t *engine) in nxt_signal_thread_stop()
H A Dnxt_conn_accept.c41 nxt_event_engine_t *engine; in nxt_listen_event() local
90 nxt_event_engine_t *engine; in nxt_conn_accept_alloc() local
191 nxt_event_engine_t *engine; in nxt_conn_accept() local
256 nxt_event_engine_t *engine; in nxt_conn_accept_close_idle() local
278 nxt_event_engine_t *engine; in nxt_conn_accept_close_idle_handler() local
H A Dnxt_conn_read.c13 nxt_event_engine_t *engine; in nxt_conn_wait() local
42 nxt_event_engine_t *engine; in nxt_conn_io_read() local
H A Dnxt_signal.h39 #define nxt_event_engine_signals_start(engine) \ argument
42 #define nxt_event_engine_signals_stop(engine) \ argument
H A Dnxt_event_engine.h354 #define nxt_fd_event_disable(engine, ev) \ argument
358 #define nxt_fd_event_delete(engine, ev) \ argument
362 #define nxt_fd_event_close(engine, ev) \ argument
366 #define nxt_fd_event_enable_read(engine, ev) \ argument
370 #define nxt_fd_event_enable_write(engine, ev) \ argument
374 #define nxt_fd_event_disable_read(engine, ev) \ argument
378 #define nxt_fd_event_disable_write(engine, ev) \ argument
382 #define nxt_fd_event_block_read(engine, ev) \ argument
390 #define nxt_fd_event_block_write(engine, ev) \ argument
398 #define nxt_fd_event_oneshot_read(engine, ev) \ argument
[all …]
H A Dnxt_thread.h84 nxt_event_engine_t *engine; member
148 nxt_event_engine_t *engine; member
H A Dnxt_conn.c105 nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c, in nxt_conn_timer()
H A Dnxt_thread_pool.h30 nxt_event_engine_t *engine; member
H A Dnxt_conn.h271 #define nxt_conn_connect(engine, c) \ argument
276 #define nxt_conn_read(engine, c) \ argument
287 #define nxt_conn_write(engine, c) \ argument
298 #define nxt_conn_idle(engine, c) \ argument
309 #define nxt_conn_active(engine, c) \ argument
H A Dnxt_runtime.c282 nxt_event_engine_t *engine; in nxt_runtime_event_engines() local
435 nxt_event_engine_t *engine; in nxt_runtime_quit() local
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() local
637 nxt_event_engine_t *engine; in nxt_runtime_event_engine_change() local
662 nxt_event_engine_t *engine; in nxt_runtime_event_engine_free() local
H A Dnxt_conn_write.c23 nxt_event_engine_t *engine; in nxt_conn_io_write() local
429 nxt_event_conn_write_delayed(nxt_event_engine_t *engine, nxt_conn_t *c, in nxt_event_conn_write_delayed()
H A Dnxt_thread.c186 nxt_event_engine_t *engine; in nxt_thread_exit() local
H A Dnxt_job.h47 nxt_event_engine_t *engine; member
H A Dnxt_conn_connect.c39 nxt_event_engine_t *engine; in nxt_conn_io_connect() local
H A Dnxt_fiber.h42 nxt_event_engine_t *engine; member

12