mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-27 04:01:08 +00:00
Code Issues 1 Projects Releases Wiki Activity

curl: add libcurl-based sink element

Browse source 
Sink acts as a client and can connect to servers to
upload media.

https://bugzilla.gnome.org/show_bug.cgi?id=641496
This commit is contained in:
Patricia Muscalu 2011-02-26 20:20:33 +00:00 committed by Tim-Philipp Müller
parent b2be3e2f1a
commit 16b79f6f2d
4 changed files with 1462 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
ext/curl/Makefile.am Normal file
View file

@ -0,0 +1,15 @@
plugin_LTLIBRARIES = libgstcurl.la
libgstcurl_la_SOURCES = gstcurl.c gstcurlsink.c
libgstcurl_la_CFLAGS = \
$(GST_BASE_CFLAGS) \
$(GST_CFLAGS) \
$(CURL_CFLAGS)
libgstcurl_la_LIBADD = \
$(GST_BASE_LIBS) \
$(GST_LIBS) \
$(CURL_LIBS)
libgstcurl_la_LDFLAGS = $(GST_PLUGIN_LDFLAGS)
libgstcurl_la_LIBTOOLFLAGS = --tag=disable-static
noinst_HEADERS = gstcurlsink.h

40
ext/curl/gstcurl.c Normal file
View file

@ -0,0 +1,40 @@
/* GStreamer
* Copyright (C) 2011 Axis Communications <dev-gstreamer@axis.com>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Library General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Library General Public License for more details.
*
* You should have received a copy of the GNU Library General Public
* License along with this library; if not, write to the
* Free Software Foundation, Inc., 59 Temple Place - Suite 330,
* Boston, MA 02111-1307, USA.
*/
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
#include "gstcurlsink.h"
static gboolean
plugin_init (GstPlugin * plugin)
{
if (!gst_element_register (plugin, "curlsink", GST_RANK_NONE,
GST_TYPE_CURL_SINK))
return FALSE;
return TRUE;
}
GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
GST_VERSION_MINOR,
"curl",
"libcurl-based elements",
plugin_init, VERSION, "LGPL", GST_PACKAGE_NAME, GST_PACKAGE_ORIGIN)

1301
ext/curl/gstcurlsink.c Normal file
View file

File diff suppressed because it is too large Load diff

106
ext/curl/gstcurlsink.h Normal file
View file

@ -0,0 +1,106 @@
/* GStreamer
* Copyright (C) 2011 Axis Communications <dev-gstreamer@axis.com>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Library General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Library General Public License for more details.
*
* You should have received a copy of the GNU Library General Public
* License along with this library; if not, write to the
* Free Software Foundation, Inc., 59 Temple Place - Suite 330,
* Boston, MA 02111-1307, USA.
*/
#ifndef __GST_CURL_SINK__
#define __GST_CURL_SINK__
#include <gst/gst.h>
#include <gst/base/gstbasesink.h>
#include <curl/curl.h>
G_BEGIN_DECLS
#define GST_TYPE_CURL_SINK \
(gst_curl_sink_get_type())
#define GST_CURL_SINK(obj) \
(G_TYPE_CHECK_INSTANCE_CAST((obj), GST_TYPE_CURL_SINK, GstCurlSink))
#define GST_CURL_SINK_CLASS(klass) \
(G_TYPE_CHECK_CLASS_CAST((klass), GST_TYPE_CURL_SINK, GstCurlSinkClass))
#define GST_IS_CURL_SINK(obj) \
(G_TYPE_CHECK_INSTANCE_TYPE((obj), GST_TYPE_CURL_SINK))
#define GST_IS_CURL_SINK_CLASS(klass) \
(G_TYPE_CHECK_CLASS_TYPE((klass), GST_TYPE_CURL_SINK))
typedef struct _GstCurlSink GstCurlSink;
typedef struct _GstCurlSinkClass GstCurlSinkClass;
typedef struct _GstCurlSinkPrivate GstCurlSinkPrivate;
typedef struct _TransferBuffer TransferBuffer;
typedef struct _TransferCondition TransferCondition;
struct _TransferBuffer {
guint8 *ptr;
size_t len;
size_t offset;
};
struct _TransferCondition {
GCond *cond;
gboolean data_sent;
gboolean data_available;
};
struct _GstCurlSinkPrivate
{
CURLM *multi_handle;
CURL *curl;
struct curl_slist *header_list;
GstPollFD fd;
GstPoll *fdset;
GThread *transfer_thread;
GstFlowReturn flow_ret;
TransferBuffer *transfer_buf;
TransferCondition *transfer_cond;
gint num_buffers_per_packet;
gint timeout;
gchar *url;
gchar *user;
gchar *passwd;
gchar *proxy;
guint proxy_port;
gchar *proxy_user;
gchar *proxy_passwd;
gchar *file_name;
guint qos_dscp;
gboolean accept_self_signed;
gboolean use_content_length;
gboolean transfer_thread_close;
gboolean new_file;
gchar *content_type;
gboolean proxy_headers_set;
};
struct _GstCurlSink
{
GstBaseSink parent;
/*< private >*/
GstCurlSinkPrivate *priv;
};
struct _GstCurlSinkClass
{
GstBaseSinkClass parent_class;
};
GType gst_curl_sink_get_type (void);
G_END_DECLS
#endif