Home
last modified time | relevance | path

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

/titanic_50/usr/src/lib/mergeq/
H A Dworkq.c62 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 …]
/titanic_50/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()
/titanic_50/usr/src/uts/common/os/
H A Dstrsubr.c689 queue_t *wqp = &qip->qu_wqueue; in queue_constructor() local
707 wqp->q_first = NULL; in queue_constructor()
708 wqp->q_link = NULL; in queue_constructor()
709 wqp->q_count = 0; in queue_constructor()
710 wqp->q_mblkcnt = 0; in queue_constructor()
711 wqp->q_sqhead = NULL; in queue_constructor()
712 wqp->q_sqtail = NULL; in queue_constructor()
713 wqp->q_sqnext = NULL; in queue_constructor()
714 wqp->q_sqprev = NULL; in queue_constructor()
715 wqp->q_sqflags = 0; in queue_constructor()
[all …]
H A Dstreamio.c2548 queue_t *wqp = stp->sd_wrq; in strput() local
2562 if (!canputnext(wqp) && !(flags & MSG_IGNFLOW)) { in strput()
2567 if (!(flags & MSG_IGNFLOW) && !bcanputnext(wqp, pri)) { in strput()
2607 putnext(wqp, mp); in strput()
2610 putnext(wqp, mp); in strput()
2642 error = rwnext(wqp, &uiod); in strput()
2666 if (!canputnext(wqp) && !(flags & MSG_IGNFLOW)) { in strput()
2671 if (!bcanputnext(wqp, pri) && !(flags & MSG_IGNFLOW)) { in strput()
2678 if ((error = struioget(wqp, mp, &uiod, 0)) != 0) { in strput()
2690 putnext(wqp, mp); in strput()
[all …]
/titanic_50/usr/src/uts/common/io/
H A Dpts.c432 queue_t *wqp; in ptsclose() local
464 wqp = WR(rqp); in ptsclose()
466 while ((bp = getq(wqp)) != NULL) { in ptsclose()
473 qreply(wqp, bp); in ptsclose()
H A Dzcons.c628 queue_t *wqp; in zc_close() local
659 wqp = WR(rqp); in zc_close()
660 while ((bp = getq(wqp)) != NULL) { in zc_close()
664 miocnak(wqp, bp, 0, 0); in zc_close()
/titanic_50/usr/src/lib/libctf/common/
H A Dctf_dwarf.c2840 workq_t *wqp = NULL; in ctf_dwarf_convert() local
2920 if (workq_init(&wqp, nthrs) == -1) { in ctf_dwarf_convert()
2929 if (workq_add(wqp, cup) == -1) { in ctf_dwarf_convert()
2935 ret = workq_work(wqp, ctf_dwarf_convert_one, NULL, errp); in ctf_dwarf_convert()
2992 workq_fini(wqp); in ctf_dwarf_convert()
/titanic_50/usr/src/uts/common/fs/sockfs/
H A Dsocktpi.c4479 struct queue *wqp; in kstrwritemp() local
4500 wqp = stp->sd_wrq; in kstrwritemp()
4501 if (canputnext(wqp) && direct && in kstrwritemp()
4526 if (canputnext(wqp)) { in kstrwritemp()
4537 putnext(wqp, mp); in kstrwritemp()
/titanic_50/usr/src/uts/common/inet/nca/
H A Dnca.h1044 queue_t *wqp; /* our write-side STREAMS queue */ member