bpf/map_tests/sk_storage_map.c

4 #include <linux/err.h>
166 	int i, map_fd, err, *sk_fds;
185 				err = -errno;
189 			err = bpf_map_update_elem(map_fd, &sk_fds[i], &value,
191 			if (err) {
192 				err = -errno;
220 	return ERR_PTR(err);
225 	int i, map_fd = -1, err = 0, nr_threads_created = 0;
236 		err = pthread_create(&sk_thread_ids[i], NULL,
238 		if (err) {
239 			err = -errno;
264 		if (IS_ERR(thread_ret) && !err) {
265 			err = PTR_ERR(thread_ret);
266 			fprintf(stderr, "threads#%u: err:%d\n", i, err);
274 	return err;
285 	int err = 0; /* Suppress compiler false alarm */
288 		err = bpf_map_update_elem(map_fd, &sk_fd, &value, 0);
289 		if (err && errno != EAGAIN) {
290 			err = -errno;
292 				err, errno);
299 		return ERR_PTR(err);
309 	int err = 0; /* Suppress compiler false alarm */
312 		err = bpf_map_delete_elem(map_fd, &sk_fd);
313 		if (err && errno != ENOENT) {
314 			err = -errno;
316 				err, errno);
323 		return ERR_PTR(err);
331 	int i, sk_fd, map_fd = -1, err = 0, nr_threads_created = 0;
343 		err = -errno;
352 			err = pthread_create(&sk_thread_ids[i], NULL,
355 			err = pthread_create(&sk_thread_ids[i], NULL,
357 		if (err) {
358 			err = -errno;
370 		if (IS_ERR(thread_ret) && !err) {
371 			err = PTR_ERR(thread_ret);
372 			fprintf(stderr, "threads#%u: err:%d\n", i, err);
381 	return err;
399 	int err;
413 		err = setrlimit(RLIMIT_NOFILE, &rlim_new);
414 		CHECK(err, "setrlimit(RLIMIT_NOFILE)", "rlim_new:%lu errno:%d",
418 	err = do_sk_storage_map_stress_free();
430 	CHECK(err, "test_sk_storage_map_stress_free", "err:%d\n", err);
435 	int err;
444 	err = do_sk_storage_map_stress_change();
453 	CHECK(err, "test_sk_storage_map_stress_change", "err:%d\n", err);
463 	int btf_fd, map_fd, sk_fd, err;
480 	err = bpf_map_update_elem(map_fd, &sk_fd, &value,
482 	CHECK(err, "bpf_map_update_elem(BPF_NOEXIST|BPF_F_LOCK)",
483 	      "err:%d errno:%d\n", err, errno);
484 	err = bpf_map_lookup_elem_flags(map_fd, &sk_fd, &lookup_value,
486 	CHECK(err || lookup_value.lock || lookup_value.cnt != value.cnt,
488 	      "err:%d errno:%d lock:%x cnt:%x(%x)\n",
489 	      err, errno, lookup_value.lock, lookup_value.cnt, value.cnt);
494 	err = bpf_map_update_elem(map_fd, &sk_fd, &value,
496 	CHECK(err, "bpf_map_update_elem(BPF_EXIST|BPF_F_LOCK)",
497 	      "err:%d errno:%d\n", err, errno);
498 	err = bpf_map_lookup_elem_flags(map_fd, &sk_fd, &lookup_value,
500 	CHECK(err || lookup_value.lock || lookup_value.cnt != value.cnt,
502 	      "err:%d errno:%d lock:%x cnt:%x(%x)\n",
503 	      err, errno, lookup_value.lock, lookup_value.cnt, value.cnt);
508 	err = bpf_map_update_elem(map_fd, &sk_fd, &value, BPF_EXIST);
509 	CHECK(err, "bpf_map_update_elem(BPF_EXIST)",
510 	      "err:%d errno:%d\n", err, errno);
511 	err = bpf_map_lookup_elem_flags(map_fd, &sk_fd, &lookup_value,
513 	CHECK(err || lookup_value.lock || lookup_value.cnt != value.cnt,
515 	      "err:%d errno:%d lock:%x cnt:%x(%x)\n",
516 	      err, errno, lookup_value.lock, lookup_value.cnt, value.cnt);
521 	err = bpf_map_update_elem(map_fd, &sk_fd, &value,
523 	CHECK(!err || errno != EEXIST,
525 	      "err:%d errno:%d\n", err, errno);
526 	err = bpf_map_update_elem(map_fd, &sk_fd, &value, BPF_NOEXIST);
527 	CHECK(!err || errno != EEXIST, "bpf_map_update_elem(BPF_NOEXIST)",
528 	      "err:%d errno:%d\n", err, errno);
530 	err = bpf_map_lookup_elem_flags(map_fd, &sk_fd, &lookup_value,
532 	CHECK(err || lookup_value.lock || lookup_value.cnt != value.cnt,
534 	      "err:%d errno:%d lock:%x cnt:%x(%x)\n",
535 	      err, errno, lookup_value.lock, lookup_value.cnt, value.cnt);
540 	err = bpf_map_update_elem(map_fd, &sk_fd, &value, 0);
541 	CHECK(err, "bpf_map_update_elem()", "err:%d errno:%d\n",
542 	      err, errno);
543 	err = bpf_map_lookup_elem_flags(map_fd, &sk_fd, &lookup_value,
545 	CHECK(err || lookup_value.lock || lookup_value.cnt != value.cnt,
547 	      "err:%d errno:%d lock:%x cnt:%x(%x)\n",
548 	      err, errno, lookup_value.lock, lookup_value.cnt, value.cnt);
551 	err = bpf_map_delete_elem(map_fd, &sk_fd);
552 	CHECK(err, "bpf_map_delete_elem()", "err:%d errno:%d\n",
553 	      err, errno);
554 	err = bpf_map_lookup_elem_flags(map_fd, &sk_fd, &lookup_value,
556 	CHECK(!err || errno != ENOENT,
558 	      "err:%d errno:%d\n", err, errno);
559 	err = bpf_map_delete_elem(map_fd, &sk_fd);
560 	CHECK(!err || errno != ENOENT, "bpf_map_delete_elem()",
561 	      "err:%d errno:%d\n", err, errno);
565 	err = bpf_map_create(BPF_MAP_TYPE_SK_STORAGE, "sk_storage_map", 4, 8, 0, &bad_xattr);
566 	CHECK(!err || errno != EINVAL, "bpf_map_create(bad_xattr)",
567 	      "err:%d errno:%d\n", err, errno);
571 	err = bpf_map_create(BPF_MAP_TYPE_SK_STORAGE, "sk_storage_map", 4, 8, 0, &bad_xattr);
572 	CHECK(!err || errno != EINVAL, "bpf_map_create(bad_xattr)",
573 	      "err:%d errno:%d\n", err, errno);
575 	err = bpf_map_create(BPF_MAP_TYPE_SK_STORAGE, "sk_storage_map", 4, 8, 1, &map_opts);
576 	CHECK(!err || errno != EINVAL, "bpf_map_create(bad_xattr)",
577 	      "err:%d errno:%d\n", err, errno);
581 	err = bpf_map_create(BPF_MAP_TYPE_SK_STORAGE, "sk_storage_map", 4, 8, 0, &bad_xattr);
582 	CHECK(!err || errno != EINVAL, "bap_create_map_xattr(bad_xattr)",
583 	      "err:%d errno:%d\n", err, errno);