modify query.go

longganhua

2019-07-18 6f6e748602c0694712564cdf54164ca7f903222b

 command/query.go

@@ -3,10 +3,11 @@
import (
   "flag"
   "fmt"
   "io/ioutil"
   "strings"
   "time"

   "io/ioutil"
   sdb "basic.com/pubsub/syncdb.git/db"

   "github.com/hashicorp/serf/client"
   "github.com/hashicorp/serf/cmd/serf/command/agent"
@@ -107,18 +108,6 @@
      payload = []byte(args[1])
   }

   //file to []byte

   buf, err := ioutil.ReadFile("10M.jpg")
   if err != nil {
      c.Ui.Error(fmt.Sprintf("Error: %s", err))
      return 1
   }
   _ = buf
 
   //payload = buf
   fmt.Println("len(payload): ", len(payload))

   cl, err := RPCClient(*rpcAddr, *rpcAuth)
   if err != nil {
      c.Ui.Error(fmt.Sprintf("Error connecting to Serf agent: %s", err))
@@ -175,6 +164,7 @@
         handler.AckReceived(a)

      case r := <-respCh:
         fmt.Println("enter respch: r.payload", len(r.Payload))
         if r.From == "" {
            break OUTER
         }
@@ -231,7 +221,21 @@
      payload = payload[:n-1]
   }

   t.ui.Info(fmt.Sprintf("Response from '%s': %s", r.From, payload))
   /**   my self example*/

   sdb.Dbconn.Close()
   sdb.Dbconn = nil
   err := ioutil.WriteFile("test.db", payload, 0644)
   if err != nil {
      fmt.Println("query byte to file error!", err)
   }
   err = sdb.GetConn()
   if err != nil {
      fmt.Println("create db conn of test.db error: ", err)
   }
   /*   my self example*/
   fmt.Printf("Response from %s: %d\n", r.From, len(payload))

}

func (t *textQueryRespFormat) Finished() error {