Commit f1300467 authored by John Fastabend's avatar John Fastabend Committed by Martin KaFai Lau
Browse files

bpf: sockmap, add tests for proto updates single socket to many map 



Add test with multiple maps where each socket is inserted in multiple
maps. Test protocols: TCP, UDP, stream af_unix and dgram af_unix.

Signed-off-by: default avatarJohn Fastabend <john.fastabend@gmail.com>
Signed-off-by: default avatarMartin KaFai Lau <martin.lau@kernel.org>
Reviewed-by: default avatarJakub Sitnicki <jakub@cloudflare.com>
Link: https://lore.kernel.org/r/20231221232327.43678-5-john.fastabend@gmail.com
parent 8c1b382a

tools/testing/selftests/bpf/prog_tests/sockmap_basic.c

+74 −0
Original line number Diff line number Diff line
@@ -623,6 +623,78 @@ static void test_sockmap_many_socket(void) 
	test_sockmap_pass_prog__destroy(skel);

}



static void test_sockmap_many_maps(void)

{

	struct test_sockmap_pass_prog *skel;

	int stream[2], dgram, udp, tcp;

	int i, err, map[2], entry = 0;



	skel = test_sockmap_pass_prog__open_and_load();

	if (!ASSERT_OK_PTR(skel, "open_and_load"))

		return;



	map[0] = bpf_map__fd(skel->maps.sock_map_rx);

	map[1] = bpf_map__fd(skel->maps.sock_map_tx);



	dgram = xsocket(AF_UNIX, SOCK_DGRAM, 0);

	if (dgram < 0) {

		test_sockmap_pass_prog__destroy(skel);

		return;

	}



	tcp = connected_socket_v4();

	if (!ASSERT_GE(tcp, 0, "connected_socket_v4")) {

		close(dgram);

		test_sockmap_pass_prog__destroy(skel);

		return;

	}



	udp = xsocket(AF_INET, SOCK_DGRAM | SOCK_NONBLOCK, 0);

	if (udp < 0) {

		close(dgram);

		close(tcp);

		test_sockmap_pass_prog__destroy(skel);

		return;

	}



	err = socketpair(AF_UNIX, SOCK_STREAM, 0, stream);

	ASSERT_OK(err, "socketpair(af_unix, sock_stream)");

	if (err)

		goto out;



	for (i = 0; i < 2; i++, entry++) {

		err = bpf_map_update_elem(map[i], &entry, &stream[0], BPF_ANY);

		ASSERT_OK(err, "bpf_map_update_elem(stream)");

	}

	for (i = 0; i < 2; i++, entry++) {

		err = bpf_map_update_elem(map[i], &entry, &dgram, BPF_ANY);

		ASSERT_OK(err, "bpf_map_update_elem(dgram)");

	}

	for (i = 0; i < 2; i++, entry++) {

		err = bpf_map_update_elem(map[i], &entry, &udp, BPF_ANY);

		ASSERT_OK(err, "bpf_map_update_elem(udp)");

	}

	for (i = 0; i < 2; i++, entry++) {

		err = bpf_map_update_elem(map[i], &entry, &tcp, BPF_ANY);

		ASSERT_OK(err, "bpf_map_update_elem(tcp)");

	}

	for (entry--; entry >= 0; entry--) {

		err = bpf_map_delete_elem(map[1], &entry);

		entry--;

		ASSERT_OK(err, "bpf_map_delete_elem(entry)");

		err = bpf_map_delete_elem(map[0], &entry);

		ASSERT_OK(err, "bpf_map_delete_elem(entry)");

	}



	close(stream[0]);

	close(stream[1]);

out:

	close(dgram);

	close(tcp);

	close(udp);

	test_sockmap_pass_prog__destroy(skel);

}



void test_sockmap_basic(void)

{

	if (test__start_subtest("sockmap create_update_free"))
@@ -669,4 +741,6 @@ void test_sockmap_basic(void) 
		test_sockmap_unconnected_unix();

	if (test__start_subtest("sockmap one socket to many map entries"))

		test_sockmap_many_socket();

	if (test__start_subtest("sockmap one socket to many maps"))

		test_sockmap_many_maps();

}