16#define PMT_SCAN_TIMEOUT 1000
78 cCaDescriptors(
int Source,
int Transponder,
int ServiceId,
int PmtPid);
80 bool Is(
int Source,
int Transponder,
int ServiceId);
85 int GetCaPids(
const int *CaSystemIds,
int BufSize,
int *Pids);
126 for (
int i = 0; i <
numCaIds; i++) {
127 if (
caIds[i] == CaId)
147#ifdef DEBUG_CA_DESCRIPTORS
151 for (
int i = 0; i < nca->
Length(); i++)
152 q += sprintf(q,
" %02X", nca->
Data()[i]);
165 if (!CaSystemIds || !*CaSystemIds)
168 if (EsPid < 0 || d->EsPid() == EsPid) {
169 const int *caids = CaSystemIds;
171 if (*caids == 0xFFFF || d->CaSystem() == *caids)
172 Buffer.
Append(d->Data(), d->Length());
180 if (!CaSystemIds || !*CaSystemIds)
182 if (BufSize > 0 && Pids) {
185 const int *caids = CaSystemIds;
187 if (*caids == 0xFFFF || d->CaSystem() == *caids) {
188 if (numPids + 1 < BufSize) {
189 Pids[numPids++] = d->CaPid();
213 int GetCaPids(
int Source,
int Transponder,
int ServiceId,
const int *CaSystemIds,
int BufSize,
int *Pids);
214 int GetPmtPid(
int Source,
int Transponder,
int ServiceId);
221 if (ca->Is(CaDescriptors)) {
222 if (*ca == *CaDescriptors) {
223 delete CaDescriptors;
232 return CaDescriptors->
Empty() ? 0 : 1;
239 if (ca->Is(Source, Transponder, ServiceId)) {
240 ca->GetCaDescriptors(CaSystemIds, Buffer, EsPid);
250 if (ca->Is(Source, Transponder, ServiceId))
251 return ca->GetCaPids(CaSystemIds, BufSize, Pids);
260 if (ca->Is(Source, Transponder, ServiceId))
261 return ca->GetPmtPid();
270 CaDescriptorHandler.GetCaDescriptors(Source, Transponder, ServiceId, CaSystemIds, Buffer, EsPid);
273int GetCaPids(
int Source,
int Transponder,
int ServiceId,
const int *CaSystemIds,
int BufSize,
int *Pids)
275 return CaDescriptorHandler.GetCaPids(Source, Transponder, ServiceId, CaSystemIds, BufSize, Pids);
278int GetPmtPid(
int Source,
int Transponder,
int ServiceId)
360#define DBGLOG(a...) { cString s = cString::sprintf(a); fprintf(stderr, "%s\n", *s); dsyslog("%s", *s); }
362#define DBGLOG(a...) void()
379 pPid->SetState(pPid->Count() > 0);
385 DBGLOG(
"PAT filter set status %d", On);
403 DBGLOG(
"PAT filter trigger");
411 DBGLOG(
"PAT filter request SID %d", Sid);
413 if (sr->Sid() == Sid) {
415 DBGLOG(
"PAT filter add SID request %d (%d)", Sid, sr->Count());
419 DBGLOG(
"PAT filter new SID request %d", Sid);
422 if (se->Sid() == Sid) {
425 DBGLOG(
" PMT pid %5d SID %5d (%d)", pPid->
Pid(), se->Sid(), pPid->
Count());
434 DBGLOG(
"PAT filter release SID %d", Sid);
436 if (sr->Sid() == Sid) {
438 DBGLOG(
"PAT filter del SID request %d (%d)", Sid, sr->Count());
439 if (sr->Count() == 0) {
442 if (se->Sid() == Sid) {
445 DBGLOG(
" PMT pid %5d SID %5d (%d)", pPid->
Pid(), se->Sid(), pPid->
Count());
458 if (sr->Sid() == Sid)
467 if (se->Pid() == PmtPid && !se->Received())
476 if (se->Pid() == PmtPid) {
477 se->SetReceived(
false);
478 se->PidEntry()->SetComplete(
false);
486 if (se->Sid() == Sid && se->Pid() == PmtPid) {
487 if (!se->Received()) {
488 se->SetReceived(
true);
491 if (se->Version() != Version) {
493 se->SetVersion(Version);
531 int State = pPid->State();
538 else if (Pid != 0x00)
559 int PmtPid = assoc.
getPid();
563 if (pPid->
Pid() == PmtPid)
567 DBGLOG(
" PMT pid %5d SID %5d%s%s", PmtPid, PmtSid, SidRequest ?
" R" :
"", pPid ?
" S" :
"");
579 if (pPid->Count() == 0) {
606 bool ChannelsModified =
false;
630 uint16_t CompositionPageIds[
MAXSPIDS + 1] = { 0 };
631 uint16_t AncillaryPageIds[
MAXSPIDS + 1] = { 0 };
640 bool ProcessCaDescriptors =
false;
641 int esPid = stream.
getPid();
650 ProcessCaDescriptors =
true;
658 Apids[NumApids] = esPid;
666 char *s = ALangs[NumApids];
686 ProcessCaDescriptors =
true;
703 ProcessCaDescriptors =
true;
707 Spids[NumSpids] = esPid;
710 char *s = SLangs[NumSpids];
742 Dpids[NumDpids] = dpid;
743 Dtypes[NumDpids] = dtype;
755 ProcessCaDescriptors =
true;
776 Dpids[NumDpids] = esPid;
781 ProcessCaDescriptors =
true;
823 Dpids[NumDpids] = esPid;
828 ProcessCaDescriptors =
true;
834 if (ProcessCaDescriptors) {
841 if (
Setup.UpdateChannels == 1 ||
Setup.UpdateChannels >= 3)
842 ChannelsModified |=
Channel->ClearObsoleteChannel();
843 if (
Setup.UpdateChannels >= 2) {
844 ChannelsModified |=
Channel->SetPids(Vpid, Ppid, Vtype, Apids, Atypes, ALangs, Dpids, Dtypes, DLangs, Spids, SLangs, Tpid);
845 ChannelsModified |=
Channel->SetCaIds(CaDescriptors->
CaIds());
846 ChannelsModified |=
Channel->SetSubtitlingDescriptors(SubtitlingTypes, CompositionPageIds, AncillaryPageIds);
850 StateKey.
Remove(ChannelsModified);
852 if (
timer.TimedOut()) {
const unsigned char * getData() const
Descriptor * getNext(Iterator &it)
DescriptorTag getDescriptorTag() const
StructureLoop< Language > languageLoop
int getTableIdExtension() const
int getSectionNumber() const
int getLastSectionNumber() const
int getVersionNumber() const
StructureLoop< Association > associationLoop
DescriptorLoop streamDescriptors
int getStreamType() const
StructureLoop< Stream > streamLoop
DescriptorLoop commonDescriptors
int getFormatIdentifier() const
int getSubtitlingType() const
int getAncillaryPageId() const
int getCompositionPageId() const
StructureLoop< Subtitling > subtitlingLoop
int GetCaPids(int Source, int Transponder, int ServiceId, const int *CaSystemIds, int BufSize, int *Pids)
int GetPmtPid(int Source, int Transponder, int ServiceId)
void GetCaDescriptors(int Source, int Transponder, int ServiceId, const int *CaSystemIds, cDynamicBuffer &Buffer, int EsPid)
int AddCaDescriptors(cCaDescriptors *CaDescriptors)
cCaDescriptor(int CaSystem, int CaPid, int EsPid, int Length, const uchar *Data)
const uchar * Data(void) const
bool operator==(const cCaDescriptor &arg) const
cCaDescriptors(int Source, int Transponder, int ServiceId, int PmtPid)
const int GetPmtPid(void)
bool Is(int Source, int Transponder, int ServiceId)
cList< cCaDescriptor > caDescriptors
void AddCaDescriptor(SI::CaDescriptor *d, int EsPid)
int GetCaPids(const int *CaSystemIds, int BufSize, int *Pids)
bool operator==(const cCaDescriptors &arg) const
void GetCaDescriptors(const int *CaSystemIds, cDynamicBuffer &Buffer, int EsPid)
static cChannels * GetChannelsWrite(cStateKey &StateKey, int TimeoutMs=0)
Gets the list of channels for write access.
const cChannel * GetByServiceID(int Source, int Transponder, unsigned short ServiceID) const
void Append(const uchar *Data, int Length)
void Set(u_short Pid, u_char Tid, u_char Mask=0xFF)
Sets the given filter data by calling Add() with Sticky = true.
int Transponder(void)
Returns the transponder of the data delivered to this filter.
virtual void SetStatus(bool On)
Turns this filter on or off, depending on the value of On.
int Source(void)
Returns the source of the data delivered to this filter.
const cChannel * Channel(void)
Returns the channel of the data delivered to this filter.
void Del(u_short Pid, u_char Tid, u_char Mask=0xFF)
Deletes the given filter data from this filter.
void Add(u_short Pid, u_char Tid, u_char Mask=0xFF, bool Sticky=false)
Adds the given filter data to this filter.
void Del(cListObject *Object, bool DeleteObject=true)
void Add(cListObject *Object, cListObject *After=NULL)
cListObject(const cListObject &ListObject)
const T * First(void) const
Returns the first element in this list, or NULL if the list is empty.
cList(const char *NeedsLocking=NULL)
const T * Next(const T *Object) const
< Returns the element immediately before Object in this list, or NULL if Object is the first element ...
cList< cPmtSidEntry > pmtSidList
int NumSidRequests(int Sid)
void PmtPidReset(int PmtPid)
bool PmtPidComplete(int PmtPid)
void SwitchToNextPmtPid(void)
virtual void SetStatus(bool On)
Turns this filter on or off, depending on the value of On.
bool PmtVersionChanged(int PmtPid, int Sid, int Version, bool SetNewVersion=false)
cList< cPmtPidEntry > pmtPidList
cSectionSyncer sectionSyncer
virtual void Process(u_short Pid, u_char Tid, const u_char *Data, int Length)
Processes the data delivered to this filter.
bool TransponderChanged(void)
cList< cPmtSidRequest > pmtSidRequestList
void SetComplete(bool State)
cPmtPidEntry * PidEntry(void)
void SetReceived(bool State)
cPmtSidEntry(int Sid, cPmtPidEntry *PidEntry)
void SetVersion(int Version)
void Remove(bool IncState=true)
Removes this key from the lock it was previously used with.
#define STANDARD_ANSISCTE
const char * I18nNormalizeLanguageCode(const char *Code)
Returns a 3 letter language code that may not be zero terminated.
@ EnhancedAC3DescriptorTag
@ SubtitlingDescriptorTag
@ ISO639LanguageDescriptorTag
@ RegistrationDescriptorTag
int GetCaPids(int Source, int Transponder, int ServiceId, const int *CaSystemIds, int BufSize, int *Pids)
Gets all CA pids for a given channel.
int GetPmtPid(int Source, int Transponder, int ServiceId)
Gets the Pid of the PMT in which the CA descriptors for this channel are defined.
void GetCaDescriptors(int Source, int Transponder, int ServiceId, const int *CaSystemIds, cDynamicBuffer &Buffer, int EsPid)
Gets all CA descriptors for a given channel.
cCaDescriptorHandler CaDescriptorHandler