RF_TRUE
cantCreateDAGs = RF_TRUE;
rf_InitNode(unblockNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc, NULL, 1, nReadNodes, 0, 0, dag_h, "Nil", allocList);
useMirror = RF_TRUE;
rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc,
rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc,
shiftable = RF_TRUE;
useMirror = RF_TRUE;
rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc,
rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc,
flags, allocList, 1, rf_RecoveryXorFunc, RF_TRUE);
rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc,
rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc,
rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc,
allocList, 1, rf_RegularXorFunc, RF_TRUE);
rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc,
rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc,
rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc,
return RF_TRUE; /* node and all succedent branches aren't in
return (RF_TRUE);
return (RF_TRUE);
ready = RF_TRUE;
ready = RF_TRUE;
skipNode = RF_TRUE;
parity_cant_correct = RF_TRUE;
parity_corrected = RF_TRUE;
red2_cant_correct = RF_TRUE;
red2_corrected = RF_TRUE;
rf_CommonCreateSimpleDegradedWriteDAG(raidPtr, asmap, dag_h, bp, flags, allocList, 2, rf_Degraded_100_EOFunc, RF_TRUE);
rf_CommonCreateLargeWriteDAG(raidPtr, asmap, dag_h, bp, flags, allocList, 1, rf_RegularPFunc, RF_TRUE);
rf_CommonCreateSimpleDegradedWriteDAG(raidPtr, asmap, dag_h, bp, flags, allocList, 1, rf_RecoveryXorFunc, RF_TRUE);
logDataList = DequeueParityLogData(raidPtr, head, tail, RF_TRUE);
logData->next = rf_SearchAndDequeueParityLogData(raidPtr, regionID, head, tail, RF_TRUE);
logData->next = rf_SearchAndDequeueParityLogData(raidPtr, regionID, head, tail, RF_TRUE);
rf_ParityLogAppend(logDataList, RF_TRUE, &log, RF_FALSE);
raidPtr->regionInfo[regionID].reintInProgress = RF_TRUE; /* cleared when reint
RF_ASSERT(raidPtr->regionInfo[regionID].reintInProgress == RF_TRUE);
punt = RF_TRUE; /* failed to find a core log */
punt = RF_TRUE; /* dump unsuccessful,
punt = RF_TRUE; /* blocked on log
done = RF_TRUE;
itemDone = RF_TRUE;
raidPtr->regionInfo[regionID].loggingEnabled = RF_TRUE;
RF_TRUE);
RF_TRUE);
rf_ParityLogAppend(logDataList, RF_TRUE, &log, RF_TRUE);
done = RF_TRUE; /* thread disabled, no work needed */
rf_InitNode(&wndNodes[i], rf_wait, RF_TRUE, rf_DiskWriteFunc, rf_DiskWriteUndoFunc, rf_GenericWakeupFunc, 1, 1, 4, 0, dag_h, "Wnd", allocList);
rf_InitNode(xorNode, rf_wait, RF_TRUE, redFunc, rf_NullNodeUndoFunc, NULL, 1, 1, 2 * (nWndNodes + nRodNodes) + 1, 1, dag_h, "Xr ", allocList);
rf_InitNode(&writeDataNodes[i], rf_wait, RF_TRUE, rf_DiskWriteFunc, rf_DiskWriteUndoFunc, rf_GenericWakeupFunc, 1, nNodes, 4, 0, dag_h, "Wnd", allocList);
rf_InitNode(&xorNodes[i], rf_wait, RF_TRUE, func, undoFunc, NULL, 1, nNodes, 7, 1, dag_h, name, allocList); /* no wakeup func for
rf_InitNode(&xorNodes[0], rf_wait, RF_TRUE, func, undoFunc, NULL, 1, nNodes, (2 * (numDataNodes + numDataNodes + 1) + 1), 1, dag_h, name, allocList);
rf_InitNode(unblockNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc, NULL, 1, nNodes, 0, 0, dag_h, "Nil", alloclist);
suspended = RF_TRUE;
suspended = RF_TRUE;
suspended = RF_TRUE;
return (RF_TRUE);
return RF_TRUE;
int i, j, done = RF_TRUE;
return RF_TRUE;