/unit/src/nodejs/unit-http/ |
H A D | unit.cpp | 28 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
|
/unit/src/ |
H A D | nxt_unit.c | 4661 fds[1].events = POLLIN; in nxt_unit_read_buf() 4670 fds[0].events = POLLIN; in nxt_unit_read_buf()
|
H A D | nxt_kqueue_engine.c | 188 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() 721 kev = &engine->u.kqueue.events[i]; in nxt_kqueue_poll()
|
H A D | nxt_process.c | 359 pfd.events = event; in nxt_process_pipe_timer()
|
H A D | nxt_event_engine.h | 182 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 D | nxt_event_engine.c | 46 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 D | nxt_test_build.h | 54 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 D | nxt_select_engine.c | 74 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 D | nxt_test_build.c | 28 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 D | nxt_poll_engine.c | 176 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 D | nxt_pollset_engine.c | 214 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 D | nxt_eventport_engine.c | 31 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 D | nxt_epoll_engine.c | 413 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 D | nxt_devpoll_engine.c | 240 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 …]
|
/unit/ |
H A D | configure | 123 . auto/events
|