aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthias P. Braendli <matthias.braendli@mpb.li>2016-03-06 12:59:26 +0100
committerMatthias P. Braendli <matthias.braendli@mpb.li>2016-03-06 12:59:26 +0100
commit8232afa98191969bacaf8cff9ecf9b39d6e1c294 (patch)
tree59e1506bcc1a557c27264d51d93106aa781b2163
parent567c6028c6cceb81efc592e63122a495ea5aa0cf (diff)
downloaddabmux-8232afa98191969bacaf8cff9ecf9b39d6e1c294.tar.gz
dabmux-8232afa98191969bacaf8cff9ecf9b39d6e1c294.tar.bz2
dabmux-8232afa98191969bacaf8cff9ecf9b39d6e1c294.zip
MPEG zmq input bugfix
-rw-r--r--src/dabInputZmq.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/dabInputZmq.cpp b/src/dabInputZmq.cpp
index e5a1654..70fd0c8 100644
--- a/src/dabInputZmq.cpp
+++ b/src/dabInputZmq.cpp
@@ -376,7 +376,7 @@ int DabInputZmqMPEG::readFromSocket(size_t framesize)
}
- if (datalen)
+ if (datalen == framesize)
{
if (m_frame_buffer.size() > m_config.buffer_size) {
etiLog.level(warn) <<
@@ -398,7 +398,7 @@ int DabInputZmqMPEG::readFromSocket(size_t framesize)
else {
etiLog.level(error) <<
"inputZMQ " << m_name <<
- " wrong data size: recv'd " << msg.size() << " Bytes" <<
+ " verify bitrate: recv'd " << msg.size() << " B" <<
", need " << framesize << ".";
messageReceived = false;
}
@@ -479,7 +479,7 @@ int DabInputZmqAAC::readFromSocket(size_t framesize)
else {
etiLog.level(error) <<
"inputZMQ " << m_name <<
- " wrong data size: recv'd " << msg.size() <<
+ " verify bitrate: recv'd " << msg.size() << " B" <<
", need " << 5*framesize << ".";
datalen = 0;