From e7da9759146edb5761f73ac7f577fdd75f3bcc1a Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期五, 31 五月 2019 20:14:18 +0800
Subject: [PATCH] rm test log
---
server.go | 17 +++++------------
1 files changed, 5 insertions(+), 12 deletions(-)
diff --git a/server.go b/server.go
index 5dd0267..41cfcf2 100644
--- a/server.go
+++ b/server.go
@@ -6,8 +6,6 @@
"strings"
"time"
- "basic.com/pubsub/protomsg.git"
-
"golang.org/x/net/context"
"nanomsg.org/go-mangos"
@@ -143,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
@@ -153,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) {
@@ -237,10 +231,9 @@
s.nodes = responses
// publish the changes
- s.publisher.Publish(s.nodes.ToSlice())
- s.publisher.Publish([]string{"123"})
+ //s.publisher.Publish(s.nodes.ToSlice())//publish nodes changed
}
-func (d *DiscoveryServer) PublishMsg(msg protomsg.PublishMessage){
- d.services.publisher.Publish([]string{string(msg)})
+func (d *DiscoveryServer) PublishMsg(msg string){
+ d.services.publisher.Publish([]string{msg})
}
\ No newline at end of file
--
Gitblit v1.8.0