我觀察到,如果我在尾部程序中寫入環形緩沖區并從用戶空間讀取環形緩沖區,尾部程序最終會被刪除。尾部程序不再出現在bpftool prog. bpftool map dump name jump_table說它Found 0 elements;它最初有 1 個元素,尾部程序。這個 BPF 程序由main_prog調用一個尾部程序組成。尾部程序寫入0環形緩沖區。#include <linux/bpf.h>#include <bpf/bpf_helpers.h>struct bpf_map_def SEC("maps") flow_ring_buf = { .type = BPF_MAP_TYPE_RINGBUF, .max_entries = 1<<12};struct bpf_map_def SEC("maps") jump_table = { .type = BPF_MAP_TYPE_PROG_ARRAY, .key_size = sizeof(__u32), .value_size = sizeof(__u32), .max_entries = 1,};SEC("xdp")int main_prog(struct xdp_md *ctx) { bpf_tail_call(ctx, &jump_table, 0); bpf_printk("Tail call failed"); return XDP_PASS;}SEC("xdp_2")int tail_prog(struct xdp_md *ctx) { __u32 num = 0; bpf_ringbuf_output(&flow_ring_buf, &num, sizeof(__u32), 0); return XDP_PASS;}char _license[] SEC("license") = "GPL";這個 Go 程序加載程序和映射并從環形緩沖區讀?。簆ackage mainimport "C"import ( "errors" "github.com/cilium/ebpf" "github.com/cilium/ebpf/ringbuf" "github.com/vishvananda/netlink" "log")type bpfObjects struct { MainProg *ebpf.Program `ebpf:"main_prog"` TailProg *ebpf.Program `ebpf:"tail_prog"` JumpTable *ebpf.Map `ebpf:"jump_table"` FlowRingBuf *ebpf.Map `ebpf:"flow_ring_buf"`}func main() { var objects bpfObjects spec, err := ebpf.LoadCollectionSpec("test.o") if err != nil { log.Fatalln("ebpf.LoadCollectionSpec", err) } if err := spec.LoadAndAssign(&objects, nil); err != nil { log.Fatalln("ebpf.LoadAndAssign", err) } // Update the jump table with the tail prog if err = objects.JumpTable.Update(uint32(0), uint32(objects.TailProg.FD()), ebpf.UpdateAny); err != nil { log.Fatalln("Update prog_array", err) } link, err := netlink.LinkByName("enp0s8") if err != nil { log.Fatalln("netlink.LinkByName", err) }當我向接口發送流量時遇到了問題。reader.Read()從不返回錯誤并且返回的Record對象有0. 因為跳轉表是空的,所以尾調用失敗,我bpf_printk在內核日志中看到了輸出。如果注釋掉下面的代碼A并將其替換為無限等待,例如select {},我不會遇到問題
1 回答

慕勒3428872
TA貢獻1848條經驗 獲得超6個贊
發生這種情況是因為objects.JumpTable在主程序循環運行時正在收集垃圾。刪除引用后,地圖將取消jump_table固定。解決方法是defer objects.JumpTable.Close()調用后做LoadAndAssign()。或添加此代碼
func (o *bpfObjects) Close() {
o.MainProg.Close()
o.TailProg.Close()
o.JumpTable.Close()
o.FlowRingBuf.Close()
}
并在調用defer objects.Close()后調用LoadAndAssign()。這在 C 版本中不會發生,因為沒有垃圾收集。
- 1 回答
- 0 關注
- 142 瀏覽
添加回答
舉報
0/150
提交
取消