From 6f6e748602c0694712564cdf54164ca7f903222b Mon Sep 17 00:00:00 2001
From: longganhua <long>
Date: 星期四, 18 七月 2019 15:39:19 +0800
Subject: [PATCH] modify query.go
---
command/query.go | 8 +++-----
1 files changed, 3 insertions(+), 5 deletions(-)
diff --git a/command/query.go b/command/query.go
index c8ad299..992a965 100644
--- a/command/query.go
+++ b/command/query.go
@@ -8,6 +8,7 @@
"time"
sdb "basic.com/pubsub/syncdb.git/db"
+
"github.com/hashicorp/serf/client"
"github.com/hashicorp/serf/cmd/serf/command/agent"
"github.com/mitchellh/cli"
@@ -107,7 +108,6 @@
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))
@@ -164,11 +164,11 @@
handler.AckReceived(a)
case r := <-respCh:
+ fmt.Println("enter respch: r.payload", len(r.Payload))
if r.From == "" {
break OUTER
}
handler.ResponseReceived(r)
- fmt.Println("enter respch: r.payload", r.Payload)
case <-c.ShutdownCh:
return 1
@@ -222,9 +222,7 @@
}
/** my self example*/
- fmt.Println("x length is: ", payload)
- // // byte to file.
sdb.Dbconn.Close()
sdb.Dbconn = nil
err := ioutil.WriteFile("test.db", payload, 0644)
@@ -236,8 +234,8 @@
fmt.Println("create db conn of test.db error: ", err)
}
/* my self example*/
+ fmt.Printf("Response from %s: %d\n", r.From, len(payload))
- t.ui.Info(fmt.Sprintf("Response from '%s': %s", r.From, payload))
}
func (t *textQueryRespFormat) Finished() error {
--
Gitblit v1.8.0