Lines Matching refs:srq

1748 smb_srqueue_init(smb_srqueue_t *srq)  in smb_srqueue_init()  argument
1750 bzero(srq, sizeof (*srq)); in smb_srqueue_init()
1751 mutex_init(&srq->srq_mutex, NULL, MUTEX_SPIN, (void *)ipltospl(SPL7)); in smb_srqueue_init()
1752 srq->srq_wlastupdate = srq->srq_rlastupdate = gethrtime_unscaled(); in smb_srqueue_init()
1759 smb_srqueue_destroy(smb_srqueue_t *srq) in smb_srqueue_destroy() argument
1761 mutex_destroy(&srq->srq_mutex); in smb_srqueue_destroy()
1768 smb_srqueue_waitq_enter(smb_srqueue_t *srq) in smb_srqueue_waitq_enter() argument
1774 mutex_enter(&srq->srq_mutex); in smb_srqueue_waitq_enter()
1776 delta = new - srq->srq_wlastupdate; in smb_srqueue_waitq_enter()
1777 srq->srq_wlastupdate = new; in smb_srqueue_waitq_enter()
1778 wcnt = srq->srq_wcnt++; in smb_srqueue_waitq_enter()
1780 srq->srq_wlentime += delta * wcnt; in smb_srqueue_waitq_enter()
1781 srq->srq_wtime += delta; in smb_srqueue_waitq_enter()
1783 mutex_exit(&srq->srq_mutex); in smb_srqueue_waitq_enter()
1790 smb_srqueue_runq_exit(smb_srqueue_t *srq) in smb_srqueue_runq_exit() argument
1796 mutex_enter(&srq->srq_mutex); in smb_srqueue_runq_exit()
1798 delta = new - srq->srq_rlastupdate; in smb_srqueue_runq_exit()
1799 srq->srq_rlastupdate = new; in smb_srqueue_runq_exit()
1800 rcnt = srq->srq_rcnt--; in smb_srqueue_runq_exit()
1802 srq->srq_rlentime += delta * rcnt; in smb_srqueue_runq_exit()
1803 srq->srq_rtime += delta; in smb_srqueue_runq_exit()
1804 mutex_exit(&srq->srq_mutex); in smb_srqueue_runq_exit()
1811 smb_srqueue_waitq_to_runq(smb_srqueue_t *srq) in smb_srqueue_waitq_to_runq() argument
1818 mutex_enter(&srq->srq_mutex); in smb_srqueue_waitq_to_runq()
1820 delta = new - srq->srq_wlastupdate; in smb_srqueue_waitq_to_runq()
1821 srq->srq_wlastupdate = new; in smb_srqueue_waitq_to_runq()
1822 wcnt = srq->srq_wcnt--; in smb_srqueue_waitq_to_runq()
1824 srq->srq_wlentime += delta * wcnt; in smb_srqueue_waitq_to_runq()
1825 srq->srq_wtime += delta; in smb_srqueue_waitq_to_runq()
1826 delta = new - srq->srq_rlastupdate; in smb_srqueue_waitq_to_runq()
1827 srq->srq_rlastupdate = new; in smb_srqueue_waitq_to_runq()
1828 rcnt = srq->srq_rcnt++; in smb_srqueue_waitq_to_runq()
1830 srq->srq_rlentime += delta * rcnt; in smb_srqueue_waitq_to_runq()
1831 srq->srq_rtime += delta; in smb_srqueue_waitq_to_runq()
1833 mutex_exit(&srq->srq_mutex); in smb_srqueue_waitq_to_runq()
1842 smb_srqueue_update(smb_srqueue_t *srq, smb_kstat_utilization_t *kd) in smb_srqueue_update() argument
1847 mutex_enter(&srq->srq_mutex); in smb_srqueue_update()
1849 delta = snaptime - srq->srq_wlastupdate; in smb_srqueue_update()
1850 srq->srq_wlastupdate = snaptime; in smb_srqueue_update()
1851 if (srq->srq_wcnt != 0) { in smb_srqueue_update()
1852 srq->srq_wlentime += delta * srq->srq_wcnt; in smb_srqueue_update()
1853 srq->srq_wtime += delta; in smb_srqueue_update()
1855 delta = snaptime - srq->srq_rlastupdate; in smb_srqueue_update()
1856 srq->srq_rlastupdate = snaptime; in smb_srqueue_update()
1857 if (srq->srq_rcnt != 0) { in smb_srqueue_update()
1858 srq->srq_rlentime += delta * srq->srq_rcnt; in smb_srqueue_update()
1859 srq->srq_rtime += delta; in smb_srqueue_update()
1861 kd->ku_rlentime = srq->srq_rlentime; in smb_srqueue_update()
1862 kd->ku_rtime = srq->srq_rtime; in smb_srqueue_update()
1863 kd->ku_wlentime = srq->srq_wlentime; in smb_srqueue_update()
1864 kd->ku_wtime = srq->srq_wtime; in smb_srqueue_update()
1865 mutex_exit(&srq->srq_mutex); in smb_srqueue_update()