diff --git a/dtmsvr/trans_status.go b/dtmsvr/trans_status.go index a8d5e00..742a094 100644 --- a/dtmsvr/trans_status.go +++ b/dtmsvr/trans_status.go @@ -232,7 +232,7 @@ func (t *TransGlobal) execBranch(ctx context.Context, branch *TransBranch, branc t.changeBranchStatus(branch, status, branchPos) } branchMetrics(t, branch, status == dtmcli.StatusSucceed) - + // if time pass 1500ms and NextCronInterval is not default, then reset NextCronInterval if err == nil && (time.Since(t.lastTouched)+NowForwardDuration >= 1500*time.Millisecond || t.NextCronInterval > conf.RetryInterval && t.NextCronInterval > t.RetryInterval) { t.touchCronTime(cronReset, 0) diff --git a/dtmsvr/trans_type_workflow.go b/dtmsvr/trans_type_workflow.go index d1de51c..da6bd45 100644 --- a/dtmsvr/trans_type_workflow.go +++ b/dtmsvr/trans_type_workflow.go @@ -42,7 +42,6 @@ func (t *transWorkflowProcessor) ProcessOnce(ctx context.Context, branches []Tra data = dtmgimp.MustProtoMarshal(&wd) } err := t.getURLResult(ctx, t.QueryPrepared, "00", cmc.Name, data) - // if time pass 1500ms and NextCronInterval is not default, then reset NextCronInterval if err == dtmimp.ErrOngoing { t.touchCronTime(cronKeep, 0) } else if err != nil {