diff options
author | Nirbheek Chauhan <nirbheek@centricular.com> | 2014-10-02 14:26:08 +0530 |
---|---|---|
committer | Sebastian Dröge <sebastian@centricular.com> | 2014-10-14 09:37:51 +0200 |
commit | e0575c791d8788c9565a47a13d8117d3380d2995 (patch) | |
tree | a09330b577365ee373c23850545863d5d586e9da | |
parent | 8060fc1d97e5d9a50f833c4f64fda3cf70d55741 (diff) |
souphttpclientsink: Fix lifetime of stream headers and queued buffers
Stream headers are updated whenever ::set_caps is called, so we can't assume
they'll be valid before the message body is written out. We *can* assume that
for queued buffers, but SOUP_MEMORY_STATIC is still wrong for those.
Also, add some debug logging for stream header interactions.
https://bugzilla.gnome.org/show_bug.cgi?id=737771
-rw-r--r-- | ext/soup/gstsouphttpclientsink.c | 15 |
1 files changed, 11 insertions, 4 deletions
diff --git a/ext/soup/gstsouphttpclientsink.c b/ext/soup/gstsouphttpclientsink.c index 190da58eb..784a53fba 100644 --- a/ext/soup/gstsouphttpclientsink.c +++ b/ext/soup/gstsouphttpclientsink.c @@ -445,6 +445,7 @@ gst_soup_http_client_sink_set_caps (GstBaseSink * sink, GstCaps * caps) const GValue *value_array; int i, n; + GST_DEBUG_OBJECT (souphttpsink, "new stream headers set"); structure = gst_caps_get_structure (caps, 0); value_array = gst_structure_get_value (structure, "streamheader"); if (value_array) { @@ -653,10 +654,13 @@ send_message_locked (GstSoupHttpClientSink * souphttpsink) GstBuffer *buffer = g->data; GstMapInfo map; - /* FIXME, lifetime of the buffer? */ + GST_DEBUG_OBJECT (souphttpsink, "queueing stream headers"); gst_buffer_map (buffer, &map, GST_MAP_READ); + /* Stream headers are updated whenever ::set_caps is called, so there's + * no guarantees about their lifetime and we ask libsoup to copy them + * into the message body with SOUP_MEMORY_COPY. */ soup_message_body_append (souphttpsink->message->request_body, - SOUP_MEMORY_STATIC, map.data, map.size); + SOUP_MEMORY_COPY, map.data, map.size); n += map.size; gst_buffer_unmap (buffer, &map); } @@ -667,10 +671,13 @@ send_message_locked (GstSoupHttpClientSink * souphttpsink) if (!GST_BUFFER_FLAG_IS_SET (buffer, GST_BUFFER_FLAG_HEADER)) { GstMapInfo map; - /* FIXME, lifetime of the buffer? */ gst_buffer_map (buffer, &map, GST_MAP_READ); + /* Queued buffers are only freed in the next iteration of the mainloop + * after the message body has been written out, so we don't need libsoup + * to copy those while appending to the body. However, if the buffer is + * used elsewhere, it should be copied. Hence, SOUP_MEMORY_TEMPORARY. */ soup_message_body_append (souphttpsink->message->request_body, - SOUP_MEMORY_STATIC, map.data, map.size); + SOUP_MEMORY_TEMPORARY, map.data, map.size); n += map.size; gst_buffer_unmap (buffer, &map); } |