run make format

aio-sig.c

@@ -13,8 +13,7 @@ atomic_int done;
 
 void callback(int sig, siginfo_t *info, void *context) {
 	stop_watch();
-	if (info->si_value.sival_int != 42)
-		errx(EXIT_FAILURE, "got unexpected sigval value");
+	if (info->si_value.sival_int != 42) errx(EXIT_FAILURE, "got unexpected sigval value");
 
 	atomic_store(&done, 1);
 }
@@ -29,8 +28,7 @@ void init(int fd) {
 	sa.sa_sigaction = callback;
 	sigemptyset(&sa.sa_mask);
 	sa.sa_flags = SA_SIGINFO;
-	if (sigaction(SIGUSR1, &sa, NULL) == -1)
-		err(EXIT_FAILURE, "sigaction failed");
+	if (sigaction(SIGUSR1, &sa, NULL) == -1) err(EXIT_FAILURE, "sigaction failed");
 }
 
 void do_write(int fd, const void *buf, size_t count) {
@@ -40,10 +38,9 @@ void do_write(int fd, const void* buf, size_t count) {
 	start_watch();
 	int res = aio_write(&aiocb);
 
-	if (res == -1)
-		err(EXIT_FAILURE, "aio_write failed");
+	if (res == -1) err(EXIT_FAILURE, "aio_write failed");
 
-	while(!atomic_load(&done)) {}
+	while (!atomic_load(&done)) {
+	}
 	atomic_store(&done, 1);
-
 }

aio-thrd.c

@@ -13,8 +13,7 @@ struct aiocb aiocb;
 void callback(union sigval sigval) {
 	stop_watch();
 
-	if (sigval.sival_int != 42)
-		errx(EXIT_FAILURE, "got unexpected sigval value");
+	if (sigval.sival_int != 42) errx(EXIT_FAILURE, "got unexpected sigval value");
 
 	atomic_store(&done, 1);
 }
@@ -33,9 +32,9 @@ void do_write(int fd, void* buf, size_t count) {
 	start_watch();
 	int res = aio_write(&aiocb);
 
-	while(!atomic_load(&done)) {}
+	while (!atomic_load(&done)) {
+	}
 	atomic_store(&done, 0);
 
-	if (res == -1)
-		err(EXIT_FAILURE, "aio_write failed");
+	if (res == -1) err(EXIT_FAILURE, "aio_write failed");
 }

bench.c

@@ -31,8 +31,7 @@ int main() {
 
 	init(fd);
 
-	for (size_t i = 0; i < warmup; ++i)
-		do_write(fd, &write_buf, sizeof(write_buf));
+	for (size_t i = 0; i < warmup; ++i) do_write(fd, &write_buf, sizeof(write_buf));
 
 	for (int64_t i = 1; i <= iterations; ++i) {
 		do_write(fd, &write_buf, sizeof(write_buf));

blocking.c

@@ -11,6 +11,5 @@ void do_write(int fd, const void* buf, size_t count) {
 	ssize_t res = write(fd, buf, count);
 	stop_watch();
 
-	if (res == -1)
-		err(EXIT_FAILURE, "write failed");
+	if (res == -1) err(EXIT_FAILURE, "write failed");
 }

epoll.c

@@ -10,15 +10,12 @@ int nfds, epollfd;
 
 void init(int fd) {
 	epollfd = epoll_create1(0);
-	if (epollfd == -1)
-		err(EXIT_FAILURE, "creating epoll failed");
+	if (epollfd == -1) err(EXIT_FAILURE, "creating epoll failed");
 
 	ev.events = EPOLLOUT;
 	ev.data.fd = fd;
 
-	if (epoll_ctl(epollfd, EPOLL_CTL_ADD, fd, &ev) == -1)
-		err(EXIT_FAILURE, "epoll_ctl failed");
-
+	if (epoll_ctl(epollfd, EPOLL_CTL_ADD, fd, &ev) == -1) err(EXIT_FAILURE, "epoll_ctl failed");
 }
 
 void do_write(int fd, const void *buf, size_t count) {
@@ -27,12 +24,9 @@ void do_write(int fd, const void* buf, size_t count) {
 	size_t res = write(fd, buf, count);
 	stop_watch();
 
-	if (nfds == -1)
-		err(EXIT_FAILURE, "epoll_wait failed");
+	if (nfds == -1) err(EXIT_FAILURE, "epoll_wait failed");
 
-	if (ev.data.fd != fd)
-		errx(EXIT_FAILURE, "got unexpected fd from epoll");
+	if (ev.data.fd != fd) errx(EXIT_FAILURE, "got unexpected fd from epoll");
 
-	if (res == -1)
-		err(EXIT_FAILURE, "write failed");
+	if (res == -1) err(EXIT_FAILURE, "write failed");
 }

io-uring-no-syscall.c

@@ -28,7 +28,8 @@ void do_write(int fd, const void* buf, size_t count) {
 	int res = io_uring_submit(&ring);
 
 	struct io_uring_cqe *cqe;
-	while (io_uring_peek_cqe(&ring, &cqe) == -EAGAIN) {}
+	while (io_uring_peek_cqe(&ring, &cqe) == -EAGAIN) {
+	}
 
 	stop_watch();
 

io-uring.c

@@ -25,14 +25,11 @@ void do_write(int fd, const void* buf, size_t count) {
 
 	stop_watch();
 
-	if (res < 0)
-		err(EXIT_FAILURE, "io_uring_submit_and_wait failed");
+	if (res < 0) err(EXIT_FAILURE, "io_uring_submit_and_wait failed");
 
 	struct io_uring_cqe *cqe;
 	res = io_uring_peek_cqe(&ring, &cqe);
-	if (res < 0)
-		err(EXIT_FAILURE, "io_uring_peek_cqe failed");
+	if (res < 0) err(EXIT_FAILURE, "io_uring_peek_cqe failed");
 
-	if (cqe->res < 0)
-		err(EXIT_FAILURE, "write request failed");
+	if (cqe->res < 0) err(EXIT_FAILURE, "write request failed");
 }

stopwatch.c

@@ -2,17 +2,12 @@
 
 struct timespec start, stop;
 
-int64_t sec_to_nanos(int64_t sec) {
-	return sec * 1000 * 1000 * 1000;
-}
+int64_t sec_to_nanos(int64_t sec) { return sec * 1000 * 1000 * 1000; }
 
-double nanos_to_millis(int64_t nanos) {
-	return ((double)nanos) / (1000 * 1000);
-}
+double nanos_to_millis(int64_t nanos) { return ((double)nanos) / (1000 * 1000); }
 
 int64_t clock_diff_nanos() {
 	int64_t nanos = sec_to_nanos(stop.tv_sec - start.tv_sec);
 	nanos += (stop.tv_nsec - start.tv_nsec);
 	return nanos;
 }
-

stopwatch.h

@@ -5,13 +5,9 @@
 
 extern struct timespec start, stop;
 
-static inline void start_watch() {
-	clock_gettime(CLOCK_MONOTONIC, &start);
-}
+static inline void start_watch() { clock_gettime(CLOCK_MONOTONIC, &start); }
 
-static inline void stop_watch() {
-	clock_gettime(CLOCK_MONOTONIC, &stop);
-}
+static inline void stop_watch() { clock_gettime(CLOCK_MONOTONIC, &stop); }
 
 int64_t clock_diff_nanos();
 double nanos_to_millis(int64_t nanos);