| /unit/src/ |
| H A D | nxt_timer.c | 31 nxt_timers_init(nxt_timers_t *timers, nxt_uint_t mchanges) in nxt_timers_init() argument
35 if (mchanges > NXT_TIMER_MAX_CHANGES) { in nxt_timers_init()
36 mchanges = NXT_TIMER_MAX_CHANGES; in nxt_timers_init()
39 timers->mchanges = mchanges; in nxt_timers_init()
41 timers->changes = nxt_malloc(sizeof(nxt_timer_change_t) * mchanges); in nxt_timers_init()
140 if (timers->nchanges >= timers->mchanges) { in nxt_timer_change()
|
| H A D | nxt_event_engine.h | 35 nxt_uint_t mchanges, nxt_uint_t mevents);
175 int mchanges; member
202 nxt_uint_t mchanges; member
239 nxt_uint_t mchanges; member
266 int mchanges; member
293 int mchanges; member
319 nxt_uint_t mchanges; member
|
| H A D | nxt_timer.h | 69 nxt_uint_t mchanges; member
95 nxt_int_t nxt_timers_init(nxt_timers_t *timers, nxt_uint_t mchanges);
|
| H A D | nxt_eventport_engine.c | 18 nxt_uint_t mchanges, nxt_uint_t mevents);
89 nxt_eventport_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_eventport_create() argument
95 engine->u.eventport.mchanges = mchanges; in nxt_eventport_create()
98 changes = nxt_malloc(sizeof(nxt_eventport_change_t) * mchanges); in nxt_eventport_create()
236 if (engine->u.eventport.nchanges >= engine->u.eventport.mchanges) { in nxt_eventport_enable_event()
284 if (engine->u.eventport.nchanges >= engine->u.eventport.mchanges) { in nxt_eventport_disable_event()
|
| H A D | nxt_epoll_engine.c | 36 nxt_uint_t mchanges, nxt_uint_t mevents);
39 nxt_uint_t mchanges, nxt_uint_t mevents);
41 nxt_uint_t mchanges, nxt_uint_t mevents, nxt_conn_io_t *io, uint32_t mode);
214 nxt_epoll_edge_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_epoll_edge_create() argument
217 return nxt_epoll_create(engine, mchanges, mevents, &nxt_epoll_edge_conn_io, in nxt_epoll_edge_create()
225 nxt_epoll_level_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_epoll_level_create() argument
228 return nxt_epoll_create(engine, mchanges, mevents, in nxt_epoll_level_create()
234 nxt_epoll_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_epoll_create() argument
239 engine->u.epoll.mchanges = mchanges; in nxt_epoll_create()
245 engine->u.epoll.changes = nxt_malloc(sizeof(nxt_epoll_change_t) * mchanges); in nxt_epoll_create()
[all …]
|
| H A D | nxt_pollset_engine.c | 26 nxt_uint_t mchanges, nxt_uint_t mevents);
90 nxt_pollset_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_pollset_create() argument
96 engine->u.pollset.mchanges = mchanges; in nxt_pollset_create()
99 changes = nxt_malloc(sizeof(nxt_pollset_change_t) * mchanges); in nxt_pollset_create()
110 changes = nxt_malloc(2 * sizeof(struct poll_ctl) * mchanges); in nxt_pollset_create()
365 if (engine->u.pollset.nchanges >= engine->u.pollset.mchanges) { in nxt_pollset_change()
|
| H A D | nxt_devpoll_engine.c | 31 nxt_uint_t mchanges, nxt_uint_t mevents);
96 nxt_devpoll_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_devpoll_create() argument
102 engine->u.devpoll.mchanges = mchanges; in nxt_devpoll_create()
105 changes = nxt_malloc(sizeof(nxt_devpoll_change_t) * mchanges); in nxt_devpoll_create()
116 changes = nxt_malloc(2 * sizeof(struct pollfd) * mchanges); in nxt_devpoll_create()
380 if (engine->u.devpoll.nchanges >= engine->u.devpoll.mchanges) { in nxt_devpoll_change()
|
| H A D | nxt_poll_engine.c | 30 nxt_uint_t mchanges, nxt_uint_t mevents);
108 nxt_poll_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_poll_create() argument
111 engine->u.poll.mchanges = mchanges; in nxt_poll_create()
113 engine->u.poll.changes = nxt_malloc(sizeof(nxt_poll_change_t) * mchanges); in nxt_poll_create()
308 if (engine->u.poll.nchanges >= engine->u.poll.mchanges) { in nxt_poll_change()
|
| H A D | nxt_kqueue_engine.c | 55 nxt_uint_t mchanges, nxt_uint_t mevents);
173 nxt_kqueue_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_kqueue_create() argument
179 engine->u.kqueue.mchanges = mchanges; in nxt_kqueue_create()
183 engine->u.kqueue.changes = nxt_malloc(sizeof(struct kevent) * mchanges); in nxt_kqueue_create()
470 if (nxt_slow_path(nchanges >= engine->u.kqueue.mchanges)) { in nxt_kqueue_get_kevent()
|
| H A D | nxt_select_engine.c | 11 nxt_uint_t mchanges, nxt_uint_t mevents);
68 nxt_select_create(nxt_event_engine_t *engine, nxt_uint_t mchanges, in nxt_select_create() argument
|