设置推送缓存

panlei

2019-11-01 d6242c4a792b2a6d06faf8920db9e3848592dedb

 labelFilter/req.go

@@ -94,6 +94,16 @@
      logger.Error("接收响应超时")
      return
   }
   errWrite := sock.SetOption(mangos.OptionWriteQLen,10)
   if errWrite != nil {
      logger.Error("设置传输缓存大小失败")
      return
   }
   errRead := sock.SetOption(mangos.OptionReadQLen,10)
   if errRead != nil {
      logger.Error("设置传输缓存大小失败")
      return
   }
   sock.AddTransport(tcp.NewTransport())
   if err = sock.Dial("tcp://"+url); err != nil {
      logger.Error("请求socket拨号失败: ", err.Error())