Lines Matching refs:commitNode
122 RF_DagNode_t *nodes, *rdNode, *blockNode, *commitNode, *termNode; in rf_CreateRaidOneDegradedReadDAG() local
149 commitNode = &nodes[i]; in rf_CreateRaidOneDegradedReadDAG()
166 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CreateRaidOneDegradedReadDAG()
213 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CreateRaidOneDegradedReadDAG()
214 rdNode->succedents[0] = commitNode; in rf_CreateRaidOneDegradedReadDAG()
215 commitNode->antecedents[0] = rdNode; in rf_CreateRaidOneDegradedReadDAG()
216 commitNode->antType[0] = rf_control; in rf_CreateRaidOneDegradedReadDAG()
219 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateRaidOneDegradedReadDAG()
222 commitNode->succedents[0] = termNode; in rf_CreateRaidOneDegradedReadDAG()
223 termNode->antecedents[0] = commitNode; in rf_CreateRaidOneDegradedReadDAG()
268 RF_DagNode_t *commitNode, *rpNode, *termNode; in rf_CreateDegradedReadDAG() local
327 commitNode = &nodes[i]; in rf_CreateDegradedReadDAG()
353 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CreateDegradedReadDAG()
528 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CreateDegradedReadDAG()
529 xorNode->succedents[0] = commitNode; in rf_CreateDegradedReadDAG()
530 commitNode->antecedents[0] = xorNode; in rf_CreateDegradedReadDAG()
531 commitNode->antType[0] = rf_control; in rf_CreateDegradedReadDAG()
534 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateDegradedReadDAG()
537 commitNode->succedents[0] = termNode; in rf_CreateDegradedReadDAG()
539 termNode->antecedents[0] = commitNode; in rf_CreateDegradedReadDAG()
569 RF_DagNode_t *nodes, *rdNode, *blockNode, *commitNode, *termNode; in rf_CreateRaidCDegradedReadDAG() local
602 commitNode = &nodes[i]; in rf_CreateRaidCDegradedReadDAG()
619 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CreateRaidCDegradedReadDAG()
675 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CreateRaidCDegradedReadDAG()
676 rdNode->succedents[0] = commitNode; in rf_CreateRaidCDegradedReadDAG()
677 commitNode->antecedents[0] = rdNode; in rf_CreateRaidCDegradedReadDAG()
678 commitNode->antType[0] = rf_control; in rf_CreateRaidCDegradedReadDAG()
681 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateRaidCDegradedReadDAG()
684 commitNode->succedents[0] = termNode; in rf_CreateRaidCDegradedReadDAG()
685 termNode->antecedents[0] = commitNode; in rf_CreateRaidCDegradedReadDAG()