Function FuzzContainerdImport

contrib/fuzz/containerd_import_fuzz_test.go:34–65

(f *testing.F)

}

func FuzzContainerdImport(f *testing.F) {
	if os.Getuid() != 0 {
		f.Skip("skipping fuzz test that requires root")
	}

	f.Fuzz(func(t *testing.T, data []byte) {
		initDaemon.Do(startDaemon)

		client, err := containerd.New(defaultAddress)
		if err != nil {
			t.Fatal(err)
		}
		defer client.Close()

		f := fuzz.NewConsumer(data)

		noOfImports, err := f.GetInt()
		if err != nil {
			return
		}
		maxImports := 20
		ctx, cancel := fuzzContext()
		defer cancel()
		for i := 0; i < noOfImports%maxImports; i++ {
			tarBytes, err := f.GetBytes()
			if err != nil {
				return
			}
			_, _ = client.Import(ctx, bytes.NewReader(tarBytes))
		}
	})
}