Function run_shared_test

test/buf-ring-mshot.c:182–370

* Run a shared buffer ring test with the given parameters. */

 * Run a shared buffer ring test with the given parameters.
 */
static int run_shared_test(int nr_bufs, int *sends_per_stream)
{
	struct test_ctx ctx = { };
	struct sender_ctx senders[NR_STREAMS];
	pthread_t threads[NR_STREAMS];
	pthread_barrier_t barrier;
	struct __kernel_timespec ts = { .tv_sec = 5 };
	int ret, i, done = 0;

	ret = io_uring_queue_init(128, &ctx.ring, 0);
	if (ret) {
		fprintf(stderr, "ring setup: %d\n", ret);
		return T_EXIT_FAIL;
	}

	ret = setup_streams(&ctx);
	if (ret) {
		io_uring_queue_exit(&ctx.ring);
		return T_EXIT_FAIL;
	}

	ret = setup_buf_ring(&ctx, nr_bufs);
	if (ret == -EINVAL || ret == -ENOENT) {
		no_buf_ring = 1;
		close_streams(&ctx);
		io_uring_queue_exit(&ctx.ring);
		return T_EXIT_SKIP;
	}
	if (ret) {
		close_streams(&ctx);
		io_uring_queue_exit(&ctx.ring);
		return T_EXIT_FAIL;
	}

	for (i = 0; i < NR_STREAMS; i++)
		ctx.streams[i].nr_sends = sends_per_stream[i];

	pthread_barrier_init(&barrier, NULL, NR_STREAMS + 1);

	for (i = 0; i < NR_STREAMS; i++) {
		senders[i].barrier = &barrier;
		senders[i].stream = &ctx.streams[i];
		senders[i].stream_id = i;
		pthread_create(&threads[i], NULL, sender_fn, &senders[i]);
	}

	/* Arm multishot recv on all streams */
	for (i = 0; i < NR_STREAMS; i++)
		arm_recv(&ctx.ring, ctx.streams[i].recv_fd, i);

	ret = io_uring_submit(&ctx.ring);
	if (ret != NR_STREAMS) {
		fprintf(stderr, "submit: %d\n", ret);
		goto err;
	}

	/* Release all senders */
	pthread_barrier_wait(&barrier);