liuxiaolong
2020-05-13 8f1e42921da26573b5d08ec2e6909f3081d85109
fix debug.Stack() and add log
1个文件已修改
17 ■■■■ 已修改文件
agent.go 17 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
agent.go
@@ -131,11 +131,11 @@
}
type DbHandler interface {
    Forward(sql string) bool
    Execute(sql string) bool
}
type DbDumpHandler interface {
    Forward(tables string) string
    Dump(tables string) string
}
//数据库execute句柄
@@ -211,12 +211,13 @@
        } else if ev.Name == QueryEventUpdateDBData {
            //fmt.Println(string(ev.Payload))
            var tableNames []string
            json.Unmarshal(ev.Payload, &tableNames)
            err := json.Unmarshal(ev.Payload, &tableNames)
            fmt.Println("androidSync tableNames:", tableNames, "err:", err)
            dumpData := dbDumpH.Forward(strings.Join(tableNames, ","))
            dumpData := dbDumpH.Dump(strings.Join(tableNames, ","))
            bytesReturn, _ := json.Marshal(dumpData)
            //fmt.Println("results: ", bytesReturn)
            fmt.Println("androidSync len(bytesReturn): ", len(bytesReturn))
            if query, ok := event.(*serf.Query); ok {
                if err := query.Respond(bytesReturn); err != nil {
                    //fmt.Printf("err: %s\n", err)
@@ -462,9 +463,9 @@
            }
        }
    }
    if specmembername == "" {
        return nil, errors.New("other pad node not found in memberlist")
    }
    //if specmembername == "" {
    //    return nil, errors.New("other pad node not found in memberlist")
    //}
    //fmt.Println("mbs:", mbs, "a.conf.BindAddr:", a.conf.BindAddr, "specmembername:", specmembername)
    //query: get db file.