Lines Matching refs:cq
1631 dumpsys_close_cq(cqueue_t *cq, int live) in dumpsys_close_cq() argument
1634 mutex_enter(&cq->mutex); in dumpsys_close_cq()
1635 atomic_dec_uint(&cq->open); in dumpsys_close_cq()
1636 cv_signal(&cq->cv); in dumpsys_close_cq()
1637 mutex_exit(&cq->mutex); in dumpsys_close_cq()
1639 atomic_dec_uint(&cq->open); in dumpsys_close_cq()
1667 dumpsys_lock(cqueue_t *cq, int live) in dumpsys_lock() argument
1670 mutex_enter(&cq->mutex); in dumpsys_lock()
1672 dumpsys_spinlock(&cq->spinlock); in dumpsys_lock()
1676 dumpsys_unlock(cqueue_t *cq, int live, int signal) in dumpsys_unlock() argument
1680 cv_signal(&cq->cv); in dumpsys_unlock()
1681 mutex_exit(&cq->mutex); in dumpsys_unlock()
1683 dumpsys_spinunlock(&cq->spinlock); in dumpsys_unlock()
1688 dumpsys_wait_cq(cqueue_t *cq, int live) in dumpsys_wait_cq() argument
1691 cv_wait(&cq->cv, &cq->mutex); in dumpsys_wait_cq()
1693 dumpsys_spinunlock(&cq->spinlock); in dumpsys_wait_cq()
1694 while (cq->open) in dumpsys_wait_cq()
1695 if (cq->first) in dumpsys_wait_cq()
1697 dumpsys_spinlock(&cq->spinlock); in dumpsys_wait_cq()
1702 dumpsys_put_cq(cqueue_t *cq, cbuf_t *cp, int newstate, int live) in dumpsys_put_cq() argument
1707 dumpsys_lock(cq, live); in dumpsys_put_cq()
1709 if (cq->ts != 0) { in dumpsys_put_cq()
1710 cq->empty += gethrtime() - cq->ts; in dumpsys_put_cq()
1711 cq->ts = 0; in dumpsys_put_cq()
1716 if (cq->last == NULL) in dumpsys_put_cq()
1717 cq->first = cp; in dumpsys_put_cq()
1719 cq->last->next = cp; in dumpsys_put_cq()
1720 cq->last = cp; in dumpsys_put_cq()
1722 dumpsys_unlock(cq, live, 1); in dumpsys_put_cq()
1726 dumpsys_get_cq(cqueue_t *cq, int live) in dumpsys_get_cq() argument
1731 dumpsys_lock(cq, live); in dumpsys_get_cq()
1735 cp = (cbuf_t *)cq->first; in dumpsys_get_cq()
1737 if (cq->open == 0) in dumpsys_get_cq()
1739 dumpsys_wait_cq(cq, live); in dumpsys_get_cq()
1742 cq->first = cp->next; in dumpsys_get_cq()
1743 if (cq->first == NULL) { in dumpsys_get_cq()
1744 cq->last = NULL; in dumpsys_get_cq()
1745 cq->ts = now; in dumpsys_get_cq()
1750 dumpsys_unlock(cq, live, cq->first != NULL || cq->open == 0); in dumpsys_get_cq()