| /illumos-gate/usr/src/lib/mergeq/ |
| H A D | mergeq.c | 351 if (mqp->mq_next == mqp->mq_cap) { in mergeq_add()
359 mqp->mq_items[mqp->mq_next] = item; in mergeq_add()
373 VERIFY(mqp->mq_next < mqp->mq_cap); in mergeq_slot()
378 VERIFY(mqp->mq_nproc != (mqp->mq_next + 1) % mqp->mq_cap); in mergeq_slot()
382 if (mqp->mq_next == mqp->mq_cap) { in mergeq_slot()
383 mqp->mq_next %= mqp->mq_cap; in mergeq_slot()
415 mqp->mq_ncommit %= mqp->mq_cap; in mergeq_push()
438 mqp->mq_nproc %= mqp->mq_cap; in mergeq_pop_one()
560 if (mqp->mq_next == mqp->mq_cap) { in mergeq_merge()
561 mqp->mq_next %= mqp->mq_cap; in mergeq_merge()
[all …]
|
| /illumos-gate/usr/src/uts/sun4u/sunfire/io/ |
| H A D | ac_stat.c | 231 memquery_t *mqp) in query_checker() argument
241 all_pop = (mqp->phys_pages == npgs); in query_checker()
289 if (mqp->phys_pages != memq.phys_pages) { in query_checker()
291 mqp->phys_pages, memq.phys_pages); in query_checker()
293 if (mqp->managed != memq.managed) { in query_checker()
295 mqp->managed, memq.managed); in query_checker()
297 if (mqp->nonrelocatable != memq.nonrelocatable) { in query_checker()
299 mqp->nonrelocatable, memq.nonrelocatable); in query_checker()
303 mqp->first_nonrelocatable, memq.first_nonrelocatable); in query_checker()
305 if (mqp->last_nonrelocatable != memq.last_nonrelocatable) { in query_checker()
[all …]
|
| /illumos-gate/usr/src/test/util-tests/tests/mergeq/ |
| H A D | mqt.c | 149 mq_test_run(mergeq_t *mqp, mq_test_t *mqt) in mq_test_run() argument
156 if ((ret = mergeq_add(mqp, *itemp)) != 0) { in mq_test_run()
165 ret = mergeq_merge(mqp, mqt->mq_proc, NULL, &out, &err); in mq_test_run()
198 mergeq_t *mqp; in main() local
203 if ((ret = mergeq_init(&mqp, nthreads[t])) != 0) { in main()
210 mq_test_run(mqp, &mq_tests[i]); in main()
213 mergeq_fini(mqp); in main()
|
| /illumos-gate/usr/src/lib/udapl/udapl_tavor/tavor/ |
| H A D | dapl_tavor_ibtf_qp.c | 174 mlnx_umap_qp_data_out_t *mqp; in dapls_ib_qp_alloc() local
276 mqp->mqp_rev = MLNX_UMAP_IF_VERSION; in dapls_ib_qp_alloc()
290 if (mqp->mqp_sdbr_mapoffset != 0 || mqp->mqp_sdbr_maplen != 0) in dapls_ib_qp_alloc()
292 hca_fd, mqp->mqp_sdbr_mapoffset, mqp->mqp_sdbr_offset); in dapls_ib_qp_alloc()
293 if (mqp->mqp_rdbr_mapoffset != 0 || mqp->mqp_rdbr_maplen != 0) in dapls_ib_qp_alloc()
295 hca_fd, mqp->mqp_rdbr_mapoffset, mqp->mqp_rdbr_offset); in dapls_ib_qp_alloc()
299 mqp->mqp_mapoffset); in dapls_ib_qp_alloc()
319 qp_p->qp_map_len = mqp->mqp_maplen; in dapls_ib_qp_alloc()
320 qp_p->qp_num = mqp->mqp_qpnum; in dapls_ib_qp_alloc()
332 qp_p->qp_sq_wqesz = mqp->mqp_sq_wqesz; in dapls_ib_qp_alloc()
[all …]
|
| /illumos-gate/usr/src/uts/sun4v/io/ |
| H A D | dr_mem.c | 723 dr_mem_query(dr_mem_blk_t *mbp, dr_mem_query_t *mqp) in dr_mem_query() argument
735 mqp->addr = mbp->addr; in dr_mem_query()
736 mqp->mq.phys_pages = ptob(mq.phys_pages); in dr_mem_query()
737 mqp->mq.managed = ptob(mq.managed); in dr_mem_query()
738 mqp->mq.nonrelocatable = ptob(mq.nonrelocatable); in dr_mem_query()
739 mqp->mq.first_nonrelocatable = ptob(mq.first_nonrelocatable); in dr_mem_query()
740 mqp->mq.last_nonrelocatable = ptob(mq.last_nonrelocatable); in dr_mem_query()
744 if (mqp->mq.nonrelocatable) in dr_mem_query()
745 mqp->mq.last_nonrelocatable += PAGESIZE - 1; in dr_mem_query()
|
| /illumos-gate/usr/src/uts/common/os/ |
| H A D | mem_config.c | 1273 memquery_t *mqp) in kphysm_del_span_query() argument
1279 mqp->phys_pages = 0; in kphysm_del_span_query()
1280 mqp->managed = 0; in kphysm_del_span_query()
1281 mqp->nonrelocatable = 0; in kphysm_del_span_query()
1282 mqp->first_nonrelocatable = 0; in kphysm_del_span_query()
1283 mqp->last_nonrelocatable = 0; in kphysm_del_span_query()
1356 mqp->nonrelocatable++; in kphysm_del_span_query()
1358 mqp-> in kphysm_del_span_query()
1397 mqp->managed++; in kphysm_del_span_query()
1399 mqp->nonrelocatable++; in kphysm_del_span_query()
[all …]
|
| /illumos-gate/usr/src/lib/libc/port/threads/ |
| H A D | synch.c | 3191 queue_head_t *mqp; in cond_sleep_queue() local
3277 queue_unlock(mqp); in cond_sleep_queue()
3290 queue_unlock(mqp); in cond_sleep_queue()
3714 queue_head_t *mqp; in cond_signal() local
3775 enqueue(mqp, ulwp, 0); in cond_signal()
3777 queue_unlock(mqp); in cond_signal()
3902 if (mqp != NULL) in cond_broadcast()
3903 queue_unlock(mqp); in cond_broadcast()
3906 enqueue(mqp, ulwp, 0); in cond_broadcast()
3910 if (mqp != NULL) in cond_broadcast()
[all …]
|
| /illumos-gate/usr/src/lib/libctf/common/ |
| H A D | ctf_merge.c | 1464 mergeq_t *mqp; in ctf_merge_merge() local
1477 if (mergeq_init(&mqp, cmh->cmh_nthreads) == -1) { in ctf_merge_merge()
1484 if (mergeq_add(mqp, cmi) == -1) { in ctf_merge_merge()
1486 mergeq_fini(mqp); in ctf_merge_merge()
1490 err = mergeq_merge(mqp, ctf_merge_types, NULL, (void **)&final, &merr); in ctf_merge_merge()
1491 mergeq_fini(mqp); in ctf_merge_merge()
|