Skip to content

Commit

Permalink
test/zcrx: minor tweaks
Browse files Browse the repository at this point in the history
- Code style: no declarations after code in given scope
- Return T_EXIT_SKIP for argument given

Signed-off-by: Jens Axboe <[email protected]>
  • Loading branch information
axboe committed Feb 18, 2025
1 parent 30bd7ba commit 27bbd57
Showing 1 changed file with 16 additions and 16 deletions.
32 changes: 16 additions & 16 deletions test/zcrx.c
Original file line number Diff line number Diff line change
Expand Up @@ -588,6 +588,9 @@ static int do_recv(struct io_uring *ring, struct recv_data *rd,
refill_garbage(rd, refill_area_token);

for (i = 0; i < LOOP_COUNT - 1; i++) {
uint64_t off, mask = (1ULL << IORING_ZCRX_AREA_SHIFT) - 1;
void *addr;

ret = io_uring_wait_cqe(ring, &cqe);
if (ret) {
fprintf(stdout, "wait_cqe: %d\n", ret);
Expand All @@ -608,9 +611,8 @@ static int do_recv(struct io_uring *ring, struct recv_data *rd,
}

zcqe = (struct io_uring_zcrx_cqe *)(cqe + 1);
uint64_t mask = (1ULL << IORING_ZCRX_AREA_SHIFT) - 1;
uint64_t off = zcqe->off & mask;
void *addr = (char *)rd->area + off;
off = zcqe->off & mask;
addr = (char *) rd->area + off;
ret = strncmp(str, addr, sizeof(str));
if (ret != 0) {
fprintf(stderr, "recv incorrect payload: %s\n", (const char *)addr);
Expand Down Expand Up @@ -646,29 +648,27 @@ static void *recv_fn(void *data)
struct io_uring_params p = { };
struct io_uring ring;
int ret, sock;

p.flags = RING_FLAGS;
ret = t_create_ring_params(8, &ring, &p);
if (ret == T_SETUP_SKIP) {
ret = 0;
goto err;
} else if (ret < 0) {
goto err;
}

struct io_uring_zcrx_area_reg area_reg = {
.addr = (__u64)(unsigned long)rd->area,
.len = AREA_SZ,
.flags = 0,
};

struct io_uring_zcrx_ifq_reg reg = {
.if_idx = ifidx,
.if_rxq = rxq,
.rq_entries = RQ_ENTRIES,
.area_ptr = (__u64)(unsigned long)&area_reg,
};

p.flags = RING_FLAGS;
ret = t_create_ring_params(8, &ring, &p);
if (ret == T_SETUP_SKIP) {
ret = 0;
goto err;
} else if (ret < 0) {
goto err;
}

ret = io_uring_register_ifq(&ring, &reg);
if (ret != 0) {
fprintf(stderr, "register_ifq failed: %d\n", ret);
Expand Down Expand Up @@ -817,7 +817,7 @@ int main(int argc, char *argv[])
int ret;

if (argc > 1)
return 0;
return T_EXIT_SKIP;

area_outer = mmap(NULL, AREA_SZ + 8192, PROT_NONE,
MAP_ANONYMOUS | MAP_PRIVATE | MAP_NORESERVE, -1, 0);
Expand Down Expand Up @@ -914,5 +914,5 @@ int main(int argc, char *argv[])
}

munmap(area, AREA_SZ);
return 0;
return T_EXIT_PASS;
}

0 comments on commit 27bbd57

Please sign in to comment.