/unit/src/ |
H A D | nxt_select_engine.c | 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() 184 nxt_fd_event_t *ev; in nxt_select_error_handler() local 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() 262 nxt_select_oneshot_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_select_oneshot_read() [all …]
|
H A D | nxt_eventport_engine.c | 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() 207 nxt_eventport_enable_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_eventport_enable_write() 228 nxt_eventport_enable_event(nxt_event_engine_t *engine, nxt_fd_event_t *ev, in nxt_eventport_enable_event() 301 nxt_fd_event_t *ev; in nxt_eventport_commit_changes() local 365 nxt_fd_event_t *ev; in nxt_eventport_error_handler() local 377 nxt_eventport_block_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_eventport_block_read() 386 nxt_eventport_block_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_eventport_block_write() [all …]
|
H A D | nxt_pollset_engine.c | 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() 240 nxt_pollset_enable_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_pollset_enable_write() 268 nxt_pollset_disable_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_pollset_disable_read() 310 nxt_pollset_block_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_pollset_block_read() 319 nxt_pollset_block_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_pollset_block_write() 357 nxt_pollset_change(nxt_event_engine_t *engine, nxt_fd_event_t *ev, in nxt_pollset_change() 384 nxt_fd_event_t *ev; in nxt_pollset_commit_changes() local [all …]
|
H A D | nxt_devpoll_engine.c | 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() 266 nxt_devpoll_enable_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_devpoll_enable_write() 294 nxt_devpoll_disable_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_devpoll_disable_read() 336 nxt_devpoll_block_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_devpoll_block_read() 345 nxt_devpoll_block_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_devpoll_block_write() 372 nxt_devpoll_change(nxt_event_engine_t *engine, nxt_fd_event_t *ev, in nxt_devpoll_change() 399 nxt_fd_event_t *ev; in nxt_devpoll_commit_changes() local [all …]
|
H A D | nxt_kqueue_engine.c | 245 nxt_kqueue_enable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_kqueue_enable() 258 nxt_kqueue_disable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_kqueue_disable() 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() 324 nxt_kqueue_enable_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_kqueue_enable_read() 366 nxt_kqueue_block_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_kqueue_block_read() 444 nxt_kqueue_fd_set(nxt_event_engine_t *engine, nxt_fd_event_t *ev, in nxt_kqueue_fd_set() 496 nxt_fd_event_t *ev; in nxt_kqueue_error() local 527 nxt_fd_event_t *ev; in nxt_kqueue_fd_error_handler() local 551 nxt_file_event_t *ev; in nxt_kqueue_file_error_handler() local [all …]
|
H A D | nxt_poll_engine.c | 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() 168 nxt_poll_enable_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_poll_enable_read() 188 nxt_poll_enable_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_poll_enable_write() 208 nxt_poll_disable_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_poll_disable_read() 248 nxt_poll_block_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_poll_block_read() 257 nxt_poll_block_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_poll_block_write() 266 nxt_poll_oneshot_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_poll_oneshot_read() 325 nxt_fd_event_t *ev; in nxt_poll_commit_changes() local [all …]
|
H A D | nxt_epoll_engine.c | 355 nxt_epoll_enable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_epoll_enable() 366 nxt_epoll_disable(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_epoll_disable() 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() 410 nxt_epoll_enable_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_epoll_enable_read() 504 nxt_epoll_block_read(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_epoll_block_read() 513 nxt_epoll_block_write(nxt_event_engine_t *engine, nxt_fd_event_t *ev) in nxt_epoll_block_write() 612 nxt_fd_event_t *ev; in nxt_epoll_commit_changes() local 652 nxt_fd_event_t *ev; in nxt_epoll_error_handler() local 725 nxt_fd_event_t *ev; in nxt_epoll_signalfd_handler() local [all …]
|
H A D | nxt_socketpair.c | 86 nxt_socketpair_send(nxt_fd_event_t *ev, nxt_fd_t *fd, nxt_iobuf_t *iob, in nxt_socketpair_send() 141 nxt_socketpair_recv(nxt_fd_event_t *ev, nxt_iobuf_t *iob, nxt_uint_t niob, in nxt_socketpair_recv()
|
H A D | nxt_fd_event.c | 33 nxt_fd_event_hash_add(nxt_lvlhsh_t *lvlhsh, nxt_fd_t fd, nxt_fd_event_t *ev) in nxt_fd_event_hash_add() 99 nxt_fd_event_t *ev; in nxt_fd_event_hash_destroy() local
|
H A D | nxt_log_moderation.c | 77 nxt_timer_t *ev; in nxt_log_moderate_timer_handler() local
|
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_conn.h | 176 #define nxt_conn_timer_init(ev, c, wq) \ argument 184 #define nxt_read_timer_conn(ev) \ argument 188 #define nxt_write_timer_conn(ev) \ argument
|
H A D | nxt_conn_accept.c | 381 nxt_fd_event_t *ev; in nxt_conn_listen_event_error() local
|
H A D | nxt_fiber.c | 416 nxt_timer_t *ev; in nxt_fiber_timer_handler() local
|
H A D | nxt_event_engine.c | 294 nxt_fd_event_t *ev; in nxt_event_engine_signal_pipe() local
|
/unit/src/nodejs/unit-http/ |
H A D | websocket_connection.js | 48 this.on('newListener', function(ev) { argument 52 }).on('removeListener', function(ev) { argument
|
H A D | http_server.js | 430 this.on('newListener', function(ev) { argument 434 }).on('removeListener', function(ev) { argument
|