test/msg-ring: synchronize remote test case with a pthread barrier

Link: https://github.com/axboe/liburing/issues/1135
Signed-off-by: Jens Axboe <axboe@kernel.dk>

1 files changed, 16 insertions, 3 deletions

diff --git a/test/msg-ring.c b/test/msg-ring.c
index bc8cdb5d..9d5d10a3 100644
--- a/test/msg-ring.c
+++ b/test/msg-ring.c
@@ -72,12 +72,20 @@ err:
 	return 1;
 }
 
-static void *wait_cqe_fn(void *data)
+struct data {
+	struct io_uring *ring;
+	pthread_barrier_t barrier;
+};
+
+static void *wait_cqe_fn(void *__data)
 {
-	struct io_uring *ring = data;
+	struct data *d = __data;
+	struct io_uring *ring = d->ring;
 	struct io_uring_cqe *cqe;
 	int ret;
 
+	pthread_barrier_wait(&d->barrier);
+
 	ret = io_uring_wait_cqe(ring, &cqe);
 	if (ret) {
 		fprintf(stderr, "wait cqe %d\n", ret);
@@ -106,9 +114,12 @@ static int test_remote(struct io_uring *ring, struct io_uring *target)
 	void *tret;
 	struct io_uring_cqe *cqe;
 	struct io_uring_sqe *sqe;
+	struct data d;
 	int ret;
 
-	pthread_create(&thread, NULL, wait_cqe_fn, target);
+	d.ring = target;
+	pthread_barrier_init(&d.barrier, NULL, 2);
+	pthread_create(&thread, NULL, wait_cqe_fn, &d);
 
 	sqe = io_uring_get_sqe(ring);
 	if (!sqe) {
@@ -125,6 +136,8 @@ static int test_remote(struct io_uring *ring, struct io_uring *target)
 		goto err;
 	}
 
+	pthread_barrier_wait(&d.barrier);
+
 	ret = io_uring_wait_cqe(ring, &cqe);
 	if (ret < 0) {
 		fprintf(stderr, "wait completion %d\n", ret);