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

souphttpsrc: Properly close the session when going back to NULL

Browse source 
Don't wait for that until the element is disposed.
This commit is contained in:
Sebastian Dröge 2014-02-13 10:28:13 +01:00
parent 4d80d3fad9
commit a79f92ee9d
1 changed files with 25 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
ext/soup/gstsouphttpsrc.c
View file

@ -128,6 +128,8 @@ static void gst_soup_http_src_set_property (GObject * object, guint prop_id,
static void gst_soup_http_src_get_property (GObject * object, guint prop_id, static void gst_soup_http_src_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec); GValue * value, GParamSpec * pspec);
static GstStateChangeReturn gst_soup_http_src_change_state (GstElement *
element, GstStateChange transition);
static GstFlowReturn gst_soup_http_src_create (GstPushSrc * psrc, static GstFlowReturn gst_soup_http_src_create (GstPushSrc * psrc,
GstBuffer ** outbuf); GstBuffer ** outbuf);
static gboolean gst_soup_http_src_start (GstBaseSrc * bsrc); static gboolean gst_soup_http_src_start (GstBaseSrc * bsrc);
@ -303,6 +305,8 @@ gst_soup_http_src_class_init (GstSoupHTTPSrcClass * klass)
"Source/Network", "Source/Network",
"Receive data as a client over the network via HTTP using SOUP", "Receive data as a client over the network via HTTP using SOUP",
"Wouter Cloetens <wouter@mind.be>"); "Wouter Cloetens <wouter@mind.be>");
gstelement_class->change_state =
GST_DEBUG_FUNCPTR (gst_soup_http_src_change_state);
gstbasesrc_class->start = GST_DEBUG_FUNCPTR (gst_soup_http_src_start); gstbasesrc_class->start = GST_DEBUG_FUNCPTR (gst_soup_http_src_start);
gstbasesrc_class->stop = GST_DEBUG_FUNCPTR (gst_soup_http_src_stop); gstbasesrc_class->stop = GST_DEBUG_FUNCPTR (gst_soup_http_src_stop);
@ -1464,6 +1468,27 @@ gst_soup_http_src_stop (GstBaseSrc * bsrc)
return TRUE; return TRUE;
} }
static GstStateChangeReturn
gst_soup_http_src_change_state (GstElement * element, GstStateChange transition)
{
GstStateChangeReturn ret;
GstSoupHTTPSrc *src;
src = GST_SOUP_HTTP_SRC (element);
switch (transition) {
case GST_STATE_CHANGE_READY_TO_NULL:
gst_soup_http_src_session_close (src);
break;
default:
break;
}
ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
return ret;
}
/* Interrupt a blocking request. */ /* Interrupt a blocking request. */
static gboolean static gboolean
gst_soup_http_src_unlock (GstBaseSrc * bsrc) gst_soup_http_src_unlock (GstBaseSrc * bsrc)