Lines Matching refs:parityLogDiskQueue
503 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
505 &raidPtr->parityLogDiskQueue.reintBlockHead,
506 &raidPtr->parityLogDiskQueue.reintBlockTail,
512 &raidPtr->parityLogDiskQueue.reintBlockHead,
513 &raidPtr->parityLogDiskQueue.reintBlockTail,
517 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
530 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
537 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
603 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
610 raidPtr->parityLogDiskQueue.threadState |= RF_PLOG_RUNNING;
611 rf_signal_cond2(raidPtr->parityLogDiskQueue.cond);
614 flushQueue = raidPtr->parityLogDiskQueue.flushQueue;
615 raidPtr->parityLogDiskQueue.flushQueue = NULL;
616 reintQueue = raidPtr->parityLogDiskQueue.reintQueue;
617 raidPtr->parityLogDiskQueue.reintQueue = NULL;
636 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
647 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
648 flushQueue = raidPtr->parityLogDiskQueue.flushQueue;
649 raidPtr->parityLogDiskQueue.flushQueue = NULL;
650 reintQueue = raidPtr->parityLogDiskQueue.reintQueue;
651 raidPtr->parityLogDiskQueue.reintQueue = NULL;
655 if (raidPtr->parityLogDiskQueue.threadState & RF_PLOG_TERMINATE) {
659 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
666 rf_wait_cond2(raidPtr->parityLogDiskQueue.cond,
667 raidPtr->parityLogDiskQueue.mutex);
670 flushQueue = raidPtr->parityLogDiskQueue.flushQueue;
671 raidPtr->parityLogDiskQueue.flushQueue = NULL;
672 reintQueue = raidPtr->parityLogDiskQueue.reintQueue;
673 raidPtr->parityLogDiskQueue.reintQueue = NULL;
680 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
681 raidPtr->parityLogDiskQueue.threadState |= RF_PLOG_SHUTDOWN;
682 rf_signal_cond2(raidPtr->parityLogDiskQueue.cond);
683 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);