Lines Matching refs:commitNode
146 RF_DagNode_t *nodes, *diskNodes, *blockNode, *commitNode, *termNode; in rf_CreateNonredundantDAG() local
199 commitNode = &nodes[i]; in rf_CreateNonredundantDAG()
211 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CreateNonredundantDAG()
222 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CreateNonredundantDAG()
257 RF_ASSERT(commitNode->numAntecedents == n); in rf_CreateNonredundantDAG()
267 diskNodes[i].succedents[0] = commitNode; in rf_CreateNonredundantDAG()
268 commitNode->antecedents[i] = &diskNodes[i]; in rf_CreateNonredundantDAG()
269 commitNode->antType[i] = rf_control; in rf_CreateNonredundantDAG()
272 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateNonredundantDAG()
275 commitNode->succedents[0] = termNode; in rf_CreateNonredundantDAG()
276 termNode->antecedents[0] = commitNode; in rf_CreateNonredundantDAG()
282 RF_ASSERT(commitNode->numAntecedents == 1); in rf_CreateNonredundantDAG()
283 blockNode->succedents[0] = commitNode; in rf_CreateNonredundantDAG()
284 commitNode->antecedents[0] = blockNode; in rf_CreateNonredundantDAG()
285 commitNode->antType[0] = rf_control; in rf_CreateNonredundantDAG()
287 RF_ASSERT(commitNode->numSuccedents == n); in rf_CreateNonredundantDAG()
293 commitNode->succedents[i] = &diskNodes[i]; in rf_CreateNonredundantDAG()
294 diskNodes[i].antecedents[0] = commitNode; in rf_CreateNonredundantDAG()
333 RF_DagNode_t *readNodes, *nodes, *blockNode, *commitNode, *termNode; in rf_CreateMirrorReadDAG() local
367 commitNode = &nodes[i]; in rf_CreateMirrorReadDAG()
376 rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, in rf_CreateMirrorReadDAG()
416 RF_ASSERT(commitNode->numAntecedents == n); in rf_CreateMirrorReadDAG()
419 readNodes[i].succedents[0] = commitNode; in rf_CreateMirrorReadDAG()
420 commitNode->antecedents[i] = &readNodes[i]; in rf_CreateMirrorReadDAG()
421 commitNode->antType[i] = rf_control; in rf_CreateMirrorReadDAG()
425 RF_ASSERT(commitNode->numSuccedents == 1); in rf_CreateMirrorReadDAG()
428 commitNode->succedents[0] = termNode; in rf_CreateMirrorReadDAG()
429 termNode->antecedents[0] = commitNode; in rf_CreateMirrorReadDAG()