From 0bdd2960707a8abb5d9e435d1313aec4cf264ab1 Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Tue, 6 Mar 2018 09:31:43 +0100
Subject: Implement TCP input auto-reconnect

---
 src/InputReader.h | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

(limited to 'src/InputReader.h')

diff --git a/src/InputReader.h b/src/InputReader.h
index 5b9e80a..84f6835 100644
--- a/src/InputReader.h
+++ b/src/InputReader.h
@@ -40,6 +40,7 @@
 #  include "ThreadsafeQueue.h"
 #endif
 #include "Log.h"
+#include "Socket.h"
 #include <unistd.h>
 #define INVALID_SOCKET   -1
 
@@ -129,11 +130,6 @@ class InputFileReader : public InputReader
 class InputTcpReader : public InputReader
 {
     public:
-        InputTcpReader();
-        InputTcpReader(const InputTcpReader& other) = delete;
-        InputTcpReader& operator=(const InputTcpReader& other) = delete;
-        virtual ~InputTcpReader();
-
         // Endpoint is either host:port or tcp://host:port
         void Open(const std::string& endpoint);
 
@@ -146,7 +142,7 @@ class InputTcpReader : public InputReader
         virtual void PrintInfo() const;
 
     private:
-        int m_sock = INVALID_SOCKET;
+        TCPClient m_tcpclient;
         std::string m_uri;
 };
 
-- 
cgit v1.2.3