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