bpf/prog_tests/ringbuf.c

92 	int err, cnt, rb_fd;
105 	err = test_ringbuf_lskel__load(skel);
106 	if (CHECK(err != 0, "skel_load", "skeleton load failed\n"))
121 	err = -errno;
123 	ASSERT_EQ(err, -EPERM, "wr_prod_pos_err");
127 	err = -errno;
129 	ASSERT_EQ(err, -EPERM, "wr_data_page_one_err");
163 	err = test_ringbuf_lskel__attach(skel);
164 	if (CHECK(err, "skel_attach", "skeleton attachment failed: %d\n", err))
203 	err = ring_buffer__poll(ringbuf, -1);
206 	if (CHECK(err != -EDONE, "err_done", "done err: %d\n", err))
212 	err = ring_buffer__poll(ringbuf, 0);
213 	if (CHECK(err != 0, "extra_samples", "poll result: %d\n", err))
230 	err = ring_buffer__poll(ringbuf, -1);
231 	CHECK(err <= 0, "poll_err", "err %d\n", err);
236 	err = pthread_create(&thread, NULL, poll_thread, (void *)(long)10000);
237 	if (CHECK(err, "bg_poll", "pthread_create failed: %d\n", err))
251 	err = pthread_tryjoin_np(thread, (void **)&bg_ret);
252 	if (CHECK(err != EBUSY, "try_join", "err %d\n", err))
274 	err = pthread_tryjoin_np(thread, (void **)&bg_ret);
275 	if (CHECK(err != EBUSY, "try_join", "err %d\n", err))
295 	err = pthread_tryjoin_np(thread, (void **)&bg_ret);
296 	if (CHECK(err, "join_bg", "err %d\n", err))
305 	err = ring_buffer__consume(ringbuf);
306 	CHECK(err < 0, "rb_consume", "failed: %d\b", err);
309 	err = ring__consume(ring);
310 	ASSERT_GE(err, 0, "ring_consume");
352 	int err, i;
361 	err = test_ringbuf_n_lskel__load(skel_n);
362 	if (!ASSERT_OK(err, "test_ringbuf_n_lskel__load"))
370 	err = test_ringbuf_n_lskel__attach(skel_n);
371 	if (!ASSERT_OK(err, "test_ringbuf_n_lskel__attach"))
380 	for (i = 0; i < N_TOT_SAMPLES; i += err) {
381 		err = ring_buffer__consume_n(ringbuf, N_SAMPLES);
382 		if (!ASSERT_EQ(err, N_SAMPLES, "rb_consume"))
395 	int err, val;
401 		err = bpf_map_lookup_elem(skel_map_key->maps.hash_map.map_fd,
403 		ASSERT_OK(err, "hash_map bpf_map_lookup_elem");
413 	int err;
422 	err = test_ringbuf_map_key_lskel__load(skel_map_key);
423 	if (!ASSERT_OK(err, "test_ringbuf_map_key_lskel__load"))
431 	err = test_ringbuf_map_key_lskel__attach(skel_map_key);
432 	if (!ASSERT_OK(err, "test_ringbuf_map_key_lskel__attach"))
437 	err = ring_buffer__poll(ringbuf, -1);
438 	ASSERT_EQ(err, -EDONE, "ring_buffer__poll");