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

Add support for selectable streaming vs cached parity generation

Browse source
This commit is contained in:
Andrea Mazzoleni 2026-09-02 16:31:21 +02:00
parent 44575b21b1
commit 0ce89aa35d
21 changed files with 1510 additions and 1137 deletions
Download patch file Download diff file Expand all files Collapse all files

38
raid/module.c
View file

@ -73,7 +73,7 @@ struct gfconst16 __aligned(16) gfconst16 =
};
#endif
void raid_gen(int nd, int np, size_t size, void **v)
void raid_gen(int nd, int np, size_t size, void **v, int streaming)
{
/* enforce limit on size */
BUG_ON(size % 64 != 0);
@ -88,8 +88,11 @@ void raid_gen(int nd, int np, size_t size, void **v)
/* enforce valid vector */
BUG_ON(v == 0);
/* enforce valid streaming flag */
BUG_ON(streaming != 0 && streaming != 1);
BUG_ON(raid_gen_ptr[np - 1] == 0);
raid_gen_ptr[np - 1](nd, size, v);
raid_gen_ptr[np - 1](nd, size, v, streaming);
}
/**
@ -199,7 +202,7 @@ void raid_rec(int nr, int *ir, int nd, int np, size_t size, void **v)
}
}
raid_gen(nd, max_p, size, v_gen);
raid_gen(nd, max_p, size, v_gen, 0);
}
}
@ -468,27 +471,30 @@ void raid_gen_ref(int nd, int np, size_t size, void **vv)
*/
static int selftest_par(int nd, int np, size_t size, void **v, void **ref)
{
int i;
int i, streaming;
void *t[TEST_COUNT + RAID_PARITY_MAX];
/* setup data */
for (i = 0; i < nd; ++i)
t[i] = ref[i];
/* setup parity */
for (i = 0; i < np; ++i) {
memset(v[nd + i], 0x55, size);
t[nd + i] = v[nd + i];
}
/* test both cached and streaming generation */
for (streaming = 0; streaming <= 1; ++streaming) {
/* setup parity */
for (i = 0; i < np; ++i) {
memset(v[nd + i], 0x55, size);
t[nd + i] = v[nd + i];
}
raid_gen(nd, np, size, t);
raid_gen(nd, np, size, t, streaming);
/* compare parity */
for (i = 0; i < np; ++i) {
if (memcmp(t[nd + i], ref[nd + i], size) != 0) {
/* LCOV_EXCL_START */
return -1;
/* LCOV_EXCL_STOP */
/* compare parity */
for (i = 0; i < np; ++i) {
if (memcmp(t[nd + i], ref[nd + i], size) != 0) {
/* LCOV_EXCL_START */
return -1;
/* LCOV_EXCL_STOP */
}
}
}