Lines Matching refs:commitNode
132 RF_DagNode_t *diskNodes, *blockNode, *commitNode, *termNode; in rf_CreateNonredundantDAG() local
198 commitNode = rf_AllocDAGNode(raidPtr); in rf_CreateNonredundantDAG()
199 commitNode->list_next = dag_h->nodes; in rf_CreateNonredundantDAG()
200 dag_h->nodes = commitNode; in rf_CreateNonredundantDAG()
211 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc, in rf_CreateNonredundantDAG()
219 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, rf_NullNodeUndoFunc, in rf_CreateNonredundantDAG()
253 RF_ASSERT(commitNode->numAntecedents == n); in rf_CreateNonredundantDAG()
264 tmpdiskNode->succedents[0] = commitNode; in rf_CreateNonredundantDAG()
265 commitNode->antecedents[i] = tmpdiskNode; in rf_CreateNonredundantDAG()
266 commitNode->antType[i] = rf_control; in rf_CreateNonredundantDAG()
270 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateNonredundantDAG()
273 commitNode->succedents[0] = termNode; in rf_CreateNonredundantDAG()
274 termNode->antecedents[0] = commitNode; in rf_CreateNonredundantDAG()
280 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CreateNonredundantDAG()
281 blockNode->succedents[0] = commitNode; in rf_CreateNonredundantDAG()
282 commitNode->antecedents[0] = blockNode; in rf_CreateNonredundantDAG()
283 commitNode->antType[0] = rf_control; in rf_CreateNonredundantDAG()
285 RF_ASSERT(commitNode->numSuccedents == n); in rf_CreateNonredundantDAG()
292 commitNode->succedents[i] = tmpdiskNode; in rf_CreateNonredundantDAG()
293 tmpdiskNode->antecedents[0] = commitNode; in rf_CreateNonredundantDAG()
328 RF_DagNode_t *readNodes, *blockNode, *commitNode, *termNode; in CreateMirrorReadDAG() local
369 commitNode = rf_AllocDAGNode(raidPtr); in CreateMirrorReadDAG()
370 commitNode->list_next = dag_h->nodes; in CreateMirrorReadDAG()
371 dag_h->nodes = commitNode; in CreateMirrorReadDAG()
380 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in CreateMirrorReadDAG()
423 RF_ASSERT(commitNode->numAntecedents == n); in CreateMirrorReadDAG()
427 tmpreadNode->succedents[0] = commitNode; in CreateMirrorReadDAG()
428 commitNode->antecedents[i] = tmpreadNode; in CreateMirrorReadDAG()
429 commitNode->antType[i] = rf_control; in CreateMirrorReadDAG()
434 RF_ASSERT(commitNode->numSuccedents == 1); in CreateMirrorReadDAG()
437 commitNode->succedents[0] = termNode; in CreateMirrorReadDAG()
438 termNode->antecedents[0] = commitNode; in CreateMirrorReadDAG()