| /titanic_50/usr/src/uts/common/avs/ns/sdbc/ |
| H A D | safestore.c | 237 _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 …]
|
| /titanic_50/usr/src/uts/common/io/cxgbe/t4nex/ |
| H A D | adapter.c | 114 t4_wrq_tx(struct adapter *sc, struct sge_wrq *wrq, mblk_t *m) in t4_wrq_tx() argument
118 TXQ_LOCK(wrq); in t4_wrq_tx()
119 rc = t4_wrq_tx_locked(sc, wrq, m); in t4_wrq_tx()
120 TXQ_UNLOCK(wrq); in t4_wrq_tx()
|
| H A D | t4_sge.c | 106 struct sge_wrq *wrq, int idx);
107 static int free_wrq(struct adapter *sc, struct sge_wrq *wrq);
815 t4_wrq_tx_locked(struct adapter *sc, struct sge_wrq *wrq, mblk_t *m0) in t4_wrq_tx_locked() argument
817 struct sge_eq *eq = &wrq->eq; in t4_wrq_tx_locked()
818 struct mblk_pair *wr_list = &wrq->wr_list; in t4_wrq_tx_locked()
823 TXQ_LOCK_ASSERT_OWNED(wrq); in t4_wrq_tx_locked()
863 wrq->no_desc++; in t4_wrq_tx_locked()
880 wrq->tx_wrs++; in t4_wrq_tx_locked()
1619 alloc_wrq(struct adapter *sc, struct port_info *pi, struct sge_wrq *wrq, in alloc_wrq() argument
1624 rc = alloc_eq(sc, pi, &wrq->eq); in alloc_wrq()
[all …]
|
| H A D | adapter.h | 582 int t4_wrq_tx(struct adapter *sc, struct sge_wrq *wrq, mblk_t *m);
606 int t4_wrq_tx_locked(struct adapter *sc, struct sge_wrq *wrq, mblk_t *m0);
|
| /titanic_50/usr/src/uts/common/io/ |
| H A D | ldterm.c | 938 queue_t *wrq = WR(q); /* write queue of ldterm mod */ in ldtermrput() local
1187 (void) putnextctl(wrq, M_STARTI); in ldtermrput()
1204 (void) putnextctl(wrq, M_STARTI); in ldtermrput()
1260 (void) putnextctl(wrq, M_START); in ldtermrput()
1281 (void) putnextctl(wrq, in ldtermrput()
1289 (void) putnextctl(wrq, in ldtermrput()
1320 ldterm_flush_output(c, wrq, tp); in ldtermrput()
1456 (void) putnextctl(wrq, M_STOPI); in ldtermrput()
1734 queue_t *wrq = WR(q); in ldterm_docanon() local
1759 ldterm_outstring((unsigned char *)"^\b", 2, wrq, in ldterm_docanon()
[all …]
|
| H A D | stream.c | 3276 queue_t *wrq; in strqset() local
3343 wrq = STREAM(q)->sd_wrq; in strqset()
3344 if (q != wrq->q_next) in strqset()
3353 mutex_enter(QLOCK(wrq)); in strqset()
3355 ASSERT(MUTEX_HELD(QLOCK(wrq))); in strqset()
3369 mutex_exit(QLOCK(wrq)); in strqset()
3386 wrq = STREAM(q)->sd_wrq; in strqset()
3387 if (q != wrq->q_next) in strqset()
3396 mutex_enter(QLOCK(wrq)); in strqset()
3401 mutex_exit(QLOCK(wrq)); in strqset()
|
| /titanic_50/usr/src/cmd/mdb/common/modules/sdbc/ |
| H A D | sdbc.c | 1137 _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 …]
|
| /titanic_50/usr/src/uts/common/os/ |
| H A D | strsubr.c | 1124 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 D | streamio.c | 3204 queue_t *wrq; in strioctl() local
3230 wrq = stp->sd_wrq; in strioctl()
3231 rdq = _RD(wrq); in strioctl()
3846 mutex_enter(QLOCK(wrq)); in strioctl()
3849 mutex_exit(QLOCK(wrq)); in strioctl()
3862 if (!wrq->q_next) /* for broken pipes */ in strioctl()
3895 q = wrq->q_next; in strioctl()
3911 mutex_enter(QLOCK(wrq->q_next)); in strioctl()
3912 rmin = wrq->q_next->q_minpsz; in strioctl()
3913 rmax = wrq->q_next->q_maxpsz; in strioctl()
[all …]
|
| /titanic_50/usr/src/uts/common/io/fibre-channel/ulp/ |
| H A D | fcip.c | 2259 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()
|