panlei
2019-12-13 34eb10fac7b0cc8ff4f081e9bf1ac8a3124fe0c5
ruleserver/readyDataForRule.go
@@ -280,7 +280,7 @@
   //if sock, err = req.NewSocket(); err != nil {
   //   logger.Error("创建请求socket失败: %s", err.Error())
   //}
   errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024)
   errSize := sock.SetOption(mangos.OptionMaxRecvSize,10*1024*1024)
   if errSize != nil {
      logger.Error("Failed set MaxRecvSize: %v", err)
      return nil
@@ -356,7 +356,7 @@
         logger.Debug("数据推送成功!收到响应,数据长度为:",len(msg))
         receiver <- msg
      default:
         time.Sleep(10 * time.Millisecond)
      }
   }
}