aboutsummaryrefslogtreecommitdiffhomepage
path: root/stream
diff options
context:
space:
mode:
authorGravatar Uoti Urpala <uau@glyph.nonexistent.invalid>2009-11-16 06:54:22 +0200
committerGravatar Uoti Urpala <uau@glyph.nonexistent.invalid>2009-11-16 07:01:46 +0200
commit287b62163eed8811b6cd33716c0691d328947d48 (patch)
tree3143d2cb17b32a19e3e7e0aa428210d1bba3eb0b /stream
parent507f4fe6c7811558b1367e4b64855ae7f9bc8da8 (diff)
parentb411278fbb00767b8013604157a43e0203f66f4c (diff)
Merge svn changes up to r29912
Diffstat (limited to 'stream')
-rw-r--r--stream/dvb_tune.c8
-rw-r--r--stream/stream.c10
-rw-r--r--stream/stream_dvb.c10
-rw-r--r--stream/stream_dvd.c91
-rw-r--r--stream/stream_dvd_common.c96
-rw-r--r--stream/stream_dvd_common.h6
-rw-r--r--stream/stream_dvdnav.c88
-rw-r--r--stream/tv.c25
-rw-r--r--stream/tv.h120
-rw-r--r--stream/tvi_def.h2
-rw-r--r--stream/tvi_dshow.c22
-rw-r--r--stream/tvi_v4l.c19
-rw-r--r--stream/tvi_v4l2.c20
-rw-r--r--stream/tvi_vbi.c1850
14 files changed, 193 insertions, 2174 deletions
diff --git a/stream/dvb_tune.c b/stream/dvb_tune.c
index 8b7bdb7317..214fe871c2 100644
--- a/stream/dvb_tune.c
+++ b/stream/dvb_tune.c
@@ -230,7 +230,7 @@ int dvb_demux_stop(int fd)
mp_msg(MSGT_DEMUX, MSGL_DBG2, "STOPPING FD: %d, RESULT: %d\n", fd, i);
- return (i==0);
+ return i == 0;
}
@@ -241,7 +241,7 @@ int dvb_demux_start(int fd)
mp_msg(MSGT_DEMUX, MSGL_DBG2, "STARTING FD: %d, RESULT: %d\n", fd, i);
- return (i==0);
+ return i == 0;
}
@@ -265,7 +265,7 @@ int dvb_tune(dvb_priv_t *priv, int freq, char pol, int srate, int diseqc, int to
if(ris != 0)
mp_msg(MSGT_DEMUX, MSGL_INFO, "dvb_tune, TUNING FAILED\n");
- return (ris == 0);
+ return ris == 0;
}
@@ -740,5 +740,5 @@ static int tune_it(int fd_frontend, int fd_sec, unsigned int freq, unsigned int
return -1;
}
- return(check_status(fd_frontend, timeout));
+ return check_status(fd_frontend, timeout);
}
diff --git a/stream/stream.c b/stream/stream.c
index 8b8a84760a..8570f0b125 100644
--- a/stream/stream.c
+++ b/stream/stream.c
@@ -245,13 +245,11 @@ int stream_fill_buffer(stream_t *s){
case STREAMTYPE_STREAM:
#ifdef CONFIG_NETWORK
if( s->streaming_ctrl!=NULL && s->streaming_ctrl->streaming_read ) {
- len=s->streaming_ctrl->streaming_read(s->fd,s->buffer,STREAM_BUFFER_SIZE, s->streaming_ctrl);break;
- } else {
- len=read(s->fd,s->buffer,STREAM_BUFFER_SIZE);break;
- }
-#else
- len=read(s->fd,s->buffer,STREAM_BUFFER_SIZE);break;
+ len=s->streaming_ctrl->streaming_read(s->fd,s->buffer,STREAM_BUFFER_SIZE, s->streaming_ctrl);
+ } else
#endif
+ len=read(s->fd,s->buffer,STREAM_BUFFER_SIZE);
+ break;
case STREAMTYPE_DS:
len = demux_read_data((demux_stream_t*)s->priv,s->buffer,STREAM_BUFFER_SIZE);
break;
diff --git a/stream/stream_dvb.c b/stream/stream_dvb.c
index 1e157f162c..7d184b02b2 100644
--- a/stream/stream_dvb.c
+++ b/stream/stream_dvb.c
@@ -323,8 +323,9 @@ static dvb_channels_list *dvb_get_channels(char *filename, int type)
ptr->mod = VSB_8;
else if(! strcmp(mod, "VSB_16") || !strcmp(mod, "16VSB"))
ptr->mod = VSB_16;
+ else if(! strcmp(mod, "QAM_AUTO"))
+ ptr->mod = QAM_AUTO;
- ptr->inv = INVERSION_AUTO;
#endif
}
@@ -342,7 +343,8 @@ static dvb_channels_list *dvb_get_channels(char *filename, int type)
ptr->trans = TRANSMISSION_MODE_2K;
else if(! strcmp(transm, "TRANSMISSION_MODE_8K"))
ptr->trans = TRANSMISSION_MODE_8K;
-
+ else if(! strcmp(transm, "TRANSMISSION_MODE_AUTO"))
+ ptr->trans = TRANSMISSION_MODE_AUTO;
if(! strcmp(gi, "GUARD_INTERVAL_1_32"))
ptr->gi = GUARD_INTERVAL_1_32;
@@ -350,7 +352,9 @@ static dvb_channels_list *dvb_get_channels(char *filename, int type)
ptr->gi = GUARD_INTERVAL_1_16;
else if(! strcmp(gi, "GUARD_INTERVAL_1_8"))
ptr->gi = GUARD_INTERVAL_1_8;
- else ptr->gi = GUARD_INTERVAL_1_4;
+ else if(! strcmp(gi, "GUARD_INTERVAL_1_4"))
+ ptr->gi = GUARD_INTERVAL_1_4;
+ else ptr->gi = GUARD_INTERVAL_AUTO;
if(! strcmp(tmp_lcr, "FEC_1_2"))
ptr->cr_lp =FEC_1_2;
diff --git a/stream/stream_dvd.c b/stream/stream_dvd.c
index 8dc73b96b3..36a8b07d05 100644
--- a/stream/stream_dvd.c
+++ b/stream/stream_dvd.c
@@ -5,25 +5,12 @@
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
-#include <fcntl.h>
#include <string.h>
#include "config.h"
#include "mp_msg.h"
#include "help_mp.h"
-#ifdef __FreeBSD__
-#include <sys/cdrio.h>
-#endif
-
-#ifdef __linux__
-#include <linux/cdrom.h>
-#include <scsi/sg.h>
-#include <sys/types.h>
-#include <sys/stat.h>
-#include <sys/ioctl.h>
-#endif
-
#include <libgen.h>
#include <errno.h>
@@ -39,84 +26,9 @@
#include "stream_dvd.h"
#include "stream_dvd_common.h"
#include "libmpdemux/demuxer.h"
-#include "ffmpeg_files/intreadwrite.h"
-extern char* dvd_device;
static char* dvd_device_current;
int dvd_angle=1;
-int dvd_speed=0; /* 0 => don't touch speed */
-
-static void dvd_set_speed(char *device, unsigned speed)
-{
-#if defined(__linux__) && defined(SG_IO) && defined(GPCMD_SET_STREAMING)
- int fd;
- unsigned char buffer[28];
- unsigned char cmd[12];
- struct sg_io_hdr sghdr;
- struct stat st;
-
- memset(&st, 0, sizeof(st));
-
- if (stat(device, &st) == -1) return;
-
- if (!S_ISBLK(st.st_mode)) return; /* not a block device */
-
- switch (speed) {
- case 0: /* don't touch speed setting */
- return;
- case -1: /* restore default value */
- if (dvd_speed == 0) return; /* we haven't touched the speed setting */
- mp_tmsg(MSGT_OPEN, MSGL_INFO, "Restoring DVD speed... ");
- break;
- default: /* limit to <speed> KB/s */
- // speed < 100 is multiple of DVD single speed (1350KB/s)
- if (speed < 100)
- speed *= 1350;
- mp_tmsg(MSGT_OPEN, MSGL_INFO, "Limiting DVD speed to %dKB/s... ", speed);
- break;
- }
-
- memset(&sghdr, 0, sizeof(sghdr));
- sghdr.interface_id = 'S';
- sghdr.timeout = 5000;
- sghdr.dxfer_direction = SG_DXFER_TO_DEV;
- sghdr.dxfer_len = sizeof(buffer);
- sghdr.dxferp = buffer;
- sghdr.cmd_len = sizeof(cmd);
- sghdr.cmdp = cmd;
-
- memset(cmd, 0, sizeof(cmd));
- cmd[0] = GPCMD_SET_STREAMING;
- cmd[10] = sizeof(buffer);
-
- memset(buffer, 0, sizeof(buffer));
- /* first sector 0, last sector 0xffffffff */
- AV_WB32(buffer + 8, 0xffffffff);
- if (speed == -1)
- buffer[0] = 4; /* restore default */
- else {
- /* <speed> kilobyte */
- AV_WB32(buffer + 12, speed);
- AV_WB32(buffer + 20, speed);
- }
- /* 1 second */
- AV_WB16(buffer + 18, 1000);
- AV_WB16(buffer + 26, 1000);
-
- fd = open(device, O_RDWR | O_NONBLOCK);
- if (fd == -1) {
- mp_tmsg(MSGT_OPEN, MSGL_INFO, "Couldn't open DVD device for writing, changing DVD speed needs write access.\n");
- return;
- }
-
- if (ioctl(fd, SG_IO, &sghdr) < 0)
- mp_tmsg(MSGT_OPEN, MSGL_INFO, "failed\n");
- else
- mp_tmsg(MSGT_OPEN, MSGL_INFO, "successful\n");
-
- close(fd);
-#endif
-}
#define LIBDVDREAD_VERSION(maj,min,micro) ((maj)*10000 + (min)*100 + (micro))
/*
@@ -133,9 +45,6 @@ static void dvd_set_speed(char *device, unsigned speed)
#endif
#endif
-const char * const dvd_audio_stream_types[8] = { "ac3","unknown","mpeg1","mpeg2ext","lpcm","unknown","dts" };
-const char * const dvd_audio_stream_channels[6] = { "mono", "stereo", "unknown", "unknown", "5.1/6.1", "5.1" };
-
static struct stream_priv_s {
int title;
diff --git a/stream/stream_dvd_common.c b/stream/stream_dvd_common.c
index 9302b5670b..d5c4cc14a6 100644
--- a/stream/stream_dvd_common.c
+++ b/stream/stream_dvd_common.c
@@ -1,7 +1,103 @@
#include "config.h"
+#include <fcntl.h>
#include <inttypes.h>
+#include <unistd.h>
+#include <stdio.h>
+#include <string.h>
#include <dvdread/ifo_types.h>
+#ifdef __FreeBSD__
+#include <sys/cdrio.h>
+#endif
+
+#ifdef __linux__
+#include <linux/cdrom.h>
+#include <scsi/sg.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <sys/ioctl.h>
+#endif
+
+#include "mp_msg.h"
+#include "help_mp.h"
#include "stream_dvd_common.h"
+#include "ffmpeg_files/intreadwrite.h"
+
+const char * const dvd_audio_stream_types[8] = { "ac3","unknown","mpeg1","mpeg2ext","lpcm","unknown","dts" };
+const char * const dvd_audio_stream_channels[6] = { "mono", "stereo", "unknown", "unknown", "5.1/6.1", "5.1" };
+
+int dvd_speed=0; /* 0 => don't touch speed */
+
+void dvd_set_speed(char *device, unsigned speed)
+{
+#if defined(__linux__) && defined(SG_IO) && defined(GPCMD_SET_STREAMING)
+ int fd;
+ unsigned char buffer[28];
+ unsigned char cmd[12];
+ struct sg_io_hdr sghdr;
+ struct stat st;
+
+ memset(&st, 0, sizeof(st));
+
+ if (stat(device, &st) == -1) return;
+
+ if (!S_ISBLK(st.st_mode)) return; /* not a block device */
+
+ switch (speed) {
+ case 0: /* don't touch speed setting */
+ return;
+ case -1: /* restore default value */
+ if (dvd_speed == 0) return; /* we haven't touched the speed setting */
+ mp_tmsg(MSGT_OPEN, MSGL_INFO, "Restoring DVD speed... ");
+ break;
+ default: /* limit to <speed> KB/s */
+ // speed < 100 is multiple of DVD single speed (1350KB/s)
+ if (speed < 100)
+ speed *= 1350;
+ mp_tmsg(MSGT_OPEN, MSGL_INFO, "Limiting DVD speed to %dKB/s... ", speed);
+ break;
+ }
+
+ memset(&sghdr, 0, sizeof(sghdr));
+ sghdr.interface_id = 'S';
+ sghdr.timeout = 5000;
+ sghdr.dxfer_direction = SG_DXFER_TO_DEV;
+ sghdr.dxfer_len = sizeof(buffer);
+ sghdr.dxferp = buffer;
+ sghdr.cmd_len = sizeof(cmd);
+ sghdr.cmdp = cmd;
+
+ memset(cmd, 0, sizeof(cmd));
+ cmd[0] = GPCMD_SET_STREAMING;
+ cmd[10] = sizeof(buffer);
+
+ memset(buffer, 0, sizeof(buffer));
+ /* first sector 0, last sector 0xffffffff */
+ AV_WB32(buffer + 8, 0xffffffff);
+ if (speed == -1)
+ buffer[0] = 4; /* restore default */
+ else {
+ /* <speed> kilobyte */
+ AV_WB32(buffer + 12, speed);
+ AV_WB32(buffer + 20, speed);
+ }
+ /* 1 second */
+ AV_WB16(buffer + 18, 1000);
+ AV_WB16(buffer + 26, 1000);
+
+ fd = open(device, O_RDWR | O_NONBLOCK);
+ if (fd == -1) {
+ mp_tmsg(MSGT_OPEN, MSGL_INFO, "Couldn't open DVD device for writing, changing DVD speed needs write access.\n");
+ return;
+ }
+
+ if (ioctl(fd, SG_IO, &sghdr) < 0)
+ mp_tmsg(MSGT_OPEN, MSGL_INFO, "failed\n");
+ else
+ mp_tmsg(MSGT_OPEN, MSGL_INFO, "successful\n");
+
+ close(fd);
+#endif
+}
/**
\brief Converts DVD time structure to milliseconds.
diff --git a/stream/stream_dvd_common.h b/stream/stream_dvd_common.h
index 906ae02ba6..b5e86c1162 100644
--- a/stream/stream_dvd_common.h
+++ b/stream/stream_dvd_common.h
@@ -5,6 +5,12 @@
#include <inttypes.h>
#include <dvdread/ifo_types.h>
+extern char *dvd_device;
+extern const char * const dvd_audio_stream_channels[6];
+extern const char * const dvd_audio_stream_types[8];
+
+extern int dvd_speed;
+void dvd_set_speed(char *device, unsigned speed);
int mp_dvdtimetomsec(dvd_time_t *dt);
#endif /* MPLAYER_STREAM_DVD_COMMON_H */
diff --git a/stream/stream_dvdnav.c b/stream/stream_dvdnav.c
index 1700463787..3f419dfb65 100644
--- a/stream/stream_dvdnav.c
+++ b/stream/stream_dvdnav.c
@@ -47,10 +47,6 @@ typedef struct {
unsigned int state;
} dvdnav_priv_t;
-extern char *dvd_device;
-extern char *audio_lang, *dvdsub_lang;
-extern char *dvd_audio_stream_channels[6], *dvd_audio_stream_types[8];
-
static struct stream_priv_s {
int track;
char* device;
@@ -91,6 +87,8 @@ static dvdnav_priv_t * new_dvdnav_stream(char * filename) {
return NULL;
}
+ dvd_set_speed(priv->filename, dvd_speed);
+
if(dvdnav_open(&(priv->dvdnav),priv->filename)!=DVDNAV_STATUS_OK)
{
free(priv->filename);
@@ -295,6 +293,7 @@ static void stream_dvdnav_close(stream_t *s) {
dvdnav_priv_t *priv = s->priv;
dvdnav_close(priv->dvdnav);
priv->dvdnav = NULL;
+ dvd_set_speed(priv->filename, -1);
free(priv);
}
@@ -350,8 +349,10 @@ static int fill_buffer(stream_t *s, char *but, int len)
if(dvdnav_current_title_info(priv->dvdnav, &tit, &part) == DVDNAV_STATUS_OK) {
mp_msg(MSGT_CPLAYER,MSGL_V, "\r\nDVDNAV, NEW TITLE %d\r\n", tit);
dvdnav_get_highlight (priv, 0);
- if(priv->title > 0 && tit != priv->title)
+ if(priv->title > 0 && tit != priv->title) {
+ priv->state |= NAV_FLAG_EOF;
return 0;
+ }
}
break;
}
@@ -365,8 +366,10 @@ static int fill_buffer(stream_t *s, char *but, int len)
priv->state |= NAV_FLAG_WAIT_READ;
if(priv->title > 0 && dvd_last_chapter > 0) {
int tit=0, part=0;
- if(dvdnav_current_title_info(priv->dvdnav, &tit, &part) == DVDNAV_STATUS_OK && part > dvd_last_chapter)
+ if(dvdnav_current_title_info(priv->dvdnav, &tit, &part) == DVDNAV_STATUS_OK && part > dvd_last_chapter) {
+ priv->state |= NAV_FLAG_EOF;
return 0;
+ }
}
dvdnav_get_highlight (priv, 1);
}
@@ -517,9 +520,9 @@ static void show_audio_subs_languages(dvdnav_t *nav)
uint8_t lg;
uint16_t i, lang, format, id, channels;
int base[7] = {128, 0, 0, 0, 160, 136, 0};
- char tmp[3];
for(i=0; i<8; i++)
{
+ char tmp[] = "unknown";
lg = dvdnav_get_audio_logical_stream(nav, i);
if(lg == 0xff) continue;
channels = dvdnav_audio_stream_channels(nav, lg);
@@ -528,41 +531,37 @@ static void show_audio_subs_languages(dvdnav_t *nav)
else
channels--;
lang = dvdnav_audio_stream_to_lang(nav, lg);
- if(lang == 0xFFFF)
- tmp[0] = tmp[1] = '?';
- else
+ if(lang != 0xFFFF)
{
tmp[0] = lang >> 8;
tmp[1] = lang & 0xFF;
+ tmp[2] = 0;
}
- tmp[2] = 0;
format = dvdnav_audio_stream_format(nav, lg);
if(format == 0xFFFF || format > 6)
format = 1; //unknown
id = i + base[format];
- if (lang != 0xFFFF) {
- mp_tmsg(MSGT_OPEN,MSGL_STATUS,"audio stream: %d format: %s (%s) language: %s aid: %d.\n", i,
- dvd_audio_stream_types[format], dvd_audio_stream_channels[channels], tmp, id);
- if(lang && tmp[0])
+ mp_tmsg(MSGT_OPEN,MSGL_STATUS,"audio stream: %d format: %s (%s) language: %s aid: %d.\n", i,
+ dvd_audio_stream_types[format], dvd_audio_stream_channels[channels], tmp, id);
+ if (lang != 0xFFFF && lang && tmp[0])
mp_msg(MSGT_IDENTIFY, MSGL_INFO, "ID_AID_%d_LANG=%s\n", id, tmp);
- }
}
for(i=0; i<32; i++)
{
+ char tmp[] = "unknown";
lg = dvdnav_get_spu_logical_stream(nav, i);
if(lg == 0xff) continue;
- lang = dvdnav_spu_stream_to_lang(nav, lg);
- if(lang == 0xFFFF)
- tmp[0] = tmp[1] = '?';
- else
+ lang = dvdnav_spu_stream_to_lang(nav, i);
+ if(lang != 0xFFFF)
{
tmp[0] = lang >> 8;
tmp[1] = lang & 0xFF;
+ tmp[2] = 0;
}
- tmp[2] = 0;
- if (lang != 0xFFFF)
- mp_tmsg(MSGT_OPEN,MSGL_STATUS,"subtitle ( sid ): %d language: %s\n", i+0x20, tmp);
+ mp_msg(MSGT_OPEN,MSGL_STATUS,"subtitle ( sid ): %d language: %s\n", lg, tmp);
+ if (lang != 0xFFFF && lang && tmp[0])
+ mp_msg(MSGT_IDENTIFY, MSGL_INFO, "ID_SID_%d_LANG=%s\n", lg, tmp);
}
}
@@ -698,11 +697,11 @@ static int mp_dvdnav_get_aid_from_format (stream_t *stream, int index, uint8_t l
format = dvdnav_audio_stream_format(priv->dvdnav, lg);
switch(format) {
case DVDNAV_FORMAT_AC3:
- return (index + 128);
+ return index + 128;
case DVDNAV_FORMAT_DTS:
- return (index + 136);
+ return index + 136;
case DVDNAV_FORMAT_LPCM:
- return (index + 160);
+ return index + 160;
case DVDNAV_FORMAT_MPEGAUDIO:
return index;
default:
@@ -713,27 +712,6 @@ static int mp_dvdnav_get_aid_from_format (stream_t *stream, int index, uint8_t l
}
/**
- * \brief mp_dvdnav_aid_from_audio_num() returns the audio id corresponding to the logical number
- * \param stream: - stream pointer
- * \param audio_num: - logical number
- * \return -1 on error, current subtitle id if successful
- */
-int mp_dvdnav_aid_from_audio_num(stream_t *stream, int audio_num) {
- dvdnav_priv_t * priv = stream->priv;
- int k;
- uint8_t lg;
-
- for(k=0; k<32; k++) {
- lg = dvdnav_get_audio_logical_stream(priv->dvdnav, k);
- if (lg == 0xff) continue;
- if (lg != audio_num) continue;
-
- return mp_dvdnav_get_aid_from_format (stream, k, lg);
- }
- return -1;
-}
-
-/**
* \brief mp_dvdnav_aid_from_lang() returns the audio id corresponding to the language code 'lang'
* \param stream: - stream pointer
* \param lang: 2-characters language code[s], eventually separated by spaces of commas
@@ -801,9 +779,9 @@ int mp_dvdnav_sid_from_lang(stream_t *stream, unsigned char *language) {
for(k=0; k<32; k++) {
lg = dvdnav_get_spu_logical_stream(priv->dvdnav, k);
if(lg == 0xff) continue;
- lang = dvdnav_spu_stream_to_lang(priv->dvdnav, lg);
+ lang = dvdnav_spu_stream_to_lang(priv->dvdnav, k);
if(lang != 0xFFFF && lang == lcode) {
- return k;
+ return lg;
}
}
language += 2;
@@ -820,12 +798,16 @@ int mp_dvdnav_sid_from_lang(stream_t *stream, unsigned char *language) {
* \return 0 on error, 1 if successful
*/
int mp_dvdnav_lang_from_sid(stream_t *stream, int sid, unsigned char *buf) {
- uint8_t lg;
+ uint8_t k;
uint16_t lang;
dvdnav_priv_t *priv = stream->priv;
if(sid < 0) return 0;
- lg = dvdnav_get_spu_logical_stream(priv->dvdnav, sid);
- lang = dvdnav_spu_stream_to_lang(priv->dvdnav, lg);
+ for (k=0; k<32; k++)
+ if (dvdnav_get_spu_logical_stream(priv->dvdnav, k) == sid)
+ break;
+ if (k == 32)
+ return 0;
+ lang = dvdnav_spu_stream_to_lang(priv->dvdnav, k);
if(lang == 0xffff) return 0;
buf[0] = lang >> 8;
buf[1] = lang & 0xFF;
@@ -846,7 +828,7 @@ int mp_dvdnav_number_of_subs(stream_t *stream) {
for(k=0; k<32; k++) {
lg = dvdnav_get_spu_logical_stream(priv->dvdnav, k);
if(lg == 0xff) continue;
- n++;
+ if(lg >= n) n = lg + 1;
}
return n;
}
diff --git a/stream/tv.c b/stream/tv.c
index 324e059c5d..85a79267b6 100644
--- a/stream/tv.c
+++ b/stream/tv.c
@@ -29,6 +29,7 @@
#include "libaf/af_format.h"
#include "libmpcodecs/img_format.h"
+#include "libmpcodecs/dec_teletext.h"
#include "libavutil/avstring.h"
#include "osdep/timer.h"
@@ -333,7 +334,8 @@ int tv_set_norm(tvi_handle_t *tvh, char* norm)
mp_tmsg(MSGT_TV, MSGL_ERR, "Error: Cannot set norm!\n");
return 0;
}
- tvh->functions->control(tvh->priv,TV_VBI_CONTROL_RESET,tvh->tv_param);
+ teletext_control(tvh->demuxer->teletext,TV_VBI_CONTROL_RESET,
+ &tvh->tv_param->teletext);
return 1;
}
@@ -347,8 +349,9 @@ static int tv_set_norm_i(tvi_handle_t *tvh, int norm)
return 0;
}
- tvh->functions->control(tvh->priv,TV_VBI_CONTROL_RESET,tvh->tv_param);
- return(1);
+ teletext_control(tvh->demuxer->teletext,TV_VBI_CONTROL_RESET,
+ &tvh->tv_param->teletext);
+ return 1;
}
static int open_tv(tvi_handle_t *tvh)
@@ -675,7 +678,11 @@ static demuxer_t* demux_open_tv(demuxer_t *demuxer)
if(!(tvh=tv_begin(demuxer->stream->priv))) return NULL;
if (!tvh->functions->init(tvh->priv)) return NULL;
- tvh->functions->control(tvh->priv,TVI_CONTROL_VBI_INIT,&(tvh->tv_param->tdevice));
+ tvh->demuxer = demuxer;
+ tvh->functions->control(tvh->priv,TVI_CONTROL_VBI_INIT,
+ &(tvh->tv_param->teletext.device));
+ tvh->functions->control(tvh->priv,TVI_CONTROL_GET_VBI_PTR,
+ &demuxer->teletext);
if (!open_tv(tvh)){
tv_uninit(tvh);
@@ -818,7 +825,8 @@ no_audio:
if(funcs->control(tvh->priv,TVI_CONTROL_VID_SET_GAIN,&tvh->tv_param->gain)!=TVI_CONTROL_TRUE)
mp_msg(MSGT_TV,MSGL_WARN,"Unable to set gain control!\n");
- funcs->control(tvh->priv,TV_VBI_CONTROL_RESET,tvh->tv_param);
+ teletext_control(demuxer->teletext,TV_VBI_CONTROL_RESET,
+ &tvh->tv_param->teletext);
return demuxer;
}
@@ -830,6 +838,7 @@ static void demux_close_tv(demuxer_t *demuxer)
tv_uninit(tvh);
free(tvh);
demuxer->priv=NULL;
+ demuxer->teletext=NULL;
}
/* utilities for mplayer (not mencoder!!) */
@@ -899,7 +908,8 @@ int tv_set_freq(tvi_handle_t *tvh, unsigned long freq)
mp_tmsg(MSGT_TV, MSGL_V, "Current frequency: %lu (%.3f)\n",
freq, (float)freq/16);
}
- tvh->functions->control(tvh->priv,TV_VBI_CONTROL_RESET,tvh->tv_param);
+ teletext_control(tvh->demuxer->teletext,TV_VBI_CONTROL_RESET,
+ &tvh->tv_param->teletext);
return 1;
}
@@ -1080,7 +1090,8 @@ int tv_step_norm(tvi_handle_t *tvh)
return 0;
}
}
- tvh->functions->control(tvh->priv,TV_VBI_CONTROL_RESET,tvh->tv_param);
+ teletext_control(tvh->demuxer->teletext,TV_VBI_CONTROL_RESET,
+ &tvh->tv_param->teletext);
return 1;
}
diff --git a/stream/tv.h b/stream/tv.h
index d177628e85..48ff88ecc2 100644
--- a/stream/tv.h
+++ b/stream/tv.h
@@ -25,6 +25,9 @@
#ifndef MPLAYER_TV_H
#define MPLAYER_TV_H
+#include "libmpcodecs/dec_teletext.h"
+#include "libmpdemux/demuxer.h"
+
typedef struct tv_param_s {
char *freq;
char *channel;
@@ -62,10 +65,7 @@ typedef struct tv_param_s {
int hue;
int saturation;
int gain;
- char *tdevice; ///< teletext device
- int tformat; ///< teletext display format
- int tpage; ///< start teletext page
- int tlang; ///< primary language code
+ struct tt_param teletext;
int scan;
int scan_threshold;
@@ -125,6 +125,7 @@ typedef struct tvi_handle_s {
const tvi_functions_t *functions;
void *priv;
int seq;
+ demuxer_t *demuxer;
/* specific */
int norm;
@@ -218,42 +219,9 @@ typedef struct {
#define TVI_CONTROL_SPC_SET_INPUT 0x402 /* set input channel (tv,s-video,composite..) */
#define TVI_CONTROL_SPC_GET_NORMID 0x403 /* get normid from norm name */
-//tvi_* ioctl (not tvi_vbi.c !!!)
+//tvi_* ioctl (not dec_teletext.c !!!)
#define TVI_CONTROL_VBI_INIT 0x501 ///< vbi init
-
-/*
- TELETEXT controls (through teletext_control() )
- NOTE:
- _SET_ should be _GET_ +1
- _STEP_ should be _GET_ +2
-*/
-#define TV_VBI_CONTROL_GET_MODE 0x510 ///< get current mode teletext
-#define TV_VBI_CONTROL_SET_MODE 0x511 ///< on/off grab teletext
-
-#define TV_VBI_CONTROL_GET_PAGE 0x513 ///< get grabbed teletext page
-#define TV_VBI_CONTROL_SET_PAGE 0x514 ///< set grab teletext page number
-#define TV_VBI_CONTROL_STEP_PAGE 0x515 ///< step grab teletext page number
-
-#define TV_VBI_CONTROL_GET_SUBPAGE 0x516 ///< get grabbed teletext page
-#define TV_VBI_CONTROL_SET_SUBPAGE 0x517 ///< set grab teletext page number
-
-#define TV_VBI_CONTROL_GET_FORMAT 0x519 ///< get teletext format
-#define TV_VBI_CONTROL_SET_FORMAT 0x51a ///< set teletext format
-
-#define TV_VBI_CONTROL_GET_HALF_PAGE 0x51c ///< get current half page
-#define TV_VBI_CONTROL_SET_HALF_PAGE 0x51d ///< switch half page
-
-#define TV_VBI_CONTROL_IS_CHANGED 0x540 ///< teletext page is changed
-#define TV_VBI_CONTROL_MARK_UNCHANGED 0x541 ///< teletext page is changed
-
-#define TV_VBI_CONTROL_ADD_DEC 0x550 ///< add page number with dec
-#define TV_VBI_CONTROL_GO_LINK 0x551 ///< go link (1..6) NYI
-#define TV_VBI_CONTROL_GET_VBIPAGE 0x552 ///< get vbi_image for grabbed teletext page
-#define TV_VBI_CONTROL_RESET 0x553 ///< vbi reset
-#define TV_VBI_CONTROL_START 0x554 ///< vbi start
-#define TV_VBI_CONTROL_STOP 0x555 ///< vbi stop
-#define TV_VBI_CONTROL_DECODE_PAGE 0x556 ///< decode vbi page
-#define TV_VBI_CONTROL_GET_NETWORKNAME 0x557 ///< get current network name
+#define TVI_CONTROL_GET_VBI_PTR 0x502 ///< get teletext private pointer
int tv_set_color_options(tvi_handle_t *tvh, int opt, int val);
int tv_get_color_options(tvi_handle_t *tvh, int opt, int* val);
@@ -292,78 +260,4 @@ void tv_start_scan(tvi_handle_t *tvh, int start);
#define TV_NORM_PALN 6
#define TV_NORM_NTSCJP 7
-#define VBI_TFORMAT_TEXT 0 ///< text mode
-#define VBI_TFORMAT_BW 1 ///< black&white mode
-#define VBI_TFORMAT_GRAY 2 ///< grayscale mode
-#define VBI_TFORMAT_COLOR 3 ///< color mode (require color_spu patch!)
-
-#define VBI_MAX_PAGES 0x800 ///< max sub pages number
-#define VBI_MAX_SUBPAGES 64 ///< max sub pages number
-
-#define VBI_ROWS 25 ///< teletext page height in rows
-#define VBI_COLUMNS 40 ///< teletext page width in chars
-#define VBI_TIME_LINEPOS 26 ///< time line pos in page header
-
-typedef
-enum{
- TT_FORMAT_OPAQUE=0, ///< opaque
- TT_FORMAT_TRANSPARENT, ///< transparent
- TT_FORMAT_OPAQUE_INV, ///< opaque with inverted colors
- TT_FORMAT_TRANSPARENT_INV ///< transparent with inverted colors
-} teletext_format;
-
-typedef
-enum{
- TT_ZOOM_NORMAL=0,
- TT_ZOOM_TOP_HALF,
- TT_ZOOM_BOTTOM_HALF
-} teletext_zoom;
-
-typedef struct tt_char_s{
- unsigned int unicode; ///< unicode (utf8) character
- unsigned char fg; ///< foreground color
- unsigned char bg; ///< background color
- unsigned char gfx; ///< 0-no gfx, 1-solid gfx, 2-separated gfx
- unsigned char flh; ///< 0-no flash, 1-flash
- unsigned char hidden; ///< char is hidden (for subtitle pages)
- unsigned char ctl; ///< control character
- unsigned char lng; ///< lang: 0-secondary language,1-primary language
- unsigned char raw; ///< raw character (as received from device)
-} tt_char;
-
-typedef struct tt_link_s{
- int pagenum; ///< page number
- int subpagenum; ///< subpage number
-} tt_link_t;
-
-typedef struct tt_page_s{
- int pagenum; ///< page number
- int subpagenum; ///< subpage number
- unsigned char primary_lang; ///< primary language code
- unsigned char secondary_lang; ///< secondary language code
- unsigned char active; ///< page is complete and ready for rendering
- unsigned char flags; ///< page flags
- unsigned char raw[VBI_ROWS*VBI_COLUMNS]; ///< page data
- struct tt_page_s* next_subpage;
- struct tt_link_s links[6];
-} tt_page;
-
-#define TT_PGFL_SUPPRESS_HEADER 0x01
-#define TT_PGFL_UPDATE_INDICATOR 0x02
-#define TT_PGFL_INTERRUPTED_SEQ 0x04
-#define TT_PGFL_INHIBIT_DISPLAY 0x08
-#define TT_PGFL_NEWFLASH 0x10
-#define TT_PGFL_SUBTITLE 0x20
-#define TT_PGFL_ERASE_PAGE 0x40
-#define TT_PGFL_MAGAZINE_SERIAL 0x80
-
-typedef struct tt_stream_props_s{
- int sampling_rate;
- int samples_per_line;
- int offset;
- int count[2]; ///< number of lines in first and second fields
- int interlaced; ///< vbi data are interlaced
- int bufsize; ///< required buffer size
-} tt_stream_props;
-
#endif /* MPLAYER_TV_H */
diff --git a/stream/tvi_def.h b/stream/tvi_def.h
index 3c0ef8edb0..f15fcce481 100644
--- a/stream/tvi_def.h
+++ b/stream/tvi_def.h
@@ -15,8 +15,6 @@ static int get_video_framesize(priv_t *priv);
static double grab_audio_frame(priv_t *priv, char *buffer, int len);
static int get_audio_framesize(priv_t *priv);
-int teletext_control(void* p, int cmd, void *arg);
-
static const tvi_functions_t functions =
{
init,
diff --git a/stream/tvi_dshow.c b/stream/tvi_dshow.c
index b77f9cb20a..09c6328d8d 100644
--- a/stream/tvi_dshow.c
+++ b/stream/tvi_dshow.c
@@ -76,6 +76,7 @@
#include <stdio.h>
#include "libmpcodecs/img_format.h"
+#include "libmpcodecs/dec_teletext.h"
#include "libaf/af_format.h"
#include "help_mp.h"
#include "osdep/timer.h"
@@ -2263,7 +2264,6 @@ static int get_audio_framesize(priv_t * priv)
return priv->chains[1]->rbuf->blocksize;
}
-#ifdef CONFIG_TV_TELETEXT
static int vbi_get_props(priv_t* priv,tt_stream_props* ptsp)
{
if(!priv || !ptsp)
@@ -2309,7 +2309,6 @@ static void vbi_grabber(priv_t* priv)
}
free(buf);
}
-#endif /* CONFIG_TV_TELETEXT */
/**
* \brief fills given buffer with video data (usually one frame)
@@ -2354,9 +2353,7 @@ static double grab_video_frame(priv_t * priv, char *buffer, int len)
rb->count--;
LeaveCriticalSection(rb->pMutex);
-#ifdef CONFIG_TV_TELETEXT
vbi_grabber(priv);
-#endif
return pts;
}
@@ -2545,13 +2542,12 @@ static HRESULT build_audio_chain(priv_t *priv)
*/
static HRESULT build_vbi_chain(priv_t *priv)
{
-#ifdef CONFIG_TV_TELETEXT
HRESULT hr;
if(priv->chains[2]->rbuf)
return S_OK;
- if(priv->tv_param->tdevice)
+ if(priv->tv_param->teletext.device)
{
priv->chains[2]->rbuf=calloc(1,sizeof(grabber_ringbuffer_t));
if(!priv->chains[2]->rbuf)
@@ -2565,7 +2561,6 @@ static HRESULT build_vbi_chain(priv_t *priv)
return 0;
}
}
-#endif
return S_OK;
}
@@ -2901,10 +2896,8 @@ static int init(priv_t * priv)
OLE_QUERYINTERFACE(priv->pBuilder,IID_IBaseFilter,pBF);
OLE_CALL_ARGS(pBF,SetSyncSource,rc);
}
-#ifdef CONFIG_TV_TELETEXT
if(vbi_get_props(priv,&(priv->tsp))!=TVI_CONTROL_TRUE)
break;
-#endif
result = 1;
} while(0);
@@ -2974,9 +2967,7 @@ static int uninit(priv_t * priv)
if (priv->dwRegister) {
RemoveFromRot(priv->dwRegister);
}
-#ifdef CONFIG_TV_TELETEXT
teletext_control(priv->priv_vbi,TV_VBI_CONTROL_STOP,(void*)1);
-#endif
//stop audio grabber thread
if (priv->state && priv->pMediaControl) {
@@ -3481,20 +3472,19 @@ static int control(priv_t * priv, int cmd, void *arg)
case TVI_CONTROL_IMMEDIATE:
priv->immediate_mode = 1;
return TVI_CONTROL_TRUE;
-#ifdef CONFIG_TV_TELETEXT
case TVI_CONTROL_VBI_INIT:
{
void* ptr;
ptr=&(priv->tsp);
- if(teletext_control(NULL,TV_VBI_CONTROL_START,&ptr)==TVI_CONTROL_TRUE)
+ if(teletext_control(NULL,TV_VBI_CONTROL_START,&ptr)==VBI_CONTROL_TRUE)
priv->priv_vbi=ptr;
else
priv->priv_vbi=NULL;
return TVI_CONTROL_TRUE;
}
- default:
- return teletext_control(priv->priv_vbi,cmd,arg);
-#endif
+ case TVI_CONTROL_GET_VBI_PTR:
+ *(void **)arg=priv->priv_vbi;
+ return TVI_CONTROL_TRUE;
}
return TVI_CONTROL_UNKNOWN;
}
diff --git a/stream/tvi_v4l.c b/stream/tvi_v4l.c
index ea7064762c..e46f13797c 100644
--- a/stream/tvi_v4l.c
+++ b/stream/tvi_v4l.c
@@ -40,6 +40,7 @@
#include "mp_msg.h"
#include "libaf/af_format.h"
#include "libmpcodecs/img_format.h"
+#include "libmpcodecs/dec_teletext.h"
#include "libvo/fastmemcpy.h"
#include "libvo/videodev_mjpeg.h"
@@ -141,14 +142,12 @@ typedef struct {
long audio_recv_blocks_total;
long audio_sent_blocks_total;
long mjpeg_bufsize;
-#ifdef CONFIG_TV_TELETEXT
char *vbi_dev;
int vbi_fd;
int vbi_bufsize;
int vbi_shutdown;
pthread_t vbi_grabber_thread;
void *priv_vbi;
-#endif
tv_param_t *tv_param;
} priv_t;
@@ -675,7 +674,6 @@ static int uninit(priv_t *priv)
{
unsigned long num;
-#ifdef CONFIG_TV_TELETEXT
priv->vbi_shutdown=1;
if(priv->vbi_grabber_thread)
pthread_join(priv->vbi_grabber_thread, NULL);
@@ -693,8 +691,6 @@ static int uninit(priv_t *priv)
priv->vbi_dev=0;
}
-#endif
-
priv->shutdown = 1;
mp_msg(MSGT_TV, MSGL_V, "Waiting for threads to finish... ");
@@ -781,7 +777,6 @@ static int get_capture_buffer_size(priv_t *priv)
return cnt;
}
-#ifdef CONFIG_TV_TELETEXT
static int vbi_init(priv_t* priv,char* device)
{
int vbi_fd=0;
@@ -897,7 +892,6 @@ static void *vbi_grabber(void *data)
free(buf);
return NULL;
}
-#endif /* CONFIG_TV_TELETEXT */
static int start(priv_t *priv)
{
@@ -1111,13 +1105,11 @@ static int start(priv_t *priv)
ioctl(priv->video_fd, VIDIOCSAUDIO, &priv->audio[priv->audio_id]);
}
-#ifdef CONFIG_TV_TELETEXT
/* start vbi thread */
if(priv->priv_vbi){
priv->vbi_shutdown = 0;
pthread_create(&priv->vbi_grabber_thread, NULL, vbi_grabber, priv);
}
-#endif
/* launch capture threads */
priv->shutdown = 0;
@@ -1511,7 +1503,6 @@ static int control(priv_t *priv, int cmd, void *arg)
priv->immediate_mode = 1;
return TVI_CONTROL_TRUE;
}
-#ifdef CONFIG_TV_TELETEXT
case TVI_CONTROL_VBI_INIT:
{
void* ptr;
@@ -1522,16 +1513,16 @@ static int control(priv_t *priv, int cmd, void *arg)
if(vbi_get_props(priv,&tsp)==TVI_CONTROL_TRUE)
{
ptr=&tsp;
- if(teletext_control(NULL,TV_VBI_CONTROL_START,&ptr)==TVI_CONTROL_TRUE)
+ if(teletext_control(NULL,TV_VBI_CONTROL_START,&ptr)==VBI_CONTROL_TRUE)
priv->priv_vbi=ptr;
else
priv->priv_vbi=NULL;
}
return TVI_CONTROL_TRUE;
}
- default:
- return teletext_control(priv->priv_vbi,cmd,arg);
-#endif
+ case TVI_CONTROL_GET_VBI_PTR:
+ *(void **)arg=priv->priv_vbi;
+ return TVI_CONTROL_TRUE;
}
return TVI_CONTROL_UNKNOWN;
diff --git a/stream/tvi_v4l2.c b/stream/tvi_v4l2.c
index 786d42529e..1472d7b6d9 100644
--- a/stream/tvi_v4l2.c
+++ b/stream/tvi_v4l2.c
@@ -53,6 +53,7 @@ known issues:
#include <linux/videodev2.h>
#include "mp_msg.h"
#include "libmpcodecs/img_format.h"
+#include "libmpcodecs/dec_teletext.h"
#include "libaf/af_format.h"
#include "tv.h"
#include "audio_in.h"
@@ -88,14 +89,12 @@ typedef struct {
/* video */
char *video_dev;
int video_fd;
-#ifdef CONFIG_TV_TELETEXT
char *vbi_dev;
int vbi_fd;
int vbi_bufsize;
int vbi_shutdown;
pthread_t vbi_grabber_thread;
void *priv_vbi;
-#endif
int mp_format;
struct v4l2_capability capability;
struct v4l2_input input;
@@ -591,7 +590,6 @@ static int get_control(priv_t *priv, struct v4l2_control *control, int val_signe
return TVI_CONTROL_TRUE;
}
-#ifdef CONFIG_TV_TELETEXT
static int vbi_init(priv_t* priv,char* device)
{
int vbi_fd=0;
@@ -714,7 +712,6 @@ static void *vbi_grabber(void *data)
free(buf);
return NULL;
}
-#endif /* CONFIG_TV_TELETEXT */
static int control(priv_t *priv, int cmd, void *arg)
{
@@ -1038,7 +1035,6 @@ static int control(priv_t *priv, int cmd, void *arg)
if (audio_in_set_samplerate(&priv->audio_in, *(int*)arg) < 0) return TVI_CONTROL_FALSE;
// setup_audio_buffer_sizes(priv);
return TVI_CONTROL_TRUE;
-#ifdef CONFIG_TV_TELETEXT
case TVI_CONTROL_VBI_INIT:
{
void* ptr;
@@ -1049,16 +1045,16 @@ static int control(priv_t *priv, int cmd, void *arg)
if(vbi_get_props(priv,&tsp)==TVI_CONTROL_TRUE)
{
ptr=&tsp;
- if(teletext_control(NULL,TV_VBI_CONTROL_START,&ptr)==TVI_CONTROL_TRUE)
+ if(teletext_control(NULL,TV_VBI_CONTROL_START,&ptr)==VBI_CONTROL_TRUE)
priv->priv_vbi=ptr;
else
priv->priv_vbi=NULL;
}
return TVI_CONTROL_TRUE;
}
- default:
- return teletext_control(priv->priv_vbi,cmd,arg);
-#endif
+ case TVI_CONTROL_GET_VBI_PTR:
+ *(void **)arg=priv->priv_vbi;
+ return TVI_CONTROL_TRUE;
}
mp_msg(MSGT_TV, MSGL_V, "%s: unknown control: %d\n", info.short_name, cmd);
return TVI_CONTROL_UNKNOWN;
@@ -1105,7 +1101,6 @@ static int uninit(priv_t *priv)
{
int i, frames, dropped = 0;
-#ifdef CONFIG_TV_TELETEXT
priv->vbi_shutdown=1;
if(priv->vbi_grabber_thread)
pthread_join(priv->vbi_grabber_thread, NULL);
@@ -1122,9 +1117,6 @@ static int uninit(priv_t *priv)
free(priv->vbi_dev);
priv->vbi_dev=0;
}
-
-#endif
-
priv->shutdown = 1;
if(priv->video_grabber_thread)
pthread_join(priv->video_grabber_thread, NULL);
@@ -1560,13 +1552,11 @@ static int start(priv_t *priv)
}
}
-#ifdef CONFIG_TV_TELETEXT
/* start vbi thread */
if(priv->priv_vbi){
priv->vbi_shutdown = 0;
pthread_create(&priv->vbi_grabber_thread, NULL, vbi_grabber, priv);
}
-#endif
/* start audio thread */
priv->shutdown = 0;
priv->audio_skew_measure_time = 0;
diff --git a/stream/tvi_vbi.c b/stream/tvi_vbi.c
deleted file mode 100644
index 8677fa1d69..0000000000
--- a/stream/tvi_vbi.c
+++ /dev/null
@@ -1,1850 +0,0 @@
-/*
- * Teletext support
- *
- * Copyright (C) 2007 Vladimir Voroshilov <voroshil@gmail.com>
- *
- * This file is part of MPlayer.
- *
- * MPlayer is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
- * (at your option) any later version.
- *
- * MPlayer is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License along
- * with MPlayer; if not, write to the Free Software Foundation, Inc.,
- * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
- *
- *
- * Based on Attila Otvos' teletext patch, Michael Niedermayer's
- * proof-of-concept teletext capture utility and some parts
- * (decode_raw_line_runin,pll_add,pll_reset) of MythTV project.
- * Code for calculating [soc:eoc] is based on aletv of Edgar Toernig.
- *
- * Teletext system is described in
- * ETS 300 706 "Enhanced Teletext specification" : May 1997
- * http://www.themm.net/~mihu/linux/saa7146/specs/ets_300706e01p.pdf
- *
- * Some implementation details:
- * How to port teletext to another tvi_* driver (see tvi_v4l2.c for example):
- *
- * 1. Implement TVI_CONTROL_VBI_INIT (initialize driver-related vbi subsystem,
- * start grabbing thread)
- * input data: vbi device name.
- * (driver should also call TV_VBI_CONTROL_START for common vbi subsystem initialization
- * with pointer to initialized tt_stream_properties structure.
- * After ioctl call variable will contain pointer to initialized priv_vbi_t structure.
- *
- * 2. After receiving next chunk of raw vbi data call TV_VBI_CONTROL_DECODE_PAGE
- * ioctl with pointer to data buffer
- * 3. pass all other VBI related ioctl cmds to teletext_control routine
- *
- * Page displaying process consist of following stages:
- *
- * ---grabbing stage---
- * 0. stream/tvi_*.c: vbi_grabber(...)
- * getting vbi data from video device
- * ---decoding stage---
- * 1. stream/tvi_vbi.c: decode_raw_line_runin(...) or decode_raw_line_sine(...)
- * decode raw vbi data into sliced 45(?) bytes long packets
- * 2. stream/tvi_vbi.c: decode_pkt0(...), decode_pkt_page(...)
- * packets processing (header analyzing, storing complete page in cache,
- * only raw member of tt_char is filled at this stage)
- * 3. stream/tvi_vbi.c: decode_page(...)
- * page decoding. filling unicode,gfx,ctl,etc members of tt_char structure
- * with appropriate values according to teletext control chars, converting
- * text to utf8.
- * ---rendering stage---
- * 4. stream/tvi_vbi.c: prepare_visible_page(...)
- * processing page. adding number of just received by background process
- * teletext page, adding current time,etc.
- * 5. libvo/sub.c: vo_update_text_teletext(...)
- * rendering displayable osd with text and graphics
- *
- * TODO:
- * v4lv1,bktr support
- * spu rendering
- * is better quality on poor signal possible ?
- * link support
- * font autoscale
- * greyscale osd
- * slave command for dumping pages
- * fix bcd<->dec as suggested my Michael
- *
- * BUGS:
- * wrong colors in debug dump
- * blinking when visible page was just updated
- */
-
-#include "config.h"
-
-#include <stdlib.h>
-#include <string.h>
-#include <unistd.h>
-#include <errno.h>
-#include <math.h>
-#include <stdio.h>
-
-#include <pthread.h>
-
-#include "tv.h"
-#include "mp_msg.h"
-#include "help_mp.h"
-#include "libmpcodecs/img_format.h"
-#include "libavutil/common.h"
-#include "input/input.h"
-#include "osdep/timer.h"
-
-//#define DEBUG_DUMP 1
-
-/// page magazine entry structure
-typedef struct mag_s{
- tt_page* pt;
- int order;
-} mag_t;
-
-typedef struct {
- int on; ///< teletext on/off
- int pagenum; ///< seek page number
- int subpagenum; ///< seek subpage
- int curr_pagenum; ///< current page number
- int pagenumdec; ///< set page num with dec
-
- teletext_format tformat; ///< see teletext_format enum
- teletext_zoom zoom; ///< see teletext_zoom enum
- mag_t* mag; ///< pages magazine (has 8 entities)
- int primary_language; ///< primary character set
- int secondary_language; ///< secondary character set
- /// Currently displayed page (with additional info, e.g current time)
- tt_char display_page[VBI_ROWS*VBI_COLUMNS];
- /// number of raw bytes between two subsequent encoded bits
- int bpb;
- /// clock run-in sequence will be searched in buffer in [soc:eoc] bytes range
- int soc;
- int eoc;
- /// minimum number of raw vbi bytes wich can be decoded into 8 data bits
- int bp8bl;
- /// maximum number of raw vbi bytes wich can be decoded into 8 data bits
- int bp8bh;
-
- int pll_adj;
- int pll_dir;
- int pll_cnt;
- int pll_err;
- int pll_lerr;
- int pll_fixed;
- /// vbi stream properties (buffer size,bytes per line, etc)
- tt_stream_props* ptsp;
- pthread_mutex_t buffer_mutex;
-
- tt_page** ptt_cache;
- unsigned char* ptt_cache_first_subpage;
- /// network info
- unsigned char initialpage;
- unsigned int initialsubpage;
- unsigned int networkid;
- int timeoffset; // timeoffset=realoffset*2
- unsigned int juliandate;
- unsigned int universaltime;
- unsigned char networkname[21];
- int cache_reset;
- /// "page changed" flag: 0-unchanged, 1-entire page, 3-only header
- int page_changed;
- int last_rendered;
-} priv_vbi_t;
-
-static unsigned char fixParity[256];
-
-static const tt_char tt_space={0x20,7,0,0,0,0,0,0,0x20};
-static const tt_char tt_error={'?',1,0,0,0,0,0,0,'?'}; // Red '?' on black background
-static double si[12];
-static double co[12];
-
-#define VBI_FORMAT(priv) (*(priv->ptsp))
-
-#define FIXP_SH 16
-#define ONE_FIXP (1<<FIXP_SH)
-#define FIXP2INT(a) ((a)>>FIXP_SH)
-#define ANY2FIXP(a) ((int)((a)*ONE_FIXP))
-
-static const unsigned char corrHamm48[256]={
- 0x01, 0xff, 0x01, 0x01, 0xff, 0x00, 0x01, 0xff,
- 0xff, 0x02, 0x01, 0xff, 0x0a, 0xff, 0xff, 0x07,
- 0xff, 0x00, 0x01, 0xff, 0x00, 0x00, 0xff, 0x00,
- 0x06, 0xff, 0xff, 0x0b, 0xff, 0x00, 0x03, 0xff,
- 0xff, 0x0c, 0x01, 0xff, 0x04, 0xff, 0xff, 0x07,
- 0x06, 0xff, 0xff, 0x07, 0xff, 0x07, 0x07, 0x07,
- 0x06, 0xff, 0xff, 0x05, 0xff, 0x00, 0x0d, 0xff,
- 0x06, 0x06, 0x06, 0xff, 0x06, 0xff, 0xff, 0x07,
- 0xff, 0x02, 0x01, 0xff, 0x04, 0xff, 0xff, 0x09,
- 0x02, 0x02, 0xff, 0x02, 0xff, 0x02, 0x03, 0xff,
- 0x08, 0xff, 0xff, 0x05, 0xff, 0x00, 0x03, 0xff,
- 0xff, 0x02, 0x03, 0xff, 0x03, 0xff, 0x03, 0x03,
- 0x04, 0xff, 0xff, 0x05, 0x04, 0x04, 0x04, 0xff,
- 0xff, 0x02, 0x0f, 0xff, 0x04, 0xff, 0xff, 0x07,
- 0xff, 0x05, 0x05, 0x05, 0x04, 0xff, 0xff, 0x05,
- 0x06, 0xff, 0xff, 0x05, 0xff, 0x0e, 0x03, 0xff,
- 0xff, 0x0c, 0x01, 0xff, 0x0a, 0xff, 0xff, 0x09,
- 0x0a, 0xff, 0xff, 0x0b, 0x0a, 0x0a, 0x0a, 0xff,
- 0x08, 0xff, 0xff, 0x0b, 0xff, 0x00, 0x0d, 0xff,
- 0xff, 0x0b, 0x0b, 0x0b, 0x0a, 0xff, 0xff, 0x0b,
- 0x0c, 0x0c, 0xff, 0x0c, 0xff, 0x0c, 0x0d, 0xff,
- 0xff, 0x0c, 0x0f, 0xff, 0x0a, 0xff, 0xff, 0x07,
- 0xff, 0x0c, 0x0d, 0xff, 0x0d, 0xff, 0x0d, 0x0d,
- 0x06, 0xff, 0xff, 0x0b, 0xff, 0x0e, 0x0d, 0xff,
- 0x08, 0xff, 0xff, 0x09, 0xff, 0x09, 0x09, 0x09,
- 0xff, 0x02, 0x0f, 0xff, 0x0a, 0xff, 0xff, 0x09,
- 0x08, 0x08, 0x08, 0xff, 0x08, 0xff, 0xff, 0x09,
- 0x08, 0xff, 0xff, 0x0b, 0xff, 0x0e, 0x03, 0xff,
- 0xff, 0x0c, 0x0f, 0xff, 0x04, 0xff, 0xff, 0x09,
- 0x0f, 0xff, 0x0f, 0x0f, 0xff, 0x0e, 0x0f, 0xff,
- 0x08, 0xff, 0xff, 0x05, 0xff, 0x0e, 0x0d, 0xff,
- 0xff, 0x0e, 0x0f, 0xff, 0x0e, 0x0e, 0xff, 0x0e };
-
-
-enum {
- LATIN=0,
- CYRILLIC1,
- CYRILLIC2,
- CYRILLIC3,
- GREEK,
- LANGS
-};
-
-// conversion table for chars 0x20-0x7F (UTF8)
-// TODO: add another languages
-static const unsigned int lang_chars[LANGS][0x60]={
- {
- //Latin
- 0x20,0x21,0x22,0x23,0x24,0x25,0x26,0x27,
- 0x28,0x29,0x2a,0x2b,0x2c,0x2d,0x2e,0x2f,
- 0x30,0x31,0x32,0x33,0x34,0x35,0x36,0x37,
- 0x38,0x39,0x3a,0x3b,0x3c,0x3d,0x3e,0x3f,
- 0x40,0x41,0x42,0x43,0x44,0x45,0x46,0x47,
- 0x48,0x49,0x4a,0x4b,0x4c,0x4d,0x4e,0x4f,
- 0x50,0x51,0x52,0x53,0x54,0x55,0x56,0x57,
- 0x58,0x59,0x5a,0x5b,0x5c,0x5d,0x5e,0x5f,
- 0x60,0x61,0x62,0x63,0x64,0x65,0x66,0x67,
- 0x68,0x69,0x6a,0x6b,0x6c,0x6d,0x6e,0x6f,
- 0x70,0x71,0x72,0x73,0x74,0x75,0x76,0x77,
- 0x78,0x79,0x7a,0x7b,0x7c,0x7d,0x7e,0x7f
- },
- {
- //Cyrillic-1 (Serbian/Croatian)
- 0x20,0x21,0x22,0x23,0x24,0x25,0x044b,0x27,
- 0x28,0x29,0x2a,0x2b,0x2c,0x2d,0x2e,0x2f,
- 0x30,0x31,0x32,0x33,0x34,0x35,0x36,0x37,
- 0x38,0x39,0x3a,0x3b,0x3c,0x3d,0x3e,0x3f,
- 0x0427,0x0410,0x0411,0x0426,0x0414,0x0415,0x0424,0x0413,
- 0x0425,0x0418,0x0408,0x041a,0x041b,0x041c,0x041d,0x041e,
- 0x041f,0x040c,0x0420,0x0421,0x0422,0x0423,0x0412,0x0403,
- 0x0409,0x040a,0x0417,0x040b,0x0416,0x0402,0x0428,0x040f,
- 0x0447,0x0430,0x0431,0x0446,0x0434,0x0435,0x0444,0x0433,
- 0x0445,0x0438,0x0428,0x043a,0x043b,0x043c,0x043d,0x043e,
- 0x043f,0x042c,0x0440,0x0441,0x0442,0x0443,0x0432,0x0423,
- 0x0429,0x042a,0x0437,0x042b,0x0436,0x0422,0x0448,0x042f
- },
- {
- //Cyrillic-2 (Russian/Bulgarian)
- 0x20,0x21,0x22,0x23,0x24,0x25,0x044b,0x27,
- 0x28,0x29,0x2a,0x2b,0x2c,0x2d,0x2e,0x2f,
- 0x30,0x31,0x32,0x33,0x34,0x35,0x36,0x37,
- 0x38,0x39,0x3a,0x3b,0x3c,0x3d,0x3e,0x3f,
- 0x042e,0x0410,0x0411,0x0426,0x0414,0x0415,0x0424,0x0413,
- 0x0425,0x0418,0x0419,0x041a,0x041b,0x041c,0x041d,0x041e,
- 0x041f,0x042f,0x0420,0x0421,0x0422,0x0423,0x0416,0x0412,
- 0x042c,0x042a,0x0417,0x0428,0x042d,0x0429,0x0427,0x042b,
- 0x044e,0x0430,0x0431,0x0446,0x0434,0x0435,0x0444,0x0433,
- 0x0445,0x0438,0x0439,0x043a,0x043b,0x043c,0x043d,0x043e,
- 0x043f,0x044f,0x0440,0x0441,0x0442,0x0443,0x0436,0x0432,
- 0x044c,0x044a,0x0437,0x0448,0x044d,0x0449,0x0447,0x044b
- },
- {
- //Cyrillic-3 (Ukrainian)
- 0x20,0x21,0x22,0x23,0x24,0x25,0xef,0x27,
- 0x28,0x29,0x2a,0x2b,0x2c,0x2d,0x2e,0x2f,
- 0x30,0x31,0x32,0x33,0x34,0x35,0x36,0x37,
- 0x38,0x39,0x3a,0x3b,0x3c,0x3d,0x3e,0x3f,
- 0x042e,0x0410,0x0411,0x0426,0x0414,0x0415,0x0424,0x0413,
- 0x0425,0x0418,0x0419,0x041a,0x041b,0x041c,0x041d,0x041e,
- 0x041f,0x042f,0x0420,0x0421,0x0422,0x0423,0x0416,0x0412,
- 0x042c,0x49,0x0417,0x0428,0x042d,0x0429,0x0427,0xcf,
- 0x044e,0x0430,0x0431,0x0446,0x0434,0x0435,0x0444,0x0433,
- 0x0445,0x0438,0x0439,0x043a,0x043b,0x043c,0x043d,0x043e,
- 0x043f,0x044f,0x0440,0x0441,0x0442,0x0443,0x0436,0x0432,
- 0x044c,0x69,0x0437,0x0448,0x044d,0x0449,0x0447,0xFF
- },
- {
- //Greek
- 0x20,0x21,0x22,0x23,0x24,0x25,0x26,0x27,
- 0x28,0x29,0x2a,0x2b,0x2c,0x2d,0x2e,0x2f,
- 0x30,0x31,0x32,0x33,0x34,0x35,0x36,0x37,
- 0x38,0x39,0x3a,0x3b,0x3c,0x3d,0x3e,0x3f,
- 0x0390,0x0391,0x0392,0x0393,0x0394,0x0395,0x0396,0x0397,
- 0x0398,0x0399,0x039a,0x039b,0x039c,0x039d,0x039e,0x039f,
- 0x03a0,0x03a1,0x03a2,0x03a3,0x03a4,0x03a5,0x03a6,0x03a7,
- 0x03a8,0x03a9,0x03aa,0x03ab,0x03ac,0x03ad,0x03ae,0x03af,
- 0x03b0,0x03b1,0x03b2,0x03b3,0x03b4,0x03b5,0x03b6,0x03b7,
- 0x03b8,0x03b9,0x03ba,0x03bb,0x03bc,0x03bd,0x03be,0x03bf,
- 0x03c0,0x03c1,0x03c2,0x03c3,0x03c4,0x03c5,0x03c6,0x03c7,
- 0x03c8,0x03c9,0x03ca,0x03cb,0x03cc,0x03cd,0x03ce,0x03cf
- }
-};
-
-/**
- * Latin National Option Sub-Sets
- * see Table 36 of ETS specification for details.
- *
- * 00: £ $ @ « ½ » ¬ # ­ ¼ ¦ ¾ ÷ English
- * 01: é ï à ë ê ù î # è â ô û ç French
- * 02: # ¤ É Ä Ö Å Ü _ é ä ö å ü Swedish/Finnish/Hungarian
- * 03: # ů č ť ž ý í ř é á ě ú š Czech/Slovak
- * 04: # $ § Ä Ö Ü ^ _ ° ä ö ü ß German
- * 05: ç $ ¡ á é í ó ú ¿ ü ñ è à Portuguese/Spanish
- * 06: £ $ é ° ç » ¬ # ù à ò è ì Italian
- *
- */
-static const unsigned int latin_subchars[8][13]={
- // English
- {0xa3,0x24,0x40,0xab,0xbd,0xbb,0xac,0x23,0xad,0xbc,0xa6,0xbe,0xf7},
- // French
- {0xe9,0xef,0xe0,0xeb,0xea,0xf9,0xee,0x23,0xe8,0xe2,0xf4,0xfb,0xe7},
- // Swedish/Finnish/Hungarian
- {0x23,0xa4,0xc9,0xc4,0xd6,0xc5,0xdc,0x5f,0xe9,0xe4,0xf6,0xe5,0xfc},
- // Czech/Slovak
- {0x23,0x16f,0x10d,0x165,0x17e,0xfd,0xed,0x159,0xe9,0xe1,0x11b,0xfa,0x161},
- // German
- {0x23,0x24,0xa7,0xc4,0xd6,0xdc,0x5e,0x5f,0xb0,0xe4,0xf6,0xfc,0xdf},
- // Portuguese/Spanish
- {0xe7,0x24,0xa1,0xe1,0xe9,0xed,0xf3,0xfa,0xbf,0xfc,0xf1,0xe8,0xe0},
- // Italian
- {0xa3,0x24,0xe9,0xb0,0xe7,0xbb,0xac,0x23,0xf9,0xe0,0xf2,0xe8,0xec},
- // Reserved
- {0x23,0x24,0x40,0x5b,0x5c,0x5d,0x5e,0x5f,0x60,0x7b,0x7c,0x7d,0x7e}
-};
-
-/**
- * List of supported languages.
- *
- * lang_code bits for primary Language:
- * bits 7-4 corresponds to bits 14-11 of 28 packet's first triplet
- * bits 3-1 corresponds to bits C12-C14 of packet 0 (lang)
- *
- * lang_code bits for secondary Language:
- * bits 7-5 corresponds to bits 3-1 of 28 packet's second triplet
- * bits 4,2 corresponds to bits 18,16 of 28 packet's first triplet
- * bits 3,1 corresponds to bits 15,17 of 28 packet's first triplet
- *
- * For details see Tables 32 and 33 of specification (subclause 15.2)
- */
-struct {
- unsigned char lang_code;
- unsigned char charset;
- const char* lang_name;
-} const tt_languages[]=
-{
- { 0x01, LATIN, "French"},
- { 0x02, LATIN, "Swedish/Finnish/Hungarian"},
- { 0x03, LATIN, "Czech/Slovak"},
- { 0x04, LATIN, "German"},
- { 0x05, LATIN, "Portuguese/Spanish"},
- { 0x06, LATIN, "Italian"},
-
- { 0x08, LATIN, "Polish"},
- { 0x09, LATIN, "French"},
- { 0x0a, LATIN, "Swedish/Finnish/Hungarian"},
- { 0x0b, LATIN, "Czech/Slovak"},
- { 0x0c, LATIN, "German"},
- { 0x0e, LATIN, "Italian"},
-
- { 0x10, LATIN, "English"},
- { 0x11, LATIN, "French"},
- { 0x12, LATIN, "Swedish/Finnish/Hungarian"},
- { 0x13, LATIN, "Turkish"},
- { 0x14, LATIN, "German"},
- { 0x15, LATIN, "Portuguese/Spanish"},
- { 0x16, LATIN, "Italian"},
-
- { 0x1d, LATIN, "Serbian/Croatian/Slovenian (Latin)"},
-
- { 0x20, CYRILLIC1, "Serbian/Croatian (Cyrillic)"},
- { 0x21, CYRILLIC2, "Russian, Bulgarian"},
- { 0x22, LATIN, "Estonian"},
- { 0x23, LATIN, "Czech/Slovak"},
- { 0x24, LATIN, "German"},
- { 0x25, CYRILLIC3, "Ukrainian"},
- { 0x26, LATIN, "Lettish/Lithuanian"},
-
- { 0x33, LATIN, "Turkish"},
- { 0x37, GREEK, "Greek"},
-
- { 0x40, LATIN, "English"},
- { 0x41, LATIN, "French"},
-// { 0x47, ARABIC, "Arabic"},
-
-// { 0x55, HEBREW, "Hebrew"},
-// { 0x57, ARABIC, "Arabic"},
-
- { 0x00, LATIN, "English"},
-};
-
-/**
- * \brief 24/18 Hamming code decoding
- * \param data bytes with hamming code (array must be at least 3 bytes long)
- * \return -1 if multiple bit error occured, D1-DI data bits - otherwise
- *
- * \note Bits must be correctly ordered, that is for 24/18 (lowest bit first)
- * P1 P2 D1 P3 D2 D3 D4 P4 D5 D6 D7 D8 D9 DA DB P5 DC DD DE DF DG DH DI P6
- */
-static int corrHamm24(unsigned char *data){
- unsigned char syndrom=0;
- int cw=data[0] | (data[1]<<8) | (data[2]<<16);
- int i;
-
- for(i=0;i<23;i++)
- syndrom^=((cw>>i)&1)*(i+33);
-
- syndrom^=(cw>>11)&32;
-
- if(syndrom&31){
- if(syndrom < 32 || syndrom > 55)
- return -1;
- cw ^= 1<<((syndrom&31)-1);
- }
-
- return (cw&4)>>2 |
- (cw&0x70)>>3 |
- (cw&0x3f00)>>4 |
- (cw&0x3f0000)>>5;
-}
-
-/**
- * \brief converts language bits to charset index
- * \param lang language bits
- * \return charset index in lang_chars array
- */
-static int lang2charset (int lang){
- int i;
- for(i=0;tt_languages[i].lang_code;i++)
- if(tt_languages[i].lang_code==lang)
- break;
-
- return tt_languages[i].charset;
-}
-
-/**
- * \brief convert chars from curent teletext codepage into MPlayer charset
- * \param p raw teletext char to decode
- * \param charset index on lang_chars
- * \param lang index in substitution array (latin charset only)
- * \return UTF8 char
- *
- * \remarks
- * routine will analyze raw member of given tt_char structure and
- * fill unicode member of the same struct with appropriate utf8 code.
- */
-static unsigned int conv2uni(unsigned int p,int charset,int lang)
-{
-
- if(p<0x80 && p>=0x20){
- if(charset==LATIN){
- lang&=7;
- if (p>=0x23 && p<=0x24){
- return latin_subchars[lang][p-0x23];
- }else if (p==0x40){
- return latin_subchars[lang][2];
- }else if (p>=0x5b && p<=0x60){
- return latin_subchars[lang][p-0x5b+3];
- }else if (p>=0x7b && p<=0x7e){
- return latin_subchars[lang][p-0x7b+9];
- }
- }
- return lang_chars[charset][p-0x20];
- }else
- return 0x20;
-}
-
-static void init_vbi_consts(priv_vbi_t* priv){
- int i,j;
- double ang;
- for(i=0; i<256; i++){
- j=i&0x7F;
- j^= j+j;
- j^= j<<2;
- j^= j<<4;
- fixParity[i]= i ^ (j&0x80) ^ 0x80;
- }
-
- for(i=0,ang=0; i<12; i++,ang+=M_PI/priv->bpb){
- si[i]= sin(ang);
- co[i]= cos(ang);
- }
-
- priv->bpb=(priv->ptsp->sampling_rate/6937500.0)*ONE_FIXP+0.5;
- priv->soc=FFMAX(9.2e-6*priv->ptsp->sampling_rate-priv->ptsp->offset, 0);
- priv->eoc=FFMIN(12.9e-6*priv->ptsp->sampling_rate-priv->ptsp->offset,
- priv->ptsp->samples_per_line-43*8*priv->bpb/ONE_FIXP);
- if (priv->eoc - priv->soc<16*priv->bpb/ONE_FIXP){ // invalid [soc:eoc]
- priv->soc=0;
- priv->eoc=92;
- }
- priv->bp8bl=0.97*8*priv->bpb/ONE_FIXP; // -3% tolerance
- priv->bp8bh=1.03*8*priv->bpb/ONE_FIXP; // +3% tolerance
-}
-/**
- * \brief calculate increased/decreased by given value page number
- * \param curr current page number in hexadecimal for
- * \param direction decimal value (can be negative) to add to value
- * of curr parameter
- * \return new page number in hexadecimal form
- *
- * VBI page numbers are represented in special hexadecimal form, e.g.
- * page with number 123 (as seen by user) internally has number 0x123.
- * and equation 0x123+8 should be equal to 0x131 instead of regular 0x12b.
- *
- *
- * Page numbers 0xYYY (where Y is not belongs to (0..9).
- * Page number belongs to [0x000,0x799] or [0x100:0x899] (first 0 can be
- * treated as '8')
- */
-static int steppage(int p, int direction, int skip_hidden)
-{
- if(skip_hidden)
- p=(p&15)+((p>>4)&15)*10+(p>>8)*100;
- p+=direction;
- if(skip_hidden){
- p=(p+800)%800;
- p=(p%10)+((p/10)%10)*16+(p/100)*256;
- }
-
- return p&0x7ff;
-}
-
-/*
-------------------------------------------------------------------
- Cache stuff
-------------------------------------------------------------------
-*/
-
-/**
- * \brief add/update entry in cache
- * \param priv private data structure
- * \param pg page to store in cache
- * \param line line to update (value below 0 means update entire page)
- */
-static void put_to_cache(priv_vbi_t* priv,tt_page* pg,int line){
- tt_page* pgc; //page in cache
- int i,j,count;
-
- if(line<0){
- i=0;
- count=VBI_ROWS*VBI_COLUMNS;
- }else if(line<VBI_ROWS){
- i=line*VBI_COLUMNS;
- count=(line+1)*VBI_COLUMNS;
- }else
- return;
-
- pthread_mutex_lock(&(priv->buffer_mutex));
-
- if(!priv->ptt_cache[pg->pagenum]){
- priv->ptt_cache[pg->pagenum]=calloc(1,sizeof(tt_page));
- pgc=priv->ptt_cache[pg->pagenum];
- }else{
- pgc=priv->ptt_cache[pg->pagenum];
- while(pgc->next_subpage && pgc->subpagenum!=pg->subpagenum)
- pgc=pgc->next_subpage;
-
- if(pgc->subpagenum!=pg->subpagenum){
- pgc->next_subpage=calloc(1,sizeof(tt_page));
- pgc=pgc->next_subpage;
- }
- }
- pgc->pagenum=pg->pagenum;
- pgc->subpagenum=pg->subpagenum;
- pgc->primary_lang=pg->primary_lang;
- pgc->secondary_lang=pg->secondary_lang;
- pgc->flags=pg->flags;
- for(j=0;j<6;++j)
- pgc->links[j]=pg->links[j];
- //instead of copying entire page into cache, copy only undamaged
- //symbols into cache
- for(;i<count;i++){
- if(!(pg->raw[i]&0x80))
- pgc->raw[i]=pg->raw[i];
- else
- mp_msg(MSGT_TV,MSGL_DBG3,"char error. pg:%x, c[%d]=0x%x\n",
- pg->pagenum,i,pg->raw[i]);
- }
- pgc->active=1;
- pthread_mutex_unlock(&(priv->buffer_mutex));
-}
-
-/**
- * \brief get any subpage number of given page
- * \param priv private data structure
- * \param pagenum page number to search subpages in
- *
- * \return subpage number of first found subpage which belongs to
- * given page number
- *
- * \note page itself is subpage too (and usually has subpage number 0)
- */
-static inline int get_subpagenum_from_cache(priv_vbi_t* priv, int pagenum){
- if (!priv->ptt_cache[pagenum])
- return 0x3f7f;
- else
- return priv->ptt_cache[pagenum]->subpagenum;
-}
-
-/**
- * \brief get page from cache by it page and subpage number
- * \param priv private data structure
- * \param pagenum page number
- * \param subpagenum subpage number
- *
- * \return pointer to tt_page structure if requested page is found
- * and NULL otherwise
- */
-static inline tt_page* get_from_cache(priv_vbi_t* priv, int pagenum,int subpagenum){
- tt_page* tp=priv->ptt_cache[pagenum];
-
- while(tp && tp->subpagenum!=subpagenum)
- tp=tp->next_subpage;
- return tp;
-}
-
-/**
- * \brief clears cache
- * \param priv private data structure
- *
- * Deletes all tt_page structures from cache and frees allocated memory.
- * Only zero-filled array of pointers remains in memory
- */
-static void clear_cache(priv_vbi_t* priv){
- int i;
- tt_page* tp;
-
- /*
- Skip next 5 buffers to avoid mixing teletext pages from different
- channels during channel switch
- */
- priv->cache_reset=5;
- for(i=0;i<VBI_MAX_PAGES;i++){
- while(priv->ptt_cache[i]){
- tp=priv->ptt_cache[i];
- priv->ptt_cache[i]=tp->next_subpage;
- free(tp);
- }
- }
- priv->initialsubpage=priv->networkid=0;
- priv->timeoffset=0;
- priv->juliandate=priv->universaltime=0;
- memset(priv->networkname,0,21);
-}
-
-/**
- * \brief cache initialization
- * \param priv private data structure
- *
- * \note Has to be called before any cache operations!
- */
-static void init_cache(priv_vbi_t* priv){
- priv->ptt_cache=calloc(VBI_MAX_PAGES,sizeof(tt_page*));
-}
-
-/**
- * \brief destroys cache
- * \param priv private data structure
- *
- * Frees all memory allocated for cache (including array of pointers).
- * It is safe to call this routine multiple times
- */
-static void destroy_cache(priv_vbi_t* priv){
- if(priv->ptt_cache){
- clear_cache(priv);
- free(priv->ptt_cache);
- priv->ptt_cache=NULL;
- }
-}
-
-/*
-------------------------------------------------------------------
- Decoder stuff
-------------------------------------------------------------------
-*/
-/**
- * \brief converts raw teletext page into useful format (1st rendering stage)
- * \param pg page to decode
- * \param raw raw data to decode page from
- * \param primary_lang primary language code
- * \param secondary_lang secondary language code
-*
- * Routine fills tt_char structure of each teletext_page character with proper
- * info about foreground and background colors, character
- * type (graphics/control/text).
- */
-static void decode_page(tt_char* p,unsigned char* raw,int primary_lang,int secondary_lang,int flags)
-{
- int row,col;
- int prim_charset=lang2charset(primary_lang);
- int sec_charset=lang2charset(secondary_lang);
-
- for(row=0;row<VBI_ROWS;row++) {
- int prim_lang=1;
- int gfx=0;
- int fg_color=7;
- int bg_color=0;
- int separated=0;
- int conceal=0;
- int hold=0;
- int flash=0;
- int box=0;
-
- tt_char tt_held=tt_space;
- for(col=0;col<VBI_COLUMNS;col++){
- int i=row*VBI_COLUMNS+col;
- int c=raw[i];
- p[i].raw=c;
- if(c&0x80){ //damaged char
- p[i]=tt_error;
- continue;
- }
- if((flags&TT_PGFL_SUBTITLE) || (flags&TT_PGFL_NEWFLASH))
- p[i].hidden=!box;
- else
- p[i].hidden=0;
- p[i].gfx=gfx?(separated?2:1):0;
- p[i].lng=prim_lang;
- p[i].ctl=(c&0x60)==0?1:0;
- p[i].fg=fg_color;
- p[i].bg=bg_color;
- p[i].flh=flash;
-
- if ((c&0x60)==0){ //control chars
- if(c>=0x08 && c<=0x09){//Flash/Steady
- flash=c==0x08;
- p[i].flh=flash;
- if(c==0x09){
- p[i].fg=fg_color;
- p[i].bg=bg_color;
- }
- }else if(c>=0x0a && c<=0x0b){
- box=c&1;
- }else if(c>=0x0c && c<=0x0f){
- }else if (c<=0x17){ //colors
- fg_color=c&0x0f;
- gfx=c>>4;
- conceal=0;
- if(!gfx) hold=0;
- }else if (c<=0x18){
- conceal=1;
- }else if (c<=0x1a){ //Contiguous/Separated gfx
- separated=!(c&1);
- }else if (c<=0x1b){
- prim_lang=!prim_lang;
- }else if (c<=0x1d){
- bg_color=(c&1)?fg_color:0;
- p[i].bg=bg_color;
- }else{ //Hold/Release Graphics
- hold=!(c&1);
- }
- p[i].ctl=1;
- if(hold || c==0x1f){
- p[i]=tt_held;
- p[i].fg=fg_color;
- p[i].bg=bg_color;
- }else
- p[i].unicode=p[i].gfx?0:' ';
- continue;
- }
-
- if(conceal){
- p[i].gfx=0;
- p[i].unicode=' ';
- }else if(gfx){
- p[i].unicode=c-0x20;
- if (p[i].unicode>0x3f) p[i].unicode-=0x20;
- tt_held=p[i];
- }else{
- if(p[i].lng){
- p[i].unicode=conv2uni(c,prim_charset,primary_lang&7);
- }else{
- p[i].unicode=conv2uni(c,sec_charset,secondary_lang&7);
- }
- }
- p[i].fg=fg_color;
- p[i].bg=bg_color;
- }
- }
-}
-
-/**
- * \brief prepares current page for displaying
- * \param priv_vbi private data structure
- *
- * Routine adds some useful info (time and page number of page, grabbed by
- * background thread to top line of current page). Displays "No teletext"
- * string if no vbi data available.
- */
-#define PRINT_HEX(dp,i,h) dp[i].unicode=((h)&0xf)>9?'A'+((h)&0xf)-10:'0'+((h)&0xf)
-static void prepare_visible_page(priv_vbi_t* priv){
- tt_page *pg,*curr_pg;
- unsigned char *p;
- int i;
-
- pthread_mutex_lock(&(priv->buffer_mutex));
- mp_msg(MSGT_TV,MSGL_DBG3,"tvi_vbi: prepare_visible_page pg:0x%x, sub:0x%x\n",
- priv->pagenum,priv->subpagenum);
- if(priv->subpagenum==0x3f7f) //no page yet
- priv->subpagenum=get_subpagenum_from_cache(priv,priv->pagenum);
-
- pg=get_from_cache(priv,priv->pagenum,priv->subpagenum);
- mp_dbg(MSGT_TV,MSGL_DBG3,"tvi_vbi: prepare_vibible_page2 pg:0x%x, sub:0x%x\n",
- priv->pagenum,priv->subpagenum);
-
- curr_pg=get_from_cache(priv,priv->curr_pagenum,
- get_subpagenum_from_cache(priv,priv->curr_pagenum));
- if (!pg && !curr_pg){
- p=_("No teletext");
- for(i=0;i<VBI_COLUMNS && *p;i++){
- GET_UTF8(priv->display_page[i].unicode,*p++,break;);
- }
- for(;i<VBI_ROWS*VBI_COLUMNS;i++)
- priv->display_page[i]=tt_space;
- pthread_mutex_unlock(&(priv->buffer_mutex));
- return;
- }
-
- if (!pg || !pg->active){
- for(i=0;i<VBI_ROWS*VBI_COLUMNS;i++){
- priv->display_page[i]=tt_space;
- }
- }else{
- decode_page(priv->display_page,pg->raw,pg->primary_lang,pg->secondary_lang,pg->flags);
- mp_msg(MSGT_TV,MSGL_DBG3,"page #%x was decoded!\n",pg->pagenum);
- }
-
- PRINT_HEX(priv->display_page,0,(priv->curr_pagenum&0x700)?priv->curr_pagenum>>8:8);
- PRINT_HEX(priv->display_page,1,priv->curr_pagenum>>4);
- PRINT_HEX(priv->display_page,2,priv->curr_pagenum);
- priv->display_page[3].unicode=' ';
- priv->display_page[4].unicode=' ';
- switch(priv->pagenumdec>>12){
- case 1:
- priv->display_page[5].unicode='_';
- priv->display_page[6].unicode='_';
- PRINT_HEX(priv->display_page,7,priv->pagenumdec);
- break;
- case 2:
- priv->display_page[5].unicode='_';
- PRINT_HEX(priv->display_page,6,priv->pagenumdec>>4);
- PRINT_HEX(priv->display_page,7,priv->pagenumdec);
- break;
- default:
- PRINT_HEX(priv->display_page,5,(priv->pagenum&0x700)?priv->pagenum>>8:8);
- PRINT_HEX(priv->display_page,6,priv->pagenum>>4);
- PRINT_HEX(priv->display_page,7,priv->pagenum);
- }
- if(priv->subpagenum!=0x3f7f){
- priv->display_page[8].unicode='.';
- PRINT_HEX(priv->display_page,9,priv->subpagenum>>4);
- PRINT_HEX(priv->display_page,10,priv->subpagenum);
- }else{
- priv->display_page[8].unicode=' ';
- priv->display_page[9].unicode=' ';
- priv->display_page[10].unicode=' ';
- }
- priv->display_page[11].unicode=' ';
- for(i=VBI_COLUMNS;i>VBI_TIME_LINEPOS ||
- ((curr_pg->raw[i]&0x60) && curr_pg->raw[i]!=0x20 && i>11);
- --i)
- if(curr_pg->raw[i]&0x60)
- priv->display_page[i].unicode=curr_pg->raw[i];
- else
- priv->display_page[i].unicode=' ';
- pthread_mutex_unlock(&(priv->buffer_mutex));
-}
-/*
-------------------------------------------------------------------
- Renderer stuff
-------------------------------------------------------------------
-*/
-#ifdef DEBUG_DUMP
-/**
- * \brief renders teletext page into given file
- * \param pt page to render
- * \param f opened file descriptor
- * \param pagenum which page to render
- * \param colored use colors not implemented yet)
- *
- * Text will be UTF8 encoded
- */
-static void render2text(tt_page* pt,FILE* f,int colored){
- int i,j;
- unsigned int u;
- unsigned char buf[8];
- unsigned char tmp;
- int pos;
- tt_char dp[VBI_ROWS*VBI_COLUMNS];
- int color=0;
- int bkg=0;
- int c1,b1;
- if(!pt)
- return;
- fprintf(f,"+========================================+\n");
- fprintf(f,"| lang:%d pagenum:0x%x subpagenum:%d flags:0x%x|\n",
- pt->lang,
- pt->pagenum,
- pt->subpagenum,
- 0);
- fprintf(f,"+----------------------------------------+\n");
-
- decode_page(dp,pt->raw,pt->primary_lang,pt->secondary_lang,pt->flags);
- for(i=0;i<VBI_ROWS;i++){
- fprintf(f,"|");
- if(colored) fprintf(f,"\033[40m");
- for(j=0;j<VBI_COLUMNS;j++)
- {
- u=dp[i*VBI_COLUMNS+j].unicode;
- if(dp[i*VBI_COLUMNS+j].fg <= 7)
- c1=30+dp[i*VBI_COLUMNS+j].fg;
- else
- c1=38;
- if(dp[i*VBI_COLUMNS+j].bg <= 7)
- b1=40+dp[i*VBI_COLUMNS+j].bg;
- else
- b1=40;
- if (b1!=bkg && colored){
- fprintf(f,"\033[%dm",b1);
- bkg=b1;
- }
- if(c1!=color && colored){
- fprintf(f,"\033[%dm",c1);
- color=c1;
- }
- if(dp[i*VBI_COLUMNS+j].gfx){
- fprintf(f,"*");
- }else{
- pos=0;
- PUT_UTF8(u,tmp,if(pos<7) buf[pos++]=tmp;);
- buf[pos]='\0';
- fprintf(f,"%s",buf);
- }
- }
-
- if (colored) fprintf(f,"\033[0m");
- color=-1;bkg=-1;
- fprintf(f,"|\n");
- }
-#if 1
- //for debug
- fprintf(f,"+====================raw=================+\n");
- for(i=0;i<VBI_ROWS;i++){
- for(j=0;j<VBI_COLUMNS;j++)
- fprintf(f,"%02x ",dp[i*VBI_COLUMNS+j].raw);
- fprintf(f,"\n");
- }
- fprintf(f,"+====================lng=================+\n");
- for(i=0;i<VBI_ROWS;i++){
- for(j=0;j<VBI_COLUMNS;j++)
- fprintf(f,"%02x ",dp[i*VBI_COLUMNS+j].lng);
- fprintf(f,"\n");
- }
-#endif
- fprintf(f,"+========================================+\n");
-}
-
-/**
- * \brief dump page into pgXXX.txt file in vurrent directory
- * \param pt page to dump
- *
- * \note XXX in filename is page number
- * \note use only for debug purposes
- */
-static void dump_page(tt_page* pt)
-{
- FILE*f;
- char name[100];
- snprintf(name,99,"pg%x.txt",pt->pagenum);
- f=fopen(name,"wb");
- render2text(pt,f,1);
- fclose(f);
-}
-#endif //DEBUG_DUMP
-
-
-/**
- * \brief checks whether page is ready and copies it into cache array if so
- * \param priv private data structure
- * \param magAddr page's magazine address (0-7)
- *
- * Routine also calls decode_page to perform 1st stage of rendering
- */
-static void store_in_cache(priv_vbi_t* priv, int magAddr, int line){
- mp_msg(MSGT_TV,MSGL_DBG2,"store_in_cache(%d): pagenum:%x\n",
- priv->mag[magAddr].order,
- priv->mag[magAddr].pt->pagenum);
-
- put_to_cache(priv,priv->mag[magAddr].pt,line);
- priv->curr_pagenum=priv->mag[magAddr].pt->pagenum;
-
-#ifdef DEBUG_DUMP
- dump_page(get_from_cache(priv,
- priv->mag[magAddr].pt->pagenum,
- priv->mag[magAddr].pt->subpagenum));
-#endif
-}
-
-
-/*
-------------------------------------------------------------------
- Grabber stuff
-------------------------------------------------------------------
-*/
-#define PLL_SAMPLES 4
-#define PLL_ERROR 4
-#define PLL_ADJUST 4
-
-/**
- * \brief adjust current phase for better signal decoding
- * \param n count of bytes processed (?)
- * \param err count of error bytes (?)
- *
- * \remarks code was got from MythTV project
- */
-static void pll_add(priv_vbi_t* priv,int n,int err){
- if(priv->pll_fixed)
- return;
- if(err>PLL_ERROR*2/3)
- err=PLL_ERROR*2/3;
- priv->pll_err+=err;
- priv->pll_cnt+=n;
- if(priv->pll_cnt<PLL_SAMPLES)
- return;
- if(priv->pll_err>PLL_ERROR)
- {
- if(priv->pll_err>priv->pll_lerr)
- priv->pll_dir= -priv->pll_dir;
- priv->pll_lerr=priv->pll_err;
- priv->pll_adj+=priv->pll_dir;
- if (priv->pll_adj<-PLL_ADJUST || priv->pll_adj>PLL_ADJUST)
- {
- priv->pll_adj=0;
- priv->pll_dir=-1;
- priv->pll_lerr=0;
- }
- mp_msg(MSGT_TV,MSGL_DBG3,"vbi: pll_adj=%2d\n",priv->pll_adj);
- }
- priv->pll_cnt=0;
- priv->pll_err=0;
-}
-
-/**
- * \brief reset error correction
- * \param priv private data structure
- * \param fine_tune shift value for adjusting
- *
- * \remarks code was got from MythTV project
- */
-static void pll_reset(priv_vbi_t* priv,int fine_tune){
- priv->pll_fixed=fine_tune >= -PLL_ADJUST && fine_tune <= PLL_ADJUST;
-
- priv->pll_err=0;
- priv->pll_lerr=0;
- priv->pll_cnt=0;
- priv->pll_dir=-1;
- priv->pll_adj=0;
- if(priv->pll_fixed)
- priv->pll_adj=fine_tune;
- if(priv->pll_fixed)
- mp_msg(MSGT_TV,MSGL_DBG3,"pll_reset (fixed@%2d)\n",priv->pll_adj);
- else
- mp_msg(MSGT_TV,MSGL_DBG3,"pll_reset (auto)\n");
-
-}
-/**
- * \brief decode packet 0 (teletext page header)
- * \param priv private data structure
- * \param data raw teletext data (with not applied hamm correction yet)
- * \param magAddr teletext page's magazine address
- *
- * \remarks
- * data buffer was shifted by 6 and now contains:
- * 0..1 page number
- * 2..5 sub-code
- * 6..7 control codes
- * 8..39 display data
- *
- * only first 8 bytes protected by Hamm 8/4 code
- */
-static int decode_pkt0(priv_vbi_t* priv,unsigned char* data,int magAddr)
-{
- int d[8];
- int i,err;
-
- if (magAddr<0 || magAddr>7)
- return 0;
- for(i=0;i<8;i++){
- d[i]= corrHamm48[ data[i] ];
- if(d[i]&0x80){
- pll_add(priv,2,4);
-
- if(priv->mag[magAddr].pt)
- free(priv->mag[magAddr].pt);
- priv->mag[magAddr].pt=NULL;
- priv->mag[magAddr].order=0;
- return 0;
- }
- }
- if (!priv->mag[magAddr].pt)
- priv->mag[magAddr].pt= malloc(sizeof(tt_page));
-
- if(priv->primary_language)
- priv->mag[magAddr].pt->primary_lang=priv->primary_language;
- else
- priv->mag[magAddr].pt->primary_lang= (d[7]&7)>>1;
- priv->mag[magAddr].pt->secondary_lang=priv->secondary_language;
- priv->mag[magAddr].pt->subpagenum=(d[2]|(d[3]<<4)|(d[4]<<8)|(d[5]<<12))&0x3f7f;
- priv->mag[magAddr].pt->pagenum=(magAddr<<8) | d[0] | (d[1]<<4);
- priv->mag[magAddr].pt->flags=((d[7]&1)<<7) | ((d[3]&8)<<3) | ((d[5]&12)<<2) | d[6];
-
- memset(priv->mag[magAddr].pt->raw, 0x00, VBI_COLUMNS*VBI_ROWS);
- priv->mag[magAddr].order=0;
-
- for(i=0;i<8;i++){
- priv->mag[magAddr].pt->raw[i]=0x20;
- }
- err=0;
- for(i=8; i<VBI_COLUMNS; i++){
- data[i]= fixParity[data[i]];
- priv->mag[magAddr].pt->raw[i]=data[i];
- if(data[i]&0x80) //Error
- err++;
- pll_add(priv,1,err);
- }
-
- store_in_cache(priv,magAddr,0);
-
- return 1;
-}
-
-/**
- * \brief decode teletext 8/30 Format 1 packet
- * \param priv private data structure
- * \param data raw teletext data (with not applied hamm correction yet)
- * \param magAddr teletext page's magazine address
- *
- * \remarks
- * packet contains:
- * 0 designation code
- * 1..2 initial page
- * 3..6 initial subpage & magazine address
- * 7..8 network id
- * 9 time offset
- * 10..12 julian date
- * 13..15 universal time
- * 20..40 network name
- *
- * First 7 bytes are protected by Hamm 8/4 code.
- * Bytes 20-40 has odd parity check.
- *
- * See subcaluse 9.8.1 of specification for details
- */
-static int decode_pkt30(priv_vbi_t* priv,unsigned char* data,int magAddr)
-{
- int d[8];
- int i,err;
-
- for(i=0;i<7;i++){
- d[i]= corrHamm48[ data[i] ];
- if(d[i]&0x80){
- pll_add(priv,2,4);
- return 0;
- }
- d[i]&=0xf;
- }
-
- err=0;
- for(i=20; i<40; i++){
- data[i]= fixParity[data[i]];
- if(data[i]&0x80)//Unrecoverable error
- err++;
- pll_add(priv,1,err);
- }
- if (err) return 0;
-
- if (d[0]&0xe) //This is not 8/30 Format 1 packet
- return 1;
-
- priv->initialpage=d[1] | d[2]<<4 | (d[6]&0xc)<<7 | (d[4]&1)<<8;
- priv->initialsubpage=d[3] | d[4]<<4 | d[5]<<8 | d[6]<<12;
- priv->networkid=data[7]<<8 | data[8];
-
- priv->timeoffset=(data[9]>>1)&0xf;
- if(data[9]&0x40)
- priv->timeoffset=-priv->timeoffset;
-
- priv->juliandate=(data[10]&0xf)<<16 | data[11]<<8 | data[12];
- priv->juliandate-=0x11111;
-
- priv->universaltime=data[13]<<16 | data[14]<<8 | data[15];
- priv->universaltime-=0x111111;
-
- snprintf(priv->networkname,21,"%s",data+20);
-
- return 1;
-}
-
-/**
- * \brief decode packets 1..24 (teletext page header)
- * \param priv private data structure
- * \param data raw teletext data
- * \param magAddr teletext page's magazine address
- * \param rowAddr teletext page's row number
- *
- * \remarks
- * data buffer was shifted by 6 and now contains 40 bytes of display data:
- * this type of packet is not proptected by Hamm 8/4 code
- */
-static void decode_pkt_page(priv_vbi_t* priv,unsigned char*data,int magAddr,int rowAddr){
- int i,err;
- if (!priv->mag[magAddr].pt)
- return;
-
- priv->mag[magAddr].order=rowAddr;
-
- err=0;
- for(i=0; i<VBI_COLUMNS; i++){
- data[i]= fixParity[ data[i] ];
- priv->mag[magAddr].pt->raw[i+rowAddr*VBI_COLUMNS]=data[i];
- if( data[i]&0x80) //HammError
- err++;
- }
- pll_add(priv,1,err);
-
- store_in_cache(priv,magAddr,rowAddr);
-}
-
-/**
- * \brief decode packets 27 (teletext links)
- * \param priv private data structure
- * \param data raw teletext data
- * \param magAddr teletext page's magazine address
- */
-static int decode_pkt27(priv_vbi_t* priv,unsigned char* data,int magAddr){
- int i,hpg;
-
- if (!priv->mag[magAddr].pt)
- return 0;
- for(i=0;i<38;++i)
- if ((data[i] = corrHamm48[ data[i] ]) & 0x80){
- pll_add(priv,2,4);
- return 0;
- }
-
- /*
- Not a X/27/0 Format 1 packet or
- flag "show links on row 24" is not set.
- */
- if (data[0] || !(data[37] & 8))
- return 1;
- for(i=0;i<6;++i) {
- hpg = (magAddr<<8) ^ ((data[4+i*6]&0x8)<<5 | (data[6+i*6]&0xc)<<7);
- if (!hpg) hpg=0x800;
- priv->mag[magAddr].pt->links[i].pagenum = (data[1+i*6] & 0xf) |
- ((data[2+i*6] & 0xf) << 4) | hpg;
- priv->mag[magAddr].pt->links[i].subpagenum = ((data[3+i*6] & 0xf) |
- (data[4+i*6] & 0xf) << 4 | (data[5+i*6] & 0xf) << 8 |
- (data[6+i*6] & 0xf) << 12) & 0x3f7f;
- }
- put_to_cache(priv,priv->mag[magAddr].pt,-1);
- return 1;
-}
-
-/**
- * \brief Decode teletext X/28/0 Format 1 packet
- * \param priv private data structure
- * \param data raw teletext data
- *
- * Primary G0 charset is transmitted in bits 14-8 of Triplet 1
- * See Table 32 of specification for details.
- *
- * Secondary G0 charset is transmitted in bits 3-1 of Triplet 2 and
- * bits 18-15 of Triplet 1
- * See Table 33 of specification for details.
- *
- */
-static void decode_pkt28(priv_vbi_t* priv,unsigned char*data){
- int d;
- int t1,t2;
- d=corrHamm48[ data[0] ];
- if(d) return; //this is not X/28/0 Format 1 packet or error occured
-
- t1=corrHamm24(data+1);
- t2=corrHamm24(data+4);
- if (t1<0 || t2<0){
- pll_add(priv,1,4);
- return;
- }
-
- priv->primary_language=(t1>>7)&0x7f;
- priv->secondary_language=((t2<<4) | (t1>>14))&0x7f;
- if (priv->secondary_language==0x7f)
- //No secondary language required
- priv->secondary_language=priv->primary_language;
- else // Swapping bits 1 and 3
- priv->secondary_language=(priv->secondary_language&0x7a) |
- (priv->secondary_language&4)>>2 |
- (priv->secondary_language&1)<<2;
-
- mp_msg(MSGT_TV,MSGL_DBG2,"pkt28: language: primary=%02x secondary=0x%02x\n",
- priv->primary_language,priv->secondary_language);
-}
-
-/**
- * \brief decodes raw vbi data (signal amplitudes) into sequence of bytes
- * \param priv private data structure
- * \param buf raw vbi data (one line of frame)
- * \param data output buffer for decoded bytes (at least 45 bytes long)
- *
- * Used XawTV's algorithm. Signal phase is calculated with help of starting clock
- * run-in sequence (min/max values and bit distance values are calculated)
- */
-static int decode_raw_line_runin(priv_vbi_t* priv,unsigned char* buf,unsigned char* data){
- const int magic= 0x27; // reversed 1110010
- int dt[256],hi[6],lo[6];
- int i,x,r;
- int decoded;
- int sync;
- unsigned char min,max;
- int thr=0; //threshold
-
- //stubs
- int soc=priv->soc;
- int eoc=priv->eoc;
-
- for(i=soc;i<eoc;i++)
- dt[i]=buf[i+priv->bpb/ONE_FIXP]-buf[i]; // amplifies the edges best.
- /* set barrier */
- for (i=eoc; i<eoc+16; i+=2)
- dt[i]=100, dt[i+1]=-100;
-
- /* find 6 rising and falling edges */
- for (i=soc, x=0; x<6; ++x)
- {
- while (dt[i]<32)
- i++;
- hi[x]=i;
- while (dt[i]>-32)
- i++;
- lo[x]=i;
- }
- if (i>=eoc)
- {
- return 0; // not enough periods found
- }
- i=hi[5]-hi[1]; // length of 4 periods (8 bits)
- if (i<priv->bp8bl || i>priv->bp8bh)
- {
- mp_msg(MSGT_TV,MSGL_DBG3,"vbi: wrong freq %d (%d,%d)\n",
- i,priv->bp8bl,priv->bp8bh);
- return 0; // bad frequency
- }
- /* AGC and sync-reference */
- min=255, max=0, sync=0;
- for (i=hi[4]; i<hi[5]; ++i)
- if (buf[i]>max)
- max=buf[i], sync=i;
- for (i=lo[4]; i<lo[5]; ++i)
- if (buf[i]<min)
- min=buf[i];
- thr=(min+max)/2;
-
- buf+=sync;
- // searching for '11'
- for(i=priv->pll_adj*priv->bpb/10;i<16*priv->bpb;i+=priv->bpb)
- if(buf[FIXP2INT(i)]>thr && buf[FIXP2INT(i+priv->bpb)]>thr)
- break;
- r=0;
- for(decoded=1; decoded<= (VBI_COLUMNS+3)<<3;decoded++){
- r>>=1;
- if(buf[FIXP2INT(i)]>thr) r|=0x80;
- if(!(decoded & 0x07)){
- data[(decoded>>3) - 1]=r;
- r=0;
- }
- i+=priv->bpb;
- }
- if(data[0]!=magic)
- return 0; //magic not found
-
- //stub
- for(i=0;i<43;i++){
- data[i]=data[i+1];
- }
- mp_msg(MSGT_TV,MSGL_DBG3,"thr:%d sync:%d ",thr,sync);
-
- return 1;
-}
-
-#if 0
-//See comment in vbi_decode for a reason of commenting out this routine.
-
-/**
- * \brief decodes raw vbi data (signal amplitudes) into sequence of bytes
- * \param priv private data structure
- * \param buf raw vbi data (one line of frame)
- * \param data output buffer for decoded bytes (at least 45 bytes long)
- *
- * Used Michael Niedermayer's algorithm.
- * Signal phase is calculated using correlation between given samples data and
- * pure sine
- */
-static int decode_raw_line_sine(priv_vbi_t* priv,unsigned char* buf,unsigned char* data){
- int i,x,r,amp,xFixp;
- int avg=0;
- double sin_sum=0, cos_sum=0;
-
- for(x=0; x< FIXP2INT(10*priv->bpb); x++)
- avg+=buf[x];
-
- avg/=FIXP2INT(10*priv->bpb);
-
- for(x=0; x<12; x++){
- amp= buf[x<<1];
- sin_sum+= si[x]*(amp-avg);
- cos_sum+= co[x]*(amp-avg);
- }
- //this is always zero. Why ?
- xFixp= atan(sin_sum/cos_sum)*priv->bpb/M_PI;
-
- //Without this line the result is full of errors
- //and routine is unable to find magic sequence
- buf+=FIXP2INT(10*priv->bpb);
-
- r=0;
- for(x=FIXP2INT(xFixp);x<70;x=FIXP2INT(xFixp)){
- r=(r<<1) & 0xFFFF;
- if(buf[x]>avg) r|=1;
- xFixp+=priv->bpb;
- if(r==0xAAE4) break;
- }
-
- //this is not teletext
- if (r!=0xaae4) return 0;
-
- //Decode remaining 45-2(clock run-in)-1(framing code)=42 bytes
- for(i=1; i<=(42<<3); i++){
- r>>=1;
- x=FIXP2INT(xFixp);
- if(buf[x]> avg)
- r|=0x80;
-
- if(!(i & 0x07)){
- data[(i>>3)-1]=r;
- r=0;
- }
- xFixp+=priv->bpb;
- }
-
- return 1;
-}
-#endif
-
-/**
- * \brief decodes all vbi lines from one video frame
- * \param priv private data structure
- * \param buf buffer with raw vbi data in it
- *
- * \note buffer size have to be at least priv->ptsp->bufsize bytes
- */
-static void vbi_decode(priv_vbi_t* priv,unsigned char*buf){
- int magAddr;
- int pkt;
- unsigned char data[64];
- unsigned char* linep;
- int d0,d1;
- int i=0;
- mp_msg(MSGT_TV,MSGL_DBG3,"vbi: vbi_decode\n");
- for(linep=buf; !priv->cache_reset && linep<buf+priv->ptsp->bufsize; linep+=priv->ptsp->samples_per_line,i++){
-#if 0
- /*
- This routine is alternative implementation of raw VBI data decoding.
- Unfortunately, it detects only about 20% of incoming data,
- but Michael says that this algorithm is better, and he wants to fix it.
- */
- if(decode_raw_line_sine(priv,linep,data)<=0){
-#endif
- if(decode_raw_line_runin(priv,linep,data)<=0){
- continue; //this is not valid teletext line
- }
- d0= corrHamm48[ data[0] ];
- d1= corrHamm48[ data[1] ];
-
- if(d0&0x80 || d1&0x80){
- pll_add(priv,2,4);
- mp_msg(MSGT_TV,MSGL_V,"vbi_decode(%d):HammErr after decode_raw_line\n",i);
-
- continue; //hamError
- }
- magAddr=d0 & 0x7;
- pkt=(d0>>3)|(d1<<1);
- mp_msg(MSGT_TV,MSGL_DBG3,"vbi_decode(%d):%x %x (mag:%x, pkt:%d)\n",
- i,d0,d1,magAddr,pkt);
- if(!pkt){
- decode_pkt0(priv,data+2,magAddr); //skip MRGA
- }else if(pkt>0 && pkt<VBI_ROWS){
- if(!priv->mag[magAddr].pt) continue;
- decode_pkt_page(priv,data+2,magAddr,pkt);//skip MRGA
- }else if(pkt==27) {
- decode_pkt27(priv,data+2,magAddr);
- }else if(pkt==28){
- decode_pkt28(priv,data+2);
- }else if(pkt==30){
- decode_pkt30(priv,data+2,magAddr);
- } else {
- mp_msg(MSGT_TV,MSGL_DBG3,"unsupported packet:%d\n",pkt);
- }
- }
- if (priv->cache_reset){
- pthread_mutex_lock(&(priv->buffer_mutex));
- priv->cache_reset--;
- pthread_mutex_unlock(&(priv->buffer_mutex));
- }
-
-}
-
-/*
----------------------------------------------------------------------------------
- Public routines
----------------------------------------------------------------------------------
-*/
-
-/**
- * \brief toggles teletext page displaying format
- * \param priv_vbi private data structure
- * \param flag new format
- * \return
- * TVI_CONTROL_TRUE is success,
- * TVI_CONTROL_FALSE otherwise
- *
- * flag:
- * 0 - opaque
- * 1 - transparent
- * 2 - opaque with black foreground color (only in bw mode)
- * 3 - transparent with black foreground color (only in bw mode)
- */
-static int teletext_set_format(priv_vbi_t * priv, teletext_format flag)
-{
- flag&=3;
-
- mp_msg(MSGT_TV,MSGL_DBG3,"teletext_set_format_is called. mode:%d\n",flag);
- pthread_mutex_lock(&(priv->buffer_mutex));
-
- priv->tformat=flag;
-
- priv->pagenumdec=0;
-
- pthread_mutex_unlock(&(priv->buffer_mutex));
- return TVI_CONTROL_TRUE;
-}
-
-/**
- * \brief append just entered digit to editing page number
- * \param priv_vbi private data structure
- * \param dec decimal digit to append
- *
- * dec:
- * '0'..'9' append digit
- * '-' remove last digit (backspace emulation)
- *
- * This routine allows user to jump to arbitrary page.
- * It implements simple page number editing algorithm.
- *
- * Subsystem can be on one of two modes: normal and page number edit mode.
- * Zero value of priv->pagenumdec means normal mode
- * Non-zero value means page number edit mode and equals to packed
- * decimal number of already entered part of page number.
- *
- * How this works.
- * Let's assume that current mode is normal (pagenumdec is zero), teletext page
- * 100 are displayed as usual. topmost left corner of page contains page number.
- * Then vbi_add_dec is sequentially called (through slave
- * command of course) with 1,4,-,2,3 * values of dec parameter.
- *
- * +-----+------------+------------------+
- * | dec | pagenumdec | displayed number |
- * +-----+------------+------------------+
- * | | 0x000 | 100 |
- * +-----+------------+------------------+
- * | 1 | 0x001 | __1 |
- * +-----+------------+------------------+
- * | 4 | 0x014 | _14 |
- * +-----+------------+------------------+
- * | - | 0x001 | __1 |
- * +-----+------------+------------------+
- * | 2 | 0x012 | _12 |
- * +-----+------------+------------------+
- * | 3 | 0x123 | 123 |
- * +-----+------------+------------------+
- * | | 0x000 | 123 |
- * +-----+------------+------------------+
- *
- * pagenumdec will automatically receive zero value after third digit of page
- * number is entered and current page will be switched to another one with
- * entered page number.
- */
-static void vbi_add_dec(priv_vbi_t * priv, char *dec)
-{
- int count, shift;
- if (!dec)
- return;
- if (!priv->on)
- return;
- if ((*dec<'0' || *dec>'9') && *dec!='-')
- return;
- if (!priv->pagenumdec) //first digit cannot be '0','9' or '-'
- if(*dec=='-' || *dec=='0' || *dec=='9')
- return;
- pthread_mutex_lock(&(priv->buffer_mutex));
- count=(priv->pagenumdec>>12)&0xf;
- if (*dec=='-') {
- count--;
- if (count)
- priv->pagenumdec=((priv->pagenumdec>>4)&0xfff)|(count<<12);
- else
- priv->pagenumdec=0;
- } else {
- shift = count * 4;
- count++;
- priv->pagenumdec=
- (((priv->pagenumdec)<<4|(*dec-'0'))&0xfff)|(count<<12);
- if (count==3) {
- priv->pagenum=priv->pagenumdec&0x7ff;
- priv->subpagenum=get_subpagenum_from_cache(priv,priv->pagenum);
- priv->pagenumdec=0;
- }
- }
- pthread_mutex_unlock(&(priv->buffer_mutex));
-}
-
-
-/**
- * \brief Teletext control routine
- * \param priv_vbi private data structure
- * \param cmd command
- * \param arg command parameter (has to be not null)
- */
-int teletext_control(void* p, int cmd, void *arg)
-{
- int fine_tune=99;
- priv_vbi_t* priv=(priv_vbi_t*)p;
- tt_page* pgc;
-
- if (!priv && cmd!=TV_VBI_CONTROL_START)
- return TVI_CONTROL_FALSE;
- if (!arg && cmd!=TV_VBI_CONTROL_STOP && cmd!=TV_VBI_CONTROL_MARK_UNCHANGED)
- return TVI_CONTROL_FALSE;
-
- switch (cmd) {
- case TV_VBI_CONTROL_RESET:
- {
- int i;
- tv_param_t* tv_param=arg;
- pthread_mutex_lock(&(priv->buffer_mutex));
- priv->pagenumdec=0;
- clear_cache(priv);
- priv->pagenum=steppage(0,tv_param->tpage&0x7ff,1);
- priv->tformat=tv_param->tformat;
- priv->subpagenum=0x3f7f;
- pll_reset(priv,fine_tune);
- if(tv_param->tlang==-1){
- mp_tmsg(MSGT_TV,MSGL_INFO,"Supported Teletext languages:\n");
- for(i=0; tt_languages[i].lang_code; i++){
- mp_msg(MSGT_TV,MSGL_INFO," %3d %s\n",
- tt_languages[i].lang_code, tt_languages[i].lang_name);
- }
- mp_msg(MSGT_TV,MSGL_INFO," %3d %s\n",
- tt_languages[i].lang_code, tt_languages[i].lang_name);
- }else{
- for(i=0; tt_languages[i].lang_code; i++){
- if(tt_languages[i].lang_code==tv_param->tlang)
- break;
- }
- if (priv->primary_language!=tt_languages[i].lang_code){
- mp_tmsg(MSGT_TV,MSGL_INFO,"Selected default teletext language: %s\n",
- tt_languages[i].lang_name);
- priv->primary_language=tt_languages[i].lang_code;
- }
- }
- priv->page_changed=1;
- pthread_mutex_unlock(&(priv->buffer_mutex));
- return TVI_CONTROL_TRUE;
- }
- case TV_VBI_CONTROL_START:
- {
- int i;
- tt_stream_props* ptsp=*(tt_stream_props**)arg;
-
- if(!ptsp)
- return TVI_CONTROL_FALSE;
-
- priv=calloc(1,sizeof(priv_vbi_t));
-
- priv->ptsp=malloc(sizeof(tt_stream_props));
- memcpy(priv->ptsp,ptsp,sizeof(tt_stream_props));
- *(priv_vbi_t**)arg=priv;
-
- priv->subpagenum=0x3f7f;
- pthread_mutex_init(&priv->buffer_mutex, NULL);
- priv->pagenumdec=0;
- for(i=0;i<VBI_ROWS*VBI_COLUMNS;i++)
- priv->display_page[i]=tt_space;
-
- priv->mag=calloc(8,sizeof(mag_t));
- init_cache(priv);
- init_vbi_consts(priv);
- pll_reset(priv,fine_tune);
- priv->page_changed=1;
- return TVI_CONTROL_TRUE;
- }
- case TV_VBI_CONTROL_STOP:
- {
- if(priv->mag)
- free(priv->mag);
- if(priv->ptsp)
- free(priv->ptsp);
- destroy_cache(priv);
- priv->page_changed=1;
- free(priv);
- return TVI_CONTROL_TRUE;
- }
- case TV_VBI_CONTROL_SET_MODE:
- priv->on=(*(int*)arg%2);
- priv->page_changed=1;
- return TVI_CONTROL_TRUE;
- case TV_VBI_CONTROL_GET_MODE:
- *(int*)arg=priv->on;
- return TVI_CONTROL_TRUE;
- case TV_VBI_CONTROL_SET_FORMAT:
- priv->page_changed=1;
- return teletext_set_format(priv, *(int *) arg);
- case TV_VBI_CONTROL_GET_FORMAT:
- pthread_mutex_lock(&(priv->buffer_mutex));
- *(int*)arg=priv->tformat;
- pthread_mutex_unlock(&(priv->buffer_mutex));
- return TVI_CONTROL_TRUE;
- case TV_VBI_CONTROL_GET_HALF_PAGE:
- if(!priv->on)
- return TVI_CONTROL_FALSE;
- *(int *)arg=priv->zoom;
- return TVI_CONTROL_TRUE;
- case TV_VBI_CONTROL_SET_HALF_PAGE:
- {
- int val=*(int*)arg;
- val%=3;
- if(val<0)
- val+=3;
- pthread_mutex_lock(&(priv->buffer_mutex));
- priv->zoom=val;
- priv->page_changed=1;
- pthread_mutex_unlock(&(priv->buffer_mutex));
- return TVI_CONTROL_TRUE;
- }
- case TV_VBI_CONTROL_GO_LINK:
- {
- int val=*(int *) arg;
- if(val<1 || val>6)
- return TVI_CONTROL_FALSE;
- pthread_mutex_lock(&(priv->buffer_mutex));
- if (!(pgc = priv->ptt_cache[priv->pagenum])) {
- pthread_mutex_unlock(&(priv->buffer_mutex));
- return TVI_CONTROL_FALSE;
- }
- if (!pgc->links[val-1].pagenum || pgc->links[val-1].pagenum>0x7ff) {
- pthread_mutex_unlock(&(priv->buffer_mutex));
- return TVI_CONTROL_FALSE;
- }
- priv->pagenum=pgc->links[val-1].pagenum;
- if(pgc->links[val-1].subpagenum!=0x3f7f)
- priv->subpagenum=pgc->links[val-1].subpagenum;
- else
- priv->subpagenum=get_subpagenum_from_cache(priv,priv->pagenum);
- priv->page_changed=1;
- pthread_mutex_unlock(&(priv->buffer_mutex));
- return TVI_CONTROL_TRUE;
- }
- case TV_VBI_CONTROL_SET_PAGE:
- {
- int val=*(int *) arg;
- if(val<100 || val>0x899)
- return TVI_CONTROL_FALSE;
- pthread_mutex_lock(&(priv->buffer_mutex));
- priv->pagenum=val&0x7ff;
- priv->subpagenum=get_subpagenum_from_cache(priv,priv->pagenum);
- priv->pagenumdec=0;
- priv->page_changed=1;
- pthread_mutex_unlock(&(priv->buffer_mutex));
- return TVI_CONTROL_TRUE;
- }
- case TV_VBI_CONTROL_STEP_PAGE:
- {
- int direction=*(int *) arg;
- pthread_mutex_lock(&(priv->buffer_mutex));
- priv->pagenum=steppage(priv->pagenum, direction,1);
- priv->subpagenum=get_subpagenum_from_cache(priv,priv->pagenum);
- priv->pagenumdec=0;
- priv->page_changed=1;
- pthread_mutex_unlock(&(priv->buffer_mutex));
- return TVI_CONTROL_TRUE;
- }
- case TV_VBI_CONTROL_GET_PAGE:
- *(int*)arg=((priv->pagenum+0x700)&0x7ff)+0x100;
- return TVI_CONTROL_TRUE;
- case TV_VBI_CONTROL_SET_SUBPAGE:
- pthread_mutex_lock(&(priv->buffer_mutex));
- priv->pagenumdec=0;
- priv->subpagenum=*(int*)arg;
- if(priv->subpagenum<0)
- priv->subpagenum=0x3f7f;
- if(priv->subpagenum>=VBI_MAX_SUBPAGES)
- priv->subpagenum=VBI_MAX_SUBPAGES-1;
- priv->page_changed=1;
- pthread_mutex_unlock(&(priv->buffer_mutex));
- return TVI_CONTROL_TRUE;
- case TV_VBI_CONTROL_GET_SUBPAGE:
- *(int*)arg=priv->subpagenum;
- return TVI_CONTROL_TRUE;
- case TV_VBI_CONTROL_ADD_DEC:
- vbi_add_dec(priv, *(char **) arg);
- priv->page_changed=1;
- return TVI_CONTROL_TRUE;
- case TV_VBI_CONTROL_DECODE_PAGE:
- vbi_decode(priv,*(unsigned char**)arg);
- return TVI_CONTROL_TRUE;
- case TV_VBI_CONTROL_GET_VBIPAGE:
- if(!priv->on)
- return TVI_CONTROL_FALSE;
- prepare_visible_page(priv);
- *(void **)arg=priv->display_page;
- return TVI_CONTROL_TRUE;
- case TV_VBI_CONTROL_GET_NETWORKNAME:
- *(void **)arg=priv->networkname;
- return TVI_CONTROL_TRUE;
- case TV_VBI_CONTROL_MARK_UNCHANGED:
- priv->page_changed=0;
- priv->last_rendered=GetTimerMS();
- return TVI_CONTROL_TRUE;
- case TV_VBI_CONTROL_IS_CHANGED:
- if(GetTimerMS()-priv->last_rendered> 250) //forcing page update every 1/4 sec
- priv->page_changed=3; //mark that header update is enough
- *(int*)arg=priv->page_changed;
- return TVI_CONTROL_TRUE;
- }
- return TVI_CONTROL_UNKNOWN;
-}
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-12 01:38:08 +0000