beenull/crowdsec
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

debug

Browse source
This commit is contained in:
sabban 2023-07-07 15:46:30 +02:00
parent 0a4dcc5bd2
commit e8d6904399
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
pkg/leakybucket/timemachine.go
View file

@ -1,9 +1,11 @@
package leakybucket
import (
"fmt"
"time"
"github.com/crowdsecurity/crowdsec/pkg/types"
"github.com/davecgh/go-spew/spew"
log "github.com/sirupsen/logrus"
)
@ -35,11 +37,13 @@ func TimeMachinePour(l *Leaky, msg types.Event) {
}
l.Last_ts = d
l.mutex.Unlock()
// fmt.Printf("event: %s", spew.Sdump(msg.Line.Raw))
if l.Limiter.AllowN(d, 1) {
fmt.Printf("event: %s", spew.Sdump(msg.Line.Raw))
l.logger.Tracef("Time-Pouring event %s (tokens:%f)", d, l.Limiter.GetTokensCount())
l.Queue.Add(msg)
} else {
fmt.Printf("overflow: %s", spew.Sdump(msg.Line.Raw))
l.Ovflw_ts = d
l.logger.Debugf("Bucket overflow at %s", l.Ovflw_ts)
l.Queue.Add(msg)