diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2013-12-15 15:56:32 +0100 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2013-12-15 16:32:15 +0100 |
| commit | f172d049863a38f33e8b15a3e47d4904b2c81323 (patch) | |
| tree | 3c4fa6fba8002a1b5d9ce2edbd9720ba13d8417f /src/ParserConfigfile.cpp | |
| parent | 2b52846562d310d55a5e16149523e2aa7de2ab0a (diff) | |
| download | dabmux-f172d049863a38f33e8b15a3e47d4904b2c81323.tar.gz dabmux-f172d049863a38f33e8b15a3e47d4904b2c81323.tar.bz2 dabmux-f172d049863a38f33e8b15a3e47d4904b2c81323.zip | |
Add ZeroMQ dabplus input
For use in combination with fdk-aac-dabplus-zmq
Diffstat (limited to 'src/ParserConfigfile.cpp')
| -rw-r--r-- | src/ParserConfigfile.cpp | 18 |
1 files changed, 17 insertions, 1 deletions
diff --git a/src/ParserConfigfile.cpp b/src/ParserConfigfile.cpp index 860b9b1..dcf6733 100644 --- a/src/ParserConfigfile.cpp +++ b/src/ParserConfigfile.cpp @@ -61,6 +61,7 @@ #include "dabInputRawFifo.h" #include "dabInputDmbFile.h" #include "dabInputDmbUdp.h" +#include "dabInputZmq.h" #include "DabMux.h" @@ -475,9 +476,24 @@ void setup_subchannel_from_ptree(dabSubchannel* subchan, } else if (strcmp(subchan->inputProto, "file") == 0) { subchan->operations = dabInputDabplusFileOperations; #endif // defined(HAVE_INPUT_FILE) +#if defined(HAVE_INPUT_ZEROMQ) + } + else if (strcmp(subchan->inputProto, "tcp") == 0) { + subchan->operations = dabInputZmqOperations; + } + else if (strcmp(subchan->inputProto, "epmg") == 0) { + etiLog.printHeader(TcpLog::WARNING, + "Using untested epmg:// zeromq input\n"); + subchan->operations = dabInputZmqOperations; + } + else if (strcmp(subchan->inputProto, "ipc") == 0) { + etiLog.printHeader(TcpLog::WARNING, + "Using untested ipc:// zeromq input\n"); + subchan->operations = dabInputZmqOperations; +#endif // defined(HAVE_INPUT_ZEROMQ) } else { stringstream ss; - ss << "Subchannel with uid " << subchanuid << + ss << "Subchannel with uid " << subchanuid << ": Invalid protocol for DAB+ input (" << subchan->inputProto << ")" << endl; throw runtime_error(ss.str()); |