diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2017-01-13 11:53:15 +0100 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2017-01-13 11:53:15 +0100 |
| commit | ea5594186bafa5489d6086a26d71b8f3d1ccf9cd (patch) | |
| tree | a307b0882a867b415c68cd7d644241abe0c971e1 /src/DabMod.cpp | |
| parent | f908d28e72887b68391a246ceb328cb52dcb2aaa (diff) | |
| download | dabmod-ea5594186bafa5489d6086a26d71b8f3d1ccf9cd.tar.gz dabmod-ea5594186bafa5489d6086a26d71b8f3d1ccf9cd.tar.bz2 dabmod-ea5594186bafa5489d6086a26d71b8f3d1ccf9cd.zip | |
Add threaded UDP input for EDI
Diffstat (limited to 'src/DabMod.cpp')
| -rw-r--r-- | src/DabMod.cpp | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/DabMod.cpp b/src/DabMod.cpp index 8065a5a..ac7842f 100644 --- a/src/DabMod.cpp +++ b/src/DabMod.cpp @@ -627,6 +627,9 @@ int launch_modulator(int argc, char* argv[]) else if (inputName.substr(0, 6) == "tcp://") { inputTransport = "tcp"; } + else if (inputName.substr(0, 6) == "udp://") { + inputTransport = "edi"; + } } else { inputName = "/dev/stdin"; @@ -784,7 +787,11 @@ int launch_modulator(int argc, char* argv[]) } set_thread_name("modulator"); - if (ediUdpInput.isEnabled()) { + if (inputTransport == "edi") { + if (not ediUdpInput.isEnabled()) { + etiLog.level(error) << "inputTransport is edi, but ediUdpInput is not enabled"; + return -1; + } Flowgraph flowgraph; auto modulator = make_shared<DabModulator>( |