diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2018-03-06 22:53:36 +0100 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2018-03-06 22:53:36 +0100 |
| commit | 56dfbcd73529ee6dc42a17a139c9ceaccf1def3d (patch) | |
| tree | 47580fcfa894fca04805f670ec6acf30a08a6f5d /src/InputReader.h | |
| parent | 5bea9241b246cfc4b9abef3d265a96d52a377c37 (diff) | |
| download | dabmod-56dfbcd73529ee6dc42a17a139c9ceaccf1def3d.tar.gz dabmod-56dfbcd73529ee6dc42a17a139c9ceaccf1def3d.tar.bz2 dabmod-56dfbcd73529ee6dc42a17a139c9ceaccf1def3d.zip | |
Avoid copies in ThreadsafeQueue and Buffer
Diffstat (limited to 'src/InputReader.h')
| -rw-r--r-- | src/InputReader.h | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/InputReader.h b/src/InputReader.h index 84f6835..4ffa2b8 100644 --- a/src/InputReader.h +++ b/src/InputReader.h @@ -173,12 +173,12 @@ class InputZeroMQReader : public InputReader std::atomic<bool> m_running = ATOMIC_VAR_INIT(false); std::string m_uri; size_t m_max_queued_frames = 0; - ThreadsafeQueue<std::shared_ptr<std::vector<uint8_t> > > m_in_messages; + ThreadsafeQueue<std::vector<uint8_t> > m_in_messages; void RecvProcess(void); zmq::context_t m_zmqcontext; // is thread-safe - boost::thread m_recv_thread; + std::thread m_recv_thread; /* We must be careful to keep frame phase consistent. If we * drop a single ETI frame, we will break the transmission |