add log

liuxiaolong

2020-05-13 99c049b8efe577815ea9af4eec182d3632d427a1

add log

 agent.go

@@ -450,7 +450,7 @@
func (a *Agent) GetTableDataFromCluster(tableNames []string) (*[]string, error) {
    //members: get name of first member
    mbs := a.GroupMembers(a.conf.ClusterID)
    var specmembername string
    specmembername := ""
    for _, m := range mbs {
        //fmt.Println("m", m)
        if m.Name != a.conf.NodeName { //前缀：DSVAD:分析服务器 DSPAD:进出入pad
@@ -459,11 +459,11 @@
                    specmembername = m.Name
                    break
                }
            }else{
                specmembername = m.Name
                break
            }
        }
    }
    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)

@@ -477,9 +477,9 @@

    resp, err := a.Query(QueryEventUpdateDBData, tBytes, &params)
    if err == nil || !strings.Contains(err.Error(), "cannot contain") {
        //fmt.Println("err: ", err)
        //fmt.Println("QueryEventUpdateDBData err: ")
    }
    //fmt.Println("Query.resp.err:", err, "resp:", resp)
    fmt.Println("Query.resp.err:", err, "resp:", resp)

    var wg sync.WaitGroup
    wg.Add(1)