From 78f2ce561daf523bb7b55a7f52741666d62d0dd7 Mon Sep 17 00:00:00 2001 From: Olivier Cazade Date: Mon, 13 Jun 2022 17:36:28 +0200 Subject: [PATCH] Add logging of transport error --- utils/netflow.go | 5 ++++- utils/nflegacy.go | 5 ++++- utils/sflow.go | 5 ++++- 3 files changed, 12 insertions(+), 3 deletions(-) diff --git a/utils/netflow.go b/utils/netflow.go index 88a127e..28bbf15 100644 --- a/utils/netflow.go +++ b/utils/netflow.go @@ -329,7 +329,10 @@ func (s *StateNetFlow) DecodeFlow(msg interface{}) error { s.Logger.Error(err) } if err == nil && s.Transport != nil { - s.Transport.Send(key, data) + err = s.Transport.Send(key, data) + if err != nil { + s.Logger.Error(err) + } } } } diff --git a/utils/nflegacy.go b/utils/nflegacy.go index 1b3114b..9b9f0be 100644 --- a/utils/nflegacy.go +++ b/utils/nflegacy.go @@ -88,7 +88,10 @@ func (s *StateNFLegacy) DecodeFlow(msg interface{}) error { s.Logger.Error(err) } if err == nil && s.Transport != nil { - s.Transport.Send(key, data) + err = s.Transport.Send(key, data) + if err != nil { + s.Logger.Error(err) + } } } } diff --git a/utils/sflow.go b/utils/sflow.go index 57915ab..4ebe68d 100644 --- a/utils/sflow.go +++ b/utils/sflow.go @@ -142,7 +142,10 @@ func (s *StateSFlow) DecodeFlow(msg interface{}) error { s.Logger.Error(err) } if err == nil && s.Transport != nil { - s.Transport.Send(key, data) + err = s.Transport.Send(key, data) + if err != nil { + s.Logger.Error(err) + } } } }