shaba/lvm2
1
0
Fork 0
mirror of git://sourceware.org/git/lvm2.git synced 2024-12-22 17:35:59 +03:00
Code Releases Activity

unit-test/io_engine_t: Improve the read test.

Browse Source 
Now verifies what it reads.
This commit is contained in:
Joe Thornber 2018-04-30 17:09:24 +01:00
parent ef79d639fe
commit 39f24a169c
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
test/unit/io_engine_t.c
View File

@ -33,7 +33,7 @@
struct fixture { struct fixture {
struct io_engine *e; struct io_engine *e;
void *data; uint8_t *data;
char fname[64]; char fname[64];
int fd; int fd;
@ -41,19 +41,25 @@ struct fixture {
static void *_fix_init(void) static void *_fix_init(void)
{ {
uint8_t b = 123;
unsigned i;
struct fixture *f = malloc(sizeof(*f)); struct fixture *f = malloc(sizeof(*f));
T_ASSERT(f); T_ASSERT(f);
f->e = create_async_io_engine(); f->e = create_async_io_engine();
T_ASSERT(f->e); T_ASSERT(f->e);
if (posix_memalign(&f->data, 4096, SECTOR_SIZE * BLOCK_SIZE_SECTORS)) if (posix_memalign((void **) &f->data, 4096, SECTOR_SIZE * BLOCK_SIZE_SECTORS))
test_fail("posix_memalign failed"); test_fail("posix_memalign failed");
snprintf(f->fname, sizeof(f->fname), "unit-test-XXXXXX"); snprintf(f->fname, sizeof(f->fname), "unit-test-XXXXXX");
f->fd = mkostemp(f->fname, O_RDWR | O_CREAT | O_EXCL); f->fd = mkostemp(f->fname, O_RDWR | O_CREAT | O_EXCL);
T_ASSERT(f->fd >= 0); T_ASSERT(f->fd >= 0);
memset(f->data, 0, SECTOR_SIZE * BLOCK_SIZE_SECTORS); for (i = 0; i < SECTOR_SIZE * BLOCK_SIZE_SECTORS; i++) {
f->data[i] = b;
b = ((b << 5) + b) + i;
}
write(f->fd, f->data, SECTOR_SIZE * BLOCK_SIZE_SECTORS); write(f->fd, f->data, SECTOR_SIZE * BLOCK_SIZE_SECTORS);
lseek(f->fd, 0, SEEK_SET); lseek(f->fd, 0, SEEK_SET);
return f; return f;
@ -97,6 +103,8 @@ static void _test_read(void *fixture)
{ {
struct fixture *f = fixture; struct fixture *f = fixture;
uint8_t b = 123;
unsigned i;
struct io io; struct io io;
_io_init(&io); _io_init(&io);
@ -104,6 +112,11 @@ static void _test_read(void *fixture)
T_ASSERT(f->e->wait(f->e, _complete_io)); T_ASSERT(f->e->wait(f->e, _complete_io));
T_ASSERT(io.completed); T_ASSERT(io.completed);
T_ASSERT(!io.error); T_ASSERT(!io.error);
for (i = 0; i < SECTOR_SIZE * BLOCK_SIZE_SECTORS; i++) {
T_ASSERT_EQUAL(f->data[i], b);
b = ((b << 5) + b) + i;
}
} }
static void _test_write(void *fixture) static void _test_write(void *fixture)