From 1be96db055f47f93c8d0e6409e764353e54942ec Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期四, 30 五月 2019 16:50:42 +0800
Subject: [PATCH] rm logs
---
server.go | 10 +++-------
client.go | 6 +-----
2 files changed, 4 insertions(+), 12 deletions(-)
diff --git a/client.go b/client.go
index 436d7e7..b70d4e2 100644
--- a/client.go
+++ b/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)
}
}
}
diff --git a/server.go b/server.go
index 1b8044b..41cfcf2 100644
--- a/server.go
+++ b/server.go
@@ -141,7 +141,7 @@
var msg []byte
var responses StringSet
- err = d.sock.Send([]byte("are you ok?"))
+ err = d.sock.Send([]byte(""))
if err != nil {
log.Println("DiscoveryServer: Error sending the SURVEY", err.Error())
return
@@ -151,21 +151,17 @@
for {
msg, err = d.sock.Recv()
if err != nil {
- if err == mangos.ErrRecvTimeout {//鍦ㄨ秴鏃舵椂闂村唴鏀跺埌鐨勫搷搴�
+ if err == mangos.ErrRecvTimeout {
// Timeout means I can add the current responses to the SET
- fmt.Println("mangos.ErrRecvTimeout")
d.services.Add(responses)
return
}
//fmt.Println(" err: ",err.Error())
//log.Println("DiscoveryServer: Error reading SURVEY responses", err.Error())
} else {
- fmt.Printf("poll received msg:%s \n",string(msg))
responses.Add(string(msg))
- //break
}
}
- fmt.Println("for out")
}
func NewPublisher(ctx context.Context, url string) (*Publisher, error) {
@@ -235,7 +231,7 @@
s.nodes = responses
// publish the changes
- s.publisher.Publish(s.nodes.ToSlice())
+ //s.publisher.Publish(s.nodes.ToSlice())//publish nodes changed
}
func (d *DiscoveryServer) PublishMsg(msg string){
--
Gitblit v1.8.0