fix

test/engine/trigger/ebpf/security.go

@@ -113,7 +113,7 @@ func rwFile(ctx context.Context, commandCnt int, filenames string) error {
 func mmapFile(ctx context.Context, commandCnt int, filenames string) error {
 	files := strings.Split(filenames, ",")
 	for _, file := range files {
-		mmapFileCommand := trigger.GetRunTriggerCommand("mmap", "commandCnt", strconv.FormatInt(int64(commandCnt), 10), "filename", file)
+		mmapFileCommand := trigger.GetRunTriggerCommand("ebpf", "mmap", "commandCnt", strconv.FormatInt(int64(commandCnt), 10), "filename", file)
 		if _, err := setup.Env.ExecOnSource(ctx, mmapFileCommand); err != nil {
 			return err
 		}

test/engine/trigger/helper.go

@@ -23,17 +23,17 @@ import (
 	"github.com/alibaba/ilogtail/test/config"
 )
 
-const commandTemplate = "python3 %s.py %s"
+const commandTemplate = "python3 remote_%s.py %s"
 
 func BeginTrigger(ctx context.Context) (context.Context, error) {
 	startTime := time.Now().Unix()
 	return context.WithValue(ctx, config.StartTimeContextKey, int32(startTime)), nil
 }
 
-func GetRunTriggerCommand(triggerName string, kvs ...string) string {
+func GetRunTriggerCommand(scenrio, triggerName string, kvs ...string) string {
 	args := make([]string, 0)
 	for i := 0; i < len(kvs); i += 2 {
 		args = append(args, fmt.Sprintf("--%s", kvs[i]), kvs[i+1])
 	}
-	return fmt.Sprintf(commandTemplate, filepath.Join(config.TestConfig.WorkDir, "engine", "trigger", "remote", triggerName), strings.Join(args, " "))
+	return fmt.Sprintf(commandTemplate, filepath.Join(config.TestConfig.WorkDir, "engine", "trigger", scenrio, triggerName), strings.Join(args, " "))
 }

test/engine/trigger/log/file.go

@@ -15,6 +15,7 @@ package log
 
 import (
 	"context"
+	"fmt"
 	"strconv"
 	"time"
 
@@ -61,17 +62,19 @@ func Nginx(ctx context.Context, rate, duration int, path string) (context.Contex
 func generate(ctx context.Context, mode, path string, count, interval int, customKV ...string) (context.Context, error) {
 	time.Sleep(3 * time.Second)
 	customKV = append(customKV, "mode", mode, "path", path, "count", strconv.Itoa(count), "interval", strconv.Itoa(interval))
-	command := trigger.GetRunTriggerCommand("log", customKV...)
-	if _, err := setup.Env.ExecOnSource(ctx, command); err != nil {
-		return ctx, err
-	}
+	command := trigger.GetRunTriggerCommand("log", "file", customKV...)
+	go func() {
+		if _, err := setup.Env.ExecOnSource(ctx, command); err != nil {
+			fmt.Println(err)
+		}
+	}()
 	return ctx, nil
 }
 
 func generateBenchmark(ctx context.Context, mode, path string, rate, duration int, customKV ...string) (context.Context, error) {
 	time.Sleep(3 * time.Second)
 	customKV = append(customKV, "mode", mode, "path", path, "rate", strconv.Itoa(rate), "duration", strconv.Itoa(duration))
-	command := trigger.GetRunTriggerCommand("log_benchmark", customKV...)
+	command := trigger.GetRunTriggerCommand("log", "file_benchmark", customKV...)
 	if _, err := setup.Env.ExecOnSource(ctx, command); err != nil {
 		return ctx, err
 	}