Home
last modified time | relevance | path

Searched refs:nchanges (Results 1 – 9 of 9) sorted by relevance

/unit/src/
H A Dnxt_timer.c140 if (timers->nchanges >= timers->mchanges) { in nxt_timer_change()
144 timers->nchanges++; in nxt_timer_change()
145 timer->change = timers->nchanges; in nxt_timer_change()
168 nxt_debug(&engine->task, "timers changes: %ui", timers->nchanges); in nxt_timer_changes_commit()
171 end = ch + timers->nchanges; in nxt_timer_changes_commit()
224 timers->nchanges = 0; in nxt_timer_changes_commit()
240 if (timers->nchanges != 0) { in nxt_timer_find()
H A Dnxt_event_engine.h174 int nchanges; member
201 nxt_uint_t nchanges; member
238 nxt_uint_t nchanges; member
265 int nchanges; member
292 int nchanges; member
318 nxt_uint_t nchanges; member
H A Dnxt_eventport_engine.c236 if (engine->u.eventport.nchanges >= engine->u.eventport.mchanges) { in nxt_eventport_enable_event()
242 change = &engine->u.eventport.changes[engine->u.eventport.nchanges++]; in nxt_eventport_enable_event()
284 if (engine->u.eventport.nchanges >= engine->u.eventport.mchanges) { in nxt_eventport_disable_event()
290 change = &engine->u.eventport.changes[engine->u.eventport.nchanges++]; in nxt_eventport_disable_event()
307 port, engine->u.eventport.nchanges); in nxt_eventport_commit_changes()
311 end = change + engine->u.eventport.nchanges; in nxt_eventport_commit_changes()
356 engine->u.eventport.nchanges = 0; in nxt_eventport_commit_changes()
462 if (engine->u.eventport.nchanges != 0) { in nxt_eventport_poll()
H A Dnxt_kqueue_engine.c304 end = &engine->u.kqueue.changes[engine->u.kqueue.nchanges]; in nxt_kqueue_close()
466 int ret, nchanges; in nxt_kqueue_get_kevent() local
468 nchanges = engine->u.kqueue.nchanges; in nxt_kqueue_get_kevent()
470 if (nxt_slow_path(nchanges >= engine->u.kqueue.mchanges)) { in nxt_kqueue_get_kevent()
473 engine->u.kqueue.fd, nchanges); in nxt_kqueue_get_kevent()
485 engine->u.kqueue.nchanges = 0; in nxt_kqueue_get_kevent()
488 return &engine->u.kqueue.changes[engine->u.kqueue.nchanges++]; in nxt_kqueue_get_kevent()
501 end = &engine->u.kqueue.changes[engine->u.kqueue.nchanges]; in nxt_kqueue_error()
690 engine->u.kqueue.fd, engine->u.kqueue.nchanges, timeout); in nxt_kqueue_poll()
693 engine->u.kqueue.changes, engine->u.kqueue.nchanges, in nxt_kqueue_poll()
[all …]
H A Dnxt_pollset_engine.c365 if (engine->u.pollset.nchanges >= engine->u.pollset.mchanges) { in nxt_pollset_change()
371 change = &engine->u.pollset.changes[engine->u.pollset.nchanges++]; in nxt_pollset_change()
389 engine->u.pollset.ps, engine->u.pollset.nchanges); in nxt_pollset_commit_changes()
395 end = change + engine->u.pollset.nchanges; in nxt_pollset_commit_changes()
421 end = change + engine->u.pollset.nchanges; in nxt_pollset_commit_changes()
432 engine->u.pollset.nchanges = 0; in nxt_pollset_commit_changes()
459 engine->u.pollset.nchanges = 0; in nxt_pollset_commit_changes()
555 if (engine->u.pollset.nchanges != 0) { in nxt_pollset_poll()
H A Dnxt_devpoll_engine.c380 if (engine->u.devpoll.nchanges >= engine->u.devpoll.mchanges) { in nxt_devpoll_change()
386 change = &engine->u.devpoll.changes[engine->u.devpoll.nchanges++]; in nxt_devpoll_change()
403 engine->u.devpoll.fd, engine->u.devpoll.nchanges); in nxt_devpoll_commit_changes()
409 end = change + engine->u.devpoll.nchanges; in nxt_devpoll_commit_changes()
436 end = change + engine->u.devpoll.nchanges; in nxt_devpoll_commit_changes()
447 engine->u.devpoll.nchanges = 0; in nxt_devpoll_commit_changes()
474 engine->u.devpoll.nchanges = 0; in nxt_devpoll_commit_changes()
567 if (engine->u.devpoll.nchanges != 0) { in nxt_devpoll_poll()
H A Dnxt_poll_engine.c308 if (engine->u.poll.nchanges >= engine->u.poll.mchanges) { in nxt_poll_change()
314 change = &engine->u.poll.changes[engine->u.poll.nchanges++]; in nxt_poll_change()
328 nxt_debug(&engine->task, "poll changes:%ui", engine->u.poll.nchanges); in nxt_poll_commit_changes()
332 end = change + engine->u.poll.nchanges; in nxt_poll_commit_changes()
379 engine->u.poll.nchanges = 0; in nxt_poll_commit_changes()
511 if (engine->u.poll.nchanges != 0) { in nxt_poll()
H A Dnxt_timer.h70 nxt_uint_t nchanges; member
H A Dnxt_epoll_engine.c595 if (engine->u.epoll.nchanges >= engine->u.epoll.mchanges) { in nxt_epoll_change()
601 change = &engine->u.epoll.changes[engine->u.epoll.nchanges++]; in nxt_epoll_change()
616 engine->u.epoll.fd, engine->u.epoll.nchanges); in nxt_epoll_commit_changes()
619 end = change + engine->u.epoll.nchanges; in nxt_epoll_commit_changes()
645 engine->u.epoll.nchanges = 0; in nxt_epoll_commit_changes()
882 if (engine->u.epoll.nchanges != 0) { in nxt_epoll_poll()