liuxiaolong
2019-05-31 767892e5a75ba6ac46808de6d39d1c4fd0e85d8b
rm publish init
1个文件已修改
3 ■■■■ 已修改文件
server.go 3 ●●●● 补丁 | 查看 | 原始文档 | 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())