add log

liuxiaolong

2020-05-14 f4e880a21a8b3ef2ab80107f1f2ea7bd84c6897e

 agent.go

@@ -96,7 +96,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 {
@@ -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,16 +211,19 @@
      } 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)
               fmt.Println("androidSync query.Respond err:", err)
               return
            } else {
               fmt.Println("androidSync query.Respond success")
            }
         }
      }
@@ -462,9 +465,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.
@@ -490,11 +493,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
         }