diff --git a/app/main.go b/app/main.go index 706b597..c161740 100644 --- a/app/main.go +++ b/app/main.go @@ -9,6 +9,7 @@ import ( "github.com/yedf/dtm/examples" ) +// M alias type M = map[string]interface{} func wait() { diff --git a/dtmsvr/config.go b/dtmsvr/config.go index 7beb64e..aeb2b55 100644 --- a/dtmsvr/config.go +++ b/dtmsvr/config.go @@ -1,7 +1,7 @@ package dtmsvr type dtmsvrConfig struct { - TransCronInterval int64 `yaml:"TransCronInterval"` // 单位秒 当事务等待这个时间之后,还没有变化,则进行一轮处理,包括prepared中的任务和commited的任务 + TransCronInterval int64 `yaml:"TransCronInterval"` // 单位秒 当事务等待这个时间之后,还没有变化,则进行一轮处理,包括prepared中的任务和committed的任务 Mysql map[string]string `yaml:"Mysql"` } diff --git a/dtmsvr/utils.go b/dtmsvr/utils.go index 7540f76..ad87dcd 100644 --- a/dtmsvr/utils.go +++ b/dtmsvr/utils.go @@ -21,9 +21,9 @@ func dbGet() *common.DB { return common.DbGet(config.Mysql) } func writeTransLog(gid string, action string, status string, branch string, detail string) { - if detail == "" { - detail = "{}" - } + // if detail == "" { + // detail = "{}" + // } // dbGet().Must().Table("trans_log").Create(M{ // "gid": gid, // "action": action,