|
Packit |
d3489f |
/* SPDX-License-Identifier: MIT */
|
|
Packit |
d3489f |
/*
|
|
Packit |
d3489f |
* Description: basic fadvise test
|
|
Packit |
d3489f |
*/
|
|
Packit |
d3489f |
#include <errno.h>
|
|
Packit |
d3489f |
#include <stdio.h>
|
|
Packit |
d3489f |
#include <unistd.h>
|
|
Packit |
d3489f |
#include <stdlib.h>
|
|
Packit |
d3489f |
#include <string.h>
|
|
Packit |
d3489f |
#include <fcntl.h>
|
|
Packit |
d3489f |
#include <sys/types.h>
|
|
Packit |
d3489f |
#include <sys/time.h>
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
#include "liburing.h"
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
#define FILE_SIZE (128 * 1024)
|
|
Packit |
d3489f |
#define LOOPS 100
|
|
Packit |
d3489f |
#define MIN_LOOPS 10
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
static unsigned long long utime_since(const struct timeval *s,
|
|
Packit |
d3489f |
const struct timeval *e)
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
long long sec, usec;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
sec = e->tv_sec - s->tv_sec;
|
|
Packit |
d3489f |
usec = (e->tv_usec - s->tv_usec);
|
|
Packit |
d3489f |
if (sec > 0 && usec < 0) {
|
|
Packit |
d3489f |
sec--;
|
|
Packit |
d3489f |
usec += 1000000;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
sec *= 1000000;
|
|
Packit |
d3489f |
return sec + usec;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
static unsigned long long utime_since_now(struct timeval *tv)
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
struct timeval end;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
gettimeofday(&end, NULL);
|
|
Packit |
d3489f |
return utime_since(tv, &end;;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
static int create_file(const char *file)
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
ssize_t ret;
|
|
Packit |
d3489f |
char *buf;
|
|
Packit |
d3489f |
int fd;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
buf = malloc(FILE_SIZE);
|
|
Packit |
d3489f |
memset(buf, 0xaa, FILE_SIZE);
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
fd = open(file, O_WRONLY | O_CREAT, 0644);
|
|
Packit |
d3489f |
if (fd < 0) {
|
|
Packit |
d3489f |
perror("open file");
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
ret = write(fd, buf, FILE_SIZE);
|
|
Packit |
d3489f |
fsync(fd);
|
|
Packit |
d3489f |
close(fd);
|
|
Packit |
d3489f |
return ret != FILE_SIZE;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
static int do_fadvise(struct io_uring *ring, int fd, off_t offset, off_t len,
|
|
Packit |
d3489f |
int advice)
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
struct io_uring_sqe *sqe;
|
|
Packit |
d3489f |
struct io_uring_cqe *cqe;
|
|
Packit |
d3489f |
int ret;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
sqe = io_uring_get_sqe(ring);
|
|
Packit |
d3489f |
if (!sqe) {
|
|
Packit |
d3489f |
fprintf(stderr, "failed to get sqe\n");
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
io_uring_prep_fadvise(sqe, fd, offset, len, advice);
|
|
Packit |
d3489f |
sqe->user_data = advice;
|
|
Packit |
d3489f |
ret = io_uring_submit_and_wait(ring, 1);
|
|
Packit |
d3489f |
if (ret != 1) {
|
|
Packit |
d3489f |
fprintf(stderr, "submit: %d\n", ret);
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = io_uring_wait_cqe(ring, &cqe);
|
|
Packit |
d3489f |
if (ret) {
|
|
Packit |
d3489f |
fprintf(stderr, "wait: %d\n", ret);
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = cqe->res;
|
|
Packit |
d3489f |
if (ret == -EINVAL || ret == -EBADF) {
|
|
Packit |
d3489f |
fprintf(stdout, "Fadvise not supported, skipping\n");
|
|
Packit |
d3489f |
unlink(".fadvise.tmp");
|
|
Packit |
d3489f |
exit(0);
|
|
Packit |
d3489f |
} else if (ret) {
|
|
Packit |
d3489f |
fprintf(stderr, "cqe->res=%d\n", cqe->res);
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
io_uring_cqe_seen(ring, cqe);
|
|
Packit |
d3489f |
return ret;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
static long do_read(int fd, char *buf)
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
struct timeval tv;
|
|
Packit |
d3489f |
int ret;
|
|
Packit |
d3489f |
long t;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = lseek(fd, 0, SEEK_SET);
|
|
Packit |
d3489f |
if (ret) {
|
|
Packit |
d3489f |
perror("lseek");
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
gettimeofday(&tv, NULL);
|
|
Packit |
d3489f |
ret = read(fd, buf, FILE_SIZE);
|
|
Packit |
d3489f |
t = utime_since_now(&tv;;
|
|
Packit |
d3489f |
if (ret < 0) {
|
|
Packit |
d3489f |
perror("read");
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
} else if (ret != FILE_SIZE) {
|
|
Packit |
d3489f |
fprintf(stderr, "short read1: %d\n", ret);
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
return t;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
static int test_fadvise(struct io_uring *ring, const char *filename)
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
unsigned long cached_read, uncached_read, cached_read2;
|
|
Packit |
d3489f |
int fd, ret;
|
|
Packit |
d3489f |
char *buf;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
fd = open(filename, O_RDONLY);
|
|
Packit |
d3489f |
if (fd < 0) {
|
|
Packit |
d3489f |
perror("open");
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
buf = malloc(FILE_SIZE);
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
cached_read = do_read(fd, buf);
|
|
Packit |
d3489f |
if (cached_read == -1)
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = do_fadvise(ring, fd, 0, FILE_SIZE, POSIX_FADV_DONTNEED);
|
|
Packit |
d3489f |
if (ret)
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
uncached_read = do_read(fd, buf);
|
|
Packit |
d3489f |
if (uncached_read == -1)
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = do_fadvise(ring, fd, 0, FILE_SIZE, POSIX_FADV_DONTNEED);
|
|
Packit |
d3489f |
if (ret)
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = do_fadvise(ring, fd, 0, FILE_SIZE, POSIX_FADV_WILLNEED);
|
|
Packit |
d3489f |
if (ret)
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
fsync(fd);
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
cached_read2 = do_read(fd, buf);
|
|
Packit |
d3489f |
if (cached_read2 == -1)
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
if (cached_read < uncached_read &&
|
|
Packit |
d3489f |
cached_read2 < uncached_read)
|
|
Packit |
d3489f |
return 0;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
return 2;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
int main(int argc, char *argv[])
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
struct io_uring ring;
|
|
Packit |
d3489f |
int ret, i, good, bad;
|
|
Packit |
d3489f |
char *fname;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
if (argc > 1) {
|
|
Packit |
d3489f |
fname = argv[1];
|
|
Packit |
d3489f |
} else {
|
|
Packit |
d3489f |
fname = ".fadvise.tmp";
|
|
Packit |
d3489f |
if (create_file(".fadvise.tmp")) {
|
|
Packit |
d3489f |
fprintf(stderr, "file creation failed\n");
|
|
Packit |
d3489f |
goto err;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
if (io_uring_queue_init(8, &ring, 0)) {
|
|
Packit |
d3489f |
fprintf(stderr, "ring creation failed\n");
|
|
Packit |
d3489f |
goto err;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
good = bad = 0;
|
|
Packit |
d3489f |
for (i = 0; i < LOOPS; i++) {
|
|
Packit |
d3489f |
ret = test_fadvise(&ring, fname);
|
|
Packit |
d3489f |
if (ret == 1) {
|
|
Packit |
d3489f |
fprintf(stderr, "read_fadvise failed\n");
|
|
Packit |
d3489f |
goto err;
|
|
Packit |
d3489f |
} else if (!ret)
|
|
Packit |
d3489f |
good++;
|
|
Packit |
d3489f |
else if (ret == 2)
|
|
Packit |
d3489f |
bad++;
|
|
Packit |
d3489f |
if (i >= MIN_LOOPS && !bad)
|
|
Packit |
d3489f |
break;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
if (bad > good) {
|
|
Packit |
d3489f |
fprintf(stderr, "Suspicious timings\n");
|
|
Packit |
d3489f |
goto err;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
if (fname != argv[1])
|
|
Packit |
d3489f |
unlink(fname);
|
|
Packit |
d3489f |
io_uring_queue_exit(&ring);
|
|
Packit |
d3489f |
return 0;
|
|
Packit |
d3489f |
err:
|
|
Packit |
d3489f |
if (fname != argv[1])
|
|
Packit |
d3489f |
unlink(fname);
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
}
|