| 134 | } |
| 135 | |
| 136 | static void recycle_buffer(struct test_ctx *ctx, int bid) |
| 137 | { |
| 138 | io_uring_buf_ring_add(ctx->br, |
| 139 | ctx->buf_base + bid * BUF_SIZE, |
| 140 | BUF_SIZE, bid, |
| 141 | io_uring_buf_ring_mask(ctx->nr_bufs), 0); |
| 142 | io_uring_buf_ring_advance(ctx->br, 1); |
| 143 | } |
| 144 | |
| 145 | static void arm_recv(struct io_uring *ring, int fd, int stream_id) |
| 146 | { |