Lines Matching refs:pollcb
330 apr_pollcb_t *pollcb = (apr_pollcb_t *) b_;
331 close(pollcb->fd);
335 static apr_status_t impl_pollcb_create(apr_pollcb_t *pollcb,
354 pollcb->fd = -1;
362 pollcb->fd = -1;
367 pollcb->fd = fd;
368 pollcb->pollset.ke = (struct kevent *)apr_pcalloc(p, 2 * size * sizeof(struct kevent));
369 apr_pool_cleanup_register(p, pollcb, cb_cleanup, apr_pool_cleanup_null);
374 static apr_status_t impl_pollcb_add(apr_pollcb_t *pollcb,
391 if (kevent(pollcb->fd, &ev, 1, NULL, 0, NULL) == -1) {
399 if (kevent(pollcb->fd, &ev, 1, NULL, 0, NULL) == -1) {
407 static apr_status_t impl_pollcb_remove(apr_pollcb_t *pollcb,
425 if (kevent(pollcb->fd, &ev, 1, NULL, 0, NULL) != -1) {
433 if (kevent(pollcb->fd, &ev, 1, NULL, 0, NULL) != -1) {
442 static apr_status_t impl_pollcb_poll(apr_pollcb_t *pollcb,
460 ret = kevent(pollcb->fd, NULL, 0, pollcb->pollset.ke, 2 * pollcb->nalloc,
471 apr_pollfd_t *pollfd = (apr_pollfd_t *)(pollcb->pollset.ke[i].udata);
473 pollfd->rtnevents = get_kqueue_revent(pollcb->pollset.ke[i].filter,
474 pollcb->pollset.ke[i].flags);