dev/raidframe/rf_dagffwr.c

172 	RF_DagNode_t *blockNode, *commitNode, *termNode;
222 	commitNode = rf_AllocDAGNode(raidPtr);
223 	commitNode->list_next = dag_h->nodes;
224 	dag_h->nodes = commitNode;
262 	rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc,
437 	RF_ASSERT(commitNode->numAntecedents == 1);
438 	xorNode->succedents[0] = commitNode;
439 	commitNode->antecedents[0] = xorNode;
440 	commitNode->antType[0] = rf_control;
443 	RF_ASSERT(commitNode->numSuccedents == nWndNodes + nfaults);
447 		commitNode->succedents[i] = tmpNode;
448 		tmpNode->antecedents[0] = commitNode;
453 	commitNode->succedents[nWndNodes] = wnpNode;
454 	wnpNode->antecedents[0] = commitNode;
459 		commitNode->succedents[nWndNodes + 1] = wnqNode;
460 		wnqNode->antecedents[0] = commitNode;
531 	RF_DagNode_t *xorNodes, *blockNode, *commitNode;
598 	commitNode = rf_AllocDAGNode(raidPtr);
599 	commitNode->list_next = dag_h->nodes;
600 	dag_h->nodes = commitNode;
678 	rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc,
1091 	RF_ASSERT(commitNode->numAntecedents == (nfaults * numParityNodes));
1095 		tmpxorNode->succedents[0] = commitNode;
1096 		commitNode->antecedents[i] = tmpxorNode;
1097 		commitNode->antType[i] = rf_control;
1107 			tmpqNode->succedents[0] = commitNode;
1108 			commitNode->antecedents[i + numParityNodes] = tmpqNode;
1109 			commitNode->antType[i + numParityNodes] = rf_control;
1115 	RF_ASSERT(commitNode->numSuccedents == (numDataNodes + (nfaults * numParityNodes)));
1119 		commitNode->succedents[i] = tmpwriteDataNode;
1120 		tmpwriteDataNode->antecedents[0] = commitNode;
1127 		commitNode->succedents[i + numDataNodes] = tmpwriteParityNode;
1128 		tmpwriteParityNode->antecedents[0] = commitNode;
1137 			commitNode->succedents[i + numDataNodes + numParityNodes] = tmpwriteQNode;
1138 			tmpwriteQNode->antecedents[0] = commitNode;
1203 	RF_DagNode_t *unblockNode, *termNode, *commitNode;
1246 	commitNode = rf_AllocDAGNode(raidPtr);
1247 	commitNode->list_next = dag_h->nodes;
1248 	dag_h->nodes = commitNode;
1264 	rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc,
1317 	RF_ASSERT(commitNode->numAntecedents == 0);
1318 	dag_h->succedents[0] = commitNode;
1321 	RF_ASSERT(commitNode->numSuccedents == (nWndNodes + nWmirNodes));
1325 		commitNode->succedents[i] = tmpwndNode;
1326 		tmpwndNode->antecedents[0] = commitNode;
1333 		commitNode->succedents[i + nWndNodes] = tmpwmirNode;
1334 		tmpwmirNode->antecedents[0] = commitNode;