merge RunBenchmarkPerfScheduling and runBenchmarkPerfScheduling

This commit is contained in:
saza-ku
2025-04-10 19:08:25 +09:00
parent 780c0d6725
commit 5ad90c3b63

View File

@@ -1156,10 +1156,6 @@ func RunBenchmarkPerfScheduling(b *testing.B, configFile string, topicName strin
option(opts)
}
runBenchmarkPerSchedulingImpl(b, configFile, topicName, outOfTreePluginRegistry, opts)
}
func runBenchmarkPerSchedulingImpl(b *testing.B, configFile string, topicName string, outOfTreePluginRegistry frameworkruntime.Registry, options *schedulerPerfOptions) {
testCases, err := getTestCases(configFile)
if err != nil {
b.Fatal(err)
@@ -1206,8 +1202,8 @@ func runBenchmarkPerSchedulingImpl(b *testing.B, configFile string, topicName st
b.Fatalf("workload %s is not valid: %v", w.Name, err)
}
if options.prepareFn != nil {
err = options.prepareFn(tCtx)
if opts.prepareFn != nil {
err = opts.prepareFn(tCtx)
if err != nil {
b.Fatalf("failed to run prepareFn: %v", err)
}