Home
last modified time | relevance | path

Searched refs:cons_pos (Results 1 – 5 of 5) sorted by relevance

/linux-6.15/kernel/bpf/
H A Dringbuf.c298 unsigned long cons_pos, prod_pos; in ringbuf_avail_data_sz() local
300 cons_pos = smp_load_acquire(&rb->consumer_pos); in ringbuf_avail_data_sz()
302 return prod_pos - cons_pos; in ringbuf_avail_data_sz()
418 cons_pos = smp_load_acquire(&rb->consumer_pos); in __bpf_ringbuf_reserve()
444 if (new_prod_pos - cons_pos > rb->mask || in __bpf_ringbuf_reserve()
484 unsigned long rec_pos, cons_pos; in bpf_ringbuf_commit() local
502 cons_pos = smp_load_acquire(&rb->consumer_pos) & rb->mask; in bpf_ringbuf_commit()
673 u64 cons_pos, prod_pos; in __bpf_user_ringbuf_peek() local
681 cons_pos = smp_load_acquire(&rb->consumer_pos); in __bpf_user_ringbuf_peek()
682 if (cons_pos >= prod_pos) in __bpf_user_ringbuf_peek()
[all …]
/linux-6.15/tools/lib/bpf/
H A Dringbuf.c240 unsigned long cons_pos, prod_pos; in ringbuf_process_ring() local
244 cons_pos = smp_load_acquire(r->consumer_pos); in ringbuf_process_ring()
248 while (cons_pos < prod_pos) { in ringbuf_process_ring()
249 len_ptr = r->data + (cons_pos & r->mask); in ringbuf_process_ring()
257 cons_pos += roundup_len(len); in ringbuf_process_ring()
265 cons_pos); in ringbuf_process_ring()
271 smp_store_release(r->consumer_pos, cons_pos); in ringbuf_process_ring()
390 unsigned long cons_pos, prod_pos; in ring__avail_data_size() local
392 cons_pos = ring__consumer_pos(r); in ring__avail_data_size()
394 return prod_pos - cons_pos; in ring__avail_data_size()
[all …]
/linux-6.15/tools/testing/selftests/bpf/prog_tests/
H A Dringbuf.c151 unsigned long avail_data, ring_size, cons_pos, prod_pos; in ringbuf_subtest() local
237 CHECK(skel->bss->cons_pos != 0, in ringbuf_subtest()
239 0L, skel->bss->cons_pos); in ringbuf_subtest()
251 cons_pos = ring__consumer_pos(ring); in ringbuf_subtest()
252 ASSERT_EQ(cons_pos, 0, "ring_cons_pos"); in ringbuf_subtest()
281 CHECK(skel->bss->cons_pos != 3 * rec_sz, in ringbuf_subtest()
283 3L * rec_sz, skel->bss->cons_pos); in ringbuf_subtest()
/linux-6.15/tools/testing/selftests/bpf/progs/
H A Dtest_ringbuf.c33 long cons_pos = 0; variable
73 cons_pos = bpf_ringbuf_query(&ringbuf, BPF_RB_CONS_POS); in test_ringbuf()
/linux-6.15/tools/testing/selftests/bpf/benchs/
H A Dbench_ringbufs.c297 unsigned long cons_pos, prod_pos; in ringbuf_custom_process_ring() local
301 cons_pos = smp_load_acquire(r->consumer_pos); in ringbuf_custom_process_ring()
305 while (cons_pos < prod_pos) { in ringbuf_custom_process_ring()
306 len_ptr = r->data + (cons_pos & r->mask); in ringbuf_custom_process_ring()
314 cons_pos += roundup_len(len); in ringbuf_custom_process_ring()
319 smp_store_release(r->consumer_pos, cons_pos); in ringbuf_custom_process_ring()