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

mxfdemux: Use a RW lock to protect metadata and add all pads at once without a lock held

Browse source 
This makes it possible, among other things, to do a query in the
pad-added callback.

Fixes bug #582656.
This commit is contained in:
Sebastian Dröge 2009-05-14 21:20:47 +02:00
parent e62b64f1d3
commit f5ba4904f7
2 changed files with 93 additions and 70 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

161
gst/mxf/mxfdemux.c
View file

@ -203,7 +203,7 @@ gst_mxf_demux_reset_metadata (GstMXFDemux * demux)
{ {
GST_DEBUG_OBJECT (demux, "Resetting metadata"); GST_DEBUG_OBJECT (demux, "Resetting metadata");
g_mutex_lock (demux->metadata_lock); g_static_rw_lock_writer_lock (&demux->metadata_lock);
demux->update_metadata = TRUE; demux->update_metadata = TRUE;
demux->metadata_resolved = FALSE; demux->metadata_resolved = FALSE;
@ -217,7 +217,7 @@ gst_mxf_demux_reset_metadata (GstMXFDemux * demux)
} }
demux->metadata = mxf_metadata_hash_table_new (); demux->metadata = mxf_metadata_hash_table_new ();
g_mutex_unlock (demux->metadata_lock); g_static_rw_lock_writer_unlock (&demux->metadata_lock);
} }
static void static void
@ -513,11 +513,14 @@ gst_mxf_demux_resolve_references (GstMXFDemux * demux)
GstStructure *structure; GstStructure *structure;
GstTagList *taglist; GstTagList *taglist;
g_static_rw_lock_writer_lock (&demux->metadata_lock);
GST_DEBUG_OBJECT (demux, "Resolve metadata references"); GST_DEBUG_OBJECT (demux, "Resolve metadata references");
demux->update_metadata = FALSE; demux->update_metadata = FALSE;
if (!demux->metadata) { if (!demux->metadata) {
GST_ERROR_OBJECT (demux, "No metadata yet"); GST_ERROR_OBJECT (demux, "No metadata yet");
g_static_rw_lock_writer_unlock (&demux->metadata_lock);
return GST_FLOW_ERROR; return GST_FLOW_ERROR;
} }
#if GLIB_CHECK_VERSION (2, 16, 0) #if GLIB_CHECK_VERSION (2, 16, 0)
@ -565,6 +568,8 @@ gst_mxf_demux_resolve_references (GstMXFDemux * demux)
g_list_free (values); g_list_free (values);
#endif #endif
g_static_rw_lock_writer_unlock (&demux->metadata_lock);
return ret; return ret;
error: error:
@ -573,6 +578,7 @@ error:
#endif #endif
demux->metadata_resolved = FALSE; demux->metadata_resolved = FALSE;
g_static_rw_lock_writer_unlock (&demux->metadata_lock);
return ret; return ret;
} }
@ -913,24 +919,29 @@ gst_mxf_demux_update_tracks (GstMXFDemux * demux)
gboolean first_run; gboolean first_run;
guint component_index; guint component_index;
GstFlowReturn ret; GstFlowReturn ret;
GList *pads = NULL, *l;
g_static_rw_lock_writer_lock (&demux->metadata_lock);
GST_DEBUG_OBJECT (demux, "Updating tracks"); GST_DEBUG_OBJECT (demux, "Updating tracks");
if ((ret = gst_mxf_demux_update_essence_tracks (demux)) != GST_FLOW_OK) { if ((ret = gst_mxf_demux_update_essence_tracks (demux)) != GST_FLOW_OK) {
return ret; goto error;
} }
current_package = gst_mxf_demux_choose_package (demux); current_package = gst_mxf_demux_choose_package (demux);
if (!current_package) { if (!current_package) {
GST_ERROR_OBJECT (demux, "Unable to find current package"); GST_ERROR_OBJECT (demux, "Unable to find current package");
return GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto error;
} else if (!current_package->tracks) { } else if (!current_package->tracks) {
GST_ERROR_OBJECT (demux, "Current package has no (resolved) tracks"); GST_ERROR_OBJECT (demux, "Current package has no (resolved) tracks");
return GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto error;
} else if (!current_package->n_essence_tracks) { } else if (!current_package->n_essence_tracks) {
GST_ERROR_OBJECT (demux, "Current package has no essence tracks"); GST_ERROR_OBJECT (demux, "Current package has no essence tracks");
return GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto error;
} }
first_run = (demux->src->len == 0); first_run = (demux->src->len == 0);
@ -977,10 +988,12 @@ gst_mxf_demux_update_tracks (GstMXFDemux * demux)
if (!track->parent.sequence) { if (!track->parent.sequence) {
GST_WARNING_OBJECT (demux, "Track with no sequence"); GST_WARNING_OBJECT (demux, "Track with no sequence");
if (!pad) if (!pad) {
continue; continue;
else } else {
return GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto error;
}
} }
sequence = track->parent.sequence; sequence = track->parent.sequence;
@ -1021,20 +1034,24 @@ gst_mxf_demux_update_tracks (GstMXFDemux * demux)
if (track->parent.type && (track->parent.type & 0xf0) != 0x30) { if (track->parent.type && (track->parent.type & 0xf0) != 0x30) {
GST_DEBUG_OBJECT (demux, "No essence track"); GST_DEBUG_OBJECT (demux, "No essence track");
if (!pad) if (!pad) {
continue; continue;
else } else {
return GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto error;
}
} }
if (!source_package || track->parent.type == MXF_METADATA_TRACK_UNKNOWN if (!source_package || track->parent.type == MXF_METADATA_TRACK_UNKNOWN
|| !source_track) { || !source_track) {
GST_WARNING_OBJECT (demux, GST_WARNING_OBJECT (demux,
"No source package or track type for track found"); "No source package or track type for track found");
if (!pad) if (!pad) {
continue; continue;
else } else {
return GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto error;
}
} }
for (k = 0; k < demux->essence_tracks->len; k++) { for (k = 0; k < demux->essence_tracks->len; k++) {
@ -1050,44 +1067,54 @@ gst_mxf_demux_update_tracks (GstMXFDemux * demux)
if (!etrack) { if (!etrack) {
GST_WARNING_OBJECT (demux, "No essence track for this track found"); GST_WARNING_OBJECT (demux, "No essence track for this track found");
if (!pad) if (!pad) {
continue; continue;
else } else {
return GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto error;
}
} }
if (track->edit_rate.n <= 0 || track->edit_rate.d <= 0 || if (track->edit_rate.n <= 0 || track->edit_rate.d <= 0 ||
source_track->edit_rate.n <= 0 || source_track->edit_rate.d <= 0) { source_track->edit_rate.n <= 0 || source_track->edit_rate.d <= 0) {
GST_WARNING_OBJECT (demux, "Track has an invalid edit rate"); GST_WARNING_OBJECT (demux, "Track has an invalid edit rate");
if (!pad) if (!pad) {
continue; continue;
else } else {
return GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto error;
}
} }
if (MXF_IS_METADATA_MATERIAL_PACKAGE (current_package) && !component) { if (MXF_IS_METADATA_MATERIAL_PACKAGE (current_package) && !component) {
GST_WARNING_OBJECT (demux, GST_WARNING_OBJECT (demux,
"Playing material package but found no component for track"); "Playing material package but found no component for track");
if (!pad) if (!pad) {
continue; continue;
else } else {
return GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto error;
}
} }
if (!source_package->descriptor) { if (!source_package->descriptor) {
GST_WARNING_OBJECT (demux, "Source package has no descriptors"); GST_WARNING_OBJECT (demux, "Source package has no descriptors");
if (!pad) if (!pad) {
continue; continue;
else } else {
return GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto error;
}
} }
if (!source_track->parent.descriptor) { if (!source_track->parent.descriptor) {
GST_WARNING_OBJECT (demux, "No descriptor found for track"); GST_WARNING_OBJECT (demux, "No descriptor found for track");
if (!pad) if (!pad) {
continue; continue;
else } else {
return GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto error;
}
} }
if (!pad && first_run) { if (!pad && first_run) {
@ -1178,31 +1205,43 @@ gst_mxf_demux_update_tracks (GstMXFDemux * demux)
gst_pad_use_fixed_caps (GST_PAD_CAST (pad)); gst_pad_use_fixed_caps (GST_PAD_CAST (pad));
gst_pad_set_active (GST_PAD_CAST (pad), TRUE); gst_pad_set_active (GST_PAD_CAST (pad), TRUE);
gst_element_add_pad (GST_ELEMENT_CAST (demux), gst_object_ref (pad)); pads = g_list_prepend (pads, gst_object_ref (pad));
g_ptr_array_add (demux->src, pad); g_ptr_array_add (demux->src, pad);
pad->discont = TRUE; pad->discont = TRUE;
} }
} }
if (first_run)
gst_element_no_more_pads (GST_ELEMENT_CAST (demux));
if (demux->src->len > 0) { if (demux->src->len > 0) {
for (i = 0; i < demux->src->len; i++) { for (i = 0; i < demux->src->len; i++) {
GstMXFDemuxPad *pad = g_ptr_array_index (demux->src, i); GstMXFDemuxPad *pad = g_ptr_array_index (demux->src, i);
if (!pad->material_track || !pad->material_package) { if (!pad->material_track || !pad->material_package) {
GST_ERROR_OBJECT (demux, "Unable to update existing pad"); GST_ERROR_OBJECT (demux, "Unable to update existing pad");
return GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto error;
} }
} }
} else { } else {
GST_ERROR_OBJECT (demux, "Couldn't create any streams"); GST_ERROR_OBJECT (demux, "Couldn't create any streams");
return GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto error;
} }
g_static_rw_lock_writer_unlock (&demux->metadata_lock);
for (l = pads; l; l = l->next)
gst_element_add_pad (GST_ELEMENT_CAST (demux), l->data);
g_list_free (pads);
if (first_run)
gst_element_no_more_pads (GST_ELEMENT_CAST (demux));
return GST_FLOW_OK; return GST_FLOW_OK;
error:
g_static_rw_lock_writer_unlock (&demux->metadata_lock);
return ret;
} }
static GstFlowReturn static GstFlowReturn
@ -1276,7 +1315,7 @@ gst_mxf_demux_handle_metadata (GstMXFDemux * demux, const MXFUL * key,
return GST_FLOW_OK; return GST_FLOW_OK;
} }
g_mutex_lock (demux->metadata_lock); g_static_rw_lock_writer_lock (&demux->metadata_lock);
demux->update_metadata = TRUE; demux->update_metadata = TRUE;
if (MXF_IS_METADATA_PREFACE (metadata)) { if (MXF_IS_METADATA_PREFACE (metadata)) {
@ -1287,7 +1326,7 @@ gst_mxf_demux_handle_metadata (GstMXFDemux * demux, const MXFUL * key,
g_hash_table_replace (demux->metadata, g_hash_table_replace (demux->metadata,
&MXF_METADATA_BASE (metadata)->instance_uid, metadata); &MXF_METADATA_BASE (metadata)->instance_uid, metadata);
g_mutex_unlock (demux->metadata_lock); g_static_rw_lock_writer_unlock (&demux->metadata_lock);
return ret; return ret;
} }
@ -1365,7 +1404,7 @@ gst_mxf_demux_handle_descriptive_metadata (GstMXFDemux * demux,
return GST_FLOW_OK; return GST_FLOW_OK;
} }
g_mutex_lock (demux->metadata_lock); g_static_rw_lock_writer_lock (&demux->metadata_lock);
demux->update_metadata = TRUE; demux->update_metadata = TRUE;
gst_mxf_demux_reset_linked_metadata (demux); gst_mxf_demux_reset_linked_metadata (demux);
@ -1373,7 +1412,7 @@ gst_mxf_demux_handle_descriptive_metadata (GstMXFDemux * demux,
g_hash_table_replace (demux->metadata, &MXF_METADATA_BASE (m)->instance_uid, g_hash_table_replace (demux->metadata, &MXF_METADATA_BASE (m)->instance_uid,
m); m);
g_mutex_unlock (demux->metadata_lock); g_static_rw_lock_writer_unlock (&demux->metadata_lock);
return ret; return ret;
} }
@ -2224,17 +2263,14 @@ next_try:
/* resolve references etc */ /* resolve references etc */
g_mutex_lock (demux->metadata_lock);
if (gst_mxf_demux_resolve_references (demux) != if (gst_mxf_demux_resolve_references (demux) !=
GST_FLOW_OK || gst_mxf_demux_update_tracks (demux) != GST_FLOW_OK) { GST_FLOW_OK || gst_mxf_demux_update_tracks (demux) != GST_FLOW_OK) {
demux->current_partition->parsed_metadata = TRUE; demux->current_partition->parsed_metadata = TRUE;
demux->offset = demux->offset =
demux->run_in + demux->current_partition->partition.this_partition - demux->run_in + demux->current_partition->partition.this_partition -
demux->current_partition->partition.prev_partition; demux->current_partition->partition.prev_partition;
g_mutex_unlock (demux->metadata_lock);
goto next_try; goto next_try;
} }
g_mutex_unlock (demux->metadata_lock);
out: out:
if (buffer) if (buffer)
@ -2253,7 +2289,6 @@ gst_mxf_demux_handle_klv_packet (GstMXFDemux * demux, const MXFUL * key,
#endif #endif
GstFlowReturn ret = GST_FLOW_OK; GstFlowReturn ret = GST_FLOW_OK;
g_mutex_lock (demux->metadata_lock);
if (demux->update_metadata if (demux->update_metadata
&& demux->preface && demux->preface
&& (demux->offset >= && (demux->offset >=
@ -2265,16 +2300,13 @@ gst_mxf_demux_handle_klv_packet (GstMXFDemux * demux, const MXFUL * key,
demux->current_partition->parsed_metadata = TRUE; demux->current_partition->parsed_metadata = TRUE;
if ((ret = gst_mxf_demux_resolve_references (demux)) != GST_FLOW_OK || if ((ret = gst_mxf_demux_resolve_references (demux)) != GST_FLOW_OK ||
(ret = gst_mxf_demux_update_tracks (demux)) != GST_FLOW_OK) { (ret = gst_mxf_demux_update_tracks (demux)) != GST_FLOW_OK) {
g_mutex_unlock (demux->metadata_lock);
goto beach; goto beach;
} }
} else if (demux->metadata_resolved && demux->requested_package_string) { } else if (demux->metadata_resolved && demux->requested_package_string) {
if ((ret = gst_mxf_demux_update_tracks (demux)) != GST_FLOW_OK) { if ((ret = gst_mxf_demux_update_tracks (demux)) != GST_FLOW_OK) {
g_mutex_unlock (demux->metadata_lock);
goto beach; goto beach;
} }
} }
g_mutex_unlock (demux->metadata_lock);
if (!mxf_is_mxf_packet (key)) { if (!mxf_is_mxf_packet (key)) {
GST_WARNING_OBJECT (demux, GST_WARNING_OBJECT (demux,
@ -3106,15 +3138,12 @@ gst_mxf_demux_seek_push (GstMXFDemux * demux, GstEvent * event)
guint64 new_offset = -1; guint64 new_offset = -1;
GstEvent *e; GstEvent *e;
g_mutex_lock (demux->metadata_lock);
if (!demux->metadata_resolved || demux->update_metadata) { if (!demux->metadata_resolved || demux->update_metadata) {
if (gst_mxf_demux_resolve_references (demux) != GST_FLOW_OK || if (gst_mxf_demux_resolve_references (demux) != GST_FLOW_OK ||
gst_mxf_demux_update_tracks (demux) != GST_FLOW_OK) { gst_mxf_demux_update_tracks (demux) != GST_FLOW_OK) {
g_mutex_unlock (demux->metadata_lock);
goto unresolved_metadata; goto unresolved_metadata;
} }
} }
g_mutex_unlock (demux->metadata_lock);
/* Do the actual seeking */ /* Do the actual seeking */
for (i = 0; i < demux->src->len; i++) { for (i = 0; i < demux->src->len; i++) {
@ -3266,15 +3295,12 @@ gst_mxf_demux_seek_pull (GstMXFDemux * demux, GstEvent * event)
if (flush || seeksegment.last_stop != demux->segment.last_stop) { if (flush || seeksegment.last_stop != demux->segment.last_stop) {
guint64 new_offset = -1; guint64 new_offset = -1;
g_mutex_lock (demux->metadata_lock);
if (!demux->metadata_resolved || demux->update_metadata) { if (!demux->metadata_resolved || demux->update_metadata) {
if (gst_mxf_demux_resolve_references (demux) != GST_FLOW_OK || if (gst_mxf_demux_resolve_references (demux) != GST_FLOW_OK ||
gst_mxf_demux_update_tracks (demux) != GST_FLOW_OK) { gst_mxf_demux_update_tracks (demux) != GST_FLOW_OK) {
g_mutex_unlock (demux->metadata_lock);
goto unresolved_metadata; goto unresolved_metadata;
} }
} }
g_mutex_unlock (demux->metadata_lock);
/* Do the actual seeking */ /* Do the actual seeking */
for (i = 0; i < demux->src->len; i++) { for (i = 0; i < demux->src->len; i++) {
@ -3455,11 +3481,11 @@ gst_mxf_demux_src_query (GstPad * pad, GstQuery * query)
pos = mxfpad->last_stop; pos = mxfpad->last_stop;
g_mutex_lock (demux->metadata_lock); g_static_rw_lock_reader_lock (&demux->metadata_lock);
if (format == GST_FORMAT_DEFAULT && pos != GST_CLOCK_TIME_NONE) { if (format == GST_FORMAT_DEFAULT && pos != GST_CLOCK_TIME_NONE) {
if (!mxfpad->material_track || mxfpad->material_track->edit_rate.n == 0 if (!mxfpad->material_track || mxfpad->material_track->edit_rate.n == 0
|| mxfpad->material_track->edit_rate.d == 0) { || mxfpad->material_track->edit_rate.d == 0) {
g_mutex_unlock (demux->metadata_lock); g_static_rw_lock_reader_unlock (&demux->metadata_lock);
goto error; goto error;
} }
@ -3468,7 +3494,7 @@ gst_mxf_demux_src_query (GstPad * pad, GstQuery * query)
mxfpad->material_track->edit_rate.n, mxfpad->material_track->edit_rate.n,
mxfpad->material_track->edit_rate.d * GST_SECOND); mxfpad->material_track->edit_rate.d * GST_SECOND);
} }
g_mutex_unlock (demux->metadata_lock); g_static_rw_lock_reader_unlock (&demux->metadata_lock);
GST_DEBUG_OBJECT (pad, GST_DEBUG_OBJECT (pad,
"Returning position %" G_GINT64_FORMAT " in format %s", pos, "Returning position %" G_GINT64_FORMAT " in format %s", pos,
@ -3487,9 +3513,9 @@ gst_mxf_demux_src_query (GstPad * pad, GstQuery * query)
if (format != GST_FORMAT_TIME && format != GST_FORMAT_DEFAULT) if (format != GST_FORMAT_TIME && format != GST_FORMAT_DEFAULT)
goto error; goto error;
g_mutex_lock (demux->metadata_lock); g_static_rw_lock_reader_lock (&demux->metadata_lock);
if (!mxfpad->material_track || !mxfpad->material_track->parent.sequence) { if (!mxfpad->material_track || !mxfpad->material_track->parent.sequence) {
g_mutex_unlock (demux->metadata_lock); g_static_rw_lock_reader_unlock (&demux->metadata_lock);
goto error; goto error;
} }
@ -3500,7 +3526,7 @@ gst_mxf_demux_src_query (GstPad * pad, GstQuery * query)
if (duration != -1 && format == GST_FORMAT_TIME) { if (duration != -1 && format == GST_FORMAT_TIME) {
if (mxfpad->material_track->edit_rate.n == 0 || if (mxfpad->material_track->edit_rate.n == 0 ||
mxfpad->material_track->edit_rate.d == 0) { mxfpad->material_track->edit_rate.d == 0) {
g_mutex_unlock (demux->metadata_lock); g_static_rw_lock_reader_unlock (&demux->metadata_lock);
goto error; goto error;
} }
@ -3509,7 +3535,7 @@ gst_mxf_demux_src_query (GstPad * pad, GstQuery * query)
GST_SECOND * mxfpad->material_track->edit_rate.d, GST_SECOND * mxfpad->material_track->edit_rate.d,
mxfpad->material_track->edit_rate.n); mxfpad->material_track->edit_rate.n);
} }
g_mutex_unlock (demux->metadata_lock); g_static_rw_lock_reader_unlock (&demux->metadata_lock);
GST_DEBUG_OBJECT (pad, GST_DEBUG_OBJECT (pad,
"Returning duration %" G_GINT64_FORMAT " in format %s", duration, "Returning duration %" G_GINT64_FORMAT " in format %s", duration,
@ -3746,7 +3772,7 @@ gst_mxf_demux_query (GstElement * element, GstQuery * query)
if (demux->src->len == 0) if (demux->src->len == 0)
goto done; goto done;
g_mutex_lock (demux->metadata_lock); g_static_rw_lock_reader_lock (&demux->metadata_lock);
for (i = 0; i < demux->src->len; i++) { for (i = 0; i < demux->src->len; i++) {
GstMXFDemuxPad *pad = g_ptr_array_index (demux->src, i); GstMXFDemuxPad *pad = g_ptr_array_index (demux->src, i);
gint64 pdur = -1; gint64 pdur = -1;
@ -3765,7 +3791,7 @@ gst_mxf_demux_query (GstElement * element, GstQuery * query)
pad->material_track->edit_rate.n); pad->material_track->edit_rate.n);
duration = MAX (duration, pdur); duration = MAX (duration, pdur);
} }
g_mutex_unlock (demux->metadata_lock); g_static_rw_lock_reader_unlock (&demux->metadata_lock);
if (duration == -1) { if (duration == -1) {
GST_DEBUG_OBJECT (demux, "No duration known (yet)"); GST_DEBUG_OBJECT (demux, "No duration known (yet)");
@ -3862,7 +3888,7 @@ gst_mxf_demux_get_property (GObject * object, guint prop_id,
case PROP_STRUCTURE:{ case PROP_STRUCTURE:{
GstStructure *s; GstStructure *s;
g_mutex_lock (demux->metadata_lock); g_static_rw_lock_reader_lock (&demux->metadata_lock);
if (demux->preface) if (demux->preface)
s = mxf_metadata_base_to_structure (MXF_METADATA_BASE (demux->preface)); s = mxf_metadata_base_to_structure (MXF_METADATA_BASE (demux->preface));
else else
@ -3873,7 +3899,7 @@ gst_mxf_demux_get_property (GObject * object, guint prop_id,
if (s) if (s)
gst_structure_free (s); gst_structure_free (s);
g_mutex_unlock (demux->metadata_lock); g_static_rw_lock_reader_unlock (&demux->metadata_lock);
break; break;
} }
default: default:
@ -3911,10 +3937,7 @@ gst_mxf_demux_finalize (GObject * object)
g_hash_table_destroy (demux->metadata); g_hash_table_destroy (demux->metadata);
if (demux->metadata_lock) { g_static_rw_lock_free (&demux->metadata_lock);
g_mutex_free (demux->metadata_lock);
demux->metadata_lock = NULL;
}
G_OBJECT_CLASS (parent_class)->finalize (object); G_OBJECT_CLASS (parent_class)->finalize (object);
} }
@ -3990,7 +4013,7 @@ gst_mxf_demux_init (GstMXFDemux * demux, GstMXFDemuxClass * g_class)
demux->max_drift = 500 * GST_MSECOND; demux->max_drift = 500 * GST_MSECOND;
demux->adapter = gst_adapter_new (); demux->adapter = gst_adapter_new ();
demux->metadata_lock = g_mutex_new (); g_static_rw_lock_init (&demux->metadata_lock);
demux->src = g_ptr_array_new (); demux->src = g_ptr_array_new ();
demux->essence_tracks = demux->essence_tracks =

2
gst/mxf/mxfdemux.h
View file

@ -154,7 +154,7 @@ struct _GstMXFDemux
GArray *random_index_pack; GArray *random_index_pack;
/* Metadata */ /* Metadata */
GMutex *metadata_lock; GStaticRWLock metadata_lock;
gboolean update_metadata; gboolean update_metadata;
gboolean pull_footer_metadata; gboolean pull_footer_metadata;