/unit/src/ |
H A D | nxt_select_engine.c | 132 fd = ev->fd; in nxt_select_enable_read() 138 ev->task, ev, ev->data); in nxt_select_enable_read() 159 fd = ev->fd; in nxt_select_enable_write() 165 ev->task, ev, ev->data); in nxt_select_enable_write() 186 ev = obj; in nxt_select_error_handler() 191 ev->error_handler(task, ev, data); in nxt_select_error_handler() 200 fd = ev->fd; in nxt_select_disable_read() 338 fd, ev->read, ev->write); in nxt_select_poll() 347 ev->task, ev, ev->data); in nxt_select_poll() 355 fd, ev->read, ev->write); in nxt_select_poll() [all …]
|
H A D | nxt_eventport_engine.c | 21 nxt_fd_event_t *ev); 234 engine->u.eventport.fd, ev->fd, events, ev); in nxt_eventport_enable_event() 319 port, ev->fd, change->events, ev); in nxt_eventport_commit_changes() 322 ev->fd, change->events, ev); in nxt_eventport_commit_changes() 346 ev->task, ev, ev->data); in nxt_eventport_commit_changes() 367 ev = obj; in nxt_eventport_error_handler() 372 ev->error_handler(task, ev, data); in nxt_eventport_error_handler() 540 event->portev_object, events, ev, ev->read, ev->write); in nxt_eventport_poll() 548 ev->task, ev, ev->data); in nxt_eventport_poll() 557 ev->task, ev, ev->data); in nxt_eventport_poll() [all …]
|
H A D | nxt_devpoll_engine.c | 36 nxt_fd_event_t *ev); 38 nxt_fd_event_t *ev); 40 nxt_fd_event_t *ev); 42 nxt_fd_event_t *ev); 44 nxt_fd_event_t *ev); 46 nxt_fd_event_t *ev); 487 ev->task, ev, ev->data); in nxt_devpoll_change_error() 619 fd, events, ev->read, ev->write); in nxt_devpoll_poll() 627 ev->task, ev, ev->data); in nxt_devpoll_poll() 636 ev->task, ev, ev->data); in nxt_devpoll_poll() [all …]
|
H A D | nxt_pollset_engine.c | 31 nxt_fd_event_t *ev); 33 nxt_fd_event_t *ev); 35 nxt_fd_event_t *ev); 37 nxt_fd_event_t *ev); 39 nxt_fd_event_t *ev); 41 nxt_fd_event_t *ev); 43 nxt_fd_event_t *ev); 472 ev->task, ev, ev->data); in nxt_pollset_change_error() 611 ev->task, ev, ev->data); in nxt_pollset_poll() 620 ev->task, ev, ev->data); in nxt_pollset_poll() [all …]
|
H A D | nxt_poll_engine.c | 34 nxt_fd_event_t *ev); 36 nxt_fd_event_t *ev); 38 nxt_fd_event_t *ev); 40 nxt_fd_event_t *ev); 42 nxt_fd_event_t *ev); 369 ev->task, ev, ev->data); in nxt_poll_commit_changes() 415 phe->event = ev; in nxt_poll_set_add() 561 fd, events, ev->read, ev->write); in nxt_poll() 571 ev->error_handler, ev->task, ev, ev->data); in nxt_poll() 614 ev->task, ev, ev->data); in nxt_poll() [all …]
|
H A D | nxt_socketpair.c | 100 nxt_debug(ev->task, "sendmsg(%d, %FD, %FD, %ui): %z", ev->fd, fd[0], in nxt_socketpair_send() 112 nxt_debug(ev->task, "sendmsg(%d) not ready", ev->fd); in nxt_socketpair_send() 119 nxt_debug(ev->task, "sendmsg(%d) no buffers", ev->fd); in nxt_socketpair_send() 123 nxt_debug(ev->task, "sendmsg(%d) interrupted", ev->fd); in nxt_socketpair_send() 133 ev->write_ready = 0; in nxt_socketpair_send() 160 ev->closed = 1; in nxt_socketpair_recv() 161 ev->read_ready = 0; in nxt_socketpair_recv() 171 nxt_debug(ev->task, "recvmsg(%d) not ready", ev->fd); in nxt_socketpair_recv() 172 ev->read_ready = 0; in nxt_socketpair_recv() 177 nxt_debug(ev->task, "recvmsg(%d) interrupted", ev->fd); in nxt_socketpair_recv() [all …]
|
H A D | nxt_epoll_engine.c | 49 nxt_fd_event_t *ev); 51 nxt_fd_event_t *ev); 53 nxt_fd_event_t *ev); 636 nxt_epoll_error_handler, ev->task, ev, ev->data); in nxt_epoll_commit_changes() 654 ev = obj; in nxt_epoll_error_handler() 659 ev->error_handler(ev->task, ev, data); in nxt_epoll_error_handler() 729 ev = obj; in nxt_epoll_signalfd_handler() 920 ev->fd, events, ev, ev->read, ev->write); in nxt_epoll_poll() 952 ev->task, ev, ev->data); in nxt_epoll_poll() 972 ev->task, ev, ev->data); in nxt_epoll_poll() [all …]
|
H A D | nxt_kqueue_engine.c | 61 nxt_fd_event_t *ev); 63 nxt_fd_event_t *ev); 511 ev->task, ev, ev->data); in nxt_kqueue_error() 529 ev = obj; in nxt_kqueue_fd_error_handler() 533 if (ev->kq_eof && ev->kq_errno != 0) { in nxt_kqueue_fd_error_handler() 534 ev->error = ev->kq_errno; in nxt_kqueue_fd_error_handler() 537 ev->fd, ev->kq_errno); in nxt_kqueue_fd_error_handler() 542 ev->error = ev->kq_errno; in nxt_kqueue_fd_error_handler() 544 ev->error_handler(task, ev, data); in nxt_kqueue_fd_error_handler() 553 ev = obj; in nxt_kqueue_file_error_handler() [all …]
|
H A D | nxt_event_engine.h | 346 nxt_fd_event_t *ev); 355 (engine)->event.disable(engine, ev) 359 (engine)->event.delete(engine, ev) 363 (engine)->event.close(engine, ev) 367 (engine)->event.enable_read(engine, ev) 371 (engine)->event.enable_write(engine, ev) 375 (engine)->event.disable_read(engine, ev) 379 (engine)->event.disable_write(engine, ev) 399 (engine)->event.oneshot_read(engine, ev) 403 (engine)->event.oneshot_write(engine, ev) [all …]
|
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() argument 40 lhq.value = ev; in nxt_fd_event_hash_add() 49 nxt_alert(ev->task, "fd event %d is already in hash", ev->fd); in nxt_fd_event_hash_add() 99 nxt_fd_event_t *ev; in nxt_fd_event_hash_destroy() local 102 ev = nxt_lvlhsh_retrieve(lvlhsh, &nxt_event_set_fd_hash_proto, NULL); in nxt_fd_event_hash_destroy() 104 } while (ev != NULL); in nxt_fd_event_hash_destroy()
|
H A D | nxt_log_moderation.c | 77 nxt_timer_t *ev; in nxt_log_moderate_timer_handler() local 81 ev = obj; in nxt_log_moderate_timer_handler() 82 mod = nxt_timer_data(ev, nxt_log_moderation_t, timer); in nxt_log_moderate_timer_handler()
|
H A D | nxt_conn.h | 176 #define nxt_conn_timer_init(ev, c, wq) \ argument 178 (ev)->work_queue = (wq); \ 179 (ev)->log = &(c)->log; \ 180 (ev)->bias = NXT_TIMER_DEFAULT_BIAS; \ 184 #define nxt_read_timer_conn(ev) \ argument 185 nxt_timer_data(ev, nxt_conn_t, read_timer) 188 #define nxt_write_timer_conn(ev) \ argument 189 nxt_timer_data(ev, nxt_conn_t, write_timer)
|
H A D | nxt_socket.h | 115 NXT_EXPORT ssize_t nxt_socketpair_send(nxt_fd_event_t *ev, nxt_fd_t *fd, 117 NXT_EXPORT ssize_t nxt_socketpair_recv(nxt_fd_event_t *ev,
|
H A D | nxt_conn_accept.c | 381 nxt_fd_event_t *ev; in nxt_conn_listen_event_error() local 383 ev = obj; in nxt_conn_listen_event_error() 385 nxt_alert(task, "accept(%d) event error", ev->fd); in nxt_conn_listen_event_error()
|
H A D | nxt_fiber.c | 416 nxt_timer_t *ev; in nxt_fiber_timer_handler() local 418 ev = obj; in nxt_fiber_timer_handler() 422 fib = nxt_timer_data(ev, nxt_fiber_t, timer); in nxt_fiber_timer_handler()
|
H A D | nxt_event_engine.c | 294 nxt_fd_event_t *ev; in nxt_event_engine_signal_pipe() local 297 ev = obj; in nxt_event_engine_signal_pipe() 304 n = nxt_fd_read(ev->fd, buf, sizeof(buf)); in nxt_event_engine_signal_pipe()
|
/unit/src/nodejs/unit-http/ |
H A D | http_server.js | 441 this.on('newListener', function(ev) { argument 442 if (ev === 'upgrade'){ 445 }).on('removeListener', function(ev) { argument 446 if (ev === 'upgrade') {
|
H A D | websocket_connection.js | 48 this.on('newListener', function(ev) { argument 49 if (ev === 'ping'){ 52 }).on('removeListener', function(ev) { argument 53 if (ev === 'ping') {
|