42 static void ringbuf_unmap_ring(struct ring_buffer *rb, struct ring *r)  in ringbuf_unmap_ring()  argument
45 		munmap(r->consumer_pos, rb->page_size);  in ringbuf_unmap_ring()
49 		munmap(r->producer_pos, rb->page_size + 2 * (r->mask + 1));  in ringbuf_unmap_ring()
55 int ring_buffer__add(struct ring_buffer *rb, int map_fd,  in ring_buffer__add()  argument
82 	tmp = libbpf_reallocarray(rb->rings, rb->ring_cnt + 1, sizeof(*rb->rings));  in ring_buffer__add()
85 	rb->rings = tmp;  in ring_buffer__add()
87 	tmp = libbpf_reallocarray(rb->events, rb->ring_cnt + 1, sizeof(*rb->events));  in ring_buffer__add()
90 	rb->events = tmp;  in ring_buffer__add()
92 	r = &rb->rings[rb->ring_cnt];  in ring_buffer__add()
101 	tmp = mmap(NULL, rb->page_size, PROT_READ | PROT_WRITE, MAP_SHARED, map_fd, 0);  in ring_buffer__add()
114 	mmap_sz = rb->page_size + 2 * (__u64)info.max_entries;  in ring_buffer__add()
119 	tmp = mmap(NULL, (size_t)mmap_sz, PROT_READ, MAP_SHARED, map_fd, rb->page_size);  in ring_buffer__add()
122 		ringbuf_unmap_ring(rb, r);  in ring_buffer__add()
128 	r->data = tmp + rb->page_size;  in ring_buffer__add()
130 	e = &rb->events[rb->ring_cnt];  in ring_buffer__add()
134 	e->data.fd = rb->ring_cnt;  in ring_buffer__add()
135 	if (epoll_ctl(rb->epoll_fd, EPOLL_CTL_ADD, map_fd, e) < 0) {  in ring_buffer__add()
137 		ringbuf_unmap_ring(rb, r);  in ring_buffer__add()
143 	rb->ring_cnt++;  in ring_buffer__add()
147 void ring_buffer__free(struct ring_buffer *rb)  in ring_buffer__free()  argument
151 	if (!rb)  in ring_buffer__free()
154 	for (i = 0; i < rb->ring_cnt; ++i)  in ring_buffer__free()
155 		ringbuf_unmap_ring(rb, &rb->rings[i]);  in ring_buffer__free()
156 	if (rb->epoll_fd >= 0)  in ring_buffer__free()
157 		close(rb->epoll_fd);  in ring_buffer__free()
159 	free(rb->events);  in ring_buffer__free()
160 	free(rb->rings);  in ring_buffer__free()
161 	free(rb);  in ring_buffer__free()
168 	struct ring_buffer *rb;  in ring_buffer__new()  local
174 	rb = calloc(1, sizeof(*rb));  in ring_buffer__new()
175 	if (!rb)  in ring_buffer__new()
178 	rb->page_size = getpagesize();  in ring_buffer__new()
180 	rb->epoll_fd = epoll_create1(EPOLL_CLOEXEC);  in ring_buffer__new()
181 	if (rb->epoll_fd < 0) {  in ring_buffer__new()
187 	err = ring_buffer__add(rb, map_fd, sample_cb, ctx);  in ring_buffer__new()
191 	return rb;  in ring_buffer__new()
194 	ring_buffer__free(rb);  in ring_buffer__new()
257 int ring_buffer__consume(struct ring_buffer *rb)  in ring_buffer__consume()  argument
262 	for (i = 0; i < rb->ring_cnt; i++) {  in ring_buffer__consume()
263 		struct ring *ring = &rb->rings[i];  in ring_buffer__consume()
279 int ring_buffer__poll(struct ring_buffer *rb, int timeout_ms)  in ring_buffer__poll()  argument
284 	cnt = epoll_wait(rb->epoll_fd, rb->events, rb->ring_cnt, timeout_ms);  in ring_buffer__poll()
289 		__u32 ring_id = rb->events[i].data.fd;  in ring_buffer__poll()
290 		struct ring *ring = &rb->rings[ring_id];  in ring_buffer__poll()