Home | History | Annotate | Line # | Download | only in raidframe
rf_evenodd.c revision 1.24
      1  1.24    andvar /*	$NetBSD: rf_evenodd.c,v 1.24 2025/06/27 21:36:22 andvar Exp $	*/
      2   1.1     oster /*
      3   1.1     oster  * Copyright (c) 1995 Carnegie-Mellon University.
      4   1.1     oster  * All rights reserved.
      5   1.1     oster  *
      6   1.1     oster  * Author: Chang-Ming Wu
      7   1.1     oster  *
      8   1.1     oster  * Permission to use, copy, modify and distribute this software and
      9   1.1     oster  * its documentation is hereby granted, provided that both the copyright
     10   1.1     oster  * notice and this permission notice appear in all copies of the
     11   1.1     oster  * software, derivative works or modified versions, and any portions
     12   1.1     oster  * thereof, and that both notices appear in supporting documentation.
     13   1.1     oster  *
     14   1.1     oster  * CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS"
     15   1.1     oster  * CONDITION.  CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND
     16   1.1     oster  * FOR ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
     17   1.1     oster  *
     18   1.1     oster  * Carnegie Mellon requests users of this software to return to
     19   1.1     oster  *
     20   1.1     oster  *  Software Distribution Coordinator  or  Software.Distribution (at) CS.CMU.EDU
     21   1.1     oster  *  School of Computer Science
     22   1.1     oster  *  Carnegie Mellon University
     23   1.1     oster  *  Pittsburgh PA 15213-3890
     24   1.1     oster  *
     25   1.1     oster  * any improvements or extensions that they make and grant Carnegie the
     26   1.1     oster  * rights to redistribute these changes.
     27   1.1     oster  */
     28   1.1     oster 
     29   1.1     oster /*****************************************************************************************
     30   1.1     oster  *
     31   1.1     oster  * rf_evenodd.c -- implements EVENODD array architecture
     32   1.1     oster  *
     33   1.1     oster  ****************************************************************************************/
     34   1.7     lukem 
     35   1.7     lukem #include <sys/cdefs.h>
     36  1.24    andvar __KERNEL_RCSID(0, "$NetBSD: rf_evenodd.c,v 1.24 2025/06/27 21:36:22 andvar Exp $");
     37   1.1     oster 
     38   1.1     oster #include "rf_archs.h"
     39   1.1     oster 
     40   1.1     oster #if RF_INCLUDE_EVENODD > 0
     41   1.1     oster 
     42   1.6     oster #include <dev/raidframe/raidframevar.h>
     43   1.6     oster 
     44   1.1     oster #include "rf_raid.h"
     45   1.1     oster #include "rf_dag.h"
     46   1.1     oster #include "rf_dagffrd.h"
     47   1.1     oster #include "rf_dagffwr.h"
     48   1.1     oster #include "rf_dagdegrd.h"
     49   1.1     oster #include "rf_dagdegwr.h"
     50   1.1     oster #include "rf_dagutils.h"
     51   1.1     oster #include "rf_dagfuncs.h"
     52   1.1     oster #include "rf_etimer.h"
     53   1.1     oster #include "rf_general.h"
     54   1.1     oster #include "rf_evenodd.h"
     55   1.1     oster #include "rf_parityscan.h"
     56   1.1     oster #include "rf_utils.h"
     57   1.1     oster #include "rf_map.h"
     58   1.1     oster #include "rf_pq.h"
     59   1.1     oster #include "rf_mcpair.h"
     60   1.1     oster #include "rf_evenodd_dagfuncs.h"
     61   1.1     oster #include "rf_evenodd_dags.h"
     62   1.1     oster #include "rf_engine.h"
     63   1.1     oster 
     64   1.1     oster typedef struct RF_EvenOddConfigInfo_s {
     65   1.2     oster 	RF_RowCol_t **stripeIdentifier;	/* filled in at config time & used by
     66   1.2     oster 					 * IdentifyStripe */
     67   1.2     oster }       RF_EvenOddConfigInfo_t;
     68   1.2     oster 
     69  1.14     perry int
     70  1.18  christos rf_ConfigureEvenOdd(RF_ShutdownList_t **listp, RF_Raid_t *raidPtr,
     71  1.18  christos 		    RF_Config_t *cfgPtr)
     72   1.2     oster {
     73   1.2     oster 	RF_RaidLayout_t *layoutPtr = &raidPtr->Layout;
     74   1.2     oster 	RF_EvenOddConfigInfo_t *info;
     75   1.2     oster 	RF_RowCol_t i, j, startdisk;
     76   1.2     oster 
     77  1.22  christos 	info = RF_MallocAndAdd(sizeof(*info), raidPtr->cleanupList);
     78   1.2     oster 	layoutPtr->layoutSpecificInfo = (void *) info;
     79   1.2     oster 
     80   1.2     oster 	info->stripeIdentifier = rf_make_2d_array(raidPtr->numCol, raidPtr->numCol, raidPtr->cleanupList);
     81   1.2     oster 	startdisk = 0;
     82   1.2     oster 	for (i = 0; i < raidPtr->numCol; i++) {
     83   1.2     oster 		for (j = 0; j < raidPtr->numCol; j++) {
     84   1.2     oster 			info->stripeIdentifier[i][j] = (startdisk + j) % raidPtr->numCol;
     85   1.2     oster 		}
     86   1.2     oster 		if ((startdisk -= 2) < 0)
     87   1.2     oster 			startdisk += raidPtr->numCol;
     88   1.2     oster 	}
     89   1.1     oster 
     90   1.2     oster 	/* fill in the remaining layout parameters */
     91   1.2     oster 	layoutPtr->numStripe = layoutPtr->stripeUnitsPerDisk;
     92   1.2     oster 	layoutPtr->numDataCol = raidPtr->numCol - 2;	/* ORIG:
     93   1.2     oster 							 * layoutPtr->numDataCol
     94   1.2     oster 							 * = raidPtr->numCol-1;  */
     95   1.1     oster #if RF_EO_MATRIX_DIM > 17
     96   1.2     oster 	if (raidPtr->numCol <= 17) {
     97   1.2     oster 		printf("Number of stripe units in a parity stripe is smaller than 17. Please\n");
     98   1.2     oster 		printf("define the macro RF_EO_MATRIX_DIM in file rf_evenodd_dagfuncs.h to \n");
     99   1.2     oster 		printf("be 17 to increase performance. \n");
    100   1.2     oster 		return (EINVAL);
    101   1.2     oster 	}
    102   1.1     oster #elif RF_EO_MATRIX_DIM == 17
    103   1.2     oster 	if (raidPtr->numCol > 17) {
    104   1.2     oster 		printf("Number of stripe units in a parity stripe is bigger than 17. Please\n");
    105   1.2     oster 		printf("define the macro RF_EO_MATRIX_DIM in file rf_evenodd_dagfuncs.h to \n");
    106   1.2     oster 		printf("be 257 for encoding and decoding functions to work. \n");
    107   1.2     oster 		return (EINVAL);
    108   1.2     oster 	}
    109   1.1     oster #endif
    110   1.2     oster 	layoutPtr->dataSectorsPerStripe = layoutPtr->numDataCol * layoutPtr->sectorsPerStripeUnit;
    111   1.2     oster 	layoutPtr->numParityCol = 2;
    112   1.2     oster 	layoutPtr->dataStripeUnitsPerDisk = layoutPtr->stripeUnitsPerDisk;
    113   1.2     oster 	raidPtr->sectorsPerDisk = layoutPtr->stripeUnitsPerDisk * layoutPtr->sectorsPerStripeUnit;
    114   1.1     oster 
    115   1.2     oster 	raidPtr->totalSectors = layoutPtr->stripeUnitsPerDisk * layoutPtr->numDataCol * layoutPtr->sectorsPerStripeUnit;
    116   1.1     oster 
    117   1.2     oster 	return (0);
    118   1.1     oster }
    119   1.1     oster 
    120  1.14     perry int
    121  1.18  christos rf_GetDefaultNumFloatingReconBuffersEvenOdd(RF_Raid_t *raidPtr)
    122   1.1     oster {
    123   1.2     oster 	return (20);
    124   1.1     oster }
    125   1.1     oster 
    126  1.14     perry RF_HeadSepLimit_t
    127  1.18  christos rf_GetDefaultHeadSepLimitEvenOdd(RF_Raid_t *raidPtr)
    128   1.1     oster {
    129   1.2     oster 	return (10);
    130   1.1     oster }
    131   1.1     oster 
    132  1.14     perry void
    133  1.12     oster rf_IdentifyStripeEvenOdd(RF_Raid_t *raidPtr, RF_RaidAddr_t addr,
    134  1.16     oster 			 RF_RowCol_t **diskids)
    135   1.1     oster {
    136   1.2     oster 	RF_StripeNum_t stripeID = rf_RaidAddressToStripeID(&raidPtr->Layout, addr);
    137   1.2     oster 	RF_EvenOddConfigInfo_t *info = (RF_EvenOddConfigInfo_t *) raidPtr->Layout.layoutSpecificInfo;
    138   1.1     oster 
    139   1.2     oster 	*diskids = info->stripeIdentifier[stripeID % raidPtr->numCol];
    140   1.1     oster }
    141   1.2     oster /* The layout of stripe unit on the disks are:      c0 c1 c2 c3 c4
    142   1.1     oster 
    143   1.1     oster  						     0  1  2  E  P
    144   1.1     oster 						     5  E  P  3  4
    145   1.1     oster 						     P  6  7  8  E
    146   1.1     oster 	 					    10 11  E  P  9
    147   1.1     oster 						     E  P 12 13 14
    148   1.1     oster 						     ....
    149   1.1     oster 
    150   1.2     oster   We use the MapSectorRAID5 to map data information because the routine can be shown to map exactly
    151   1.1     oster   the layout of data stripe unit as shown above although we have 2 redundant information now.
    152   1.1     oster   But for E and P, we use rf_MapEEvenOdd and rf_MapParityEvenOdd which are different method from raid-5.
    153   1.1     oster */
    154   1.1     oster 
    155   1.1     oster 
    156  1.14     perry void
    157  1.12     oster rf_MapParityEvenOdd(RF_Raid_t *raidPtr, RF_RaidAddr_t raidSector,
    158  1.16     oster 		    RF_RowCol_t *col,
    159  1.18  christos 		    RF_SectorNum_t *diskSector, int remap)
    160   1.1     oster {
    161   1.2     oster 	RF_StripeNum_t SUID = raidSector / raidPtr->Layout.sectorsPerStripeUnit;
    162   1.2     oster 	RF_StripeNum_t endSUIDofthisStrip = (SUID / raidPtr->Layout.numDataCol + 1) * raidPtr->Layout.numDataCol - 1;
    163   1.1     oster 
    164   1.2     oster 	*col = (endSUIDofthisStrip + 2) % raidPtr->numCol;
    165   1.2     oster 	*diskSector = (SUID / (raidPtr->Layout.numDataCol)) * raidPtr->Layout.sectorsPerStripeUnit +
    166   1.2     oster 	    (raidSector % raidPtr->Layout.sectorsPerStripeUnit);
    167   1.1     oster }
    168   1.1     oster 
    169  1.14     perry void
    170  1.12     oster rf_MapEEvenOdd(RF_Raid_t *raidPtr, RF_RaidAddr_t raidSector,
    171  1.16     oster 	       RF_RowCol_t *col, RF_SectorNum_t *diskSector,
    172  1.18  christos 	       int remap)
    173   1.1     oster {
    174   1.2     oster 	RF_StripeNum_t SUID = raidSector / raidPtr->Layout.sectorsPerStripeUnit;
    175   1.2     oster 	RF_StripeNum_t endSUIDofthisStrip = (SUID / raidPtr->Layout.numDataCol + 1) * raidPtr->Layout.numDataCol - 1;
    176   1.1     oster 
    177   1.2     oster 	*col = (endSUIDofthisStrip + 1) % raidPtr->numCol;
    178   1.2     oster 	*diskSector = (SUID / (raidPtr->Layout.numDataCol)) * raidPtr->Layout.sectorsPerStripeUnit +
    179   1.2     oster 	    (raidSector % raidPtr->Layout.sectorsPerStripeUnit);
    180   1.1     oster }
    181   1.1     oster 
    182  1.14     perry void
    183  1.12     oster rf_EODagSelect(RF_Raid_t *raidPtr, RF_IoType_t type,
    184  1.12     oster 	       RF_AccessStripeMap_t *asmap, RF_VoidFuncPtr *createFunc)
    185   1.1     oster {
    186   1.2     oster 	RF_RaidLayout_t *layoutPtr = &(raidPtr->Layout);
    187   1.2     oster 	unsigned ndfail = asmap->numDataFailed;
    188   1.2     oster 	unsigned npfail = asmap->numParityFailed + asmap->numQFailed;
    189   1.2     oster 	unsigned ntfail = npfail + ndfail;
    190   1.2     oster 
    191   1.2     oster 	RF_ASSERT(RF_IO_IS_R_OR_W(type));
    192   1.2     oster 	if (ntfail > 2) {
    193   1.2     oster 		RF_ERRORMSG("more than two disks failed in a single group!  Aborting I/O operation.\n");
    194  1.10     oster 		*createFunc = NULL;
    195   1.2     oster 		return;
    196   1.2     oster 	}
    197   1.2     oster 	/* ok, we can do this I/O */
    198   1.2     oster 	if (type == RF_IO_TYPE_READ) {
    199   1.2     oster 		switch (ndfail) {
    200   1.2     oster 		case 0:
    201   1.2     oster 			/* fault free read */
    202   1.2     oster 			*createFunc = (RF_VoidFuncPtr) rf_CreateFaultFreeReadDAG;	/* same as raid 5 */
    203   1.2     oster 			break;
    204   1.2     oster 		case 1:
    205   1.2     oster 			/* lost a single data unit */
    206   1.2     oster 			/* two cases: (1) parity is not lost. do a normal raid
    207   1.2     oster 			 * 5 reconstruct read. (2) parity is lost. do a
    208   1.2     oster 			 * reconstruct read using "e". */
    209   1.2     oster 			if (ntfail == 2) {	/* also lost redundancy */
    210   1.2     oster 				if (asmap->failedPDAs[1]->type == RF_PDA_TYPE_PARITY)
    211   1.2     oster 					*createFunc = (RF_VoidFuncPtr) rf_EO_110_CreateReadDAG;
    212   1.2     oster 				else
    213   1.2     oster 					*createFunc = (RF_VoidFuncPtr) rf_EO_101_CreateReadDAG;
    214   1.2     oster 			} else {
    215   1.2     oster 				/* P and E are ok. But is there a failure in
    216   1.2     oster 				 * some unaccessed data unit? */
    217   1.2     oster 				if (rf_NumFailedDataUnitsInStripe(raidPtr, asmap) == 2)
    218   1.2     oster 					*createFunc = (RF_VoidFuncPtr) rf_EO_200_CreateReadDAG;
    219   1.2     oster 				else
    220   1.2     oster 					*createFunc = (RF_VoidFuncPtr) rf_EO_100_CreateReadDAG;
    221   1.2     oster 			}
    222   1.2     oster 			break;
    223   1.2     oster 		case 2:
    224   1.2     oster 			/* *createFunc = rf_EO_200_CreateReadDAG; */
    225   1.2     oster 			*createFunc = NULL;
    226   1.2     oster 			break;
    227   1.2     oster 		}
    228   1.2     oster 		return;
    229   1.2     oster 	}
    230   1.2     oster 	/* a write */
    231   1.2     oster 	switch (ntfail) {
    232   1.2     oster 	case 0:		/* fault free */
    233   1.2     oster 		if (rf_suppressLocksAndLargeWrites ||
    234   1.2     oster 		    (((asmap->numStripeUnitsAccessed <= (layoutPtr->numDataCol / 2)) && (layoutPtr->numDataCol != 1)) ||
    235   1.2     oster 			(asmap->parityInfo->next != NULL) || (asmap->qInfo->next != NULL) || rf_CheckStripeForFailures(raidPtr, asmap))) {
    236   1.2     oster 
    237   1.2     oster 			*createFunc = (RF_VoidFuncPtr) rf_EOCreateSmallWriteDAG;
    238   1.2     oster 		} else {
    239   1.2     oster 			*createFunc = (RF_VoidFuncPtr) rf_EOCreateLargeWriteDAG;
    240   1.2     oster 		}
    241   1.2     oster 		break;
    242   1.2     oster 
    243   1.2     oster 	case 1:		/* single disk fault */
    244   1.2     oster 		if (npfail == 1) {
    245   1.2     oster 			RF_ASSERT((asmap->failedPDAs[0]->type == RF_PDA_TYPE_PARITY) || (asmap->failedPDAs[0]->type == RF_PDA_TYPE_Q));
    246   1.2     oster 			if (asmap->failedPDAs[0]->type == RF_PDA_TYPE_Q) {	/* q died, treat like
    247   1.2     oster 										 * normal mode raid5
    248   1.2     oster 										 * write. */
    249   1.2     oster 				if (((asmap->numStripeUnitsAccessed <= (layoutPtr->numDataCol / 2)) || (asmap->numStripeUnitsAccessed == 1))
    250   1.2     oster 				    || (asmap->parityInfo->next != NULL) || rf_NumFailedDataUnitsInStripe(raidPtr, asmap))
    251   1.2     oster 					*createFunc = (RF_VoidFuncPtr) rf_EO_001_CreateSmallWriteDAG;
    252   1.2     oster 				else
    253   1.2     oster 					*createFunc = (RF_VoidFuncPtr) rf_EO_001_CreateLargeWriteDAG;
    254   1.2     oster 			} else {/* parity died, small write only updating Q */
    255   1.2     oster 				if (((asmap->numStripeUnitsAccessed <= (layoutPtr->numDataCol / 2)) || (asmap->numStripeUnitsAccessed == 1))
    256   1.2     oster 				    || (asmap->qInfo->next != NULL) || rf_NumFailedDataUnitsInStripe(raidPtr, asmap))
    257   1.2     oster 					*createFunc = (RF_VoidFuncPtr) rf_EO_010_CreateSmallWriteDAG;
    258   1.2     oster 				else
    259   1.2     oster 					*createFunc = (RF_VoidFuncPtr) rf_EO_010_CreateLargeWriteDAG;
    260   1.2     oster 			}
    261   1.2     oster 		} else {	/* data missing. Do a P reconstruct write if
    262   1.2     oster 				 * only a single data unit is lost in the
    263   1.2     oster 				 * stripe, otherwise a reconstruct write which
    264  1.24    andvar 				 * employing both P and E units. */
    265   1.2     oster 			if (rf_NumFailedDataUnitsInStripe(raidPtr, asmap) == 2) {
    266   1.2     oster 				if (asmap->numStripeUnitsAccessed == 1)
    267   1.2     oster 					*createFunc = (RF_VoidFuncPtr) rf_EO_200_CreateWriteDAG;
    268   1.2     oster 				else
    269   1.2     oster 					*createFunc = NULL;	/* No direct support for
    270   1.2     oster 								 * this case now, like
    271   1.2     oster 								 * that in Raid-5  */
    272   1.2     oster 			} else {
    273   1.2     oster 				if (asmap->numStripeUnitsAccessed != 1 && asmap->failedPDAs[0]->numSector != layoutPtr->sectorsPerStripeUnit)
    274   1.2     oster 					*createFunc = NULL;	/* No direct support for
    275   1.2     oster 								 * this case now, like
    276   1.2     oster 								 * that in Raid-5  */
    277   1.2     oster 				else
    278   1.2     oster 					*createFunc = (RF_VoidFuncPtr) rf_EO_100_CreateWriteDAG;
    279   1.2     oster 			}
    280   1.2     oster 		}
    281   1.2     oster 		break;
    282   1.2     oster 
    283   1.2     oster 	case 2:		/* two disk faults */
    284   1.2     oster 		switch (npfail) {
    285   1.2     oster 		case 2:	/* both p and q dead */
    286   1.2     oster 			*createFunc = (RF_VoidFuncPtr) rf_EO_011_CreateWriteDAG;
    287   1.2     oster 			break;
    288   1.2     oster 		case 1:	/* either p or q and dead data */
    289   1.2     oster 			RF_ASSERT(asmap->failedPDAs[0]->type == RF_PDA_TYPE_DATA);
    290   1.2     oster 			RF_ASSERT((asmap->failedPDAs[1]->type == RF_PDA_TYPE_PARITY) || (asmap->failedPDAs[1]->type == RF_PDA_TYPE_Q));
    291   1.2     oster 			if (asmap->failedPDAs[1]->type == RF_PDA_TYPE_Q) {
    292   1.2     oster 				if (asmap->numStripeUnitsAccessed != 1 && asmap->failedPDAs[0]->numSector != layoutPtr->sectorsPerStripeUnit)
    293   1.2     oster 					*createFunc = NULL;	/* In both PQ and
    294   1.2     oster 								 * EvenOdd, no direct
    295   1.2     oster 								 * support for this case
    296   1.2     oster 								 * now, like that in
    297   1.2     oster 								 * Raid-5  */
    298   1.2     oster 				else
    299   1.2     oster 					*createFunc = (RF_VoidFuncPtr) rf_EO_101_CreateWriteDAG;
    300   1.2     oster 			} else {
    301   1.2     oster 				if (asmap->numStripeUnitsAccessed != 1 && asmap->failedPDAs[0]->numSector != layoutPtr->sectorsPerStripeUnit)
    302   1.2     oster 					*createFunc = NULL;	/* No direct support for
    303   1.2     oster 								 * this case, like that
    304   1.2     oster 								 * in Raid-5  */
    305   1.2     oster 				else
    306   1.2     oster 					*createFunc = (RF_VoidFuncPtr) rf_EO_110_CreateWriteDAG;
    307   1.2     oster 			}
    308   1.2     oster 			break;
    309   1.2     oster 		case 0:	/* double data loss */
    310   1.2     oster 			/* if(asmap->failedPDAs[0]->numSector +
    311   1.2     oster 			 * asmap->failedPDAs[1]->numSector == 2 *
    312   1.2     oster 			 * layoutPtr->sectorsPerStripeUnit ) createFunc =
    313   1.2     oster 			 * rf_EOCreateLargeWriteDAG; else    							 */
    314   1.2     oster 			*createFunc = NULL;	/* currently, in Evenodd, No
    315   1.2     oster 						 * support for simultaneous
    316   1.2     oster 						 * access of both failed SUs */
    317   1.2     oster 			break;
    318   1.2     oster 		}
    319   1.2     oster 		break;
    320   1.2     oster 
    321   1.2     oster 	default:		/* more than 2 disk faults */
    322   1.2     oster 		*createFunc = NULL;
    323   1.2     oster 		RF_PANIC();
    324   1.2     oster 	}
    325   1.2     oster 	return;
    326   1.1     oster }
    327   1.1     oster 
    328   1.1     oster 
    329  1.14     perry int
    330  1.12     oster rf_VerifyParityEvenOdd(RF_Raid_t *raidPtr, RF_RaidAddr_t raidAddr,
    331  1.12     oster 		       RF_PhysDiskAddr_t *parityPDA, int correct_it,
    332  1.12     oster 		       RF_RaidAccessFlags_t flags)
    333   1.1     oster {
    334   1.2     oster 	RF_RaidLayout_t *layoutPtr = &(raidPtr->Layout);
    335   1.2     oster 	RF_RaidAddr_t startAddr = rf_RaidAddressOfPrevStripeBoundary(layoutPtr, raidAddr);
    336   1.2     oster 	RF_SectorCount_t numsector = parityPDA->numSector;
    337   1.2     oster 	int     numbytes = rf_RaidAddressToByte(raidPtr, numsector);
    338   1.2     oster 	int     bytesPerStripe = numbytes * layoutPtr->numDataCol;
    339   1.2     oster 	RF_DagHeader_t *rd_dag_h, *wr_dag_h;	/* read, write dag */
    340  1.21  christos 	RF_DagNode_t *blockNode, *wrBlock;
    341   1.2     oster 	RF_AccessStripeMapHeader_t *asm_h;
    342   1.2     oster 	RF_AccessStripeMap_t *asmap;
    343   1.2     oster 	RF_AllocListElem_t *alloclist;
    344   1.2     oster 	RF_PhysDiskAddr_t *pda;
    345   1.2     oster 	char   *pbuf, *buf, *end_p, *p;
    346   1.2     oster 	char   *redundantbuf2;
    347   1.2     oster 	int     redundantTwoErr = 0, redundantOneErr = 0;
    348   1.2     oster 	int     parity_cant_correct = RF_FALSE, red2_cant_correct = RF_FALSE,
    349   1.2     oster 	        parity_corrected = RF_FALSE, red2_corrected = RF_FALSE;
    350   1.2     oster 	int     i, retcode;
    351   1.2     oster 	RF_ReconUnitNum_t which_ru;
    352   1.2     oster 	RF_StripeNum_t psID = rf_RaidAddressToParityStripeID(layoutPtr, raidAddr, &which_ru);
    353   1.2     oster 	int     stripeWidth = layoutPtr->numDataCol + layoutPtr->numParityCol;
    354   1.2     oster 	RF_AccTraceEntry_t tracerec;
    355   1.2     oster 	RF_MCPair_t *mcpair;
    356   1.2     oster 
    357   1.2     oster 	retcode = RF_PARITY_OKAY;
    358   1.2     oster 
    359  1.23     oster 	mcpair = rf_AllocMCPair(raidPtr);
    360   1.2     oster 	rf_MakeAllocList(alloclist);
    361  1.22  christos 	buf = RF_MallocAndAdd(
    362  1.22  christos 	    numbytes * (layoutPtr->numDataCol + layoutPtr->numParityCol),
    363  1.22  christos 	    alloclist);
    364  1.22  christos 	pbuf = RF_MallocAndAdd(numbytes, alloclist);
    365   1.2     oster 	end_p = buf + bytesPerStripe;
    366  1.22  christos 	redundantbuf2 = RF_MallocAndAdd(numbytes, alloclist);
    367   1.2     oster 
    368   1.2     oster 	rd_dag_h = rf_MakeSimpleDAG(raidPtr, stripeWidth, numbytes, buf, rf_DiskReadFunc, rf_DiskReadUndoFunc,
    369   1.2     oster 	    "Rod", alloclist, flags, RF_IO_NORMAL_PRIORITY);
    370   1.2     oster 	blockNode = rd_dag_h->succedents[0];
    371   1.2     oster 
    372   1.2     oster 	/* map the stripe and fill in the PDAs in the dag */
    373   1.2     oster 	asm_h = rf_MapAccess(raidPtr, startAddr, layoutPtr->dataSectorsPerStripe, buf, RF_DONT_REMAP);
    374   1.2     oster 	asmap = asm_h->stripeMap;
    375   1.2     oster 
    376   1.2     oster 	for (pda = asmap->physInfo, i = 0; i < layoutPtr->numDataCol; i++, pda = pda->next) {
    377   1.2     oster 		RF_ASSERT(pda);
    378   1.2     oster 		rf_RangeRestrictPDA(raidPtr, parityPDA, pda, 0, 1);
    379   1.2     oster 		RF_ASSERT(pda->numSector != 0);
    380   1.2     oster 		if (rf_TryToRedirectPDA(raidPtr, pda, 0))
    381   1.2     oster 			goto out;	/* no way to verify parity if disk is
    382   1.2     oster 					 * dead.  return w/ good status */
    383   1.2     oster 		blockNode->succedents[i]->params[0].p = pda;
    384   1.2     oster 		blockNode->succedents[i]->params[2].v = psID;
    385  1.13     oster 		blockNode->succedents[i]->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru);
    386   1.2     oster 	}
    387   1.2     oster 
    388   1.2     oster 	RF_ASSERT(!asmap->parityInfo->next);
    389   1.2     oster 	rf_RangeRestrictPDA(raidPtr, parityPDA, asmap->parityInfo, 0, 1);
    390   1.2     oster 	RF_ASSERT(asmap->parityInfo->numSector != 0);
    391   1.2     oster 	if (rf_TryToRedirectPDA(raidPtr, asmap->parityInfo, 1))
    392   1.2     oster 		goto out;
    393   1.2     oster 	blockNode->succedents[layoutPtr->numDataCol]->params[0].p = asmap->parityInfo;
    394   1.2     oster 
    395   1.2     oster 	RF_ASSERT(!asmap->qInfo->next);
    396   1.2     oster 	rf_RangeRestrictPDA(raidPtr, parityPDA, asmap->qInfo, 0, 1);
    397   1.2     oster 	RF_ASSERT(asmap->qInfo->numSector != 0);
    398   1.2     oster 	if (rf_TryToRedirectPDA(raidPtr, asmap->qInfo, 1))
    399   1.2     oster 		goto out;
    400   1.2     oster 	/* if disk is dead, b/c no reconstruction is implemented right now,
    401   1.2     oster 	 * the function "rf_TryToRedirectPDA" always return one, which cause
    402   1.2     oster 	 * go to out and return w/ good status   */
    403   1.2     oster 	blockNode->succedents[layoutPtr->numDataCol + 1]->params[0].p = asmap->qInfo;
    404   1.2     oster 
    405   1.2     oster 	/* fire off the DAG */
    406  1.22  christos 	memset(&tracerec, 0, sizeof(tracerec));
    407   1.2     oster 	rd_dag_h->tracerec = &tracerec;
    408   1.2     oster 
    409   1.8     oster #if RF_DEBUG_VALIDATE_DAG
    410   1.2     oster 	if (rf_verifyParityDebug) {
    411   1.2     oster 		printf("Parity verify read dag:\n");
    412   1.2     oster 		rf_PrintDAGList(rd_dag_h);
    413   1.2     oster 	}
    414   1.8     oster #endif
    415  1.20       mrg 	RF_LOCK_MCPAIR(mcpair);
    416   1.2     oster 	mcpair->flag = 0;
    417   1.2     oster 	rf_DispatchDAG(rd_dag_h, (void (*) (void *)) rf_MCPairWakeupFunc,
    418   1.2     oster 	    (void *) mcpair);
    419   1.2     oster 	while (!mcpair->flag)
    420  1.20       mrg 		RF_WAIT_MCPAIR(mcpair);
    421  1.20       mrg 	RF_UNLOCK_MCPAIR(mcpair);
    422   1.2     oster 	if (rd_dag_h->status != rf_enable) {
    423   1.2     oster 		RF_ERRORMSG("Unable to verify parity:  can't read the stripe\n");
    424   1.2     oster 		retcode = RF_PARITY_COULD_NOT_VERIFY;
    425   1.2     oster 		goto out;
    426   1.2     oster 	}
    427   1.2     oster 	for (p = buf, i = 0; p < end_p; p += numbytes, i++) {
    428   1.2     oster 		rf_e_encToBuf(raidPtr, i, p, RF_EO_MATRIX_DIM - 2, redundantbuf2, numsector);
    429   1.2     oster 		/* the corresponding columes in EvenOdd encoding Matrix for
    430   1.2     oster 		 * these p pointers which point to the databuffer in a full
    431   1.2     oster 		 * stripe are sequentially from 0 to layoutPtr->numDataCol-1 */
    432  1.16     oster 		rf_bxor(p, pbuf, numbytes);
    433   1.2     oster 	}
    434   1.2     oster 	RF_ASSERT(i == layoutPtr->numDataCol);
    435   1.2     oster 
    436   1.2     oster 	for (i = 0; i < numbytes; i++) {
    437   1.2     oster 		if (pbuf[i] != buf[bytesPerStripe + i]) {
    438   1.2     oster 			if (!correct_it) {
    439   1.2     oster 				RF_ERRORMSG3("Parity verify error: byte %d of parity is 0x%x should be 0x%x\n",
    440   1.2     oster 				    i, (u_char) buf[bytesPerStripe + i], (u_char) pbuf[i]);
    441   1.2     oster 			}
    442   1.2     oster 		}
    443   1.2     oster 		redundantOneErr = 1;
    444   1.2     oster 		break;
    445   1.2     oster 	}
    446   1.2     oster 
    447   1.2     oster 	for (i = 0; i < numbytes; i++) {
    448   1.2     oster 		if (redundantbuf2[i] != buf[bytesPerStripe + numbytes + i]) {
    449   1.2     oster 			if (!correct_it) {
    450   1.2     oster 				RF_ERRORMSG3("Parity verify error: byte %d of second redundant information is 0x%x should be 0x%x\n",
    451   1.2     oster 				    i, (u_char) buf[bytesPerStripe + numbytes + i], (u_char) redundantbuf2[i]);
    452   1.2     oster 			}
    453   1.2     oster 			redundantTwoErr = 1;
    454   1.2     oster 			break;
    455   1.2     oster 		}
    456   1.2     oster 	}
    457   1.2     oster 	if (redundantOneErr || redundantTwoErr)
    458   1.2     oster 		retcode = RF_PARITY_BAD;
    459   1.2     oster 
    460   1.2     oster 	/* correct the first redundant disk, ie parity if it is error    */
    461   1.2     oster 	if (redundantOneErr && correct_it) {
    462   1.2     oster 		wr_dag_h = rf_MakeSimpleDAG(raidPtr, 1, numbytes, pbuf, rf_DiskWriteFunc, rf_DiskWriteUndoFunc,
    463   1.2     oster 		    "Wnp", alloclist, flags, RF_IO_NORMAL_PRIORITY);
    464   1.2     oster 		wrBlock = wr_dag_h->succedents[0];
    465   1.2     oster 		wrBlock->succedents[0]->params[0].p = asmap->parityInfo;
    466   1.2     oster 		wrBlock->succedents[0]->params[2].v = psID;
    467  1.13     oster 		wrBlock->succedents[0]->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru);
    468  1.22  christos 		memset(&tracerec, 0, sizeof(tracerec));
    469   1.2     oster 		wr_dag_h->tracerec = &tracerec;
    470   1.8     oster #if RF_DEBUG_VALIDATE_DAG
    471   1.2     oster 		if (rf_verifyParityDebug) {
    472   1.2     oster 			printf("Parity verify write dag:\n");
    473   1.2     oster 			rf_PrintDAGList(wr_dag_h);
    474   1.2     oster 		}
    475   1.8     oster #endif
    476  1.20       mrg 		RF_LOCK_MCPAIR(mcpair);
    477   1.2     oster 		mcpair->flag = 0;
    478   1.2     oster 		rf_DispatchDAG(wr_dag_h, (void (*) (void *)) rf_MCPairWakeupFunc,
    479   1.2     oster 		    (void *) mcpair);
    480   1.2     oster 		while (!mcpair->flag)
    481  1.20       mrg 			RF_WAIT_MCPAIR(mcpair);
    482  1.20       mrg 		RF_UNLOCK_MCPAIR(mcpair);
    483   1.2     oster 		if (wr_dag_h->status != rf_enable) {
    484   1.2     oster 			RF_ERRORMSG("Unable to correct parity in VerifyParity:  can't write the stripe\n");
    485   1.2     oster 			parity_cant_correct = RF_TRUE;
    486   1.2     oster 		} else {
    487   1.2     oster 			parity_corrected = RF_TRUE;
    488   1.2     oster 		}
    489   1.2     oster 		rf_FreeDAG(wr_dag_h);
    490   1.2     oster 	}
    491   1.2     oster 	if (redundantTwoErr && correct_it) {
    492   1.2     oster 		wr_dag_h = rf_MakeSimpleDAG(raidPtr, 1, numbytes, redundantbuf2, rf_DiskWriteFunc, rf_DiskWriteUndoFunc,
    493   1.2     oster 		    "Wnred2", alloclist, flags, RF_IO_NORMAL_PRIORITY);
    494   1.2     oster 		wrBlock = wr_dag_h->succedents[0];
    495   1.2     oster 		wrBlock->succedents[0]->params[0].p = asmap->qInfo;
    496   1.2     oster 		wrBlock->succedents[0]->params[2].v = psID;
    497  1.13     oster 		wrBlock->succedents[0]->params[3].v = RF_CREATE_PARAM3(RF_IO_NORMAL_PRIORITY, which_ru);
    498  1.22  christos 		memset(&tracerec, 0, sizeof(tracerec));
    499   1.2     oster 		wr_dag_h->tracerec = &tracerec;
    500   1.8     oster #if RF_DEBUG_VALIDATE_DAG
    501   1.2     oster 		if (rf_verifyParityDebug) {
    502   1.2     oster 			printf("Dag of write new second redundant information in parity verify :\n");
    503   1.2     oster 			rf_PrintDAGList(wr_dag_h);
    504   1.2     oster 		}
    505   1.8     oster #endif
    506  1.20       mrg 		RF_LOCK_MCPAIR(mcpair);
    507   1.2     oster 		mcpair->flag = 0;
    508   1.2     oster 		rf_DispatchDAG(wr_dag_h, (void (*) (void *)) rf_MCPairWakeupFunc,
    509   1.2     oster 		    (void *) mcpair);
    510   1.2     oster 		while (!mcpair->flag)
    511  1.20       mrg 			RF_WAIT_MCPAIR(mcpair);
    512  1.20       mrg 		RF_UNLOCK_MCPAIR(mcpair);
    513   1.2     oster 		if (wr_dag_h->status != rf_enable) {
    514   1.2     oster 			RF_ERRORMSG("Unable to correct second redundant information in VerifyParity:  can't write the stripe\n");
    515   1.2     oster 			red2_cant_correct = RF_TRUE;
    516   1.2     oster 		} else {
    517   1.2     oster 			red2_corrected = RF_TRUE;
    518   1.2     oster 		}
    519   1.2     oster 		rf_FreeDAG(wr_dag_h);
    520   1.2     oster 	}
    521   1.2     oster 	if ((redundantOneErr && parity_cant_correct) ||
    522   1.2     oster 	    (redundantTwoErr && red2_cant_correct))
    523   1.2     oster 		retcode = RF_PARITY_COULD_NOT_CORRECT;
    524   1.2     oster 	if ((retcode = RF_PARITY_BAD) && parity_corrected && red2_corrected)
    525   1.2     oster 		retcode = RF_PARITY_CORRECTED;
    526   1.1     oster 
    527   1.1     oster 
    528   1.1     oster out:
    529  1.23     oster 	rf_FreeAccessStripeMap(raidPtr, asm_h);
    530   1.2     oster 	rf_FreeAllocList(alloclist);
    531   1.2     oster 	rf_FreeDAG(rd_dag_h);
    532  1.23     oster 	rf_FreeMCPair(raidPtr, mcpair);
    533   1.2     oster 	return (retcode);
    534   1.1     oster }
    535   1.2     oster #endif				/* RF_INCLUDE_EVENODD > 0 */
    536