Lines Matching refs:phe

392     nxt_poll_hash_entry_t  *phe;  in nxt_poll_set_add()  local
408 phe = nxt_malloc(sizeof(nxt_poll_hash_entry_t)); in nxt_poll_set_add()
409 if (nxt_slow_path(phe == NULL)) { in nxt_poll_set_add()
413 phe->fd = ev->fd; in nxt_poll_set_add()
414 phe->index = engine->u.poll.nfds; in nxt_poll_set_add()
415 phe->event = ev; in nxt_poll_set_add()
424 lhq.value = phe; in nxt_poll_set_add()
434 nxt_free(phe); in nxt_poll_set_add()
443 nxt_poll_hash_entry_t *phe; in nxt_poll_set_change() local
448 phe = nxt_poll_fd_hash_get(engine, fd); in nxt_poll_set_change()
450 if (nxt_fast_path(phe != NULL)) { in nxt_poll_set_change()
451 engine->u.poll.set[phe->index].events = events; in nxt_poll_set_change()
465 nxt_poll_hash_entry_t *phe; in nxt_poll_set_delete() local
479 phe = lhq.value; in nxt_poll_set_delete()
481 index = phe->index; in nxt_poll_set_delete()
488 phe = nxt_poll_fd_hash_get(engine, engine->u.poll.set[nfds].fd); in nxt_poll_set_delete()
490 phe->index = index; in nxt_poll_set_delete()
509 nxt_poll_hash_entry_t *phe; in nxt_poll() local
546 phe = nxt_poll_fd_hash_get(engine, fd); in nxt_poll()
548 if (nxt_slow_path(phe == NULL)) { in nxt_poll()
558 ev = phe->event; in nxt_poll()
640 nxt_poll_hash_entry_t *phe; in nxt_poll_fd_hash_get() local
647 phe = lhq.value; in nxt_poll_fd_hash_get()
648 return phe; in nxt_poll_fd_hash_get()
661 nxt_poll_hash_entry_t *phe; in nxt_poll_fd_hash_test() local
663 phe = data; in nxt_poll_fd_hash_test()
669 if (nxt_fast_path(phe->fd == engine->u.poll.set[phe->index].fd)) { in nxt_poll_fd_hash_test()
674 phe->fd, engine->u.poll.set[phe->index].fd); in nxt_poll_fd_hash_test()
683 nxt_poll_hash_entry_t *phe; in nxt_poll_fd_hash_destroy() local
686 phe = nxt_lvlhsh_retrieve(lh, &nxt_poll_fd_hash_proto, NULL); in nxt_poll_fd_hash_destroy()
688 if (phe == NULL) { in nxt_poll_fd_hash_destroy()
692 nxt_free(phe); in nxt_poll_fd_hash_destroy()