Lines Matching refs:lhq
63 static nxt_int_t nxt_poll_fd_hash_test(nxt_lvlhsh_query_t *lhq, void *data);
391 nxt_lvlhsh_query_t lhq; in nxt_poll_set_add() local
422 lhq.key_hash = nxt_murmur_hash2(&ev->fd, sizeof(nxt_fd_t)); in nxt_poll_set_add()
423 lhq.replace = 0; in nxt_poll_set_add()
424 lhq.value = phe; in nxt_poll_set_add()
425 lhq.proto = &nxt_poll_fd_hash_proto; in nxt_poll_set_add()
426 lhq.data = engine; in nxt_poll_set_add()
428 ret = nxt_lvlhsh_insert(&engine->u.poll.fd_hash, &lhq); in nxt_poll_set_add()
464 nxt_lvlhsh_query_t lhq; in nxt_poll_set_delete() local
469 lhq.key_hash = nxt_murmur_hash2(&fd, sizeof(nxt_fd_t)); in nxt_poll_set_delete()
470 lhq.proto = &nxt_poll_fd_hash_proto; in nxt_poll_set_delete()
471 lhq.data = engine; in nxt_poll_set_delete()
473 ret = nxt_lvlhsh_delete(&engine->u.poll.fd_hash, &lhq); in nxt_poll_set_delete()
479 phe = lhq.value; in nxt_poll_set_delete()
493 nxt_free(lhq.value); in nxt_poll_set_delete()
639 nxt_lvlhsh_query_t lhq; in nxt_poll_fd_hash_get() local
642 lhq.key_hash = nxt_murmur_hash2(&fd, sizeof(nxt_fd_t)); in nxt_poll_fd_hash_get()
643 lhq.proto = &nxt_poll_fd_hash_proto; in nxt_poll_fd_hash_get()
644 lhq.data = engine; in nxt_poll_fd_hash_get()
646 if (nxt_lvlhsh_find(&engine->u.poll.fd_hash, &lhq) == NXT_OK) { in nxt_poll_fd_hash_get()
647 phe = lhq.value; in nxt_poll_fd_hash_get()
658 nxt_poll_fd_hash_test(nxt_lvlhsh_query_t *lhq, void *data) in nxt_poll_fd_hash_test() argument
667 engine = lhq->data; in nxt_poll_fd_hash_test()