Lines Matching refs:rctrl
85 RF_ReconCtrl_t *rctrl = raidPtr->reconControl; in rf_GetNextReconEvent() local
89 rf_lock_mutex2(rctrl->eq_mutex); in rf_GetNextReconEvent()
91 RF_ASSERT((rctrl->eventQueue == NULL) == (rctrl->eq_count == 0)); in rf_GetNextReconEvent()
123 rctrl->eq_mutex); in rf_GetNextReconEvent()
130 while (!rctrl->eventQueue) { in rf_GetNextReconEvent()
135 rf_timedwait_cond2(rctrl->eq_cv, rctrl->eq_mutex, in rf_GetNextReconEvent()
141 rctrl->headSepCBList) { in rf_GetNextReconEvent()
155 event = rctrl->eventQueue; in rf_GetNextReconEvent()
156 rctrl->eventQueue = event->next; in rf_GetNextReconEvent()
158 rctrl->eq_count--; in rf_GetNextReconEvent()
161 RF_ASSERT((rctrl->eventQueue == NULL) == (rctrl->eq_count == 0)); in rf_GetNextReconEvent()
162 rf_unlock_mutex2(rctrl->eq_mutex); in rf_GetNextReconEvent()
170 RF_ReconCtrl_t *rctrl = raidPtr->reconControl; in rf_CauseReconEvent() local
174 RF_ASSERT(col != rctrl->fcol); in rf_CauseReconEvent()
177 rf_lock_mutex2(rctrl->eq_mutex); in rf_CauseReconEvent()
179 RF_ASSERT((rctrl->eventQueue == NULL) == (rctrl->eq_count == 0)); in rf_CauseReconEvent()
180 event->next = rctrl->eventQueue; in rf_CauseReconEvent()
181 rctrl->eventQueue = event; in rf_CauseReconEvent()
182 rctrl->eq_count++; in rf_CauseReconEvent()
183 rf_broadcast_cond2(rctrl->eq_cv); in rf_CauseReconEvent()
184 rf_unlock_mutex2(rctrl->eq_mutex); in rf_CauseReconEvent()
209 RF_ReconCtrl_t *rctrl = reconDesc->raidPtr->reconControl; in rf_DrainReconEventQueue() local
212 rf_lock_mutex2(rctrl->eq_mutex); in rf_DrainReconEventQueue()
213 while (rctrl->eventQueue!=NULL) { in rf_DrainReconEventQueue()
215 event = rctrl->eventQueue; in rf_DrainReconEventQueue()
216 rctrl->eventQueue = event->next; in rf_DrainReconEventQueue()
218 rctrl->eq_count--; in rf_DrainReconEventQueue()
222 rf_unlock_mutex2(rctrl->eq_mutex); in rf_DrainReconEventQueue()