Hello
To be able to debug ttxtsubs plugin with a vdr daemon, I had to modify
ttxtsubs plugin to change the fprintf(stderr,...) calls to esyslog calls.
I've made debian patches (dpatch styles), but they are usable for
non-debian environment.
The first patch add some "#include <vdr/tools.h>"
The second patch is actually a dpatch, i.e. a small perl script that
replaces fprintf with esyslog. This script accepts -patch and -unpatch
arguments so the modif can be reversed. (I've written a script so the
dpatch will be smaller and more resilient to upstream changes)
Feel free to use it for debian project or any other vdr related project.
Cheers
#! /bin/sh /usr/share/dpatch/dpatch-run
## 95_include_vdr_tools.dpatch by <domi(a)gandalf.hd.free.fr>
##
## All lines beginning with `## DP:' are a description of the patch.
## DP: No description.
@DPATCH@
diff -urNad vdr-plugin-ttxtsubs-0.0.5~/teletext.c vdr-plugin-ttxtsubs-0.0.5/teletext.c
--- vdr-plugin-ttxtsubs-0.0.5~/teletext.c 2004-03-01 23:53:17.000000000 +0100
+++ vdr-plugin-ttxtsubs-0.0.5/teletext.c 2005-10-22 14:37:14.000000000 +0200
@@ -12,6 +12,7 @@
//#include <linux/dvb/dmx.h>
//#include <vdr/osd.h>
+#include <vdr/tools.h>
#include "teletext.h"
#include "teletext-tables.h"
diff -urNad vdr-plugin-ttxtsubs-0.0.5~/teletext.c~ vdr-plugin-ttxtsubs-0.0.5/teletext.c~
--- vdr-plugin-ttxtsubs-0.0.5~/teletext.c~ 1970-01-01 01:00:00.000000000 +0100
+++ vdr-plugin-ttxtsubs-0.0.5/teletext.c~ 2004-03-01 23:53:17.000000000 +0100
@@ -0,0 +1,724 @@
+
+#include <stdio.h>
+#include <stdint.h>
+#include <sys/types.h>
+#include <sys/ioctl.h>
+#include <unistd.h>
+#include <fcntl.h>
+#include <stdlib.h>
+#include <netinet/in.h>
+#include <ctype.h>
+#include <string.h>
+
+//#include <linux/dvb/dmx.h>
+//#include <vdr/osd.h>
+
+#include "teletext.h"
+#include "teletext-tables.h"
+#include "teletext-chars.h"
+#include "utils.h"
+
+
+// FROM vbidecode
+// unham 2 bytes into 1, report 2 bit errors but ignore them
+unsigned char unham(unsigned char a,unsigned char b)
+{
+ unsigned char c1,c2;
+
+ c1=unhamtab[a];
+ c2=unhamtab[b];
+// if ((c1|c2)&0x40)
+// fprintf(stderr,"bad ham!");
+ return (c2<<4)|(0x0f&c1);
+}
+
+
+// ham 8/4 the byte in into two bytes pointed to by out
+// should make a table instead
+void ham8_4byte(uint8_t in, uint8_t *out)
+{
+ out[0] = ham8_4nibble(in & 0xF);
+ out[1] = ham8_4nibble(in >> 4);
+
+ if (1) { // XXX debug
+ int a;
+ if(unham(out[0], out[1]) != in) {
+ fprintf(stderr, "ham8_4: 1 - result not correct %02x -> %02x %02x!\n", in, out[0], out[1]);
+ }
+ a = unhamtab[out[0]];
+ a ^= 0x80;
+ if(a & 0xf0 || (a != (in & 0xF))) {
+ fprintf(stderr, "ham8_4: 2 - result not correct %02x -> %02x %02x, %02x!\n", in, out[0], out[1], a);
+ }
+ a = unhamtab[out[1]];
+ a ^= 0x80;
+ if(a & 0xf0 || (a != (in >> 4))) {
+ fprintf(stderr, "ham8_4: 3 - result not correct %02x -> %02x %02x, %02x!\n", in, out[0], out[1], a);
+ }
+ }
+}
+
+// should be a table instead
+int parity(uint8_t x) {
+ int res = 1;
+ int count = x & 0xf0 ? 8 : 4;
+
+ while(count--) {
+ if(x & 0x01)
+ res = !res;
+ x >>= 1;
+ }
+
+ return res;
+}
+
+// ham 8/4 the nibble in into the byte pointed to by out
+// should make a table instead
+// D4 P4 D3 P3 D2 P2 D1 P1
+// P4 = all the rest
+uint8_t ham8_4nibble(uint8_t in)
+{
+ uint8_t o = 0;
+
+ // insert the data bits
+ o |= (in << 4) & 0x80;
+ o |= (in << 3) & 0x20;
+ o |= (in << 2) & 0x08;
+ o |= (in << 1) & 0x02;
+
+ if(parity(in & 0x0d)) // P1 = 1 . D1 . D3 . D4
+ o |= 0x01;
+ if(parity(in & 0x0b)) // P2 = 1 . D1 . D2 . D4
+ o |= 0x04;
+ if(parity(in & 0x07)) // P3 = 1 . D1 . D2 . D3
+ o |= 0x10;
+ if(parity(o & 0xbf)) // P4 = 1 . P1 . D1 . ... . D3 . D4
+ o |= 0x40;
+
+ return o;
+}
+
+
+/*
+ * Map Latin G0 teletext characters into a ISO-8859-1 approximation.
+ * Trying to use similar looking or similar meaning characters.
+ * Gtriplet - 4 bits = triplet-1 bits 14-11 (14-8) of a X/28 or M/29 packet, if unknown - use 0
+ * natopts - 3 bits = national_options field of a Y/0 packet (or triplet-1 bits 10-8 as above?)
+ * inchar - 7 bits = characted to remap
+ * Also strips parity
+ */
+
+uint8_t ttxt_laG0_la1_char(int Gtriplet, int natopts, uint8_t inchar)
+{
+ int no = laG0_nat_opts_lookup[Gtriplet & 0xf][natopts & 0x7];
+ uint8_t c = inchar & 0x7f;
+
+ //dprint("\n%x/%c/%x/%x\n", c, c, laG0_nat_replace_map[c], laG0_nat_opts[no][laG0_nat_replace_map[c]]);
+
+ if(!laG0_nat_replace_map[c])
+ return c;
+ else
+ return laG0_nat_opts[no][laG0_nat_replace_map[c]];
+}
+
+/*
+ * Map Latin G2 teletext characters into a ISO-8859-1 approximation.
+ * Trying to use similar looking or similar meaning characters.
+ */
+uint8_t ttxt_laG2_la1_char(uint8_t inchar)
+{
+ return laG2_la1_table[inchar & 0x7f];
+}
+
+void dump_hex(char *msg, const uint8_t *p, int len)
+{
+ int i;
+ printf("%s:", msg);
+ for(i = 0; i < len; i++) {
+ printf(" %02x", p[i]);
+ }
+ printf("\n");
+}
+
+
+void
+print_code(uint8_t c, int natopts)
+{
+ if(c >= 0x20) {
+ dprint("%c", ttxt_laG0_la1_char(0, natopts, c));
+ } else
+ switch(c) {
+ case 0x0:
+ case 0x1:
+ case 0x2:
+ case 0x3:
+ case 0x4:
+ case 0x5:
+ case 0x6:
+ case 0x7:
+ dprint("<fc%d>", c);
+ break;
+ case 0x08:
+ dprint("<flash>");
+ break;
+ case 0x09:
+ dprint("<Steady>");
+ break;
+ case 0x0a:
+ dprint("]");
+ break;
+ case 0x0b:
+ dprint("[");
+ break;
+ case 0x0c:
+ dprint("<normal size>");
+ break;
+ case 0x0d:
+ dprint("<dh>");
+ break;
+ case 0x0e:
+ dprint("<dbl width>");
+ break;
+ case 0x0f:
+ dprint("<dbl size>");
+ break;
+ case 0x10:
+ case 0x11:
+ case 0x12:
+ case 0x13:
+ case 0x14:
+ case 0x15:
+ case 0x16:
+ case 0x17:
+ dprint("<mosc%d>", c-0x10);
+ break;
+ case 0x18:
+ dprint("<conceal>");
+ break;
+ case 0x19:
+ dprint("<cont mosaic>");
+ break;
+ case 0x1a:
+ dprint("<sep mosaic>");
+ break;
+ case 0x1b:
+ dprint("<charset switch>");
+ break;
+ case 0x1c:
+ dprint("<black bg>");
+ break;
+ case 0x1d:
+ dprint("<new bg>");
+ break;
+ case 0x1e:
+ dprint("<hold mosaic>");
+ break;
+ case 0x1f:
+ dprint("<rele mosaic>");
+ break;
+ default:
+ dprint("<U%02x>", c);
+ }
+}
+
+void
+print_page(struct ttxt_page *p)
+{
+ int r, c, e;
+
+ dprint("\n\n%03x %s%s%s%s%snatchars: %d\n",
+ (p->mag << 8) + p->no,
+ p->flags & erasepage ? "erasepage, " : "",
+ p->flags & newsflash ? "Newsflash, " : "",
+ p->flags & subtitle ? "Subtitle, " : "",
+ p->flags & suppress_header ? "SuppressHeader, " : "",
+ p->flags & inhibit_display ? "InihinitDisplay, " : "",
+ p->national_charset);
+
+ for(r = 0; r < 26; r++) {
+ int do_display = 0;
+
+ for(e = 39; e > 0; e--) {
+ if(p->data[r][e]) {
+ do_display = 1;
+ break;
+ }
+ }
+
+ if(do_display) {
+ dprint("%02d ", r);
+ for(c = 0; c <= e; c++) {
+ char z = p->data[r][c] & 0x7f;
+ print_code(z, p->national_charset);
+ //dprint("%c", isprint(z) ? z : z == 0 ? '\'' : '.');
+ }
+ dprint("\n");
+ }
+ }
+}
+
+
+void print_line(char *p)
+{
+ int mp;
+ int mag; // X in ETSI EN 300 706
+ int packet; // Y
+ struct ttxt_data_field *d = (struct ttxt_data_field *) p;
+
+ mp = unham(invtab[d->mag_addr_ham[0]], invtab[d->mag_addr_ham[1]]);
+ mag = mp & 0x7;
+ packet = (mp >> 3) & 0x1f;
+
+ dprint("I%d Y%02d M%d ", d->data_unit_id, packet, mag);
+
+ // packet 0, change page no in this magazine
+ if(packet == 0) {
+ int no;
+ uint8_t buf[8];
+
+ for(int i = 0; i < 8; i++)
+ buf[i] = invtab[d->data[i]];
+
+ no = unham(buf[0], buf[1]);
+
+ dprint("P%02x ", no);
+
+ dprint("<");
+ for(int i = 8; i < 40; i++)
+ print_code(invtab[d->data[i]] & 0x7f, 0);
+ dprint(">");
+
+ if(buf[3] & 0x80) dprint(", erase page");
+ if(buf[5] & 0x20) dprint(", newsflash");
+ if(buf[5] & 0x80) dprint(", subtitle");
+ if(buf[6] & 0x02) dprint(", suppress header");
+ if(buf[6] & 0x08) dprint(", update indicator");
+ if(buf[6] & 0x20) dprint(", interrupted sequence");
+ if(buf[6] & 0x80) dprint(", inhibit display");
+ if(buf[7] & 0x02) dprint(", magazine serial");
+
+ dprint(", charset=%d", ((buf[7] & 0x80) >> 5) + ((buf[7] & 0x20) >> 4) + ((buf[7] & 0x08) >> 3));
+ } else {
+ dprint("<");
+ for(int i = 0; i < 40; i++)
+ print_code(invtab[d->data[i]] & 0x7f, 0);
+ dprint(">");
+ }
+
+ dprint("\n");
+}
+
+
+#if 0
+void
+show_page(struct ttxt_page *p)
+{
+ static cOsdBase *o = NULL;
+ static tWindowHandle w1 = 0;
+ static tWindowHandle w2 = 0;
+ static int open1 = 0, open2 = 0;
+ char *s1 = NULL, *s2 = NULL;
+ int i, j;
+
+ for(i = 1; i < TTXT_ROWS; i++) {
+ char *s = NULL;
+ if(p->data[i][0]) {
+ int do_incr = 0;
+ dprint("Checking row %d\n", i);
+ for(j = 0; j < 40; j++) {
+ p->data[i][j] = p->data[i][j] & 0x7f;
+ switch(p->data[i][j]) {
+ case 0x0d: // double height
+ case 0x0f: // double size
+ do_incr = 1;
+ break;
+ case 0x0a: // box end
+ p->data[i][j] = '\0';
+ break;
+ case 0x0b: // box begin
+ s = (char *) &(p->data[i][j+1]);
+ dprint("Using row %d\n", i);
+ break;
+ case '[':
+ p->data[i][j] = 'Ä';
+ break;
+ case ']':
+ p->data[i][j] = 'Ã…';
+ break;
+ case '\\':
+ p->data[i][j] = 'Ö';
+ break;
+ case '{':
+ p->data[i][j] = 'ä';
+ break;
+ case '}':
+ p->data[i][j] = 'Ã¥';
+ break;
+ case '|':
+ p->data[i][j] = 'ö';
+ break;
+ }
+ }
+ if(do_incr)
+ i++;
+ dprint("\n");
+ }
+
+ if(s)
+ if(!s1)
+ s1 = s;
+ else if(!s2)
+ s2 = s;
+ }
+
+ if(s1 && !s2) {
+ s2 = s1;
+ s1 = NULL;
+ }
+
+ if(s1)
+ dprint("S1: %s\n", s1);
+ else
+ dprint("S1: <none>\n");
+ if(s2)
+ dprint("S2: %s\n", s2);
+ else
+ dprint("S2: <none>\n");
+
+ if(o != NULL) {
+ if(open1) {
+ o->Clear(w1);
+ open1 = 0;
+ }
+ if(open2) {
+ o->Clear(w2);
+ open2 = 0;
+ }
+
+ o->Clear();
+ delete o;
+ o = NULL;
+ }
+
+ if(!s1 && !s2)
+ return;
+
+ o = cOsd::OpenRaw(125, 450);
+
+ if(o == NULL)
+ return;
+
+ o->SetFont(fontOsd);
+
+ if(s1) {
+ int w = o->Width((char *) s1);
+ dprint("w1: %d\n", w);
+ w = 450;
+ int h = 36;
+ w1 = o->Create(0, 0, w, h, 2);
+#if 0
+ o->AddColor(clrBackground, w1);
+ o->AddColor(clrWhite, w1);
+#endif
+ o->Fill(0, 0, w, h, clrBackground, w1);
+ o->Text(15, 4, (char *) s1, clrWhite, clrBackground, w1);
+ open1 = 1;
+ }
+
+ if(s2) {
+ int w = o->Width((char *) s2);
+ dprint("w2: %d\n", w);
+ w = 452;
+ int h = 36;
+ w2 = o->Create(0, 45, w, h, 2);
+#if 0
+ o->AddColor(clrBackground, w2);
+ o->AddColor(clrWhite, w2);
+#endif
+ o->Fill(0, 45, w, 45 + h, clrBackground, w2);
+ o->Text(15, 45 + 4, (char *) s2, clrWhite, clrBackground, w2);
+ open2 = 1;
+ }
+
+ o->Flush();
+}
+#endif
+
+#if 0
+void
+ttxt_packet_in(int data_unit_id, int mag, int pack, uint8_t *data)
+{
+ static int valid = 0;
+ static struct ttxt_page p;
+ int i;
+
+ if(pack == 0) {
+ if(valid)
+ if(p.mag == TTXT_MAG && p.no == TTXT_PAGE)
+ if(p.subtitle)
+ //print_page(&p);
+ /* if(p.mag == 1) */{
+ show_page(&p);
+ print_page(&p);
+ }
+
+ memset(&p, 0, sizeof(p));
+ p.data_unit_id = data_unit_id;
+ p.mag = mag;
+ p.no = unham(data[0], data[1]);
+
+ if(data[3] & 0x80) { // Erase Page
+ memset(p.data, 0, sizeof(p.data));
+ p.erasepage = 1;
+ }
+ if(data[5] & 0x20) // Newsflash
+ p.newsflash = 1;
+ if(data[5] & 0x80) // Subtitle
+ p.subtitle = 1;
+ if(data[6] & 0x02) // Suppress Header
+ p.suppress_header = 1;
+ //if(data[6] & 0x08) // Update Indicator
+ //if(data[6] & 0x20) // Interrupted Sequence
+ if(data[6] & 0x80) // Inhibit Display
+ p.inhibit_display = 1;
+ //if(data[7] & 0x02) // Magazine Serial
+
+ p.national_charset =
+ ((data[7] & 0x80) >> 7) + ((data[7] & 0x20) >> 4) + ((data[7] & 0x08) >> 1);
+
+ valid = 1;
+
+ for(i = 0; i < 32; i++)
+ p.data[0][i] = data[i+8];
+ } else if(pack < 26) {
+ for(i = 0; i < 42; i++)
+ p.data[pack][i] = data[i];
+ } else {
+ if((valid && p.mag == TTXT_MAG && p.no == TTXT_PAGE) ||
+ pack == 28)
+ dprint("mag: %d, pack: %d, page: %02x\n", p.mag, pack, p.no);
+ }
+}
+#endif
+
+#if 0
+void
+ttxt_pes_data_in(struct ttxt_pes_data_field *t, int len)
+{
+ int i;
+
+ if(len < 1)
+ return;
+
+ if(t->data_identifier < 0x10 || t->data_identifier > 0x1F) {
+ dprint("Unknown data identifier: %02x\n", t->data_identifier);
+ return;
+ }
+
+ for(i = 0; (uint8_t *) (&(t->d[i+1])) < (((uint8_t *) t) + len); i++) {
+ struct ttxt_data_field *d = &(t->d[i]);
+ int i;
+ uint8_t *p;
+ int uh;
+ int mag;
+ int pack;
+
+ // if(d->data_unit_id != ttxt_subtitle)
+ // continue;
+
+ p = (uint8_t *) &(d->mag_addr_ham);
+ for(i = 0; i < 42; i++) {
+ p[i] = invtab[p[i]];
+ }
+
+ uh = unham(d->mag_addr_ham[0], d->mag_addr_ham[1]);
+ mag = uh & 0x7;
+ pack = (uh >> 3) & 0x1f;
+
+ // dump_hex("line", (uint8_t *) d, 20);
+ // dprint("id: %d, line: %d, mag %d, pack: %d\n", d->data_unit_id, TTXT_LINE_NO(*d), mag, pack);
+
+ ttxt_packet_in(d->data_unit_id, mag, pack, d->data);
+ }
+}
+
+
+void
+set_filt(int fd,uint16_t tt_pid, dmx_pes_type_t t)
+{
+ struct dmx_pes_filter_params pesFilterParams;
+
+ memset(&pesFilterParams, 0, sizeof(pesFilterParams));
+
+ pesFilterParams.pid = tt_pid;
+ pesFilterParams.input = DMX_IN_FRONTEND;
+ pesFilterParams.output = DMX_OUT_TAP;
+ pesFilterParams.pes_type = t;
+ pesFilterParams.flags = DMX_IMMEDIATE_START;
+
+ if (ioctl(fd, DMX_SET_PES_FILTER, &pesFilterParams) < 0)
+ perror("DMX SET PES FILTER:");
+
+ // XXX set buffer size too?
+}
+#endif
+
+#if 0
+#define BUFSIZE 2000
+
+// external entry point
+void ttxt_decode(int fd, int tpid, int *doRun)
+{
+ uint8_t buf[BUFSIZE];
+ int n;
+ int hunt = 1;
+
+ set_filt(fd, tpid, DMX_PES_OTHER);
+
+ while (*doRun) {
+ restart:
+ if(hunt) {
+ int i;
+
+ dprint("hunting...\n");
+ n = read(fd, buf, 199);
+ if(n < 0) {
+ perror("ttxt_decode:read: ");
+ goto restart;
+ }
+
+ for(i = 0; i < (n - 3); i++) {
+ if(buf[i] == 0 && buf[i+1] == 0 && buf[i+2] == 1 && buf[i+3] == 0xbd) {
+ struct ttxt_pes_header *p = (struct ttxt_pes_header *) (buf + i);
+ size_t skip = ntohs(p->len) + 6 - (n - i);
+
+ if(skip > 0) {
+ read(fd, buf, skip < sizeof(buf) ? skip : sizeof(buf));
+ if(n < 0) {
+ perror("ttxt_decode:read: ");
+ goto restart;
+ }
+ hunt = 0;
+ break;
+ }
+ }
+ }
+ } else {
+ struct ttxt_pes_header *p = (struct ttxt_pes_header *) buf;
+
+ n = read(fd, buf, 6);
+ if(n < 0) {
+ perror("ttxt_decode:read: ");
+ goto restart;
+ }
+
+ if(p->start[0] != 0 || p->start[1] != 0 || p->start[2] != 1 ||
+ p->stream_id != 0xbd || // private_stream_1
+ ntohs(p->len) > (sizeof(buf) - 6)) {
+ dprint("Lost PES packet sync, hunting...\n");
+ hunt = 1;
+ continue;
+ }
+
+ n = read(fd, buf + 6, ntohs(p->len));
+ if(n < 0) {
+ perror("ttxt_decode:read: ");
+ goto restart;
+ }
+
+ // dprint("len: %d\n", n);
+
+ if(n != ntohs(p->len) ||
+ p->header_len != 0x24) { // header should allways be 0x24 long (EN 300 472)
+ dprint("Error reading PES packet, hunting...\n");
+ hunt = 1;
+ continue;
+ }
+
+ ttxt_pes_data_in((struct ttxt_pes_data_field *) (buf + 45), n + 6 - 45);
+ }
+
+ // fwrite(buf,1,n,stdout);
+ }
+
+ dprint("ttxt_decode DONE!\n");
+}
+#endif
+
+
+#if 0
+int
+main(int argc, char **argv)
+{
+ int fd;
+ int pid;
+ uint8_t buf[BUFSIZE];
+ int n;
+ int hunt = 1;
+
+ if (argc!=2) {
+ fprintf(stderr,"USAGE: %s PID\n", argv[0]);
+ return -1;
+ }
+
+ pid = atoi(argv[1]);
+
+ if((fd = open("/dev/dvb/adapter0/demux0", O_RDWR)) < 0){
+ perror("Error opening demux device: ");
+ return -1;
+ }
+
+ set_filt(fd, pid, DMX_PES_OTHER);
+
+ for (;;) {
+ if(hunt) {
+ int i;
+
+ dprint("hunting...\n");
+ n = read(fd, buf, 199);
+
+ for(i = 0; i < (n - 3); i++) {
+ if(buf[i] == 0 && buf[i+1] == 0 && buf[i+2] == 1 && buf[i+3] == 0xbd) {
+ struct ttxt_pes_header *p = (struct ttxt_pes_header *) (buf + i);
+ int skip = ntohs(p->len) + 6 - (n - i);
+
+ if(skip > 0) {
+ read(fd, buf, skip < sizeof(buf) ? skip : sizeof(buf));
+ hunt = 0;
+ break;
+ }
+ }
+ }
+ } else {
+ struct ttxt_pes_header *p = (struct ttxt_pes_header *) buf;
+
+ n = read(fd, buf, 6);
+
+ if(p->start[0] != 0 || p->start[1] != 0 || p->start[2] != 1 ||
+ p->stream_id != 0xbd || // private_stream_1
+ ntohs(p->len) > (sizeof(buf) - 6)) {
+ dprint("Lost PES packet sync, hunting...\n");
+ hunt = 1;
+ continue;
+ }
+
+ n = read(fd, buf + 6, ntohs(p->len));
+
+ // dprint("len: %d\n", n);
+
+ if(n != ntohs(p->len) ||
+ p->header_len != 0x24) { // header should allways be 0x24 long (EN 300 472)
+ dprint("Error reading PES packet, hunting...\n");
+ hunt = 1;
+ continue;
+ }
+
+ ttxt_pes_data_in((struct ttxt_pes_data_field *) (buf + 45), n + 6 - 45);
+ }
+
+ // fwrite(buf,1,n,stdout);
+ }
+
+ return 0;
+}
+#endif
diff -urNad vdr-plugin-ttxtsubs-0.0.5~/ttxtsubsfilter.c vdr-plugin-ttxtsubs-0.0.5/ttxtsubsfilter.c
--- vdr-plugin-ttxtsubs-0.0.5~/ttxtsubsfilter.c 2004-03-01 23:53:17.000000000 +0100
+++ vdr-plugin-ttxtsubs-0.0.5/ttxtsubsfilter.c 2005-10-22 14:37:38.000000000 +0200
@@ -4,6 +4,8 @@
#include <stdint.h>
#include <string.h>
+#include <vdr/tools.h>
+
#include "ttxtsubsfilter.h"
#include "teletext.h"
diff -urNad vdr-plugin-ttxtsubs-0.0.5~/ttxtsubsfilter.c~ vdr-plugin-ttxtsubs-0.0.5/ttxtsubsfilter.c~
--- vdr-plugin-ttxtsubs-0.0.5~/ttxtsubsfilter.c~ 1970-01-01 01:00:00.000000000 +0100
+++ vdr-plugin-ttxtsubs-0.0.5/ttxtsubsfilter.c~ 2004-03-01 23:53:17.000000000 +0100
@@ -0,0 +1,162 @@
+
+#include <stdlib.h>
+#include <stdio.h>
+#include <stdint.h>
+#include <string.h>
+
+#include "ttxtsubsfilter.h"
+#include "teletext.h"
+
+cTtxtSubsFilter::cTtxtSubsFilter(void)
+ :
+ mCount(0),
+ mPages(0)
+{
+ int i;
+ for(i = 0; i < 8; i++)
+ mMagPage[i] = -1;
+}
+
+
+cTtxtSubsFilter::~cTtxtSubsFilter(void)
+{
+ FreePages();
+}
+
+
+void cTtxtSubsFilter::SetPages(size_t count, uint16_t *pages)
+{
+ FreePages();
+
+ mPages = (uint16_t *) malloc(count * sizeof(uint16_t));
+
+ memcpy((char *) mPages, (char *) pages, count * sizeof(uint16_t));
+
+ mCount = count;
+
+ if(0) {
+ fprintf(stderr, "SetPages: %d, ", count);
+ for(size_t i = 0; i < count; i++)
+ fprintf(stderr, "%03x ", pages[i]);
+ fprintf(stderr, "\n");
+ }
+}
+
+// XXX IF MERGING PAGES FROM SEVERAL PIDS (which we currently don't)
+// Need to insert a line Y0 if
+// - there has been data from other streams inserted and the next line is not a Y0
+// there has been data from other magazines and the next line for this mag is not a Y0
+// indata and outdata are pointers to a ttxt data row buffers,
+// if return value <> 0 outdata countains data to pass on
+int cTtxtSubsFilter::Filter(char *indata, char *outdata)
+{
+ int mp;
+ int mag; // X in ETSI EN 300 706
+ int packet; // Y
+ int result = 0;
+
+ struct ttxt_data_field *d = (struct ttxt_data_field *) indata;
+
+ mp = UNHAM_INV(d->mag_addr_ham[0], d->mag_addr_ham[1]);
+ mag = mp & 0x7;
+ packet = (mp >> 3) & 0x1f;
+
+ if (0) { // XXX
+ uint8_t buf[2];
+ ham8_4byte(mp, buf);
+ fprintf(stderr, "unham %02x %02x -> %02x, ham: %02x %02x\n",
+ invtab[d->mag_addr_ham[0]], invtab[d->mag_addr_ham[1]],
+ mp,
+ buf[0], buf[1]);
+ }
+
+ // packet 0, change page no in this magazine
+ if(packet == 0) {
+ uint8_t no;
+ int newindex;
+
+ no = UNHAM_INV(d->data[0], d->data[1]);
+
+ mMagPage[mag] = newindex = Find(mCount, mPages, (mag << 8) | no);
+
+ if(newindex != -1) {
+ //fprintf(stderr, "Filter: %x%02x (%d)\n", mag, no, newindex); // XXX
+
+ MakeY0(outdata, indata, mPages[newindex]);
+ result = 1;
+ }
+ } else if(packet >= 1 && packet <= 25) {
+ if(mMagPage[mag] != -1) {
+ memcpy(outdata, indata, sizeof(ttxt_data_field));
+ result = 1;
+ }
+ }
+
+ return result;
+}
+
+
+void cTtxtSubsFilter::FreePages(void)
+{
+ mCount = 0;
+
+ if(mPages) {
+ free(mPages);
+ mPages = NULL;
+ }
+}
+
+
+int cTtxtSubsFilter::Find(int count, uint16_t *pages, uint16_t pageno){
+
+ int i;
+ for(i = 0; i < count; i++) {
+ if(pages[i] == pageno)
+ return i;
+ }
+
+ return -1;
+}
+
+
+// make a new Y0 line with the flags in
+void cTtxtSubsFilter::MakeY0(char *outdata, char *indata, uint16_t newpageno)
+{
+ struct ttxt_data_field *i = (struct ttxt_data_field *) indata;
+ struct ttxt_data_field *o = (struct ttxt_data_field *) outdata;
+ uint8_t hambuf[2];
+
+ o->data_unit_id = 3; // EBU Teletxt subtitle data
+ o->data_unit_length = 44;
+ o->par_loff = 0xc0; // reserved bits + unknown line
+ o->framing_code = 0xe4;
+
+ // new magazine number (Y = 0)
+ ham8_4byte((newpageno >> 8) & 0x7, hambuf);
+ o->mag_addr_ham[0] = invtab[hambuf[0]];
+ o->mag_addr_ham[1] = invtab[hambuf[1]];
+
+ // new page number
+ ham8_4byte(newpageno & 0xff, hambuf);
+ o->data[0] = invtab[hambuf[0]];
+ o->data[1] = invtab[hambuf[1]];
+
+ // copy flags
+ memcpy(o->data + 2, i->data + 2, 6);
+
+ // new text
+ unsigned char txtbuf[32];
+ size_t txtlen;
+ size_t n;
+
+ txtlen = snprintf((char *) txtbuf, 32, "%03x", newpageno < 0x100 ? newpageno + 0x800 : newpageno);
+
+ for(n = 0; n < txtlen; n++) {
+ if(parity(txtbuf[n]))
+ o->data[n + 8] = invtab[txtbuf[n] | 0x80]; // XXX wrong parity?
+ else
+ o->data[n + 8] = invtab[txtbuf[n]]; // XXX wrong parity?
+ }
+ for(; n < 32; n++)
+ o->data[n + 8] = invtab[(unsigned char) ' ']; // space already has right parity
+}
#!/usr/bin/perl
## 96_use_syslog.dpatch -- domi.dumont(a)free.fr
## DP: perl script to replace fprintf with esyslog calls
## DP: (c) Dominique Dumont. Released under GPLv2 or later version.
use strict ;
my $action = shift @ARGV || die "Expected -patch or -unpatch option" ;
my $working_dir = shift @ARGV || '';
$working_dir .= '/' unless $working_dir eq '' ;
my @files = glob( $working_dir.'*.[hc]' ) ;
my $to_esyslog
= sub { $_[0] =~ s/fprintf\s*\(\s*stderr\s*,/esyslog\(/ ;} ;
my $to_fprintf
= sub { $_[0] =~ s/esyslog\s*\(/fprintf\(stderr,/ ;} ;
my $replace
= $action eq '-patch' ? $to_esyslog
: $action eq '-unpatch' ? $to_fprintf
: die "Expected -patch or -unpatch option, not $action" ;
foreach my $c_file (@files) {
my $nb_of_modified_lines ;
open(FIN, $c_file) || die "Can't open $c_file:$!" ;
my @lines = <FIN> ;
close FIN ;
$nb_of_modified_lines = scalar grep { $replace->($_) } @lines ;
next unless $nb_of_modified_lines ;
print "patched $nb_of_modified_lines lines in $c_file\n";
open(FOUT, ">$c_file") || die "Can't open $c_file to write:$!" ;
print FOUT @lines ;
close FOUT;
}
