hearbeat are you ok?

liuxiaolong

2019-06-01 55aac9b1d7fa4078f73a21087938608fe4738e41

 client.go

@@ -102,14 +102,12 @@

func (d *DiscoveryClient) run() {
   var err error
   var surveyMsg []byte
   for {
      surveyMsg, err = d.sock.Recv()
      _, err = d.sock.Recv()

      if err != nil {
         log.Println("DiscoveryClient: Cannot receive the SURVEY", err.Error())
      } else {
         log.Printf("client:%s received surveyor msg=%s ",d.service,string(surveyMsg))
         select {
         case <-d.ctx.Done():
            return
@@ -118,8 +116,6 @@
            err = d.sock.Send([]byte(d.service))
            if err != nil {
               log.Println("DiscoveryClient: Cannot send the SURVEY response", err.Error())
            }else {
               log.Printf("client:%s sent response i'm online",d.service)
            }
         }
      }