| lists.openwall.net | lists / announce owl-users owl-dev john-users john-dev passwdqc-users yescrypt popa3d-users / oss-security kernel-hardening musl sabotage tlsify passwords / crypt-dev xvendor / Bugtraq Full-Disclosure linux-kernel linux-netdev linux-ext4 linux-hardening linux-cve-announce PHC | |
|
Open Source and information security mailing list archives
| ||
|
Date: Wed, 11 Dec 2019 14:33:44 -0800
From: Brian Vazquez <brianvv@...gle.com>
To: Brian Vazquez <brianvv.kernel@...il.com>,
Brian Vazquez <brianvv@...gle.com>,
Alexei Starovoitov <ast@...nel.org>,
Daniel Borkmann <daniel@...earbox.net>,
"David S . Miller" <davem@...emloft.net>
Cc: Yonghong Song <yhs@...com>, Stanislav Fomichev <sdf@...gle.com>,
Petar Penkov <ppenkov@...gle.com>,
Willem de Bruijn <willemb@...gle.com>,
linux-kernel@...r.kernel.org, netdev@...r.kernel.org,
bpf@...r.kernel.org
Subject: [PATCH v3 bpf-next 11/11] selftests/bpf: add batch ops testing to
lpm_trie bpf map
Tested bpf_map_batch_ops functionality.
$ ./test_maps
...
test_trie_map_batch_ops:PASS
...
Signed-off-by: Brian Vazquez <brianvv@...gle.com>
Signed-off-by: Yonghong Song <yhs@...com>
---
.../bpf/map_tests/trie_map_batch_ops.c | 235 ++++++++++++++++++
1 file changed, 235 insertions(+)
create mode 100644 tools/testing/selftests/bpf/map_tests/trie_map_batch_ops.c
diff --git a/tools/testing/selftests/bpf/map_tests/trie_map_batch_ops.c b/tools/testing/selftests/bpf/map_tests/trie_map_batch_ops.c
new file mode 100644
index 0000000000000..927e898bea2d0
--- /dev/null
+++ b/tools/testing/selftests/bpf/map_tests/trie_map_batch_ops.c
@@ -0,0 +1,235 @@
+// SPDX-License-Identifier: GPL-2.0
+#include <stdio.h>
+#include <errno.h>
+#include <string.h>
+#include <arpa/inet.h>
+
+#include <bpf/bpf.h>
+#include <bpf/libbpf.h>
+
+#include <bpf_util.h>
+#include <test_maps.h>
+
+static void map_batch_update(int map_fd, __u32 max_entries)
+{
+ int i, err;
+ struct bpf_lpm_trie_key *key_helper;
+ void *key, *values;
+ size_t key_size;
+
+ key_size = sizeof(*key_helper) + sizeof(__u32);
+ key = alloca(max_entries * key_size);
+ values = alloca(max_entries * sizeof(int));
+
+ for (i = 0; i < max_entries; i++) {
+ key_helper = (struct bpf_lpm_trie_key *)(key + i * key_size);
+ inet_pton(AF_INET, "192.168.0.0", key_helper->data);
+ key_helper->data[3] = i;
+ key_helper->prefixlen = 16 + i;
+ ((int *)values)[i] = i + 1;
+ }
+
+ err = bpf_map_update_batch(map_fd, key, values, &max_entries, 0, 0);
+ CHECK(err, "bpf_map_update_batch()", "error:%s\n", strerror(errno));
+}
+
+static void map_batch_verify(int *visited, __u32 max_entries,
+ void *keys, void *values)
+{
+ struct bpf_lpm_trie_key *key;
+ size_t key_size;
+ int i;
+
+ memset(visited, 0, max_entries * sizeof(*visited));
+ key_size = sizeof(*key) + sizeof(__u32);
+
+ for (i = 0; i < max_entries; i++) {
+ key = keys + i * key_size;
+ CHECK(key->data[3] + 1 != ((int *)values)[i],
+ "key/value checking",
+ "error: i %d key %d.%d.%d.%d value %d\n", i, key->data[0],
+ key->data[1], key->data[2], key->data[3],
+ ((int *)values)[i]);
+
+ visited[i] = 1;
+
+ }
+ for (i = 0; i < max_entries; i++) {
+ CHECK(visited[i] != 1, "visited checking",
+ "error: keys array at index %d missing\n", i);
+ }
+}
+
+void __test_trie_map_lookup_and_delete_batch(void)
+{
+ struct bpf_lpm_trie_key *batch, *key_p;
+ size_t key_size = sizeof(*key_p) + sizeof(__u32);
+ struct bpf_create_map_attr xattr = {
+ .name = "lpm_trie_map",
+ .map_type = BPF_MAP_TYPE_LPM_TRIE,
+ .key_size = key_size,
+ .value_size = sizeof(int),
+ };
+ __u32 count, total, total_success;
+ const __u32 max_entries = 10;
+ int map_fd, *visited, key;
+ int err, i, step;
+ int *values;
+ void *keys;
+
+ xattr.max_entries = max_entries;
+ xattr.map_flags = BPF_F_NO_PREALLOC;
+ map_fd = bpf_create_map_xattr(&xattr);
+ CHECK(map_fd == -1,
+ "bpf_create_map_xattr()", "error:%s\n", strerror(errno));
+
+ keys = malloc(max_entries * key_size);
+ batch = malloc(key_size);
+ values = malloc(max_entries * sizeof(int));
+ visited = malloc(max_entries * sizeof(int));
+ CHECK(!keys || !values || !visited, "malloc()",
+ "error:%s\n", strerror(errno));
+
+ /* test 1: lookup/delete an empty hash table, -ENOENT */
+ count = max_entries;
+ err = bpf_map_lookup_and_delete_batch(map_fd, NULL, batch, keys,
+ values, &count, 0, 0);
+ CHECK((err && errno != ENOENT), "empty map",
+ "error: %s\n", strerror(errno));
+
+ /* populate elements to the map */
+ map_batch_update(map_fd, max_entries);
+
+ /* test 2: lookup/delete with count = 0, success */
+ count = 0;
+ err = bpf_map_lookup_and_delete_batch(map_fd, NULL, batch, keys,
+ values, &count, 0, 0);
+ CHECK(err, "count = 0", "error: %s\n", strerror(errno));
+
+ /* test 3: lookup/delete with count = max_entries, success */
+ memset(keys, 0, max_entries * key_size);
+ memset(values, 0, max_entries * sizeof(int));
+ count = max_entries;
+ err = bpf_map_lookup_and_delete_batch(map_fd, NULL, batch, keys,
+ values, &count, 0, 0);
+ CHECK((err && errno != ENOENT), "count = max_entries",
+ "error: %s\n", strerror(errno));
+ CHECK(count != max_entries, "count = max_entries",
+ "count = %u, max_entries = %u\n", count, max_entries);
+ map_batch_verify(visited, max_entries, keys, values);
+
+ /* bpf_map_get_next_key() should return -ENOENT for an empty map. */
+ err = bpf_map_get_next_key(map_fd, NULL, &key);
+ CHECK(!err, "bpf_map_get_next_key()", "error: %s\n", strerror(errno));
+
+ /* test 4: lookup/delete in a loop with various steps. */
+ total_success = 0;
+ for (step = 4; step < max_entries; step++) {
+ map_batch_update(map_fd, max_entries);
+ memset(keys, 0, max_entries * key_size);
+ memset(values, 0, max_entries * sizeof(int));
+ total = 0;
+ /* iteratively lookup elements with 'step'
+ * elements each
+ */
+ count = step;
+ while (true) {
+ err = bpf_map_lookup_batch(map_fd,
+ total ? batch : NULL,
+ batch,
+ keys + total * key_size,
+ values + total,
+ &count, 0, 0);
+ /* It is possible that we are failing due to buffer size
+ * not big enough. In such cases, let us just exit and
+ * go with large steps. Not that a buffer size with
+ * max_entries should always work.
+ */
+ CHECK((err && errno != ENOENT), "lookup with steps",
+ "error: %s\n", strerror(errno));
+
+ total += count;
+ if (err)
+ break;
+ }
+
+ CHECK(total != max_entries, "lookup with steps",
+ "total = %u, max_entries = %u\n", total, max_entries);
+ map_batch_verify(visited, max_entries, keys, values);
+
+ total = 0;
+ while (true) {
+ err = bpf_map_delete_batch(map_fd,
+ keys + total * key_size,
+ &count, 0, 0);
+ /* It is possible that we are failing due to buffer size
+ * not big enough. In such cases, let us just exit and
+ * go with large steps. Not that a buffer size with
+ * max_entries should always work.
+ */
+ CHECK((err && errno != ENOENT), "lookup with steps",
+ "error: %s\n", strerror(errno));
+ total += count;
+ if (err)
+ break;
+ }
+
+ CHECK(total != max_entries, "delete with steps",
+ "total = %u, max_entries = %u\n", total, max_entries);
+
+ /* check map is empty, errno == -ENOENT */
+ err = bpf_map_get_next_key(map_fd, NULL, keys);
+ CHECK(!err || errno != ENOENT, "bpf_map_get_next_key()",
+ "error: %s\n", strerror(errno));
+
+ map_batch_update(map_fd, max_entries);
+ memset(keys, 0, max_entries * key_size);
+ memset(values, 0, max_entries * sizeof(int));
+ total = 0;
+ i = 0;
+ /* iteratively lookup/delete elements with 'step'
+ * elements each
+ */
+ count = step;
+ while (true) {
+ err = bpf_map_lookup_and_delete_batch(map_fd,
+ total ? batch : NULL,
+ batch,
+ keys + total * key_size,
+ values + total,
+ &count, 0, 0);
+
+ CHECK((err && errno != ENOENT), "lookup with steps",
+ "error: %s\n", strerror(errno));
+
+ total += count;
+ if (err)
+ break;
+ i++;
+ }
+
+ CHECK(total != max_entries, "lookup/delete with steps",
+ "total = %u, max_entries = %u\n", total, max_entries);
+
+ map_batch_verify(visited, max_entries, keys, values);
+ err = bpf_map_get_next_key(map_fd, NULL, &key);
+ CHECK(!err, "bpf_map_get_next_key()", "error: %s\n",
+ strerror(errno));
+
+ total_success++;
+ }
+
+ CHECK(total_success == 0, "check total_success",
+ "unexpected failure\n");
+}
+
+void trie_map_batch_ops(void)
+{
+ __test_trie_map_lookup_and_delete_batch();
+ printf("test_%s:PASS\n", __func__);
+}
+
+void test_trie_map_batch_ops(void)
+{
+ trie_map_batch_ops();
+}
--
2.24.1.735.g03f4e72817-goog
Powered by blists - more mailing lists