Function recv_fn

test/recvsend_bundle.c:275–334

}

static void *recv_fn(void *data)
{
	struct recv_data *rd = data;
	struct io_uring_params p = { };
	struct io_uring ring;
	struct io_uring_buf_ring *br;
	void *buf = NULL, *ptr;
	int ret, sock, i;

	p.cq_entries = 4096;
	p.flags = IORING_SETUP_CQSIZE;
	ret = t_create_ring_params(16, &ring, &p);
	if (ret == T_SETUP_SKIP) {
		ret = 0;
		goto err;
	} else if (ret < 0) {
		goto err;
	}

	if (posix_memalign(&buf, sysconf(_SC_PAGESIZE), MSG_SIZE * RECV_BIDS))
		goto err;

	if (!classic_buffers) {
		br = io_uring_setup_buf_ring(&ring, RECV_BIDS, RECV_BGID, 0, &ret);
		if (!br) {
			if (ret != -EINVAL)
				fprintf(stderr, "failed setting up recv ring %d\n", ret);
			goto err;
		}

		ptr = buf;
		for (i = 0; i < RECV_BIDS; i++) {
			io_uring_buf_ring_add(br, ptr, MSG_SIZE, i, RECV_BID_MASK, i);
			ptr += MSG_SIZE;
		}
		io_uring_buf_ring_advance(br, RECV_BIDS);
		rd->recv_buf = buf;
	} else {
		ret = provide_classic_buffers(&ring, buf, RECV_BIDS, RECV_BGID);
		if (ret) {
			fprintf(stderr, "failed providing classic buffers\n");
			goto err;
		}
	}

	ret = recv_prep(&ring, rd, &sock);
	if (ret) {
		fprintf(stderr, "recv_prep failed: %d\n", ret);
		goto err;
	}

	ret = do_recv(&ring, rd);

	close(sock);
	close(rd->accept_fd);
	io_uring_queue_exit(&ring);
err:
	free(buf);