summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEdward Hervey <bilboed@bilboed.com>2009-09-15 19:16:36 +0200
committerEdward Hervey <bilboed@bilboed.com>2009-09-19 12:41:34 +0200
commitfcc4f8388c6db04fbc453165c30df0f8ab7a29e0 (patch)
treeb119abec744e953ebff12da0042ee882fb926450
parentd88af539f90f6fd662b25942b6e88e6aba130421 (diff)
mpegtsparse/mpegtspacketizer: Register and use GQuark for structures.
-rw-r--r--gst/mpegdemux/mpegtspacketizer.c185
-rw-r--r--gst/mpegdemux/mpegtsparse.c52
2 files changed, 165 insertions, 72 deletions
diff --git a/gst/mpegdemux/mpegtspacketizer.c b/gst/mpegdemux/mpegtspacketizer.c
index 2cbb97551..7a3fd3f35 100644
--- a/gst/mpegdemux/mpegtspacketizer.c
+++ b/gst/mpegdemux/mpegtspacketizer.c
@@ -30,6 +30,39 @@
GST_DEBUG_CATEGORY_STATIC (mpegts_packetizer_debug);
#define GST_CAT_DEFAULT mpegts_packetizer_debug
+static GQuark QUARK_PAT;
+static GQuark QUARK_TRANSPORT_STREAM_ID;
+static GQuark QUARK_PROGRAM_NUMBER;
+static GQuark QUARK_PID;
+static GQuark QUARK_PROGRAMS;
+
+static GQuark QUARK_PMT;
+static GQuark QUARK_PCR_PID;
+static GQuark QUARK_VERSION_NUMBER;
+static GQuark QUARK_DESCRIPTORS;
+static GQuark QUARK_STREAM_TYPE;
+static GQuark QUARK_STREAMS;
+
+static GQuark QUARK_NIT;
+static GQuark QUARK_NETWORK_ID;
+static GQuark QUARK_CURRENT_NEXT_INDICATOR;
+static GQuark QUARK_ACTUAL_NETWORK;
+static GQuark QUARK_NETWORK_NAME;
+static GQuark QUARK_TRANSPORT_STREAM_ID;
+static GQuark QUARK_ORIGINAL_NETWORK_ID;
+static GQuark QUARK_TRANSPORTS;
+
+static GQuark QUARK_SDT;
+static GQuark QUARK_ACTUAL_TRANSPORT_STREAM;
+static GQuark QUARK_SERVICES;
+
+static GQuark QUARK_EIT;
+static GQuark QUARK_SERVICE_ID;
+static GQuark QUARK_PRESENT_FOLLOWING;
+static GQuark QUARK_SEGMENT_LAST_SECTION_NUMBER;
+static GQuark QUARK_LAST_TABLE_ID;
+static GQuark QUARK_EVENTS;
+
static void _init_local (void);
G_DEFINE_TYPE_EXTENDED (MpegTSPacketizer, mpegts_packetizer, G_TYPE_OBJECT, 0,
_init_local ());
@@ -365,8 +398,8 @@ mpegts_packetizer_parse_pat (MpegTSPacketizer * packetizer,
/* skip section_number and last_section_number */
data += 2;
- pat_info = gst_structure_new ("pat",
- "transport-stream-id", G_TYPE_UINT, transport_stream_id, NULL);
+ pat_info = gst_structure_id_new (QUARK_PAT,
+ QUARK_TRANSPORT_STREAM_ID, G_TYPE_UINT, transport_stream_id, NULL);
g_value_init (&entries, GST_TYPE_LIST);
/* stop at the CRC */
end = GST_BUFFER_DATA (section->buffer) + GST_BUFFER_SIZE (section->buffer);
@@ -378,10 +411,10 @@ mpegts_packetizer_parse_pat (MpegTSPacketizer * packetizer,
data += 2;
struct_name = g_strdup_printf ("program-%d", program_number);
- entry = gst_structure_new (struct_name,
- "program-number", G_TYPE_UINT, program_number,
- "pid", G_TYPE_UINT, pmt_pid, NULL);
+ entry = gst_structure_new (struct_name, NULL);
g_free (struct_name);
+ gst_structure_id_set (entry, QUARK_PROGRAM_NUMBER, G_TYPE_UINT,
+ program_number, QUARK_PID, G_TYPE_UINT, pmt_pid, NULL);
g_value_init (&value, GST_TYPE_STRUCTURE);
g_value_take_boxed (&value, entry);
@@ -389,7 +422,7 @@ mpegts_packetizer_parse_pat (MpegTSPacketizer * packetizer,
g_value_unset (&value);
}
- gst_structure_set_value (pat_info, "programs", &entries);
+ gst_structure_id_set_value (pat_info, QUARK_PROGRAMS, &entries);
g_value_unset (&entries);
if (data != end - 4) {
@@ -452,12 +485,10 @@ mpegts_packetizer_parse_pmt (MpegTSPacketizer * packetizer,
program_info_length = GST_READ_UINT16_BE (data) & 0x0FFF;
data += 2;
- struct_name = g_strdup ("pmt");
- pmt = gst_structure_new (struct_name,
- "program-number", G_TYPE_UINT, program_number,
- "pcr-pid", G_TYPE_UINT, pcr_pid,
- "version-number", G_TYPE_UINT, section->version_number, NULL);
- g_free (struct_name);
+ pmt = gst_structure_id_new (QUARK_PMT,
+ QUARK_PROGRAM_NUMBER, G_TYPE_UINT, program_number,
+ QUARK_PCR_PID, G_TYPE_UINT, pcr_pid,
+ QUARK_VERSION_NUMBER, G_TYPE_UINT, section->version_number, NULL);
if (program_info_length) {
/* check that the buffer is large enough to contain at least
@@ -475,8 +506,8 @@ mpegts_packetizer_parse_pmt (MpegTSPacketizer * packetizer,
goto error;
}
- gst_structure_set (pmt, "descriptors", G_TYPE_VALUE_ARRAY, descriptors,
- NULL);
+ gst_structure_id_set (pmt, QUARK_DESCRIPTORS, G_TYPE_VALUE_ARRAY,
+ descriptors, NULL);
g_value_array_free (descriptors);
}
@@ -500,9 +531,11 @@ mpegts_packetizer_parse_pmt (MpegTSPacketizer * packetizer,
}
struct_name = g_strdup_printf ("pid-%d", pid);
- stream_info = gst_structure_new (struct_name,
- "pid", G_TYPE_UINT, pid, "stream-type", G_TYPE_UINT, stream_type, NULL);
+ stream_info = gst_structure_new (struct_name, NULL);
g_free (struct_name);
+ gst_structure_id_set (stream_info,
+ QUARK_PID, G_TYPE_UINT, pid, QUARK_STREAM_TYPE, G_TYPE_UINT,
+ stream_type, NULL);
if (stream_info_length) {
/* check for AC3 descriptor */
@@ -563,8 +596,8 @@ mpegts_packetizer_parse_pmt (MpegTSPacketizer * packetizer,
goto error;
}
- gst_structure_set (stream_info,
- "descriptors", G_TYPE_VALUE_ARRAY, descriptors, NULL);
+ gst_structure_id_set (stream_info,
+ QUARK_DESCRIPTORS, G_TYPE_VALUE_ARRAY, descriptors, NULL);
g_value_array_free (descriptors);
}
@@ -575,7 +608,7 @@ mpegts_packetizer_parse_pmt (MpegTSPacketizer * packetizer,
g_value_unset (&stream_value);
}
- gst_structure_set_value (pmt, "streams", &programs);
+ gst_structure_id_set_value (pmt, QUARK_STREAMS, &programs);
g_value_unset (&programs);
g_assert (data == end - 4);
@@ -636,11 +669,12 @@ mpegts_packetizer_parse_nit (MpegTSPacketizer * packetizer,
descriptors_loop_length = GST_READ_UINT16_BE (data) & 0x0FFF;
data += 2;
- nit = gst_structure_new ("nit",
- "network-id", G_TYPE_UINT, network_id,
- "version-number", G_TYPE_UINT, section->version_number,
- "current-next-indicator", G_TYPE_UINT, section->current_next_indicator,
- "actual-network", G_TYPE_BOOLEAN, section->table_id == 0x40, NULL);
+ nit = gst_structure_id_new (QUARK_NIT,
+ QUARK_NETWORK_ID, G_TYPE_UINT, network_id,
+ QUARK_VERSION_NUMBER, G_TYPE_UINT, section->version_number,
+ QUARK_CURRENT_NEXT_INDICATOR, G_TYPE_UINT,
+ section->current_next_indicator, QUARK_ACTUAL_NETWORK, G_TYPE_BOOLEAN,
+ section->table_id == 0x40, NULL);
/* see if the buffer is large enough */
if (descriptors_loop_length) {
@@ -667,8 +701,8 @@ mpegts_packetizer_parse_nit (MpegTSPacketizer * packetizer,
networkname_tmp =
get_encoding_and_convert (networkname, networkname_length);
- gst_structure_set (nit, "network-name", G_TYPE_STRING, networkname_tmp,
- NULL);
+ gst_structure_id_set (nit, QUARK_NETWORK_NAME, G_TYPE_STRING,
+ networkname_tmp, NULL);
g_free (networkname_tmp);
}
gst_mpeg_descriptor_free (mpegdescriptor);
@@ -681,8 +715,8 @@ mpegts_packetizer_parse_nit (MpegTSPacketizer * packetizer,
goto error;
}
- gst_structure_set (nit, "descriptors", G_TYPE_VALUE_ARRAY, descriptors,
- NULL);
+ gst_structure_id_set (nit, QUARK_DESCRIPTORS, G_TYPE_VALUE_ARRAY,
+ descriptors, NULL);
g_value_array_free (descriptors);
}
@@ -713,10 +747,11 @@ mpegts_packetizer_parse_nit (MpegTSPacketizer * packetizer,
data += 2;
transport_name = g_strdup_printf ("transport-%d", transport_stream_id);
- transport = gst_structure_new (transport_name,
- "transport-stream-id", G_TYPE_UINT, transport_stream_id,
- "original-network-id", G_TYPE_UINT, original_network_id, NULL);
+ transport = gst_structure_new (transport_name, NULL);
g_free (transport_name);
+ gst_structure_id_set (transport,
+ QUARK_TRANSPORT_STREAM_ID, G_TYPE_UINT, transport_stream_id,
+ QUARK_ORIGINAL_NETWORK_ID, G_TYPE_UINT, original_network_id, NULL);
if (descriptors_loop_length) {
GstMPEGDescriptor *mpegdescriptor;
@@ -1183,7 +1218,7 @@ mpegts_packetizer_parse_nit (MpegTSPacketizer * packetizer,
goto error;
}
- gst_structure_set (transport, "descriptors", G_TYPE_VALUE_ARRAY,
+ gst_structure_id_set (transport, QUARK_DESCRIPTORS, G_TYPE_VALUE_ARRAY,
descriptors, NULL);
g_value_array_free (descriptors);
}
@@ -1203,7 +1238,7 @@ mpegts_packetizer_parse_nit (MpegTSPacketizer * packetizer,
goto error;
}
- gst_structure_set_value (nit, "transports", &transports);
+ gst_structure_id_set_value (nit, QUARK_TRANSPORTS, &transports);
g_value_unset (&transports);
GST_DEBUG ("NIT %" GST_PTR_FORMAT, nit);
@@ -1274,13 +1309,13 @@ mpegts_packetizer_parse_sdt (MpegTSPacketizer * packetizer,
/* skip reserved byte */
data += 1;
- sdt = gst_structure_new ("sdt",
- "transport-stream-id", G_TYPE_UINT, transport_stream_id,
- "version-number", G_TYPE_UINT, section->version_number,
- "current-next-indicator", G_TYPE_UINT, section->current_next_indicator,
- "original-network-id", G_TYPE_UINT, original_network_id,
- "actual-transport-stream", G_TYPE_BOOLEAN, section->table_id == 0x42,
- NULL);
+ sdt = gst_structure_id_new (QUARK_SDT,
+ QUARK_TRANSPORT_STREAM_ID, G_TYPE_UINT, transport_stream_id,
+ QUARK_VERSION_NUMBER, G_TYPE_UINT, section->version_number,
+ QUARK_CURRENT_NEXT_INDICATOR, G_TYPE_UINT,
+ section->current_next_indicator, QUARK_ORIGINAL_NETWORK_ID, G_TYPE_UINT,
+ original_network_id, QUARK_ACTUAL_TRANSPORT_STREAM, G_TYPE_BOOLEAN,
+ section->table_id == 0x42, NULL);
sdt_info_length = section->section_length - 8;
g_value_init (&services, GST_TYPE_LIST);
@@ -1388,7 +1423,7 @@ mpegts_packetizer_parse_sdt (MpegTSPacketizer * packetizer,
goto error;
}
- gst_structure_set (service, "descriptors", G_TYPE_VALUE_ARRAY,
+ gst_structure_id_set (service, QUARK_DESCRIPTORS, G_TYPE_VALUE_ARRAY,
descriptors, NULL);
g_value_array_free (descriptors);
@@ -1409,7 +1444,7 @@ mpegts_packetizer_parse_sdt (MpegTSPacketizer * packetizer,
goto error;
}
- gst_structure_set_value (sdt, "services", &services);
+ gst_structure_id_set_value (sdt, QUARK_SERVICES, &services);
g_value_unset (&services);
return sdt;
@@ -1484,18 +1519,19 @@ mpegts_packetizer_parse_eit (MpegTSPacketizer * packetizer,
last_table_id = *data;
data += 1;
- eit = gst_structure_new ("eit",
- "version-number", G_TYPE_UINT, section->version_number,
- "current-next-indicator", G_TYPE_UINT, section->current_next_indicator,
- "service-id", G_TYPE_UINT, service_id,
- "actual-transport-stream", G_TYPE_BOOLEAN, (section->table_id == 0x4E ||
- (section->table_id >= 0x50 && section->table_id <= 0x5F)),
- "present-following", G_TYPE_BOOLEAN, (section->table_id == 0x4E ||
- section->table_id == 0x4F),
- "transport-stream-id", G_TYPE_UINT, transport_stream_id,
- "original-network-id", G_TYPE_UINT, original_network_id,
- "segment-last-section-number", G_TYPE_UINT, segment_last_section_number,
- "last-table-id", G_TYPE_UINT, last_table_id, NULL);
+ eit = gst_structure_id_new (QUARK_EIT,
+ QUARK_VERSION_NUMBER, G_TYPE_UINT, section->version_number,
+ QUARK_CURRENT_NEXT_INDICATOR, G_TYPE_UINT,
+ section->current_next_indicator, QUARK_SERVICE_ID, G_TYPE_UINT,
+ service_id, QUARK_ACTUAL_TRANSPORT_STREAM, G_TYPE_BOOLEAN,
+ (section->table_id == 0x4E || (section->table_id >= 0x50
+ && section->table_id <= 0x5F)), QUARK_PRESENT_FOLLOWING,
+ G_TYPE_BOOLEAN, (section->table_id == 0x4E
+ || section->table_id == 0x4F), QUARK_TRANSPORT_STREAM_ID, G_TYPE_UINT,
+ transport_stream_id, QUARK_ORIGINAL_NETWORK_ID, G_TYPE_UINT,
+ original_network_id, QUARK_SEGMENT_LAST_SECTION_NUMBER, G_TYPE_UINT,
+ segment_last_section_number, QUARK_LAST_TABLE_ID, G_TYPE_UINT,
+ last_table_id, NULL);
g_value_init (&events, GST_TYPE_LIST);
while (data < end - 4) {
@@ -1850,8 +1886,8 @@ mpegts_packetizer_parse_eit (MpegTSPacketizer * packetizer,
g_value_array_free (descriptors);
goto error;
}
- gst_structure_set (event, "descriptors", G_TYPE_VALUE_ARRAY, descriptors,
- NULL);
+ gst_structure_id_set (event, QUARK_DESCRIPTORS, G_TYPE_VALUE_ARRAY,
+ descriptors, NULL);
g_value_array_free (descriptors);
}
@@ -1868,7 +1904,7 @@ mpegts_packetizer_parse_eit (MpegTSPacketizer * packetizer,
goto error;
}
- gst_structure_set_value (eit, "events", &events);
+ gst_structure_id_set_value (eit, QUARK_EVENTS, &events);
g_value_unset (&events);
GST_DEBUG ("EIT %" GST_PTR_FORMAT, eit);
@@ -2092,6 +2128,41 @@ _init_local ()
{
GST_DEBUG_CATEGORY_INIT (mpegts_packetizer_debug, "mpegtspacketizer", 0,
"MPEG transport stream parser");
+
+ QUARK_PAT = g_quark_from_string ("pat");
+ QUARK_TRANSPORT_STREAM_ID = g_quark_from_string ("transport-stream-id");
+ QUARK_PROGRAM_NUMBER = g_quark_from_string ("program-number");
+ QUARK_PID = g_quark_from_string ("pid");
+ QUARK_PROGRAMS = g_quark_from_string ("programs");
+
+ QUARK_PMT = g_quark_from_string ("pmt");
+ QUARK_PCR_PID = g_quark_from_string ("pcr-pid");
+ QUARK_VERSION_NUMBER = g_quark_from_string ("version-number");
+ QUARK_DESCRIPTORS = g_quark_from_string ("descriptors");
+ QUARK_STREAM_TYPE = g_quark_from_string ("stream-type");
+ QUARK_STREAMS = g_quark_from_string ("streams");
+
+ QUARK_NIT = g_quark_from_string ("nit");
+ QUARK_NETWORK_ID = g_quark_from_string ("network-id");
+ QUARK_CURRENT_NEXT_INDICATOR = g_quark_from_string ("current-next-indicator");
+ QUARK_ACTUAL_NETWORK = g_quark_from_string ("actual-network");
+ QUARK_NETWORK_NAME = g_quark_from_string ("network-name");
+ QUARK_TRANSPORT_STREAM_ID = g_quark_from_string ("transport-stream-id");
+ QUARK_ORIGINAL_NETWORK_ID = g_quark_from_string ("original-network-id");
+ QUARK_TRANSPORTS = g_quark_from_string ("transports");
+
+ QUARK_SDT = g_quark_from_string ("sdt");
+ QUARK_ACTUAL_TRANSPORT_STREAM =
+ g_quark_from_string ("actual-transport-stream");
+ QUARK_SERVICES = g_quark_from_string ("services");
+
+ QUARK_EIT = g_quark_from_string ("eit");
+ QUARK_SERVICE_ID = g_quark_from_string ("service-id");
+ QUARK_PRESENT_FOLLOWING = g_quark_from_string ("present-following");
+ QUARK_SEGMENT_LAST_SECTION_NUMBER =
+ g_quark_from_string ("segment-last-section-number");
+ QUARK_LAST_TABLE_ID = g_quark_from_string ("last-table-id");
+ QUARK_EVENTS = g_quark_from_string ("events");
}
/**
diff --git a/gst/mpegdemux/mpegtsparse.c b/gst/mpegdemux/mpegtsparse.c
index 698072137..8761a55d3 100644
--- a/gst/mpegdemux/mpegtsparse.c
+++ b/gst/mpegdemux/mpegtsparse.c
@@ -75,6 +75,13 @@ struct _MpegTSParsePad
GstFlowReturn flow_return;
};
+static GQuark QUARK_PROGRAMS;
+static GQuark QUARK_PROGRAM_NUMBER;
+static GQuark QUARK_PID;
+static GQuark QUARK_PCR_PID;
+static GQuark QUARK_STREAMS;
+static GQuark QUARK_STREAM_TYPE;
+
static GstElementDetails mpegts_parse_details =
GST_ELEMENT_DETAILS ("MPEG transport stream parser",
"Codec/Parser",
@@ -134,8 +141,10 @@ static gboolean mpegts_parse_sink_event (GstPad * pad, GstEvent * event);
static GstStateChangeReturn mpegts_parse_change_state (GstElement * element,
GstStateChange transition);
static gboolean mpegts_parse_src_pad_query (GstPad * pad, GstQuery * query);
+static void _extra_init (GType type);
-GST_BOILERPLATE (MpegTSParse, mpegts_parse, GstElement, GST_TYPE_ELEMENT);
+GST_BOILERPLATE_FULL (MpegTSParse, mpegts_parse, GstElement, GST_TYPE_ELEMENT,
+ _extra_init);
static const guint32 crc_tab[256] = {
0x00000000, 0x04c11db7, 0x09823b6e, 0x0d4326d9, 0x130476dc, 0x17c56b6b,
@@ -197,6 +206,17 @@ mpegts_parse_calc_crc32 (guint8 * data, guint datalen)
}
static void
+_extra_init (GType type)
+{
+ QUARK_PROGRAMS = g_quark_from_string ("programs");
+ QUARK_PROGRAM_NUMBER = g_quark_from_string ("program-number");
+ QUARK_PID = g_quark_from_string ("pid");
+ QUARK_PCR_PID = g_quark_from_string ("pcr-pid");
+ QUARK_STREAMS = g_quark_from_string ("streams");
+ QUARK_STREAM_TYPE = g_quark_from_string ("stream-type");
+}
+
+static void
mpegts_parse_base_init (gpointer klass)
{
GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
@@ -564,13 +584,13 @@ mpegts_parse_deactivate_pmt (MpegTSParse * parse, MpegTSParseProgram * program)
const GValue *value;
if (program->pmt_info) {
- streams = gst_structure_get_value (program->pmt_info, "streams");
+ streams = gst_structure_id_get_value (program->pmt_info, QUARK_STREAMS);
for (i = 0; i < gst_value_list_get_size (streams); ++i) {
value = gst_value_list_get_value (streams, i);
stream = g_value_get_boxed (value);
- gst_structure_get_uint (stream, "pid", &pid);
- gst_structure_get_uint (stream, "stream-type", &stream_type);
+ gst_structure_id_get (stream, QUARK_PID, G_TYPE_UINT, &pid,
+ QUARK_STREAM_TYPE, G_TYPE_UINT, &stream_type, NULL);
mpegts_parse_program_remove_stream (parse, program, (guint16) pid);
g_hash_table_remove (parse->pes_pids, GINT_TO_POINTER ((gint) pid));
}
@@ -900,14 +920,14 @@ mpegts_parse_apply_pat (MpegTSParse * parse, GstStructure * pat_info)
gst_structure_copy (pat_info)));
GST_OBJECT_LOCK (parse);
- programs = gst_structure_get_value (pat_info, "programs");
+ programs = gst_structure_id_get_value (pat_info, QUARK_PROGRAMS);
/* activate the new table */
for (i = 0; i < gst_value_list_get_size (programs); ++i) {
value = gst_value_list_get_value (programs, i);
program_info = g_value_get_boxed (value);
- gst_structure_get_uint (program_info, "program-number", &program_number);
- gst_structure_get_uint (program_info, "pid", &pid);
+ gst_structure_id_get (program_info, QUARK_PROGRAM_NUMBER, G_TYPE_UINT,
+ &program_number, QUARK_PID, G_TYPE_UINT, &pid, NULL);
program = mpegts_parse_get_program (parse, program_number);
if (program) {
@@ -936,13 +956,14 @@ mpegts_parse_apply_pat (MpegTSParse * parse, GstStructure * pat_info)
if (old_pat) {
/* deactivate the old table */
- programs = gst_structure_get_value (old_pat, "programs");
+ programs = gst_structure_id_get_value (old_pat, QUARK_PROGRAMS);
for (i = 0; i < gst_value_list_get_size (programs); ++i) {
value = gst_value_list_get_value (programs, i);
program_info = g_value_get_boxed (value);
- gst_structure_get_uint (program_info, "program-number", &program_number);
- gst_structure_get_uint (program_info, "pid", &pid);
+ gst_structure_id_get (program_info,
+ QUARK_PROGRAM_NUMBER, G_TYPE_UINT, &program_number,
+ QUARK_PID, G_TYPE_UINT, &pid, NULL);
program = mpegts_parse_get_program (parse, program_number);
if (program == NULL) {
@@ -990,9 +1011,10 @@ mpegts_parse_apply_pmt (MpegTSParse * parse,
const GValue *new_streams;
const GValue *value;
- gst_structure_get_uint (pmt_info, "program-number", &program_number);
- gst_structure_get_uint (pmt_info, "pcr-pid", &pcr_pid);
- new_streams = gst_structure_get_value (pmt_info, "streams");
+ gst_structure_id_get (pmt_info,
+ QUARK_PROGRAM_NUMBER, G_TYPE_UINT, &program_number,
+ QUARK_PCR_PID, G_TYPE_UINT, &pcr_pid, NULL);
+ new_streams = gst_structure_id_get_value (pmt_info, QUARK_STREAMS);
GST_OBJECT_LOCK (parse);
program = mpegts_parse_get_program (parse, program_number);
@@ -1021,8 +1043,8 @@ mpegts_parse_apply_pmt (MpegTSParse * parse,
value = gst_value_list_get_value (new_streams, i);
stream = g_value_get_boxed (value);
- gst_structure_get_uint (stream, "pid", &pid);
- gst_structure_get_uint (stream, "stream-type", &stream_type);
+ gst_structure_id_get (stream, QUARK_PID, G_TYPE_UINT, &pid,
+ QUARK_STREAM_TYPE, G_TYPE_UINT, &stream_type, NULL);
mpegts_parse_program_add_stream (parse, program,
(guint16) pid, (guint8) stream_type);
g_hash_table_insert (parse->pes_pids, GINT_TO_POINTER ((gint) pid),