From 30a100d4fbc17972d71f75695441bbedeee076ef Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Wed, 4 Dec 2024 08:41:03 +0100
Subject: common: Update Socket

---
 lib/edioutput/Transport.cpp | 10 +++++++++-
 lib/edioutput/Transport.h   |  2 --
 2 files changed, 9 insertions(+), 3 deletions(-)

(limited to 'lib/edioutput')

diff --git a/lib/edioutput/Transport.cpp b/lib/edioutput/Transport.cpp
index 8ebb9fc..4979e93 100644
--- a/lib/edioutput/Transport.cpp
+++ b/lib/edioutput/Transport.cpp
@@ -193,7 +193,15 @@ void Sender::write(const AFPacket& af_packet)
                 tcp_dispatchers.at(tcp_dest.get())->write(af_packet);
             }
             else if (auto tcp_dest = dynamic_pointer_cast<edi::tcp_client_t>(dest)) {
-                tcp_senders.at(tcp_dest.get())->sendall(af_packet);
+                const auto error_stats = tcp_senders.at(tcp_dest.get())->sendall(af_packet);
+
+                if (m_conf.verbose and error_stats.has_seen_new_errors) {
+                    fprintf(stderr, "TCP output %s:%d has %zu reconnects: most recent error: %s\n",
+                            tcp_dest->dest_addr.c_str(),
+                            tcp_dest->dest_port,
+                            error_stats.num_reconnects,
+                            error_stats.last_error.c_str());
+                }
             }
             else {
                 throw logic_error("EDI destination not implemented");
diff --git a/lib/edioutput/Transport.h b/lib/edioutput/Transport.h
index 6a3f229..c62545c 100644
--- a/lib/edioutput/Transport.h
+++ b/lib/edioutput/Transport.h
@@ -31,11 +31,9 @@
 #include "AFPacket.h"
 #include "PFT.h"
 #include "Socket.h"
-#include <vector>
 #include <chrono>
 #include <map>
 #include <unordered_map>
-#include <stdexcept>
 #include <fstream>
 #include <cstdint>
 #include <thread>
-- 
cgit v1.2.3