From fd6d695275f88e83ebba6fa39afc044e329a690f Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Sun, 25 Dec 2016 23:53:51 +0100
Subject: Add first version of EDI input

---
 src/InputReader.h | 29 ++++++++++++++++++++++++++---
 1 file changed, 26 insertions(+), 3 deletions(-)

(limited to 'src/InputReader.h')

diff --git a/src/InputReader.h b/src/InputReader.h
index 4d0792b..fddfccf 100644
--- a/src/InputReader.h
+++ b/src/InputReader.h
@@ -25,8 +25,7 @@
    along with ODR-DabMod.  If not, see <http://www.gnu.org/licenses/>.
  */
 
-#ifndef INPUTREADER_H
-#define INPUTREADER_H
+#pragma once
 
 #ifdef HAVE_CONFIG_H
 #   include "config.h"
@@ -41,6 +40,8 @@
 #endif
 #include "porting.h"
 #include "Log.h"
+#include "lib/edi/ETIDecoder.hpp"
+#include "lib/UdpSocket.h"
 #include <sys/socket.h>
 #include <netinet/in.h>
 #include <unistd.h>
@@ -244,6 +245,28 @@ class InputZeroMQReader : public InputReader
         struct InputZeroMQThreadData workerdata_;
 };
 
-#endif
+class InputEdiReader : public InputReader
+{
+public:
+    InputEdiReader();
+
+    int Open(const std::string& uri);
+
+    int GetNextFrame(void* buffer);
+
+    void PrintInfo(void);
+
+private:
+    void rx_packet(void);
+
+    std::vector<uint8_t> getEtiFrame(void);
+
+    EdiDecoder::ETIWriter m_writer;
+    EdiDecoder::ETIDecoder m_decoder;
+
+    int m_port;
+    UdpSocket m_sock;
+};
+
 #endif
 
-- 
cgit v1.2.3