fix multi runners : only run several parsers for now
@@ -202,7 +202,6 @@ func StartProcessingRoutines(cConfig *csconfig.CrowdSec) (chan types.Event, erro
})
}
- for i := 0; i < cConfig.NbParsers; i++ {
bucketsTomb.Go(func() error {
err := runPour(inputEventChan, holders, buckets)
if err != nil {
@@ -211,9 +210,7 @@ func StartProcessingRoutines(cConfig *csconfig.CrowdSec) (chan types.Event, erro
}
return nil
})
- }
- for i := 0; i < cConfig.NbParsers; i++ {
outputsTomb.Go(func() error {
err := runOutput(inputEventChan, outputEventChan, holders, buckets, *postOverflowCTX, postOverflowNodes, outputProfiles, OutputRunner)
if err != nil {
@@ -222,7 +219,7 @@ func StartProcessingRoutines(cConfig *csconfig.CrowdSec) (chan types.Event, erro
}
return nil
})
- }
+
return inputLineChan, nil
}
