Home
last modified time | relevance | path

Searched refs:events (Results 1 – 14 of 14) sorted by relevance

/unit/src/
H A Dnxt_poll_engine.c176 events = POLLIN; in nxt_poll_enable_read()
196 events = POLLOUT; in nxt_poll_enable_write()
216 events = 0; in nxt_poll_disable_read()
236 events = 0; in nxt_poll_disable_write()
240 events = POLLIN; in nxt_poll_disable_write()
302 nxt_uint_t events) in nxt_poll_change() argument
316 change->events = events; in nxt_poll_change()
419 pfd->events = events; in nxt_poll_set_add()
451 engine->u.poll.set[phe->index].events = events; in nxt_poll_set_change()
551 fd, pfd->events, events); in nxt_poll()
[all …]
H A Dnxt_pollset_engine.c214 nxt_uint_t op, events; in nxt_pollset_enable_read() local
218 events = POLLIN; in nxt_pollset_enable_read()
246 events = POLLOUT; in nxt_pollset_enable_write()
281 events = POLLOUT; in nxt_pollset_disable_read()
302 events = POLLIN; in nxt_pollset_disable_write()
374 change->events = events; in nxt_pollset_change()
413 ctl->events = change->events; in nxt_pollset_commit_changes()
489 pfd.events = 0; in nxt_pollset_remove()
514 ctl.events = 0; in nxt_pollset_remove()
597 engine->u.pollset.ps, fd, pfd->events, events); in nxt_pollset_poll()
[all …]
H A Dnxt_devpoll_engine.c240 nxt_uint_t op, events; in nxt_devpoll_enable_read() local
244 events = POLLIN; in nxt_devpoll_enable_read()
268 nxt_uint_t op, events; in nxt_devpoll_enable_write() local
272 events = POLLOUT; in nxt_devpoll_enable_write()
307 events = POLLOUT; in nxt_devpoll_disable_read()
328 events = POLLIN; in nxt_devpoll_disable_write()
388 change->events = events; in nxt_devpoll_change()
426 pfd->events = change->events; in nxt_devpoll_commit_changes()
502 pfd.events = 0; in nxt_devpoll_remove()
612 engine->u.devpoll.fd, fd, pfd->events, events); in nxt_devpoll_poll()
[all …]
H A Dnxt_eventport_engine.c31 nxt_fd_event_t *ev, nxt_uint_t events);
146 nxt_free(engine->u.eventport.events); in nxt_eventport_free()
194 nxt_uint_t events; in nxt_eventport_enable_read() local
209 nxt_uint_t events; in nxt_eventport_enable_write() local
229 nxt_uint_t events) in nxt_eventport_enable_event() argument
243 change->events = events; in nxt_eventport_enable_event()
291 change->events = 0; in nxt_eventport_disable_event()
317 if (change->events != 0) { in nxt_eventport_commit_changes()
552 if (events & POLLIN) { in nxt_eventport_poll()
566 if (events & POLLOUT) { in nxt_eventport_poll()
[all …]
H A Dnxt_epoll_engine.c413 uint32_t events; in nxt_epoll_enable_read() local
438 uint32_t events; in nxt_epoll_enable_write() local
463 uint32_t events; in nxt_epoll_disable_read() local
470 events = 0; in nxt_epoll_disable_read()
485 uint32_t events; in nxt_epoll_disable_write() local
492 events = 0; in nxt_epoll_disable_write()
567 uint32_t events; in nxt_epoll_enable_accept() local
571 events = EPOLLIN; in nxt_epoll_enable_accept()
588 uint32_t events) in nxt_epoll_change() argument
603 change->event.events = events; in nxt_epoll_change()
[all …]
H A Dnxt_event_engine.h182 struct kevent *events; member
208 struct epoll_event *events; member
231 int events; member
243 port_event_t *events; member
258 short events; member
271 struct pollfd *events; member
285 short events; member
298 struct pollfd *events; member
309 short events; member
334 nxt_fd_event_t **events; member
H A Dnxt_test_build.c28 epoll_wait(int epfd, struct epoll_event *events, int nevents, int timeout) in epoll_wait() argument
66 port_associate(int port, int source, uintptr_t object, int events, void *user) in port_associate() argument
80 port_send(int port, int events, void *user) in port_send() argument
H A Dnxt_select_engine.c74 engine->u.select.events = nxt_zalloc(FD_SETSIZE * sizeof(nxt_fd_event_t *)); in nxt_select_create()
76 if (engine->u.select.events != NULL) { in nxt_select_create()
91 nxt_free(engine->u.select.events); in nxt_select_free()
145 engine->u.select.events[fd] = ev; in nxt_select_enable_read()
172 engine->u.select.events[fd] = ev; in nxt_select_enable_write()
213 engine->u.select.events[fd] = NULL; in nxt_select_disable_read()
237 engine->u.select.events[fd] = NULL; in nxt_select_disable_write()
300 if (engine->u.select.events[i] != NULL) { in nxt_select_poll()
335 ev = engine->u.select.events[fd]; in nxt_select_poll()
352 ev = engine->u.select.events[fd]; in nxt_select_poll()
H A Dnxt_test_build.h54 uint32_t events; member
84 int epoll_wait(int epfd, struct epoll_event *events, int nevents, int timeout);
143 int port_associate(int port, int source, uintptr_t object, int events,
146 int port_send(int port, int events, void *user);
193 short events; member
H A Dnxt_event_engine.c46 nxt_uint_t events; in nxt_event_engine_create() local
116 events = (batch != 0) ? batch : 32; in nxt_event_engine_create()
118 if (interface->create(engine, 4 * events, events) != NXT_OK) { in nxt_event_engine_create()
128 if (nxt_timers_init(&engine->timers, 4 * events) != NXT_OK) { in nxt_event_engine_create()
386 nxt_uint_t events; in nxt_event_engine_change() local
418 events = (batch != 0) ? batch : 32; in nxt_event_engine_change()
420 if (interface->create(engine, 4 * events, events) != NXT_OK) { in nxt_event_engine_change()
H A Dnxt_kqueue_engine.c188 engine->u.kqueue.events = nxt_malloc(sizeof(struct kevent) * mevents); in nxt_kqueue_create()
189 if (engine->u.kqueue.events == NULL) { in nxt_kqueue_create()
237 nxt_free(engine->u.kqueue.events); in nxt_kqueue_free()
694 engine->u.kqueue.events, engine->u.kqueue.mevents, tp); in nxt_kqueue_poll()
719 kev = &engine->u.kqueue.events[i]; in nxt_kqueue_poll()
H A Dnxt_unit.c4642 fds[1].events = POLLIN; in nxt_unit_read_buf()
4651 fds[0].events = POLLIN; in nxt_unit_read_buf()
/unit/
H A Dconfigure120 . auto/events
/unit/src/nodejs/unit-http/
H A Dunit.cpp28 static void read_callback(uv_poll_t *handle, int status, int events);
115 port_data_t::read_callback(uv_poll_t *handle, int status, int events) in read_callback() argument