Searched refs:nchanges (Results 1 – 9 of 9) sorted by path
/unit/src/ |
H A D | nxt_devpoll_engine.c | 380 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 D | nxt_epoll_engine.c | 595 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()
|
H A D | nxt_event_engine.h | 174 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 D | nxt_eventport_engine.c | 236 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 D | nxt_kqueue_engine.c | 304 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 D | nxt_poll_engine.c | 308 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 D | nxt_pollset_engine.c | 365 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 D | nxt_timer.c | 140 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 D | nxt_timer.h | 70 nxt_uint_t nchanges; member
|