liuxiaolong
2020-05-14 54480e6f402018d29f62b861179a280a3c2e6cb5
agent.go
@@ -36,7 +36,6 @@
   "github.com/hashicorp/serf/serf"
   //"github.com/apache/servicecomb-service-center/pkg/log"
   "log"
   "runtime/debug"
)
const (
@@ -96,7 +95,7 @@
// Start agent
func (a *Agent) Start(ctx context.Context) {
   log.Println("aaaaaaaaa")
   log.Println(string(debug.Stack()))
   //log.Println(string(debug.Stack()))
   //debug.PrintStack()
   err := a.Agent.Start()
   if err != nil {
@@ -220,8 +219,10 @@
         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)
               fmt.Println("androidSync query.Respond err:", err)
               return
            } else {
               fmt.Println("androidSync query.Respond success")
            }
         }
      }
@@ -491,11 +492,13 @@
      for {
         select {
         case r := <-respCh:
            //fmt.Println("Query response's len:", len(r.Payload))
            fmt.Println("Query response's len:", len(r.Payload))
            err := json.Unmarshal(r.Payload, &dumpSqls)
            if err == nil {
               //fmt.Println("dumpSql:", dumpSqls)
               //fmt.Println("data dump success")
               fmt.Println("dumpSql:", dumpSqls)
               fmt.Println("data dump success")
            } else {
               fmt.Println("Query response.err:", err)
            }
            return
         }