Merge pull request #1474 from wxnzb/ut_cgroup_skb

feat: add cgroup_skb eBPF program

Author: kmesh-bot

pkg/bpf/factory/factory.go

@@ -19,11 +19,12 @@ package factory
 import "github.com/cilium/ebpf"
 
 type GlobalBpfConfig struct {
-	BpfLogLevel      uint32
-	NodeIP           [16]byte
-	PodGateway       [16]byte
-	AuthzOffload     uint32
-	EnableMonitoring uint32
+	BpfLogLevel          uint32
+	NodeIP               [16]byte
+	PodGateway           [16]byte
+	AuthzOffload         uint32
+	EnableMonitoring     uint32
+	EnablePeriodicReport uint32
 }
 
 type KmeshBpfConfig struct {

test/bpf_ut/Makefile

@@ -30,7 +30,8 @@ all: xdp_shutdown_in_userspace_test.o \
 		xdp_authz_offload_test.o          \
 		workload_sockops_test.o           \
 		tc_mark_encrypt_test.o            \
-		tc_mark_decrypt_test.o
+		tc_mark_decrypt_test.o            \
+		workload_cgroup_skb_test.o       
 
 
 XDP_FLAGS = -I$(ROOT_DIR)/bpf/kmesh/ -I$(ROOT_DIR)/bpf/kmesh/workload/include -I$(ROOT_DIR)/api/v2-c
@@ -47,6 +48,12 @@ tc_mark_encrypt_test.o: tc_mark_encrypt_test.c
 tc_mark_decrypt_test.o: tc_mark_decrypt_test.c
 	$(QUIET) $(CLANG) $(CLANG_FLAGS) $(TC_FLAGS) -c $< -o $@
 
+WORKLOAD_CGROUP_SKB_FLAGS = -I$(ROOT_DIR)/bpf/kmesh/ \
+                            -I$(ROOT_DIR)/bpf/kmesh/probes \
+                            -I$(ROOT_DIR)/bpf/kmesh/workload/include \
+                            -I$(ROOT_DIR)/api/v2-c
+workload_cgroup_skb_test.o: workload_cgroup_skb_test.c
+	$(QUIET) $(CLANG) $(CLANG_FLAGS) $(WORKLOAD_CGROUP_SKB_FLAGS) -c $< -o $@
 clean:
 	$(QUIET) rm -f $(wildcard *.o)
 	$(QUIET) rm -f $(wildcard *.d)

test/bpf_ut/bpftest/bpf_test.go

@@ -234,6 +234,11 @@ func setBpfConfig(t *testing.T, coll *ebpf.Collection, config *factory.GlobalBpf
 			t.Fatalf("failed to set authz_offload: %v", err)
 		}
 	}
+	if v, ok := coll.Variables["enable_periodic_report"]; ok {
+		if err := v.Set(&config.EnablePeriodicReport); err != nil {
+			t.Fatalf("failed to set enable_periodic_report: %v", err)
+		}
+	}
 }
 
 // registerTailCall registers a tail call in the eBPF collection by updating the specified