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