Lines Matching refs:commitNode
162 RF_DagNode_t *wnqNode, *blockNode, *commitNode, *termNode; in rf_CommonCreateLargeWriteDAG() local
197 commitNode = &nodes[i]; in rf_CommonCreateLargeWriteDAG()
227 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CommonCreateLargeWriteDAG()
390 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CommonCreateLargeWriteDAG()
391 xorNode->succedents[0] = commitNode; in rf_CommonCreateLargeWriteDAG()
392 commitNode->antecedents[0] = xorNode; in rf_CommonCreateLargeWriteDAG()
393 commitNode->antType[0] = rf_control; in rf_CommonCreateLargeWriteDAG()
396 RF_ASSERT(commitNode->numSuccedents == nWndNodes + nfaults); in rf_CommonCreateLargeWriteDAG()
399 commitNode->succedents[i] = &wndNodes[i]; in rf_CommonCreateLargeWriteDAG()
400 wndNodes[i].antecedents[0] = commitNode; in rf_CommonCreateLargeWriteDAG()
404 commitNode->succedents[nWndNodes] = wnpNode; in rf_CommonCreateLargeWriteDAG()
405 wnpNode->antecedents[0] = commitNode; in rf_CommonCreateLargeWriteDAG()
409 commitNode->succedents[nWndNodes + 1] = wnqNode; in rf_CommonCreateLargeWriteDAG()
410 wnqNode->antecedents[0] = commitNode; in rf_CommonCreateLargeWriteDAG()
473 RF_DagNode_t *xorNodes, *qNodes, *blockNode, *commitNode, *nodes; in rf_CommonCreateSmallWriteDAG() local
537 commitNode = &nodes[i]; in rf_CommonCreateSmallWriteDAG()
587 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CommonCreateSmallWriteDAG()
983 RF_ASSERT(commitNode->numAntecedents == (nfaults * numParityNodes)); in rf_CommonCreateSmallWriteDAG()
986 xorNodes[i].succedents[0] = commitNode; in rf_CommonCreateSmallWriteDAG()
987 commitNode->antecedents[i] = &xorNodes[i]; in rf_CommonCreateSmallWriteDAG()
988 commitNode->antType[i] = rf_control; in rf_CommonCreateSmallWriteDAG()
995 qNodes[i].succedents[0] = commitNode; in rf_CommonCreateSmallWriteDAG()
996 commitNode->antecedents[i + numParityNodes] = in rf_CommonCreateSmallWriteDAG()
998 commitNode->antType[i + numParityNodes] = rf_control; in rf_CommonCreateSmallWriteDAG()
1002 RF_ASSERT(commitNode->numSuccedents == in rf_CommonCreateSmallWriteDAG()
1006 commitNode->succedents[i] = &writeDataNodes[i]; in rf_CommonCreateSmallWriteDAG()
1007 writeDataNodes[i].antecedents[0] = commitNode; in rf_CommonCreateSmallWriteDAG()
1012 commitNode->succedents[i + numDataNodes] = &writeParityNodes[i]; in rf_CommonCreateSmallWriteDAG()
1013 writeParityNodes[i].antecedents[0] = commitNode; in rf_CommonCreateSmallWriteDAG()
1019 commitNode->succedents in rf_CommonCreateSmallWriteDAG()
1022 writeQNodes[i].antecedents[0] = commitNode; in rf_CommonCreateSmallWriteDAG()
1136 RF_DagNode_t *unblockNode, *termNode, *commitNode; in rf_CreateRaidOneWriteDAG() local
1171 commitNode = &nodes[i]; in rf_CreateRaidOneWriteDAG()
1185 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CreateRaidOneWriteDAG()
1237 RF_ASSERT(commitNode->numAntecedents == 0); in rf_CreateRaidOneWriteDAG()
1238 dag_h->succedents[0] = commitNode; in rf_CreateRaidOneWriteDAG()
1241 RF_ASSERT(commitNode->numSuccedents == (nWndNodes + nWmirNodes)); in rf_CreateRaidOneWriteDAG()
1244 commitNode->succedents[i] = &wndNode[i]; in rf_CreateRaidOneWriteDAG()
1245 wndNode[i].antecedents[0] = commitNode; in rf_CreateRaidOneWriteDAG()
1250 commitNode->succedents[i + nWndNodes] = &wmirNode[i]; in rf_CreateRaidOneWriteDAG()
1251 wmirNode[i].antecedents[0] = commitNode; in rf_CreateRaidOneWriteDAG()