#include "ULEdec.hh"
+#include <linux/dvb/dmx.h>
+#include <boost/format.hpp>
#include "Packets/PacketData.hh"
#include "Utils/hexdump.hh"
#include "Utils/membind.hh"
#define PID 271
-#define TS_SYNC 0x47
+#define TRANSPORT_PACKET_SIZE 188
+// max. payload_pointer = ts packet payload size ( = ts packet size - ts header - payload_pointer)
+// - 2 bytes min. sndu header
+#define MAX_PAYLOAD_POINTER ( TRANSPORT_PACKET_SIZE - 4 - 1 - 2 )
#define prefix_
///////////////////////////////cc.p////////////////////////////////////////
-ULEdec::ULEdec()
+ULEdec::ULEdec(unsigned short adapter, unsigned short device)
+ : demuxHandle( adapter, device ), dvrHandle( adapter, device )
{
struct dmx_pes_filter_params pes_filter;
memset(&pes_filter, 0, sizeof (struct dmx_pes_filter_params));
dvrHandle.read( ts_packet.data() );
// Check TS error conditions: sync_byte, transport_error_indicator, scrambling_control.
- if ( (ts_packet->sync_byte() != TS_SYNC) ||
+ if ( (ts_packet->sync_byte() != TRANSPORT_PACKET_SYNC_BYTE) ||
(ts_packet->transport_error_indicator() == true) ||
(ts_packet->transport_scrmbl_ctrl() != 0))
{
return;
default:
if ( (*payload_iter++ << 8 | *payload_iter++) != ULE_END_INDICATOR )
- std::cerr << "delimiting error 1\n";
+ std::cerr << "delimiting error\n";
} else {
BOOST_ASSERT( std::distance( payload_iter, payload_end ) == 0 );
}
case 1: {
// a PUSI value of 1 indicates the presence of a Payload Pointer.
unsigned char payload_pointer = *payload_iter++;
- if (payload_pointer > 181) {
- std::cerr << "invalid payload_pointer\n";
+ if (payload_pointer > MAX_PAYLOAD_POINTER) {
+ std::cerr << str( boost::format(
+ "invalid payload_pointer (%d)\n") % unsigned(payload_pointer) ) ;
this->receiver_state = Idle;
return;
}
// Reassembly Payload Pointer Checking
if (snduPacketBytesLeft() != payload_pointer) {
// delimiting error
- std::cerr << "delimiting error 2\n";
+ std::cerr << str( boost::format(
+ "delimiting error: bytes left in SNDU packet != payload_pointer ("
+ "(%d != %d)\n") % snduPacketBytesLeft() % payload_pointer );
std::advance(payload_iter, payload_pointer);
} else {
payload_iter = readContSNDUPacket( payload_iter, payload_end );
dbit = true;
}
if (sndu_length < 5 || sndu_length == 0xffff) {
- throw ULEdecException("SNDU length error");
+ throw ULEdecException( str( boost::format(
+ "SNDU length error. length=%d") % sndu_length) );
}
this->snduPacket = senf::SNDUPacket::create(sndu_length+4);
this->snduPacket->d_bit() = dbit;
this->snduPacket.dump(std::cout);
std::cout << "----------------------------------------------------------------------------\n\n";
if (this->snduPacket->crc() != this->snduPacket->calcCrc()) {
- throw ULEdecException("CRC Error");
+ throw ULEdecException( str( boost::format(
+ "CRC Error. received crc:%d calculated crc:%d")
+ % this->snduPacket->crc() % this->snduPacket->calcCrc() ) );
}
// senf::Packet nextPacket = this->snduPacket.next();
// senf::hexdump(