Lines Matching refs:evpd

141 	struct evport_data *evpd;  in evport_init()  local
144 if (!(evpd = mm_calloc(1, sizeof(struct evport_data)))) in evport_init()
147 if ((evpd->ed_port = port_create()) == -1) { in evport_init()
148 mm_free(evpd); in evport_init()
155 evpd->ed_fds = mm_calloc(DEFAULT_NFDS, sizeof(struct fd_info)); in evport_init()
156 if (evpd->ed_fds == NULL) { in evport_init()
157 close(evpd->ed_port); in evport_init()
158 mm_free(evpd); in evport_init()
161 evpd->ed_nevents = DEFAULT_NFDS; in evport_init()
163 evpd->ed_pending[i] = -1; in evport_init()
167 return (evpd); in evport_init()
178 check_evportop(struct evport_data *evpd) in check_evportop() argument
180 EVUTIL_ASSERT(evpd); in check_evportop()
181 EVUTIL_ASSERT(evpd->ed_nevents > 0); in check_evportop()
182 EVUTIL_ASSERT(evpd->ed_port > 0); in check_evportop()
183 EVUTIL_ASSERT(evpd->ed_fds > 0); in check_evportop()
377 struct evport_data *evpd = base->evbase; in evport_add() local
382 check_evportop(evpd); in evport_add()
389 while (fd >= factor * evpd->ed_nevents) in evport_add()
393 if (-1 == grow(evpd, factor)) { in evport_add()
398 fdi = &evpd->ed_fds[fd]; in evport_add()
401 return reassociate(evpd, fdi, fd); in evport_add()
411 struct evport_data *evpd = base->evbase; in evport_del() local
417 check_evportop(evpd); in evport_del()
419 if (evpd->ed_nevents < fd) { in evport_del()
424 if (evpd->ed_pending[i] == fd) { in evport_del()
430 fdi = &evpd->ed_fds[fd]; in evport_del()
438 port_dissociate(evpd->ed_port, PORT_SOURCE_FD, fd) == -1) { in evport_del()
449 return (reassociate(evpd, fdi, fd)); in evport_del()
454 evpd->ed_pending[i] = -1; in evport_del()
464 struct evport_data *evpd = base->evbase; in evport_dealloc() local
468 close(evpd->ed_port); in evport_dealloc()
470 if (evpd->ed_fds) in evport_dealloc()
471 mm_free(evpd->ed_fds); in evport_dealloc()
472 mm_free(evpd); in evport_dealloc()