rm no use import

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 {
@@ -131,11 +130,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 +210,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 +464,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 +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
         }