| | |
|---|
| | | // 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 { |
|---|
| | |
|---|
| | | 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") |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | 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 |
|---|
| | | } |
|---|
