server.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
server.go
@@ -1,6 +1,7 @@ package gopherdiscovery import ( "fmt" "log" "strings" "time" @@ -149,11 +150,11 @@ responses = NewStringSet() for { msg, err = d.sock.Recv() fmt.Println("DiscoveryServer.Recv->err:",err) if err != nil { if err == mangos.ErrRecvTimeout { // Timeout means I can add the current responses to the SET d.services.Add(responses) d.PublishMsg("Init") return } //fmt.Println(" err: ",err.Error())