summaryrefslogtreecommitdiff
path: root/sections.c
diff options
context:
space:
mode:
authorKlaus Schmidinger <vdr@tvdr.de>2003-12-22 13:29:24 +0100
committerKlaus Schmidinger <vdr@tvdr.de>2003-12-22 13:29:24 +0100
commit7ff59171e3f907a5584b72f0f8588ed65f22c0bd (patch)
tree801b1b65840c50a4f1d8abea806fa5c180051df1 /sections.c
parent84b99ea81095f421ec049dd6b5bd5f0f2fe679c1 (diff)
downloadvdr-7ff59171e3f907a5584b72f0f8588ed65f22c0bd.tar.gz
vdr-7ff59171e3f907a5584b72f0f8588ed65f22c0bd.tar.bz2
Changed section handling; replaced 'libdtv' with 'libsi'
Diffstat (limited to 'sections.c')
-rw-r--r--sections.c180
1 files changed, 180 insertions, 0 deletions
diff --git a/sections.c b/sections.c
new file mode 100644
index 00000000..4a2f6d5f
--- /dev/null
+++ b/sections.c
@@ -0,0 +1,180 @@
+/*
+ * sections.c: Section data handling
+ *
+ * See the main source file 'vdr.c' for copyright information and
+ * how to reach the author.
+ *
+ * $Id: sections.c 1.1 2003/12/22 11:17:38 kls Exp $
+ */
+
+#include "sections.h"
+#include <unistd.h>
+#include "device.h"
+
+// --- cFilterHandle----------------------------------------------------------
+
+class cFilterHandle : public cListObject {
+public:
+ cFilterData filterData;
+ int handle;
+ int used;
+ cFilterHandle(const cFilterData &FilterData);
+ };
+
+cFilterHandle::cFilterHandle(const cFilterData &FilterData)
+{
+ filterData = FilterData;
+ handle = -1;
+ used = 0;
+}
+
+// --- cSectionHandler -------------------------------------------------------
+
+cSectionHandler::cSectionHandler(cDevice *Device)
+:cThread("Section handler")
+{
+ device = Device;
+ active = false;
+ source = 0;
+ transponder = 0;
+ statusCount = 0;
+ on = false;
+ Start();
+}
+
+cSectionHandler::~cSectionHandler()
+{
+ active = false;
+ Cancel(3);
+ cFilter *fi;
+ while ((fi = filters.First()) != NULL)
+ Detach(fi);
+}
+
+void cSectionHandler::Add(const cFilterData *FilterData)
+{
+ Lock();
+ statusCount++;
+ cFilterHandle *fh;
+ for (fh = filterHandles.First(); fh; fh = filterHandles.Next(fh)) {
+ if (fh->filterData.Is(FilterData->pid, FilterData->tid, FilterData->mask))
+ break;
+ }
+ if (!fh) {
+ fh = new cFilterHandle(*FilterData);
+ filterHandles.Add(fh);
+ fh->handle = device->OpenFilter(FilterData->pid, FilterData->tid, FilterData->mask);
+ }
+ fh->used++;
+ Unlock();
+}
+
+void cSectionHandler::Del(const cFilterData *FilterData)
+{
+ Lock();
+ statusCount++;
+ cFilterHandle *fh;
+ for (fh = filterHandles.First(); fh; fh = filterHandles.Next(fh)) {
+ if (fh->filterData.Is(FilterData->pid, FilterData->tid, FilterData->mask)) {
+ if (--fh->used <= 0) {
+ close(fh->handle);
+ filterHandles.Del(fh);
+ break;
+ }
+ }
+ }
+ Unlock();
+}
+
+void cSectionHandler::Attach(cFilter *Filter)
+{
+ Lock();
+ statusCount++;
+ filters.Add(Filter);
+ Filter->sectionHandler = this;
+ Filter->SetStatus(true);
+ Unlock();
+}
+
+void cSectionHandler::Detach(cFilter *Filter)
+{
+ Lock();
+ statusCount++;
+ Filter->SetStatus(false);
+ Filter->sectionHandler = NULL;
+ filters.Del(Filter, false);
+ Unlock();
+}
+
+void cSectionHandler::SetSource(int Source, int Transponder)
+{
+ source = Source;
+ transponder = Transponder;
+}
+
+void cSectionHandler::SetStatus(bool On)
+{
+ if (on != On) {
+ Lock();
+ statusCount++;
+ for (cFilter *fi = filters.First(); fi; fi = filters.Next(fi)) {
+ fi->SetStatus(false);
+ if (On)
+ fi->SetStatus(true);
+ }
+ Unlock();
+ on = On;
+ }
+}
+
+void cSectionHandler::Action(void)
+{
+ active = true;
+ while (active) {
+
+ Lock();
+ int NumFilters = filterHandles.Count();
+ pollfd pfd[NumFilters];
+ for (cFilterHandle *fh = filterHandles.First(); fh; fh = filterHandles.Next(fh)) {
+ int i = fh->Index();
+ pfd[i].fd = fh->handle;
+ pfd[i].events = POLLIN;
+ }
+ int oldStatusCount = statusCount;
+ Unlock();
+
+ if (poll(pfd, NumFilters, 1000) != 0) {
+ for (int i = 0; i < NumFilters; i++) {
+ if (pfd[i].revents & POLLIN) {
+ cFilterHandle *fh = NULL;
+ LOCK_THREAD;
+ if (statusCount != oldStatusCount)
+ break;
+ for (fh = filterHandles.First(); fh; fh = filterHandles.Next(fh)) {
+ if (pfd[i].fd == fh->handle)
+ break;
+ }
+ if (fh) {
+ // Read section data:
+ unsigned char buf[4096]; // max. allowed size for any EIT section
+ int r = safe_read(fh->handle, buf, sizeof(buf));
+ if (r > 3) { // minimum number of bytes necessary to get section length
+ int len = (((buf[1] & 0x0F) << 8) | (buf[2] & 0xFF)) + 3;
+ if (len == r) {
+ // Distribute data to all attached filters:
+ int pid = fh->filterData.pid;
+ int tid = buf[0];
+ for (cFilter *fi = filters.First(); fi; fi = filters.Next(fi)) {
+ if (fi->Matches(pid, tid))
+ fi->Process(pid, tid, buf, len);
+ }
+ }
+ else
+ dsyslog("read incomplete section - len = %d, r = %d", len, r);
+ }
+ }
+ }
+ }
+ }
+ }
+}