labelFilter/req.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
labelFilter/ruleForLabel.go | ●●●●● 补丁 | 查看 | 原始文档 | 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]) } }