|
|
@ -77,7 +77,7 @@ func (t *transMsgProcessor) ProcessOnce(branches []TransBranch) error { |
|
|
var started int |
|
|
var started int |
|
|
resultsChan := make(chan error, len(branches)) |
|
|
resultsChan := make(chan error, len(branches)) |
|
|
var err error |
|
|
var err error |
|
|
for i, _ := range branches { |
|
|
for i := range branches { |
|
|
b := &branches[i] |
|
|
b := &branches[i] |
|
|
if b.Op != dtmcli.BranchAction || b.Status != dtmcli.StatusPrepared { |
|
|
if b.Op != dtmcli.BranchAction || b.Status != dtmcli.StatusPrepared { |
|
|
continue |
|
|
continue |
|
|
|