| /f-stack/app/nginx-1.16.1/src/event/modules/ |
| H A D | ngx_win32_poll_module.c | 27 static ngx_uint_t nevents; variable
76 nevents = 0; in ngx_poll_init()
166 event_list[nevents].fd = c->fd; in ngx_poll_add_event()
170 event_index[nevents] = c; in ngx_poll_add_event()
172 ev->index = nevents; in ngx_poll_add_event()
173 nevents++; in ngx_poll_add_event()
221 nevents--; in ngx_poll_del_event()
223 if (ev->index < nevents) { in ngx_poll_del_event()
275 for (i = 0; i < nevents; i++) { in ngx_poll_process_events()
357 if (i == nevents - 1) { in ngx_poll_process_events()
[all …]
|
| H A D | ngx_poll_module.c | 25 static ngx_uint_t nevents; variable
73 nevents = 0; in ngx_poll_init()
146 event_list[nevents].fd = c->fd; in ngx_poll_add_event()
148 event_list[nevents].revents = 0; in ngx_poll_add_event()
150 ev->index = nevents; in ngx_poll_add_event()
151 nevents++; in ngx_poll_add_event()
199 nevents--; in ngx_poll_del_event()
201 if (ev->index < nevents) { in ngx_poll_del_event()
252 for (i = 0; i < nevents; i++) { in ngx_poll_process_events()
347 if (i == nevents - 1) { in ngx_poll_process_events()
[all …]
|
| H A D | ngx_select_module.c | 33 static ngx_uint_t nevents; variable
84 nevents = 0; in ngx_select_init()
98 ngx_memcpy(index, event_index, sizeof(ngx_event_t *) * nevents); in ngx_select_init()
164 event_index[nevents] = ev; in ngx_select_add_event()
165 ev->index = nevents; in ngx_select_add_event()
166 nevents++; in ngx_select_add_event()
200 if (ev->index < --nevents) { in ngx_select_del_event()
201 e = event_index[nevents]; in ngx_select_del_event()
225 for (i = 0; i < nevents; i++) { in ngx_select_process_events()
238 for (i = 0; i < nevents; i++) { in ngx_select_process_events()
[all …]
|
| H A D | ngx_win32_select_module.c | 33 static ngx_uint_t nevents; variable
84 nevents = 0; in ngx_select_init()
98 ngx_memcpy(index, event_index, sizeof(ngx_event_t *) * nevents); in ngx_select_init()
172 event_index[nevents] = ev; in ngx_select_add_event()
173 ev->index = nevents; in ngx_select_add_event()
174 nevents++; in ngx_select_add_event()
206 if (ev->index < --nevents) { in ngx_select_del_event()
207 e = event_index[nevents]; in ngx_select_del_event()
232 for (i = 0; i < nevents; i++) { in ngx_select_process_events()
305 for (i = 0; i < nevents; i++) { in ngx_select_process_events()
|
| H A D | ngx_ff_host_event_module.c | 49 static ngx_uint_t nevents; variable
120 nevents = 64; in ngx_ff_epoll_init()
122 event_list = ngx_alloc(sizeof(struct epoll_event) * nevents, cycle->log); in ngx_ff_epoll_init()
143 nevents = 0; in ngx_ff_epoll_done()
340 events = epoll_wait(ep, event_list, (int) nevents, timer); in ngx_ff_epoll_process_events()
|
| H A D | ngx_devpoll_module.c | 54 static ngx_uint_t nchanges, max_changes, nevents; variable
170 if (nevents < dpcf->events) { in ngx_devpoll_init()
182 nevents = dpcf->events; in ngx_devpoll_init()
213 nevents = 0; in ngx_devpoll_done()
372 dvp.dp_nfds = (int) nevents; in ngx_devpoll_process_events()
|
| H A D | ngx_kqueue_module.c | 46 static ngx_uint_t max_changes, nchanges, nevents; variable
56 struct kevent *eventlist, int nevents, const struct timespec *timeout);
182 if (nevents < kcf->events) { in ngx_kqueue_init()
231 nevents = kcf->events; in ngx_kqueue_init()
289 nevents = 0; in ngx_kqueue_done()
554 events = kevent(ngx_kqueue, change_list, n, event_list, (int) nevents, tp); in ngx_kqueue_process_events()
|
| H A D | ngx_eventport_module.c | 154 static ngx_uint_t nevents; variable
233 if (nevents < epcf->events) { in ngx_eventport_init()
275 nevents = epcf->events; in ngx_eventport_init()
307 nevents = 0; in ngx_eventport_done()
463 n = port_getn(ep, event_list, (u_int) nevents, &events, tp); in ngx_eventport_process_events()
|
| H A D | ngx_epoll_module.c | 67 int epoll_wait(int epfd, struct epoll_event *events, int nevents, int timeout);
69 int epoll_wait(int epfd, struct epoll_event *events, int nevents, int timeout) in epoll_wait() argument
135 static ngx_uint_t nevents; variable
353 if (nevents < epcf->events) { in ngx_epoll_init()
365 nevents = epcf->events; in ngx_epoll_init()
574 nevents = 0; in ngx_epoll_done()
800 events = epoll_wait(ep, event_list, (int) nevents, timer); in ngx_epoll_process_events()
|
| H A D | ngx_ff_module.c | 523 struct kevent *eventlist, int nevents, const struct timespec *timeout) in kevent() argument
545 return ff_kevent(kq, changelist, nchanges, eventlist, nevents, timeout); in kevent()
|
| /f-stack/app/redis-5.0.5/src/ |
| H A D | ae_evport.c | 247 uint_t nevents; in aeApiPoll() local
284 nevents = 1; in aeApiPoll()
285 if (port_getn(state->portfd, event, MAX_EVENT_BATCHSZ, &nevents, in aeApiPoll()
286 tsp) == -1 && (errno != ETIME || nevents == 0)) { in aeApiPoll()
295 state->npending = nevents; in aeApiPoll()
297 for (i = 0; i < nevents; i++) { in aeApiPoll()
315 return nevents; in aeApiPoll()
|
| /f-stack/example/ |
| H A D | main_epoll.c | 62 int nevents = ff_epoll_wait(epfd, events, MAX_EVENTS, 0); in loop() local
65 for (i = 0; i < nevents; ++i) { in loop()
|
| H A D | main.c | 63 unsigned nevents = ff_kevent(kq, NULL, 0, events, MAX_EVENTS, NULL); in loop() local
66 for (i = 0; i < nevents; ++i) { in loop()
|
| H A D | main_zc.c | 140 unsigned nevents = ff_kevent(kq, NULL, 0, events, MAX_EVENTS, NULL); in loop() local
146 for (i = 0; i < nevents; ++i) { in loop()
|
| /f-stack/lib/ |
| H A D | ff_api.h | 110 struct kevent *eventlist, int nevents, const struct timespec *timeout);
112 void *eventlist, int nevents, const struct timespec *timeout,
|
| H A D | ff_syscall_wrapper.c | 1180 int nevents; member
1225 void *eventlist, int nevents, const struct timespec *timeout, in ff_kevent_do_each() argument
1238 nevents, in ff_kevent_do_each()
1249 if ((rc = kern_kevent(curthread, kq, nchanges, nevents, &k_ops, in ff_kevent_do_each()
1262 struct kevent *eventlist, int nevents, const struct timespec *timeout) in ff_kevent() argument
1264 return ff_kevent_do_each(kq, changelist, nchanges, eventlist, nevents, timeout, NULL); in ff_kevent()
|
| /f-stack/freebsd/kern/ |
| H A D | kern_event.c | 1014 int nevents; member
1032 .nevents = uap->nevents, in sys_kevent()
1063 error = kern_kevent(td, uap->fd, uap->nchanges, uap->nevents, in kern_kevent_generic()
1182 .nevents = uap->nevents, in freebsd11_kevent()
1191 kern_kevent(struct thread *td, int fd, int nchanges, int nevents, in kern_kevent() argument
1201 if (nevents > 0) in kern_kevent()
1235 if (nevents == 0) in kqueue_kevent()
1240 nevents--; in kqueue_kevent()
1251 return (kqueue_scan(kq, nevents, k_ops, timeout, keva, td)); in kqueue_kevent()
1274 kern_kevent_anonymous(struct thread *td, int nevents, in kern_kevent_anonymous() argument
[all …]
|
| /f-stack/dpdk/drivers/net/mlx4/ |
| H A D | mlx4_glue.c | 143 mlx4_glue_ack_cq_events(struct ibv_cq *cq, unsigned int nevents) in mlx4_glue_ack_cq_events() argument
145 ibv_ack_cq_events(cq, nevents); in mlx4_glue_ack_cq_events()
|
| H A D | mlx4_glue.h | 57 void (*ack_cq_events)(struct ibv_cq *cq, unsigned int nevents);
|
| /f-stack/freebsd/sys/ |
| H A D | syscallsubr.h | 174 int kern_kevent(struct thread *td, int fd, int nchanges, int nevents,
176 int kern_kevent_anonymous(struct thread *td, int nevents,
179 int nevents, struct kevent_copyops *k_ops,
|
| H A D | event.h | 360 struct kevent *eventlist, int nevents,
|
| /f-stack/tools/compat/include/sys/ |
| H A D | event.h | 293 struct kevent *eventlist, int nevents,
|
| /f-stack/dpdk/drivers/common/mlx5/linux/ |
| H A D | mlx5_glue.h | 162 void (*ack_cq_events)(struct ibv_cq *cq, unsigned int nevents);
|
| H A D | mlx5_glue.c | 123 mlx5_glue_ack_cq_events(struct ibv_cq *cq, unsigned int nevents) in mlx5_glue_ack_cq_events() argument
125 ibv_ack_cq_events(cq, nevents); in mlx5_glue_ack_cq_events()
|
| /f-stack/doc/ |
| H A D | F-Stack_API_Reference.md | 157 …t struct kevent *changelist, int nchanges, struct kevent *eventlist, int nevents, const struct tim…
|