|
|
@ -22,8 +22,8 @@ import ( |
|
|
"github.com/yedf/dtm/examples" |
|
|
"github.com/yedf/dtm/examples" |
|
|
) |
|
|
) |
|
|
|
|
|
|
|
|
var dtmsvrPort = 8080 |
|
|
var dtmsvrPort = 36789 |
|
|
var dtmsvrGrpcPort = 58080 |
|
|
var dtmsvrGrpcPort = 36790 |
|
|
var metricsPort = 8889 |
|
|
var metricsPort = 8889 |
|
|
|
|
|
|
|
|
// StartSvr StartSvr
|
|
|
// StartSvr StartSvr
|
|
|
@ -84,7 +84,7 @@ func updateBranchAsync() { |
|
|
for len(updates) > 0 { |
|
|
for len(updates) > 0 { |
|
|
dbr := dbGet().Clauses(clause.OnConflict{ |
|
|
dbr := dbGet().Clauses(clause.OnConflict{ |
|
|
OnConstraint: "trans_branch_op_pkey", |
|
|
OnConstraint: "trans_branch_op_pkey", |
|
|
DoUpdates: clause.AssignmentColumns([]string{"status", "finish_time","update_time"}), |
|
|
DoUpdates: clause.AssignmentColumns([]string{"status", "finish_time", "update_time"}), |
|
|
}).Create(updates) |
|
|
}).Create(updates) |
|
|
dtmimp.Logf("flushed %d branch status to db. affected: %d", len(updates), dbr.RowsAffected) |
|
|
dtmimp.Logf("flushed %d branch status to db. affected: %d", len(updates), dbr.RowsAffected) |
|
|
if dbr.Error != nil { |
|
|
if dbr.Error != nil { |
|
|
|