Home | History | Annotate | Download | only in raidframe

Lines Matching defs:numDataNodes

543 	int     numDataNodes, numParityNodes;
554 	numDataNodes = asmap->numStripeUnitsAccessed;
562 	RF_ASSERT(numDataNodes > 0);
586 	 * totalNumNodes = (2 * numDataNodes) + (nfaults * numParityNodes)
602 	for (i = 0; i < numDataNodes; i++) {
616 	for (i = 0; i < numDataNodes; i++) {
672 	nNodes = numDataNodes + (nfaults * numParityNodes);
689 	for (i = 0; i < numDataNodes; i++) {
761 	for (i = 0; i < numDataNodes; i++) {
789 	if ((numParityNodes == 2) || ((numDataNodes == 1)
832 				    (numDataNodes + numParityNodes),
849 					    (numDataNodes + numParityNodes),
872 			    undoFunc, NULL, 1, (numDataNodes + numParityNodes),
873 			    (2 * (numDataNodes + numDataNodes + 1) + 1), 1,
877 		for (i = 0; i < numDataNodes; i++) { /* used to be"numDataNodes + 1" until we factored
885 		xorNodes->params[2 * numDataNodes + 0] = readParityNodes->params[0];    /* pda */
886 		xorNodes->params[2 * numDataNodes + 1] = readParityNodes->params[1];    /* buffer ptr */
889 		for (i = 0; i < numDataNodes; i++) {
891 			xorNodes->params[2 * (numDataNodes + 1 + i) + 0] =	/* pda */
893 			xorNodes->params[2 * (numDataNodes + 1 + i) + 1] =	/* buffer ptr */
898 		xorNodes->params[2 * (numDataNodes + numDataNodes + 1)].p = raidPtr;
904 				    (numDataNodes + numParityNodes),
905 				    (2 * (numDataNodes + numDataNodes + 1) + 1), 1,
908 			for (i = 0; i < numDataNodes; i++) {
915 			qNodes->params[2 * numDataNodes + 0] =	/* pda */
917 			qNodes->params[2 * numDataNodes + 1] =	/* buffer ptr */
920 			for (i = 0; i < numDataNodes; i++) {
922 				qNodes->params[2 * (numDataNodes + 1 + i) + 0] =	/* pda */
924 				qNodes->params[2 * (numDataNodes + 1 + i) + 1] =	/* buffer ptr */
929 			qNodes->params[2 * (numDataNodes + numDataNodes + 1)].p = raidPtr;
992 	RF_ASSERT(blockNode->numSuccedents == (numDataNodes + (numParityNodes * nfaults)));
994 	for (i = 0; i < numDataNodes; i++) {
1005 		blockNode->succedents[numDataNodes + i] = tmpreadParityNode;
1017 			blockNode->succedents[numDataNodes + numParityNodes + i] = tmpreadQNode;
1027 	for (i = 0; i < numDataNodes; i++) {
1031 			RF_ASSERT(tmpxorNode->numAntecedents == numDataNodes + numParityNodes);
1044 		for (i = 0; i < numDataNodes; i++) {
1047 				RF_ASSERT(tmpqNode->numAntecedents == numDataNodes + numParityNodes);
1064 			tmpxorNode->antecedents[numDataNodes + i] = tmpreadParityNode;
1065 			tmpxorNode->antType[numDataNodes + i] = rf_trueData;
1081 				tmpqNode->antecedents[numDataNodes + i] = tmpreadQNode;
1082 				tmpqNode->antType[numDataNodes + i] = rf_trueData;
1115 	RF_ASSERT(commitNode->numSuccedents == (numDataNodes + (nfaults * numParityNodes)));
1117 	for (i = 0; i < numDataNodes; i++) {
1127 		commitNode->succedents[i + numDataNodes] = tmpwriteParityNode;
1137 			commitNode->succedents[i + numDataNodes + numParityNodes] = tmpwriteQNode;
1144 	RF_ASSERT(termNode->numAntecedents == (numDataNodes + (nfaults * numParityNodes)));
1147 	for (i = 0; i < numDataNodes; i++) {
1150 		RF_ASSERT(termNode->numAntecedents == (numDataNodes + (nfaults * numParityNodes)));
1161 		termNode->antecedents[numDataNodes + i] = tmpwriteParityNode;
1162 		termNode->antType[numDataNodes + i] = rf_control;
1172 			termNode->antecedents[numDataNodes + numParityNodes + i] = tmpwriteQNode;
1173 			termNode->antType[numDataNodes + numParityNodes + i] = rf_control;