Lines Matching refs:numDataNodes
480 int numDataNodes, numParityNodes; in rf_CommonCreateSmallWriteDAG() local
492 numDataNodes = asmap->numStripeUnitsAccessed; in rf_CommonCreateSmallWriteDAG()
498 RF_ASSERT(numDataNodes > 0); in rf_CommonCreateSmallWriteDAG()
524 totalNumNodes = (2 * numDataNodes) + (nfaults * numParityNodes) in rf_CommonCreateSmallWriteDAG()
527 totalNumNodes += (numDataNodes + (nfaults * numParityNodes)); in rf_CommonCreateSmallWriteDAG()
540 i += numDataNodes; in rf_CommonCreateSmallWriteDAG()
544 i += numDataNodes; in rf_CommonCreateSmallWriteDAG()
553 i += numDataNodes; in rf_CommonCreateSmallWriteDAG()
581 nNodes = numDataNodes + (nfaults * numParityNodes); in rf_CommonCreateSmallWriteDAG()
597 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
665 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
705 if ((numParityNodes == 2) || ((numDataNodes == 1) && in rf_CommonCreateSmallWriteDAG()
739 undoFunc, NULL, 1, (numDataNodes + numParityNodes), in rf_CommonCreateSmallWriteDAG()
755 (numDataNodes + numParityNodes), 7, 1, in rf_CommonCreateSmallWriteDAG()
776 NULL, 1, (numDataNodes + numParityNodes), in rf_CommonCreateSmallWriteDAG()
777 (2 * (numDataNodes + numDataNodes + 1) + 1), 1, in rf_CommonCreateSmallWriteDAG()
780 for (i = 0; i < numDataNodes + 1; i++) { in rf_CommonCreateSmallWriteDAG()
787 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
789 xorNodes[0].params[2 * (numDataNodes + 1 + i) + 0] = in rf_CommonCreateSmallWriteDAG()
791 xorNodes[0].params[2 * (numDataNodes + 1 + i) + 1] = in rf_CommonCreateSmallWriteDAG()
795 xorNodes[0].params[2 * (numDataNodes + numDataNodes + 1)].p = in rf_CommonCreateSmallWriteDAG()
800 undoFunc, NULL, 1, (numDataNodes + numParityNodes), in rf_CommonCreateSmallWriteDAG()
801 (2 * (numDataNodes + numDataNodes + 1) + 1), 1, in rf_CommonCreateSmallWriteDAG()
803 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
811 qNodes[0].params[2 * numDataNodes + 0] = in rf_CommonCreateSmallWriteDAG()
813 qNodes[0].params[2 * numDataNodes + 1] = in rf_CommonCreateSmallWriteDAG()
815 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
818 [2 * (numDataNodes + 1 + i) + 0] = in rf_CommonCreateSmallWriteDAG()
822 [2 * (numDataNodes + 1 + i) + 1] = in rf_CommonCreateSmallWriteDAG()
828 [2 * (numDataNodes + numDataNodes + 1)].p = raidPtr; in rf_CommonCreateSmallWriteDAG()
905 (numDataNodes + (numParityNodes * nfaults))); in rf_CommonCreateSmallWriteDAG()
906 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
915 blockNode->succedents[numDataNodes + i] = &readParityNodes[i]; in rf_CommonCreateSmallWriteDAG()
924 blockNode->succedents[numDataNodes + numParityNodes + i] in rf_CommonCreateSmallWriteDAG()
932 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
937 numDataNodes + numParityNodes); in rf_CommonCreateSmallWriteDAG()
946 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
949 numDataNodes + numParityNodes); in rf_CommonCreateSmallWriteDAG()
962 xorNodes[j].antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAG()
964 xorNodes[j].antType[numDataNodes + i] = rf_trueData; in rf_CommonCreateSmallWriteDAG()
975 qNodes[j].antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAG()
977 qNodes[j].antType[numDataNodes + i] = in rf_CommonCreateSmallWriteDAG()
1003 (numDataNodes + (nfaults * numParityNodes))); in rf_CommonCreateSmallWriteDAG()
1004 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
1012 commitNode->succedents[i + numDataNodes] = &writeParityNodes[i]; in rf_CommonCreateSmallWriteDAG()
1020 [i + numDataNodes + numParityNodes] = in rf_CommonCreateSmallWriteDAG()
1027 (numDataNodes + (nfaults * numParityNodes))); in rf_CommonCreateSmallWriteDAG()
1029 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAG()
1047 (numDataNodes + (nfaults * numParityNodes))); in rf_CommonCreateSmallWriteDAG()
1068 termNode->antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAG()
1070 termNode->antType[numDataNodes + i] = rf_control; in rf_CommonCreateSmallWriteDAG()
1074 termNode->antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAG()
1076 termNode->antType[numDataNodes + i] = rf_control; in rf_CommonCreateSmallWriteDAG()
1095 [numDataNodes + numParityNodes + i] = in rf_CommonCreateSmallWriteDAG()
1098 [numDataNodes + numParityNodes + i] = in rf_CommonCreateSmallWriteDAG()
1104 [numDataNodes + numParityNodes + i] = in rf_CommonCreateSmallWriteDAG()
1107 [numDataNodes + numParityNodes + i] = in rf_CommonCreateSmallWriteDAG()
1611 int numDataNodes, numParityNodes; in rf_CommonCreateSmallWriteDAGFwd() local
1623 numDataNodes = asmap->numStripeUnitsAccessed; in rf_CommonCreateSmallWriteDAGFwd()
1628 RF_ASSERT(numDataNodes > 0); in rf_CommonCreateSmallWriteDAGFwd()
1654 totalNumNodes = (2 * numDataNodes) + (nfaults * numParityNodes) in rf_CommonCreateSmallWriteDAGFwd()
1657 totalNumNodes += (numDataNodes + (nfaults * numParityNodes)); in rf_CommonCreateSmallWriteDAGFwd()
1667 i += numDataNodes; in rf_CommonCreateSmallWriteDAGFwd()
1671 i += numDataNodes; in rf_CommonCreateSmallWriteDAGFwd()
1680 i += numDataNodes; in rf_CommonCreateSmallWriteDAGFwd()
1706 nNodes = numDataNodes + (nfaults * numParityNodes); in rf_CommonCreateSmallWriteDAGFwd()
1717 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1782 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1822 if ((numParityNodes == 2) || ((numDataNodes == 1) && in rf_CommonCreateSmallWriteDAGFwd()
1850 numDataNodes, 7, 1, dag_h, name, allocList); in rf_CommonCreateSmallWriteDAGFwd()
1865 numParityNodes + numDataNodes, 7, 1, in rf_CommonCreateSmallWriteDAGFwd()
1886 NULL, numParityNodes, numParityNodes + numDataNodes, in rf_CommonCreateSmallWriteDAGFwd()
1887 (2 * (numDataNodes + numDataNodes + 1) + 1), 1, dag_h, in rf_CommonCreateSmallWriteDAGFwd()
1890 for (i = 0; i < numDataNodes + 1; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1897 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1899 xorNodes[0].params[2 * (numDataNodes + 1 + i) + 0] = in rf_CommonCreateSmallWriteDAGFwd()
1901 xorNodes[0].params[2 * (numDataNodes + 1 + i) + 1] = in rf_CommonCreateSmallWriteDAGFwd()
1904 xorNodes[0].params[2 * (numDataNodes + numDataNodes + 1)].p = in rf_CommonCreateSmallWriteDAGFwd()
1910 numParityNodes + numDataNodes, in rf_CommonCreateSmallWriteDAGFwd()
1911 (2 * (numDataNodes + numDataNodes + 1) + 1), in rf_CommonCreateSmallWriteDAGFwd()
1913 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1923 qNodes[0].params[2 * numDataNodes + 0] = in rf_CommonCreateSmallWriteDAGFwd()
1925 qNodes[0].params[2 * numDataNodes + 1] = in rf_CommonCreateSmallWriteDAGFwd()
1927 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
1931 [2 * (numDataNodes + 1 + i) + 0] = in rf_CommonCreateSmallWriteDAGFwd()
1935 [2 * (numDataNodes + 1 + i) + 1] = in rf_CommonCreateSmallWriteDAGFwd()
1940 [2 * (numDataNodes + numDataNodes + 1)].p = in rf_CommonCreateSmallWriteDAGFwd()
2018 (numDataNodes + (numParityNodes * nfaults))); in rf_CommonCreateSmallWriteDAGFwd()
2019 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2028 blockNode->succedents[numDataNodes + i] = &readParityNodes[i]; in rf_CommonCreateSmallWriteDAGFwd()
2037 blockNode->succedents[numDataNodes + in rf_CommonCreateSmallWriteDAGFwd()
2045 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2055 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2058 numDataNodes + numParityNodes); in rf_CommonCreateSmallWriteDAGFwd()
2067 for (i = 0; i < numDataNodes; i++) in rf_CommonCreateSmallWriteDAGFwd()
2070 numDataNodes + numParityNodes); in rf_CommonCreateSmallWriteDAGFwd()
2083 xorNodes[j].antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAGFwd()
2085 xorNodes[j].antType[numDataNodes + i] = rf_trueData; in rf_CommonCreateSmallWriteDAGFwd()
2096 qNodes[j].antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAGFwd()
2098 qNodes[j].antType[numDataNodes + i] = in rf_CommonCreateSmallWriteDAGFwd()
2128 (numDataNodes + (nfaults * numParityNodes))); in rf_CommonCreateSmallWriteDAGFwd()
2130 for (i = 0; i < numDataNodes; i++) { in rf_CommonCreateSmallWriteDAGFwd()
2148 (numDataNodes + (nfaults * numParityNodes))); in rf_CommonCreateSmallWriteDAGFwd()
2169 termNode->antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAGFwd()
2171 termNode->antType[numDataNodes + i] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2175 termNode->antecedents[numDataNodes + i] = in rf_CommonCreateSmallWriteDAGFwd()
2177 termNode->antType[numDataNodes + i] = rf_control; in rf_CommonCreateSmallWriteDAGFwd()
2195 termNode->antecedents[numDataNodes + in rf_CommonCreateSmallWriteDAGFwd()
2197 termNode->antType[numDataNodes + in rf_CommonCreateSmallWriteDAGFwd()
2202 termNode->antecedents[numDataNodes + in rf_CommonCreateSmallWriteDAGFwd()
2204 termNode->antType[numDataNodes + in rf_CommonCreateSmallWriteDAGFwd()