diff options
author | Edward Hervey <bilboed@bilboed.com> | 2009-09-15 19:00:30 +0200 |
---|---|---|
committer | Edward Hervey <bilboed@bilboed.com> | 2009-09-19 12:31:52 +0200 |
commit | 0daedae52f4184fa605bde8583c29fe57c228aa4 (patch) | |
tree | 1ea53221bf6793c74852684b91d64024a63eb8e6 /gst | |
parent | f367e5fbde2a4ea35e2976446474a1884be3b32c (diff) | |
download | gstreamer-plugins-bad-0daedae52f4184fa605bde8583c29fe57c228aa4.tar.gz |
gst: Remove dead mpegtsparse directory.
This was seriously confusing. Also, the code is in gst/mpegdemux/
Diffstat (limited to 'gst')
-rw-r--r-- | gst/mpegtsparse/.gitignore | 3 | ||||
-rw-r--r-- | gst/mpegtsparse/Makefile.am | 15 | ||||
-rw-r--r-- | gst/mpegtsparse/gstmpegdesc.c | 205 | ||||
-rw-r--r-- | gst/mpegtsparse/gstmpegdesc.h | 321 | ||||
-rw-r--r-- | gst/mpegtsparse/mpegtspacketizer.c | 2234 | ||||
-rw-r--r-- | gst/mpegtsparse/mpegtspacketizer.h | 135 | ||||
-rw-r--r-- | gst/mpegtsparse/mpegtsparse.c | 1292 | ||||
-rw-r--r-- | gst/mpegtsparse/mpegtsparse.h | 81 | ||||
-rw-r--r-- | gst/mpegtsparse/mpegtsparsemarshal.list | 1 |
9 files changed, 0 insertions, 4287 deletions
diff --git a/gst/mpegtsparse/.gitignore b/gst/mpegtsparse/.gitignore deleted file mode 100644 index 59744e683..000000000 --- a/gst/mpegtsparse/.gitignore +++ /dev/null @@ -1,3 +0,0 @@ -mpegtsparsemarshal.c -mpegtsparsemarshal.h - diff --git a/gst/mpegtsparse/Makefile.am b/gst/mpegtsparse/Makefile.am deleted file mode 100644 index d85c23856..000000000 --- a/gst/mpegtsparse/Makefile.am +++ /dev/null @@ -1,15 +0,0 @@ -plugin_LTLIBRARIES = libgstmpegtsparse.la - -libgstmpegtsparse_la_SOURCES = \ - mpegtsparse.c \ - mpegtspacketizer.c \ - gstmpegdesc.c - -libgstmpegtsparse_la_CFLAGS = $(GST_CFLAGS) -libgstmpegtsparse_la_LIBADD = $(GST_BASE_LIBS) $(GST_LIBS) -libgstmpegtsparse_la_LDFLAGS = $(GST_PLUGIN_LDFLAGS) - -noinst_HEADERS = \ - mpegtsparse.h \ - mpegtspacketizer.h \ - gstmpegdesc.h diff --git a/gst/mpegtsparse/gstmpegdesc.c b/gst/mpegtsparse/gstmpegdesc.c deleted file mode 100644 index 727b3e8af..000000000 --- a/gst/mpegtsparse/gstmpegdesc.c +++ /dev/null @@ -1,205 +0,0 @@ -/* - * The contents of this file are subject to the Mozilla Public License - * Version 1.1 (the "License"); you may not use this file except in - * compliance with the License. You may obtain a copy of the License at - * http://www.mozilla.org/MPL/. - * - * Software distributed under the License is distributed on an "AS IS" - * basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the - * License for the specific language governing rights and limitations - * under the License. - * - * The Original Code is Fluendo MPEG Demuxer plugin. - * - * The Initial Developer of the Original Code is Fluendo, S.L. - * Portions created by Fluendo, S.L. are Copyright (C) 2005 - * Fluendo, S.L. All Rights Reserved. - * - * Contributor(s): Wim Taymans <wim@fluendo.com> - * - * Alternatively, the contents of this file may be used under the terms of - * the GNU Lesser General Public License Version 2 or later (the "LGPL"), - * in which case the provisions of the LGPL are applicable instead - * of those above. If you wish to allow use of your version of this file only - * under the terms of the LGPL, and not to allow others to - * use your version of this file under the terms of the MPL, indicate your - * decision by deleting the provisions above and replace them with the notice - * and other provisions required by the LGPL. If you do not delete - * the provisions above, a recipient may use your version of this file under - * the terms of the MPL or the LGPL. - */ - -#include <string.h> - -#include <gst/gst.h> - -#include "gstmpegdesc.h" - -GST_DEBUG_CATEGORY (gstmpegtsdesc_debug); -#define GST_CAT_DEFAULT (gstmpegtsdesc_debug) - -void -gst_mpeg_descriptor_free (GstMPEGDescriptor * desc) -{ - g_return_if_fail (desc != NULL); - - g_free (desc); -} - -static guint -gst_mpeg_descriptor_parse_1 (guint8 * data, guint size) -{ - guint8 tag; - guint8 length; - - /* need at least 2 bytes for tag and length */ - if (size < 2) - return 0; - - tag = *data++; - length = *data++; - size -= 2; - - GST_DEBUG ("tag: 0x%02x, length: %d", tag, length); - - if (length > size) - return 0; - - return length + 2;; -} - -GstMPEGDescriptor * -gst_mpeg_descriptor_parse (guint8 * data, guint size) -{ - guint8 *current; - guint consumed, total, n_desc; - GstMPEGDescriptor *result; - - g_return_val_if_fail (data != NULL, NULL); - - current = data; - total = 0; - n_desc = 0; - - do { - consumed = gst_mpeg_descriptor_parse_1 (current, size); - - if (consumed > 0) { - current += consumed; - total += consumed; - size -= consumed; - n_desc++; - } - } - while (consumed > 0); - - GST_DEBUG ("parsed %d descriptors", n_desc); - - if (total == 0) - return NULL; - - result = g_malloc (sizeof (GstMPEGDescriptor) + total); - result->n_desc = n_desc; - result->data_length = total; - result->data = ((guint8 *) result) + sizeof (GstMPEGDescriptor); - - memcpy (result->data, data, total); - - return result; -} - -guint -gst_mpeg_descriptor_n_desc (GstMPEGDescriptor * desc) -{ - g_return_val_if_fail (desc != NULL, 0); - - return desc->n_desc; -} - -guint8 * -gst_mpeg_descriptor_find (GstMPEGDescriptor * desc, gint tag) -{ - gint length; - guint8 *current; - guint size; - - g_return_val_if_fail (desc != NULL, NULL); - - current = desc->data; - length = desc->data_length; - - while (length > 0) { - if (DESC_TAG (current) == tag) - return current; - - size = DESC_LENGTH (current) + 2; - - current += size; - length -= size; - } - return NULL; -} - -/* array needs freeing afterwards */ -GArray * -gst_mpeg_descriptor_find_all (GstMPEGDescriptor * desc, gint tag) -{ - GArray *all; - - gint length; - guint8 *current; - guint size; - - g_return_val_if_fail (desc != NULL, NULL); - all = g_array_new (TRUE, TRUE, sizeof (guint8 *)); - - current = desc->data; - length = desc->data_length; - - while (length > 0) { - if (DESC_TAG (current) == tag) - g_array_append_val (all, current); - size = DESC_LENGTH (current) + 2; - - current += size; - length -= size; - } - - return all; -} - -guint8 * -gst_mpeg_descriptor_nth (GstMPEGDescriptor * desc, guint i) -{ - gint length; - guint8 *current; - guint size; - - g_return_val_if_fail (desc != NULL, NULL); - - if (i > desc->n_desc) - return NULL; - - current = desc->data; - length = desc->data_length; - - while (length > 0) { - if (i == 0) - return current; - - size = DESC_LENGTH (current) + 2; - - current += size; - length -= size; - i--; - - } - return NULL; -} - -void -gst_mpegtsdesc_init_debug () -{ - GST_DEBUG_CATEGORY_INIT (gstmpegtsdesc_debug, "mpegtsdesc", 0, - "MPEG transport stream parser (descriptor)"); -} diff --git a/gst/mpegtsparse/gstmpegdesc.h b/gst/mpegtsparse/gstmpegdesc.h deleted file mode 100644 index 12b8377d9..000000000 --- a/gst/mpegtsparse/gstmpegdesc.h +++ /dev/null @@ -1,321 +0,0 @@ -/* - * The contents of this file are subject to the Mozilla Public License - * Version 1.1 (the "License"); you may not use this file except in - * compliance with the License. You may obtain a copy of the License at - * http://www.mozilla.org/MPL/. - * - * Software distributed under the License is distributed on an "AS IS" - * basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the - * License for the specific language governing rights and limitations - * under the License. - * - * The Original Code is Fluendo MPEG Demuxer plugin. - * - * The Initial Developer of the Original Code is Fluendo, S.L. - * Portions created by Fluendo, S.L. are Copyright (C) 2005 - * Fluendo, S.L. All Rights Reserved. - * - * Contributor(s): Wim Taymans <wim@fluendo.com> - * - * Alternatively, the contents of this file may be used under the terms of - * the GNU Lesser General Public License Version 2 or later (the "LGPL"), - * in which case the provisions of the LGPL are applicable instead - * of those above. If you wish to allow use of your version of this file only - * under the terms of the LGPL, and not to allow others to - * use your version of this file under the terms of the MPL, indicate your - * decision by deleting the provisions above and replace them with the notice - * and other provisions required by the LGPL. If you do not delete - * the provisions above, a recipient may use your version of this file under - * the terms of the MPL or the LGPL. - */ - -#ifndef __GST_MPEG_DESC_H__ -#define __GST_MPEG_DESC_H__ - -#include <glib.h> -/* - * descriptor_tag TS PS Identification - * 0 n/a n/a Reserved - * 1 n/a n/a Reserved - * 2 X X video_stream_descriptor - * 3 X X audio_stream_descriptor - * 4 X X hierarchy_descriptor - * 5 X X registration_descriptor - * 6 X X data_stream_alignment_descriptor - * 7 X X target_background_grid_descriptor - * 8 X X video_window_descriptor - * 9 X X CA_descriptor - * 10 X X ISO_639_language_descriptor - * 11 X X system_clock_descriptor - * 12 X X multiplex_buffer_utilization_descriptor - * 13 X X copyright_descriptor - * 14 X maximum bitrate descriptor - * 15 X X private data indicator descriptor - * 16 X X smoothing buffer descriptor - * 17 X STD_descriptor - * 18 X X IBP descriptor - * 19-63 n/a n/a ITU-T Rec. H.222.0 | ISO/IEC 13818-1 Reserved - * 64-255 n/a n/a User Private - */ -#define DESC_VIDEO_STREAM 2 -#define DESC_AUDIO_STREAM 3 -#define DESC_HIERARCHY 4 -#define DESC_REGISTRATION 5 -#define DESC_DATA_STREAM_ALIGNMENT 6 -#define DESC_TARGET_BACKGROUND_GRID 7 -#define DESC_VIDEO_WINDOW 8 -#define DESC_CA 9 -#define DESC_ISO_639_LANGUAGE 10 -#define DESC_SYSTEM_CLOCK 11 -#define DESC_MULTIPLEX_BUFFER_UTILISATION 12 -#define DESC_COPYRIGHT 13 -#define DESC_MAXIMUM_BITRATE 14 -#define DESC_PRIVATE_DATA_INDICATOR 15 -#define DESC_SMOOTHING_BUFFER 16 -#define DESC_STD 17 -#define DESC_IBP 18 - -#define DESC_DIRAC_TC_PRIVATE 0xAC - -/* DVB tags */ -#define DESC_DVB_NETWORK_NAME 0x40 -#define DESC_DVB_SERVICE_LIST 0x41 -#define DESC_DVB_STUFFING 0x42 -#define DESC_DVB_SATELLITE_DELIVERY_SYSTEM 0x43 -#define DESC_DVB_CABLE_DELIVERY_SYSTEM 0x44 -#define DESC_DVB_VBI_DATA 0x45 -#define DESC_DVB_VBI_TELETEXT 0x46 -#define DESC_DVB_BOUQUET_NAME 0x47 -#define DESC_DVB_SERVICE 0x48 -#define DESC_DVB_COUNTRY_AVAILABILITY 0x49 -#define DESC_DVB_LINKAGE 0x4A -#define DESC_DVB_NVOD_REFERENCE 0x4B -#define DESC_DVB_TIME_SHIFTED_SERVICE 0x4C -#define DESC_DVB_SHORT_EVENT 0x4D -#define DESC_DVB_EXTENDED_EVENT 0x4E -#define DESC_DVB_TIME_SHIFTED_EVENT 0x4F -#define DESC_DVB_COMPONENT 0x50 -#define DESC_DVB_MOSAIC 0x51 -#define DESC_DVB_STREAM_IDENTIFIER 0x52 -#define DESC_DVB_CA_IDENTIFIER 0x53 -#define DESC_DVB_CONTENT 0x54 -#define DESC_DVB_PARENTAL_RATING 0x55 -#define DESC_DVB_TELETEXT 0x56 -#define DESC_DVB_TELEPHONE 0x57 -#define DESC_DVB_LOCAL_TIME_OFFSET 0x58 -#define DESC_DVB_SUBTITLING 0x59 -#define DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM 0x5A -#define DESC_DVB_MULTILINGUAL_NETWORK_NAME 0x5B -#define DESC_DVB_MULTILINGUAL_BOUQUET_NAME 0x5C -#define DESC_DVB_MULTILINGUAL_SERVICE_NAME 0x5D -#define DESC_DVB_MULTILINGUAL_COMPONENT 0x5E -#define DESC_DVB_PRIVATE_DATA 0x5F -#define DESC_DVB_SERVICE_MOVE 0x60 -#define DESC_DVB_SHORT_SMOOTHING_BUFFER 0x61 -#define DESC_DVB_FREQUENCY_LIST 0x62 -#define DESC_DVB_PARTIAL_TRANSPORT_STREAM 0x63 -#define DESC_DVB_DATA_BROADCAST 0x64 -#define DESC_DVB_SCRAMBLING 0x65 -#define DESC_DVB_DATA_BROADCAST_ID 0x66 -#define DESC_DVB_TRANSPORT_STREAM 0x67 -#define DESC_DVB_DSNG 0x68 -#define DESC_DVB_PDC 0x69 -#define DESC_DVB_AC3 0x6A -#define DESC_DVB_ANCILLARY_DATA 0x6B -#define DESC_DVB_CELL_LIST 0x6C -#define DESC_DVB_CELL_FREQUENCY_LINK 0x6D -#define DESC_DVB_ANNOUNCEMENT_SUPPORT 0x6E -#define DESC_DVB_APPLICATION_SIGNALLING 0x6F -#define DESC_DVB_ADAPTATION_FIELD_DATA 0x70 -#define DESC_DVB_SERVICE_IDENTIFIER 0x71 -#define DESC_DVB_SERVICE_AVAILABILITY 0x72 -#define DESC_DVB_DEFAULT_AUTHORITY 0x73 -#define DESC_DVB_RELATED_CONTENT 0x74 -#define DESC_DVB_TVA_ID 0x75 -#define DESC_DVB_CONTENT_IDENTIFIER 0x76 -#define DESC_DVB_TIMESLICE_FEC_IDENTIFIER 0x77 -#define DESC_DVB_ECM_REPETITION_RATE 0x78 -#define DESC_DVB_S2_SATELLITE_DELIVERY_SYSTEM 0x79 -#define DESC_DVB_ENHANCED_AC3 0x7A -#define DESC_DVB_DTS 0x7B -#define DESC_DVB_AAC 0x7C -/* 0x7D and 0x7E are reserved for future use */ -#define DESC_DVB_EXTENSION 0x7F -/* 0x80 - 0xFE are user defined */ -#define DESC_DTG_LOGICAL_CHANNEL 0x83 /* from DTG D-Book */ -/* 0xFF is forbidden */ - -/* common for all descriptors */ -#define DESC_TAG(desc) (desc[0]) -#define DESC_LENGTH(desc) (desc[1]) - -/* video_stream_descriptor */ -#define DESC_VIDEO_STREAM_multiple_framerate_flag(desc) (((desc)[2] & 0x80) == 0x80) -#define DESC_VIDEO_STREAM_frame_rate_code(desc) (((desc)[2] & 0x38) >> 3) -#define DESC_VIDEO_STREAM_MPEG_1_only_flag(desc) (((desc)[2] & 0x04) == 0x04) -#define DESC_VIDEO_STREAM_constrained_parameter_flag(desc) (((desc)[2] & 0x02) == 0x02) -#define DESC_VIDEO_STREAM_still_picture_flag(desc) (((desc)[2] & 0x01) == 0x01) -/* if (MPEG_1_only_flag == 1) */ -#define DESC_VIDEO_STREAM_profile_and_level_indication(desc) ((desc)[3]) -#define DESC_VIDEO_STREAM_chroma_format(desc) (((desc)[4] & 0xc0) >> 6) -#define DESC_VIDEO_STREAM_frame_rate_extension_flag(desc) (((desc)[4] & 0x20) == 0x20) - -/* audio_stream_descriptor */ -#define DESC_AUDIO_STREAM_free_format_flag(desc) (((desc)[2] & 0x80) == 0x80) -#define DESC_AUDIO_STREAM_ID(desc) (((desc)[2] & 0x40) == 0x40) -#define DESC_AUDIO_STREAM_layer(desc) (((desc)[2] & 0x30) >> 4) -#define DESC_AUDIO_STREAM_variable_rate_audio_indicator(desc) (((desc)[2] & 0x08) == 0x08) - -/* hierarchy_descriptor */ -#define DESC_HIERARCHY_hierarchy_type(desc) (((desc)[2] & 0x0f)) -#define DESC_HIERARCHY_hierarchy_layer_index(desc) (((desc)[3] & 0x3f)) -#define DESC_HIERARCHY_hierarchy_embedded_layer_index(desc) (((desc)[4] & 0x3f)) -#define DESC_HIERARCHY_hierarchy_channel(desc) (((desc)[5] & 0x3f)) - -/* registration_descriptor */ -#define DESC_REGISTRATION_format_identifier(desc) (GST_READ_UINT32_BE ((desc)+2)) -#define DESC_REGISTRATION_additional_ident_info_len(desc) ((desc)[1] - 4) -#define DESC_REGISTRATION_additional_ident_info(desc) (&(desc)[6]) - -/* data_stream_alignment_descriptor */ -#define DESC_DATA_STREAM_ALIGNMENT_alignment_type(desc) ((desc)[2]) - -/* target_background_grid_descriptor */ -#define DESC_TARGET_BACKGROUND_GRID_horizontal_size(desc) (GST_READ_UINT16_BE ((desc)+2) >> 2) -#define DESC_TARGET_BACKGROUND_GRID_vertical_size(desc) ((GST_READ_UINT32_BE ((desc)+2) & 0x0003fff0) >> 4) -#define DESC_TARGET_BACKGROUND_GRID_aspect_ratio_information(desc) ((desc)[5] & 0x0f) - -/* video_window_descriptor */ -#define DESC_VIDEO_WINDOW_horizontal_offset(desc) (GST_READ_UINT16_BE ((desc)+2) >> 2) -#define DESC_VIDEO_WINDOW_vertical_offset(desc) ((GST_READ_UINT32_BE ((desc)+2) & 0x0003fff0) >> 4) -#define DESC_VIDEO_WINDOW_window_priority(desc) ((desc)[5] & 0x0f) - -/* CA_descriptor */ -#define DESC_CA_system_ID(desc) (GST_READ_UINT16_BE ((desc)+2)) -#define DESC_CA_PID(desc) (GST_READ_UINT16_BE ((desc)+2) & 0x1fff) - -/* ISO_639_language_descriptor */ -#define DESC_ISO_639_LANGUAGE_codes_n(desc) ((desc[1]) >> 2) -#define DESC_ISO_639_LANGUAGE_language_code_nth(desc,i) (&(desc[2 + (4*i)])) -#define DESC_ISO_639_LANGUAGE_audio_type_nth(desc,i) ((desc)[5 + (4*i)]) - -/* system_clock_descriptor */ -#define DESC_SYSTEM_CLOCK_external_clock_reference_indicator(desc) (((desc)[2] & 0x80) == 0x80) -#define DESC_SYSTEM_CLOCK_clock_accuracy_integer(desc) ((desc)[2] & 0x3f) -#define DESC_SYSTEM_CLOCK_clock_accuracy_exponent(desc) (((desc)[3] & 0xe0) >> 5) - -/* multiplex_buffer_utilization_descriptor */ -#define DESC_MULTIPLEX_BUFFER_UTILISATION_bound_valid_flag(desc) (((desc)[2] & 0x80) == 0x80) -#define DESC_MULTIPLEX_BUFFER_UTILISATION_LTW_offset_lower_bound(desc) (GST_READ_UINT16_BE ((desc)+2) & 0x7fff) -#define DESC_MULTIPLEX_BUFFER_UTILISATION_LTW_offset_upper_bound(desc) (GST_READ_UINT16_BE ((desc)+4) & 0x7fff) - -/* copyright_descriptor */ -#define DESC_COPYRIGHT_copyright_identifier(desc) (GST_READ_UINT32_BE ((desc)+2)) -#define DESC_COPYRIGHT_additional_copyright_info_len(desc) ((desc)[1] - 4) -#define DESC_COPYRIGHT_additional_copyright_info(desc) (&(desc)[6]) - -/* maximum_bitrate_descriptor */ -#define DESC_MAXIMUM_BITRAT_maximum_bitrate(desc) (((((guint32)desc[2]) & 0x3f) << 16) | \ - GST_READ_UINT16_BE ((desc)+3)) - -/* private_data_indicator_descriptor */ -#define DESC_PRIVATE_DATA_INDICATOR_indicator(desc) (GST_READ_UINT32_BE(&desc[2])) - -/* smoothing_buffer_descriptor */ -#define DESC_SMOOTHING_BUFFER_sb_leak_rate(desc) (((((guint32)desc[2]) & 0x3f) << 16) | \ - GST_READ_UINT16_BE ((desc)+3)) -#define DESC_SMOOTHING_BUFFER_sb_size(desc) (((((guint32)desc[5]) & 0x3f) << 16) | \ - GST_READ_UINT16_BE ((desc)+6)) -/* STD_descriptor */ -#define DESC_STD_leak_valid_flag(desc) (((desc)[2] & 0x01) == 0x01) - -/* ibp_descriptor */ -#define DESC_IBP_closed_gop_flag(desc) (((desc)[2] & 0x80) == 0x80) -#define DESC_IBP_identical_gop_flag(desc) (((desc)[2] & 0x40) == 0x40) -#define DESC_IBP_max_gop_length(desc) (GST_READ_UINT16_BE ((desc)+6) & 0x3fff) - -/* time_code descriptor */ -#define DESC_TIMECODE_video_pid(desc) (GST_READ_UINT16_BE ((desc) + 2) & 0x1fff) - -/* Stream identifier descriptor */ -#define DESC_DVB_STREAM_IDENTIFIER_component_tag(desc) (desc[2]) - -/* DVB Network Name descriptor */ -#define DESC_DVB_NETWORK_NAME_length(desc) (GST_READ_UINT8((desc)+1)) -#define DESC_DVB_NETWORK_NAME_text(desc) (desc+2) - -/* DVB Service Descriptor */ -#define DESC_DVB_SERVICE_type(desc) (desc[2]) -#define DESC_DVB_SERVICE_provider_name_length(desc) (desc[3]) -#define DESC_DVB_SERVICE_provider_name_text(desc) (desc+4) -#define DESC_DVB_SERVICE_name_length(desc) (desc[4 + DESC_DVB_SERVICE_provider_name_length(desc)]) -#define DESC_DVB_SERVICE_name_text(desc) (desc + 5 + DESC_DVB_SERVICE_provider_name_length(desc)) - -/* DVB Component Descriptor */ -#define DESC_DVB_COMPONENT_stream_content(desc) (desc[2] & 0x0F) -#define DESC_DVB_COMPONENT_type(desc) (desc[3]) -#define DESC_DVB_COMPONENT_tag(desc) (desc[4]) -#define DESC_DVB_COMPONENT_language(desc) (desc + 5) - -/* DVB Bouquet Name Descriptor */ -#define DESC_DVB_BOUQUET_NAME_text(desc) (desc + 2) - -/* DVB Short Event Descriptor */ -#define DESC_DVB_SHORT_EVENT_name_text(desc) (desc + 6) -#define DESC_DVB_SHORT_EVENT_name_length(desc) (desc[5]) -#define DESC_DVB_SHORT_EVENT_description_text(desc) (desc + 6 + DESC_DVB_SHORT_EVENT_name_length(desc) + 1) -#define DESC_DVB_SHORT_EVENT_description_length(desc) (desc[6 + DESC_DVB_SHORT_EVENT_name_length(desc)]) - -/* DVB Extended Event Descriptor */ -#define DESC_DVB_EXTENDED_EVENT_descriptor_number(desc) ((desc[2] & 0xF0) >> 4) -#define DESC_DVB_EXTENDED_EVENT_last_descriptor_number(desc) (desc[2] & 0x0F) -#define DESC_DVB_EXTENDED_EVENT_iso639_language_code(desc) (desc + 3) -#define DESC_DVB_EXTENDED_EVENT_items_length(desc) (desc[6]) -#define DESC_DVB_EXTENDED_EVENT_items(desc) (desc + 7) -#define DESC_DVB_EXTENDED_EVENT_text_length(desc) (desc[7 + DESC_DVB_EXTENDED_EVENT_items_length(desc)]) -#define DESC_DVB_EXTENDED_EVENT_text(desc) (desc + 7 + DESC_DVB_EXTENDED_EVENT_items_length(desc) + 1) - -/* DVB Satellite Delivery System Descriptor */ -#define DESC_DVB_SATELLITE_DELIVERY_SYSTEM_frequency(desc) (desc + 2) -#define DESC_DVB_SATELLITE_DELIVERY_SYSTEM_orbital_position(desc) (desc + 6) -#define DESC_DVB_SATELLITE_DELIVERY_SYSTEM_west_east_flag(desc) ((desc[8] & 0x80) == 0x80) -#define DESC_DVB_SATELLITE_DELIVERY_SYSTEM_polarization(desc) ((desc[8] & 0x60) >> 5) -#define DESC_DVB_SATELLITE_DELIVERY_SYSTEM_modulation(desc) (desc[8] & 0x1F) -#define DESC_DVB_SATELLITE_DELIVERY_SYSTEM_symbol_rate(desc) (desc + 9) -#define DESC_DVB_SATELLITE_DELIVERY_SYSTEM_fec_inner(desc) (desc[12] & 0x0F) - -/* DVB Terrestrial Delivery System Descriptor */ -#define DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_frequency(desc) (GST_READ_UINT32_BE((desc) + 2)) -#define DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_bandwidth(desc) (desc[6] & 0xE0) -#define DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_constellation(desc) (desc[7] & 0xC0) -#define DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_hierarchy(desc) (desc[7] & 0x38) -#define DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_code_rate_hp(desc) (desc[7] & 0x07) -#define DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_code_rate_lp(desc) (desc[8] & 0xE0) -#define DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_guard_interval(desc) (desc[8] & 0x18) -#define DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_transmission_mode(desc) (desc[8] & 0x06) -#define DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_other_frequency(desc) ((desc[8] & 0x01) == 0x01) - -/* DVB Cable Delivery System Descriptor */ -#define DESC_DVB_CABLE_DELIVERY_SYSTEM_frequency(desc) (desc + 2) -#define DESC_DVB_CABLE_DELIVERY_SYSTEM_fec_outer(desc) (desc[7] & 0x0F) -#define DESC_DVB_CABLE_DELIVERY_SYSTEM_modulation(desc) (desc[8]) -#define DESC_DVB_CABLE_DELIVERY_SYSTEM_symbol_rate(desc) (desc + 9) -#define DESC_DVB_CABLE_DELIVERY_SYSTEM_fec_inner(desc) (desc[12] & 0x0F) - -typedef struct { - guint n_desc; - guint8 data_length; - guint8 *data; -} GstMPEGDescriptor; - -void gst_mpegtsdesc_init_debug (); -GstMPEGDescriptor* gst_mpeg_descriptor_parse (guint8 *data, guint size); -void gst_mpeg_descriptor_free (GstMPEGDescriptor *desc); - -guint gst_mpeg_descriptor_n_desc (GstMPEGDescriptor *desc); -guint8* gst_mpeg_descriptor_find (GstMPEGDescriptor *desc, gint tag); -GArray* gst_mpeg_descriptor_find_all (GstMPEGDescriptor * desc, gint tag); - -guint8* gst_mpeg_descriptor_nth (GstMPEGDescriptor *desc, guint i); - -#endif /* __GST_MPEG_DESC_H__ */ diff --git a/gst/mpegtsparse/mpegtspacketizer.c b/gst/mpegtsparse/mpegtspacketizer.c deleted file mode 100644 index ce4a644a2..000000000 --- a/gst/mpegtsparse/mpegtspacketizer.c +++ /dev/null @@ -1,2234 +0,0 @@ -/* - * mpegtspacketizer.c - - * Copyright (C) 2007, 2008 Alessandro Decina, Zaheer Merali - * - * Authors: - * Zaheer Merali <zaheerabbas at merali dot org> - * Alessandro Decina <alessandro@nnva.org> - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Library General Public - * License as published by the Free Software Foundation; either - * version 2 of the License, or (at your option) any later version. - * - * This library 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 - * Library General Public License for more details. - * - * You should have received a copy of the GNU Library General Public - * License along with this library; if not, write to the - * Free Software Foundation, Inc., 59 Temple Place - Suite 330, - * Boston, MA 02111-1307, USA. - */ - -#include <string.h> - -#include "mpegtspacketizer.h" -#include "gstmpegdesc.h" - -GST_DEBUG_CATEGORY_STATIC (mpegts_packetizer_debug); -#define GST_CAT_DEFAULT mpegts_packetizer_debug - -G_DEFINE_TYPE (MpegTSPacketizer, mpegts_packetizer, G_TYPE_OBJECT); - -static void mpegts_packetizer_dispose (GObject * object); -static void mpegts_packetizer_finalize (GObject * object); -static gchar *convert_to_utf8 (const gchar * text, gint length, guint start, - const gchar * encoding, gboolean is_multibyte, GError ** error); -static gchar *get_encoding (const gchar * text, guint * start_text, - gboolean * is_multibyte); -static gchar *get_encoding_and_convert (const gchar * text, guint length); - -#define CONTINUITY_UNSET 255 -#define MAX_CONTINUITY 15 -#define VERSION_NUMBER_UNSET 255 -#define TABLE_ID_UNSET 0xFF - -static gint -mpegts_packetizer_stream_subtable_compare (gconstpointer a, gconstpointer b) -{ - MpegTSPacketizerStreamSubtable *asub, *bsub; - - asub = (MpegTSPacketizerStreamSubtable *) a; - bsub = (MpegTSPacketizerStreamSubtable *) b; - - if (asub->table_id == bsub->table_id && - asub->subtable_extension == bsub->subtable_extension) - return 0; - return -1; -} - -static MpegTSPacketizerStreamSubtable * -mpegts_packetizer_stream_subtable_new (guint8 table_id, - guint16 subtable_extension) -{ - MpegTSPacketizerStreamSubtable *subtable; - - subtable = g_new0 (MpegTSPacketizerStreamSubtable, 1); - subtable->version_number = VERSION_NUMBER_UNSET; - subtable->table_id = table_id; - subtable->subtable_extension = subtable_extension; - return subtable; -} - -static MpegTSPacketizerStream * -mpegts_packetizer_stream_new () -{ - MpegTSPacketizerStream *stream; - - stream = (MpegTSPacketizerStream *) g_new0 (MpegTSPacketizerStream, 1); - stream->section_adapter = gst_adapter_new (); - stream->continuity_counter = CONTINUITY_UNSET; - stream->subtables = NULL; - stream->section_table_id = TABLE_ID_UNSET; - return stream; -} - -static void -mpegts_packetizer_stream_free (MpegTSPacketizerStream * stream) -{ - gst_adapter_clear (stream->section_adapter); - g_object_unref (stream->section_adapter); - g_slist_foreach (stream->subtables, (GFunc) g_free, NULL); - g_slist_free (stream->subtables); - g_free (stream); -} - -static void -mpegts_packetizer_clear_section (MpegTSPacketizer * packetizer, - MpegTSPacketizerStream * stream) -{ - gst_adapter_clear (stream->section_adapter); - stream->continuity_counter = CONTINUITY_UNSET; - stream->section_length = 0; - stream->section_table_id = TABLE_ID_UNSET; -} - -static void -mpegts_packetizer_class_init (MpegTSPacketizerClass * klass) -{ - GObjectClass *gobject_class; - - gobject_class = G_OBJECT_CLASS (klass); - - gobject_class->dispose = mpegts_packetizer_dispose; - gobject_class->finalize = mpegts_packetizer_finalize; -} - -static void -mpegts_packetizer_init (MpegTSPacketizer * packetizer) -{ - packetizer->adapter = gst_adapter_new (); - packetizer->streams = g_hash_table_new (g_direct_hash, g_direct_equal); -} - -static void -mpegts_packetizer_dispose (GObject * object) -{ - MpegTSPacketizer *packetizer = GST_MPEGTS_PACKETIZER (object); - - if (!packetizer->disposed) { - gst_adapter_clear (packetizer->adapter); - g_object_unref (packetizer->adapter); - packetizer->disposed = TRUE; - } - - if (G_OBJECT_CLASS (mpegts_packetizer_parent_class)->dispose) - G_OBJECT_CLASS (mpegts_packetizer_parent_class)->dispose (object); -} - -static gboolean -stream_foreach_remove (gpointer key, gpointer value, gpointer data) -{ - MpegTSPacketizerStream *stream; - - stream = (MpegTSPacketizerStream *) value; - mpegts_packetizer_stream_free (stream); - - return TRUE; -} - -static void -mpegts_packetizer_finalize (GObject * object) -{ - MpegTSPacketizer *packetizer = GST_MPEGTS_PACKETIZER (object); - - g_hash_table_foreach_remove (packetizer->streams, - stream_foreach_remove, packetizer); - g_hash_table_destroy (packetizer->streams); - - if (G_OBJECT_CLASS (mpegts_packetizer_parent_class)->finalize) - G_OBJECT_CLASS (mpegts_packetizer_parent_class)->finalize (object); -} - -static gboolean -mpegts_packetizer_parse_adaptation_field_control (MpegTSPacketizer * packetizer, - MpegTSPacketizerPacket * packet) -{ - guint8 length; - - length = *packet->data; - packet->data += 1; - - if (packet->adaptation_field_control == 0x02) { - /* no payload, adaptation field of 183 bytes */ - if (length != 183) { - GST_DEBUG ("PID %d afc == 0x%x and length %d != 183", - packet->pid, packet->adaptation_field_control, length); - } - } else if (length > 182) { - GST_DEBUG ("PID %d afc == 0x%01x and length %d > 182", - packet->pid, packet->adaptation_field_control, length); - } - - /* skip the adaptation field body for now */ - if (packet->data + length > packet->data_end) { - GST_DEBUG ("PID %d afc length %d overflows the buffer current %d max %d", - packet->pid, length, packet->data - packet->data_start, - packet->data_end - packet->data_start); - return FALSE; - } - - packet->data += length; - - return TRUE; -} - -static gboolean -mpegts_packetizer_parse_packet (MpegTSPacketizer * packetizer, - MpegTSPacketizerPacket * packet) -{ - guint8 *data; - - data = GST_BUFFER_DATA (packet->buffer); - /* skip sync_byte */ - data++; - - packet->payload_unit_start_indicator = (*data >> 6) & 0x01; - packet->pid = GST_READ_UINT16_BE (data) & 0x1FFF; - data += 2; - - packet->adaptation_field_control = (*data >> 4) & 0x03; - packet->continuity_counter = *data & 0x0F; - data += 1; - - packet->data = data; - - if (packet->adaptation_field_control & 0x02) - if (!mpegts_packetizer_parse_adaptation_field_control (packetizer, packet)) - return FALSE; - - if (packet->adaptation_field_control & 0x01) - packet->payload = packet->data; - else - packet->payload = NULL; - - return TRUE; -} - -static gboolean -mpegts_packetizer_parse_section_header (MpegTSPacketizer * packetizer, - MpegTSPacketizerStream * stream, MpegTSPacketizerSection * section) -{ - guint8 tmp; - guint8 *data; - MpegTSPacketizerStreamSubtable *subtable; - GSList *subtable_list = NULL; - - section->complete = TRUE; - /* get the section buffer, pass the ownership to the caller */ - section->buffer = gst_adapter_take_buffer (stream->section_adapter, - 3 + stream->section_length); - data = GST_BUFFER_DATA (section->buffer); - - section->table_id = *data++; - if ((data[0] & 0x80) == 0) - section->subtable_extension = 0; - else - section->subtable_extension = GST_READ_UINT16_BE (data + 2); - - subtable = mpegts_packetizer_stream_subtable_new (section->table_id, - section->subtable_extension); - - subtable_list = g_slist_find_custom (stream->subtables, subtable, - mpegts_packetizer_stream_subtable_compare); - if (subtable_list) { - g_free (subtable); - subtable = (MpegTSPacketizerStreamSubtable *) (subtable_list->data); - } else { - stream->subtables = g_slist_prepend (stream->subtables, subtable); - } - - section->section_length = GST_READ_UINT16_BE (data) & 0x0FFF; - data += 2; - - /* skip to the version byte */ - data += 2; - - tmp = *data++; - section->version_number = (tmp >> 1) & 0x1F; - section->current_next_indicator = tmp & 0x01; - if (!section->current_next_indicator) - goto not_applicable; - - if (section->version_number == subtable->version_number) - goto not_applicable; - subtable->version_number = section->version_number; - stream->section_table_id = section->table_id; - - return TRUE; - -not_applicable: - GST_LOG - ("not applicable pid %d table_id %d subtable_extension %d, current_next %d version %d", - section->pid, section->table_id, section->subtable_extension, - section->current_next_indicator, section->version_number); - section->complete = FALSE; - gst_buffer_unref (section->buffer); - return TRUE; -} - -static gboolean -mpegts_packetizer_parse_descriptors (MpegTSPacketizer * packetizer, - guint8 ** buffer, guint8 * buffer_end, GValueArray * descriptors) -{ - guint8 tag, length; - guint8 *data; - GValue value = { 0 }; - GString *desc; - - data = *buffer; - - while (data < buffer_end) { - tag = *data++; - length = *data++; - - if (data + length > buffer_end) { - GST_WARNING ("invalid descriptor length %d now at %d max %d", - length, data - *buffer, buffer_end - *buffer); - goto error; - } - - /* include tag and length */ - desc = g_string_new_len ((gchar *) data - 2, length + 2); - data += length; - /* G_TYPE_GSTING is a GBoxed type and is used so properly marshalled from python */ - g_value_init (&value, G_TYPE_GSTRING); - g_value_take_boxed (&value, desc); - g_value_array_append (descriptors, &value); - g_value_unset (&value); - } - - if (data != buffer_end) { - GST_WARNING ("descriptors size %d expected %d", - data - *buffer, buffer_end - *buffer); - goto error; - } - - *buffer = data; - - return TRUE; -error: - return FALSE; -} - -GstStructure * -mpegts_packetizer_parse_pat (MpegTSPacketizer * packetizer, - MpegTSPacketizerSection * section) -{ - GstStructure *pat_info = NULL; - guint8 *data, *end; - guint transport_stream_id; - guint8 tmp; - guint program_number; - guint pmt_pid; - GValue entries = { 0 }; - GValue value = { 0 }; - GstStructure *entry = NULL; - gchar *struct_name; - - data = GST_BUFFER_DATA (section->buffer); - - section->table_id = *data++; - section->section_length = GST_READ_UINT16_BE (data) & 0x0FFF; - data += 2; - - transport_stream_id = GST_READ_UINT16_BE (data); - data += 2; - - tmp = *data++; - section->version_number = (tmp >> 1) & 0x1F; - section->current_next_indicator = tmp & 0x01; - - /* 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); - g_value_init (&entries, GST_TYPE_LIST); - /* stop at the CRC */ - end = GST_BUFFER_DATA (section->buffer) + GST_BUFFER_SIZE (section->buffer); - while (data < end - 4) { - program_number = GST_READ_UINT16_BE (data); - data += 2; - - pmt_pid = GST_READ_UINT16_BE (data) & 0x1FFF; - 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); - g_free (struct_name); - - g_value_init (&value, GST_TYPE_STRUCTURE); - g_value_take_boxed (&value, entry); - gst_value_list_append_value (&entries, &value); - g_value_unset (&value); - } - - gst_structure_set_value (pat_info, "programs", &entries); - g_value_unset (&entries); - - if (data != end - 4) { - /* FIXME: check the CRC before parsing the packet */ - GST_ERROR ("at the end of PAT data != end - 4"); - gst_structure_free (pat_info); - - return NULL; - } - - return pat_info; -} - -GstStructure * -mpegts_packetizer_parse_pmt (MpegTSPacketizer * packetizer, - MpegTSPacketizerSection * section) -{ - GstStructure *pmt = NULL; - guint8 *data, *end; - guint16 program_number; - guint8 tmp; - guint pcr_pid; - guint program_info_length; - guint8 stream_type; - guint16 pid; - guint stream_info_length; - GValueArray *descriptors; - GValue stream_value = { 0 }; - GValue programs = { 0 }; - GstStructure *stream_info = NULL; - gchar *struct_name; - - /* fixed header + CRC == 16 */ - if (GST_BUFFER_SIZE (section->buffer) < 16) { - GST_WARNING ("PID %d invalid PMT size %d", - section->pid, section->section_length); - goto error; - } - - data = GST_BUFFER_DATA (section->buffer); - end = data + GST_BUFFER_SIZE (section->buffer); - - section->table_id = *data++; - section->section_length = GST_READ_UINT16_BE (data) & 0x0FFF; - data += 2; - - program_number = GST_READ_UINT16_BE (data); - data += 2; - - tmp = *data++; - section->version_number = (tmp >> 1) & 0x1F; - section->current_next_indicator = tmp & 0x01; - - /* skip section_number and last_section_number */ - data += 2; - - pcr_pid = GST_READ_UINT16_BE (data) & 0x1FFF; - data += 2; - - 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); - - if (program_info_length) { - /* check that the buffer is large enough to contain at least - * program_info_length bytes + CRC */ - if (data + program_info_length + 4 > end) { - GST_WARNING ("PID %d invalid program info length %d " - "left %d", section->pid, program_info_length, end - data); - goto error; - } - - descriptors = g_value_array_new (0); - if (!mpegts_packetizer_parse_descriptors (packetizer, - &data, data + program_info_length, descriptors)) { - g_value_array_free (descriptors); - goto error; - } - - gst_structure_set (pmt, "descriptors", G_TYPE_VALUE_ARRAY, descriptors, - NULL); - g_value_array_free (descriptors); - } - - g_value_init (&programs, GST_TYPE_LIST); - /* parse entries, cycle until there's space for another entry (at least 5 - * bytes) plus the CRC */ - while (data <= end - 4 - 5) { - stream_type = *data++; - - pid = GST_READ_UINT16_BE (data) & 0x1FFF; - data += 2; - - stream_info_length = GST_READ_UINT16_BE (data) & 0x0FFF; - data += 2; - - if (data + stream_info_length + 4 > end) { - GST_WARNING ("PID %d invalid stream info length %d " - "left %d", section->pid, stream_info_length, end - data); - g_value_unset (&programs); - goto error; - } - - 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); - g_free (struct_name); - - if (stream_info_length) { - descriptors = g_value_array_new (0); - if (!mpegts_packetizer_parse_descriptors (packetizer, - &data, data + stream_info_length, descriptors)) { - g_value_unset (&programs); - gst_structure_free (stream_info); - g_value_array_free (descriptors); - goto error; - } - - gst_structure_set (stream_info, - "descriptors", G_TYPE_VALUE_ARRAY, descriptors, NULL); - g_value_array_free (descriptors); - } - - g_value_init (&stream_value, GST_TYPE_STRUCTURE); - g_value_take_boxed (&stream_value, stream_info); - gst_value_list_append_value (&programs, &stream_value); - g_value_unset (&stream_value); - } - - gst_structure_set_value (pmt, "streams", &programs); - g_value_unset (&programs); - - g_assert (data == end - 4); - - return pmt; - -error: - if (pmt) - gst_structure_free (pmt); - - return NULL; -} - -GstStructure * -mpegts_packetizer_parse_nit (MpegTSPacketizer * packetizer, - MpegTSPacketizerSection * section) -{ - GstStructure *nit = NULL, *transport = NULL, *delivery_structure = NULL; - guint8 *data, *end, *entry_begin; - guint16 network_id, transport_stream_id, original_network_id; - guint tmp; - guint16 descriptors_loop_length, transport_stream_loop_length; - GValue transports = { 0 }; - GValue transport_value = { 0 }; - GValueArray *descriptors = NULL; - gchar *dbg_str; - - GST_DEBUG ("NIT"); - /* fixed header + CRC == 16 */ - if (GST_BUFFER_SIZE (section->buffer) < 23) { - GST_WARNING ("PID %d invalid NIT size %d", - section->pid, section->section_length); - goto error; - } - - data = GST_BUFFER_DATA (section->buffer); - end = data + GST_BUFFER_SIZE (section->buffer); - - section->table_id = *data++; - section->section_length = GST_READ_UINT16_BE (data) & 0x0FFF; - data += 2; - - if (data + section->section_length != end) { - GST_WARNING ("PID %d invalid NIT section length %d expected %d", - section->pid, section->section_length, end - data); - goto error; - } - - network_id = GST_READ_UINT16_BE (data); - data += 2; - - tmp = *data++; - section->version_number = (tmp >> 1) & 0x1F; - section->current_next_indicator = tmp & 0x01; - - /* skip section_number and last_section_number */ - data += 2; - - 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); - - /* see if the buffer is large enough */ - if (descriptors_loop_length) { - guint8 *networkname_descriptor; - GstMPEGDescriptor *mpegdescriptor; - - if (data + descriptors_loop_length > end - 4) { - GST_WARNING ("PID %d invalid NIT descriptors loop length %d", - section->pid, descriptors_loop_length); - gst_structure_free (nit); - goto error; - } - mpegdescriptor = gst_mpeg_descriptor_parse (data, descriptors_loop_length); - networkname_descriptor = - gst_mpeg_descriptor_find (mpegdescriptor, DESC_DVB_NETWORK_NAME); - if (networkname_descriptor != NULL) { - gchar *networkname_tmp; - - /* No need to bounds check this value as it comes from the descriptor length itself */ - guint8 networkname_length = - DESC_DVB_NETWORK_NAME_length (networkname_descriptor); - gchar *networkname = - (gchar *) DESC_DVB_NETWORK_NAME_text (networkname_descriptor); - - networkname_tmp = - get_encoding_and_convert (networkname, networkname_length); - gst_structure_set (nit, "network-name", G_TYPE_STRING, networkname_tmp, - NULL); - g_free (networkname_tmp); - } - gst_mpeg_descriptor_free (mpegdescriptor); - - descriptors = g_value_array_new (0); - if (!mpegts_packetizer_parse_descriptors (packetizer, - &data, data + descriptors_loop_length, descriptors)) { - gst_structure_free (nit); - g_value_array_free (descriptors); - goto error; - } - - gst_structure_set (nit, "descriptors", G_TYPE_VALUE_ARRAY, descriptors, - NULL); - g_value_array_free (descriptors); - } - - transport_stream_loop_length = GST_READ_UINT16_BE (data) & 0x0FFF; - data += 2; - - g_value_init (&transports, GST_TYPE_LIST); - /* read up to the CRC */ - while (transport_stream_loop_length - 4 > 0) { - gchar *transport_name; - - entry_begin = data; - - if (transport_stream_loop_length < 10) { - /* each entry must be at least 6 bytes (+ 4bytes CRC) */ - GST_WARNING ("PID %d invalid NIT entry size %d", - section->pid, transport_stream_loop_length); - goto error; - } - - transport_stream_id = GST_READ_UINT16_BE (data); - data += 2; - - original_network_id = GST_READ_UINT16_BE (data); - data += 2; - - descriptors_loop_length = GST_READ_UINT16_BE (data) & 0x0FFF; - 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); - g_free (transport_name); - - if (descriptors_loop_length) { - GstMPEGDescriptor *mpegdescriptor; - guint8 *delivery; - - if (data + descriptors_loop_length > end - 4) { - GST_WARNING ("PID %d invalid NIT entry %d descriptors loop length %d", - section->pid, transport_stream_id, descriptors_loop_length); - gst_structure_free (transport); - goto error; - } - mpegdescriptor = - gst_mpeg_descriptor_parse (data, descriptors_loop_length); - - if ((delivery = - gst_mpeg_descriptor_find (mpegdescriptor, - DESC_DVB_SATELLITE_DELIVERY_SYSTEM))) { - - guint8 *frequency_bcd = - DESC_DVB_SATELLITE_DELIVERY_SYSTEM_frequency (delivery); - guint32 frequency = - 10 * ((frequency_bcd[3] & 0x0F) + - 10 * ((frequency_bcd[3] & 0xF0) >> 4) + - 100 * (frequency_bcd[2] & 0x0F) + - 1000 * ((frequency_bcd[2] & 0xF0) >> 4) + - 10000 * (frequency_bcd[1] & 0x0F) + - 100000 * ((frequency_bcd[1] & 0xF0) >> 4) + - 1000000 * (frequency_bcd[0] & 0x0F) + - 10000000 * ((frequency_bcd[0] & 0xF0) >> 4)); - guint8 *orbital_bcd = - DESC_DVB_SATELLITE_DELIVERY_SYSTEM_orbital_position (delivery); - gfloat orbital = - (orbital_bcd[1] & 0x0F) / 10. + ((orbital_bcd[1] & 0xF0) >> 4) + - 10 * (orbital_bcd[0] & 0x0F) + 100 * ((orbital_bcd[0] & 0xF0) >> 4); - gboolean east = - DESC_DVB_SATELLITE_DELIVERY_SYSTEM_west_east_flag (delivery); - guint8 polarization = - DESC_DVB_SATELLITE_DELIVERY_SYSTEM_polarization (delivery); - gchar *polarization_str; - guint8 modulation = - DESC_DVB_SATELLITE_DELIVERY_SYSTEM_modulation (delivery); - gchar *modulation_str; - guint8 *symbol_rate_bcd = - DESC_DVB_SATELLITE_DELIVERY_SYSTEM_symbol_rate (delivery); - guint32 symbol_rate = - (symbol_rate_bcd[2] & 0x0F) + - 10 * ((symbol_rate_bcd[2] & 0xF0) >> 4) + - 100 * (symbol_rate_bcd[1] & 0x0F) + - 1000 * ((symbol_rate_bcd[1] & 0xF0) >> 4) + - 10000 * (symbol_rate_bcd[0] & 0x0F) + - 100000 * ((symbol_rate_bcd[0] & 0xF0) >> 4); - guint8 fec_inner = - DESC_DVB_SATELLITE_DELIVERY_SYSTEM_fec_inner (delivery); - gchar *fec_inner_str; - - switch (polarization) { - case 0: - polarization_str = "horizontal"; - break; - case 1: - polarization_str = "vertical"; - break; - case 2: - polarization_str = "left"; - break; - case 3: - polarization_str = "right"; - break; - default: - polarization_str = ""; - } - switch (fec_inner) { - case 0: - fec_inner_str = "undefined"; - break; - case 1: - fec_inner_str = "1/2"; - break; - case 2: - fec_inner_str = "2/3"; - break; - case 3: - fec_inner_str = "3/4"; - break; - case 4: - fec_inner_str = "5/6"; - break; - case 5: - fec_inner_str = "7/8"; - break; - case 6: - fec_inner_str = "8/9"; - break; - case 0xF: - fec_inner_str = "none"; - break; - default: - fec_inner_str = "reserved"; - } - switch (modulation) { - case 0x00: - modulation_str = "undefined"; - break; - case 0x01: - modulation_str = "QAM16"; - break; - case 0x02: - modulation_str = "QAM32"; - break; - case 0x03: - modulation_str = "QAM64"; - break; - case 0x04: - modulation_str = "QAM128"; - break; - case 0x05: - modulation_str = "QAM256"; - break; - default: - modulation_str = "reserved"; - } - delivery_structure = gst_structure_new ("satellite", - "orbital", G_TYPE_FLOAT, orbital, - "east-or-west", G_TYPE_STRING, east ? "east" : "west", - "modulation", G_TYPE_STRING, modulation_str, - "frequency", G_TYPE_UINT, frequency, - "polarization", G_TYPE_STRING, polarization_str, - "symbol-rate", G_TYPE_UINT, symbol_rate, - "inner-fec", G_TYPE_STRING, fec_inner_str, NULL); - gst_structure_set (transport, "delivery", GST_TYPE_STRUCTURE, - delivery_structure, NULL); - } else if ((delivery = - gst_mpeg_descriptor_find (mpegdescriptor, - DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM))) { - - guint32 frequency = - DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_frequency (delivery) * 10; - guint8 bandwidth = - DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_bandwidth (delivery); - guint8 constellation = - DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_constellation (delivery); - guint8 hierarchy = - DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_hierarchy (delivery); - guint8 code_rate_hp = - DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_code_rate_hp (delivery); - guint8 code_rate_lp = - DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_code_rate_lp (delivery); - guint8 guard_interval = - DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_guard_interval (delivery); - guint8 transmission_mode = - DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_transmission_mode (delivery); - gboolean other_frequency = - DESC_DVB_TERRESTRIAL_DELIVERY_SYSTEM_other_frequency (delivery); - gchar *constellation_str, *code_rate_hp_str, *code_rate_lp_str, - *transmission_mode_str; - /* do the stuff */ - /* bandwidth is 8 if 0, 7 if 1, 6 if 2, reserved otherwise */ - if (bandwidth <= 2) - bandwidth = 8 - bandwidth; - else - bandwidth = 0; - switch (constellation) { - case 0: - constellation_str = "QPSK"; - break; - case 1: - constellation_str = "QAM16"; - break; - case 2: - constellation_str = "QAM64"; - break; - default: - constellation_str = "reserved"; - } - /* hierarchy is 4 if 3, 2 if 2, 1 if 1, 0 if 0, reserved if > 3 */ - if (hierarchy <= 3) { - if (hierarchy == 3) - hierarchy = 4; - } else { - hierarchy = 0; - } - - switch (code_rate_hp) { - case 0: - code_rate_hp_str = "1/2"; - break; - case 1: - code_rate_hp_str = "2/3"; - break; - case 2: - code_rate_hp_str = "3/4"; - break; - case 3: - code_rate_hp_str = "5/6"; - break; - case 4: - code_rate_hp_str = "7/8"; - break; - default: - code_rate_hp_str = "reserved"; - } - - switch (code_rate_lp) { - case 0: - code_rate_lp_str = "1/2"; - break; - case 1: - code_rate_lp_str = "2/3"; - break; - case 2: - code_rate_lp_str = "3/4"; - break; - case 3: - code_rate_lp_str = "5/6"; - break; - case 4: - code_rate_lp_str = "7/8"; - break; - default: - code_rate_lp_str = "reserved"; - } - /* guard is 32 if 0, 16 if 1, 8 if 2, 4 if 4 */ - switch (guard_interval) { - case 0: - guard_interval = 32; - break; - case 1: - guard_interval = 16; - break; - case 2: - guard_interval = 8; - break; - case 4: - guard_interval = 4; - break; - default: /* make it default to 32 */ - guard_interval = 32; - } - switch (transmission_mode) { - case 0: - transmission_mode_str = "2k"; - break; - case 1: - transmission_mode_str = "8k"; - break; - default: - transmission_mode_str = "reserved"; - } - delivery_structure = gst_structure_new ("terrestrial", - "frequency", G_TYPE_UINT, frequency, - "bandwidth", G_TYPE_UINT, bandwidth, - "constellation", G_TYPE_STRING, constellation_str, - "hierarchy", G_TYPE_UINT, hierarchy, - "code-rate-hp", G_TYPE_STRING, code_rate_hp_str, - "code-rate-lp", G_TYPE_STRING, code_rate_lp_str, - "guard-interval", G_TYPE_UINT, guard_interval, - "transmission-mode", G_TYPE_STRING, transmission_mode_str, - "other-frequency", G_TYPE_BOOLEAN, other_frequency, NULL); - gst_structure_set (transport, "delivery", GST_TYPE_STRUCTURE, - delivery_structure, NULL); - } else if ((delivery = - gst_mpeg_descriptor_find (mpegdescriptor, - DESC_DVB_CABLE_DELIVERY_SYSTEM))) { - - guint8 *frequency_bcd = - DESC_DVB_CABLE_DELIVERY_SYSTEM_frequency (delivery); - /* see en 300 468 section 6.2.13.1 least significant bcd digit - * is measured in 100Hz units so multiplier needs to be 100 to get - * into Hz */ - guint32 frequency = 100 * - ((frequency_bcd[3] & 0x0F) + - 10 * ((frequency_bcd[3] & 0xF0) >> 4) + - 100 * (frequency_bcd[2] & 0x0F) + - 1000 * ((frequency_bcd[2] & 0xF0) >> 4) + - 10000 * (frequency_bcd[1] & 0x0F) + - 100000 * ((frequency_bcd[1] & 0xF0) >> 4) + - 1000000 * (frequency_bcd[0] & 0x0F) + - 10000000 * ((frequency_bcd[0] & 0xF0) >> 4)); - guint8 modulation = - DESC_DVB_CABLE_DELIVERY_SYSTEM_modulation (delivery); - gchar *modulation_str; - guint8 *symbol_rate_bcd = - DESC_DVB_CABLE_DELIVERY_SYSTEM_symbol_rate (delivery); - guint32 symbol_rate = - (symbol_rate_bcd[2] & 0x0F) + - 10 * ((symbol_rate_bcd[2] & 0xF0) >> 4) + - 100 * (symbol_rate_bcd[1] & 0x0F) + - 1000 * ((symbol_rate_bcd[1] & 0xF0) >> 4) + - 10000 * (symbol_rate_bcd[0] & 0x0F) + - 100000 * ((symbol_rate_bcd[0] & 0xF0) >> 4); - guint8 fec_inner = DESC_DVB_CABLE_DELIVERY_SYSTEM_fec_inner (delivery); - gchar *fec_inner_str; - - switch (fec_inner) { - case 0: - fec_inner_str = "undefined"; - break; - case 1: - fec_inner_str = "1/2"; - break; - case 2: - fec_inner_str = "2/3"; - break; - case 3: - fec_inner_str = "3/4"; - break; - case 4: - fec_inner_str = "5/6"; - break; - case 5: - fec_inner_str = "7/8"; - break; - case 6: - fec_inner_str = "8/9"; - break; - case 0xF: - fec_inner_str = "none"; - break; - default: - fec_inner_str = "reserved"; - } - switch (modulation) { - case 0x00: - modulation_str = "undefined"; - break; - case 0x01: - modulation_str = "QAM16"; - break; - case 0x02: - modulation_str = "QAM32"; - break; - case 0x03: - modulation_str = "QAM64"; - break; - case 0x04: - modulation_str = "QAM128"; - break; - case 0x05: - modulation_str = "QAM256"; - break; - default: - modulation_str = "reserved"; - } - delivery_structure = gst_structure_new ("cable", - "modulation", G_TYPE_STRING, modulation_str, - "frequency", G_TYPE_UINT, frequency, - "symbol-rate", G_TYPE_UINT, symbol_rate, - "inner-fec", G_TYPE_STRING, fec_inner_str, NULL); - gst_structure_set (transport, "delivery", GST_TYPE_STRUCTURE, - delivery_structure, NULL); - } - if ((delivery = - gst_mpeg_descriptor_find (mpegdescriptor, - DESC_DTG_LOGICAL_CHANNEL))) { - guint8 *current_pos = delivery + 2; - GValue channel_numbers = { 0 }; - - g_value_init (&channel_numbers, GST_TYPE_LIST); - while (current_pos < delivery + DESC_LENGTH (delivery)) { - GstStructure *channel; - GValue channel_value = { 0 }; - guint16 service_id = GST_READ_UINT16_BE (current_pos); - guint16 logical_channel_number; - - current_pos += 2; - logical_channel_number = GST_READ_UINT16_BE (current_pos) & 0x03ff; - channel = - gst_structure_new ("channels", "service-id", G_TYPE_UINT, - service_id, "logical-channel-number", G_TYPE_UINT, - logical_channel_number, NULL); - g_value_init (&channel_value, GST_TYPE_STRUCTURE); - g_value_take_boxed (&channel_value, channel); - gst_value_list_append_value (&channel_numbers, &channel_value); - g_value_unset (&channel_value); - current_pos += 2; - } - gst_structure_set_value (transport, "channels", &channel_numbers); - g_value_unset (&channel_numbers); - } - gst_mpeg_descriptor_free (mpegdescriptor); - - descriptors = g_value_array_new (0); - if (!mpegts_packetizer_parse_descriptors (packetizer, - &data, data + descriptors_loop_length, descriptors)) { - gst_structure_free (transport); - g_value_array_free (descriptors); - goto error; - } - - gst_structure_set (transport, "descriptors", G_TYPE_VALUE_ARRAY, - descriptors, NULL); - g_value_array_free (descriptors); - } - - g_value_init (&transport_value, GST_TYPE_STRUCTURE); - g_value_take_boxed (&transport_value, transport); - gst_value_list_append_value (&transports, &transport_value); - g_value_unset (&transport_value); - - transport_stream_loop_length -= data - entry_begin; - } - - if (data != end - 4) { - GST_WARNING ("PID %d invalid NIT parsed %d length %d", - section->pid, data - GST_BUFFER_DATA (section->buffer), - GST_BUFFER_SIZE (section->buffer)); - goto error; - } - - gst_structure_set_value (nit, "transports", &transports); - g_value_unset (&transports); - - dbg_str = gst_structure_to_string (nit); - GST_DEBUG ("NIT %s", dbg_str); - g_free (dbg_str); - - return nit; - -error: - if (nit) - gst_structure_free (nit); - - if (GST_VALUE_HOLDS_LIST (&transports)) - g_value_unset (&transports); - - return NULL; -} - -GstStructure * -mpegts_packetizer_parse_sdt (MpegTSPacketizer * packetizer, - MpegTSPacketizerSection * section) -{ - GstStructure *sdt = NULL, *service = NULL; - guint8 *data, *end, *entry_begin; - guint16 transport_stream_id, original_network_id, service_id; - guint tmp; - guint sdt_info_length; - gboolean EIT_schedule, EIT_present_following; - guint8 running_status; - gboolean scrambled; - guint descriptors_loop_length; - GValue services = { 0 }; - GValueArray *descriptors = NULL; - GValue service_value = { 0 }; - gchar *dbg_str; - - GST_DEBUG ("SDT"); - /* fixed header + CRC == 16 */ - if (GST_BUFFER_SIZE (section->buffer) < 14) { - GST_WARNING ("PID %d invalid SDT size %d", - section->pid, section->section_length); - goto error; - } - - data = GST_BUFFER_DATA (section->buffer); - end = data + GST_BUFFER_SIZE (section->buffer); - - section->table_id = *data++; - section->section_length = GST_READ_UINT16_BE (data) & 0x0FFF; - data += 2; - - if (data + section->section_length != end) { - GST_WARNING ("PID %d invalid SDT section length %d expected %d", - section->pid, section->section_length, end - data); - goto error; - } - - transport_stream_id = GST_READ_UINT16_BE (data); - data += 2; - - tmp = *data++; - section->version_number = (tmp >> 1) & 0x1F; - section->current_next_indicator = tmp & 0x01; - - /* skip section_number and last_section_number */ - data += 2; - - original_network_id = GST_READ_UINT16_BE (data); - data += 2; - - /* 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_info_length = section->section_length - 8; - g_value_init (&services, GST_TYPE_LIST); - /* read up to the CRC */ - while (sdt_info_length - 4 > 0) { - gchar *service_name; - - entry_begin = data; - - if (sdt_info_length < 9) { - /* each entry must be at least 5 bytes (+4 bytes for the CRC) */ - GST_WARNING ("PID %d invalid SDT entry size %d", - section->pid, sdt_info_length); - goto error; - } - - service_id = GST_READ_UINT16_BE (data); - data += 2; - - /* reserved */ - data += 1; - - tmp = GST_READ_UINT16_BE (data); - data += 2; - - EIT_schedule = (tmp >> 15); - EIT_present_following = (tmp >> 14) & 0x01; - running_status = (tmp >> 5) & 0x03; - scrambled = (tmp >> 4) & 0x01; - descriptors_loop_length = tmp & 0x0FFF; - - /* TODO send tag event down relevant pad for channel name and provider */ - service_name = g_strdup_printf ("service-%d", service_id); - service = gst_structure_new (service_name, NULL); - g_free (service_name); - - if (descriptors_loop_length) { - guint8 *service_descriptor; - GstMPEGDescriptor *mpegdescriptor; - - if (data + descriptors_loop_length > end - 4) { - GST_WARNING ("PID %d invalid SDT entry %d descriptors loop length %d", - section->pid, service_id, descriptors_loop_length); - gst_structure_free (service); - goto error; - } - mpegdescriptor = - gst_mpeg_descriptor_parse (data, descriptors_loop_length); - service_descriptor = - gst_mpeg_descriptor_find (mpegdescriptor, DESC_DVB_SERVICE); - if (service_descriptor != NULL) { - gchar *servicename_tmp, *serviceprovider_name_tmp; - guint8 serviceprovider_name_length = - DESC_DVB_SERVICE_provider_name_length (service_descriptor); - gchar *serviceprovider_name = - (gchar *) DESC_DVB_SERVICE_provider_name_text (service_descriptor); - guint8 servicename_length = - DESC_DVB_SERVICE_name_length (service_descriptor); - gchar *servicename = - (gchar *) DESC_DVB_SERVICE_name_text (service_descriptor); - if (servicename_length + serviceprovider_name_length + 2 <= - DESC_LENGTH (service_descriptor)) { - - servicename_tmp = - get_encoding_and_convert (servicename, servicename_length); - serviceprovider_name_tmp = - get_encoding_and_convert (serviceprovider_name, - serviceprovider_name_length); - - gst_structure_set (service, "name", G_TYPE_STRING, servicename_tmp, - NULL); - gst_structure_set (service, "provider-name", G_TYPE_STRING, - serviceprovider_name_tmp, NULL); - g_free (servicename_tmp); - g_free (serviceprovider_name_tmp); - } - } - gst_mpeg_descriptor_free (mpegdescriptor); - - descriptors = g_value_array_new (0); - if (!mpegts_packetizer_parse_descriptors (packetizer, - &data, data + descriptors_loop_length, descriptors)) { - gst_structure_free (service); - g_value_array_free (descriptors); - goto error; - } - - gst_structure_set (service, "descriptors", G_TYPE_VALUE_ARRAY, - descriptors, NULL); - - g_value_array_free (descriptors); - } - - g_value_init (&service_value, GST_TYPE_STRUCTURE); - g_value_take_boxed (&service_value, service); - gst_value_list_append_value (&services, &service_value); - g_value_unset (&service_value); - - sdt_info_length -= data - entry_begin; - } - - if (data != end - 4) { - GST_WARNING ("PID %d invalid SDT parsed %d length %d", - section->pid, data - GST_BUFFER_DATA (section->buffer), - GST_BUFFER_SIZE (section->buffer)); - goto error; - } - - gst_structure_set_value (sdt, "services", &services); - g_value_unset (&services); - - dbg_str = gst_structure_to_string (sdt); - g_free (dbg_str); - - return sdt; - -error: - if (sdt) - gst_structure_free (sdt); - - if (GST_VALUE_HOLDS_LIST (&services)) - g_value_unset (&services); - - return NULL; -} - -GstStructure * -mpegts_packetizer_parse_eit (MpegTSPacketizer * packetizer, - MpegTSPacketizerSection * section) -{ - GstStructure *eit = NULL, *event = NULL; - guint service_id, last_table_id, segment_last_section_number; - guint transport_stream_id, original_network_id; - gboolean free_ca_mode; - guint event_id, running_status; - guint64 start_and_duration; - guint16 mjd; - guint year, month, day, hour, minute, second; - guint duration; - guint8 *data, *end, *duration_ptr, *utc_ptr; - guint16 descriptors_loop_length; - GValue events = { 0 }; - GValue event_value = { 0 }; - GValueArray *descriptors = NULL; - gchar *dbg_str, *event_name; - guint tmp; - - /* fixed header + CRC == 16 */ - if (GST_BUFFER_SIZE (section->buffer) < 18) { - GST_WARNING ("PID %d invalid EIT size %d", - section->pid, section->section_length); - goto error; - } - - data = GST_BUFFER_DATA (section->buffer); - end = data + GST_BUFFER_SIZE (section->buffer); - - section->table_id = *data++; - section->section_length = GST_READ_UINT16_BE (data) & 0x0FFF; - data += 2; - - if (data + section->section_length != end) { - GST_WARNING ("PID %d invalid EIT section length %d expected %d", - section->pid, section->section_length, end - data); - goto error; - } - - service_id = GST_READ_UINT16_BE (data); - data += 2; - - tmp = *data++; - section->version_number = (tmp >> 1) & 0x1F; - section->current_next_indicator = tmp & 0x01; - - /* skip section_number and last_section_number */ - data += 2; - - transport_stream_id = GST_READ_UINT16_BE (data); - data += 2; - original_network_id = GST_READ_UINT16_BE (data); - data += 2; - segment_last_section_number = *data; - data += 1; - 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); - - g_value_init (&events, GST_TYPE_LIST); - while (data < end - 4) { - /* 12 is the minimum entry size + CRC */ - if (end - data < 12 + 4) { - GST_WARNING ("PID %d invalid EIT entry length %d", - section->pid, end - 4 - data); - gst_structure_free (eit); - goto error; - } - - event_id = GST_READ_UINT16_BE (data); - data += 2; - start_and_duration = GST_READ_UINT64_BE (data); - duration_ptr = data + 5; - utc_ptr = data + 2; - mjd = GST_READ_UINT16_BE (data); - if (mjd == G_MAXUINT16) { - year = 1900; - month = day = hour = minute = second = 0; - } else { - /* See EN 300 468 Annex C */ - year = (guint32) (((mjd - 15078.2) / 365.25)); - month = (guint8) ((mjd - 14956.1 - (guint) (year * 365.25)) / 30.6001); - day = mjd - 14956 - (guint) (year * 365.25) - (guint) (month * 30.6001); - if (month == 14 || month == 15) { - year++; - month = month - 1 - 12; - } else { - month--; - } - year += 1900; - hour = ((utc_ptr[0] & 0xF0) >> 4) * 10 + (utc_ptr[0] & 0x0F); - minute = ((utc_ptr[1] & 0xF0) >> 4) * 10 + (utc_ptr[1] & 0x0F); - second = ((utc_ptr[2] & 0xF0) >> 4) * 10 + (utc_ptr[2] & 0x0F); - } - - duration = (((duration_ptr[0] & 0xF0) >> 4) * 10 + - (duration_ptr[0] & 0x0F)) * 60 * 60 + - (((duration_ptr[1] & 0xF0) >> 4) * 10 + - (duration_ptr[1] & 0x0F)) * 60 + - ((duration_ptr[2] & 0xF0) >> 4) * 10 + (duration_ptr[2] & 0x0F); - - data += 8; - running_status = *data >> 5; - free_ca_mode = (*data >> 4) & 0x01; - descriptors_loop_length = GST_READ_UINT16_BE (data) & 0x0FFF; - data += 2; - - /* TODO: send tag event down relevant pad saying what is currently playing */ - event_name = g_strdup_printf ("event-%d", event_id); - event = gst_structure_new (event_name, - "event-id", G_TYPE_UINT, event_id, - "year", G_TYPE_UINT, year, - "month", G_TYPE_UINT, month, - "day", G_TYPE_UINT, day, - "hour", G_TYPE_UINT, hour, - "minute", G_TYPE_UINT, minute, - "second", G_TYPE_UINT, second, - "duration", G_TYPE_UINT, duration, - "running-status", G_TYPE_UINT, running_status, - "free-ca-mode", G_TYPE_BOOLEAN, free_ca_mode, NULL); - g_free (event_name); - - if (descriptors_loop_length) { - guint8 *event_descriptor; - GArray *component_descriptors; - GArray *extended_event_descriptors; - GstMPEGDescriptor *mpegdescriptor; - - if (data + descriptors_loop_length > end - 4) { - GST_WARNING ("PID %d invalid EIT descriptors loop length %d", - section->pid, descriptors_loop_length); - gst_structure_free (event); - goto error; - } - mpegdescriptor = - gst_mpeg_descriptor_parse (data, descriptors_loop_length); - event_descriptor = - gst_mpeg_descriptor_find (mpegdescriptor, DESC_DVB_SHORT_EVENT); - if (event_descriptor != NULL) { - gchar *eventname_tmp, *eventdescription_tmp; - guint8 eventname_length = - DESC_DVB_SHORT_EVENT_name_length (event_descriptor); - gchar *eventname = - (gchar *) DESC_DVB_SHORT_EVENT_name_text (event_descriptor); - guint8 eventdescription_length = - DESC_DVB_SHORT_EVENT_description_length (event_descriptor); - gchar *eventdescription = - (gchar *) DESC_DVB_SHORT_EVENT_description_text (event_descriptor); - if (eventname_length + eventdescription_length + 2 <= - DESC_LENGTH (event_descriptor)) { - - eventname_tmp = - get_encoding_and_convert (eventname, eventname_length), - eventdescription_tmp = - get_encoding_and_convert (eventdescription, - eventdescription_length); - - gst_structure_set (event, "name", G_TYPE_STRING, eventname_tmp, NULL); - gst_structure_set (event, "description", G_TYPE_STRING, - eventdescription_tmp, NULL); - g_free (eventname_tmp); - g_free (eventdescription_tmp); - } - } - extended_event_descriptors = gst_mpeg_descriptor_find_all (mpegdescriptor, - DESC_DVB_EXTENDED_EVENT); - if (extended_event_descriptors) { - int i; - guint8 *extended_descriptor; - /*GValue extended_items = { 0 }; */ - gchar *extended_text = NULL; - gchar *extended_text_tmp; - /*g_value_init (&extended_items, GST_TYPE_LIST); */ - for (i = 0; i < extended_event_descriptors->len; i++) { - extended_descriptor = g_array_index (extended_event_descriptors, - guint8 *, i); - if (DESC_DVB_EXTENDED_EVENT_descriptor_number (extended_descriptor) == - i) { - if (extended_text) { - gchar *tmp; - gchar *old_extended_text = extended_text; - tmp = g_strndup ((gchar *) - DESC_DVB_EXTENDED_EVENT_text (extended_descriptor), - DESC_DVB_EXTENDED_EVENT_text_length (extended_descriptor)); - extended_text = g_strdup_printf ("%s%s", extended_text, tmp); - g_free (old_extended_text); - g_free (tmp); - } else { - extended_text = g_strndup ((gchar *) - DESC_DVB_EXTENDED_EVENT_text (extended_descriptor), - DESC_DVB_EXTENDED_EVENT_text_length (extended_descriptor)); - } - } - } - if (extended_text) { - extended_text_tmp = get_encoding_and_convert (extended_text, - strlen (extended_text)); - - gst_structure_set (event, "extended-text", G_TYPE_STRING, - extended_text_tmp, NULL); - g_free (extended_text_tmp); - g_free (extended_text); - } - g_array_free (extended_event_descriptors, TRUE); - } - - component_descriptors = gst_mpeg_descriptor_find_all (mpegdescriptor, - DESC_DVB_COMPONENT); - if (component_descriptors) { - int i; - guint8 *comp_descriptor; - GValue components = { 0 }; - g_value_init (&components, GST_TYPE_LIST); - /* FIXME: do the component descriptor parsing less verbosely - * and better...a task for 0.10.6 */ - for (i = 0; i < component_descriptors->len; i++) { - GstStructure *component = NULL; - GValue component_value = { 0 }; - gint widescreen = 0; /* 0 for 4:3, 1 for 16:9, 2 for > 16:9 */ - gint freq = 25; /* 25 or 30 measured in Hertz */ - gboolean highdef = FALSE; - gboolean panvectors = FALSE; - gchar *comptype = ""; - - comp_descriptor = g_array_index (component_descriptors, guint8 *, i); - switch (DESC_DVB_COMPONENT_stream_content (comp_descriptor)) { - case 0x01: - /* video */ - switch (DESC_DVB_COMPONENT_type (comp_descriptor)) { - case 0x01: - widescreen = 0; - freq = 25; - break; - case 0x02: - widescreen = 1; - panvectors = TRUE; - freq = 25; - break; - case 0x03: - widescreen = 1; - panvectors = FALSE; - freq = 25; - break; - case 0x04: - widescreen = 2; - freq = 25; - break; - case 0x05: - widescreen = 0; - freq = 30; - break; - case 0x06: - widescreen = 1; - panvectors = TRUE; - freq = 30; - break; - case 0x07: - widescreen = 1; - panvectors = FALSE; - freq = 30; - break; - case 0x08: - widescreen = 2; - freq = 30; - break; - case 0x09: - widescreen = 0; - highdef = TRUE; - freq = 25; - break; - case 0x0A: - widescreen = 1; - highdef = TRUE; - panvectors = TRUE; - freq = 25; - break; - case 0x0B: - widescreen = 1; - highdef = TRUE; - panvectors = FALSE; - freq = 25; - break; - case 0x0C: - widescreen = 2; - highdef = TRUE; - freq = 25; - break; - case 0x0D: - widescreen = 0; - highdef = TRUE; - freq = 30; - break; - case 0x0E: - widescreen = 1; - highdef = TRUE; - panvectors = TRUE; - freq = 30; - break; - case 0x0F: - widescreen = 1; - highdef = TRUE; - panvectors = FALSE; - freq = 30; - break; - case 0x10: - widescreen = 2; - highdef = TRUE; - freq = 30; - break; - } - component = gst_structure_new ("video", "high-definition", - G_TYPE_BOOLEAN, TRUE, "frequency", G_TYPE_INT, freq, NULL); - if (widescreen == 0) { - gst_structure_set (component, "aspect-ratio", - G_TYPE_STRING, "4:3", NULL); - } else if (widescreen == 2) { - gst_structure_set (component, "aspect-ratio", G_TYPE_STRING, - "> 16:9", NULL); - } else { - gst_structure_set (component, "aspect-ratio", G_TYPE_STRING, - "16:9", "pan-vectors", G_TYPE_BOOLEAN, panvectors, NULL); - } - break; - case 0x02: /* audio */ - comptype = "undefined"; - switch (DESC_DVB_COMPONENT_type (comp_descriptor)) { - case 0x01: - comptype = "single channel mono"; - break; - case 0x02: - comptype = "dual channel mono"; - break; - case 0x03: - comptype = "stereo"; - break; - case 0x04: - comptype = "multi-channel multi-lingual"; - break; - case 0x05: - comptype = "surround"; - break; - case 0x40: - comptype = "audio description for the visually impaired"; - break; - case 0x41: - comptype = "audio for the hard of hearing"; - break; - } - component = gst_structure_new ("audio", "type", G_TYPE_STRING, - comptype, NULL); - break; - case 0x03: /* subtitles/teletext/vbi */ - comptype = "reserved"; - switch (DESC_DVB_COMPONENT_type (comp_descriptor)) { - case 0x01: - comptype = "EBU Teletext subtitles"; - break; - case 0x02: - comptype = "associated EBU Teletext"; - break; - case 0x03: - comptype = "VBI data"; - break; - case 0x10: - comptype = "Normal DVB subtitles"; - break; - case 0x11: - comptype = "Normal DVB subtitles for 4:3"; - break; - case 0x12: - comptype = "Normal DVB subtitles for 16:9"; - break; - case 0x13: - comptype = "Normal DVB subtitles for 2.21:1"; - break; - case 0x20: - comptype = "Hard of hearing DVB subtitles"; - break; - case 0x21: - comptype = "Hard of hearing DVB subtitles for 4:3"; - break; - case 0x22: - comptype = "Hard of hearing DVB subtitles for 16:9"; - break; - case 0x23: - comptype = "Hard of hearing DVB subtitles for 2.21:1"; - break; - } - component = gst_structure_new ("teletext", "type", G_TYPE_STRING, - comptype, NULL); - break; - } - if (component) { - g_value_init (&component_value, GST_TYPE_STRUCTURE); - g_value_take_boxed (&component_value, component); - gst_value_list_append_value (&components, &component_value); - g_value_unset (&component_value); - component = NULL; - } - } - gst_structure_set_value (event, "components", &components); - g_array_free (component_descriptors, TRUE); - } - gst_mpeg_descriptor_free (mpegdescriptor); - - descriptors = g_value_array_new (0); - if (!mpegts_packetizer_parse_descriptors (packetizer, - &data, data + descriptors_loop_length, descriptors)) { - gst_structure_free (event); - g_value_array_free (descriptors); - goto error; - } - gst_structure_set (event, "descriptors", G_TYPE_VALUE_ARRAY, descriptors, - NULL); - g_value_array_free (descriptors); - } - - g_value_init (&event_value, GST_TYPE_STRUCTURE); - g_value_take_boxed (&event_value, event); - gst_value_list_append_value (&events, &event_value); - g_value_unset (&event_value); - } - - if (data != end - 4) { - GST_WARNING ("PID %d invalid EIT parsed %d length %d", - section->pid, data - GST_BUFFER_DATA (section->buffer), - GST_BUFFER_SIZE (section->buffer)); - goto error; - } - - gst_structure_set_value (eit, "events", &events); - g_value_unset (&events); - - dbg_str = gst_structure_to_string (eit); - GST_DEBUG ("EIT %s", dbg_str); - g_free (dbg_str); - - return eit; - -error: - if (eit) - gst_structure_free (eit); - - if (GST_VALUE_HOLDS_LIST (&events)) - g_value_unset (&events); - - return NULL; -} - -static void -foreach_stream_clear (gpointer key, gpointer value, gpointer data) -{ - MpegTSPacketizerStream *stream = (MpegTSPacketizerStream *) value; - - /* remove the stream */ - g_object_unref (stream->section_adapter); - g_free (stream); -} - -static gboolean -remove_all (gpointer key, gpointer value, gpointer user_data) -{ - return TRUE; -} - -void -mpegts_packetizer_clear (MpegTSPacketizer * packetizer) -{ - g_hash_table_foreach (packetizer->streams, foreach_stream_clear, packetizer); - - /* FIXME can't use remove_all because we don't depend on 2.12 yet */ - g_hash_table_foreach_remove (packetizer->streams, remove_all, NULL); - gst_adapter_clear (packetizer->adapter); -} - -MpegTSPacketizer * -mpegts_packetizer_new () -{ - MpegTSPacketizer *packetizer; - - packetizer = - GST_MPEGTS_PACKETIZER (g_object_new (GST_TYPE_MPEGTS_PACKETIZER, NULL)); - - return packetizer; -} - -void -mpegts_packetizer_push (MpegTSPacketizer * packetizer, GstBuffer * buffer) -{ - g_return_if_fail (GST_IS_MPEGTS_PACKETIZER (packetizer)); - g_return_if_fail (GST_IS_BUFFER (buffer)); - - gst_adapter_push (packetizer->adapter, buffer); -} - -gboolean -mpegts_packetizer_has_packets (MpegTSPacketizer * packetizer) -{ - g_return_val_if_fail (GST_IS_MPEGTS_PACKETIZER (packetizer), FALSE); - - return gst_adapter_available (packetizer->adapter) >= 188; -} - -gboolean -mpegts_packetizer_next_packet (MpegTSPacketizer * packetizer, - MpegTSPacketizerPacket * packet) -{ - guint8 sync_byte; - gboolean ret = FALSE; - - g_return_val_if_fail (GST_IS_MPEGTS_PACKETIZER (packetizer), FALSE); - g_return_val_if_fail (packet != NULL, FALSE); - - packet->buffer = NULL; - while (gst_adapter_available (packetizer->adapter) >= 188) { - sync_byte = *gst_adapter_peek (packetizer->adapter, 1); - if (sync_byte != 0x47) { - GST_DEBUG ("lost sync %02x", sync_byte); - gst_adapter_flush (packetizer->adapter, 1); - continue; - } - - packet->buffer = gst_adapter_take_buffer (packetizer->adapter, 188); - packet->data_start = GST_BUFFER_DATA (packet->buffer); - packet->data_end = - GST_BUFFER_DATA (packet->buffer) + GST_BUFFER_SIZE (packet->buffer); - ret = mpegts_packetizer_parse_packet (packetizer, packet); - break; - } - - return ret; -} - -void -mpegts_packetizer_clear_packet (MpegTSPacketizer * packetizer, - MpegTSPacketizerPacket * packet) -{ - g_return_if_fail (GST_IS_MPEGTS_PACKETIZER (packetizer)); - g_return_if_fail (packet != NULL); - - if (packet->buffer) - gst_buffer_unref (packet->buffer); - packet->buffer = NULL; - packet->continuity_counter = 0; - packet->payload_unit_start_indicator = 0; - packet->payload = NULL; - packet->data_start = NULL; - packet->data_end = NULL; -} - -gboolean -mpegts_packetizer_push_section (MpegTSPacketizer * packetizer, - MpegTSPacketizerPacket * packet, MpegTSPacketizerSection * section) -{ - gboolean res = FALSE; - MpegTSPacketizerStream *stream; - guint8 pointer, table_id; - guint16 subtable_extension; - guint section_length; - GstBuffer *sub_buf; - guint8 *data; - - g_return_val_if_fail (GST_IS_MPEGTS_PACKETIZER (packetizer), FALSE); - g_return_val_if_fail (packet != NULL, FALSE); - g_return_val_if_fail (section != NULL, FALSE); - - data = packet->data; - section->pid = packet->pid; - - if (packet->payload_unit_start_indicator == 1) { - pointer = *data++; - if (data + pointer > packet->data_end) { - GST_WARNING ("PID %d PSI section pointer points past the end " - "of the buffer", packet->pid); - goto out; - } - - data += pointer; - } - /* create a sub buffer from the start of the section (table_id and - * section_length included) to the end */ - sub_buf = gst_buffer_create_sub (packet->buffer, - data - GST_BUFFER_DATA (packet->buffer), packet->data_end - data); - - stream = (MpegTSPacketizerStream *) g_hash_table_lookup (packetizer->streams, - GINT_TO_POINTER ((gint) packet->pid)); - if (stream == NULL) { - stream = mpegts_packetizer_stream_new (); - g_hash_table_insert (packetizer->streams, - GINT_TO_POINTER ((gint) packet->pid), stream); - } - - if (packet->payload_unit_start_indicator) { - table_id = *data++; - /* subtable_extension should be read from 4th and 5th bytes only if - * section_syntax_indicator is 1 */ - if ((data[0] & 0x80) == 0) - subtable_extension = 0; - else - subtable_extension = GST_READ_UINT16_BE (data + 2); - GST_DEBUG ("pid: %d table_id %d sub_table_extension %d", - packet->pid, table_id, subtable_extension); - - section_length = GST_READ_UINT16_BE (data) & 0x0FFF; - - if (stream->continuity_counter != CONTINUITY_UNSET) { - GST_DEBUG - ("PID %d table_id %d sub_table_extension %d payload_unit_start_indicator set but section " - "not complete (last_continuity: %d continuity: %d sec len %d buffer %d avail %d", - packet->pid, table_id, subtable_extension, stream->continuity_counter, - packet->continuity_counter, section_length, GST_BUFFER_SIZE (sub_buf), - gst_adapter_available (stream->section_adapter)); - mpegts_packetizer_clear_section (packetizer, stream); - } else { - GST_DEBUG - ("pusi set and new stream section is %d long and data we have is: %d", - section_length, packet->data_end - packet->data); - } - stream->continuity_counter = packet->continuity_counter; - stream->section_length = section_length; - stream->section_table_id = table_id; - gst_adapter_push (stream->section_adapter, sub_buf); - - res = TRUE; - } else if (stream->continuity_counter != CONTINUITY_UNSET && - (packet->continuity_counter == stream->continuity_counter + 1 || - (stream->continuity_counter == MAX_CONTINUITY && - packet->continuity_counter == 0))) { - stream->continuity_counter = packet->continuity_counter; - gst_adapter_push (stream->section_adapter, sub_buf); - - res = TRUE; - } else { - if (stream->continuity_counter == CONTINUITY_UNSET) - GST_DEBUG ("PID %d waiting for pusi", packet->pid); - else - GST_DEBUG ("PID %d section discontinuity " - "(last_continuity: %d continuity: %d", packet->pid, - stream->continuity_counter, packet->continuity_counter); - mpegts_packetizer_clear_section (packetizer, stream); - gst_buffer_unref (sub_buf); - } - - if (res) { - /* we pushed some data in the section adapter, see if the section is - * complete now */ - - /* >= as sections can be padded and padding is not included in - * section_length */ - if (gst_adapter_available (stream->section_adapter) >= - stream->section_length + 3) { - res = mpegts_packetizer_parse_section_header (packetizer, - stream, section); - - /* flush stuffing bytes */ - mpegts_packetizer_clear_section (packetizer, stream); - } else { - /* section not complete yet */ - section->complete = FALSE; - } - } else { - GST_WARNING ("section not complete"); - section->complete = FALSE; - } - -out: - packet->data = data; - return res; -} - -void -mpegts_packetizer_init_debug () -{ - GST_DEBUG_CATEGORY_INIT (mpegts_packetizer_debug, "mpegtspacketizer", 0, - "MPEG transport stream parser"); -} - -/** - * @text: The text you want to get the encoding from - * @start_text: Location where the beginning of the actual text is stored - * @is_multibyte: Location where information whether it's a multibyte encoding - * or not is stored - * @returns: Name of encoding or NULL of encoding could not be detected. - * - * The returned string should be freed with g_free () when no longer needed. - */ -static gchar * -get_encoding (const gchar * text, guint * start_text, gboolean * is_multibyte) -{ - gchar *encoding; - guint8 firstbyte; - - g_return_val_if_fail (text != NULL, NULL); - - firstbyte = (guint8) text[0]; - - if (firstbyte == 0x01) { - encoding = g_strdup ("iso8859-5"); - *start_text = 1; - *is_multibyte = FALSE; - } else if (firstbyte == 0x02) { - encoding = g_strdup ("iso8859-6"); - *start_text = 1; - *is_multibyte = FALSE; - } else if (firstbyte == 0x03) { - encoding = g_strdup ("iso8859-7"); - *start_text = 1; - *is_multibyte = FALSE; - } else if (firstbyte == 0x04) { - encoding = g_strdup ("iso8859-8"); - *start_text = 1; - *is_multibyte = FALSE; - } else if (firstbyte == 0x05) { - encoding = g_strdup ("iso8859-9"); - *start_text = 1; - *is_multibyte = FALSE; - } else if (firstbyte >= 0x20) { - encoding = g_strdup ("iso6937"); - *start_text = 0; - *is_multibyte = FALSE; - } else if (firstbyte == 0x10) { - guint16 table; - gchar table_str[6]; - - text++; - table = GST_READ_UINT16_BE (text); - g_snprintf (table_str, 6, "%d", table); - - encoding = g_strconcat ("iso8859-", table_str, NULL); - *start_text = 3; - *is_multibyte = FALSE; - } else if (firstbyte == 0x11) { - encoding = g_strdup ("ISO-10646/UCS2"); - *start_text = 1; - *is_multibyte = TRUE; - } else if (firstbyte == 0x12) { - // That's korean encoding. - // The spec says it's encoded in KSC 5601, but iconv only knows KSC 5636. - // Couldn't find any information about either of them. - encoding = NULL; - *start_text = 1; - *is_multibyte = TRUE; - } else { - // reserved - encoding = NULL; - } - - return encoding; -} - -/** - * @text: The text to convert. It may include pango markup (<b> and </b>) - * @length: The length of the string -1 if it's nul-terminated - * @start: Where to start converting in the text - * @encoding: The encoding of text - * @is_multibyte: Whether the encoding is a multibyte encoding - * @error: The location to store the error, or NULL to ignore errors - * @returns: UTF-8 encoded string - * - * Convert text to UTF-8. - */ -static gchar * -convert_to_utf8 (const gchar * text, gint length, guint start, - const gchar * encoding, gboolean is_multibyte, GError ** error) -{ - gchar *new_text; - GByteArray *sb; - gint i; - - g_return_val_if_fail (text != NULL, NULL); - g_return_val_if_fail (encoding != NULL, NULL); - - text += start; - - sb = g_byte_array_sized_new (length * 1.1); - - if (is_multibyte) { - if (length == -1) { - while (*text != '\0') { - guint16 code = GST_READ_UINT16_BE (text); - - switch (code) { - case 0xE086:{ - guint8 emph_on[] = { 0x3C, 0x00, // < - 0x62, 0x00, // b - 0x3E, 0x00 // > - }; - g_byte_array_append (sb, emph_on, 6); - break; - } - case 0xE087:{ - guint8 emph_on[] = { 0x3C, 0x00, // < - 0x2F, 0x00, // / - 0x62, 0x00, // b - 0x3E, 0x00 // > - }; - g_byte_array_append (sb, emph_on, 8); - break; - } - case 0xE08A:{ - guint8 nl[] = { 0x0A, 0x00 }; // new line - g_byte_array_append (sb, nl, 2); - break; - } - default: - g_byte_array_append (sb, (guint8 *) text, 2); - break; - } - - text += 2; - } - } else { - for (i = 0; i < length; i += 2) { - guint16 code = GST_READ_UINT16_BE (text); - - switch (code) { - case 0xE086:{ - guint8 emph_on[] = { 0x3C, 0x00, // < - 0x62, 0x00, // b - 0x3E, 0x00 // > - }; - g_byte_array_append (sb, emph_on, 6); - break; - } - case 0xE087:{ - guint8 emph_on[] = { 0x3C, 0x00, // < - 0x2F, 0x00, // / - 0x62, 0x00, // b - 0x3E, 0x00 // > - }; - g_byte_array_append (sb, emph_on, 8); - break; - } - case 0xE08A:{ - guint8 nl[] = { 0x0A, 0x00 }; // new line - g_byte_array_append (sb, nl, 2); - break; - } - default: - g_byte_array_append (sb, (guint8 *) text, 2); - break; - } - - text += 2; - } - } - } else { - if (length == -1) { - while (*text != '\0') { - guint8 code = (guint8) (*text); - - switch (code) { - case 0x86: - g_byte_array_append (sb, (guint8 *) "<b>", 3); - break; - case 0x87: - g_byte_array_append (sb, (guint8 *) "</b>", 4); - break; - case 0x8A: - g_byte_array_append (sb, (guint8 *) "\n", 1); - break; - default: - g_byte_array_append (sb, &code, 1); - break; - } - - text++; - } - } else { - for (i = 0; i < length; i++) { - guint8 code = (guint8) (*text); - - switch (code) { - case 0x86: - g_byte_array_append (sb, (guint8 *) "<b>", 3); - break; - case 0x87: - g_byte_array_append (sb, (guint8 *) "</b>", 4); - break; - case 0x8A: - g_byte_array_append (sb, (guint8 *) "\n", 1); - break; - default: - g_byte_array_append (sb, &code, 1); - break; - } - - text++; - } - } - } - - if (sb->len > 0) { - new_text = - g_convert ((gchar *) sb->data, sb->len, "utf-8", encoding, NULL, NULL, - error); - } else { - new_text = g_strdup (""); - } - - g_byte_array_free (sb, TRUE); - - return new_text; -} - -static gchar * -get_encoding_and_convert (const gchar * text, guint length) -{ - GError *error = NULL; - gchar *converted_str; - gchar *encoding; - guint start_text = 0; - gboolean is_multibyte; - - g_return_val_if_fail (text != NULL, NULL); - - encoding = get_encoding (text, &start_text, &is_multibyte); - - if (encoding == NULL) { - converted_str = g_strndup (text, length); - } else { - converted_str = convert_to_utf8 (text, length - start_text, start_text, - encoding, is_multibyte, &error); - if (error != NULL) { - g_critical ("Could not convert string: %s", error->message); - g_error_free (error); - text += start_text; - converted_str = g_strndup (text, length - start_text); - } - - g_free (encoding); - } - - return converted_str; -} diff --git a/gst/mpegtsparse/mpegtspacketizer.h b/gst/mpegtsparse/mpegtspacketizer.h deleted file mode 100644 index c54228afa..000000000 --- a/gst/mpegtsparse/mpegtspacketizer.h +++ /dev/null @@ -1,135 +0,0 @@ -/* - * mpegtspacketizer.h - - * Copyright (C) 2007 Alessandro Decina - * - * Authors: - * Alessandro Decina <alessandro@nnva.org> - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Library General Public - * License as published by the Free Software Foundation; either - * version 2 of the License, or (at your option) any later version. - * - * This library 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 - * Library General Public License for more details. - * - * You should have received a copy of the GNU Library General Public - * License along with this library; if not, write to the - * Free Software Foundation, Inc., 59 Temple Place - Suite 330, - * Boston, MA 02111-1307, USA. - */ - -#ifndef GST_MPEGTS_PACKETIZER_H -#define GST_MPEGTS_PACKETIZER_H - -#include <gst/gst.h> -#include <gst/base/gstadapter.h> -#include <glib.h> - -G_BEGIN_DECLS - -#define GST_TYPE_MPEGTS_PACKETIZER \ - (mpegts_packetizer_get_type()) -#define GST_MPEGTS_PACKETIZER(obj) \ - (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_MPEGTS_PACKETIZER,MpegTSPacketizer)) -#define GST_MPEGTS_PACKETIZER_CLASS(klass) \ - (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_MPEGTS_PACKETIZER,MpegTSPacketizerClass)) -#define GST_IS_MPEGTS_PACKETIZER(obj) \ - (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_MPEGTS_PACKETIZER)) -#define GST_IS_MPEGTS_PACKETIZER_CLASS(klass) \ - (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_MPEGTS_PACKETIZER)) - - -typedef struct _MpegTSPacketizer MpegTSPacketizer; -typedef struct _MpegTSPacketizerClass MpegTSPacketizerClass; - -struct _MpegTSPacketizer { - GObject object; - - GstAdapter *adapter; - /* streams hashed by pid */ - GHashTable *streams; - gboolean disposed; -}; - -struct _MpegTSPacketizerClass { - GObjectClass object_class; -}; - -typedef struct -{ - GstBuffer *buffer; - gint16 pid; - guint8 payload_unit_start_indicator; - guint8 adaptation_field_control; - guint8 continuity_counter; - guint8 *payload; - - guint8 *data_start; - guint8 *data_end; - guint8 *data; - -} MpegTSPacketizerPacket; - -typedef struct -{ - gboolean complete; - GstBuffer *buffer; - gint16 pid; - guint8 table_id; - guint16 subtable_extension; - guint section_length; - guint8 version_number; - guint8 current_next_indicator; -} MpegTSPacketizerSection; - -typedef struct -{ - guint8 table_id; - /* the spec says sub_table_extension is the fourth and fifth byte of a - * section when the section_syntax_indicator is set to a value of "1". If - * section_syntax_indicator is 0, sub_table_extension will be set to 0 */ - guint16 subtable_extension; - guint8 version_number; -} MpegTSPacketizerStreamSubtable; - -typedef struct -{ - guint continuity_counter; - GstAdapter *section_adapter; - guint8 section_table_id; - guint section_length; - GSList *subtables; -} MpegTSPacketizerStream; - - -GType gst_mpegts_packetizer_get_type(void); - -void mpegts_packetizer_init_debug (); -MpegTSPacketizer *mpegts_packetizer_new (); -void mpegts_packetizer_clear (MpegTSPacketizer *packetizer); -void mpegts_packetizer_push (MpegTSPacketizer *packetizer, GstBuffer *buffer); -gboolean mpegts_packetizer_has_packets (MpegTSPacketizer *packetizer); -gboolean mpegts_packetizer_next_packet (MpegTSPacketizer *packetizer, - MpegTSPacketizerPacket *packet); -void mpegts_packetizer_clear_packet (MpegTSPacketizer *packetizer, - MpegTSPacketizerPacket *packet); - -gboolean mpegts_packetizer_push_section (MpegTSPacketizer *packetzer, - MpegTSPacketizerPacket *packet, MpegTSPacketizerSection *section); -GstStructure *mpegts_packetizer_parse_pat (MpegTSPacketizer *packetizer, - MpegTSPacketizerSection *section); -GstStructure *mpegts_packetizer_parse_pmt (MpegTSPacketizer *packetizer, - MpegTSPacketizerSection *section); -GstStructure *mpegts_packetizer_parse_nit (MpegTSPacketizer *packetizer, - MpegTSPacketizerSection *section); -GstStructure *mpegts_packetizer_parse_sdt (MpegTSPacketizer *packetizer, - MpegTSPacketizerSection *section); -GstStructure *mpegts_packetizer_parse_eit (MpegTSPacketizer *packetizer, - MpegTSPacketizerSection *section); - -G_END_DECLS - -#endif /* GST_MPEGTS_PACKETIZER_H */ diff --git a/gst/mpegtsparse/mpegtsparse.c b/gst/mpegtsparse/mpegtsparse.c deleted file mode 100644 index 3ac66c7a7..000000000 --- a/gst/mpegtsparse/mpegtsparse.c +++ /dev/null @@ -1,1292 +0,0 @@ -/* - * mpegtsparse.c - - * Copyright (C) 2007 Alessandro Decina - * - * Authors: - * Alessandro Decina <alessandro@nnva.org> - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Library General Public - * License as published by the Free Software Foundation; either - * version 2 of the License, or (at your option) any later version. - * - * This library 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 - * Library General Public License for more details. - * - * You should have received a copy of the GNU Library General Public - * License along with this library; if not, write to the - * Free Software Foundation, Inc., 59 Temple Place - Suite 330, - * Boston, MA 02111-1307, USA. - */ - -#ifdef HAVE_CONFIG_H -#include "config.h" -#endif - -#include <stdlib.h> - -#include "mpegtsparse.h" -#include "gstmpegdesc.h" - -/* latency in mseconds */ -#define TS_LATENCY 700 - -#define TABLE_ID_UNSET 0xFF - -GST_DEBUG_CATEGORY_STATIC (mpegts_parse_debug); -#define GST_CAT_DEFAULT mpegts_parse_debug - -typedef struct _MpegTSParsePad MpegTSParsePad; - -typedef struct -{ - guint16 pid; - guint8 stream_type; -} MpegTSParseStream; - -typedef struct -{ - gint program_number; - guint16 pmt_pid; - guint16 pcr_pid; - GstStructure *pmt_info; - GHashTable *streams; - gint patcount; - gint selected; - gboolean active; - MpegTSParsePad *tspad; -} MpegTSParseProgram; - -struct _MpegTSParsePad -{ - GstPad *pad; - - /* the program number that the peer wants on this pad */ - gint program_number; - MpegTSParseProgram *program; - - /* set to FALSE before a push and TRUE after */ - gboolean pushed; - - /* the return of the latest push */ - GstFlowReturn flow_return; -}; - -static GstElementDetails mpegts_parse_details = -GST_ELEMENT_DETAILS ("MPEG transport stream parser", - "Codec/Parser", - "Parses MPEG2 transport streams", - "Alessandro Decina <alessandro@nnva.org>"); - -static GstStaticPadTemplate sink_template = GST_STATIC_PAD_TEMPLATE ("sink", - GST_PAD_SINK, - GST_PAD_ALWAYS, - GST_STATIC_CAPS ("video/mpegts, " "systemstream = (boolean) true ") - ); - -static GstStaticPadTemplate src_template = -GST_STATIC_PAD_TEMPLATE ("src%d", GST_PAD_SRC, - GST_PAD_REQUEST, - GST_STATIC_CAPS ("video/mpegts, " "systemstream = (boolean) true ") - ); - -static GstStaticPadTemplate program_template = -GST_STATIC_PAD_TEMPLATE ("program_%d", GST_PAD_SRC, - GST_PAD_SOMETIMES, - GST_STATIC_CAPS ("video/mpegts, " "systemstream = (boolean) true ") - ); - -enum -{ - ARG_0, - PROP_PROGRAM_NUMBERS, - /* FILL ME */ -}; - -static void mpegts_parse_set_property (GObject * object, guint prop_id, - const GValue * value, GParamSpec * pspec); -static void mpegts_parse_get_property (GObject * object, guint prop_id, - GValue * value, GParamSpec * pspec); -static void mpegts_parse_dispose (GObject * object); -static void mpegts_parse_finalize (GObject * object); - -static MpegTSParsePad *mpegts_parse_create_tspad (MpegTSParse * parse, - const gchar * name); -static void mpegts_parse_destroy_tspad (MpegTSParse * parse, - MpegTSParsePad * tspad); -static GstPad *mpegts_parse_activate_program (MpegTSParse * parse, - MpegTSParseProgram * program); -static void mpegts_parse_free_program (MpegTSParseProgram * program); -static void mpegts_parse_free_stream (MpegTSParseStream * ptream); -static void mpegts_parse_reset_selected_programs (MpegTSParse * parse, - gchar * programs); - -static void mpegts_parse_pad_removed (GstElement * element, GstPad * pad); -static GstPad *mpegts_parse_request_new_pad (GstElement * element, - GstPadTemplate * templ, const gchar * name); -static void mpegts_parse_release_pad (GstElement * element, GstPad * pad); -static GstFlowReturn mpegts_parse_chain (GstPad * pad, GstBuffer * buf); -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); - -GST_BOILERPLATE (MpegTSParse, mpegts_parse, GstElement, GST_TYPE_ELEMENT); - -static const guint32 crc_tab[256] = { - 0x00000000, 0x04c11db7, 0x09823b6e, 0x0d4326d9, 0x130476dc, 0x17c56b6b, - 0x1a864db2, 0x1e475005, 0x2608edb8, 0x22c9f00f, 0x2f8ad6d6, 0x2b4bcb61, - 0x350c9b64, 0x31cd86d3, 0x3c8ea00a, 0x384fbdbd, 0x4c11db70, 0x48d0c6c7, - 0x4593e01e, 0x4152fda9, 0x5f15adac, 0x5bd4b01b, 0x569796c2, 0x52568b75, - 0x6a1936c8, 0x6ed82b7f, 0x639b0da6, 0x675a1011, 0x791d4014, 0x7ddc5da3, - 0x709f7b7a, 0x745e66cd, 0x9823b6e0, 0x9ce2ab57, 0x91a18d8e, 0x95609039, - 0x8b27c03c, 0x8fe6dd8b, 0x82a5fb52, 0x8664e6e5, 0xbe2b5b58, 0xbaea46ef, - 0xb7a96036, 0xb3687d81, 0xad2f2d84, 0xa9ee3033, 0xa4ad16ea, 0xa06c0b5d, - 0xd4326d90, 0xd0f37027, 0xddb056fe, 0xd9714b49, 0xc7361b4c, 0xc3f706fb, - 0xceb42022, 0xca753d95, 0xf23a8028, 0xf6fb9d9f, 0xfbb8bb46, 0xff79a6f1, - 0xe13ef6f4, 0xe5ffeb43, 0xe8bccd9a, 0xec7dd02d, 0x34867077, 0x30476dc0, - 0x3d044b19, 0x39c556ae, 0x278206ab, 0x23431b1c, 0x2e003dc5, 0x2ac12072, - 0x128e9dcf, 0x164f8078, 0x1b0ca6a1, 0x1fcdbb16, 0x018aeb13, 0x054bf6a4, - 0x0808d07d, 0x0cc9cdca, 0x7897ab07, 0x7c56b6b0, 0x71159069, 0x75d48dde, - 0x6b93dddb, 0x6f52c06c, 0x6211e6b5, 0x66d0fb02, 0x5e9f46bf, 0x5a5e5b08, - 0x571d7dd1, 0x53dc6066, 0x4d9b3063, 0x495a2dd4, 0x44190b0d, 0x40d816ba, - 0xaca5c697, 0xa864db20, 0xa527fdf9, 0xa1e6e04e, 0xbfa1b04b, 0xbb60adfc, - 0xb6238b25, 0xb2e29692, 0x8aad2b2f, 0x8e6c3698, 0x832f1041, 0x87ee0df6, - 0x99a95df3, 0x9d684044, 0x902b669d, 0x94ea7b2a, 0xe0b41de7, 0xe4750050, - 0xe9362689, 0xedf73b3e, 0xf3b06b3b, 0xf771768c, 0xfa325055, 0xfef34de2, - 0xc6bcf05f, 0xc27dede8, 0xcf3ecb31, 0xcbffd686, 0xd5b88683, 0xd1799b34, - 0xdc3abded, 0xd8fba05a, 0x690ce0ee, 0x6dcdfd59, 0x608edb80, 0x644fc637, - 0x7a089632, 0x7ec98b85, 0x738aad5c, 0x774bb0eb, 0x4f040d56, 0x4bc510e1, - 0x46863638, 0x42472b8f, 0x5c007b8a, 0x58c1663d, 0x558240e4, 0x51435d53, - 0x251d3b9e, 0x21dc2629, 0x2c9f00f0, 0x285e1d47, 0x36194d42, 0x32d850f5, - 0x3f9b762c, 0x3b5a6b9b, 0x0315d626, 0x07d4cb91, 0x0a97ed48, 0x0e56f0ff, - 0x1011a0fa, 0x14d0bd4d, 0x19939b94, 0x1d528623, 0xf12f560e, 0xf5ee4bb9, - 0xf8ad6d60, 0xfc6c70d7, 0xe22b20d2, 0xe6ea3d65, 0xeba91bbc, 0xef68060b, - 0xd727bbb6, 0xd3e6a601, 0xdea580d8, 0xda649d6f, 0xc423cd6a, 0xc0e2d0dd, - 0xcda1f604, 0xc960ebb3, 0xbd3e8d7e, 0xb9ff90c9, 0xb4bcb610, 0xb07daba7, - 0xae3afba2, 0xaafbe615, 0xa7b8c0cc, 0xa379dd7b, 0x9b3660c6, 0x9ff77d71, - 0x92b45ba8, 0x9675461f, 0x8832161a, 0x8cf30bad, 0x81b02d74, 0x857130c3, - 0x5d8a9099, 0x594b8d2e, 0x5408abf7, 0x50c9b640, 0x4e8ee645, 0x4a4ffbf2, - 0x470cdd2b, 0x43cdc09c, 0x7b827d21, 0x7f436096, 0x7200464f, 0x76c15bf8, - 0x68860bfd, 0x6c47164a, 0x61043093, 0x65c52d24, 0x119b4be9, 0x155a565e, - 0x18197087, 0x1cd86d30, 0x029f3d35, 0x065e2082, 0x0b1d065b, 0x0fdc1bec, - 0x3793a651, 0x3352bbe6, 0x3e119d3f, 0x3ad08088, 0x2497d08d, 0x2056cd3a, - 0x2d15ebe3, 0x29d4f654, 0xc5a92679, 0xc1683bce, 0xcc2b1d17, 0xc8ea00a0, - 0xd6ad50a5, 0xd26c4d12, 0xdf2f6bcb, 0xdbee767c, 0xe3a1cbc1, 0xe760d676, - 0xea23f0af, 0xeee2ed18, 0xf0a5bd1d, 0xf464a0aa, 0xf9278673, 0xfde69bc4, - 0x89b8fd09, 0x8d79e0be, 0x803ac667, 0x84fbdbd0, 0x9abc8bd5, 0x9e7d9662, - 0x933eb0bb, 0x97ffad0c, 0xafb010b1, 0xab710d06, 0xa6322bdf, 0xa2f33668, - 0xbcb4666d, 0xb8757bda, 0xb5365d03, 0xb1f740b4 -}; - -/* relicenced to LGPL from fluendo ts demuxer */ -static guint32 -mpegts_parse_calc_crc32 (guint8 * data, guint datalen) -{ - gint i; - guint32 crc = 0xffffffff; - - for (i = 0; i < datalen; i++) { - crc = (crc << 8) ^ crc_tab[((crc >> 24) ^ *data++) & 0xff]; - } - return crc; -} - -static void -mpegts_parse_base_init (gpointer klass) -{ - GstElementClass *element_class = GST_ELEMENT_CLASS (klass); - - gst_element_class_add_pad_template (element_class, - gst_static_pad_template_get (&sink_template)); - gst_element_class_add_pad_template (element_class, - gst_static_pad_template_get (&src_template)); - gst_element_class_add_pad_template (element_class, - gst_static_pad_template_get (&program_template)); - - gst_element_class_set_details (element_class, &mpegts_parse_details); -} - -static void -mpegts_parse_class_init (MpegTSParseClass * klass) -{ - GObjectClass *gobject_class; - GstElementClass *element_class; - - element_class = GST_ELEMENT_CLASS (klass); - element_class->pad_removed = mpegts_parse_pad_removed; - element_class->request_new_pad = mpegts_parse_request_new_pad; - element_class->release_pad = mpegts_parse_release_pad; - element_class->change_state = mpegts_parse_change_state; - - gobject_class = G_OBJECT_CLASS (klass); - gobject_class->set_property = mpegts_parse_set_property; - gobject_class->get_property = mpegts_parse_get_property; - gobject_class->dispose = mpegts_parse_dispose; - gobject_class->finalize = mpegts_parse_finalize; - - g_object_class_install_property (gobject_class, PROP_PROGRAM_NUMBERS, - g_param_spec_string ("program-numbers", - "Program Numbers", - "Colon separated list of programs", "", G_PARAM_READWRITE)); -} - -static gboolean -foreach_psi_pid_remove (gpointer key, gpointer value, gpointer data) -{ - return TRUE; -} - -static void -mpegts_parse_reset (MpegTSParse * parse) -{ - mpegts_packetizer_clear (parse->packetizer); - g_hash_table_foreach_remove (parse->psi_pids, foreach_psi_pid_remove, NULL); - - /* PAT */ - g_hash_table_insert (parse->psi_pids, - GINT_TO_POINTER (0), GINT_TO_POINTER (1)); - - /* pmt pids will be added and removed dynamically */ -} - -static void -mpegts_parse_init (MpegTSParse * parse, MpegTSParseClass * klass) -{ - parse->sinkpad = gst_pad_new_from_static_template (&sink_template, "sink"); - gst_pad_set_chain_function (parse->sinkpad, mpegts_parse_chain); - gst_pad_set_event_function (parse->sinkpad, mpegts_parse_sink_event); - gst_element_add_pad (GST_ELEMENT (parse), parse->sinkpad); - - parse->disposed = FALSE; - parse->packetizer = mpegts_packetizer_new (); - parse->program_numbers = g_strdup (""); - parse->pads_to_add = NULL; - parse->programs = g_hash_table_new_full (g_direct_hash, g_direct_equal, - NULL, (GDestroyNotify) mpegts_parse_free_program); - parse->psi_pids = g_hash_table_new (g_direct_hash, g_direct_equal); - mpegts_parse_reset (parse); -} - -static void -mpegts_parse_dispose (GObject * object) -{ - MpegTSParse *parse = GST_MPEGTS_PARSE (object); - - if (!parse->disposed) { - g_object_unref (parse->packetizer); - parse->disposed = TRUE; - } - - if (G_OBJECT_CLASS (parent_class)->dispose) - G_OBJECT_CLASS (parent_class)->dispose (object); -} - -static void -mpegts_parse_finalize (GObject * object) -{ - MpegTSParse *parse = GST_MPEGTS_PARSE (object); - - g_free (parse->program_numbers); - if (parse->pat) - gst_structure_free (parse->pat); - g_hash_table_destroy (parse->programs); - g_hash_table_destroy (parse->psi_pids); - - if (G_OBJECT_CLASS (parent_class)->finalize) - G_OBJECT_CLASS (parent_class)->finalize (object); -} - -static void -mpegts_parse_set_property (GObject * object, guint prop_id, - const GValue * value, GParamSpec * pspec) -{ - MpegTSParse *parse = GST_MPEGTS_PARSE (object); - - switch (prop_id) { - case PROP_PROGRAM_NUMBERS: - mpegts_parse_reset_selected_programs (parse, g_value_dup_string (value)); - break; - default: - G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); - } -} - -static void -mpegts_parse_get_property (GObject * object, guint prop_id, - GValue * value, GParamSpec * pspec) -{ - MpegTSParse *parse = GST_MPEGTS_PARSE (object); - - switch (prop_id) { - case PROP_PROGRAM_NUMBERS: - g_value_set_string (value, parse->program_numbers); - break; - default: - G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); - } -} - -static MpegTSParseProgram * -mpegts_parse_add_program (MpegTSParse * parse, - gint program_number, guint16 pmt_pid) -{ - MpegTSParseProgram *program; - - program = g_new0 (MpegTSParseProgram, 1); - program->program_number = program_number; - program->pmt_pid = pmt_pid; - program->pcr_pid = G_MAXUINT16; - program->streams = g_hash_table_new_full (g_direct_hash, g_direct_equal, - NULL, (GDestroyNotify) mpegts_parse_free_stream); - program->patcount = 1; - program->selected = 0; - program->active = FALSE; - - g_hash_table_insert (parse->programs, - GINT_TO_POINTER (program_number), program); - - return program; -} - -static MpegTSParseProgram * -mpegts_parse_get_program (MpegTSParse * parse, gint program_number) -{ - MpegTSParseProgram *program; - - program = (MpegTSParseProgram *) g_hash_table_lookup (parse->programs, - GINT_TO_POINTER ((gint) program_number)); - - return program; -} - -static GstPad * -mpegts_parse_activate_program (MpegTSParse * parse, - MpegTSParseProgram * program) -{ - MpegTSParsePad *tspad; - gchar *pad_name; - - pad_name = g_strdup_printf ("program_%d", program->program_number); - - tspad = mpegts_parse_create_tspad (parse, pad_name); - tspad->program_number = program->program_number; - tspad->program = program; - program->tspad = tspad; - g_free (pad_name); - gst_pad_set_active (tspad->pad, TRUE); - program->active = TRUE; - - return tspad->pad; -} - -static GstPad * -mpegts_parse_deactivate_program (MpegTSParse * parse, - MpegTSParseProgram * program) -{ - MpegTSParsePad *tspad; - - tspad = program->tspad; - gst_pad_set_active (tspad->pad, FALSE); - program->active = FALSE; - - /* tspad will be destroyed in GstElementClass::pad_removed */ - - return tspad->pad; -} - -static void -mpegts_parse_free_program (MpegTSParseProgram * program) -{ - if (program->pmt_info) - gst_structure_free (program->pmt_info); - - g_hash_table_destroy (program->streams); - - g_free (program); -} - -static void -mpegts_parse_remove_program (MpegTSParse * parse, gint program_number) -{ - g_hash_table_remove (parse->programs, GINT_TO_POINTER (program_number)); -} - -static void -mpegts_parse_sync_program_pads (MpegTSParse * parse, - GList * to_add, GList * to_remove) -{ - GList *walk; - - for (walk = to_remove; walk; walk = walk->next) - gst_element_remove_pad (GST_ELEMENT (parse), GST_PAD (walk->data)); - - for (walk = to_add; walk; walk = walk->next) - gst_element_add_pad (GST_ELEMENT (parse), GST_PAD (walk->data)); - - if (to_add) - g_list_free (to_add); - - if (to_remove) - g_list_free (to_remove); -} - - -static MpegTSParseStream * -mpegts_parse_program_add_stream (MpegTSParse * parse, - MpegTSParseProgram * program, guint16 pid, guint8 stream_type) -{ - MpegTSParseStream *stream; - - stream = g_new0 (MpegTSParseStream, 1); - stream->pid = pid; - stream->stream_type = stream_type; - - g_hash_table_insert (program->streams, GINT_TO_POINTER ((gint) pid), stream); - - return stream; -} - -static void -foreach_program_activate_or_deactivate (gpointer key, gpointer value, - gpointer data) -{ - MpegTSParse *parse = GST_MPEGTS_PARSE (data); - MpegTSParseProgram *program = (MpegTSParseProgram *) value; - - /* at this point selected programs have program->selected == 2, - * unselected programs thay may have to be deactivated have selected == 1 and - * unselected inactive programs have selected == 0 */ - - switch (--program->selected) { - case 1: - /* selected */ - if (!program->active && program->pmt_pid != G_MAXUINT16) - parse->pads_to_add = g_list_append (parse->pads_to_add, - mpegts_parse_activate_program (parse, program)); - break; - case 0: - /* unselected */ - if (program->active) - parse->pads_to_remove = g_list_append (parse->pads_to_remove, - mpegts_parse_deactivate_program (parse, program)); - break; - case -1: - /* was already unselected */ - program->selected = 0; - break; - default: - g_return_if_reached (); - } -} - -static void -mpegts_parse_reset_selected_programs (MpegTSParse * parse, - gchar * program_numbers) -{ - GList *pads_to_add = NULL; - GList *pads_to_remove = NULL; - - GST_OBJECT_LOCK (parse); - if (parse->program_numbers) - g_free (parse->program_numbers); - - parse->program_numbers = program_numbers; - - if (*parse->program_numbers != '\0') { - gint program_number; - MpegTSParseProgram *program; - gchar **progs, **walk; - - progs = g_strsplit (parse->program_numbers, ":", 0); - - walk = progs; - while (*walk != NULL) { - program_number = strtol (*walk, NULL, 0); - program = mpegts_parse_get_program (parse, program_number); - if (program == NULL) - /* create the program, it will get activated once we get a PMT for it */ - program = mpegts_parse_add_program (parse, program_number, G_MAXUINT16); - - program->selected = 2; - ++walk; - } - g_strfreev (progs); - } - - g_hash_table_foreach (parse->programs, - foreach_program_activate_or_deactivate, parse); - - pads_to_add = parse->pads_to_add; - parse->pads_to_add = NULL; - pads_to_remove = parse->pads_to_remove; - parse->pads_to_remove = NULL; - GST_OBJECT_UNLOCK (parse); - - mpegts_parse_sync_program_pads (parse, pads_to_add, pads_to_remove); -} - -static void -mpegts_parse_free_stream (MpegTSParseStream * stream) -{ - g_free (stream); -} - -static void -mpegts_parse_program_remove_stream (MpegTSParse * parse, - MpegTSParseProgram * program, guint16 pid) -{ - g_hash_table_remove (program->streams, GINT_TO_POINTER ((gint) pid)); -} - -static MpegTSParsePad * -mpegts_parse_create_tspad (MpegTSParse * parse, const gchar * pad_name) -{ - GstPad *pad; - MpegTSParsePad *tspad; - - pad = gst_pad_new_from_static_template (&program_template, pad_name); - gst_pad_set_query_function (pad, - GST_DEBUG_FUNCPTR (mpegts_parse_src_pad_query)); - - /* create our wrapper */ - tspad = g_new0 (MpegTSParsePad, 1); - tspad->pad = pad; - tspad->program_number = -1; - tspad->program = NULL; - tspad->pushed = FALSE; - tspad->flow_return = GST_FLOW_NOT_LINKED; - gst_pad_set_element_private (pad, tspad); - - return tspad; -} - -static void -mpegts_parse_destroy_tspad (MpegTSParse * parse, MpegTSParsePad * tspad) -{ - /* free the wrapper */ - g_free (tspad); -} - -static void -mpegts_parse_pad_removed (GstElement * element, GstPad * pad) -{ - MpegTSParsePad *tspad; - MpegTSParse *parse = GST_MPEGTS_PARSE (element); - - if (gst_pad_get_direction (pad) == GST_PAD_SINK) - return; - - tspad = (MpegTSParsePad *) gst_pad_get_element_private (pad); - mpegts_parse_destroy_tspad (parse, tspad); - - if (GST_ELEMENT_CLASS (parent_class)->pad_removed) - GST_ELEMENT_CLASS (parent_class)->pad_removed (element, pad); -} - -static GstPad * -mpegts_parse_request_new_pad (GstElement * element, GstPadTemplate * template, - const gchar * unused) -{ - MpegTSParse *parse; - gchar *name; - GstPad *pad; - - g_return_val_if_fail (template != NULL, NULL); - g_return_val_if_fail (GST_IS_MPEGTS_PARSE (element), NULL); - - parse = GST_MPEGTS_PARSE (element); - - GST_OBJECT_LOCK (element); - name = g_strdup_printf ("src%d", parse->req_pads++); - GST_OBJECT_UNLOCK (element); - - pad = mpegts_parse_create_tspad (parse, name)->pad; - gst_pad_set_active (pad, TRUE); - gst_element_add_pad (element, pad); - - return pad; -} - -static void -mpegts_parse_release_pad (GstElement * element, GstPad * pad) -{ - g_return_if_fail (GST_IS_MPEGTS_PARSE (element)); - - gst_pad_set_active (pad, FALSE); - /* we do the cleanup in GstElement::pad-removed */ - gst_element_remove_pad (element, pad); -} - -static GstFlowReturn -mpegts_parse_tspad_push_section (MpegTSParse * parse, MpegTSParsePad * tspad, - MpegTSPacketizerSection * section, GstBuffer * buffer) -{ - GstFlowReturn ret = GST_FLOW_NOT_LINKED; - gboolean to_push = TRUE; - - if (tspad->program_number != -1) { - if (tspad->program) { - /* we push all sections to all pads except PMTs which we - * only push to pads meant to receive that program number */ - if (section->table_id == 0x02) { - /* PMT */ - if (section->subtable_extension != tspad->program_number) - to_push = FALSE; - } - } else { - /* there's a program filter on the pad but the PMT for the program has not - * been parsed yet, ignore the pad until we get a PMT */ - to_push = FALSE; - ret = GST_FLOW_OK; - } - } - GST_DEBUG_OBJECT (parse, - "pushing section: %d program number: %d table_id: %d", to_push, - tspad->program_number, section->table_id); - if (to_push) { - ret = gst_pad_push (tspad->pad, buffer); - } else { - gst_buffer_unref (buffer); - if (gst_pad_is_linked (tspad->pad)) - ret = GST_FLOW_OK; - } - - return ret; -} - -static GstFlowReturn -mpegts_parse_tspad_push (MpegTSParse * parse, MpegTSParsePad * tspad, - guint16 pid, GstBuffer * buffer) -{ - GstFlowReturn ret = GST_FLOW_NOT_LINKED; - GHashTable *pad_pids = NULL; - - if (tspad->program_number != -1) { - if (tspad->program) { - pad_pids = tspad->program->streams; - } else { - /* there's a program filter on the pad but the PMT for the program has not - * been parsed yet, ignore the pad until we get a PMT */ - gst_buffer_unref (buffer); - ret = GST_FLOW_OK; - goto out; - } - } - - if (pad_pids == NULL || - g_hash_table_lookup (pad_pids, GINT_TO_POINTER ((gint) pid)) != NULL) { - /* push if there's no filter or if the pid is in the filter */ - ret = gst_pad_push (tspad->pad, buffer); - } else { - gst_buffer_unref (buffer); - if (gst_pad_is_linked (tspad->pad)) - ret = GST_FLOW_OK; - } - -out: - return ret; -} - -static void -pad_clear_for_push (GstPad * pad, MpegTSParse * parse) -{ - MpegTSParsePad *tspad = (MpegTSParsePad *) gst_pad_get_element_private (pad); - - tspad->flow_return = GST_FLOW_NOT_LINKED; - tspad->pushed = FALSE; -} - -static GstFlowReturn -mpegts_parse_push (MpegTSParse * parse, MpegTSPacketizerPacket * packet, - MpegTSPacketizerSection * section) -{ - GstIterator *iterator; - gboolean done = FALSE; - gpointer pad = NULL; - MpegTSParsePad *tspad; - guint16 pid; - GstBuffer *buffer; - GstFlowReturn ret; - GstCaps *caps; - - pid = packet->pid; - buffer = packet->buffer; - /* we have the same caps on all the src pads */ - caps = gst_static_pad_template_get_caps (&src_template); - gst_buffer_set_caps (buffer, caps); - gst_caps_unref (caps); - - GST_OBJECT_LOCK (parse); - /* clear tspad->pushed on pads */ - g_list_foreach (GST_ELEMENT_CAST (parse)->srcpads, - (GFunc) pad_clear_for_push, parse); - if (GST_ELEMENT_CAST (parse)->srcpads) - ret = GST_FLOW_NOT_LINKED; - else - ret = GST_FLOW_OK; - GST_OBJECT_UNLOCK (parse); - - iterator = gst_element_iterate_src_pads (GST_ELEMENT_CAST (parse)); - while (!done) { - switch (gst_iterator_next (iterator, &pad)) { - case GST_ITERATOR_OK: - tspad = gst_pad_get_element_private (GST_PAD (pad)); - - /* make sure to push only once if the iterator resyncs */ - if (!tspad->pushed) { - /* ref the buffer as gst_pad_push takes a ref but we want to reuse the - * same buffer for next pushes */ - gst_buffer_ref (buffer); - if (section) { - tspad->flow_return = - mpegts_parse_tspad_push_section (parse, tspad, section, buffer); - } else { - tspad->flow_return = - mpegts_parse_tspad_push (parse, tspad, pid, buffer); - } - tspad->pushed = TRUE; - - if (GST_FLOW_IS_FATAL (tspad->flow_return)) { - /* return the error upstream */ - ret = tspad->flow_return; - done = TRUE; - } - } - - if (ret == GST_FLOW_NOT_LINKED) - ret = tspad->flow_return; - - /* the iterator refs the pad */ - g_object_unref (GST_PAD (pad)); - break; - case GST_ITERATOR_RESYNC: - gst_iterator_resync (iterator); - break; - case GST_ITERATOR_DONE: - done = TRUE; - break; - default: - g_warning ("this should not be reached"); - } - } - - gst_iterator_free (iterator); - - gst_buffer_unref (buffer); - packet->buffer = NULL; - - return ret; -} - -static gboolean -mpegts_parse_is_psi (MpegTSParse * parse, MpegTSPacketizerPacket * packet) -{ - gboolean retval = FALSE; - guint8 table_id; - int i; - guint8 si_tables[] = { 0x00, 0x01, 0x02, 0x03, 0x40, 0x41, 0x42, 0x46, 0x4A, - 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, 0x7E, 0x7F, TABLE_ID_UNSET - }; - if (g_hash_table_lookup (parse->psi_pids, - GINT_TO_POINTER ((gint) packet->pid)) != NULL) - retval = TRUE; - if (!retval) { - if (packet->payload_unit_start_indicator) { - table_id = *(packet->data); - i = 0; - while (si_tables[i] != TABLE_ID_UNSET) { - if (si_tables[i] == table_id) { - GST_DEBUG_OBJECT (parse, "Packet has table id 0x%x", table_id); - retval = TRUE; - break; - } - i++; - } - } else { - MpegTSPacketizerStream *stream = (MpegTSPacketizerStream *) - g_hash_table_lookup (parse->packetizer->streams, - GINT_TO_POINTER ((gint) packet->pid)); - - if (stream) { - i = 0; - GST_DEBUG_OBJECT (parse, "section table id: 0x%x", - stream->section_table_id); - while (si_tables[i] != TABLE_ID_UNSET) { - if (si_tables[i] == stream->section_table_id) { - retval = TRUE; - break; - } - i++; - } - } - } - } - GST_DEBUG_OBJECT (parse, "Packet of pid 0x%x is psi: %d", packet->pid, - retval); - return retval; -} - -static void -mpegts_parse_apply_pat (MpegTSParse * parse, GstStructure * pat_info) -{ - const GValue *value; - GstStructure *old_pat; - GstStructure *program_info; - guint program_number; - guint pid; - MpegTSParseProgram *program; - gint i; - GList *pads_to_add = NULL; - GList *pads_to_remove = NULL; - const GValue *programs; - gchar *dbg; - - old_pat = parse->pat; - parse->pat = pat_info; - - dbg = gst_structure_to_string (pat_info); - GST_INFO_OBJECT (parse, "PAT %s", dbg); - g_free (dbg); - - gst_element_post_message (GST_ELEMENT_CAST (parse), - gst_message_new_element (GST_OBJECT (parse), - gst_structure_copy (pat_info))); - - GST_OBJECT_LOCK (parse); - programs = gst_structure_get_value (pat_info, "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); - - program = mpegts_parse_get_program (parse, program_number); - if (program) { - if (program->pmt_pid != pid) { - if (program->pmt_pid != G_MAXUINT16) { - /* pmt pid changed */ - g_hash_table_remove (parse->psi_pids, - GINT_TO_POINTER ((gint) program->pmt_pid)); - } - - program->pmt_pid = pid; - g_hash_table_insert (parse->psi_pids, - GINT_TO_POINTER ((gint) pid), GINT_TO_POINTER (1)); - } - - program->patcount += 1; - } else { - g_hash_table_insert (parse->psi_pids, - GINT_TO_POINTER ((gint) pid), GINT_TO_POINTER (1)); - program = mpegts_parse_add_program (parse, program_number, pid); - } - - if (program->selected && !program->active) - parse->pads_to_add = g_list_append (parse->pads_to_add, - mpegts_parse_activate_program (parse, program)); - } - - if (old_pat) { - /* deactivate the old table */ - - programs = gst_structure_get_value (old_pat, "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); - - program = mpegts_parse_get_program (parse, program_number); - if (program == NULL) { - GST_DEBUG_OBJECT (parse, "broken PAT, duplicated entry for program %d", - program_number); - continue; - } - - if (--program->patcount > 0) - /* the program has been referenced by the new pat, keep it */ - continue; - - { - gchar *dbg = gst_structure_to_string (program_info); - - GST_INFO_OBJECT (parse, "PAT removing program %s", dbg); - g_free (dbg); - } - - if (program->active) - parse->pads_to_remove = g_list_append (parse->pads_to_remove, - mpegts_parse_deactivate_program (parse, program)); - - mpegts_parse_remove_program (parse, program_number); - g_hash_table_remove (parse->psi_pids, GINT_TO_POINTER ((gint) pid)); - } - - gst_structure_free (old_pat); - } - - pads_to_add = parse->pads_to_add; - parse->pads_to_add = NULL; - pads_to_remove = parse->pads_to_remove; - parse->pads_to_remove = NULL; - GST_OBJECT_UNLOCK (parse); - - mpegts_parse_sync_program_pads (parse, pads_to_add, pads_to_remove); -} - -static void -mpegts_parse_apply_pmt (MpegTSParse * parse, - guint16 pmt_pid, GstStructure * pmt_info) -{ - MpegTSParseProgram *program; - guint program_number; - guint pcr_pid; - guint pid; - guint stream_type; - GstStructure *stream; - gint i; - const GValue *old_streams; - 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_OBJECT_LOCK (parse); - program = mpegts_parse_get_program (parse, program_number); - if (program) { - if (program->pmt_info) { - /* deactivate old pmt */ - old_streams = gst_structure_get_value (program->pmt_info, "streams"); - - for (i = 0; i < gst_value_list_get_size (old_streams); ++i) { - value = gst_value_list_get_value (old_streams, i); - stream = g_value_get_boxed (value); - - gst_structure_get_uint (stream, "pid", &pid); - gst_structure_get_uint (stream, "stream-type", &stream_type); - mpegts_parse_program_remove_stream (parse, program, (guint16) pid); - } - /* remove pcr stream */ - mpegts_parse_program_remove_stream (parse, program, program->pcr_pid); - gst_structure_free (program->pmt_info); - } - } else { - /* no PAT?? */ - g_hash_table_insert (parse->psi_pids, - GINT_TO_POINTER ((gint) pmt_pid), GINT_TO_POINTER (1)); - program = mpegts_parse_add_program (parse, program_number, pid); - } - - /* activate new pmt */ - program->pmt_info = pmt_info; - program->pmt_pid = pmt_pid; - program->pcr_pid = pcr_pid; - mpegts_parse_program_add_stream (parse, program, (guint16) pcr_pid, -1); - - for (i = 0; i < gst_value_list_get_size (new_streams); ++i) { - 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); - mpegts_parse_program_add_stream (parse, program, - (guint16) pid, (guint8) stream_type); - } - GST_OBJECT_UNLOCK (parse); - - { - gchar *dbg = gst_structure_to_string (pmt_info); - - GST_DEBUG_OBJECT (parse, "new pmt %s", dbg); - g_free (dbg); - } - - gst_element_post_message (GST_ELEMENT_CAST (parse), - gst_message_new_element (GST_OBJECT (parse), - gst_structure_copy (pmt_info))); -} - -static void -mpegts_parse_apply_nit (MpegTSParse * parse, - guint16 pmt_pid, GstStructure * nit_info) -{ - gst_element_post_message (GST_ELEMENT_CAST (parse), - gst_message_new_element (GST_OBJECT (parse), - gst_structure_copy (nit_info))); -} - -static void -mpegts_parse_apply_sdt (MpegTSParse * parse, - guint16 pmt_pid, GstStructure * sdt_info) -{ - gst_element_post_message (GST_ELEMENT_CAST (parse), - gst_message_new_element (GST_OBJECT (parse), - gst_structure_copy (sdt_info))); -} - -static void -mpegts_parse_apply_eit (MpegTSParse * parse, - guint16 pmt_pid, GstStructure * eit_info) -{ - gst_element_post_message (GST_ELEMENT_CAST (parse), - gst_message_new_element (GST_OBJECT (parse), - gst_structure_copy (eit_info))); -} - -static gboolean -mpegts_parse_handle_psi (MpegTSParse * parse, MpegTSPacketizerSection * section) -{ - gboolean res = TRUE; - GstStructure *structure = NULL; - - if (mpegts_parse_calc_crc32 (GST_BUFFER_DATA (section->buffer), - GST_BUFFER_SIZE (section->buffer)) != 0) { - GST_WARNING_OBJECT (parse, "bad crc in psi pid 0x%x", section->pid); - return FALSE; - } - - switch (section->table_id) { - case 0x00: - /* PAT */ - structure = mpegts_packetizer_parse_pat (parse->packetizer, section); - if (structure) - mpegts_parse_apply_pat (parse, structure); - else - res = FALSE; - - break; - case 0x02: - structure = mpegts_packetizer_parse_pmt (parse->packetizer, section); - if (structure) - mpegts_parse_apply_pmt (parse, section->pid, structure); - else - res = FALSE; - - break; - case 0x40: - /* NIT, actual network */ - case 0x41: - /* NIT, other network */ - structure = mpegts_packetizer_parse_nit (parse->packetizer, section); - if (structure) - mpegts_parse_apply_nit (parse, section->pid, structure); - else - res = FALSE; - - break; - case 0x42: - case 0x46: - structure = mpegts_packetizer_parse_sdt (parse->packetizer, section); - if (structure) - mpegts_parse_apply_sdt (parse, section->pid, structure); - else - res = FALSE; - break; - case 0x4E: - case 0x4F: - /* EIT, present/following */ - case 0x50: - case 0x51: - case 0x52: - case 0x53: - case 0x54: - case 0x55: - case 0x56: - case 0x57: - case 0x58: - case 0x59: - case 0x5A: - case 0x5B: - case 0x5C: - case 0x5D: - case 0x5E: - case 0x5F: - case 0x60: - case 0x61: - case 0x62: - case 0x63: - case 0x64: - case 0x65: - case 0x66: - case 0x67: - case 0x68: - case 0x69: - case 0x6A: - case 0x6B: - case 0x6C: - case 0x6D: - case 0x6E: - case 0x6F: - /* EIT, schedule */ - structure = mpegts_packetizer_parse_eit (parse->packetizer, section); - if (structure) - mpegts_parse_apply_eit (parse, section->pid, structure); - else - res = FALSE; - break; - default: - break; - } - - if (structure) - gst_structure_free (structure); - - return res; -} - -static gboolean -mpegts_parse_sink_event (GstPad * pad, GstEvent * event) -{ - gboolean res; - MpegTSParse *parse = - GST_MPEGTS_PARSE (gst_object_get_parent (GST_OBJECT (pad))); - - switch (GST_EVENT_TYPE (event)) { - case GST_EVENT_FLUSH_STOP: - mpegts_packetizer_clear (parse->packetizer); - res = gst_pad_event_default (pad, event); - break; - default: - res = gst_pad_event_default (pad, event); - } - - gst_object_unref (parse); - return res; -} - -static GstFlowReturn -mpegts_parse_chain (GstPad * pad, GstBuffer * buf) -{ - GstFlowReturn res = GST_FLOW_OK; - MpegTSParse *parse; - gboolean parsed; - MpegTSPacketizer *packetizer; - MpegTSPacketizerPacket packet; - - parse = GST_MPEGTS_PARSE (gst_object_get_parent (GST_OBJECT (pad))); - packetizer = parse->packetizer; - - mpegts_packetizer_push (parse->packetizer, buf); - while (mpegts_packetizer_has_packets (parse->packetizer) && - !GST_FLOW_IS_FATAL (res)) { - /* get the next packet */ - parsed = mpegts_packetizer_next_packet (packetizer, &packet); - if (!parsed) - /* bad header, skip the packet */ - goto next; - - /* parse PSI data */ - if (packet.payload != NULL && mpegts_parse_is_psi (parse, &packet)) { - MpegTSPacketizerSection section; - - parsed = mpegts_packetizer_push_section (packetizer, &packet, §ion); - if (!parsed) - /* bad section data */ - goto next; - - if (section.complete) { - /* section complete */ - parsed = mpegts_parse_handle_psi (parse, §ion); - gst_buffer_unref (section.buffer); - - if (!parsed) - /* bad PSI table */ - goto next; - } - /* we need to push section packet downstream */ - res = mpegts_parse_push (parse, &packet, §ion); - - } else { - /* push the packet downstream */ - res = mpegts_parse_push (parse, &packet, NULL); - } - - next: - mpegts_packetizer_clear_packet (parse->packetizer, &packet); - } - - gst_object_unref (parse); - return res; -} - -static GstStateChangeReturn -mpegts_parse_change_state (GstElement * element, GstStateChange transition) -{ - MpegTSParse *parse; - GstStateChangeReturn ret; - - parse = GST_MPEGTS_PARSE (element); - ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition); - - switch (transition) { - case GST_STATE_CHANGE_PAUSED_TO_READY: - mpegts_parse_reset (parse); - break; - default: - break; - } - - return ret; -} - -static gboolean -mpegts_parse_src_pad_query (GstPad * pad, GstQuery * query) -{ - MpegTSParse *parse = GST_MPEGTS_PARSE (gst_pad_get_parent (pad)); - gboolean res; - - switch (GST_QUERY_TYPE (query)) { - case GST_QUERY_LATENCY: - { - if ((res = gst_pad_peer_query (parse->sinkpad, query))) { - gboolean is_live; - GstClockTime min_latency, max_latency; - - gst_query_parse_latency (query, &is_live, &min_latency, &max_latency); - if (is_live) { - min_latency += TS_LATENCY * GST_MSECOND; - if (max_latency != GST_CLOCK_TIME_NONE) - max_latency += TS_LATENCY * GST_MSECOND; - } - - gst_query_set_latency (query, is_live, min_latency, max_latency); - } - - break; - } - default: - res = gst_pad_query_default (pad, query); - } - - return res; -} - -static gboolean -plugin_init (GstPlugin * plugin) -{ - GST_DEBUG_CATEGORY_INIT (mpegts_parse_debug, "mpegtsparse", 0, - "MPEG transport stream parser"); - - mpegts_packetizer_init_debug (); - gst_mpegtsdesc_init_debug (); - - return gst_element_register (plugin, "mpegtsparse", - GST_RANK_NONE, GST_TYPE_MPEGTS_PARSE); -} - -GST_PLUGIN_DEFINE (GST_VERSION_MAJOR, - GST_VERSION_MINOR, - "mpegtsparse", - "MPEG-2 transport stream parser", - plugin_init, VERSION, GST_LICENSE, GST_PACKAGE_NAME, GST_PACKAGE_ORIGIN) diff --git a/gst/mpegtsparse/mpegtsparse.h b/gst/mpegtsparse/mpegtsparse.h deleted file mode 100644 index 60f079aba..000000000 --- a/gst/mpegtsparse/mpegtsparse.h +++ /dev/null @@ -1,81 +0,0 @@ -/* - * mpegts_parse.h - GStreamer MPEG transport stream parser - * Copyright (C) 2007 Alessandro Decina - * - * Authors: - * Alessandro Decina <alessandro@nnva.org> - * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Library General Public - * License as published by the Free Software Foundation; either - * version 2 of the License, or (at your option) any later version. - * - * This library 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 - * Library General Public License for more details. - * - * You should have received a copy of the GNU Library General Public - * License along with this library; if not, write to the - * Free Software Foundation, Inc., 59 Temple Place - Suite 330, - * Boston, MA 02111-1307, USA. - */ - - -#ifndef GST_MPEG_TS_PARSE_H -#define GST_MPEG_TS_PARSE_H - -#include <gst/gst.h> -#include "mpegtspacketizer.h" - -G_BEGIN_DECLS - -#define GST_TYPE_MPEGTS_PARSE \ - (mpegts_parse_get_type()) -#define GST_MPEGTS_PARSE(obj) \ - (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_MPEGTS_PARSE,MpegTSParse)) -#define GST_MPEGTS_PARSE_CLASS(klass) \ - (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_MPEGTS_PARSE,MpegTSParseClass)) -#define GST_IS_MPEGTS_PARSE(obj) \ - (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_MPEGTS_PARSE)) -#define GST_IS_MPEGTS_PARSE_CLASS(klass) \ - (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_MPEGTS_PARSE)) - -typedef struct _MpegTSParse MpegTSParse; -typedef struct _MpegTSParseClass MpegTSParseClass; - -struct _MpegTSParse { - GstElement element; - - GstPad *sinkpad; - - /* the following vars must be protected with the OBJECT_LOCK as they can be - * accessed from the application thread and the streaming thread */ - gchar *program_numbers; - GList *pads_to_add; - GList *pads_to_remove; - GHashTable *programs; - guint req_pads; - - GstStructure *pat; - MpegTSPacketizer *packetizer; - GHashTable *psi_pids; - gboolean disposed; -}; - -struct _MpegTSParseClass { - GstElementClass parent_class; - - /* signals */ - void (*pat_info) (GstStructure *pat); - void (*pmt_info) (GstStructure *pmt); - void (*nit_info) (GstStructure *nit); - void (*sdt_info) (GstStructure *sdt); - void (*eit_info) (GstStructure *eit); -}; - -GType gst_mpegts_parse_get_type(void); - -G_END_DECLS - -#endif /* GST_MPEG_TS_PARSE_H */ diff --git a/gst/mpegtsparse/mpegtsparsemarshal.list b/gst/mpegtsparse/mpegtsparsemarshal.list deleted file mode 100644 index 41e7f2b59..000000000 --- a/gst/mpegtsparse/mpegtsparsemarshal.list +++ /dev/null @@ -1 +0,0 @@ -VOID:INT,OBJECT |