/unit/src/ |
H A D | nxt_eventport_engine.c | 89 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 D | nxt_select_engine.c | 68 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 D | nxt_pollset_engine.c | 90 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 D | nxt_devpoll_engine.c | 96 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 D | nxt_poll_engine.c | 108 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 D | nxt_epoll_engine.c | 234 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 D | nxt_kqueue_engine.c | 173 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 D | nxt_event_engine.c | 48 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 D | nxt_timer.c | 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 D | nxt_conn_close.c | 19 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 D | nxt_signal.c | 111 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 D | nxt_conn_accept.c | 41 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 D | nxt_conn_read.c | 13 nxt_event_engine_t *engine; in nxt_conn_wait() local 42 nxt_event_engine_t *engine; in nxt_conn_io_read() local
|
H A D | nxt_signal.h | 39 #define nxt_event_engine_signals_start(engine) \ argument 42 #define nxt_event_engine_signals_stop(engine) \ argument
|
H A D | nxt_event_engine.h | 354 #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 D | nxt_thread.h | 84 nxt_event_engine_t *engine; member 148 nxt_event_engine_t *engine; member
|
H A D | nxt_conn.c | 105 nxt_conn_timer(nxt_event_engine_t *engine, nxt_conn_t *c, in nxt_conn_timer()
|
H A D | nxt_thread_pool.h | 30 nxt_event_engine_t *engine; member
|
H A D | nxt_conn.h | 271 #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 D | nxt_runtime.c | 282 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 D | nxt_conn_write.c | 23 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 D | nxt_thread.c | 186 nxt_event_engine_t *engine; in nxt_thread_exit() local
|
H A D | nxt_job.h | 47 nxt_event_engine_t *engine; member
|
H A D | nxt_conn_connect.c | 39 nxt_event_engine_t *engine; in nxt_conn_io_connect() local
|
H A D | nxt_fiber.h | 42 nxt_event_engine_t *engine; member
|