Home
last modified time | relevance | path

Searched refs:wqp (Results 1 – 8 of 8) sorted by relevance

/illumos-gate/usr/src/lib/mergeq/
H A Dworkq.c71 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 Dwqt.c135 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 Dstrsubr.c713 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 Dstreamio.c2678 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 Dpts.c434 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 Dzcons.c632 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 Dctf_dwarf.c3467 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 Dsocktpi.c4414 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()