Lines Matching refs:lhq

1170 nxt_proto_lvlhsh_isolated_pid_test(nxt_lvlhsh_query_t *lhq, void *data)  in nxt_proto_lvlhsh_isolated_pid_test()  argument
1176 qpid = (nxt_pid_t *) lhq->key.start; in nxt_proto_lvlhsh_isolated_pid_test()
1195 nxt_proto_process_lhq_pid(nxt_lvlhsh_query_t *lhq, nxt_pid_t *pid) in nxt_proto_process_lhq_pid() argument
1197 lhq->key_hash = nxt_murmur_hash2(pid, sizeof(nxt_pid_t)); in nxt_proto_process_lhq_pid()
1198 lhq->key.length = sizeof(nxt_pid_t); in nxt_proto_process_lhq_pid()
1199 lhq->key.start = (u_char *) pid; in nxt_proto_process_lhq_pid()
1200 lhq->proto = &lvlhsh_processes_proto; in nxt_proto_process_lhq_pid()
1208 nxt_lvlhsh_query_t lhq; in nxt_proto_process_add() local
1212 nxt_proto_process_lhq_pid(&lhq, &process->isolated_pid); in nxt_proto_process_add()
1214 lhq.replace = 0; in nxt_proto_process_add()
1215 lhq.value = process; in nxt_proto_process_add()
1216 lhq.pool = rt->mem_pool; in nxt_proto_process_add()
1218 switch (nxt_lvlhsh_insert(&nxt_proto_processes, &lhq)) { in nxt_proto_process_add()
1239 nxt_lvlhsh_query_t lhq; in nxt_proto_process_remove() local
1241 nxt_proto_process_lhq_pid(&lhq, &pid); in nxt_proto_process_remove()
1245 lhq.pool = rt->mem_pool; in nxt_proto_process_remove()
1247 switch (nxt_lvlhsh_delete(&nxt_proto_processes, &lhq)) { in nxt_proto_process_remove()
1252 process = lhq.value; in nxt_proto_process_remove()
1273 nxt_lvlhsh_query_t lhq; in nxt_proto_process_find() local
1275 nxt_proto_process_lhq_pid(&lhq, &pid); in nxt_proto_process_find()
1277 if (nxt_lvlhsh_find(&nxt_proto_processes, &lhq) == NXT_OK) { in nxt_proto_process_find()
1278 process = lhq.value; in nxt_proto_process_find()