mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-27 20:21:24 +00:00
Code Issues 1 Projects Releases Wiki Activity

tsbase: parse the mgt and add listed EIT/ETT pids to the known psi

Browse source 
This will make tsbase also parse the EITs and ETTs from ATSC streams that have
their pids reported on the MGT and post to the bus

https://bugzilla.gnome.org/show_bug.cgi?id=730435
This commit is contained in:
Thiago Santos 2014-05-16 15:39:48 -03:00 committed by Edward Hervey
parent 9eed28d353
commit 32d8022820
1 changed files with 28 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
gst/mpegtsdemux/mpegtsbase.c
View file

@ -88,6 +88,8 @@ static GstStateChangeReturn mpegts_base_change_state (GstElement * element,
GstStateChange transition); GstStateChange transition);
static gboolean mpegts_base_get_tags_from_eit (MpegTSBase * base, static gboolean mpegts_base_get_tags_from_eit (MpegTSBase * base,
GstMpegTsSection * section); GstMpegTsSection * section);
static gboolean mpegts_base_parse_atsc_mgt (MpegTSBase * base,
GstMpegTsSection * section);
static gboolean remove_each_program (gpointer key, MpegTSBaseProgram * program, static gboolean remove_each_program (gpointer key, MpegTSBaseProgram * program,
MpegTSBase * base); MpegTSBase * base);
@ -915,6 +917,9 @@ mpegts_base_handle_psi (MpegTSBase * base, GstMpegTsSection * section)
/* some tag xtraction + posting */ /* some tag xtraction + posting */
post_message = mpegts_base_get_tags_from_eit (base, section); post_message = mpegts_base_get_tags_from_eit (base, section);
break; break;
case GST_MPEGTS_SECTION_ATSC_MGT:
post_message = mpegts_base_parse_atsc_mgt (base, section);
break;
default: default:
break; break;
} }
@ -926,6 +931,29 @@ mpegts_base_handle_psi (MpegTSBase * base, GstMpegTsSection * section)
gst_mpegts_section_unref (section); gst_mpegts_section_unref (section);
} }
static gboolean
mpegts_base_parse_atsc_mgt (MpegTSBase * base, GstMpegTsSection * section)
{
const GstMpegTsAtscMGT *mgt;
gint i;
mgt = gst_mpegts_section_get_atsc_mgt (section);
if (G_UNLIKELY (mgt == NULL))
return FALSE;
for (i = 0; i < mgt->tables->len; ++i) {
GstMpegTsAtscMGTTable *table = g_ptr_array_index (mgt->tables, i);
if ((table->table_type >= GST_MPEG_TS_ATSC_MGT_TABLE_TYPE_EIT0 &&
table->table_type <= GST_MPEG_TS_ATSC_MGT_TABLE_TYPE_EIT127) ||
(table->table_type >= GST_MPEG_TS_ATSC_MGT_TABLE_TYPE_ETT0 &&
table->table_type <= GST_MPEG_TS_ATSC_MGT_TABLE_TYPE_ETT127)) {
MPEGTS_BIT_SET (base->known_psi, table->pid);
}
}
return TRUE;
}
static gboolean static gboolean
mpegts_base_get_tags_from_eit (MpegTSBase * base, GstMpegTsSection * section) mpegts_base_get_tags_from_eit (MpegTSBase * base, GstMpegTsSection * section)