cpp/liburing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update tests for 'sqe submit always posts a cqe'

Browse Source 
Signed-off-by: Jens Axboe <axboe@kernel.dk>
This commit is contained in:
Jens Axboe
2019-04-30 14:50:36 -06:00
parent 49d2017b3d
commit ce8e2bc298
2 changed files with 18 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
test/eeed8b54e0df-test.c
View File

@@ -47,6 +47,7 @@ int main(int argc, char *argv[])
{ {
struct io_uring ring; struct io_uring ring;
struct io_uring_sqe *sqe; struct io_uring_sqe *sqe;
struct io_uring_cqe *cqe;
struct iovec iov; struct iovec iov;
int ret, fd; int ret, fd;
@@ -74,8 +75,19 @@ int main(int argc, char *argv[])
sqe->rw_flags = RWF_NOWAIT; sqe->rw_flags = RWF_NOWAIT;
ret = io_uring_submit(&ring); ret = io_uring_submit(&ring);
if (ret != -EAGAIN) { if (ret != 1) {
printf("Got submit %d, expected EAGAIN\n", ret); printf("Got submit %d, expected 1\n", ret);
goto err;
}
ret = io_uring_peek_cqe(&ring, &cqe);
if (ret) {
printf("Ring peek got %d\n", ret);
goto err;
}
if (cqe->res != -EAGAIN) {
printf("cqe error: %d\n", cqe->res);
goto err; goto err;
} }

5
test/fsync.c
View File

@@ -112,6 +112,9 @@ static int test_barrier_fsync(struct io_uring *ring)
printf("child: wait completion %d\n", ret); printf("child: wait completion %d\n", ret);
goto err; goto err;
} }
/* kernel doesn't support IOSQE_IO_DRAIN */
if (cqe->res == -EINVAL)
break;
if (i <= 3) { if (i <= 3) {
if (cqe->user_data) { if (cqe->user_data) {
printf("Got fsync early?\n"); printf("Got fsync early?\n");
@@ -153,7 +156,7 @@ int main(int argc, char *argv[])
ret = test_barrier_fsync(&ring); ret = test_barrier_fsync(&ring);
if (ret) { if (ret) {
printf("test_single_fsync failed\n"); printf("test_barrier_fsync failed\n");
return ret; return ret;
} }