panlei
2019-10-29 6ae526a2746848443ccde19ce113de79db01088e
labelFilter/req.go
@@ -65,7 +65,7 @@
      fmt.Errorf("Failed set MaxRecvSize: %v", err)
      return
   }
   errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 3000)
   errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 2000)
   if errTimeOut != nil {
      fmt.Errorf("Failed set MaxRecvDeadline: %v", err)
      return
@@ -86,10 +86,12 @@
   if err = sock.Send(bytes); err != nil {
      Die("推送socket发送数据失败: %s", err.Error())
   }
   if msg, err = sock.Recv(); err != nil {
   msg, err = sock.Recv();
   if err != nil {
      Die("接收响应失败: %s", err.Error())
   } else {
      logger.Debug("事件推送成功!收到响应",string(msg))
   }
   logger.Debug("事件推送成功!收到响应",string(msg))
   sock.Close()
}