/illumos-gate/usr/src/lib/mergeq/ |
H A D | workq.c | 71 workq_free(wqp->wq_items, sizeof (void *) * wqp->wq_cap); in workq_fini() 81 workq_t *wqp; in workq_init() local 130 *outp = wqp; in workq_init() 140 bzero(wqp->wq_items, sizeof (void *) * wqp->wq_cap); in workq_reset() 183 if (wqp->wq_nitems == wqp->wq_cap) { in workq_add() 192 wqp->wq_items[wqp->wq_nitems] = item; in workq_add() 206 VERIFY(wqp->wq_next < wqp->wq_nitems); in workq_pop() 208 out = wqp->wq_items[wqp->wq_next]; in workq_pop() 209 wqp->wq_items[wqp->wq_next] = NULL; in workq_pop() 228 wqp->wq_next == wqp->wq_nitems) { in workq_thr_work() [all …]
|
/illumos-gate/usr/src/test/util-tests/tests/workq/ |
H A D | wqt.c | 135 wq_test_run(workq_t *wqp, wq_test_t *wqt) in wq_test_run() argument 141 if ((ret = workq_add(wqp, *itemp)) != 0) { in wq_test_run() 150 ret = workq_work(wqp, wqt->wq_proc, NULL, &err); in wq_test_run() 176 workq_t *wqp; in main() local 181 if ((ret = workq_init(&wqp, nthreads[t])) != 0) { in main() 188 wq_test_run(wqp, &wq_tests[i]); in main() 191 workq_fini(wqp); in main()
|
/illumos-gate/usr/src/uts/common/os/ |
H A D | strsubr.c | 713 wqp->q_count = 0; in queue_constructor() 720 wqp->q_rwcnt = 0; in queue_constructor() 721 wqp->q_spri = 0; in queue_constructor() 1307 ASSERT(flush_syncq(wqp->q_syncq, wqp) == 0); in qdetach() 1434 cv_wait(&wqp->q_wait, QLOCK(wqp)); in wait_svc() 3415 wqp->q_spri = 0; in allocq() 3454 (void) flush_syncq(wqp->q_syncq, wqp); in freeq() 3483 if (qp->q_syncq != wqp->q_syncq && wqp->q_syncq != SQ(qp)) in freeq() 4925 cv_wait(&wqp->q_wait, QLOCK(wqp)); in removeq() 4946 ASSERT(qp->q_next == NULL || backq(wqp)->q_next == wqp); in removeq() [all …]
|
H A D | streamio.c | 2678 putnext(wqp, mp); in strput() 2681 putnext(wqp, mp); in strput() 2777 putnext(wqp, mp); in strput() 2780 putnext(wqp, mp); in strput() 2819 struct queue *wqp; in strwrite_common() local 2847 wqp = stp->sd_wrq; in strwrite_common() 2868 wqp, 0, ERANGE); in strwrite_common() 7857 queue_t *wqp; in strputmsg() local 7869 wqp = stp->sd_wrq; in strputmsg() 8061 queue_t *wqp; in kstrputmsg() local [all …]
|
/illumos-gate/usr/src/uts/common/io/ |
H A D | pts.c | 434 queue_t *wqp; in ptsclose() local 466 wqp = WR(rqp); in ptsclose() 468 while ((bp = getq(wqp)) != NULL) { in ptsclose() 475 qreply(wqp, bp); in ptsclose()
|
H A D | zcons.c | 632 queue_t *wqp; in zc_close() local 663 wqp = WR(rqp); in zc_close() 664 while ((bp = getq(wqp)) != NULL) { in zc_close() 668 miocnak(wqp, bp, 0, 0); in zc_close()
|
/illumos-gate/usr/src/lib/libctf/common/ |
H A D | ctf_dwarf.c | 3467 workq_t *wqp, ctf_cu_t *cdies, ctf_file_t **fpp) in ctf_dwarf_convert_batch() argument 3484 if (workq_add(wqp, cup) == -1) { in ctf_dwarf_convert_batch() 3504 ret = workq_work(wqp, ctf_dwarf_convert_one, NULL, &err); in ctf_dwarf_convert_batch() 3583 workq_t *wqp = NULL; in ctf_dwarf_convert() local 3666 if (workq_init(&wqp, nthrs) == -1) { in ctf_dwarf_convert() 3677 fd, nthrs, wqp, cdies, fpp); in ctf_dwarf_convert() 3690 workq_fini(wqp); in ctf_dwarf_convert()
|
/illumos-gate/usr/src/uts/common/fs/sockfs/ |
H A D | socktpi.c | 4414 struct queue *wqp; in kstrwritemp() local 4435 wqp = stp->sd_wrq; in kstrwritemp() 4436 if (canputnext(wqp) && direct && in kstrwritemp() 4461 if (canputnext(wqp)) { in kstrwritemp() 4472 putnext(wqp, mp); in kstrwritemp()
|