add queryResponse timeout

liuxiaolong

2019-10-11 a699ff4f66e264d88faa93c0aeee732ca3d9aa1f

add queryResponse timeout

 agent.go

@@ -519,10 +519,14 @@

    var wg sync.WaitGroup
    wg.Add(1)
    go func() {
    ticker := time.NewTicker(300*time.Second)
    go func(tk *time.Ticker) {
        defer tk.Stop()
        defer wg.Done()
        for {
            select {
            case <-tk.C:
                return
            case msg := <- QueryTcpResponseChan:
                logger.Info("Query response's len:", len(msg))
                err := json.Unmarshal(msg, &dumpSqls)
@@ -533,7 +537,7 @@
                return
            }
        }
    }()
    }(ticker)
    wg.Wait()
    return &dumpSqls,nil