diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2015-02-20 10:12:06 +0100 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2015-02-20 10:12:06 +0100 |
| commit | c5c21c73c310c29675bff1a1f2da4ddd298c0f92 (patch) | |
| tree | b58887652b2c0605b0d7d145377638cd7c754187 /src/InputReader.h | |
| parent | 7bacaf3818494cf706f7372cb6cd194dbaf3f251 (diff) | |
| download | dabmod-c5c21c73c310c29675bff1a1f2da4ddd298c0f92.tar.gz dabmod-c5c21c73c310c29675bff1a1f2da4ddd298c0f92.tar.bz2 dabmod-c5c21c73c310c29675bff1a1f2da4ddd298c0f92.zip | |
Add max_frames_queued option for zmq input
Diffstat (limited to 'src/InputReader.h')
| -rw-r--r-- | src/InputReader.h | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/InputReader.h b/src/InputReader.h index 3e0dcab..3e3e000 100644 --- a/src/InputReader.h +++ b/src/InputReader.h @@ -3,7 +3,7 @@ Her Majesty the Queen in Right of Canada (Communications Research Center Canada) - Copyrigth (C) 2013 + Copyrigth (C) 2013, 2015 Matthias P. Braendli, matthias.braendli@mpb.li */ /* @@ -137,6 +137,7 @@ struct InputZeroMQThreadData { ThreadsafeQueue<uint8_t*> *in_messages; std::string uri; + unsigned max_queued_frames; }; class InputZeroMQWorker @@ -179,7 +180,7 @@ class InputZeroMQReader : public InputReader worker_.Stop(); } - int Open(std::string uri); + int Open(const std::string& uri, unsigned max_queued_frames); int GetNextFrame(void* buffer); @@ -197,3 +198,4 @@ class InputZeroMQReader : public InputReader #endif #endif + |