#define THREADS_NUM 100
+static size_t page_size;
+
void
aio_worker(void *ptr)
{
- int i, j, fd;
- char buffer[PAGE_SIZE] __attribute__((aligned(PAGE_SIZE)));
+ int i, j, fd, ret;
+ char *buffer = NULL;
+
+ ret = posix_memalign((void **)&buffer, page_size, page_size);
+ assert(ret == 0);
+ assert(buffer != NULL);
fd = open(FILENAME, O_DIRECT|O_RDONLY);
assert(fd >= 0);
struct iocb *cbs[1];
assert(!io_queue_init(1, &ctx));
- io_prep_pread(&cb, fd, buffer, PAGE_SIZE, 0);
+ io_prep_pread(&cb, fd, buffer, page_size, 0);
cbs[0] = &cb;
- memset(buffer, '0', PAGE_SIZE);
+ memset(buffer, '0', page_size);
assert(io_submit(ctx, 1, &cbs[0]) == 1);
// wait random time (0-500ms) ?
io_destroy(ctx);
- memset(buffer, DESTROY_PATTERN, PAGE_SIZE);
+ memset(buffer, DESTROY_PATTERN, page_size);
// wait random for (0-500ms) ?
// check it is still DESTROY_PATTERN
- for (j = 0; j < PAGE_SIZE; j++) {
+ for (j = 0; j < page_size; j++) {
if (buffer[j] != DESTROY_PATTERN) {
fprintf(stderr,
"Buffer has unexpected character: %c\n",
}
}
+ free(buffer);
close(fd);
}
test_main(void)
{
int i, fd, ret;
- char buffer[PAGE_SIZE];
+ char *buffer = NULL;
pthread_t threads[THREADS_NUM];
+ page_size = sysconf(_SC_PAGESIZE);
+ assert(page_size >= 1);
+
+ ret = posix_memalign((void **)&buffer, page_size, page_size);
+ assert(ret == 0);
+ assert(buffer != NULL);
+
fd = open(FILENAME, O_CREAT|O_TRUNC|O_APPEND|O_RDWR, S_IRUSR|S_IWUSR);
assert(fd != -1);
- memset(buffer, FILEPATTERN, PAGE_SIZE);
- ret = write(fd, buffer, PAGE_SIZE);
- assert(ret == PAGE_SIZE);
+ memset(buffer, FILEPATTERN, page_size);
+ ret = write(fd, buffer, page_size);
+ assert(ret == page_size);
close(fd);
for (i = 0; i < THREADS_NUM; i++) {