diff options
Diffstat (limited to 'ttxtsubsdisplay.c')
| -rw-r--r-- | ttxtsubsdisplay.c | 331 |
1 files changed, 331 insertions, 0 deletions
diff --git a/ttxtsubsdisplay.c b/ttxtsubsdisplay.c new file mode 100644 index 0000000..370b4c9 --- /dev/null +++ b/ttxtsubsdisplay.c @@ -0,0 +1,331 @@ + +#include <stdio.h> +#include <stdint.h> +#include <string.h> +#include <sys/time.h> +#include <time.h> + +#include <vdr/osd.h> +#include <vdr/osdbase.h> +#include <vdr/thread.h> + +#include "ttxtsubsdisplay.h" +#include "utils.h" + +// pageState +enum { + invalid = 0, + collecting, + interimshow, + finished +}; + + +cTtxtSubsDisplay::cTtxtSubsDisplay(void) + : + mPageState(invalid), + mMag(0), + mNo(0), + mDoDisplay(0), + mOsd(NULL), + mOsdLock(), + mLastDataTime(NULL) +{ + memset(&page.data, 0, sizeof(page.data)); + mLastDataTime = (struct timeval *) calloc(1, sizeof(*mLastDataTime)); +} + + +cTtxtSubsDisplay::~cTtxtSubsDisplay(void) +{ + if(mLastDataTime) + free(mLastDataTime); + ClearOSD(); +} + + +void cTtxtSubsDisplay::SetPage(int Pageno) +{ + Clear(); + + mMag = (Pageno >> 8) & 0xF; + mNo = Pageno & 0xFF; +} + + +void cTtxtSubsDisplay::Hide(void) +{ + //dprint("cTtxtSubsDisplay::Hide\n"); + mDoDisplay = 0; + ClearOSD(); +} + + +void cTtxtSubsDisplay::Show(void) +{ + //dprint("cTtxtSubsDisplay::Show\n"); + mDoDisplay = 1; + ShowOSD(); +} + + +void cTtxtSubsDisplay::Clear(void) +{ + mPageState = invalid; + ClearOSD(); +} + + +void cTtxtSubsDisplay::TtxtData(const uint8_t *Data) +{ + int mp; + int mag; // X in ETSI EN 300 706 + int packet; // Y + struct ttxt_data_field *d; + + // idle time - if we have been sitting on a half finished page for a while - show it + if(Data == NULL && mPageState == collecting) { + struct timeval tv; + gettimeofday(&tv, NULL); + // add second diff to usecs + tv.tv_usec += 1000000 * (tv.tv_sec - mLastDataTime->tv_sec); + + if((tv.tv_usec - mLastDataTime->tv_usec) > 500000) { + //dprint("Interimshow!\n"); + mPageState = interimshow; + ClearOSD(); + ShowOSD(); + } + } + + if(Data == NULL) + return; + + //print_line((char *) Data); + + d = (struct ttxt_data_field *) Data; + + mp = unham(invtab[d->mag_addr_ham[0]], invtab[d->mag_addr_ham[1]]); + mag = mp & 0x7; + packet = (mp >> 3) & 0x1f; + + //dprint("cTtxtSubsDisplay::TtxtData: mag:%d packet: %d\n", mag, packet); // XXX + + if(packet == 0) { + int i, no; + uint8_t fi[8]; // flags field inverted + + for(i = 0; i < 8; i++) + fi[i] = invtab[d->data[i]]; + + if(mPageState == collecting) { + mPageState = finished; + ClearOSD(); + ShowOSD(); + } + if(mPageState == interimshow) + mPageState = finished; + + no = unham(fi[0], fi[1]); + + //dprint("cTtxtSubsDisplay::TtxtData: page:%d%02x, packet: %d\n", mag, no, packet); // XXX + //print_line((char *) Data); + + if(mag == mMag && no == mNo) { + //dprint("cTtxtSubsDisplay::TtxtData: page:%d%02x, packet: %d\n", mag, no, packet); // XXX + page.mag = mag; + page.no = no; + page.flags = 0; + page.national_charset = 0; + + if(fi[3] & 0x80) { // Newsflash + page.flags |= erasepage; + memset(&page.data, 0, sizeof(page.data)); // only if erasepage is set? + } + if(fi[5] & 0x20) // Subtitle + page.flags |= newsflash; + if(fi[5] & 0x80) // Suppress Header + page.flags |= subtitle; + // if(fi[6] & 0x08) // Update Indicator + // if(fi[6] & 0x20) // Interrupted Sequence + if(fi[6] & 0x80) // Inhibit Display + page.flags |= inhibit_display; + // if(fi[7] & 0x02) // Magazine Serial + + page.national_charset = ((fi[7] & 0x80) >> 5) + + ((fi[7] & 0x20) >> 4) + ((fi[7] & 0x08) >> 3); + + mPageState = collecting; + gettimeofday(mLastDataTime, NULL); + + for(i = 0; i < 32; i++) + page.data[0][i] = invtab[d->data[i+8]]; + } + } else if(mag == page.mag && packet < TTXT_DISPLAYABLE_ROWS && + (mPageState == collecting || mPageState == interimshow)) { + // mag == page.mag: The magazines can be sent interleaved + int i; + for(i = 0; i < 40; i++) + page.data[packet][i] = invtab[d->data[i]]; + + mPageState = collecting; + gettimeofday(mLastDataTime, NULL); + + //dprint("row: %d ", packet); + //dump_hex("", page.data[packet], 40); + } else { + // packets with national characters information: X/28/0 format 1, X/28/1, X/28/4, M/29/0 M/29/4, + if(packet == 28 || packet == 29) + dprint("mag: %d, packet: %d, page: %02x, state: %d\n", page.mag, packet, page.no, mPageState); + + //if(packet == 26) { + // dprint("mag: %d, packet: %d, page: %02x, state: %d\n", page.mag, packet, page.no, mPageState); + // dump_hex("", page.data[packet], 40); + //} + } +} + + +static char * +ttxt2la1(uint8_t *p, char *buf, int natopts) +{ + int i, j = 0, skip = 1; + for(i = 0; i < 40; i++) { + uint8_t c = p[i] & 0x7f; + + if(c == 0x0b) { // box begin + skip = 0; + if(j != 0) // if we have chars in buf + buf[j++] = ' '; + continue; + } + + if(c == 0x0a) { // box end + skip = 1; + continue; + } + + if(skip) + continue; + + if(j == 0 && c == 20) // skip leading spaces + continue; + + if(c >= 0x20) { + buf[j++] = ttxt_laG0_la1_char(0, natopts, c); + } + } + + while(j > 0 && buf[j-1] == ' ') // strip extra spaces + j--; + + buf[j++] = '\0'; + if(strlen(buf)) + return buf; + else + return NULL; +} + +#define SCREENLEFT 125 +#define SCREENBOT 540 +#if 0 +#define ROWINCR 45 +#define ROWH 36 +#define TEXTY 4 +#else +#define ROWINCR 43 +#define ROWH 34 +#define TEXTY 3 +#endif +#define TEXTX 15 +#define SCREENTOP (SCREENBOT - MAXTTXTROWS * ROWINCR) + +void cTtxtSubsDisplay::ShowOSD(void) +{ + int i, y; + int rowcount = 0; + char buf[TTXT_DISPLAYABLE_ROWS][41]; + int doneWidthWorkaround = 0; + + cMutexLock lock(&mOsdLock); + + if(!mDoDisplay) { + //dprint("NOT displaying subtitles because of other OSD activities!\n"); + return; + } + + if(mPageState != interimshow && mPageState != finished) { + //dprint("NOT displaying subtitles because page state: %d!\n", mPageState); + return; + } + + if(mOsd != NULL) + ClearOSD(); + + //print_page(&page); + + for(i = 1; i < 24; i++) { + if(page.data[i][0] != 0) // anything on this line? + if(ttxt2la1(page.data[i], buf[rowcount], page.national_charset)) + rowcount++; + } + +#if 0 + mOsd = cOsd::OpenRaw(SCREENLEFT, SCREENTOP); +#else + mOsd = cDevice::PrimaryDevice()->NewOsd(SCREENLEFT, SCREENTOP); +#endif + if(mOsd == NULL) { + dprint("Error: cOsd::OpenRaw returned NULL!\n"); + return; + } + + mOsd->SetFont(fontOsd); + + if(rowcount > MAXTTXTROWS) + rowcount = MAXTTXTROWS; + + y = SCREENBOT - SCREENTOP - ROWH - (ROWINCR * (rowcount-1)); + for(i = 0; i < rowcount; i++) { + tWindowHandle wind; + int w = 0; // XXX should be text width - not %4! + + // XXX Width calculations doesn't work before we have created a window... + if(!doneWidthWorkaround) { + wind = mOsd->Create(0, y, 4, ROWH, 2); + w = mOsd->Width(buf[i]) + 2 * TEXTX; + mOsd->Clear(wind); + mOsd->Hide(wind); + doneWidthWorkaround = 1; + } else + w = mOsd->Width(buf[i]) + 2 * TEXTX; + + if(w % 4) + w += 4 - (w % 4); + + wind = mOsd->Create(0, y, w, ROWH, 2); + //dprint("W: %d\n", w); + mOsd->Fill(0, y, w, y + ROWH, clrBackground, wind); + mOsd->Text(TEXTX, y + TEXTY, buf[i], clrWhite, clrBackground, wind); + + y += ROWINCR; + } + + mOsd->Flush(); +} + + +void cTtxtSubsDisplay::ClearOSD(void) +{ + // dprint("\nClearOSD!\n"); + cMutexLock lock(&mOsdLock); + + if(mOsd) { + + mOsd->Clear(ALL_WINDOWS); + mOsd->Hide(ALL_WINDOWS); + mOsd->Flush(); + delete mOsd; + mOsd = NULL; + } +} |