Lines Matching refs:parityLogDiskQueue
70 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
71 if (raidPtr->parityLogDiskQueue.freeCommonList) {
72 common = raidPtr->parityLogDiskQueue.freeCommonList;
73 raidPtr->parityLogDiskQueue.freeCommonList = raidPtr->parityLogDiskQueue.freeCommonList->next;
74 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
76 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
95 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
96 common->next = raidPtr->parityLogDiskQueue.freeCommonList;
97 raidPtr->parityLogDiskQueue.freeCommonList = common;
98 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
110 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
111 if (raidPtr->parityLogDiskQueue.freeDataList) {
112 data = raidPtr->parityLogDiskQueue.freeDataList;
113 raidPtr->parityLogDiskQueue.freeDataList = raidPtr->parityLogDiskQueue.freeDataList->next;
114 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
116 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
132 * (data) into the free list (parityLogDiskQueue.freeList).
136 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
139 data->next = raidPtr->parityLogDiskQueue.freeDataList;
140 raidPtr->parityLogDiskQueue.freeDataList = data;
143 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
163 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
180 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
197 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
220 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
240 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
256 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
353 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
395 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
456 RequeueParityLogData(logData, &raidPtr->parityLogDiskQueue.logBlockHead, &raidPtr->parityLogDiskQueue.logBlockTail);
458 EnqueueParityLogData(logData, &raidPtr->parityLogDiskQueue.logBlockHead, &raidPtr->parityLogDiskQueue.logBlockTail);
482 * parityLogDiskQueue forces synchronization with AcquireParityLog(). */
484 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
485 logDataList = DequeueMatchingLogData(raidPtr, &raidPtr->parityLogDiskQueue.logBlockHead, &raidPtr->parityLogDiskQueue.logBlockTail);
493 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
506 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
508 logDataList = DequeueMatchingLogData(raidPtr, &raidPtr->parityLogDiskQueue.logBlockHead, &raidPtr->parityLogDiskQueue.logBlockTail);
535 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
558 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
559 log->next = raidPtr->parityLogDiskQueue.reintQueue;
560 raidPtr->parityLogDiskQueue.reintQueue = log;
562 rf_signal_cond2(raidPtr->parityLogDiskQueue.cond);
563 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
572 * (parityLogDiskQueue.flushQueue) waiting to be written to disk.
579 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
580 log->next = raidPtr->parityLogDiskQueue.flushQueue;
581 raidPtr->parityLogDiskQueue.flushQueue = log;
582 rf_signal_cond2(raidPtr->parityLogDiskQueue.cond);
583 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);
627 RequeueParityLogData(logData, &raidPtr->parityLogDiskQueue.reintBlockHead, &raidPtr->parityLogDiskQueue.reintBlockTail);
629 EnqueueParityLogData(logData, &raidPtr->parityLogDiskQueue.reintBlockHead, &raidPtr->parityLogDiskQueue.reintBlockTail);
702 rf_lock_mutex2(raidPtr->parityLogDiskQueue.mutex);
709 rf_unlock_mutex2(raidPtr->parityLogDiskQueue.mutex);