@@ -103,7 +103,7 @@ int main(int argc, char **argv)
ret = listen(listen_fd, SOMAXCONN);
if (ret < 0) {
perror("listen");
- return 1;
+ return T_EXIT_FAIL;
}
memset(&sa, 0, sizeof(sa));
@@ -510,7 +510,7 @@ static int test_accept_cancel(unsigned usecs, unsigned int nr, bool multishot)
int fd, i, ret;
if (multishot && no_accept_multi)
- return 0;
+ return T_EXIT_SKIP;
ret = io_uring_queue_init(32, &m_io_uring, 0);
assert(ret >= 0);
@@ -605,7 +605,7 @@ static int test_multishot_accept(int count, bool before, bool overflow)
};
if (no_accept_multi)
- return 0;
+ return T_EXIT_SKIP;
ret = io_uring_queue_init(MAX_FDS + 10, &m_io_uring, 0);
assert(ret >= 0);
@@ -695,7 +695,7 @@ static int test_multishot_fixed_accept(void)
};
if (no_accept_multi)
- return 0;
+ return T_EXIT_SKIP;
memset(fd, -1, sizeof(fd));
ret = io_uring_queue_init(MAX_FDS + 10, &m_io_uring, 0);
@@ -742,7 +742,7 @@ int main(int argc, char *argv[])
return ret;
}
if (no_accept)
- return 0;
+ return T_EXIT_SKIP;
ret = test_accept(2, false);
if (ret) {
@@ -380,7 +380,7 @@ int main(int argc, char *argv[])
return T_EXIT_FAIL;
}
if (no_connect)
- return 0;
+ return T_EXIT_SKIP;
ret = test_connect(&ring);
if (ret == -1) {
@@ -123,10 +123,10 @@ int main(int argc, char *argv[])
mmap_ret = mmap((void *)0x20000000ul, 0x1000000ul, 7ul, 0x32ul, -1, 0ul);
if (mmap_ret == MAP_FAILED)
- return 0;
+ return T_EXIT_SKIP;
mmap_ret = mmap((void *)0x21000000ul, 0x1000ul, 0ul, 0x32ul, -1, 0ul);
if (mmap_ret == MAP_FAILED)
- return 0;
+ return T_EXIT_SKIP;
intptr_t res = 0;
*(uint32_t*)0x20000484 = 0;
*(uint32_t*)0x20000488 = 0;
@@ -73,7 +73,7 @@ static int do_fadvise(struct io_uring *ring, int fd, off_t offset, off_t len,
if (ret == -EINVAL || ret == -EBADF) {
fprintf(stdout, "Fadvise not supported, skipping\n");
unlink(".fadvise.tmp");
- exit(0);
+ exit(T_EXIT_SKIP);
} else if (ret) {
fprintf(stderr, "cqe->res=%d\n", cqe->res);
}
@@ -1034,7 +1034,7 @@ int main(int argc, char *argv[])
}
if (no_update)
- return 0;
+ return T_EXIT_SKIP;
ret = test_additions(&ring);
if (ret) {
@@ -131,7 +131,7 @@ static int test_sqe_update(struct io_uring *ring)
free(fds);
if (ret == -EINVAL) {
fprintf(stdout, "IORING_OP_FILES_UPDATE not supported, skipping\n");
- return 0;
+ return T_EXIT_SKIP;
}
return ret != 10;
}
@@ -171,5 +171,5 @@ int main(int argc, char *argv[])
return ret;
}
- return 0;
+ return T_EXIT_PASS;
}
@@ -95,7 +95,7 @@ int main(int argc, char *argv[])
break;
if (errno != EADDRINUSE) {
fprintf(stderr, "bind: %s\n", strerror(errno));
- return 1;
+ return T_EXIT_FAIL;
}
if (i == 99) {
printf("Gave up on finding a port, skipping\n");
@@ -105,7 +105,7 @@ int main(int argc, char *argv[])
if (listen(sock_listen_fd, BACKLOG) < 0) {
perror("Error listening on socket\n");
- return 1;
+ return T_EXIT_FAIL;
}
if (setup_io_uring())
@@ -132,7 +132,7 @@ int main(int argc, char *argv[])
return T_EXIT_FAIL;
}
if (!(p.features & IORING_FEAT_CQE_SKIP))
- return 0;
+ return T_EXIT_SKIP;
memset(files, -1, sizeof(files));
ret = io_uring_register_files(&ring, files, ARRAY_SIZE(files));
@@ -508,26 +508,26 @@ int main(int argc, char *argv[])
int i, ret;
if (argc > 1)
- return 0;
+ return T_EXIT_SKIP;
if (test_dont_cancel_another_ring()) {
fprintf(stderr, "test_dont_cancel_another_ring() failed\n");
- return 1;
+ return T_EXIT_FAIL;
}
if (test_cancel_req_across_fork()) {
fprintf(stderr, "test_cancel_req_across_fork() failed\n");
- return 1;
+ return T_EXIT_FAIL;
}
if (test_cancel_inflight_exit()) {
fprintf(stderr, "test_cancel_inflight_exit() failed\n");
- return 1;
+ return T_EXIT_FAIL;
}
if (test_sqpoll_cancel_iowq_requests()) {
fprintf(stderr, "test_sqpoll_cancel_iowq_requests() failed\n");
- return 1;
+ return T_EXIT_FAIL;
}
t_create_file(fname, FILE_SIZE);
@@ -548,8 +548,8 @@ int main(int argc, char *argv[])
}
unlink(fname);
- return 0;
+ return T_EXIT_PASS;
err:
unlink(fname);
- return 1;
+ return T_EXIT_FAIL;
}
@@ -185,14 +185,14 @@ int main(int argc, char **argv)
unsigned completed, dropped;
if (argc > 1)
- return 0;
+ return T_EXIT_SKIP;
ret = io_uring_queue_init(IORING_MAX_ENTRIES, &ring, 0);
if (ret == -ENOMEM)
ret = io_uring_queue_init(IORING_MAX_ENTRIES_FALLBACK, &ring, 0);
if (ret < 0) {
perror("io_uring_queue_init");
- exit(1);
+ exit(T_EXIT_FAIL);
}
mask = *sq->kring_mask;
@@ -254,8 +254,8 @@ int main(int argc, char **argv)
}
if (!status)
- return 0;
+ return T_EXIT_PASS;
fprintf(stderr, "FAIL\n");
- return -1;
+ return T_EXIT_FAIL;
}
@@ -459,20 +459,20 @@ int main(int argc, char **argv)
struct rlimit rlim;
if (argc > 1)
- return 0;
+ return T_EXIT_SKIP;
/* setup globals */
pagesize = getpagesize();
ret = getrlimit(RLIMIT_MEMLOCK, &rlim);
if (ret < 0) {
perror("getrlimit");
- return 1;
+ return T_EXIT_PASS;
}
mlock_limit = rlim.rlim_cur;
devnull = open("/dev/null", O_RDWR);
if (devnull < 0) {
perror("open /dev/null");
- exit(1);
+ exit(T_EXIT_FAIL);
}
/* invalid fd */
@@ -15,6 +15,7 @@
#include <errno.h>
#include <sys/sysinfo.h>
#include "liburing.h"
+#include "helpers.h"
#include "../syscall.h"
@@ -130,7 +131,7 @@ main(int argc, char **argv)
struct io_uring_params p;
if (argc > 1)
- return 0;
+ return T_EXIT_SKIP;
memset(&p, 0, sizeof(p));
status |= try_io_uring_setup(0, &p, -1, EINVAL);
@@ -179,8 +180,8 @@ main(int argc, char **argv)
}
if (!status)
- return 0;
+ return T_EXIT_PASS;
fprintf(stderr, "FAIL\n");
- return -1;
+ return T_EXIT_FAIL;
}
@@ -323,7 +323,7 @@ int main(int argc, char *argv[])
char *fname;
if (probe_buf_select())
- return 1;
+ return T_EXIT_FAIL;
if (argc > 1) {
fname = argv[1];
@@ -364,9 +364,9 @@ int main(int argc, char *argv[])
if (fname != argv[1])
unlink(fname);
- return 0;
+ return T_EXIT_PASS;
err:
if (fname != argv[1])
unlink(fname);
- return 1;
+ return T_EXIT_FAIL;
}
@@ -14,6 +14,8 @@
#include <sys/resource.h>
#include <unistd.h>
+#include "helpers.h"
+
static const int RSIZE = 2;
static const int OPEN_FLAGS = O_RDWR | O_CREAT;
static const mode_t OPEN_MODE = S_IRUSR | S_IWUSR;
@@ -100,7 +102,7 @@ int main(int argc, char *argv[])
int dfd, ret;
if (argc > 1)
- return 0;
+ return T_EXIT_SKIP;
dfd = open("/tmp", O_RDONLY | O_DIRECTORY);
if (dfd < 0)
@@ -12,6 +12,7 @@
#include <poll.h>
#include "liburing.h"
+#include "helpers.h"
static int test_fail_lone_link_timeouts(struct io_uring *ring)
{
@@ -1011,12 +1012,12 @@ int main(int argc, char *argv[])
int ret;
if (argc > 1)
- return 0;
+ return T_EXIT_SKIP;
ret = io_uring_queue_init(8, &ring, 0);
if (ret) {
printf("ring setup failed\n");
- return 1;
+ return T_EXIT_FAIL;
}
ret = test_timeout_link_chain1(&ring);
@@ -1103,5 +1104,5 @@ int main(int argc, char *argv[])
return ret;
}
- return 0;
+ return T_EXIT_PASS;
}
@@ -11,6 +11,7 @@
#include <fcntl.h>
#include "liburing.h"
+#include "helpers.h"
static int no_hardlink;
@@ -435,19 +436,19 @@ int main(int argc, char *argv[])
int ret;
if (argc > 1)
- return 0;
+ return T_EXIT_SKIP;
ret = io_uring_queue_init(8, &ring, 0);
if (ret) {
printf("ring setup failed\n");
- return 1;
+ return T_EXIT_FAIL;
}
ret = io_uring_queue_init(8, &poll_ring, IORING_SETUP_IOPOLL);
if (ret) {
printf("poll_ring setup failed\n");
- return 1;
+ return T_EXIT_FAIL;
}
ret = test_single_link(&ring);
@@ -492,5 +493,5 @@ int main(int argc, char *argv[])
return ret;
}
- return 0;
+ return T_EXIT_PASS;
}
@@ -187,9 +187,9 @@ int main(int argc, char *argv[])
if (fname != argv[1])
unlink(fname);
io_uring_queue_exit(&ring);
- return 0;
+ return T_EXIT_PASS;
err:
if (fname != argv[1])
unlink(fname);
- return 1;
+ return T_EXIT_FAIL;
}
@@ -10,6 +10,7 @@
#include <unistd.h>
#include "liburing.h"
+#include "helpers.h"
static int do_mkdirat(struct io_uring *ring, const char *fn)
{
@@ -59,7 +60,7 @@ int main(int argc, char *argv[])
struct io_uring ring;
if (argc > 1)
- return 0;
+ return T_EXIT_SKIP;
ret = io_uring_queue_init(8, &ring, 0);
if (ret) {
@@ -104,5 +105,5 @@ err1:
unlinkat(AT_FDCWD, fn, AT_REMOVEDIR);
err:
io_uring_queue_exit(&ring);
- return 1;
+ return T_EXIT_FAIL;
}
@@ -12,6 +12,7 @@
#include <pthread.h>
#include "liburing.h"
+#include "helpers.h"
static int no_msg;
@@ -183,22 +184,22 @@ int main(int argc, char *argv[])
int ret;
if (argc > 1)
- return 0;
+ return T_EXIT_SKIP;
ret = io_uring_queue_init(8, &ring, 0);
if (ret) {
fprintf(stderr, "ring setup failed: %d\n", ret);
- return 1;
+ return T_EXIT_FAIL;
}
ret = io_uring_queue_init(8, &ring2, 0);
if (ret) {
fprintf(stderr, "ring setup failed: %d\n", ret);
- return 1;
+ return T_EXIT_FAIL;
}
ret = io_uring_queue_init(8, &pring, IORING_SETUP_IOPOLL);
if (ret) {
fprintf(stderr, "ring setup failed: %d\n", ret);
- return 1;
+ return T_EXIT_FAIL;
}
ret = test_own(&ring);
@@ -208,7 +209,7 @@ int main(int argc, char *argv[])
}
if (no_msg) {
fprintf(stdout, "Skipped\n");
- return 0;
+ return T_EXIT_SKIP;
}
ret = test_own(&pring);
if (ret) {
@@ -232,5 +233,5 @@ int main(int argc, char *argv[])
pthread_join(thread, &tret);
- return 0;
+ return T_EXIT_PASS;
}
@@ -17,6 +17,7 @@
#include <poll.h>
#include "liburing.h"
+#include "helpers.h"
enum {
multi,
@@ -360,12 +361,12 @@ int main(int argc, char *argv[])
int i, ret;
if (argc > 1)
- return 0;
+ return T_EXIT_SKIP;
ret = io_uring_queue_init(1024, &ring, 0);
if (ret) {
printf("ring setup failed\n");
- return 1;
+ return T_EXIT_FAIL;
}
for (i = 0; i < 5; i++) {
Signed-off-by: Eli Schwartz <eschwartz93@gmail.com> --- test/accept-reuse.c | 2 +- test/accept.c | 8 ++++---- test/connect.c | 2 +- test/double-poll-crash.c | 4 ++-- test/fadvise.c | 2 +- test/file-register.c | 2 +- test/file-update.c | 4 ++-- test/files-exit-hang-timeout.c | 4 ++-- test/fixed-reuse.c | 2 +- test/io-cancel.c | 14 +++++++------- test/io_uring_enter.c | 8 ++++---- test/io_uring_register.c | 6 +++--- test/io_uring_setup.c | 7 ++++--- test/iopoll.c | 6 +++--- test/lfs-openat-write.c | 4 +++- test/link-timeout.c | 7 ++++--- test/link.c | 9 +++++---- test/madvise.c | 4 ++-- test/mkdir.c | 5 +++-- test/msg-ring.c | 13 +++++++------ test/multicqes_drain.c | 5 +++-- 21 files changed, 63 insertions(+), 55 deletions(-)