Function TestCacheConcurrentModule

btf/kernel_test.go:110–137

(t *testing.T)

}

func TestCacheConcurrentModule(t *testing.T) {
	if _, err := os.Stat("/sys/kernel/btf/bpf_testmod"); os.IsNotExist(err) {
		t.Skip("/sys/kernel/btf/bpf_testmod not present")
	}

	const goroutines = 8

	c := NewCache()
	specs := make([]*Spec, goroutines)
	errs := make([]error, goroutines)

	var wg sync.WaitGroup
	wg.Add(goroutines)
	for i := range goroutines {
		go func(i int) {
			defer wg.Done()
			specs[i], errs[i] = c.Module("bpf_testmod")
		}(i)
	}
	wg.Wait()

	for _, err := range errs {
		qt.Assert(t, qt.IsNil(err))
	}
	for i := 1; i < goroutines; i++ {
		qt.Assert(t, qt.Equals(specs[0], specs[i]))
	}
}