blob: d6dc20b8f95bb1dda164a5f7df24d925b09387b9 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
|
// SPDX-License-Identifier: GPL-2.0
/* Copyright (c) 2026 Isovalent */
#include <unistd.h>
#include "test_progs.h"
#include "ksock_wq.skel.h"
#define CALLBACK_WAIT_RETRIES 1000
#define CALLBACK_WAIT_US 1000
void test_ksock_wq(void)
{
LIBBPF_OPTS(bpf_test_run_opts, opts);
struct ksock_wq *skel;
u32 callback_done;
int err, i;
skel = ksock_wq__open_and_load();
if (!ASSERT_OK_PTR(skel, "ksock_wq open and load"))
return;
err = bpf_prog_test_run_opts(bpf_program__fd(skel->progs.ksock_wq_start),
&opts);
if (!ASSERT_OK(err, "run ksock_wq_start"))
goto out;
if (!ASSERT_OK(opts.retval, "ksock_wq_start retval"))
goto out;
for (i = 0; i < CALLBACK_WAIT_RETRIES; i++) {
if (__atomic_load_n(&skel->bss->callback_done, __ATOMIC_ACQUIRE))
break;
usleep(CALLBACK_WAIT_US);
}
callback_done = __atomic_load_n(&skel->bss->callback_done,
__ATOMIC_ACQUIRE);
if (!ASSERT_EQ(callback_done, 1, "workqueue callback completed"))
goto out;
ASSERT_EQ(skel->bss->create_err, -EOPNOTSUPP,
"workqueue create rejected");
out:
ksock_wq__destroy(skel);
}
|
