mirror/netsampler-goflow2
1
0
Fork 0
mirror of https://github.com/netsampler/goflow2.git synced 2024-05-06 15:54:52 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #86 from OlivierCazade/log-transport-error

Browse Source 
Add logging of transport error
This commit is contained in:
Louis
2022-07-06 20:24:53 -07:00
committed by GitHub
parent 1834503bb5 78f2ce561d
commit 838505b10b
3 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
utils/netflow.go
View File

@ -329,7 +329,10 @@ func (s *StateNetFlow) DecodeFlow(msg interface{}) error {
s.Logger.Error(err) s.Logger.Error(err)
} }
if err == nil && s.Transport != nil { if err == nil && s.Transport != nil {
s.Transport.Send(key, data) err = s.Transport.Send(key, data)
if err != nil {
s.Logger.Error(err)
}
} }
} }
} }

5
utils/nflegacy.go
View File

@ -88,7 +88,10 @@ func (s *StateNFLegacy) DecodeFlow(msg interface{}) error {
s.Logger.Error(err) s.Logger.Error(err)
} }
if err == nil && s.Transport != nil { if err == nil && s.Transport != nil {
s.Transport.Send(key, data) err = s.Transport.Send(key, data)
if err != nil {
s.Logger.Error(err)
}
} }
} }
} }

5
utils/sflow.go
View File

@ -142,7 +142,10 @@ func (s *StateSFlow) DecodeFlow(msg interface{}) error {
s.Logger.Error(err) s.Logger.Error(err)
} }
if err == nil && s.Transport != nil { if err == nil && s.Transport != nil {
s.Transport.Send(key, data) err = s.Transport.Send(key, data)
if err != nil {
s.Logger.Error(err)
}
} }
} }
} }