frodovdr/vdr-plugin-iptv
1
0
Fork 0
mirror of https://github.com/rofafor/vdr-plugin-iptv.git synced 2023-10-10 13:37:03 +02:00
Code Issues Releases Wiki Activity

Minor cosmetic changes.

Browse Source
This commit is contained in:
Rolf Ahrenberg 2007-09-24 17:20:58 +00:00
parent 10173c0eac
commit 49234919ea
4 changed files with 190 additions and 221 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
device.c
View File

@ -3,7 +3,7 @@
* *
* See the README file for copyright information and how to reach the author. * See the README file for copyright information and how to reach the author.
* *
* $Id: device.c,v 1.38 2007/09/24 16:10:19 ajhseppa Exp $ * $Id: device.c,v 1.39 2007/09/24 17:20:58 rahrenbe Exp $
*/ */
#include "common.h" #include "common.h"
@ -34,7 +34,6 @@ cIptvDevice::cIptvDevice(unsigned int Index)
pIptvStreamer = new cIptvStreamer(tsBuffer, &mutex); pIptvStreamer = new cIptvStreamer(tsBuffer, &mutex);
// Initialize filter pointers // Initialize filter pointers
memset(&secfilters, '\0', sizeof(secfilters)); memset(&secfilters, '\0', sizeof(secfilters));
StartSectionHandler(); StartSectionHandler();
} }
@ -45,7 +44,7 @@ cIptvDevice::~cIptvDevice()
delete pUdpProtocol; delete pUdpProtocol;
delete tsBuffer; delete tsBuffer;
// Destroy all filters // Destroy all filters
for (int i = 0; i < eMaxFilterCount; ++i) for (int i = 0; i < eMaxSecFilterCount; ++i)
DeleteFilter(i); DeleteFilter(i);
} }
@ -155,7 +154,7 @@ bool cIptvDevice::SetPid(cPidHandle *Handle, int Type, bool On)
bool cIptvDevice::DeleteFilter(unsigned int Index) bool cIptvDevice::DeleteFilter(unsigned int Index)
{ {
if ((Index < eMaxFilterCount) && secfilters[Index]) { if ((Index < eMaxSecFilterCount) && secfilters[Index]) {
debug("cIptvDevice::DeleteFilter(%d) Index=%d\n", deviceIndex, Index); debug("cIptvDevice::DeleteFilter(%d) Index=%d\n", deviceIndex, Index);
delete secfilters[Index]; delete secfilters[Index];
secfilters[Index] = NULL; secfilters[Index] = NULL;
@ -167,12 +166,10 @@ bool cIptvDevice::DeleteFilter(unsigned int Index)
int cIptvDevice::OpenFilter(u_short Pid, u_char Tid, u_char Mask) int cIptvDevice::OpenFilter(u_short Pid, u_char Tid, u_char Mask)
{ {
// Search the next free filter slot // Search the next free filter slot
for (unsigned int i = 0; i < eMaxFilterCount; ++i) { for (unsigned int i = 0; i < eMaxSecFilterCount; ++i) {
if (!secfilters[i]) { if (!secfilters[i]) {
debug("cIptvDevice::OpenFilter(%d): Pid=%d Tid=%02X Mask=%02X Index=%d\n", deviceIndex, Pid, Tid, Mask, i); debug("cIptvDevice::OpenFilter(%d): Pid=%d Tid=%02X Mask=%02X Index=%d\n", deviceIndex, Pid, Tid, Mask, i);
secfilters[i] = new cIptvSectionFilter(i, deviceIndex, Pid, Tid, Mask);
secfilters[i] = new cIptvSectionFilter(i, deviceIndex, Pid, Tid,
Mask);
return secfilters[i]->GetReadDesc(); return secfilters[i]->GetReadDesc();
} }
} }
@ -183,7 +180,7 @@ int cIptvDevice::OpenFilter(u_short Pid, u_char Tid, u_char Mask)
bool cIptvDevice::CloseFilter(int Handle) bool cIptvDevice::CloseFilter(int Handle)
{ {
debug("cIptvDevice::CloseFilter(%d): %d\n", deviceIndex, Handle); debug("cIptvDevice::CloseFilter(%d): %d\n", deviceIndex, Handle);
for (unsigned int i = 0; i < eMaxFilterCount; ++i) { for (unsigned int i = 0; i < eMaxSecFilterCount; ++i) {
if (secfilters[i] && Handle == secfilters[i]->GetReadDesc()) if (secfilters[i] && Handle == secfilters[i]->GetReadDesc())
return DeleteFilter(i); return DeleteFilter(i);
} }
@ -260,10 +257,9 @@ bool cIptvDevice::GetTSPacket(uchar *&Data)
isPacketDelivered = true; isPacketDelivered = true;
Data = p; Data = p;
// Run the data through all filters // Run the data through all filters
for (unsigned int i = 0; i < eMaxFilterCount; ++i) { for (unsigned int i = 0; i < eMaxSecFilterCount; ++i) {
if (secfilters[i]) { if (secfilters[i])
secfilters[i]->ProcessData(p); secfilters[i]->ProcessData(p);
}
} }
return true; return true;
} }

10
device.h
View File

@ -3,7 +3,7 @@
* *
* See the README file for copyright information and how to reach the author. * See the README file for copyright information and how to reach the author.
* *
* $Id: device.h,v 1.16 2007/09/24 13:03:38 ajhseppa Exp $ * $Id: device.h,v 1.17 2007/09/24 17:20:58 rahrenbe Exp $
*/ */
#ifndef __IPTV_DEVICE_H #ifndef __IPTV_DEVICE_H
@ -11,14 +11,11 @@
#include <vdr/device.h> #include <vdr/device.h>
#include "protocoludp.h" #include "protocoludp.h"
//#include "protocolrtsp.h"
#include "protocolhttp.h" #include "protocolhttp.h"
#include "protocolfile.h" #include "protocolfile.h"
#include "streamer.h" #include "streamer.h"
#include "sectionfilter.h" #include "sectionfilter.h"
class cIptvDevice : public cDevice { class cIptvDevice : public cDevice {
// static ones // static ones
public: public:
@ -30,7 +27,7 @@ public:
// private parts // private parts
private: private:
enum { enum {
eMaxFilterCount = 32, eMaxSecFilterCount = 32
}; };
unsigned int deviceIndex; unsigned int deviceIndex;
bool isPacketDelivered; bool isPacketDelivered;
@ -42,7 +39,7 @@ private:
cIptvProtocolFile *pFileProtocol; cIptvProtocolFile *pFileProtocol;
cIptvStreamer *pIptvStreamer; cIptvStreamer *pIptvStreamer;
cMutex mutex; cMutex mutex;
cIptvSectionFilter* secfilters[eMaxFilterCount]; cIptvSectionFilter* secfilters[eMaxSecFilterCount];
// constructor & destructor // constructor & destructor
public: public:
@ -83,4 +80,3 @@ public:
}; };
#endif // __IPTV_DEVICE_H #endif // __IPTV_DEVICE_H

275
sectionfilter.c
View File

@ -3,7 +3,7 @@
* *
* See the README file for copyright information and how to reach the author. * See the README file for copyright information and how to reach the author.
* *
* $Id: sectionfilter.c,v 1.2 2007/09/24 16:08:09 ajhseppa Exp $ * $Id: sectionfilter.c,v 1.3 2007/09/24 17:20:58 rahrenbe Exp $
*/ */
#include "sectionfilter.h" #include "sectionfilter.h"
@ -12,19 +12,18 @@
cIptvSectionFilter::cIptvSectionFilter(int Index, int devInd, cIptvSectionFilter::cIptvSectionFilter(int Index, int devInd,
u_short Pid, u_char Tid, u_char Mask) u_short Pid, u_char Tid, u_char Mask)
: pusi_seen(0), : pusi_seen(0),
feedcc(0), feedcc(0),
doneq(0), doneq(0),
secbuf(NULL), secbuf(NULL),
secbufp(0), secbufp(0),
seclen(0), seclen(0),
tsfeedp(0), tsfeedp(0),
crc_val(0), crc_val(0),
pid(Pid), pid(Pid),
id(Index) id(Index)
{ {
debug("cIptvSectionFilter::cIptvSectionFilter(%d)\n", Index); debug("cIptvSectionFilter::cIptvSectionFilter(%d)\n", Index);
memset(secbuf_base, '\0', sizeof(secbuf_base)); memset(secbuf_base, '\0', sizeof(secbuf_base));
memset(filter_value, '\0', sizeof(filter_value)); memset(filter_value, '\0', sizeof(filter_value));
memset(filter_mask, '\0', sizeof(filter_mask)); memset(filter_mask, '\0', sizeof(filter_mask));
@ -97,21 +96,21 @@ inline uint16_t cIptvSectionFilter::ts_pid(const uint8_t *buf)
inline uint8_t cIptvSectionFilter::payload(const uint8_t *tsp) inline uint8_t cIptvSectionFilter::payload(const uint8_t *tsp)
{ {
if (!(tsp[3] & 0x10)) // no payload? if (!(tsp[3] & 0x10)) // no payload?
return 0; return 0;
if (tsp[3] & 0x20) { // adaptation field? if (tsp[3] & 0x20) { // adaptation field?
if (tsp[4] > 183) // corrupted data? if (tsp[4] > 183) // corrupted data?
return 0; return 0;
else else
return 184 - 1 - tsp[4]; return 184 - 1 - tsp[4];
} }
return 184; return 184;
} }
int cIptvSectionFilter::dvb_dmxdev_section_callback(const uint8_t *buffer1, size_t buffer1_len, int cIptvSectionFilter::dvb_dmxdev_section_callback(const uint8_t *buffer1, size_t buffer1_len,
const uint8_t *buffer2, size_t buffer2_len, const uint8_t *buffer2, size_t buffer2_len,
enum dmx_success success) enum dmx_success success)
{ {
struct timeval tv; struct timeval tv;
tv.tv_sec = 0; tv.tv_sec = 0;
@ -123,30 +122,26 @@ int cIptvSectionFilter::dvb_dmxdev_section_callback(const uint8_t *buffer1, size
// Check if error // Check if error
if (retval < 0) { if (retval < 0) {
char tmp[64]; char tmp[64];
error("ERROR: select(): %s", strerror_r(errno, tmp, sizeof(tmp))); error("ERROR: select(): %s", strerror_r(errno, tmp, sizeof(tmp)));
} }
// There is no data in the fifo, more can be written // There is no data in the fifo, more can be written
else if (!retval) { else if (!retval) {
#ifdef DEBUG_PRINTF #ifdef DEBUG_PRINTF
printf("id = %d, pid %d would now write %d data to buffer\n", id, pid, buffer1_len); printf("id = %d, pid %d would now write %d data to buffer\n", id, pid, buffer1_len);
for (unsigned int i = 0; i < buffer1_len; ++i) { for (unsigned int i = 0; i < buffer1_len; ++i)
printf("0x%X ", buffer1[i]); printf("0x%X ", buffer1[i]);
} printf("\n");
printf("\n");
#endif #endif
retval = write(fifoDescriptor, buffer1, buffer1_len);
retval = write(fifoDescriptor, buffer1, buffer1_len); if (retval < 0) {
char tmp[64];
if (retval < 0) { error("ERROR: write(): %s", strerror_r(errno, tmp, sizeof(tmp)));
char tmp[64]; }
error("ERROR: write(): %s", strerror_r(errno, tmp, sizeof(tmp))); }
}
}
#ifdef DEBUG_PRINTF #ifdef DEBUG_PRINTF
else if (retval) { else if (retval)
printf("id %d pid %d data is already present\n", id, pid); printf("id %d pid %d data is already present\n", id, pid);
}
#endif #endif
return 0; return 0;
} }
@ -157,64 +152,56 @@ void cIptvSectionFilter::dvb_dmx_swfilter_section_new()
{ {
#ifdef DVB_DEMUX_SECTION_LOSS_LOG #ifdef DVB_DEMUX_SECTION_LOSS_LOG
if (secbufp < tsfeedp) { if (secbufp < tsfeedp) {
int i, n = tsfeedp - secbufp; int i, n = tsfeedp - secbufp;
/*
/* * Section padding is done with 0xff bytes entirely.
* Section padding is done with 0xff bytes entirely. * Due to speed reasons, we won't check all of them
* Due to speed reasons, we won't check all of them * but just first and last.
* but just first and last. */
*/ if (secbuf[0] != 0xff || secbuf[n - 1] != 0xff) {
if (secbuf[0] != 0xff || secbuf[n - 1] != 0xff) { printf("dvb_demux.c section ts padding loss: %d/%d\n",
printf("dvb_demux.c section ts padding loss: %d/%d\n", n, tsfeedp);
n, tsfeedp); printf("dvb_demux.c pad data:");
printf("dvb_demux.c pad data:"); for (i = 0; i < n; i++)
for (i = 0; i < n; i++) printf(" %02x", secbuf[i]);
printf(" %02x", secbuf[i]); printf("\n");
printf("\n"); }
} }
}
#endif #endif
tsfeedp = secbufp = seclen = 0; tsfeedp = secbufp = seclen = 0;
secbuf = secbuf_base; secbuf = secbuf_base;
} }
int cIptvSectionFilter::dvb_dmx_swfilter_sectionfilter() int cIptvSectionFilter::dvb_dmx_swfilter_sectionfilter()
{ {
uint8_t neq = 0; uint8_t neq = 0;
int i; int i;
for (i = 0; i < DVB_DEMUX_MASK_MAX; i++) { for (i = 0; i < DVB_DEMUX_MASK_MAX; i++) {
uint8_t local_xor = filter_value[i] ^ secbuf[i]; uint8_t local_xor = filter_value[i] ^ secbuf[i];
if (maskandmode[i] & local_xor) {
if (maskandmode[i] & local_xor) {
#ifdef DEBUG_PRINTF #ifdef DEBUG_PRINTF
printf("maskandmode discard\n"); printf("maskandmode discard\n");
#endif #endif
return 0; return 0;
} }
neq |= maskandnotmode[i] & local_xor;
neq |= maskandnotmode[i] & local_xor; }
}
if (doneq && !neq) { if (doneq && !neq) {
#ifdef DEBUG_PRINTF #ifdef DEBUG_PRINTF
printf("doneq discard, doneq = 0x%X, neq = 0x%X\n", doneq, !neq); printf("doneq discard, doneq = 0x%X, neq = 0x%X\n", doneq, !neq);
#endif #endif
return 0; return 0;
} }
return dvb_dmxdev_section_callback(secbuf, seclen, NULL, 0, DMX_OK); return dvb_dmxdev_section_callback(secbuf, seclen, NULL, 0, DMX_OK);
} }
inline int cIptvSectionFilter::dvb_dmx_swfilter_section_feed() inline int cIptvSectionFilter::dvb_dmx_swfilter_section_feed()
{ {
if (dvb_dmx_swfilter_sectionfilter() < 0) if (dvb_dmx_swfilter_sectionfilter() < 0)
return -1; return -1;
seclen = 0; seclen = 0;
return 0; return 0;
} }
@ -222,20 +209,20 @@ int cIptvSectionFilter::dvb_dmx_swfilter_section_copy_dump(const uint8_t *buf, u
{ {
uint16_t limit, seclen_local, n; uint16_t limit, seclen_local, n;
if (tsfeedp >= DMX_MAX_SECFEED_SIZE) { if (tsfeedp >= DMX_MAX_SECFEED_SIZE)
return 0; return 0;
}
if (tsfeedp + len > DMX_MAX_SECFEED_SIZE) { if (tsfeedp + len > DMX_MAX_SECFEED_SIZE) {
#ifdef DVB_DEMUX_SECTION_LOSS_LOG #ifdef DVB_DEMUX_SECTION_LOSS_LOG
printf("dvb_demux.c section buffer full loss: %d/%d\n", printf("dvb_demux.c section buffer full loss: %d/%d\n",
tsfeedp + len - DMX_MAX_SECFEED_SIZE, tsfeedp + len - DMX_MAX_SECFEED_SIZE,
DMX_MAX_SECFEED_SIZE); DMX_MAX_SECFEED_SIZE);
#endif #endif
len = DMX_MAX_SECFEED_SIZE - tsfeedp; len = DMX_MAX_SECFEED_SIZE - tsfeedp;
} }
if (len <= 0) if (len <= 0)
return 0; return 0;
memcpy(secbuf_base + tsfeedp, buf, len); memcpy(secbuf_base + tsfeedp, buf, len);
tsfeedp += len; tsfeedp += len;
@ -244,55 +231,50 @@ int cIptvSectionFilter::dvb_dmx_swfilter_section_copy_dump(const uint8_t *buf, u
* Dump all the sections we can find in the data (Emard) * Dump all the sections we can find in the data (Emard)
*/ */
limit = tsfeedp; limit = tsfeedp;
if (limit > DMX_MAX_SECFEED_SIZE) { if (limit > DMX_MAX_SECFEED_SIZE)
return -1; /* internal error should never happen */ return -1; /* internal error should never happen */
}
/* to be sure always set secbuf */ /* to be sure always set secbuf */
secbuf = secbuf_base + secbufp; secbuf = secbuf_base + secbufp;
for (n = 0; secbufp + 2 < limit; n++) { for (n = 0; secbufp + 2 < limit; n++) {
seclen_local = section_length(secbuf); seclen_local = section_length(secbuf);
if (seclen_local <= 0 || seclen_local > DMX_MAX_SECTION_SIZE if (seclen_local <= 0 || seclen_local > DMX_MAX_SECTION_SIZE ||
|| seclen_local + secbufp > limit) { seclen_local + secbufp > limit)
return 0; return 0;
}
#ifdef DEBUG_PRINTF #ifdef DEBUG_PRINTF
printf("Non-mismatching seclen! %d, limit = %d\n", seclen_local, limit); printf("Non-mismatching seclen! %d, limit = %d\n", seclen_local, limit);
#endif #endif
seclen = seclen_local; seclen = seclen_local;
crc_val = ~0; crc_val = ~0;
/* dump [secbuf .. secbuf+seclen) */ /* dump [secbuf .. secbuf+seclen) */
if (pusi_seen) { if (pusi_seen)
dvb_dmx_swfilter_section_feed(); dvb_dmx_swfilter_section_feed();
}
#ifdef DVB_DEMUX_SECTION_LOSS_LOG #ifdef DVB_DEMUX_SECTION_LOSS_LOG
else else
printf("dvb_demux.c pusi not seen, discarding section data\n"); printf("dvb_demux.c pusi not seen, discarding section data\n");
#endif #endif
secbufp += seclen_local; /* secbufp and secbuf moving together is */ secbufp += seclen_local; /* secbufp and secbuf moving together is */
secbuf += seclen_local; /* redundant but saves pointer arithmetic */ secbuf += seclen_local; /* redundant but saves pointer arithmetic */
} }
return 0; return 0;
} }
void cIptvSectionFilter::ProcessData(const uint8_t* buf) void cIptvSectionFilter::ProcessData(const uint8_t* buf)
{ {
if (buf[0] != 0x47) { if (buf[0] != 0x47) {
error("Not TS packet: 0x%X\n", buf[0]); error("Not TS packet: 0x%X\n", buf[0]);
return; return;
} }
// Stop if not the PID this filter is looking for // Stop if not the PID this filter is looking for
if (ts_pid(buf) != pid) if (ts_pid(buf) != pid)
return; return;
uint8_t count = payload(buf); uint8_t count = payload(buf);
if (count == 0) /* count == 0 if no payload or out of range */ if (count == 0) /* count == 0 if no payload or out of range */
return; return;
uint8_t p = 188 - count; /* payload start */ uint8_t p = 188 - count; /* payload start */
@ -302,53 +284,52 @@ void cIptvSectionFilter::ProcessData(const uint8_t* buf)
int dc_i = 0; int dc_i = 0;
if (buf[3] & 0x20) { if (buf[3] & 0x20) {
/* adaption field present, check for discontinuity_indicator */ /* adaption field present, check for discontinuity_indicator */
if ((buf[4] > 0) && (buf[5] & 0x80)) if ((buf[4] > 0) && (buf[5] & 0x80))
dc_i = 1; dc_i = 1;
} }
if (!ccok || dc_i) { if (!ccok || dc_i) {
#ifdef DVB_DEMUX_SECTION_LOSS_LOG #ifdef DVB_DEMUX_SECTION_LOSS_LOG
printf("dvb_demux.c discontinuity detected %d bytes lost\n", printf("dvb_demux.c discontinuity detected %d bytes lost\n",
count); count);
/* /*
* those bytes under sume circumstances will again be reported * those bytes under sume circumstances will again be reported
* in the following dvb_dmx_swfilter_section_new * in the following dvb_dmx_swfilter_section_new
*/ */
#endif #endif
/* /*
* Discontinuity detected. Reset pusi_seen = 0 to * Discontinuity detected. Reset pusi_seen = 0 to
* stop feeding of suspicious data until next PUSI=1 arrives * stop feeding of suspicious data until next PUSI=1 arrives
*/ */
pusi_seen = 0; pusi_seen = 0;
dvb_dmx_swfilter_section_new(); dvb_dmx_swfilter_section_new();
} }
if (buf[1] & 0x40) { if (buf[1] & 0x40) {
/* PUSI=1 (is set), section boundary is here */ /* PUSI=1 (is set), section boundary is here */
if (count > 1 && buf[p] < count) { if (count > 1 && buf[p] < count) {
#ifdef DEBUG_PRINTF #ifdef DEBUG_PRINTF
printf("Valid section\n"); printf("Valid section\n");
#endif #endif
const uint8_t *before = &buf[p + 1]; const uint8_t *before = &buf[p + 1];
uint8_t before_len = buf[p]; uint8_t before_len = buf[p];
const uint8_t *after = &before[before_len]; const uint8_t *after = &before[before_len];
uint8_t after_len = count - 1 - before_len; uint8_t after_len = count - 1 - before_len;
dvb_dmx_swfilter_section_copy_dump(before, before_len); dvb_dmx_swfilter_section_copy_dump(before, before_len);
/* before start of new section, set pusi_seen = 1 */ /* before start of new section, set pusi_seen = 1 */
pusi_seen = 1; pusi_seen = 1;
dvb_dmx_swfilter_section_new(); dvb_dmx_swfilter_section_new();
dvb_dmx_swfilter_section_copy_dump(after, after_len); dvb_dmx_swfilter_section_copy_dump(after, after_len);
} }
#ifdef DVB_DEMUX_SECTION_LOSS_LOG #ifdef DVB_DEMUX_SECTION_LOSS_LOG
else if (count > 0) else if (count > 0)
printf("dvb_demux.c PUSI=1 but %d bytes lost\n", count); printf("dvb_demux.c PUSI=1 but %d bytes lost\n", count);
#endif #endif
} else { }
/* PUSI=0 (is not set), no section boundary */ else {
dvb_dmx_swfilter_section_copy_dump(&buf[p], count); /* PUSI=0 (is not set), no section boundary */
} dvb_dmx_swfilter_section_copy_dump(&buf[p], count);
}
} }

106
sectionfilter.h
View File

@ -3,7 +3,7 @@
* *
* See the README file for copyright information and how to reach the author. * See the README file for copyright information and how to reach the author.
* *
* $Id: sectionfilter.h,v 1.1 2007/09/24 13:03:39 ajhseppa Exp $ * $Id: sectionfilter.h,v 1.2 2007/09/24 17:20:58 rahrenbe Exp $
*/ */
#ifndef __IPTV_SECTIONFILTER_H #ifndef __IPTV_SECTIONFILTER_H
@ -20,7 +20,6 @@
#include <sys/ioctl.h> #include <sys/ioctl.h>
#include <libgen.h> #include <libgen.h>
#include <stdint.h> #include <stdint.h>
#include <sys/param.h> #include <sys/param.h>
#include "common.h" #include "common.h"
@ -39,79 +38,76 @@
#define DVB_DEMUX_MASK_MAX 18 #define DVB_DEMUX_MASK_MAX 18
class cIptvSectionFilter { class cIptvSectionFilter {
private: private:
enum dmx_success { enum dmx_success {
DMX_OK = 0, /* Received Ok */ DMX_OK = 0, /* Received Ok */
DMX_LENGTH_ERROR, /* Incorrect length */ DMX_LENGTH_ERROR, /* Incorrect length */
DMX_OVERRUN_ERROR, /* Receiver ring buffer overrun */ DMX_OVERRUN_ERROR, /* Receiver ring buffer overrun */
DMX_CRC_ERROR, /* Incorrect CRC */ DMX_CRC_ERROR, /* Incorrect CRC */
DMX_FRAME_ERROR, /* Frame alignment error */ DMX_FRAME_ERROR, /* Frame alignment error */
DMX_FIFO_ERROR, /* Receiver FIFO overrun */ DMX_FIFO_ERROR, /* Receiver FIFO overrun */
DMX_MISSED_ERROR /* Receiver missed packet */ DMX_MISSED_ERROR /* Receiver missed packet */
} ; };
int fifoDescriptor; int fifoDescriptor;
int readDescriptor; int readDescriptor;
int pusi_seen; int pusi_seen;
int feedcc; int feedcc;
int doneq; int doneq;
uint8_t *secbuf; uint8_t *secbuf;
uint8_t secbuf_base[DMX_MAX_SECFEED_SIZE]; uint8_t secbuf_base[DMX_MAX_SECFEED_SIZE];
uint16_t secbufp; uint16_t secbufp;
uint16_t seclen; uint16_t seclen;
uint16_t tsfeedp; uint16_t tsfeedp;
uint32_t crc_val; uint32_t crc_val;
uint16_t pid; uint16_t pid;
int id; int id;
uint8_t filter_value[DMX_MAX_FILTER_SIZE];
uint8_t filter_value[DMX_MAX_FILTER_SIZE]; uint8_t filter_mask[DMX_MAX_FILTER_SIZE];
uint8_t filter_mask[DMX_MAX_FILTER_SIZE]; uint8_t filter_mode[DMX_MAX_FILTER_SIZE];
uint8_t filter_mode[DMX_MAX_FILTER_SIZE];
uint8_t maskandmode[DMX_MAX_FILTER_SIZE]; uint8_t maskandmode[DMX_MAX_FILTER_SIZE];
uint8_t maskandnotmode[DMX_MAX_FILTER_SIZE]; uint8_t maskandnotmode[DMX_MAX_FILTER_SIZE];
char pipeName[128]; char pipeName[128];
inline uint16_t section_length(const uint8_t *buf); inline uint16_t section_length(const uint8_t *buf);
inline uint16_t ts_pid(const uint8_t *buf); inline uint16_t ts_pid(const uint8_t *buf);
inline uint8_t payload(const uint8_t *tsp); inline uint8_t payload(const uint8_t *tsp);
int dvb_dmxdev_section_callback(const uint8_t *buffer1, int dvb_dmxdev_section_callback(const uint8_t *buffer1,
size_t buffer1_len, size_t buffer1_len,
const uint8_t *buffer2, const uint8_t *buffer2,
size_t buffer2_len, size_t buffer2_len,
enum dmx_success success); enum dmx_success success);
void dvb_dmx_swfilter_section_new(); void dvb_dmx_swfilter_section_new();
int dvb_dmx_swfilter_sectionfilter(); int dvb_dmx_swfilter_sectionfilter();
inline int dvb_dmx_swfilter_section_feed(); inline int dvb_dmx_swfilter_section_feed();
int dvb_dmx_swfilter_section_copy_dump(const uint8_t *buf, int dvb_dmx_swfilter_section_copy_dump(const uint8_t *buf,
uint8_t len); uint8_t len);
int GetFifoDesc(); int GetFifoDesc();
void ClearPipeName(); void ClearPipeName();
void SetPipeName(int deviceIndex); void SetPipeName(int deviceIndex);
public: public:
// constructor & destructor // constructor & destructor
cIptvSectionFilter(int Index, int devInd, u_short Pid, u_char Tid, cIptvSectionFilter(int Index, int devInd, u_short Pid, u_char Tid,
u_char Mask); u_char Mask);
virtual ~cIptvSectionFilter(); virtual ~cIptvSectionFilter();
void ProcessData(const uint8_t* buf); void ProcessData(const uint8_t* buf);
int GetReadDesc(); int GetReadDesc();
}; };
#endif // __IPTV_SECTIONFILTER_H #endif // __IPTV_SECTIONFILTER_H