Home | History | Annotate | Download | only in raidframe

Lines Matching defs:numDataNodes

336 	int     numDataNodes = asmap->numStripeUnitsAccessed;
347 	RF_ASSERT(numDataNodes > 0);
361 	totalNumNodes = (2 * numDataNodes) + numParityNodes + (2 * numParityNodes) + 3;
363 	nNodes = numDataNodes + numParityNodes;
365 	dag_h->numCommitNodes = numDataNodes + numParityNodes;
377 	i += numDataNodes;
381 	i += numDataNodes;
402 	for (i = 0; i < numDataNodes; i++) {
431 	for (i = 0; i < numDataNodes; i++) {
453 	if ((numParityNodes == 2) || ((numDataNodes == 1) && (asmap->totalSectorsAccessed < raidPtr->Layout.sectorsPerStripeUnit))) {
481 		rf_InitNode(&xorNodes[0], rf_wait, RF_TRUE, func, undoFunc, NULL, 1, nNodes, (2 * (numDataNodes + numDataNodes + 1) + 1), 1, dag_h, name, allocList);
483 		for (i = 0; i < numDataNodes + 1; i++) {
488 		for (i = 0; i < numDataNodes; i++) {
490 			xorNodes[0].params[2 * (numDataNodes + 1 + i) + 0] = writeDataNodes[i].params[0];	/* pda */
491 			xorNodes[0].params[2 * (numDataNodes + 1 + i) + 1] = writeDataNodes[i].params[1];	/* buffer pointer */
493 		xorNodes[0].params[2 * (numDataNodes + numDataNodes + 1)].p = raidPtr;	/* xor node needs to get
518 	RF_ASSERT(blockNode->numSuccedents == (numDataNodes + numParityNodes));
519 	for (i = 0; i < numDataNodes; i++) {
528 		blockNode->succedents[numDataNodes + i] = &readParityNodes[i];
535 	for (i = 0; i < numDataNodes; i++) {
536 		RF_ASSERT(readDataNodes[i].numSuccedents == numDataNodes + numParityNodes);
537 		for (j = 0; j < numDataNodes; j++) {
538 			RF_ASSERT(writeDataNodes[j].numAntecedents == numDataNodes + numParityNodes);
549 	for (i = 0; i < numDataNodes; i++)
551 			RF_ASSERT(xorNodes[j].numAntecedents == numDataNodes + numParityNodes);
552 			readDataNodes[i].succedents[numDataNodes + j] = &xorNodes[j];
559 		RF_ASSERT(readParityNodes[i].numSuccedents == numDataNodes + numParityNodes);
560 		for (j = 0; j < numDataNodes; j++) {
562 			writeDataNodes[j].antecedents[numDataNodes + i] = &readParityNodes[i];
563 			writeDataNodes[j].antType[numDataNodes + i] = rf_control;
570 			readParityNodes[i].succedents[numDataNodes + j] = &xorNodes[j];
571 			xorNodes[j].antecedents[numDataNodes + i] = &readParityNodes[i];
572 			xorNodes[j].antType[numDataNodes + i] = rf_trueData;
584 	for (i = 0; i < numDataNodes; i++) {
587 		RF_ASSERT(unblockNode->numAntecedents == (numDataNodes + (nfaults * numParityNodes)));
597 		unblockNode->antecedents[numDataNodes + i] = &lpuNodes[i];
598 		unblockNode->antType[numDataNodes + i] = rf_control;