Lines Matching defs:termNode
172 RF_DagNode_t *blockNode, *commitNode, *termNode;
226 termNode = rf_AllocDAGNode(raidPtr);
227 termNode->list_next = dag_h->nodes;
228 dag_h->nodes = termNode;
265 rf_InitNode(termNode, rf_wait, RF_FALSE, rf_TerminateFunc,
465 RF_ASSERT(termNode->numAntecedents == nWndNodes + nfaults);
466 RF_ASSERT(termNode->numSuccedents == 0);
470 tmpNode->succedents[0] = termNode;
471 termNode->antecedents[i] = tmpNode;
472 termNode->antType[i] = rf_control;
476 wnpNode->succedents[0] = termNode;
477 termNode->antecedents[nWndNodes] = wnpNode;
478 termNode->antType[nWndNodes] = rf_control;
482 wnqNode->succedents[0] = termNode;
483 termNode->antecedents[nWndNodes + 1] = wnqNode;
484 termNode->antType[nWndNodes + 1] = rf_control;
529 RF_DagNode_t *readDataNodes, *readParityNodes, *termNode;
637 termNode = rf_AllocDAGNode(raidPtr);
638 termNode->list_next = dag_h->nodes;
639 dag_h->nodes = termNode;
683 rf_InitNode(termNode, rf_wait, RF_FALSE, rf_TerminateFunc,
1144 RF_ASSERT(termNode->numAntecedents == (numDataNodes + (nfaults * numParityNodes)));
1145 RF_ASSERT(termNode->numSuccedents == 0);
1150 RF_ASSERT(termNode->numAntecedents == (numDataNodes + (nfaults * numParityNodes)));
1151 tmpwriteDataNode->succedents[0] = termNode;
1152 termNode->antecedents[i] = tmpwriteDataNode;
1153 termNode->antType[i] = rf_control;
1160 tmpwriteParityNode->succedents[0] = termNode;
1161 termNode->antecedents[numDataNodes + i] = tmpwriteParityNode;
1162 termNode->antType[numDataNodes + i] = rf_control;
1171 tmpwriteQNode->succedents[0] = termNode;
1172 termNode->antecedents[numDataNodes + numParityNodes + i] = tmpwriteQNode;
1173 termNode->antType[numDataNodes + numParityNodes + i] = rf_control;
1203 RF_DagNode_t *unblockNode, *termNode, *commitNode;
1254 termNode = rf_AllocDAGNode(raidPtr);
1255 termNode->list_next = dag_h->nodes;
1256 dag_h->nodes = termNode;
1270 rf_InitNode(termNode, rf_wait, RF_FALSE, rf_TerminateFunc,
1360 RF_ASSERT(termNode->numAntecedents == 1);
1361 RF_ASSERT(termNode->numSuccedents == 0);
1362 unblockNode->succedents[0] = termNode;
1363 termNode->antecedents[0] = unblockNode;
1364 termNode->antType[0] = rf_control;