---

panlei

2019-11-02 74f6cb6302a6f375f8093650fb601f0d9e432c99

---

 labelFilter/req.go

@@ -97,16 +97,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
    }
    //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())