Method Handler

core/pool/checkpool.go:214–232

()

}

func (pool *CheckPool) Handler() {
	defer close(pool.handlerDone)
	for bl := range pool.processCh {
		if bl.IsValid {
			params := map[string]interface{}{
				"current": bl,
			}
			if pool.MatchExpr != nil && pkg.CompareWithExpr(pool.MatchExpr, params) {
				bl.IsValid = true
			}
		}
		if bl.Source == parsers.CheckSource {
			pool.Bar.Done()
		}
		pool.recordCheckStat(bl)
		pool.putToOutput(bl)
		pool.wg.Done()
	}
}

func (pool *CheckPool) recordCheckStat(bl *baseline.Baseline) {
	if pool.Statistor == nil || bl == nil || bl.SprayResult == nil {