1 // SPDX-License-Identifier: GPL-2.0
47 	switch (s->seq) {  in process_sample()
49 		CHECK(s->value != 333, "sample1_value", "exp %ld, got %ld\n",  in process_sample()
50 		      333L, s->value);  in process_sample()
53 		CHECK(s->value != 777, "sample2_value", "exp %ld, got %ld\n",  in process_sample()
54 		      777L, s->value);  in process_sample()
55 		return -EDONE;  in process_sample()
68 	skel->bss->dropped = 0;  in trigger_samples()
69 	skel->bss->total = 0;  in trigger_samples()
70 	skel->bss->discarded = 0;  in trigger_samples()
73 	skel->bss->value = 333;  in trigger_samples()
75 	skel->bss->value = 777;  in trigger_samples()
81 	long timeout = (long)input;  in poll_thread()  local
83 	return (void *)(long)ring_buffer__poll(ringbuf, timeout);  in poll_thread()
90 	long bg_ret = -1;  in ringbuf_subtest()
99 	skel->maps.ringbuf.max_entries = page_size;  in ringbuf_subtest()
105 	rb_fd = skel->maps.ringbuf.map_fd;  in ringbuf_subtest()
117 	err = -errno;  in ringbuf_subtest()
119 	ASSERT_EQ(err, -EPERM, "wr_prod_pos_err");  in ringbuf_subtest()
123 	err = -errno;  in ringbuf_subtest()
125 	ASSERT_EQ(err, -EPERM, "wr_data_page_one_err");  in ringbuf_subtest()
131 	/* good read-only pages */  in ringbuf_subtest()
141 	/* good read-only pages with initial offset */  in ringbuf_subtest()
152 	skel->bss->pid = getpid();  in ringbuf_subtest()
154 	ringbuf = ring_buffer__new(skel->maps.ringbuf.map_fd,  in ringbuf_subtest()
166 	CHECK(skel->bss->avail_data != 3 * rec_sz,  in ringbuf_subtest()
168 	      3L * rec_sz, skel->bss->avail_data);  in ringbuf_subtest()
169 	CHECK(skel->bss->ring_size != page_size,  in ringbuf_subtest()
171 	      (long)page_size, skel->bss->ring_size);  in ringbuf_subtest()
172 	CHECK(skel->bss->cons_pos != 0,  in ringbuf_subtest()
174 	      0L, skel->bss->cons_pos);  in ringbuf_subtest()
175 	CHECK(skel->bss->prod_pos != 3 * rec_sz,  in ringbuf_subtest()
177 	      3L * rec_sz, skel->bss->prod_pos);  in ringbuf_subtest()
180 	err = ring_buffer__poll(ringbuf, -1);  in ringbuf_subtest()
182 	/* -EDONE is used as an indicator that we are done */  in ringbuf_subtest()
183 	if (CHECK(err != -EDONE, "err_done", "done err: %d\n", err))  in ringbuf_subtest()
195 	CHECK(skel->bss->dropped != 0, "err_dropped", "exp %ld, got %ld\n",  in ringbuf_subtest()
196 	      0L, skel->bss->dropped);  in ringbuf_subtest()
197 	CHECK(skel->bss->total != 2, "err_total", "exp %ld, got %ld\n",  in ringbuf_subtest()
198 	      2L, skel->bss->total);  in ringbuf_subtest()
199 	CHECK(skel->bss->discarded != 1, "err_discarded", "exp %ld, got %ld\n",  in ringbuf_subtest()
200 	      1L, skel->bss->discarded);  in ringbuf_subtest()
204 	CHECK(skel->bss->cons_pos != 3 * rec_sz,  in ringbuf_subtest()
206 	      3L * rec_sz, skel->bss->cons_pos);  in ringbuf_subtest()
207 	err = ring_buffer__poll(ringbuf, -1);  in ringbuf_subtest()
212 	/* start poll in background w/ long timeout */  in ringbuf_subtest()
218 	skel->bss->flags = BPF_RB_NO_WAKEUP;  in ringbuf_subtest()
233 	CHECK(skel->bss->dropped != 0, "err_dropped", "exp %ld, got %ld\n",  in ringbuf_subtest()
234 	      0L, skel->bss->dropped);  in ringbuf_subtest()
235 	CHECK(skel->bss->total != 2, "err_total", "exp %ld, got %ld\n",  in ringbuf_subtest()
236 	      2L, skel->bss->total);  in ringbuf_subtest()
237 	CHECK(skel->bss->discarded != 1, "err_discarded", "exp %ld, got %ld\n",  in ringbuf_subtest()
238 	      1L, skel->bss->discarded);  in ringbuf_subtest()
243 	skel->bss->flags = 0;  in ringbuf_subtest()
259 	skel->bss->dropped = 0;  in ringbuf_subtest()
260 	skel->bss->total = 0;  in ringbuf_subtest()
261 	skel->bss->discarded = 0;  in ringbuf_subtest()
263 	skel->bss->value = 333;  in ringbuf_subtest()
266 	skel->bss->flags = BPF_RB_FORCE_WAKEUP;  in ringbuf_subtest()
267 	skel->bss->value = 777;  in ringbuf_subtest()
279 	/* due to timing variations, there could still be non-notified  in ringbuf_subtest()
290 	CHECK(skel->bss->dropped != 0, "err_dropped", "exp %ld, got %ld\n",  in ringbuf_subtest()
291 	      0L, skel->bss->dropped);  in ringbuf_subtest()
292 	CHECK(skel->bss->total != 2, "err_total", "exp %ld, got %ld\n",  in ringbuf_subtest()
293 	      2L, skel->bss->total);  in ringbuf_subtest()
294 	CHECK(skel->bss->discarded != 1, "err_discarded", "exp %ld, got %ld\n",  in ringbuf_subtest()
295 	      1L, skel->bss->discarded);  in ringbuf_subtest()
309 	switch (s->seq) {  in process_map_key_sample()
311 		ASSERT_EQ(s->value, 42, "sample_value");  in process_map_key_sample()
312 		err = bpf_map_lookup_elem(skel_map_key->maps.hash_map.map_fd,  in process_map_key_sample()
316 		return -EDONE;  in process_map_key_sample()
330 	skel_map_key->maps.ringbuf.max_entries = getpagesize();  in ringbuf_map_key_subtest()
331 	skel_map_key->bss->pid = getpid();  in ringbuf_map_key_subtest()
337 	ringbuf = ring_buffer__new(skel_map_key->maps.ringbuf.map_fd,  in ringbuf_map_key_subtest()
347 	ASSERT_EQ(skel_map_key->bss->seq, 1, "skel_map_key->bss->seq");  in ringbuf_map_key_subtest()
348 	err = ring_buffer__poll(ringbuf, -1);  in ringbuf_map_key_subtest()
349 	ASSERT_EQ(err, -EDONE, "ring_buffer__poll");  in ringbuf_map_key_subtest()