mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-26 03:31:05 +00:00
Code Issues 1 Projects Releases Wiki Activity

avdemux: Fix leak of demuxer input context in error cases

Browse source 
Also simplify context lifetime management a bit.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/6505>
This commit is contained in:
Sebastian Dröge 2024-05-01 14:10:59 +03:00 committed by GStreamer Marge Bot
parent 73d0cac16c
commit 2a3f791c90
1 changed files with 13 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
subprojects/gst-libav/ext/libav/gstavdemux.c
View file

@ -67,7 +67,6 @@ struct _GstFFMpegDemux
guint group_id; guint group_id;
AVFormatContext *context; AVFormatContext *context;
gboolean opened;
GstFFStream *streams[MAX_STREAMS]; GstFFStream *streams[MAX_STREAMS];
@ -273,7 +272,6 @@ gst_ffmpegdemux_init (GstFFMpegDemux * demux)
demux->have_group_id = FALSE; demux->have_group_id = FALSE;
demux->group_id = G_MAXUINT; demux->group_id = G_MAXUINT;
demux->opened = FALSE;
demux->context = NULL; demux->context = NULL;
for (n = 0; n < MAX_STREAMS; n++) { for (n = 0; n < MAX_STREAMS; n++) {
@ -324,7 +322,7 @@ gst_ffmpegdemux_close (GstFFMpegDemux * demux)
gint n; gint n;
GstEvent **event_p; GstEvent **event_p;
if (!demux->opened) if (!demux->context)
return; return;
/* remove pads from ourselves */ /* remove pads from ourselves */
@ -353,12 +351,8 @@ gst_ffmpegdemux_close (GstFFMpegDemux * demux)
gst_ffmpeg_pipe_close (demux->context->pb); gst_ffmpeg_pipe_close (demux->context->pb);
demux->context->pb = NULL; demux->context->pb = NULL;
avformat_close_input (&demux->context); avformat_close_input (&demux->context);
if (demux->context)
avformat_free_context (demux->context);
demux->context = NULL;
GST_OBJECT_LOCK (demux); GST_OBJECT_LOCK (demux);
demux->opened = FALSE;
event_p = &demux->seek_event; event_p = &demux->seek_event;
gst_event_replace (event_p, NULL); gst_event_replace (event_p, NULL);
GST_OBJECT_UNLOCK (demux); GST_OBJECT_UNLOCK (demux);
@ -700,7 +694,7 @@ gst_ffmpegdemux_send_event (GstElement * element, GstEvent * event)
switch (GST_EVENT_TYPE (event)) { switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_SEEK: case GST_EVENT_SEEK:
GST_OBJECT_LOCK (demux); GST_OBJECT_LOCK (demux);
if (!demux->opened) { if (!demux->context) {
GstEvent **event_p; GstEvent **event_p;
GST_DEBUG_OBJECT (demux, "caching seek event"); GST_DEBUG_OBJECT (demux, "caching seek event");
@ -1309,7 +1303,6 @@ gst_ffmpegdemux_open (GstFFMpegDemux * demux)
demux->segment.duration = demux->duration; demux->segment.duration = demux->duration;
GST_OBJECT_LOCK (demux); GST_OBJECT_LOCK (demux);
demux->opened = TRUE;
event = demux->seek_event; event = demux->seek_event;
demux->seek_event = NULL; demux->seek_event = NULL;
cached_events = demux->cached_events; cached_events = demux->cached_events;
@ -1366,6 +1359,15 @@ gst_ffmpegdemux_open (GstFFMpegDemux * demux)
/* ERRORS */ /* ERRORS */
beach: beach:
{ {
if (demux->context->pb) {
if (demux->seekable)
gst_ffmpegdata_close (demux->context->pb);
else
gst_ffmpeg_pipe_close (demux->context->pb);
demux->context->pb = NULL;
}
avformat_close_input (&demux->context);
GST_ELEMENT_ERROR (demux, LIBRARY, FAILED, (NULL), GST_ELEMENT_ERROR (demux, LIBRARY, FAILED, (NULL),
("%s", gst_ffmpegdemux_averror (res))); ("%s", gst_ffmpegdemux_averror (res)));
return FALSE; return FALSE;
@ -1390,7 +1392,7 @@ gst_ffmpegdemux_loop (GstFFMpegDemux * demux)
gint64 pts; gint64 pts;
/* open file if we didn't so already */ /* open file if we didn't so already */
if (!demux->opened) if (!demux->context)
if (!gst_ffmpegdemux_open (demux)) if (!gst_ffmpegdemux_open (demux))
goto open_failed; goto open_failed;
@ -1725,7 +1727,7 @@ gst_ffmpegdemux_sink_event (GstPad * sinkpad, GstObject * parent,
* If the demuxer isn't opened, push straight away, since we'll * If the demuxer isn't opened, push straight away, since we'll
* be waiting against a cond that will never be signalled. */ * be waiting against a cond that will never be signalled. */
if (GST_EVENT_IS_SERIALIZED (event)) { if (GST_EVENT_IS_SERIALIZED (event)) {
if (demux->opened) { if (demux->context) {
GST_FFMPEG_PIPE_MUTEX_LOCK (ffpipe); GST_FFMPEG_PIPE_MUTEX_LOCK (ffpipe);
while (!ffpipe->needed) while (!ffpipe->needed)
GST_FFMPEG_PIPE_WAIT (ffpipe); GST_FFMPEG_PIPE_WAIT (ffpipe);