diff options
author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2017-07-28 11:54:32 +0200 |
---|---|---|
committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2017-07-28 11:54:32 +0200 |
commit | a1921a1a967b65c99a830141e9faaecd77b0f317 (patch) | |
tree | 193c00c382f1389f61a01870c937802e7e49212c /src/dabOutput | |
parent | 9aee86aace7d6c504b410c972d0ab5065f7f7b94 (diff) | |
download | dabmux-a1921a1a967b65c99a830141e9faaecd77b0f317.tar.gz dabmux-a1921a1a967b65c99a830141e9faaecd77b0f317.tar.bz2 dabmux-a1921a1a967b65c99a830141e9faaecd77b0f317.zip |
Add new zeromq config format
This gives the choice for the transmission of the metadata,
and the enabling of the TAI downloader is also triggered
appropriately
Diffstat (limited to 'src/dabOutput')
-rw-r--r-- | src/dabOutput/dabOutput.h | 6 | ||||
-rw-r--r-- | src/dabOutput/dabOutputZMQ.cpp | 4 |
2 files changed, 7 insertions, 3 deletions
diff --git a/src/dabOutput/dabOutput.h b/src/dabOutput/dabOutput.h index 58a2929..4142b25 100644 --- a/src/dabOutput/dabOutput.h +++ b/src/dabOutput/dabOutput.h @@ -305,11 +305,12 @@ struct zmq_dab_message_t class DabOutputZMQ : public DabOutput { public: - DabOutputZMQ(const std::string &zmq_proto) : + DabOutputZMQ(const std::string &zmq_proto, bool allow_metadata) : endpoint_(""), zmq_proto_(zmq_proto), zmq_context_(1), zmq_pub_sock_(zmq_context_, ZMQ_PUB), - zmq_message_ix(0) + zmq_message_ix(0), + m_allow_metadata(allow_metadata) { } DabOutputZMQ(const DabOutputZMQ& other) = delete; @@ -338,6 +339,7 @@ class DabOutputZMQ : public DabOutput zmq_dab_message_t zmq_message; int zmq_message_ix; + bool m_allow_metadata; std::vector<std::shared_ptr<OutputMetadata> > meta_; }; diff --git a/src/dabOutput/dabOutputZMQ.cpp b/src/dabOutput/dabOutputZMQ.cpp index 582af80..f50b7c3 100644 --- a/src/dabOutput/dabOutputZMQ.cpp +++ b/src/dabOutput/dabOutputZMQ.cpp @@ -126,7 +126,9 @@ int DabOutputZMQ::Close() void DabOutputZMQ::setMetadata(std::shared_ptr<OutputMetadata> &md) { - meta_.push_back(md); + if (m_allow_metadata) { + meta_.push_back(md); + } } #endif |