summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorMatthias P. Braendli <matthias.braendli@mpb.li>2017-01-27 22:37:13 +0100
committerMatthias P. Braendli <matthias.braendli@mpb.li>2017-01-27 22:37:13 +0100
commitaf782e67db704d1d58c265fb4e1ff12aa1526596 (patch)
tree3d645e4389f446599b6b9eb1c74400d84f72b013 /src
parent713a5bc97a02e79b8e53dc96d64817f7f34ce311 (diff)
downloaddabmux-af782e67db704d1d58c265fb4e1ff12aa1526596.tar.gz
dabmux-af782e67db704d1d58c265fb4e1ff12aa1526596.tar.bz2
dabmux-af782e67db704d1d58c265fb4e1ff12aa1526596.zip
Fix STI-D/RTP input
Diffstat (limited to 'src')
-rw-r--r--src/input/Udp.cpp29
1 files changed, 13 insertions, 16 deletions
diff --git a/src/input/Udp.cpp b/src/input/Udp.cpp
index 5d11d1c..a7f9013 100644
--- a/src/input/Udp.cpp
+++ b/src/input/Udp.cpp
@@ -93,12 +93,14 @@ void Udp::openUdpSocket(const std::string& endpoint)
ss << "Could not set non-blocking UDP socket: " << inetErrMsg;
throw runtime_error(ss.str());
}
+
+ etiLog.level(info) << "Opened UDP port " << address << ":" << port;
}
int Udp::readFrame(uint8_t* buffer, size_t size)
{
// Regardless of buffer contents, try receiving data.
- UdpPacket packet;
+ UdpPacket packet(32768);
int ret = m_sock.receive(packet);
if (ret == -1) {
@@ -147,8 +149,8 @@ static const size_t RTP_HEADER_LEN = 12;
static bool stiSyncValid(const uint8_t *buf)
{
- return (memcmp(buf+1, STI_FSync0, sizeof(STI_FSync0)) == 0) or
- (memcmp(buf+1, STI_FSync1, sizeof(STI_FSync1)) == 0);
+ return (memcmp(buf, STI_FSync0, sizeof(STI_FSync0)) == 0) or
+ (memcmp(buf, STI_FSync1, sizeof(STI_FSync1)) == 0);
}
static bool rtpHeaderValid(const uint8_t *buf)
@@ -160,7 +162,7 @@ static bool rtpHeaderValid(const uint8_t *buf)
static uint16_t unpack2(const uint8_t *buf)
{
- return (buf[0] << 8) | buf[1];
+ return (((uint16_t)buf[0]) << 8) | buf[1];
}
int Sti_d_Rtp::open(const std::string& name)
@@ -188,7 +190,7 @@ int Sti_d_Rtp::open(const std::string& name)
void Sti_d_Rtp::receive_packet()
{
- UdpPacket packet;
+ UdpPacket packet(32768);
int ret = m_sock.receive(packet);
if (ret == -1) {
@@ -234,7 +236,7 @@ void Sti_d_Rtp::receive_packet()
// TFH
// DFS
uint16_t DFS = unpack2(buf+index);
- index += 4;
+ index += 2;
if (DFS == 0) {
etiLog.level(info) << "Received STI data with DFS=0 for " <<
m_name;
@@ -254,12 +256,6 @@ void Sti_d_Rtp::receive_packet()
m_name;
}
- // FD
- // STAT
- // ERR
- index += 1;
-
- // FC
// SPID
index += 2;
// rfa DL
@@ -268,15 +264,16 @@ void Sti_d_Rtp::receive_packet()
index += 1;
// DFCT
- uint32_t DFCTL = buf[index];
+ uint8_t DFCTL = buf[index];
index += 1;
- uint32_t DFCTH = buf[index] >> 3;
- uint32_t NST = unpack2(buf+index) & 0x7FF; // 11 bits
+ uint8_t DFCTH = buf[index] >> 3;
+ uint16_t NST = unpack2(buf+index) & 0x7FF; // 11 bits
index += 2;
if (packet.getSize() < index + 4*NST) {
etiLog.level(info) << "Received STI too small to contain NST for " <<
- m_name;
+ m_name << " packet: " << packet.getSize() << " need " <<
+ index + 4*NST;
return;
}