|
@@ -173,6 +173,10 @@ func canCollect() bool {
|
|
|
c_log.GlobalLogger.Info("采集数量已超过限额,当前周期内不再采集。", resp.Code)
|
|
|
return false
|
|
|
}
|
|
|
+ if len(entity.TimeWindowConsumerQueue) > 0 {
|
|
|
+ c_log.GlobalLogger.Info("存在正在处理的窗口,当前周期内不再采集。", resp.Code)
|
|
|
+ return false
|
|
|
+ }
|
|
|
c_log.GlobalLogger.Info("允许采集。")
|
|
|
return true
|
|
|
}
|