mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-25 23:46:45 +00:00
Code Issues 1 Projects Releases Wiki Activity

souphttpsrc: Post an element message with the HTTP headers on the bus too

Browse source 
Instead of just sending a sticky event with them downstream. This allows
getting the HTTP headers easily in the application, and especially also
on errors.
This commit is contained in:
Sebastian Dröge 2017-07-13 14:50:44 +03:00
parent c0318f3d60
commit d0dfbb04c0
1 changed files with 15 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
ext/soup/gstsouphttpsrc.c
View file

@ -1130,16 +1130,9 @@ gst_soup_http_src_got_headers (GstSoupHTTPSrc * src, SoupMessage * msg)
return GST_FLOW_OK; return GST_FLOW_OK;
} }
if (msg->status_code == SOUP_STATUS_UNAUTHORIZED) {
/* force an error */
return gst_soup_http_src_parse_status (msg, src);
}
src->got_headers = TRUE;
g_cond_broadcast (&src->have_headers_cond);
http_headers = gst_structure_new_empty ("http-headers"); http_headers = gst_structure_new_empty ("http-headers");
gst_structure_set (http_headers, "uri", G_TYPE_STRING, src->location, NULL); gst_structure_set (http_headers, "uri", G_TYPE_STRING, src->location,
"http-status-code", G_TYPE_UINT, msg->status_code, NULL);
if (src->redirection_uri) if (src->redirection_uri)
gst_structure_set (http_headers, "redirection-uri", G_TYPE_STRING, gst_structure_set (http_headers, "redirection-uri", G_TYPE_STRING,
src->redirection_uri, NULL); src->redirection_uri, NULL);
@ -1156,6 +1149,19 @@ gst_soup_http_src_got_headers (GstSoupHTTPSrc * src, SoupMessage * msg)
headers, NULL); headers, NULL);
gst_structure_free (headers); gst_structure_free (headers);
gst_element_post_message (GST_ELEMENT_CAST (src),
gst_message_new_element (GST_OBJECT_CAST (src),
gst_structure_copy (http_headers)));
if (msg->status_code == SOUP_STATUS_UNAUTHORIZED) {
/* force an error */
gst_structure_free (http_headers);
return gst_soup_http_src_parse_status (msg, src);
}
src->got_headers = TRUE;
g_cond_broadcast (&src->have_headers_cond);
http_headers_event = http_headers_event =
gst_event_new_custom (GST_EVENT_CUSTOM_DOWNSTREAM_STICKY, http_headers); gst_event_new_custom (GST_EVENT_CUSTOM_DOWNSTREAM_STICKY, http_headers);
gst_event_replace (&src->http_headers_event, http_headers_event); gst_event_replace (&src->http_headers_event, http_headers_event);