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