From 472f40b9d40d0658ac32b2df1ad1555168c39559 Mon Sep 17 00:00:00 2001 From: alteredCoder Date: Wed, 19 Jul 2023 18:18:24 +0200 Subject: [PATCH] fix --- pkg/acquisition/modules/waf/waf.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/acquisition/modules/waf/waf.go b/pkg/acquisition/modules/waf/waf.go index 9f4e764bb..61d826c68 100644 --- a/pkg/acquisition/modules/waf/waf.go +++ b/pkg/acquisition/modules/waf/waf.go @@ -293,7 +293,7 @@ func (w *WafSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) err w.logger.Infof("%d waf runner to start", len(w.WafRunners)) for _, runner := range w.WafRunners { - w.logger.Infof("Running waf runner: %s", runner.UUID) + runner := runner runner.outChan = out t.Go(func() error { return runner.Run(t) @@ -420,6 +420,7 @@ func (r *WafRunner) processReqWithEngine(tx experimental.FullTransaction, parsed } func (r *WafRunner) Run(t *tomb.Tomb) error { + r.logger.Infof("Waf Runner ready to process event") for { select { case <-t.Dying():