rt/snapraid
1
0
Fork 0
mirror of https://github.com/amadvance/snapraid.git synced 2026-10-26 19:01:57 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Enforce mode parity limits

Browse source
This commit is contained in:
Andrea Mazzoleni 2026-08-20 01:22:31 +02:00
parent fcb78a8e29
commit ee4e3175c8
3 changed files with 26 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

5
raid/check.c
View file

@ -115,7 +115,10 @@ int raid_check(int nr, int *ir, int nd, int np, size_t size, void **v)
/* enforce limit on number of failures */
BUG_ON(nr >= np); /* >= because we check with extra parity */
BUG_ON(np > RAID_PARITY_MAX);
if (raid_mode(RAID_MODE_GET) == RAID_MODE_VANDERMONDE_RAID)
BUG_ON(np > 3);
else
BUG_ON(np > RAID_PARITY_MAX);
/* enforce order in index vector */
BUG_ON(nr >= 2 && ir[0] >= ir[1]);

23
raid/module.c
View file

@ -80,8 +80,12 @@ void raid_gen(int nd, int np, size_t size, void **v)
/* enforce limit on number of failures */
BUG_ON(np < 1);
BUG_ON(np > RAID_PARITY_MAX);
if (raid_mode_active == RAID_MODE_VANDERMONDE_RAID)
BUG_ON(np > 3);
else
BUG_ON(np > RAID_PARITY_MAX);
BUG_ON(raid_gen_ptr[np - 1] == 0);
raid_gen_ptr[np - 1](nd, size, v);
}
@ -104,7 +108,10 @@ void raid_rec(int nr, int *ir, int nd, int np, size_t size, void **v)
/* enforce limit on number of failures */
BUG_ON(nr > np);
BUG_ON(np > RAID_PARITY_MAX);
if (raid_mode_active == RAID_MODE_VANDERMONDE_RAID)
BUG_ON(np > 3);
else
BUG_ON(np > RAID_PARITY_MAX);
/* enforce order in index vector */
BUG_ON(nr >= 2 && ir[0] >= ir[1]);
@ -183,9 +190,17 @@ void raid_data(int nr, int *id, int *ip, int nd, size_t size, void **v)
BUG_ON(nr >= 5 && ip[3] >= ip[4]);
BUG_ON(nr >= 6 && ip[4] >= ip[5]);
/* enforce limit on index vector for parity */
if (raid_mode_active == RAID_MODE_VANDERMONDE_RAID)
BUG_ON(nr > 0 && ip[nr - 1] >= 3);
else
BUG_ON(nr > 0 && ip[nr - 1] >= RAID_PARITY_MAX);
/* if failed data is present */
if (nr != 0)
raid_rec_algo[nr - 1].rec(nr, id, ip, nd, size, v);
if (nr != 0) {
BUG_ON(raid_rec_ptr[nr - 1] == 0);
raid_rec_ptr[nr - 1](nr, id, ip, nd, size, v);
}
}
const char * raid_gen_tag(int na)

3
raid/raid.c
View file

@ -295,6 +295,9 @@ void raid_delta_gen(int nr, int *id, int *ip, int nd, size_t size, void **v)
int np;
void *latest;
/* zero buffer must be initialized prior to delta recovery */
BUG_ON(raid_zero_block == 0);
/*
* Total number of parities we are going to process
* they are both the used and the unused ones