---

panlei

2019-11-02 ffeb770e0232631cc2db13d2b82f6ead9b9f637f

---

 labelFilter/req.go

@@ -104,16 +104,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())