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

Add logging of transport error
tgragnato · Jul 7, 2022 · 838505b · 838505b
2 parents 1834503 + 78f2ce5
commit 838505b
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 3 deletions.
diff --git 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
@@ -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
@@ -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)
+				}
 			}
 		}
 	}