diff mbox series

[v5,bpf-next,5/6] selftests: xsk: make sure single threaded test terminates

Message ID 20220830135604.10173-6-maciej.fijalkowski@intel.com (mailing list archive)
State Superseded
Delegated to: BPF
Headers show
Series selftests: xsk: real device testing support | expand

Checks

Context Check Description
netdev/tree_selection success Clearly marked for bpf-next
netdev/apply fail Patch does not apply to bpf-next
bpf/vmtest-bpf-next-PR fail merge-conflict

Commit Message

Maciej Fijalkowski Aug. 30, 2022, 1:56 p.m. UTC
For single threaded poll tests call pthread_kill() from main thread so
that we are sure worker thread has finished its job and it is possible
to proceed with next test types from test suite. It was observed that on
some platforms it takes a bit longer for worker thread to exit and next
test case sees device as busy in this case.

Signed-off-by: Maciej Fijalkowski <maciej.fijalkowski@intel.com>
---
 tools/testing/selftests/bpf/xskxceiver.c | 7 +++++++
 1 file changed, 7 insertions(+)

Comments

Magnus Karlsson Aug. 31, 2022, 8:55 a.m. UTC | #1
On Tue, Aug 30, 2022 at 4:14 PM Maciej Fijalkowski
<maciej.fijalkowski@intel.com> wrote:
>
> For single threaded poll tests call pthread_kill() from main thread so
> that we are sure worker thread has finished its job and it is possible
> to proceed with next test types from test suite. It was observed that on
> some platforms it takes a bit longer for worker thread to exit and next
> test case sees device as busy in this case.

Acked-by: Magnus Karlsson <magnus.karlsson@intel.com>

> Signed-off-by: Maciej Fijalkowski <maciej.fijalkowski@intel.com>
> ---
>  tools/testing/selftests/bpf/xskxceiver.c | 7 +++++++
>  1 file changed, 7 insertions(+)
>
> diff --git a/tools/testing/selftests/bpf/xskxceiver.c b/tools/testing/selftests/bpf/xskxceiver.c
> index 4f8a028f5433..8e157c462cd0 100644
> --- a/tools/testing/selftests/bpf/xskxceiver.c
> +++ b/tools/testing/selftests/bpf/xskxceiver.c
> @@ -1345,6 +1345,11 @@ static void testapp_clean_xsk_umem(struct ifobject *ifobj)
>         munmap(ifobj->umem->buffer, umem_sz);
>  }
>
> +static void handler(int signum)
> +{
> +       pthread_exit(NULL);
> +}
> +
>  static int testapp_validate_traffic_single_thread(struct test_spec *test, struct ifobject *ifobj,
>                                                   enum test_type type)
>  {
> @@ -1362,6 +1367,7 @@ static int testapp_validate_traffic_single_thread(struct test_spec *test, struct
>         test->ifobj_rx->shared_umem = false;
>         test->ifobj_tx->shared_umem = false;
>
> +       signal(SIGUSR1, handler);
>         /* Spawn thread */
>         pthread_create(&t0, NULL, ifobj->func_ptr, test);
>
> @@ -1371,6 +1377,7 @@ static int testapp_validate_traffic_single_thread(struct test_spec *test, struct
>         if (pthread_barrier_destroy(&barr))
>                 exit_with_error(errno);
>
> +       pthread_kill(t0, SIGUSR1);
>         pthread_join(t0, NULL);
>
>         if (test->total_steps == test->current_step || test->fail) {
> --
> 2.34.1
>
diff mbox series

Patch

diff --git a/tools/testing/selftests/bpf/xskxceiver.c b/tools/testing/selftests/bpf/xskxceiver.c
index 4f8a028f5433..8e157c462cd0 100644
--- a/tools/testing/selftests/bpf/xskxceiver.c
+++ b/tools/testing/selftests/bpf/xskxceiver.c
@@ -1345,6 +1345,11 @@  static void testapp_clean_xsk_umem(struct ifobject *ifobj)
 	munmap(ifobj->umem->buffer, umem_sz);
 }
 
+static void handler(int signum)
+{
+	pthread_exit(NULL);
+}
+
 static int testapp_validate_traffic_single_thread(struct test_spec *test, struct ifobject *ifobj,
 						  enum test_type type)
 {
@@ -1362,6 +1367,7 @@  static int testapp_validate_traffic_single_thread(struct test_spec *test, struct
 	test->ifobj_rx->shared_umem = false;
 	test->ifobj_tx->shared_umem = false;
 
+	signal(SIGUSR1, handler);
 	/* Spawn thread */
 	pthread_create(&t0, NULL, ifobj->func_ptr, test);
 
@@ -1371,6 +1377,7 @@  static int testapp_validate_traffic_single_thread(struct test_spec *test, struct
 	if (pthread_barrier_destroy(&barr))
 		exit_with_error(errno);
 
+	pthread_kill(t0, SIGUSR1);
 	pthread_join(t0, NULL);
 
 	if (test->total_steps == test->current_step || test->fail) {