X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/a262e80aef98d57cc90a397629671124f4fa08f2..0adf3ed39b6fe254154e3b4c38feea616e5aece1:/lib/dvb/teletext.cpp

diff --git a/lib/dvb/teletext.cpp b/lib/dvb/teletext.cpp
index 17020bb3..2a44f4f9 100644
--- a/lib/dvb/teletext.cpp
+++ b/lib/dvb/teletext.cpp
@@ -45,14 +45,35 @@ static inline unsigned long decode_hamming_2418(unsigned char *b)
 		((h24 & 0x7f0000) >> 5);
 }
 
+static int extractPTS(pts_t &pts, unsigned char *pkt)
+{
+	pkt += 7;
+	int flags = *pkt++;
+	
+	pkt++; // header length
+	
+	if (flags & 0x80) /* PTS present? */
+	{
+			/* damn gcc bug */
+		pts  = ((unsigned long long)(((pkt[0] >> 1) & 7))) << 30;
+		pts |=   pkt[1] << 22;
+		pts |=  (pkt[2]>>1) << 15;
+		pts |=   pkt[3] << 7;
+		pts |=  (pkt[5]>>1);
+		
+		return 0;
+	} else
+		return -1;
+}
+
 eDVBTeletextParser::eDVBTeletextParser(iDVBDemux *demux)
 {
 	setStreamID(0xBD); /* as per en 300 472 */
 	
-	setPage(0x150);
+	setPage(-1);
 	
 	if (demux->createPESReader(eApp, m_pes_reader))
-		eDebug("failed to create PES reader!");
+		eDebug("failed to create teletext subtitle PES reader!");
 	else
 		m_pes_reader->connectRead(slot(*this, &eDVBTeletextParser::processData), m_read_connection);
 }
@@ -65,6 +86,9 @@ void eDVBTeletextParser::processPESPacket(__u8 *pkt, int len)
 {
 	unsigned char *p = pkt;
 	
+	pts_t pts;
+	int have_pts = extractPTS(pts, pkt);
+	
 	p += 4; len -= 4; /* start code, already be verified by pes parser */
 	p += 2; len -= 2; /* length, better use the argument */	
 	
@@ -90,7 +114,7 @@ void eDVBTeletextParser::processPESPacket(__u8 *pkt, int len)
 		
 		if (data_unit_length != 44)
 		{
-			eDebug("illegal data unit length %d", data_unit_length);
+			/* eDebug("illegal data unit length %d", data_unit_length); */
 			break;
 		}
 		
@@ -107,7 +131,8 @@ void eDVBTeletextParser::processPESPacket(__u8 *pkt, int len)
 		
 		m_M = magazine_and_packet_address & 7;
 		m_Y = magazine_and_packet_address >> 3;
-//		eDebug("line %d, framing code: %02x, M=%02x, Y=%02x", line_offset, framing_code, M, Y);
+
+//			eDebug("line %d, framing code: %02x, M=%02x, Y=%02x", line_offset, framing_code, m_M, m_Y);
 		
 		if (m_Y == 0) /* page header */
 		{
@@ -129,15 +154,20 @@ void eDVBTeletextParser::processPESPacket(__u8 *pkt, int len)
 			m_C |= decode_hamming_84(data + 6) << 7;
 			m_C |= decode_hamming_84(data + 7) << 11;
 			
+			int serial_mode = m_C & (1<<11);
+			
 				/* page on the same magazine? end current page. */
-			if ((m_M == m_page_M) && (m_page_open))
+			if ((serial_mode || (m_M == m_page_M)) && (m_page_open))
 			{
-				handlePageEnd();
+				handlePageEnd(have_pts, pts);
 				m_page_open = 0;
 			}
 			
 			m_X = decode_hamming_84(data+1) * 0x10 + decode_hamming_84(data);
 			
+			if ((m_C & (1<<6)) && (m_X != 0xFF)) /* scan for pages with subtitle bit set */
+				m_found_subtitle_pages.insert((m_M << 8) | m_X);
+			
 				/* correct page on correct magazine? open page. */
 			if ((m_M == m_page_M) && (m_X == m_page_X))
 			{
@@ -166,19 +196,36 @@ int eDVBTeletextParser::start(int pid)
 
 void eDVBTeletextParser::handlePageStart()
 {
-	if (m_C & (1<<4)) /* erase flag set */
-		m_subtitle_page.clear();
+//	if (m_C & (1<<4)) /* erase flag set */
+
+		/* we are always erasing the page, 
+		   even when the erase flag is not set. */
+	m_subtitle_page.clear();
 }
 
 void eDVBTeletextParser::handleLine(unsigned char *data, int len)
 {
+/* // hexdump
+	for (int i=0; i<len; ++i)
+		eDebugNoNewLine("%02x ", decode_odd_parity(data + i));
+	eDebug(""); */
 	if (!m_Y) /* first line is page header, we don't need that. */
+	{
+		m_double_height = -1;
 		return;
+	}
+		
+	if (m_double_height == m_Y)
+	{
+		m_double_height = -1;
+		return;
+	}
 
-	int last_was_white = 1, color = -1;
+	int last_was_white = 1, color = 7; /* start with whitespace. start with color=white. (that's unrelated.) */
 	
 	std::string text;
 	
+//	eDebug("handle subtitle line: %d len", len);
 	for (int i=0; i<len; ++i)
 	{
 		unsigned char b = decode_odd_parity(data + i);
@@ -189,15 +236,19 @@ void eDVBTeletextParser::handleLine(unsigned char *data, int len)
 			{
 				if (b != color) /* new color is split into a new string */
 				{
-					if (color != -1)
-						addSubtitleString(color, text);
+					addSubtitleString(color, text);
 					text = "";
 					color = b;
 				}
-			}
+			} else if (b == 0xd)
+			{
+				m_double_height = m_Y + 1;
+			} else if (b != 0xa && b != 0xb) /* box */
+				eDebug("[ignore %x]", b);
 				/* ignore other attributes */
 		} else
 		{
+			//eDebugNoNewLine("%c", b);
 				/* no more than one whitespace, only printable chars */
 			if (((!last_was_white) || (b != ' ')) && (b >= 0x20))
 			{
@@ -206,12 +257,18 @@ void eDVBTeletextParser::handleLine(unsigned char *data, int len)
 			}
 		}
 	}
+	//eDebug("");
 	addSubtitleString(color, text);
 }
 
-void eDVBTeletextParser::handlePageEnd()
+void eDVBTeletextParser::handlePageEnd(int have_pts, const pts_t &pts)
 {
-	addSubtitleString(-1, ""); /* end last line */ 
+//	eDebug("handle page end");
+	addSubtitleString(-2, ""); /* end last line */ 
+	
+	m_subtitle_page.m_have_pts = have_pts;
+	m_subtitle_page.m_pts = pts;
+	m_subtitle_page.m_timeout = 90000 * 20; /* 20s */
 	sendSubtitlePage();  /* send assembled subtitle page to display */
 }
 
@@ -221,22 +278,45 @@ void eDVBTeletextParser::setPage(int page)
 	m_page_X = page & 0xFF;     /* page number */
 }
 
