2 * Copyright (C) 2011 David Schleef <ds@entropywave.com>
4 * This library is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU Library General Public
6 * License as published by the Free Software Foundation; either
7 * version 2 of the License, or (at your option) any later version.
9 * This library is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * Library General Public License for more details.
14 * You should have received a copy of the GNU Library General Public
15 * License along with this library; if not, write to the
16 * Free Software Foundation, Inc., 51 Franklin Street, Suite 500,
17 * Boston, MA 02110-1335, USA.
20 * SECTION:element-gstsouphttpclientsink
22 * The souphttpclientsink element sends pipeline data to an HTTP server
23 * using HTTP PUT commands.
26 * <title>Example launch line</title>
28 * gst-launch-1.0 -v videotestsrc num-buffers=300 ! theoraenc ! oggmux !
29 * souphttpclientsink location=http://server/filename.ogv
32 * This example encodes 10 seconds of video and sends it to the HTTP
33 * server "server" using HTTP PUT commands.
42 #include <gst/base/gstbasesink.h>
43 #include "gstsouphttpclientsink.h"
45 #include <gst/glib-compat-private.h>
47 GST_DEBUG_CATEGORY_STATIC (souphttpclientsink_dbg);
48 #define GST_CAT_DEFAULT souphttpclientsink_dbg
53 static void gst_soup_http_client_sink_set_property (GObject * object,
54 guint property_id, const GValue * value, GParamSpec * pspec);
55 static void gst_soup_http_client_sink_get_property (GObject * object,
56 guint property_id, GValue * value, GParamSpec * pspec);
57 static void gst_soup_http_client_sink_dispose (GObject * object);
58 static void gst_soup_http_client_sink_finalize (GObject * object);
60 static gboolean gst_soup_http_client_sink_set_caps (GstBaseSink * sink,
62 static void gst_soup_http_client_sink_get_times (GstBaseSink * sink,
63 GstBuffer * buffer, GstClockTime * start, GstClockTime * end);
64 static gboolean gst_soup_http_client_sink_start (GstBaseSink * sink);
65 static gboolean gst_soup_http_client_sink_stop (GstBaseSink * sink);
66 static gboolean gst_soup_http_client_sink_unlock (GstBaseSink * sink);
67 static gboolean gst_soup_http_client_sink_event (GstBaseSink * sink,
69 static GstFlowReturn gst_soup_http_client_sink_preroll (GstBaseSink * sink,
71 static GstFlowReturn gst_soup_http_client_sink_render (GstBaseSink * sink,
74 static void free_buffer_list (GList * list);
75 static void gst_soup_http_client_sink_reset (GstSoupHttpClientSink *
77 static void authenticate (SoupSession * session, SoupMessage * msg,
78 SoupAuth * auth, gboolean retrying, gpointer user_data);
79 static void callback (SoupSession * session, SoupMessage * msg,
81 static gboolean gst_soup_http_client_sink_set_proxy (GstSoupHttpClientSink *
82 souphttpsink, const gchar * uri);
89 PROP_AUTOMATIC_REDIRECT,
99 #define DEFAULT_USER_AGENT "GStreamer souphttpclientsink "
103 static GstStaticPadTemplate gst_soup_http_client_sink_sink_template =
104 GST_STATIC_PAD_TEMPLATE ("sink",
107 GST_STATIC_CAPS_ANY);
110 /* class initialization */
112 #define gst_soup_http_client_sink_parent_class parent_class
113 G_DEFINE_TYPE (GstSoupHttpClientSink, gst_soup_http_client_sink,
117 gst_soup_http_client_sink_class_init (GstSoupHttpClientSinkClass * klass)
119 GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
120 GstElementClass *gstelement_class = GST_ELEMENT_CLASS (klass);
121 GstBaseSinkClass *base_sink_class = GST_BASE_SINK_CLASS (klass);
123 gobject_class->set_property = gst_soup_http_client_sink_set_property;
124 gobject_class->get_property = gst_soup_http_client_sink_get_property;
125 gobject_class->dispose = gst_soup_http_client_sink_dispose;
126 gobject_class->finalize = gst_soup_http_client_sink_finalize;
128 g_object_class_install_property (gobject_class,
130 g_param_spec_string ("location", "Location",
131 "URI to send to", "", G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
132 g_object_class_install_property (gobject_class,
134 g_param_spec_string ("user-agent", "User-Agent",
135 "Value of the User-Agent HTTP request header field",
136 DEFAULT_USER_AGENT, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
137 g_object_class_install_property (gobject_class,
138 PROP_AUTOMATIC_REDIRECT,
139 g_param_spec_boolean ("automatic-redirect", "automatic-redirect",
140 "Automatically follow HTTP redirects (HTTP Status Code 3xx)",
141 TRUE, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
142 g_object_class_install_property (gobject_class,
144 g_param_spec_string ("proxy", "Proxy",
145 "HTTP proxy server URI", "",
146 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
147 g_object_class_install_property (gobject_class,
149 g_param_spec_string ("user-id", "user-id",
150 "user id for authentication", "",
151 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
152 g_object_class_install_property (gobject_class, PROP_USER_PW,
153 g_param_spec_string ("user-pw", "user-pw",
154 "user password for authentication", "",
155 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
156 g_object_class_install_property (gobject_class, PROP_PROXY_ID,
157 g_param_spec_string ("proxy-id", "proxy-id",
158 "user id for proxy authentication", "",
159 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
160 g_object_class_install_property (gobject_class, PROP_PROXY_PW,
161 g_param_spec_string ("proxy-pw", "proxy-pw",
162 "user password for proxy authentication", "",
163 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
164 g_object_class_install_property (gobject_class, PROP_SESSION,
165 g_param_spec_object ("session", "session",
166 "SoupSession object to use for communication",
167 SOUP_TYPE_SESSION, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
168 g_object_class_install_property (gobject_class, PROP_COOKIES,
169 g_param_spec_boxed ("cookies", "Cookies", "HTTP request cookies",
170 G_TYPE_STRV, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
172 gst_element_class_add_pad_template (gstelement_class,
173 gst_static_pad_template_get (&gst_soup_http_client_sink_sink_template));
175 gst_element_class_set_static_metadata (gstelement_class, "HTTP client sink",
176 "Generic", "Sends streams to HTTP server via PUT",
177 "David Schleef <ds@entropywave.com>");
179 base_sink_class->set_caps =
180 GST_DEBUG_FUNCPTR (gst_soup_http_client_sink_set_caps);
182 base_sink_class->get_times =
183 GST_DEBUG_FUNCPTR (gst_soup_http_client_sink_get_times);
184 base_sink_class->start = GST_DEBUG_FUNCPTR (gst_soup_http_client_sink_start);
185 base_sink_class->stop = GST_DEBUG_FUNCPTR (gst_soup_http_client_sink_stop);
186 base_sink_class->unlock =
187 GST_DEBUG_FUNCPTR (gst_soup_http_client_sink_unlock);
188 base_sink_class->event = GST_DEBUG_FUNCPTR (gst_soup_http_client_sink_event);
190 base_sink_class->preroll =
191 GST_DEBUG_FUNCPTR (gst_soup_http_client_sink_preroll);
192 base_sink_class->render =
193 GST_DEBUG_FUNCPTR (gst_soup_http_client_sink_render);
195 GST_DEBUG_CATEGORY_INIT (souphttpclientsink_dbg, "souphttpclientsink", 0,
196 "souphttpclientsink element");
201 gst_soup_http_client_sink_init (GstSoupHttpClientSink * souphttpsink)
205 g_mutex_init (&souphttpsink->mutex);
206 g_cond_init (&souphttpsink->cond);
208 souphttpsink->location = NULL;
209 souphttpsink->automatic_redirect = TRUE;
210 souphttpsink->user_agent = g_strdup (DEFAULT_USER_AGENT);
211 souphttpsink->user_id = NULL;
212 souphttpsink->user_pw = NULL;
213 souphttpsink->proxy_id = NULL;
214 souphttpsink->proxy_pw = NULL;
215 souphttpsink->prop_session = NULL;
216 souphttpsink->timeout = 1;
217 proxy = g_getenv ("http_proxy");
218 if (proxy && !gst_soup_http_client_sink_set_proxy (souphttpsink, proxy)) {
219 GST_WARNING_OBJECT (souphttpsink,
220 "The proxy in the http_proxy env var (\"%s\") cannot be parsed.",
224 gst_soup_http_client_sink_reset (souphttpsink);
228 gst_soup_http_client_sink_reset (GstSoupHttpClientSink * souphttpsink)
230 g_free (souphttpsink->reason_phrase);
231 souphttpsink->reason_phrase = NULL;
232 souphttpsink->status_code = 0;
233 souphttpsink->offset = 0;
238 gst_soup_http_client_sink_set_proxy (GstSoupHttpClientSink * souphttpsink,
241 if (souphttpsink->proxy) {
242 soup_uri_free (souphttpsink->proxy);
243 souphttpsink->proxy = NULL;
245 if (g_str_has_prefix (uri, "http://")) {
246 souphttpsink->proxy = soup_uri_new (uri);
248 gchar *new_uri = g_strconcat ("http://", uri, NULL);
250 souphttpsink->proxy = soup_uri_new (new_uri);
258 gst_soup_http_client_sink_set_property (GObject * object, guint property_id,
259 const GValue * value, GParamSpec * pspec)
261 GstSoupHttpClientSink *souphttpsink = GST_SOUP_HTTP_CLIENT_SINK (object);
263 g_mutex_lock (&souphttpsink->mutex);
264 switch (property_id) {
266 if (souphttpsink->prop_session) {
267 g_object_unref (souphttpsink->prop_session);
269 souphttpsink->prop_session = g_value_dup_object (value);
272 g_free (souphttpsink->location);
273 souphttpsink->location = g_value_dup_string (value);
274 souphttpsink->offset = 0;
276 case PROP_USER_AGENT:
277 g_free (souphttpsink->user_agent);
278 souphttpsink->user_agent = g_value_dup_string (value);
280 case PROP_AUTOMATIC_REDIRECT:
281 souphttpsink->automatic_redirect = g_value_get_boolean (value);
284 g_free (souphttpsink->user_id);
285 souphttpsink->user_id = g_value_dup_string (value);
288 g_free (souphttpsink->user_pw);
289 souphttpsink->user_pw = g_value_dup_string (value);
292 g_free (souphttpsink->proxy_id);
293 souphttpsink->proxy_id = g_value_dup_string (value);
296 g_free (souphttpsink->proxy_pw);
297 souphttpsink->proxy_pw = g_value_dup_string (value);
303 proxy = g_value_get_string (value);
306 GST_WARNING ("proxy property cannot be NULL");
309 if (!gst_soup_http_client_sink_set_proxy (souphttpsink, proxy)) {
310 GST_WARNING ("badly formatted proxy URI");
316 g_strfreev (souphttpsink->cookies);
317 souphttpsink->cookies = g_strdupv (g_value_get_boxed (value));
320 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
324 g_mutex_unlock (&souphttpsink->mutex);
328 gst_soup_http_client_sink_get_property (GObject * object, guint property_id,
329 GValue * value, GParamSpec * pspec)
331 GstSoupHttpClientSink *souphttpsink = GST_SOUP_HTTP_CLIENT_SINK (object);
333 switch (property_id) {
335 g_value_set_object (value, souphttpsink->prop_session);
338 g_value_set_string (value, souphttpsink->location);
340 case PROP_AUTOMATIC_REDIRECT:
341 g_value_set_boolean (value, souphttpsink->automatic_redirect);
343 case PROP_USER_AGENT:
344 g_value_set_string (value, souphttpsink->user_agent);
347 g_value_set_string (value, souphttpsink->user_id);
350 g_value_set_string (value, souphttpsink->user_pw);
353 g_value_set_string (value, souphttpsink->proxy_id);
356 g_value_set_string (value, souphttpsink->proxy_pw);
359 if (souphttpsink->proxy == NULL)
360 g_value_set_static_string (value, "");
362 char *proxy = soup_uri_to_string (souphttpsink->proxy, FALSE);
364 g_value_set_string (value, proxy);
369 g_value_set_boxed (value, g_strdupv (souphttpsink->cookies));
372 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
378 gst_soup_http_client_sink_dispose (GObject * object)
380 GstSoupHttpClientSink *souphttpsink = GST_SOUP_HTTP_CLIENT_SINK (object);
382 /* clean up as possible. may be called multiple times */
383 if (souphttpsink->prop_session)
384 g_object_unref (souphttpsink->prop_session);
385 souphttpsink->prop_session = NULL;
387 G_OBJECT_CLASS (parent_class)->dispose (object);
391 gst_soup_http_client_sink_finalize (GObject * object)
393 GstSoupHttpClientSink *souphttpsink = GST_SOUP_HTTP_CLIENT_SINK (object);
395 /* clean up object here */
397 g_free (souphttpsink->user_agent);
398 g_free (souphttpsink->user_id);
399 g_free (souphttpsink->user_pw);
400 g_free (souphttpsink->proxy_id);
401 g_free (souphttpsink->proxy_pw);
402 if (souphttpsink->proxy)
403 soup_uri_free (souphttpsink->proxy);
404 g_free (souphttpsink->location);
406 g_cond_clear (&souphttpsink->cond);
407 g_mutex_clear (&souphttpsink->mutex);
409 G_OBJECT_CLASS (parent_class)->finalize (object);
415 gst_soup_http_client_sink_set_caps (GstBaseSink * sink, GstCaps * caps)
417 GstSoupHttpClientSink *souphttpsink = GST_SOUP_HTTP_CLIENT_SINK (sink);
418 GstStructure *structure;
419 const GValue *value_array;
422 structure = gst_caps_get_structure (caps, 0);
423 value_array = gst_structure_get_value (structure, "streamheader");
425 free_buffer_list (souphttpsink->streamheader_buffers);
426 souphttpsink->streamheader_buffers = NULL;
428 n = gst_value_array_get_size (value_array);
429 for (i = 0; i < n; i++) {
432 value = gst_value_array_get_value (value_array, i);
433 buffer = GST_BUFFER (gst_value_get_buffer (value));
434 souphttpsink->streamheader_buffers =
435 g_list_append (souphttpsink->streamheader_buffers,
436 gst_buffer_ref (buffer));
444 gst_soup_http_client_sink_get_times (GstBaseSink * sink, GstBuffer * buffer,
445 GstClockTime * start, GstClockTime * end)
451 thread_ready_idle_cb (gpointer data)
453 GstSoupHttpClientSink *souphttpsink = GST_SOUP_HTTP_CLIENT_SINK (data);
455 GST_LOG_OBJECT (souphttpsink, "thread ready");
457 g_mutex_lock (&souphttpsink->mutex);
458 g_cond_signal (&souphttpsink->cond);
459 g_mutex_unlock (&souphttpsink->mutex);
461 return FALSE; /* only run once */
465 thread_func (gpointer ptr)
467 GstSoupHttpClientSink *souphttpsink = GST_SOUP_HTTP_CLIENT_SINK (ptr);
469 GST_DEBUG ("thread start");
471 g_main_loop_run (souphttpsink->loop);
473 GST_DEBUG ("thread quit");
479 gst_soup_http_client_sink_start (GstBaseSink * sink)
481 GstSoupHttpClientSink *souphttpsink = GST_SOUP_HTTP_CLIENT_SINK (sink);
483 if (souphttpsink->prop_session) {
484 souphttpsink->session = souphttpsink->prop_session;
487 GError *error = NULL;
489 souphttpsink->context = g_main_context_new ();
491 /* set up idle source to signal when the main loop is running and
492 * it's safe for ::stop() to call g_main_loop_quit() */
493 source = g_idle_source_new ();
494 g_source_set_callback (source, thread_ready_idle_cb, sink, NULL);
495 g_source_attach (source, souphttpsink->context);
496 g_source_unref (source);
498 souphttpsink->loop = g_main_loop_new (souphttpsink->context, TRUE);
500 g_mutex_lock (&souphttpsink->mutex);
502 /* FIXME: error handling */
503 souphttpsink->thread = g_thread_try_new ("souphttpclientsink-thread",
504 thread_func, souphttpsink, &error);
506 GST_LOG_OBJECT (souphttpsink, "waiting for main loop thread to start up");
507 g_cond_wait (&souphttpsink->cond, &souphttpsink->mutex);
508 g_mutex_unlock (&souphttpsink->mutex);
509 GST_LOG_OBJECT (souphttpsink, "main loop thread running");
511 souphttpsink->session =
512 soup_session_async_new_with_options (SOUP_SESSION_ASYNC_CONTEXT,
513 souphttpsink->context, SOUP_SESSION_USER_AGENT,
514 souphttpsink->user_agent, SOUP_SESSION_TIMEOUT, souphttpsink->timeout,
517 //soup_session_add_feature (souphttpsink->session,
518 // SOUP_SESSION_FEATURE (soup_logger_new (SOUP_LOGGER_LOG_BODY, 100)));
520 g_signal_connect (souphttpsink->session, "authenticate",
521 G_CALLBACK (authenticate), souphttpsink);
528 gst_soup_http_client_sink_stop (GstBaseSink * sink)
530 GstSoupHttpClientSink *souphttpsink = GST_SOUP_HTTP_CLIENT_SINK (sink);
534 if (souphttpsink->prop_session == NULL) {
535 soup_session_abort (souphttpsink->session);
536 g_object_unref (souphttpsink->session);
539 if (souphttpsink->loop) {
540 g_main_loop_quit (souphttpsink->loop);
541 g_thread_join (souphttpsink->thread);
542 g_main_loop_unref (souphttpsink->loop);
543 souphttpsink->loop = NULL;
545 if (souphttpsink->context) {
546 g_main_context_unref (souphttpsink->context);
547 souphttpsink->context = NULL;
550 gst_soup_http_client_sink_reset (souphttpsink);
556 gst_soup_http_client_sink_unlock (GstBaseSink * sink)
558 GST_DEBUG ("unlock");
564 gst_soup_http_client_sink_event (GstBaseSink * sink, GstEvent * event)
566 GstSoupHttpClientSink *souphttpsink = GST_SOUP_HTTP_CLIENT_SINK (sink);
568 GST_DEBUG_OBJECT (souphttpsink, "event");
570 if (GST_EVENT_TYPE (event) == GST_EVENT_EOS) {
571 GST_DEBUG_OBJECT (souphttpsink, "got eos");
572 g_mutex_lock (&souphttpsink->mutex);
573 while (souphttpsink->message) {
574 GST_DEBUG_OBJECT (souphttpsink, "waiting");
575 g_cond_wait (&souphttpsink->cond, &souphttpsink->mutex);
577 g_mutex_unlock (&souphttpsink->mutex);
578 GST_DEBUG_OBJECT (souphttpsink, "finished eos");
581 return GST_BASE_SINK_CLASS (parent_class)->event (sink, event);
585 gst_soup_http_client_sink_preroll (GstBaseSink * sink, GstBuffer * buffer)
587 GST_DEBUG ("preroll");
593 free_buffer_list (GList * list)
596 for (g = list; g; g = g_list_next (g)) {
597 GstBuffer *buffer = g->data;
598 gst_buffer_unref (buffer);
604 send_message_locked (GstSoupHttpClientSink * souphttpsink)
609 if (souphttpsink->queued_buffers == NULL || souphttpsink->message) {
613 /* If the URI went away, drop all these buffers */
614 if (souphttpsink->location == NULL) {
615 free_buffer_list (souphttpsink->queued_buffers);
616 souphttpsink->queued_buffers = NULL;
620 souphttpsink->message = soup_message_new ("PUT", souphttpsink->location);
623 if (souphttpsink->offset == 0) {
624 for (g = souphttpsink->streamheader_buffers; g; g = g_list_next (g)) {
625 GstBuffer *buffer = g->data;
628 /* FIXME, lifetime of the buffer? */
629 gst_buffer_map (buffer, &map, GST_MAP_READ);
630 soup_message_body_append (souphttpsink->message->request_body,
631 SOUP_MEMORY_STATIC, map.data, map.size);
633 gst_buffer_unmap (buffer, &map);
637 for (g = souphttpsink->queued_buffers; g; g = g_list_next (g)) {
638 GstBuffer *buffer = g->data;
639 if (!GST_BUFFER_FLAG_IS_SET (buffer, GST_BUFFER_FLAG_HEADER)) {
642 /* FIXME, lifetime of the buffer? */
643 gst_buffer_map (buffer, &map, GST_MAP_READ);
644 soup_message_body_append (souphttpsink->message->request_body,
645 SOUP_MEMORY_STATIC, map.data, map.size);
647 gst_buffer_unmap (buffer, &map);
651 if (souphttpsink->offset != 0) {
653 s = g_strdup_printf ("bytes %" G_GUINT64_FORMAT "-%" G_GUINT64_FORMAT "/*",
654 souphttpsink->offset, souphttpsink->offset + n - 1);
655 soup_message_headers_append (souphttpsink->message->request_headers,
661 free_buffer_list (souphttpsink->queued_buffers);
662 souphttpsink->queued_buffers = NULL;
663 g_object_unref (souphttpsink->message);
664 souphttpsink->message = NULL;
668 souphttpsink->sent_buffers = souphttpsink->queued_buffers;
669 souphttpsink->queued_buffers = NULL;
671 GST_DEBUG_OBJECT (souphttpsink,
672 "queue message %" G_GUINT64_FORMAT " %" G_GUINT64_FORMAT,
673 souphttpsink->offset, n);
674 soup_session_queue_message (souphttpsink->session, souphttpsink->message,
675 callback, souphttpsink);
677 souphttpsink->offset += n;
681 send_message (GstSoupHttpClientSink * souphttpsink)
683 g_mutex_lock (&souphttpsink->mutex);
684 send_message_locked (souphttpsink);
685 g_mutex_unlock (&souphttpsink->mutex);
691 callback (SoupSession * session, SoupMessage * msg, gpointer user_data)
693 GstSoupHttpClientSink *souphttpsink = GST_SOUP_HTTP_CLIENT_SINK (user_data);
695 GST_DEBUG_OBJECT (souphttpsink, "callback status=%d %s",
696 msg->status_code, msg->reason_phrase);
698 g_mutex_lock (&souphttpsink->mutex);
699 g_cond_signal (&souphttpsink->cond);
700 souphttpsink->message = NULL;
702 if (!SOUP_STATUS_IS_SUCCESSFUL (msg->status_code)) {
703 souphttpsink->status_code = msg->status_code;
704 souphttpsink->reason_phrase = g_strdup (msg->reason_phrase);
705 g_mutex_unlock (&souphttpsink->mutex);
709 free_buffer_list (souphttpsink->sent_buffers);
710 souphttpsink->sent_buffers = NULL;
712 send_message_locked (souphttpsink);
713 g_mutex_unlock (&souphttpsink->mutex);
717 gst_soup_http_client_sink_render (GstBaseSink * sink, GstBuffer * buffer)
719 GstSoupHttpClientSink *souphttpsink = GST_SOUP_HTTP_CLIENT_SINK (sink);
723 if (souphttpsink->status_code != 0) {
724 /* FIXME we should allow a moderate amount of retries. */
725 GST_ELEMENT_ERROR (souphttpsink, RESOURCE, WRITE,
726 ("Could not write to HTTP URI"),
727 ("error: %d %s", souphttpsink->status_code,
728 souphttpsink->reason_phrase));
729 return GST_FLOW_ERROR;
732 g_mutex_lock (&souphttpsink->mutex);
733 if (souphttpsink->location != NULL) {
734 wake = (souphttpsink->queued_buffers == NULL);
735 souphttpsink->queued_buffers =
736 g_list_append (souphttpsink->queued_buffers, gst_buffer_ref (buffer));
739 source = g_idle_source_new ();
740 g_source_set_callback (source, (GSourceFunc) (send_message),
742 g_source_attach (source, souphttpsink->context);
743 g_source_unref (source);
746 g_mutex_unlock (&souphttpsink->mutex);
752 authenticate (SoupSession * session, SoupMessage * msg,
753 SoupAuth * auth, gboolean retrying, gpointer user_data)
755 GstSoupHttpClientSink *souphttpsink = GST_SOUP_HTTP_CLIENT_SINK (user_data);
758 if (souphttpsink->user_id && souphttpsink->user_pw) {
759 soup_auth_authenticate (auth,
760 souphttpsink->user_id, souphttpsink->user_pw);