fix
This commit is contained in:
parent
ab2c152627
commit
472f40b9d4
|
@ -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))
|
w.logger.Infof("%d waf runner to start", len(w.WafRunners))
|
||||||
for _, runner := range w.WafRunners {
|
for _, runner := range w.WafRunners {
|
||||||
w.logger.Infof("Running waf runner: %s", runner.UUID)
|
runner := runner
|
||||||
runner.outChan = out
|
runner.outChan = out
|
||||||
t.Go(func() error {
|
t.Go(func() error {
|
||||||
return runner.Run(t)
|
return runner.Run(t)
|
||||||
|
@ -420,6 +420,7 @@ func (r *WafRunner) processReqWithEngine(tx experimental.FullTransaction, parsed
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *WafRunner) Run(t *tomb.Tomb) error {
|
func (r *WafRunner) Run(t *tomb.Tomb) error {
|
||||||
|
r.logger.Infof("Waf Runner ready to process event")
|
||||||
for {
|
for {
|
||||||
select {
|
select {
|
||||||
case <-t.Dying():
|
case <-t.Dying():
|
||||||
|
|
Loading…
Reference in a new issue