diff --git a/dtmsvr/trans_status.go b/dtmsvr/trans_status.go index 742a094..8cde388 100644 --- a/dtmsvr/trans_status.go +++ b/dtmsvr/trans_status.go @@ -232,11 +232,8 @@ 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) - } else if err == dtmimp.ErrOngoing { + + if err == dtmimp.ErrOngoing { t.touchCronTime(cronKeep, 0) } else if err != nil { t.touchCronTime(cronBackoff, 0)