| /titanic_50/usr/src/lib/mergeq/ |
| H A D | mergeq.c | 220 mergeq_fini(mergeq_t *mqp) in mergeq_fini() argument
222 if (mqp == NULL) in mergeq_fini()
225 VERIFY(mqp->mq_working != B_TRUE); in mergeq_fini()
227 if (mqp->mq_items != NULL) in mergeq_fini()
228 mergeq_free(mqp->mq_items, sizeof (void *) * mqp->mq_cap); in mergeq_fini()
229 if (mqp->mq_ndthreads > 0) { in mergeq_fini()
230 mergeq_free(mqp->mq_thrs, sizeof (thread_t) * in mergeq_fini()
231 mqp->mq_ndthreads); in mergeq_fini()
233 VERIFY0(cond_destroy(&mqp->mq_cond)); in mergeq_fini()
234 VERIFY0(mutex_destroy(&mqp->mq_lock)); in mergeq_fini()
[all …]
|
| /titanic_50/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()
301 if (mqp->first_nonrelocatable != memq.first_nonrelocatable) { in query_checker()
303 mqp->first_nonrelocatable, memq.first_nonrelocatable); in query_checker()
[all …]
|
| /titanic_50/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()
|
| /titanic_50/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
190 mqp = (mlnx_umap_qp_data_out_t *)ep_args.ep_qp_data_out; in dapls_ib_qp_alloc()
276 mqp->mqp_rev = MLNX_UMAP_IF_VERSION; in dapls_ib_qp_alloc()
278 if (retval != 0 || 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()
291 qp_p->qp_sq_dbp = dapls_ib_get_dbp(mqp->mqp_sdbr_maplen, 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()
294 qp_p->qp_rq_dbp = dapls_ib_get_dbp(mqp->mqp_rdbr_maplen, in dapls_ib_qp_alloc()
295 hca_fd, mqp->mqp_rdbr_mapoffset, mqp->mqp_rdbr_offset); in dapls_ib_qp_alloc()
[all …]
|
| /titanic_50/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()
|
| /titanic_50/usr/src/uts/common/os/ |
| H A D | mem_config.c | 1272 memquery_t *mqp) in kphysm_del_span_query() argument
1278 mqp->phys_pages = 0; in kphysm_del_span_query()
1279 mqp->managed = 0; in kphysm_del_span_query()
1280 mqp->nonrelocatable = 0; in kphysm_del_span_query()
1281 mqp->first_nonrelocatable = 0; in kphysm_del_span_query()
1282 mqp->last_nonrelocatable = 0; in kphysm_del_span_query()
1293 mqp->phys_pages += mdsp->mds_npgs; in kphysm_del_span_query()
1355 mqp->nonrelocatable++; in kphysm_del_span_query()
1357 mqp-> in kphysm_del_span_query()
1362 mqp->last_nonrelocatable = in kphysm_del_span_query()
[all …]
|
| /titanic_50/usr/src/lib/libc/port/threads/ |
| H A D | synch.c | 3182 queue_head_t *mqp; in cond_sleep_queue() local
3240 mqp = queue_lock(mp, MX); in cond_sleep_queue()
3249 if (!cv_wake && self->ul_sleepq == mqp) { /* mutex queue */ in cond_sleep_queue()
3251 mp->mutex_waiters = dequeue_self(mqp); in cond_sleep_queue()
3268 queue_unlock(mqp); in cond_sleep_queue()
3281 queue_unlock(mqp); in cond_sleep_queue()
3705 queue_head_t *mqp; in cond_signal() local
3765 mqp = queue_lock(mp, MX); in cond_signal()
3766 enqueue(mqp, ulwp, 0); in cond_signal()
3768 queue_unlock(mqp); in cond_signal()
[all …]
|
| /titanic_50/usr/src/lib/libctf/common/ |
| H A D | ctf_merge.c | 1321 mergeq_t *mqp; in ctf_merge_merge() local
1333 if (mergeq_init(&mqp, cmh->cmh_nthreads) == -1) { in ctf_merge_merge()
1340 if (mergeq_add(mqp, cmi) == -1) { in ctf_merge_merge()
1342 mergeq_fini(mqp); in ctf_merge_merge()
1346 err = mergeq_merge(mqp, ctf_merge_types, NULL, (void **)&final, &merr); in ctf_merge_merge()
1347 mergeq_fini(mqp); in ctf_merge_merge()
|
| /titanic_50/usr/src/uts/sun4u/starfire/io/ |
| H A D | idn_proto.c | 10287 register idn_mboxmsg_t *mqp; in idn_mainmbox_flush() local
10379 mqp = &mmp[c].mm_smr_mboxp->mt_queue[0]; in idn_mainmbox_flush()
10390 if (mqp[qi].ms_owner) in idn_mainmbox_flush()
10392 mqp[qi].ms_owner = 0; in idn_mainmbox_flush()
10601 register idn_mboxmsg_t *mqp; in idn_chan_server() local
10792 mqp = &smr_mboxp->mt_queue[0]; in idn_chan_server()
10796 if (mqp[qi].ms_owner == 0) in idn_chan_server()
10799 bufoffset = IDN_BFRAME2OFFSET(mqp[qi].ms_bframe); in idn_chan_server()
10803 mqp[qi].ms_flag |= IDN_MBOXMSG_FLAG_ERR_BADOFFSET; in idn_chan_server()
10804 mqp[qi].ms_owner = 0; in idn_chan_server()
[all …]
|