Lines Matching refs:commitNode
121 RF_DagNode_t *rdNode, *blockNode, *commitNode, *termNode; in rf_CreateRaidOneDegradedReadDAG() local
152 commitNode = rf_AllocDAGNode(raidPtr); in rf_CreateRaidOneDegradedReadDAG()
153 commitNode->list_next = dag_h->nodes; in rf_CreateRaidOneDegradedReadDAG()
154 dag_h->nodes = commitNode; in rf_CreateRaidOneDegradedReadDAG()
170 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc, in rf_CreateRaidOneDegradedReadDAG()
215 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CreateRaidOneDegradedReadDAG()
216 rdNode->succedents[0] = commitNode; in rf_CreateRaidOneDegradedReadDAG()
217 commitNode->antecedents[0] = rdNode; in rf_CreateRaidOneDegradedReadDAG()
218 commitNode->antType[0] = rf_control; in rf_CreateRaidOneDegradedReadDAG()
221 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateRaidOneDegradedReadDAG()
224 commitNode->succedents[0] = termNode; in rf_CreateRaidOneDegradedReadDAG()
225 termNode->antecedents[0] = commitNode; in rf_CreateRaidOneDegradedReadDAG()
269 RF_DagNode_t *commitNode, *rpNode, *termNode; in rf_CreateDegradedReadDAG() local
322 commitNode = rf_AllocDAGNode(raidPtr); in rf_CreateDegradedReadDAG()
323 commitNode->list_next = dag_h->nodes; in rf_CreateDegradedReadDAG()
324 dag_h->nodes = commitNode; in rf_CreateDegradedReadDAG()
361 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc, in rf_CreateDegradedReadDAG()
543 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CreateDegradedReadDAG()
544 xorNode->succedents[0] = commitNode; in rf_CreateDegradedReadDAG()
545 commitNode->antecedents[0] = xorNode; in rf_CreateDegradedReadDAG()
546 commitNode->antType[0] = rf_control; in rf_CreateDegradedReadDAG()
549 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateDegradedReadDAG()
552 commitNode->succedents[0] = termNode; in rf_CreateDegradedReadDAG()
554 termNode->antecedents[0] = commitNode; in rf_CreateDegradedReadDAG()
580 RF_DagNode_t *nodes, *rdNode, *blockNode, *commitNode, *termNode; in rf_CreateRaidCDegradedReadDAG() local
614 commitNode = &nodes[i]; in rf_CreateRaidCDegradedReadDAG()
631 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc, in rf_CreateRaidCDegradedReadDAG()
682 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CreateRaidCDegradedReadDAG()
683 rdNode->succedents[0] = commitNode; in rf_CreateRaidCDegradedReadDAG()
684 commitNode->antecedents[0] = rdNode; in rf_CreateRaidCDegradedReadDAG()
685 commitNode->antType[0] = rf_control; in rf_CreateRaidCDegradedReadDAG()
688 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateRaidCDegradedReadDAG()
691 commitNode->succedents[0] = termNode; in rf_CreateRaidCDegradedReadDAG()
692 termNode->antecedents[0] = commitNode; in rf_CreateRaidCDegradedReadDAG()