---
panlei
2019-11-02 e43bff88dd81ce443efca9b33aadeeb6f0fe5f59
---
2个文件已修改
9 ■■■■■ 已修改文件
labelFilter/req.go 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
labelFilter/ruleForLabel.go 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
labelFilter/req.go
@@ -73,9 +73,8 @@
                // 为每个url建立一个chan
                if strings.Contains(url.Url,"114") {
                    ch := make(chan []byte,10)
                    urlPool[url.Url] = ch
                    logger.Info("初始化信息:",ch,urlPool)
                    urlPool[url.Url] = make(chan []byte,10)
                    logger.Info("初始化信息:",urlPool)
                    go GoPush(url.Url)
                }
            }
@@ -125,7 +124,7 @@
    //        ch = v.ch
    //    }
    //}
    //logger.Info("chan信息:",ch)
    logger.Info("chan信息:",urlPool[url])
    for {
        select {
        // case <-ctx.Done():
labelFilter/ruleForLabel.go
@@ -326,7 +326,7 @@
            logger.Info("序列化失败:",err1)
        }
        urlPool[url.Url] <- bytes
        logger.Info("urlPool大小: ", urlPool[url.Url])
        logger.Info("chan信息以: ", urlPool[url.Url])
    }
}