summaryrefslogtreecommitdiffstats
path: root/src/InputReader.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/InputReader.h')
-rw-r--r--src/InputReader.h13
1 files changed, 12 insertions, 1 deletions
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