diff --git a/dtmsvr/trans_status.go b/dtmsvr/trans_status.go index 9879b87..742a094 100644 --- a/dtmsvr/trans_status.go +++ b/dtmsvr/trans_status.go @@ -262,13 +262,15 @@ func (t *TransGlobal) execBranch(ctx context.Context, branch *TransBranch, branc func (t *TransGlobal) getNextCronInterval(ctype cronType) int64 { if ctype == cronBackoff { return t.NextCronInterval * 2 - } else if ctype == cronKeep { + } + if ctype == cronKeep { return t.NextCronInterval - } else if t.RetryInterval != 0 { + } + if t.RetryInterval != 0 { return t.RetryInterval - } else if t.TimeoutToFail > 0 && t.TimeoutToFail < conf.RetryInterval { + } + if t.TimeoutToFail > 0 && t.TimeoutToFail < conf.RetryInterval { return t.TimeoutToFail - } else { - return conf.RetryInterval } + return conf.RetryInterval }