| /illumos-gate/usr/src/lib/mergeq/ |
| H A D | workq.c | 62 workq_fini(workq_t *wqp) in workq_fini() argument
64 if (wqp == NULL) in workq_fini()
67 VERIFY(wqp->wq_working != B_TRUE); in workq_fini()
68 VERIFY0(mutex_destroy(&wqp->wq_lock)); in workq_fini()
69 VERIFY0(cond_destroy(&wqp->wq_cond)); in workq_fini()
70 if (wqp->wq_cap > 0) in workq_fini()
71 workq_free(wqp->wq_items, sizeof (void *) * wqp->wq_cap); in workq_fini()
72 if (wqp->wq_ndthreads > 0) in workq_fini()
73 workq_free(wqp->wq_thrs, sizeof (thread_t) * wqp->wq_ndthreads); in workq_fini()
74 workq_free(wqp, sizeof (workq_t)); in workq_fini()
[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 | 692 queue_t *wqp = &qip->qu_wqueue; in queue_constructor() local
710 wqp->q_first = NULL; in queue_constructor()
711 wqp->q_link = NULL; in queue_constructor()
712 wqp->q_count = 0; in queue_constructor()
713 wqp->q_mblkcnt = 0; in queue_constructor()
714 wqp->q_sqhead = NULL; in queue_constructor()
715 wqp->q_sqtail = NULL; in queue_constructor()
716 wqp->q_sqnext = NULL; in queue_constructor()
717 wqp->q_sqprev = NULL; in queue_constructor()
718 wqp->q_sqflags = 0; in queue_constructor()
[all …]
|
| H A D | streamio.c | 2619 queue_t *wqp = stp->sd_wrq; in strput() local
2633 if (!canputnext(wqp) && !(flags & MSG_IGNFLOW)) { in strput()
2638 if (!(flags & MSG_IGNFLOW) && !bcanputnext(wqp, pri)) { in strput()
2678 putnext(wqp, mp); in strput()
2681 putnext(wqp, mp); in strput()
2719 error = rwnext(wqp, &uiod); in strput()
2747 if (!canputnext(wqp) && !(flags & MSG_IGNFLOW)) { in strput()
2754 if (!bcanputnext(wqp, pri) && !(flags & MSG_IGNFLOW)) { in strput()
2763 if ((error = struioget(wqp, mp, &uiod, 0)) != 0) { in strput()
2777 putnext(wqp, mp); in strput()
[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 | 4406 struct queue *wqp; in kstrwritemp() local
4427 wqp = stp->sd_wrq; in kstrwritemp()
4428 if (canputnext(wqp) && direct && in kstrwritemp()
4453 if (canputnext(wqp)) { in kstrwritemp()
4464 putnext(wqp, mp); in kstrwritemp()
|