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

adaptivedemux2/downloadrequest: add a helper to retrieve the Age header

Browse source 
Add a method to look at HTTP response headers and parse and return any Age
header, provided by caching proxy servers if the data was provided from a cache.

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/3883>
This commit is contained in:
Jan Schmidt 2022-11-17 03:49:12 +11:00 committed by GStreamer Marge Bot
parent 90bedcb2bc
commit a3770523c0
2 changed files with 50 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

48
subprojects/gst-plugins-good/ext/adaptivedemux2/downloadrequest.c
View file

@ -476,6 +476,54 @@ download_request_get_caps (DownloadRequest * request)
return caps;
}
static GstClockTime
_get_age_header (GstStructure * headers)
{
const GstStructure *response_headers;
const gchar *http_age;
const GValue *val;
val = gst_structure_get_value (headers, "response-headers");
if (!val) {
return 0;
}
response_headers = gst_value_get_structure (val);
http_age = gst_structure_get_string (response_headers, "Date");
if (!http_age) {
return 0;
}
return atoi (http_age) * GST_SECOND;
}
/* Return the age of the download from the Age header,
* or 0 if there was none */
GstClockTime
download_request_get_age (DownloadRequest * request)
{
DownloadRequestPrivate *priv = DOWNLOAD_REQUEST_PRIVATE (request);
GstClockTime age = 0;
g_return_val_if_fail (request != NULL, age);
if (request->state != DOWNLOAD_REQUEST_STATE_LOADING
&& request->state != DOWNLOAD_REQUEST_STATE_COMPLETE)
return age;
g_rec_mutex_lock (&priv->lock);
if (request->headers != NULL) {
/* We have headers for the download, see if there was an Age
* header in the response */
GstClockTime age = _get_age_header (request->headers);
GST_LOG ("Got cached data with age %" GST_TIMEP_FORMAT, &age);
}
g_rec_mutex_unlock (&priv->lock);
return age;
}
void
download_request_add_buffer (DownloadRequest * request, GstBuffer * buffer)
{

2
subprojects/gst-plugins-good/ext/adaptivedemux2/downloadrequest.h
View file

@ -84,6 +84,8 @@ void download_request_set_caps (DownloadRequest * request, GstCaps * caps);
GstCaps * download_request_get_caps (DownloadRequest * request);
GstClockTime download_request_get_age (DownloadRequest *request);
void download_request_add_buffer (DownloadRequest *request, GstBuffer *buffer);
GstBuffer * download_request_take_buffer (DownloadRequest *request);
GstBuffer * download_request_take_buffer_range (DownloadRequest *request, gint64 range_start, gint64 range_end);