From e64bf1b85548b515b78cdf09b389493e80b1e1b1 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期一, 04 十一月 2019 14:36:09 +0800
Subject: [PATCH] ---
---
labelFilter/ruleForLabel.go | 12 +++++++++---
1 files changed, 9 insertions(+), 3 deletions(-)
diff --git a/labelFilter/ruleForLabel.go b/labelFilter/ruleForLabel.go
index 71f30b0..e8b0193 100644
--- a/labelFilter/ruleForLabel.go
+++ b/labelFilter/ruleForLabel.go
@@ -17,7 +17,7 @@
logger.Error("浜嬩欢鎺ㄩ�佹ā鍧楀効鐨勫紓甯告崟鑾凤細",err)
}
}()
-
+ start := time.Now()
// 瑁呴厤鎴愯嚜宸卞彲浠ヨ瘑鍒殑鏁版嵁
label := new(Label)
label.DataFormatToLabel(msg)
@@ -84,6 +84,7 @@
logger.Info("閫氳繃瑙勫垯锛岃〃杈惧紡涓猴細", result)
// 鎺ㄩ�佹湇鍔″櫒
pushData(ruleGroup.Urls, msg)
+ logger.Info("鏃堕棿鎺ㄩ�佹墍鐢ㄦ椂闂达細",time.Since(start))
//os.Exit(1)
} else {
logger.Info("娌￠�氳繃瑙勫垯,琛ㄨ揪寮忎负锛�", result)
@@ -325,9 +326,14 @@
if err1 != nil {
logger.Info("搴忓垪鍖栧け璐ワ細",err1)
}
- urlPool[url.Url] <- bytes
- logger.Info("urlPool澶у皬锛� ", urlPool[url.Url])
+ if _, ok := urlPool[url.Url] ; ok {
+ urlPool[url.Url] <- bytes
+ logger.Info("chan淇℃伅鑰岋細 ", urlPool[url.Url])
+ }
+ logger.Info("chan淇℃伅浠ワ細 ", urlPool[url.Url])
+
}
+
}
// 鎶婃姤璀︾瓑绾ц浆鍖栨垚姹夊瓧
--
Gitblit v1.8.0