515 		RF_LOCK_MUTEX(raidPtr->parityLogDiskQueue.mutex);  in rf_ReintegrateLogs()
517 		    &raidPtr->parityLogDiskQueue.reintBlockHead,  in rf_ReintegrateLogs()
518 		    &raidPtr->parityLogDiskQueue.reintBlockTail, RF_TRUE);  in rf_ReintegrateLogs()
523 			     &raidPtr->parityLogDiskQueue.reintBlockHead,  in rf_ReintegrateLogs()
524 			     &raidPtr->parityLogDiskQueue.reintBlockTail,  in rf_ReintegrateLogs()
528 		RF_UNLOCK_MUTEX(raidPtr->parityLogDiskQueue.mutex);  in rf_ReintegrateLogs()
544 			RF_LOCK_MUTEX(raidPtr->parityLogDiskQueue.mutex);  in rf_ReintegrateLogs()
551 			RF_UNLOCK_MUTEX(raidPtr->parityLogDiskQueue.mutex);  in rf_ReintegrateLogs()
624 	RF_LOCK_MUTEX(raidPtr->parityLogDiskQueue.mutex);  in rf_ParityLoggingDiskManager()
631 	raidPtr->parityLogDiskQueue.threadState |= RF_PLOG_RUNNING;  in rf_ParityLoggingDiskManager()
632 	RF_SIGNAL_COND(raidPtr->parityLogDiskQueue.cond);  in rf_ParityLoggingDiskManager()
635 	flushQueue = raidPtr->parityLogDiskQueue.flushQueue;  in rf_ParityLoggingDiskManager()
636 	raidPtr->parityLogDiskQueue.flushQueue = NULL;  in rf_ParityLoggingDiskManager()
637 	reintQueue = raidPtr->parityLogDiskQueue.reintQueue;  in rf_ParityLoggingDiskManager()
638 	raidPtr->parityLogDiskQueue.reintQueue = NULL;  in rf_ParityLoggingDiskManager()
659 			RF_UNLOCK_MUTEX(raidPtr->parityLogDiskQueue.mutex);  in rf_ParityLoggingDiskManager()
674 			RF_LOCK_MUTEX(raidPtr->parityLogDiskQueue.mutex);  in rf_ParityLoggingDiskManager()
675 			flushQueue = raidPtr->parityLogDiskQueue.flushQueue;  in rf_ParityLoggingDiskManager()
676 			raidPtr->parityLogDiskQueue.flushQueue = NULL;  in rf_ParityLoggingDiskManager()
677 			reintQueue = raidPtr->parityLogDiskQueue.reintQueue;  in rf_ParityLoggingDiskManager()
678 			raidPtr->parityLogDiskQueue.reintQueue = NULL;  in rf_ParityLoggingDiskManager()
682 		if (raidPtr->parityLogDiskQueue.threadState & RF_PLOG_TERMINATE) {  in rf_ParityLoggingDiskManager()
689 			RF_UNLOCK_MUTEX(raidPtr->parityLogDiskQueue.mutex);  in rf_ParityLoggingDiskManager()
697 			RF_WAIT_COND(raidPtr->parityLogDiskQueue.cond,  in rf_ParityLoggingDiskManager()
698 			    raidPtr->parityLogDiskQueue.mutex);  in rf_ParityLoggingDiskManager()
702 			flushQueue = raidPtr->parityLogDiskQueue.flushQueue;  in rf_ParityLoggingDiskManager()
703 			raidPtr->parityLogDiskQueue.flushQueue = NULL;  in rf_ParityLoggingDiskManager()
704 			reintQueue = raidPtr->parityLogDiskQueue.reintQueue;  in rf_ParityLoggingDiskManager()
705 			raidPtr->parityLogDiskQueue.reintQueue = NULL;  in rf_ParityLoggingDiskManager()
712 	RF_LOCK_MUTEX(raidPtr->parityLogDiskQueue.mutex);  in rf_ParityLoggingDiskManager()
713 	raidPtr->parityLogDiskQueue.threadState |= RF_PLOG_SHUTDOWN;  in rf_ParityLoggingDiskManager()
714 	RF_UNLOCK_MUTEX(raidPtr->parityLogDiskQueue.mutex);  in rf_ParityLoggingDiskManager()
715 	RF_SIGNAL_COND(raidPtr->parityLogDiskQueue.cond);  in rf_ParityLoggingDiskManager()