| 208 | } |
| 209 | |
| 210 | static void recycle_buffer(struct ctx *ctx, int idx) |
| 211 | { |
| 212 | io_uring_buf_ring_add(ctx->buf_ring, get_buffer(ctx, idx), buffer_size(ctx), idx, |
| 213 | io_uring_buf_ring_mask(BUFFERS), 0); |
| 214 | io_uring_buf_ring_advance(ctx->buf_ring, 1); |
| 215 | } |
| 216 | |
| 217 | static int process_cqe_send(struct ctx *ctx, struct io_uring_cqe *cqe) |
| 218 | { |
no test coverage detected