cilium#2972: Debug

Signed-off-by: Trung-DV <[email protected]>
Trung-DV · Nov 13, 2024 · cf19ed8 · cf19ed8
1 parent 05e4231
commit cf19ed8
Show file tree

Hide file tree

Showing 128 changed files with 531 additions and 3 deletions.
diff --git a/.github/workflows/vmtests.yml b/.github/workflows/vmtests.yml
@@ -5,7 +5,7 @@ on:
       - 'docs/**'
   push:
     branches:
-      - main
+      - '**'
     paths-ignore:
       - 'docs/**'
 

diff --git a/api/v1/tetragon/types_test.go b/api/v1/tetragon/types_test.go
@@ -10,6 +10,7 @@ import (
 )
 
 func TestResponseIsType(t *testing.T) {
+	t.Skip()
 	ger := GetEventsResponse{
 		Event: &GetEventsResponse_ProcessExec{},
 	}
@@ -20,6 +21,7 @@ func TestResponseIsType(t *testing.T) {
 }
 
 func TestEventIsType(t *testing.T) {
+	t.Skip()
 	event := ProcessExec{}
 
 	assert.True(t, EventType_PROCESS_EXEC.EventIsType(&event))

diff --git a/bpf/tests/prepend_name_test.go b/bpf/tests/prepend_name_test.go
@@ -110,6 +110,7 @@ func NewPrependNameState(t *testing.T, stateMap *ebpf.Map) PrependNameState {
 }
 
 func Test_PrependName(t *testing.T) {
+	t.Skip()
 	// load test program
 	coll, err := ebpf.LoadCollection("objs/prepend_name_test.o")
 	if err != nil {

diff --git a/cmd/tetra/common/utils_test.go b/cmd/tetra/common/utils_test.go
@@ -9,6 +9,7 @@ import (
 )
 
 func TestHumanizeByteCount(t *testing.T) {
+	t.Skip()
 	tests := []struct {
 		input int
 		want  string

diff --git a/cmd/tetra/getevents/getevents_test.go b/cmd/tetra/getevents/getevents_test.go
@@ -14,6 +14,7 @@ import (
 )
 
 func Test_GetEvents_Namespaces(t *testing.T) {
+	t.Skip()
 	t.Run("FilterNothing", func(t *testing.T) {
 		testutils.MockPipedFile(t, testutils.RepoRootPath("testdata/events.json"))
 		cmd := New()
@@ -32,6 +33,7 @@ func Test_GetEvents_Namespaces(t *testing.T) {
 }
 
 func Test_GetEvents_EventTypes(t *testing.T) {
+	t.Skip()
 	t.Run("FilterProcessExec", func(t *testing.T) {
 		testutils.MockPipedFile(t, testutils.RepoRootPath("testdata/events.json"))
 		cmd := New()
@@ -57,6 +59,7 @@ func Test_GetEvents_EventTypes(t *testing.T) {
 }
 
 func Test_GetEvents_Pods(t *testing.T) {
+	t.Skip()
 	t.Run("FilterTie", func(t *testing.T) {
 		testutils.MockPipedFile(t, testutils.RepoRootPath("testdata/events.json"))
 		cmd := New()
@@ -75,6 +78,7 @@ func Test_GetEvents_Pods(t *testing.T) {
 }
 
 func Test_GetEvents_Processes(t *testing.T) {
+	t.Skip()
 	t.Run("FilterNetserver", func(t *testing.T) {
 		testutils.MockPipedFile(t, testutils.RepoRootPath("testdata/events.json"))
 		cmd := New()
@@ -93,6 +97,7 @@ func Test_GetEvents_Processes(t *testing.T) {
 }
 
 func Test_GetEvents_FilterFields(t *testing.T) {
+	t.Skip()
 	t.Run("ExcludeParent", func(t *testing.T) {
 		testutils.MockPipedFile(t, testutils.RepoRootPath("testdata/events.json"))
 		cmd := New()

diff --git a/cmd/tetra/getevents/io_reader_client_test.go b/cmd/tetra/getevents/io_reader_client_test.go
@@ -15,6 +15,7 @@ import (
 )
 
 func Test_ioReaderClient_GetEvents(t *testing.T) {
+	t.Skip()
 	events, err := os.Open(testutils.RepoRootPath("testdata/events.json"))
 	assert.NoError(t, err)
 	client := newIOReaderClient(events, false)

diff --git a/cmd/tetra/probe/probe_test.go b/cmd/tetra/probe/probe_test.go
@@ -13,6 +13,7 @@ import (
 )
 
 func Test_ProbeCommand(t *testing.T) {
+	t.Skip()
 	cmd := New()
 	cmdOutput := &bytes.Buffer{}
 	cmd.SetOut(cmdOutput)

diff --git a/cmd/tetragon/conf_test.go b/cmd/tetragon/conf_test.go
@@ -1142,6 +1142,7 @@ func runTestCases(t *testing.T) {
 }
 
 func TestReadConfigSettings(t *testing.T) {
+	t.Skip()
 	for i, c := range testCases {
 		globalTestIndex = i
 		rootCmd := &cobra.Command{

diff --git a/cmd/tetragon/main_test.go b/cmd/tetragon/main_test.go
@@ -26,6 +26,7 @@ func TestMain(m *testing.M) {
 // when it observer is ready. By that time we should have
 // exec events generated, make sure it's done.
 func TestGeneratedExecEvents(t *testing.T) {
+	t.Skip()
 	ctx, cancel := context.WithCancel(context.Background())
 	ready := func() {
 		cancel()

diff --git a/contrib/tetragon-rthooks/cmd/oci-hook/cel_test.go b/contrib/tetragon-rthooks/cmd/oci-hook/cel_test.go
@@ -22,6 +22,7 @@ func celAllowNamespacesNoError(t *testing.T, vals []string) *celProg {
 }
 
 func TestCel(t *testing.T) {
+	t.Skip()
 	type testCase struct {
 		prog        *celProg
 		expectedVal interface{}

diff --git a/operator/podinfo/podinfo_controller_suite_test.go b/operator/podinfo/podinfo_controller_suite_test.go
@@ -137,5 +137,6 @@ func (suite *ControllerTestSuite) TearDownSuite() {
 }
 
 func TestControllerSuite(t *testing.T) {
+	t.Skip()
 	suite.Run(t, new(ControllerTestSuite))
 }
diff --git a/operator/podinfo/podinfo_controller_test.go b/operator/podinfo/podinfo_controller_test.go
@@ -112,6 +112,7 @@ func randomPodGenerator() *corev1.Pod {
 
 // TestGeneratePod tests if the corresponding podInfo CR generated for a pod is same when using generatePodInfo function
 func TestGeneratePod(t *testing.T) {
+	t.Skip()
 	t.Run("Testing Object Meta", func(t *testing.T) {
 		pod := randomPodGenerator()
 		controller := true
@@ -153,6 +154,7 @@ func TestGeneratePod(t *testing.T) {
 
 // TestHasAllRequiredFields checks if a pod is ready or not.
 func TestHasAllRequiredFields(t *testing.T) {
+	t.Skip()
 	t.Run("Check if all the necessary fields of pod are available", func(t *testing.T) {
 
 		// test ready pod.
@@ -196,6 +198,7 @@ func TestHasAllRequiredFields(t *testing.T) {
 
 // TestEqual checks if controller function checkIfChanged returns true if the Pod is changed and false if it did not change.
 func TestEqual(t *testing.T) {
+	t.Skip()
 	t.Run("Check if the pod and podInfo are different", func(t *testing.T) {
 		// All fields match
 		t.Run("All fields same", func(*testing.T) {
@@ -284,6 +287,7 @@ func TestEqual(t *testing.T) {
 }
 
 func TestReconcile(t *testing.T) {
+	t.Skip()
 	pod := randomPodGenerator()
 	client := getClientBuilder().WithObjects(pod).Build()
 	reconciler := Reconciler{client}
@@ -295,6 +299,7 @@ func TestReconcile(t *testing.T) {
 }
 
 func TestReconcileWithDeletionTimestamp(t *testing.T) {
+	t.Skip()
 	pod := randomPodGenerator()
 	pod.SetFinalizers([]string{"finalize-it"})
 	deletionTimestamp := metav1.Now()

diff --git a/pkg/aggregator/aggregator_test.go b/pkg/aggregator/aggregator_test.go
@@ -10,6 +10,7 @@ import (
 )
 
 func Test_getNameOrIp(t *testing.T) {
+	t.Skip()
 	assert.Equal(t, "1.1.1.1", getNameOrIp("1.1.1.1", []string{}))
 	assert.Equal(t, "a.com,b.com,c.com", getNameOrIp("1.1.1.1", []string{"b.com", "c.com", "a.com"}))
 }
diff --git a/pkg/alignchecker/alignchecker_test.go b/pkg/alignchecker/alignchecker_test.go
@@ -25,6 +25,7 @@ func init() {
 }
 
 func Test_Alignments(t *testing.T) {
+	t.Skip()
 	bpfObjPath := filepath.Join(tetragonLib, "bpf_alignchecker.o")
 
 	err := CheckStructAlignments(bpfObjPath)

diff --git a/pkg/api/ops/ops_test.go b/pkg/api/ops/ops_test.go
@@ -8,6 +8,7 @@ import (
 )
 
 func TestCgroupOpCode(t *testing.T) {
+	t.Skip()
 	testcases := map[CgroupOpCode]string{
 		MSG_OP_CGROUP_UNDEF:       "Undef",
 		MSG_OP_CGROUP_MKDIR:       "CgroupMkdir",
@@ -24,6 +25,7 @@ func TestCgroupOpCode(t *testing.T) {
 }
 
 func TestCgroupState(t *testing.T) {
+	t.Skip()
 	testcases := map[CgroupState]string{
 		CGROUP_UNTRACKED:    "Untracked",
 		CGROUP_NEW:          "New",

diff --git a/pkg/arch/arch_test.go b/pkg/arch/arch_test.go
@@ -10,6 +10,7 @@ import (
 )
 
 func Test_addSyscallPrefix(t *testing.T) {
+	t.Skip()
 	symbol := "sys_test"
 	arch := "test64"
 	supportedArchPrefix[arch] = "__test64_"

diff --git a/pkg/bpf/maps_test.go b/pkg/bpf/maps_test.go
@@ -28,6 +28,7 @@ func Benchmark_parseMemlockFromFDInfoReader(b *testing.B) {
 }
 
 func Test_parseMemlockFromFDInfoReader(t *testing.T) {
+	t.Skip()
 	tests := []struct {
 		name    string
 		args    io.Reader

diff --git a/pkg/btf/btf_test.go b/pkg/btf/btf_test.go
@@ -41,6 +41,7 @@ func setupfiles() func(*testing.T, string, ...string) {
 }
 
 func TestObserverFindBTF(t *testing.T) {
+	t.Skip()
 	tmpdir := t.TempDir()
 
 	old := os.Getenv("TETRAGON_BTF")
@@ -78,6 +79,7 @@ func TestObserverFindBTF(t *testing.T) {
 }
 
 func TestObserverFindBTFEnv(t *testing.T) {
+	t.Skip()
 	old := os.Getenv("TETRAGON_BTF")
 	defer os.Setenv("TETRAGON_BTF", old)
 
@@ -142,6 +144,7 @@ func TestObserverFindBTFEnv(t *testing.T) {
 }
 
 func TestInitCachedBTF(t *testing.T) {
+	t.Skip()
 	_, err := os.Stat(defaults.DefaultBTFFile)
 	if err != nil {
 		btffile := os.Getenv("TETRAGON_BTF")

diff --git a/pkg/btf/validation_test.go b/pkg/btf/validation_test.go
@@ -49,6 +49,7 @@ var testFiles = []struct {
 }
 
 func TestSpecs(t *testing.T) {
+	t.Skip()
 	_, testFname, _, _ := runtime.Caller(0)
 	testdataPath := filepath.Join(filepath.Dir(testFname), "..", "..", "testdata")
 
@@ -82,6 +83,7 @@ func TestSpecs(t *testing.T) {
 }
 
 func TestEnum(t *testing.T) {
+	t.Skip()
 	require.Equal(t,
 		getKernelType(&btf.Enum{
 			Size:   2,

diff --git a/pkg/bugtool/bugtool_test.go b/pkg/bugtool/bugtool_test.go
@@ -14,6 +14,7 @@ import (
 )
 
 func TestSaveAndLoad(t *testing.T) {
+	t.Skip()
 
 	tmpFile, err := os.CreateTemp(t.TempDir(), "tetragon-bugtool-test-")
 	if err != nil {
@@ -46,6 +47,7 @@ func TestSaveAndLoad(t *testing.T) {
 }
 
 func Test_findCgroupMountPath(t *testing.T) {
+	t.Skip()
 	const cgroupMountsHybrid = `tmpfs /sys/fs/cgroup tmpfs ro,nosuid,nodev,noexec,mode=755 0 0
 cgroup2 /sys/fs/cgroup/unified cgroup2 rw,nosuid,nodev,noexec,relatime,nsdelegate 0 0
 cgroup /sys/fs/cgroup/systemd cgroup rw,nosuid,nodev,noexec,relatime,xattr,name=systemd 0 0
@@ -150,6 +152,7 @@ bpf /sys/fs/bpf bpf rw,nosuid,nodev,noexec,relatime,mode=700 0 0`
 }
 
 func Test_findMemoryCgroupPath(t *testing.T) {
+	t.Skip()
 	tests := []struct {
 		name    string
 		args    io.Reader

diff --git a/pkg/bugtool/maps_test.go b/pkg/bugtool/maps_test.go
@@ -20,6 +20,7 @@ func TestMain(m *testing.M) {
 }
 
 func TestFindMaps(t *testing.T) {
+	t.Skip()
 	t.Run("NoSuchFile", func(t *testing.T) {
 		const path = "/sys/fs/bpf/nosuchfile"
 		_, err := FindPinnedMaps(path)

diff --git a/pkg/bugtool/multilog_test.go b/pkg/bugtool/multilog_test.go
@@ -11,6 +11,7 @@ import (
 )
 
 func TestMultiLog(t *testing.T) {
+	t.Skip()
 
 	fmt := logrus.TextFormatter{
 		DisableColors:    true,

diff --git a/pkg/cgrouprate/cgrouprate_test.go b/pkg/cgrouprate/cgrouprate_test.go
@@ -54,6 +54,7 @@ type testData struct {
 }
 
 func TestProcessCgroup(t *testing.T) {
+	t.Skip()
 	key := processapi.CgroupRateKey{
 		Id: 123,
 	}
@@ -260,6 +261,7 @@ func TestProcessCgroup(t *testing.T) {
 }
 
 func TestParseCgroupRate(t *testing.T) {
+	t.Skip()
 	var opt option.CgroupRate
 
 	// ok

diff --git a/pkg/cgroups/cgroups_test.go b/pkg/cgroups/cgroups_test.go
@@ -46,6 +46,7 @@ func isDirMountFsType(path string, mntType string) (bool, error) {
 }
 
 func TestCgroupNameFromCStr(t *testing.T) {
+	t.Skip()
 	type progTest struct {
 		in   []byte
 		want string
@@ -104,6 +105,7 @@ func TestCgroupNameFromCStr(t *testing.T) {
 
 // Ensure that Cgroupv1 controllers discovery fails if no 'cpuset' and no 'memory'
 func TestParseCgroupSubSysIdsWithoutMemoryCpuset(t *testing.T) {
+	t.Skip()
 	testDir := t.TempDir()
 	invalid_cgroupv1_controllers :=
 		`
@@ -123,6 +125,7 @@ perf_event	8	2	1
 }
 
 func TestParseCgroupSubSysIds(t *testing.T) {
+	t.Skip()
 
 	testDir := t.TempDir()
 
@@ -165,6 +168,7 @@ misc	10	1	1
 }
 
 func TestCheckCgroupv2Controllers(t *testing.T) {
+	t.Skip()
 	testDir := t.TempDir()
 	empty_controllers := ""
 
@@ -185,13 +189,15 @@ func TestCheckCgroupv2Controllers(t *testing.T) {
 
 // Test cgroup mode detection on an invalid directory
 func TestDetectCgroupModeInvalid(t *testing.T) {
+	t.Skip()
 	mode, err := detectCgroupMode("invalid-cgroupfs-path")
 	assert.Error(t, err)
 	assert.Equal(t, CGROUP_UNDEF, mode)
 }
 
 // Test cgroup mode detection on default cgroup root /sys/fs/cgroup
 func TestDetectCgroupModeDefault(t *testing.T) {
+	t.Skip()
 	var st syscall.Statfs_t
 
 	err := syscall.Statfs(defaultCgroupRoot, &st)
@@ -225,6 +231,7 @@ func TestDetectCgroupModeDefault(t *testing.T) {
 
 // Test cgroup mode detection on our custom location /run/tetragon/cgroup2
 func TestDetectCgroupModeCustomLocation(t *testing.T) {
+	t.Skip()
 	// We also mount cgroup2 on /run/tetragon/cgroup2 let's test it
 	mounted, err := isDirMountFsType(defaults.Cgroup2Dir, mountinfo.FilesystemTypeCgroup2)
 	assert.NoError(t, err)
@@ -246,6 +253,7 @@ func TestDetectCgroupModeCustomLocation(t *testing.T) {
 // calls to DetectCgroupMode() will just return cgroupMode, so ensure
 // they are properly set.
 func TestDetectCgroupMode(t *testing.T) {
+	t.Skip()
 	mode, err := DetectCgroupMode()
 	assert.NoError(t, err)
 	assert.NotEqual(t, CGROUP_UNDEF, mode)
@@ -260,6 +268,7 @@ func TestDetectCgroupMode(t *testing.T) {
 //
 // TODO Setup multiple cgroupv1 and cgroupv2 combinations
 func TestDetectCgroupFSMagic(t *testing.T) {
+	t.Skip()
 	fs, err := DetectCgroupFSMagic()
 	assert.NoError(t, err)
 	assert.NotEqual(t, CGROUP_UNDEF, fs)
@@ -288,6 +297,7 @@ func TestDetectCgroupFSMagic(t *testing.T) {
 // - Their hierarchy IDs
 // - Their css index
 func TestDiscoverCgroupv1SubSysIdsDefault(t *testing.T) {
+	t.Skip()
 	fs, err := DetectCgroupFSMagic()
 	assert.NoError(t, err)
 	assert.NotEqual(t, CGROUP_UNDEF, fs)
@@ -327,6 +337,7 @@ func TestDiscoverCgroupv1SubSysIdsDefault(t *testing.T) {
 }
 
 func TestGetCgroupIdFromPath(t *testing.T) {
+	t.Skip()
 	mode, err := DetectCgroupMode()
 	assert.NoError(t, err)
 	assert.NotEqual(t, CGROUP_UNDEF, mode)