Home
last modified time | relevance | path

Searched refs:ev (Results 1 – 21 of 21) sorted by relevance

/unit/src/
H A Dnxt_select_engine.c132 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 Dnxt_eventport_engine.c21 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 Dnxt_devpoll_engine.c36 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 Dnxt_pollset_engine.c31 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 Dnxt_poll_engine.c34 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 Dnxt_socketpair.c100 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 Dnxt_epoll_engine.c49 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 Dnxt_kqueue_engine.c61 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 Dnxt_event_engine.h346 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 Dnxt_fd_event.c33 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 Dnxt_file_cache.c19 static void nxt_file_cache_timeout_handler(nxt_event_timer_t *ev);
240 nxt_event_timer_t *ev; in nxt_cache_wait_handler() local
249 ev = &q->timer; in nxt_cache_wait_handler()
251 if (!nxt_event_timer_is_set(ev)) { in nxt_cache_wait_handler()
253 ev->log = thr->log; in nxt_cache_wait_handler()
254 ev->handler = nxt_cache_timeout_handler; in nxt_cache_wait_handler()
255 ev->data = q; in nxt_cache_wait_handler()
256 nxt_event_timer_ident(ev, -1); in nxt_cache_wait_handler()
258 nxt_event_timer_add(thr->engine, ev, q->timeout); in nxt_cache_wait_handler()
264 nxt_cache_timeout_handler(nxt_event_timer_t *ev) in nxt_cache_timeout_handler() argument
[all …]
H A Dnxt_log_moderation.c77 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 Dnxt_conn.h175 #define nxt_conn_timer_init(ev, c, wq) \ argument
177 (ev)->work_queue = (wq); \
178 (ev)->log = &(c)->log; \
179 (ev)->bias = NXT_TIMER_DEFAULT_BIAS; \
183 #define nxt_read_timer_conn(ev) \ argument
184 nxt_timer_data(ev, nxt_conn_t, read_timer)
187 #define nxt_write_timer_conn(ev) \ argument
188 nxt_timer_data(ev, nxt_conn_t, write_timer)
H A Dnxt_cache.c345 nxt_event_timer_t *ev; in nxt_cache_wait_handler() local
352 ev = &cq->timer; in nxt_cache_wait_handler()
354 if (ev->state == NXT_EVENT_TIMER_DISABLED) { in nxt_cache_wait_handler()
355 ev->handler = nxt_cache_timeout_handler; in nxt_cache_wait_handler()
356 nxt_event_timer_ident(ev, -1); in nxt_cache_wait_handler()
358 nxt_event_timer_add(thr->engine, ev, cq->timeout); in nxt_cache_wait_handler()
368 nxt_event_timer_t *ev; in nxt_cache_timeout_handler() local
370 ev = obj; in nxt_cache_timeout_handler()
372 cq = nxt_event_timer_data(ev, nxt_cache_query_t, timer); in nxt_cache_timeout_handler()
H A Dnxt_socket.h115 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 Dnxt_conn_accept.c376 nxt_fd_event_t *ev; in nxt_conn_listen_event_error() local
378 ev = obj; in nxt_conn_listen_event_error()
380 nxt_alert(task, "accept(%d) event error", ev->fd); in nxt_conn_listen_event_error()
H A Dnxt_stream_source.c451 nxt_event_fd_t *ev; in nxt_stream_source_error() local
453 ev = obj; in nxt_stream_source_error()
455 nxt_debug(task, "stream source error fd:%d", ev->fd); in nxt_stream_source_error()
H A Dnxt_fiber.c416 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 Dnxt_event_engine.c294 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 Dhttp_server.js418 this.on('newListener', function(ev) { argument
419 if (ev === 'upgrade'){
422 }).on('removeListener', function(ev) { argument
423 if (ev === 'upgrade') {
H A Dwebsocket_connection.js48 this.on('newListener', function(ev) { argument
49 if (ev === 'ping'){
52 }).on('removeListener', function(ev) { argument
53 if (ev === 'ping') {