avoid data race.

This commit is contained in:
徐聪
2022-01-19 21:09:14 +08:00
parent 30f77d1ff8
commit a543e5c05c
2 changed files with 5 additions and 10 deletions

View File

@@ -108,8 +108,7 @@ func (b *HRPBoomer) convertBoomerTask(testcase *TestCase) *boomer.Task {
}
}
config := runner.TestCase.Config
if err := runner.parseConfig(config); err != nil {
if err := runner.parseConfig(caseConfig); err != nil {
log.Error().Err(err).Msg("parse config failed")
return
}

View File

@@ -160,10 +160,10 @@ func (r *caseRunner) reset() *caseRunner {
func (r *caseRunner) run() error {
config := r.TestCase.Config
cfg := config.ToStruct()
// init plugin
var err error
if r.parser.plugin, err = initPlugin(config.ToStruct().Path); err != nil {
if r.parser.plugin, err = initPlugin(cfg.Path); err != nil {
return err
}
defer func() {
@@ -171,11 +171,9 @@ func (r *caseRunner) run() error {
r.parser.plugin.Quit()
}
}()
if err := r.parseConfig(config); err != nil {
if err := r.parseConfig(cfg); err != nil {
return err
}
cfg := config.ToStruct()
log.Info().Str("testcase", config.Name()).Msg("run testcase start")
r.startTime = time.Now()
@@ -545,9 +543,7 @@ func (r *caseRunner) runStepTestCase(step *TStep) (stepResult *stepData, err err
return stepResult, nil
}
func (r *caseRunner) parseConfig(config IConfig) error {
cfg := config.ToStruct()
func (r *caseRunner) parseConfig(cfg *TConfig) error {
// parse config variables
parsedVariables, err := r.parser.parseVariables(cfg.Variables)
if err != nil {