liuxiaolong
2019-05-31 767892e5a75ba6ac46808de6d39d1c4fd0e85d8b
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())