Lines Matching defs:dq
352 disk_queue *dq = &krdc->group->diskq;
366 mutex_enter(QHEADLOCK(dq));
367 mutex_enter(QLOCK(dq));
372 SET_QHEAD(dq, RDC_DISKQ_DATA_OFF);
373 SET_QTAIL(dq, RDC_DISKQ_DATA_OFF);
374 SET_QNXTIO(dq, RDC_DISKQ_DATA_OFF);
375 SET_LASTQTAIL(dq, 0);
377 rdc_dump_iohdrs(dq);
379 mutex_exit(QLOCK(dq));
380 mutex_exit(QHEADLOCK(dq));
546 disk_queue *dq = &group->diskq;
567 mutex_enter(QLOCK(dq));
574 mutex_exit(QLOCK(dq));
578 SET_QNXTIO(dq, QHEAD(dq));
579 SET_QHDRCNT(dq, 0);
580 SET_QSTATE(dq, RDC_SHUTDOWN_BAD); /* only suspend can write good */
581 dq->iohdrs = NULL;
582 dq->hdr_last = NULL;
585 rdc_dump_iohdrs(dq);
587 mutex_exit(QLOCK(dq));
964 disk_queue *dq = &group->diskq;
983 mutex_enter(QLOCK(dq));
984 if ((QNXTIO(dq) == QTAIL(dq)) && !IS_QSTATE(dq, RDC_QFULL)) {
985 mutex_exit(QLOCK(dq));
988 mutex_exit(QLOCK(dq));
1683 disk_queue *dq = &grp->diskq;
1756 cmn_err(CE_WARN, "!qinfo: " QDISPLAY(dq));
1760 cmn_err(CE_WARN, "!qinfo: " QDISPLAYND(dq));
1851 mutex_enter(QLOCK(dq));
1852 INC_QNXTIO(dq, bufcnt);
1853 mutex_exit(QLOCK(dq));
1877 mutex_enter(QLOCK(dq));
1878 rdc_dump_iohdrs(dq);
1879 mutex_exit(QLOCK(dq));
2235 rdc_calc_len(rdc_k_info_t *krdc, disk_queue *dq)
2239 ASSERT(MUTEX_HELD(QLOCK(dq)));
2242 if (QNXTIO(dq) < QTAIL(dq)) {
2244 len = min(RDC_MAX_DISKQREAD, QTAIL(dq) - QNXTIO(dq));
2247 } else if (QNXTIO(dq) > QTAIL(dq)) {
2248 if (QWRAP(dq)) {
2249 len = min(RDC_MAX_DISKQREAD, QWRAP(dq) - QNXTIO(dq));
2251 len = min(RDC_MAX_DISKQREAD, QSIZE(dq) - QNXTIO(dq));
2253 } else if (QNXTIO(dq) == QTAIL(dq)) {
2254 if (QWRAP(dq) && !IS_QSTATE(dq, QNXTIOWRAPD))
2255 len = min(RDC_MAX_DISKQREAD, QWRAP(dq) - QNXTIO(dq));
2314 disk_queue *dq = NULL;
2329 dq = &group->diskq;
2331 mutex_enter(QLOCK(dq));
2332 rdc_set_qbusy(dq); /* prevent disables on the queue */
2333 mutex_exit(QLOCK(dq));
2338 mutex_enter(QLOCK(dq));
2339 rdc_clr_qbusy(dq); /* prevent disables on the queue */
2340 mutex_exit(QLOCK(dq));
2344 mutex_enter(QHEADLOCK(dq));
2345 mutex_enter(QLOCK(dq));
2350 mutex_exit(QLOCK(dq));
2351 mutex_exit(QHEADLOCK(dq));
2360 if (IS_QSTATE(dq, QNXTIOWRAPD) && AUXQWRAP(dq)) {
2361 mutex_exit(QLOCK(dq));
2362 mutex_exit(QHEADLOCK(dq));
2366 if (QNXTIOSHLDWRAP(dq)) {
2368 cmn_err(CE_NOTE, "!wrapping Q nxtio: " QDISPLAY(dq));
2371 WRAPQNXTIO(dq);
2375 if (!QNITEMS(dq)) { /* empty */
2377 if (dq->lastio->handle)
2378 (void) nsc_free_buf(dq->lastio->handle);
2379 bzero(&(*dq->lastio), sizeof (*dq->lastio));
2380 mutex_exit(QLOCK(dq));
2381 mutex_exit(QHEADLOCK(dq));
2387 len = rdc_calc_len(krdc, dq);
2392 mutex_exit(QLOCK(dq));
2393 mutex_exit(QHEADLOCK(dq));
2411 DTRACE_PROBE2(rdc_calc_len, int, len, int, (int)QNXTIO(dq));
2415 len, QHEAD(dq), QNXTIO(dq), QTAIL(dq), QWRAP(dq));
2416 cmn_err(CE_CONT, "!qinfo: " QDISPLAYND(dq));
2418 SET_QCOALBOUNDS(dq, QNXTIO(dq) + len);
2420 while ((LASTQTAIL(dq) > 0) && !QWRAP(dq) &&
2421 ((QNXTIO(dq) + len) >= LASTQTAIL(dq)) &&
2422 (IS_QSTATE(dq, QTAILBUSY))) {
2423 mutex_exit(QLOCK(dq));
2427 "lastqtail: %d", QNXTIO(dq), len, LASTQTAIL(dq));
2430 mutex_enter(QLOCK(dq));
2433 offset = QNXTIO(dq);
2442 mutex_exit(QLOCK(dq));
2443 mutex_exit(QHEADLOCK(dq));
2447 mutex_exit(QLOCK(dq));
2448 mutex_exit(QHEADLOCK(dq));
2457 " len %d", urdc->disk_queue, QNXTIO(dq), len);
2495 mutex_enter(QLOCK(dq));
2496 rdc_clr_qbusy(dq);
2497 mutex_exit(QLOCK(dq));
2517 disk_queue *dq = &krdc->group->diskq;
2545 (!IS_STATE(urdc, RDC_SYNCING)) && (QNITEMS(dq) > 0)) {
2592 (IS_QSTATE(dq, (RDC_QDISABLEPEND | RDC_STOPPINGFLUSH))) ||
2615 disk_queue *dq = &krdc->group->diskq;
2639 mutex_enter(QLOCK(dq));
2640 if ((QNXTIO(dq) == QTAIL(dq)) && !IS_QSTATE(dq, RDC_QFULL)) {
2644 mutex_exit(QLOCK(dq));
2647 mutex_exit(QLOCK(dq));