mirror of
https://github.com/varun-r-mallya/pylibbpf.git
synced 2026-02-12 16:11:00 +00:00
Add src/core/bpf_perf_buffer
This commit is contained in:
28
src/core/bpf_perf_buffer.h
Normal file
28
src/core/bpf_perf_buffer.h
Normal file
@ -0,0 +1,28 @@
|
||||
#ifndef PYLIBBPF_BPF_PERF_BUFFER_H
|
||||
#define PYLIBBPF_BPF_PERF_BUFFER_H
|
||||
|
||||
#include <libbpf.h>
|
||||
#include <pybind11/pybind11.h>
|
||||
#include <pybind11/functional.h>
|
||||
|
||||
namespace py = pybind11;
|
||||
|
||||
class BpfPerfBuffer {
|
||||
private:
|
||||
struct perf_buffer *pb_;
|
||||
py::function callback_;
|
||||
py::function lost_callback_;
|
||||
|
||||
// Static callback wrappers for C API
|
||||
static void sample_callback_wrapper(void *ctx, int cpu, void *data, unsigned int size);
|
||||
static void lost_callback_wrapper(void *ctx, int cpu, unsigned long long cnt);
|
||||
|
||||
public:
|
||||
BpfPerfBuffer(int map_fd, int page_cnt, py::function callback, py::object lost_callback);
|
||||
~BpfPerfBuffer();
|
||||
|
||||
int poll(int timeout_ms);
|
||||
int consume();
|
||||
};
|
||||
|
||||
#endif // PYLIBBPF_BPF_PERF_BUFFER_H
|
||||
Reference in New Issue
Block a user