Home
last modified time | relevance | path

Searched refs:wrq (Results 1 – 7 of 7) sorted by relevance

/onnv-gate/usr/src/uts/common/avs/ns/sdbc/
H A Dsafestore.c237 _sdbc_writeq_configure(_sd_writeq_t *wrq) in _sdbc_writeq_configure() argument
241 wrq->wq_inq = 0; in _sdbc_writeq_configure()
242 mutex_init(&wrq->wq_qlock, NULL, MUTEX_DRIVER, NULL); in _sdbc_writeq_configure()
243 wrq->wq_qtop = NULL; in _sdbc_writeq_configure()
244 wrq->wq_slp_top = 0; in _sdbc_writeq_configure()
245 wrq->wq_slp_index = 0; in _sdbc_writeq_configure()
246 wrq->wq_slp_inq = 0; in _sdbc_writeq_configure()
249 wrq->wq_slp[i].slp_wqneed = 0; in _sdbc_writeq_configure()
250 cv_init(&wrq->wq_slp[i].slp_wqcv, NULL, CV_DRIVER, NULL); in _sdbc_writeq_configure()
262 _sdbc_writeq_deconfigure(_sd_writeq_t *wrq) in _sdbc_writeq_deconfigure() argument
[all …]
/onnv-gate/usr/src/uts/common/io/
H A Dldterm.c939 queue_t *wrq = WR(q); /* write queue of ldterm mod */ in ldtermrput() local
1188 (void) putnextctl(wrq, M_STARTI); in ldtermrput()
1205 (void) putnextctl(wrq, M_STARTI); in ldtermrput()
1261 (void) putnextctl(wrq, M_START); in ldtermrput()
1282 (void) putnextctl(wrq, in ldtermrput()
1290 (void) putnextctl(wrq, in ldtermrput()
1321 ldterm_flush_output(c, wrq, tp); in ldtermrput()
1446 (void) putnextctl(wrq, M_STOPI); in ldtermrput()
1724 queue_t *wrq = WR(q); in ldterm_docanon() local
1749 ldterm_outstring((unsigned char *)"^\b", 2, wrq, in ldterm_docanon()
[all …]
H A Dstream.c3275 queue_t *wrq; in strqset() local
3342 wrq = STREAM(q)->sd_wrq; in strqset()
3343 if (q != wrq->q_next) in strqset()
3352 mutex_enter(QLOCK(wrq)); in strqset()
3354 ASSERT(MUTEX_HELD(QLOCK(wrq))); in strqset()
3368 mutex_exit(QLOCK(wrq)); in strqset()
3385 wrq = STREAM(q)->sd_wrq; in strqset()
3386 if (q != wrq->q_next) in strqset()
3395 mutex_enter(QLOCK(wrq)); in strqset()
3400 mutex_exit(QLOCK(wrq)); in strqset()
/onnv-gate/usr/src/cmd/mdb/common/modules/sdbc/
H A Dsdbc.c1137 _sd_writeq_t wrq; in sdbc_wctl_winit() local
1208 _sd_writeq_t wrq; in sdbc_wrq_winit() local
2051 print_wrq(_sd_writeq_t *wrq, uint_t verbose) in print_wrq() argument
2058 wrq->wq_qtop, in print_wrq()
2059 wrq->wq_qlock._opaque[0], in print_wrq()
2060 wrq->wq_inq); in print_wrq()
2063 wrq->wq_slp_top, in print_wrq()
2064 wrq->wq_slp_index, in print_wrq()
2065 wrq->wq_slp_inq); in print_wrq()
2070 wrq->wq_slp[i].slp_wqcv._opaque, in print_wrq()
[all …]
/onnv-gate/usr/src/uts/common/os/
H A Dstrsubr.c1124 queue_t *wrq; in qattach() local
1132 wrq = _WR(rq); in qattach()
1133 STREAM(rq) = STREAM(wrq) = STREAM(qp); in qattach()
1207 if (backq(wrq) != NULL && backq(wrq)->q_next == wrq) in qattach()
1210 rq->q_next = wrq->q_next = NULL; in qattach()
2014 queue_t *rq, *wrq; in munlink() local
2083 wrq = stpdown->sd_wrq; in munlink()
2084 rq = _RD(wrq); in munlink()
2100 if (wrq->q_flag & QPERMOD) { in munlink()
2101 syncq_t *sq = wrq->q_syncq; in munlink()
[all …]
H A Dstreamio.c3203 queue_t *wrq; in strioctl() local
3229 wrq = stp->sd_wrq; in strioctl()
3230 rdq = _RD(wrq); in strioctl()
3845 mutex_enter(QLOCK(wrq)); in strioctl()
3848 mutex_exit(QLOCK(wrq)); in strioctl()
3861 if (!wrq->q_next) /* for broken pipes */ in strioctl()
3894 q = wrq->q_next; in strioctl()
3910 mutex_enter(QLOCK(wrq->q_next)); in strioctl()
3911 rmin = wrq->q_next->q_minpsz; in strioctl()
3912 rmax = wrq->q_next->q_maxpsz; in strioctl()
[all …]
/onnv-gate/usr/src/uts/common/io/fibre-channel/ulp/
H A Dfcip.c2259 queue_t *wrq; in fcip_statec_cb() local
2397 wrq = WR(slp->sl_rq); in fcip_statec_cb()
2398 if (wrq->q_flag & QFULL) { in fcip_statec_cb()
2399 qenable(wrq); in fcip_statec_cb()