syncdb.go

longganhua

2019-07-18 fc8d3a64d69d0eb08783d1cbe85bc2b3835a49e8

syncdb.go

 command/query.go

@@ -107,6 +107,7 @@
        payload = []byte(args[1])
    }

    fmt.Println("query send len payload", len(payload))
    cl, err := RPCClient(*rpcAddr, *rpcAuth)
    if err != nil {
        c.Ui.Error(fmt.Sprintf("Error connecting to Serf agent: %s", err))
@@ -167,7 +168,7 @@
                break OUTER
            }
            handler.ResponseReceived(r)
            return 0
            fmt.Println("enter respch: r.payload", r.Payload)

        case <-c.ShutdownCh:
            return 1