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

error mgmt

Browse source
This commit is contained in:
Thibault bui Koechlin 2020-06-10 11:47:42 +02:00
parent ff3ac7aeb7
commit 3a0b2504f5
2 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
pkg/parser/runtime.go
View file

@ -298,7 +298,9 @@ func /*(u types.UnixParser)*/ Parse(ctx UnixParserCtx, xp types.Event, nodes []N
isStageOK = true isStageOK = true
if ParseDump { if ParseDump {
evtcopy := types.Event{} evtcopy := types.Event{}
types.Clone(&event, &evtcopy) if err := types.Clone(&event, &evtcopy); err != nil {
log.Fatalf("while cloning Event in parser : %s", err)
}
StageParseCache[stage][node.Name] = evtcopy StageParseCache[stage][node.Name] = evtcopy
} }
} }

7
pkg/types/utils.go
View file

@ -96,15 +96,16 @@ func ConfigureLogger(clog *log.Logger) error {
return nil return nil
} }
func Clone(a, b interface{}) { func Clone(a, b interface{}) error {
buff := new(bytes.Buffer) buff := new(bytes.Buffer)
enc := gob.NewEncoder(buff) enc := gob.NewEncoder(buff)
dec := gob.NewDecoder(buff) dec := gob.NewDecoder(buff)
if err := enc.Encode(a); err != nil { if err := enc.Encode(a); err != nil {
log.Fatalf("failed cloning %T", a) return fmt.Errorf("failed cloning %T", a)
} }
if err := dec.Decode(b); err != nil { if err := dec.Decode(b); err != nil {
log.Fatalf("failed cloning %T", b) return fmt.Errorf("failed cloning %T", b)
} }
return nil
} }