-void eDVBTeletextParser::addSubtitleString(int color, const std::string &string)
+void eDVBTeletextParser::connectNewPage(const Slot1<void, const eDVBTeletextSubtitlePage&> &slot, ePtr<eConnection> &connection)
+{
+	connection = new eConnection(this, m_new_subtitle_page.connect(slot));
+}
+
+void eDVBTeletextParser::addSubtitleString(int color, std::string string)
 {
-	if ((color != m_subtitle_color) && !m_subtitle_text.empty())
+//	eDebug("add subtitle string: %s, col %d", string.c_str(), color);
+
+	int force_cell = 0;
+	
+	if (string.substr(0, 2) == "- ")
+	{
+		string = string.substr(2);
+		force_cell = 1;
+	}
+
+//	eDebug("color %d, m_subtitle_color %d", color, m_subtitle_color);
+	gRGB rgbcol((color & 1) ? 255 : 128, (color & 2) ? 255 : 128, (color & 4) ? 255 : 128);
+	if ((color != m_subtitle_color || force_cell) && !m_subtitle_text.empty() && ((color == -2) || !string.empty()))
 	{
-		m_subtitle_page.m_elements.push_back(eDVBTeletextSubtitlePageElement(gRGB(0, 0xff, 0), m_subtitle_text));
+//		eDebug("add text |%s|: %d != %d || %d", m_subtitle_text.c_str(), color, m_subtitle_color, force_cell);
+		m_subtitle_page.m_elements.push_back(eDVBTeletextSubtitlePageElement(rgbcol, m_subtitle_text));
 		m_subtitle_text = "";
 	} else if (!m_subtitle_text.empty() && m_subtitle_text[m_subtitle_text.size()-1] != ' ')
 		m_subtitle_text += " ";
 	
-	m_subtitle_color = color;
-	m_subtitle_text += string;
+	if (!string.empty())
+	{
+//		eDebug("set %d as new color", color);
+		m_subtitle_color = color;
+		m_subtitle_text += string;
+	}
 }
 
 void eDVBTeletextParser::sendSubtitlePage()
 {
-	eDebug("subtitle page:");
-	for (unsigned int i = 0; i < m_subtitle_page.m_elements.size(); ++i)
-		eDebug("%s", m_subtitle_page.m_elements[i].m_text.c_str());
+//	eDebug("subtitle page:");
+	//for (unsigned int i = 0; i < m_subtitle_page.m_elements.size(); ++i)
+	//	eDebug("%s", m_subtitle_page.m_elements[i].m_text.c_str());
+	m_new_subtitle_page(m_subtitle_page);
 }