commitNode 141 dev/raidframe/rf_dag.h int commitNode; /* commitNode 122 dev/raidframe/rf_dagdegrd.c RF_DagNode_t *nodes, *rdNode, *blockNode, *commitNode, *termNode; commitNode 149 dev/raidframe/rf_dagdegrd.c commitNode = &nodes[i]; commitNode 166 dev/raidframe/rf_dagdegrd.c rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, commitNode 213 dev/raidframe/rf_dagdegrd.c RF_ASSERT(commitNode->numAntecedents == 1); commitNode 214 dev/raidframe/rf_dagdegrd.c rdNode->succedents[0] = commitNode; commitNode 215 dev/raidframe/rf_dagdegrd.c commitNode->antecedents[0] = rdNode; commitNode 216 dev/raidframe/rf_dagdegrd.c commitNode->antType[0] = rf_control; commitNode 219 dev/raidframe/rf_dagdegrd.c RF_ASSERT(commitNode->numSuccedents == 1); commitNode 222 dev/raidframe/rf_dagdegrd.c commitNode->succedents[0] = termNode; commitNode 223 dev/raidframe/rf_dagdegrd.c termNode->antecedents[0] = commitNode; commitNode 268 dev/raidframe/rf_dagdegrd.c RF_DagNode_t *commitNode, *rpNode, *termNode; commitNode 327 dev/raidframe/rf_dagdegrd.c commitNode = &nodes[i]; commitNode 353 dev/raidframe/rf_dagdegrd.c rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, commitNode 528 dev/raidframe/rf_dagdegrd.c RF_ASSERT(commitNode->numAntecedents == 1); commitNode 529 dev/raidframe/rf_dagdegrd.c xorNode->succedents[0] = commitNode; commitNode 530 dev/raidframe/rf_dagdegrd.c commitNode->antecedents[0] = xorNode; commitNode 531 dev/raidframe/rf_dagdegrd.c commitNode->antType[0] = rf_control; commitNode 534 dev/raidframe/rf_dagdegrd.c RF_ASSERT(commitNode->numSuccedents == 1); commitNode 537 dev/raidframe/rf_dagdegrd.c commitNode->succedents[0] = termNode; commitNode 539 dev/raidframe/rf_dagdegrd.c termNode->antecedents[0] = commitNode; commitNode 569 dev/raidframe/rf_dagdegrd.c RF_DagNode_t *nodes, *rdNode, *blockNode, *commitNode, *termNode; commitNode 602 dev/raidframe/rf_dagdegrd.c commitNode = &nodes[i]; commitNode 619 dev/raidframe/rf_dagdegrd.c rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, commitNode 675 dev/raidframe/rf_dagdegrd.c RF_ASSERT(commitNode->numAntecedents == 1); commitNode 676 dev/raidframe/rf_dagdegrd.c rdNode->succedents[0] = commitNode; commitNode 677 dev/raidframe/rf_dagdegrd.c commitNode->antecedents[0] = rdNode; commitNode 678 dev/raidframe/rf_dagdegrd.c commitNode->antType[0] = rf_control; commitNode 681 dev/raidframe/rf_dagdegrd.c RF_ASSERT(commitNode->numSuccedents == 1); commitNode 684 dev/raidframe/rf_dagdegrd.c commitNode->succedents[0] = termNode; commitNode 685 dev/raidframe/rf_dagdegrd.c termNode->antecedents[0] = commitNode; commitNode 162 dev/raidframe/rf_dagdegwr.c RF_DagNode_t *nodes, *wndNodes, *rrdNodes, *xorNode, *commitNode; commitNode 238 dev/raidframe/rf_dagdegwr.c commitNode = &nodes[i]; commitNode 272 dev/raidframe/rf_dagdegwr.c rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, commitNode 494 dev/raidframe/rf_dagdegwr.c RF_ASSERT(commitNode->numAntecedents == 1); commitNode 495 dev/raidframe/rf_dagdegwr.c xorNode->succedents[0] = commitNode; commitNode 496 dev/raidframe/rf_dagdegwr.c commitNode->antecedents[0] = xorNode; commitNode 497 dev/raidframe/rf_dagdegwr.c commitNode->antType[0] = rf_control; commitNode 500 dev/raidframe/rf_dagdegwr.c RF_ASSERT(commitNode->numSuccedents == nfaults + nWndNodes); commitNode 503 dev/raidframe/rf_dagdegwr.c commitNode->succedents[i] = &wndNodes[i]; commitNode 504 dev/raidframe/rf_dagdegwr.c wndNodes[i].antecedents[0] = commitNode; commitNode 510 dev/raidframe/rf_dagdegwr.c commitNode->succedents[nWndNodes] = wnpNode; commitNode 511 dev/raidframe/rf_dagdegwr.c wnpNode->antecedents[0] = commitNode; commitNode 515 dev/raidframe/rf_dagdegwr.c commitNode->succedents[nWndNodes + 1] = wnqNode; commitNode 516 dev/raidframe/rf_dagdegwr.c wnqNode->antecedents[0] = commitNode; commitNode 146 dev/raidframe/rf_dagffrd.c RF_DagNode_t *nodes, *diskNodes, *blockNode, *commitNode, *termNode; commitNode 199 dev/raidframe/rf_dagffrd.c commitNode = &nodes[i]; commitNode 211 dev/raidframe/rf_dagffrd.c rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, commitNode 222 dev/raidframe/rf_dagffrd.c rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, commitNode 257 dev/raidframe/rf_dagffrd.c RF_ASSERT(commitNode->numAntecedents == n); commitNode 267 dev/raidframe/rf_dagffrd.c diskNodes[i].succedents[0] = commitNode; commitNode 268 dev/raidframe/rf_dagffrd.c commitNode->antecedents[i] = &diskNodes[i]; commitNode 269 dev/raidframe/rf_dagffrd.c commitNode->antType[i] = rf_control; commitNode 272 dev/raidframe/rf_dagffrd.c RF_ASSERT(commitNode->numSuccedents == 1); commitNode 275 dev/raidframe/rf_dagffrd.c commitNode->succedents[0] = termNode; commitNode 276 dev/raidframe/rf_dagffrd.c termNode->antecedents[0] = commitNode; commitNode 282 dev/raidframe/rf_dagffrd.c RF_ASSERT(commitNode->numAntecedents == 1); commitNode 283 dev/raidframe/rf_dagffrd.c blockNode->succedents[0] = commitNode; commitNode 284 dev/raidframe/rf_dagffrd.c commitNode->antecedents[0] = blockNode; commitNode 285 dev/raidframe/rf_dagffrd.c commitNode->antType[0] = rf_control; commitNode 287 dev/raidframe/rf_dagffrd.c RF_ASSERT(commitNode->numSuccedents == n); commitNode 293 dev/raidframe/rf_dagffrd.c commitNode->succedents[i] = &diskNodes[i]; commitNode 294 dev/raidframe/rf_dagffrd.c diskNodes[i].antecedents[0] = commitNode; commitNode 333 dev/raidframe/rf_dagffrd.c RF_DagNode_t *readNodes, *nodes, *blockNode, *commitNode, *termNode; commitNode 367 dev/raidframe/rf_dagffrd.c commitNode = &nodes[i]; commitNode 376 dev/raidframe/rf_dagffrd.c rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, commitNode 416 dev/raidframe/rf_dagffrd.c RF_ASSERT(commitNode->numAntecedents == n); commitNode 419 dev/raidframe/rf_dagffrd.c readNodes[i].succedents[0] = commitNode; commitNode 420 dev/raidframe/rf_dagffrd.c commitNode->antecedents[i] = &readNodes[i]; commitNode 421 dev/raidframe/rf_dagffrd.c commitNode->antType[i] = rf_control; commitNode 425 dev/raidframe/rf_dagffrd.c RF_ASSERT(commitNode->numSuccedents == 1); commitNode 428 dev/raidframe/rf_dagffrd.c commitNode->succedents[0] = termNode; commitNode 429 dev/raidframe/rf_dagffrd.c termNode->antecedents[0] = commitNode; commitNode 162 dev/raidframe/rf_dagffwr.c RF_DagNode_t *wnqNode, *blockNode, *commitNode, *termNode; commitNode 197 dev/raidframe/rf_dagffwr.c commitNode = &nodes[i]; commitNode 227 dev/raidframe/rf_dagffwr.c rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, commitNode 390 dev/raidframe/rf_dagffwr.c RF_ASSERT(commitNode->numAntecedents == 1); commitNode 391 dev/raidframe/rf_dagffwr.c xorNode->succedents[0] = commitNode; commitNode 392 dev/raidframe/rf_dagffwr.c commitNode->antecedents[0] = xorNode; commitNode 393 dev/raidframe/rf_dagffwr.c commitNode->antType[0] = rf_control; commitNode 396 dev/raidframe/rf_dagffwr.c RF_ASSERT(commitNode->numSuccedents == nWndNodes + nfaults); commitNode 399 dev/raidframe/rf_dagffwr.c commitNode->succedents[i] = &wndNodes[i]; commitNode 400 dev/raidframe/rf_dagffwr.c wndNodes[i].antecedents[0] = commitNode; commitNode 404 dev/raidframe/rf_dagffwr.c commitNode->succedents[nWndNodes] = wnpNode; commitNode 405 dev/raidframe/rf_dagffwr.c wnpNode->antecedents[0] = commitNode; commitNode 409 dev/raidframe/rf_dagffwr.c commitNode->succedents[nWndNodes + 1] = wnqNode; commitNode 410 dev/raidframe/rf_dagffwr.c wnqNode->antecedents[0] = commitNode; commitNode 473 dev/raidframe/rf_dagffwr.c RF_DagNode_t *xorNodes, *qNodes, *blockNode, *commitNode, *nodes; commitNode 537 dev/raidframe/rf_dagffwr.c commitNode = &nodes[i]; commitNode 587 dev/raidframe/rf_dagffwr.c rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, commitNode 983 dev/raidframe/rf_dagffwr.c RF_ASSERT(commitNode->numAntecedents == (nfaults * numParityNodes)); commitNode 986 dev/raidframe/rf_dagffwr.c xorNodes[i].succedents[0] = commitNode; commitNode 987 dev/raidframe/rf_dagffwr.c commitNode->antecedents[i] = &xorNodes[i]; commitNode 988 dev/raidframe/rf_dagffwr.c commitNode->antType[i] = rf_control; commitNode 995 dev/raidframe/rf_dagffwr.c qNodes[i].succedents[0] = commitNode; commitNode 996 dev/raidframe/rf_dagffwr.c commitNode->antecedents[i + numParityNodes] = commitNode 998 dev/raidframe/rf_dagffwr.c commitNode->antType[i + numParityNodes] = rf_control; commitNode 1002 dev/raidframe/rf_dagffwr.c RF_ASSERT(commitNode->numSuccedents == commitNode 1006 dev/raidframe/rf_dagffwr.c commitNode->succedents[i] = &writeDataNodes[i]; commitNode 1007 dev/raidframe/rf_dagffwr.c writeDataNodes[i].antecedents[0] = commitNode; commitNode 1012 dev/raidframe/rf_dagffwr.c commitNode->succedents[i + numDataNodes] = &writeParityNodes[i]; commitNode 1013 dev/raidframe/rf_dagffwr.c writeParityNodes[i].antecedents[0] = commitNode; commitNode 1019 dev/raidframe/rf_dagffwr.c commitNode->succedents commitNode 1022 dev/raidframe/rf_dagffwr.c writeQNodes[i].antecedents[0] = commitNode; commitNode 1136 dev/raidframe/rf_dagffwr.c RF_DagNode_t *unblockNode, *termNode, *commitNode; commitNode 1171 dev/raidframe/rf_dagffwr.c commitNode = &nodes[i]; commitNode 1185 dev/raidframe/rf_dagffwr.c rf_InitNode(commitNode, rf_wait, RF_TRUE, rf_NullNodeFunc, commitNode 1237 dev/raidframe/rf_dagffwr.c RF_ASSERT(commitNode->numAntecedents == 0); commitNode 1238 dev/raidframe/rf_dagffwr.c dag_h->succedents[0] = commitNode; commitNode 1241 dev/raidframe/rf_dagffwr.c RF_ASSERT(commitNode->numSuccedents == (nWndNodes + nWmirNodes)); commitNode 1244 dev/raidframe/rf_dagffwr.c commitNode->succedents[i] = &wndNode[i]; commitNode 1245 dev/raidframe/rf_dagffwr.c wndNode[i].antecedents[0] = commitNode; commitNode 1250 dev/raidframe/rf_dagffwr.c commitNode->succedents[i + nWndNodes] = &wmirNode[i]; commitNode 1251 dev/raidframe/rf_dagffwr.c wmirNode[i].antecedents[0] = commitNode; commitNode 96 dev/raidframe/rf_dagutils.c node->commitNode = commit; commitNode 366 dev/raidframe/rf_dagutils.c node->nodeNum, node->commitNode, node->name, commitNode 691 dev/raidframe/rf_dagutils.c if (nodes[i]->commitNode) commitNode 378 dev/raidframe/rf_engine.c if (node->commitNode) commitNode 387 dev/raidframe/rf_engine.c RF_ASSERT(node->commitNode == RF_FALSE); commitNode 424 dev/raidframe/rf_engine.c if (node->commitNode) commitNode 435 dev/raidframe/rf_engine.c RF_ASSERT(node->commitNode == RF_FALSE); commitNode 586 dev/raidframe/rf_engine.c if (skiplist->commitNode) { commitNode 598 dev/raidframe/rf_engine.c if (finishlist->commitNode)