mirror of
https://github.com/varun-r-mallya/pylibbpf.git
synced 2026-02-11 07:30:56 +00:00
Add basic userspace support for struct value type for maps
This commit is contained in:
@ -65,6 +65,10 @@ PYBIND11_MODULE(pylibbpf, m) {
|
||||
.def("get_key_size", &BpfMap::get_key_size)
|
||||
.def("get_value_size", &BpfMap::get_value_size)
|
||||
.def("get_max_entries", &BpfMap::get_max_entries)
|
||||
.def("set_value_struct", &BpfMap::set_value_struct,
|
||||
py::arg("struct_name"))
|
||||
.def("get_value_struct_name", &BpfMap::get_value_struct_name)
|
||||
.def("has_struct_value", &BpfMap::has_struct_value)
|
||||
.def("__getitem__", &BpfMap::lookup, py::arg("key"))
|
||||
.def("__setitem__", &BpfMap::update, py::arg("key"), py::arg("value"))
|
||||
.def("__delitem__", &BpfMap::delete_elem, py::arg("key"));
|
||||
|
||||
@ -25,6 +25,24 @@ BpfMap::BpfMap(std::shared_ptr<BpfObject> parent, struct bpf_map *raw_map,
|
||||
value_size_ = bpf_map__value_size(map_);
|
||||
}
|
||||
|
||||
void BpfMap::set_value_struct(const std::string &struct_name) {
|
||||
auto parent = parent_obj_.lock();
|
||||
if (!parent) {
|
||||
throw BpfException("Parent BpfObject no longer exists");
|
||||
}
|
||||
|
||||
struct_parser_ = parent->get_struct_parser();
|
||||
if (!struct_parser_) {
|
||||
throw BpfException("No struct definitions available in BpfObject");
|
||||
}
|
||||
|
||||
if (!struct_parser_->has_struct(struct_name)) {
|
||||
throw BpfException("Unknown struct: " + struct_name);
|
||||
}
|
||||
|
||||
value_struct_name_ = struct_name;
|
||||
}
|
||||
|
||||
py::object BpfMap::lookup(const py::object &key) const {
|
||||
if (map_fd_ < 0)
|
||||
throw BpfException("Map '" + map_name_ + "' is not initialized properly");
|
||||
@ -216,6 +234,12 @@ void BpfMap::python_to_bytes_inplace(const py::object &obj,
|
||||
}
|
||||
|
||||
py::object BpfMap::bytes_to_python(std::span<const uint8_t> data) {
|
||||
// NOTE: Struct parsing for value type
|
||||
if (struct_parser_ && !value_struct_name_.empty()) {
|
||||
py::bytes py_data(reinterpret_cast<const char *>(data.data()), data.size());
|
||||
return struct_parser_->parse(value_struct_name_, py_data);
|
||||
}
|
||||
|
||||
if (data.size() == 4) {
|
||||
uint32_t value;
|
||||
std::memcpy(&value, data.data(), 4);
|
||||
|
||||
@ -9,6 +9,7 @@
|
||||
#include <vector>
|
||||
|
||||
class BpfObject;
|
||||
class StructParser;
|
||||
|
||||
namespace py = pybind11;
|
||||
|
||||
@ -20,6 +21,11 @@ private:
|
||||
std::string map_name_;
|
||||
__u32 key_size_, value_size_;
|
||||
|
||||
// TODO: For now, we'll only support struct parsing for value types
|
||||
// later we can extend this to keys
|
||||
std::shared_ptr<StructParser> struct_parser_;
|
||||
std::string value_struct_name_;
|
||||
|
||||
template <size_t StackSize = 64> struct BufferManager {
|
||||
std::array<uint8_t, StackSize> stack_buf;
|
||||
std::vector<uint8_t> heap_buf;
|
||||
@ -52,6 +58,7 @@ public:
|
||||
py::dict items() const;
|
||||
py::list keys() const;
|
||||
py::list values() const;
|
||||
void set_value_struct(const std::string &struct_name);
|
||||
|
||||
[[nodiscard]] std::string get_name() const { return map_name_; }
|
||||
[[nodiscard]] int get_fd() const { return map_fd_; }
|
||||
@ -62,6 +69,12 @@ public:
|
||||
[[nodiscard]] std::shared_ptr<BpfObject> get_parent() const {
|
||||
return parent_obj_.lock();
|
||||
}
|
||||
[[nodiscard]] std::string get_value_struct_name() const {
|
||||
return value_struct_name_;
|
||||
}
|
||||
[[nodiscard]] bool has_struct_value() const {
|
||||
return !value_struct_name_.empty();
|
||||
}
|
||||
|
||||
private:
|
||||
static void python_to_bytes_inplace(const py::object &obj,
|
||||
|
||||
Reference in New Issue
Block a user