From d43c72adb60395ea20550d49d0310aebbdca53a3 Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Sun, 23 Mar 2014 21:51:13 +0100
Subject: Maintain transmission frame FP relationship in ZeroMQ input

---
 src/InputReader.h | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

(limited to 'src/InputReader.h')

diff --git a/src/InputReader.h b/src/InputReader.h
index de8fb78..6a7d7c3 100644
--- a/src/InputReader.h
+++ b/src/InputReader.h
@@ -143,15 +143,26 @@ class InputZeroMQWorker
 {
     public:
         InputZeroMQWorker() :
-            zmqcontext(1)  {}
+            running(false),
+            zmqcontext(1),
+            m_to_drop(0) { }
 
         void Start(struct InputZeroMQThreadData* workerdata);
         void Stop();
     private:
         void RecvProcess(struct InputZeroMQThreadData* workerdata);
+
         bool running;
         zmq::context_t zmqcontext; // is thread-safe
         boost::thread recv_thread;
+
+        /* We must be careful to keep frame phase consistent. If we
+         * drop a single ETI frame, we will break the transmission
+         * frame vs. ETI frame phase.
+         *
+         * Here we keep track of how many ETI frames we must drop
+         */
+        int m_to_drop;
 };
 
 class InputZeroMQReader : public InputReader
-- 
cgit v1.2.3