diff options
Diffstat (limited to 'gst-libs')
-rw-r--r-- | gst-libs/gst/Makefile.am | 8 | ||||
-rw-r--r-- | gst-libs/gst/sctp/Makefile.am | 17 | ||||
-rw-r--r-- | gst-libs/gst/sctp/sctpreceivemeta.c | 90 | ||||
-rw-r--r-- | gst-libs/gst/sctp/sctpreceivemeta.h | 53 | ||||
-rw-r--r-- | gst-libs/gst/sctp/sctpsendmeta.c | 99 | ||||
-rw-r--r-- | gst-libs/gst/sctp/sctpsendmeta.h | 65 |
6 files changed, 330 insertions, 2 deletions
diff --git a/gst-libs/gst/Makefile.am b/gst-libs/gst/Makefile.am index db67fc89f..79fa13463 100644 --- a/gst-libs/gst/Makefile.am +++ b/gst-libs/gst/Makefile.am @@ -6,9 +6,13 @@ if USE_OPENCV OPENCV_DIR=opencv endif +if USE_SCTP +SCTP_DIR=sctp +endif + SUBDIRS = uridownloader adaptivedemux interfaces basecamerabinsrc codecparsers \ insertbin mpegts video audio player isoff webrtc $(WAYLAND_DIR) \ - $(OPENCV_DIR) + $(OPENCV_DIR) $(SCTP_DIR) noinst_HEADERS = gst-i18n-plugin.h gettext.h glib-compat-private.h DIST_SUBDIRS = uridownloader adaptivedemux interfaces basecamerabinsrc \ @@ -18,7 +22,7 @@ adaptivedemux: uridownloader INDEPENDENT_SUBDIRS = \ interfaces basecamerabinsrc codecparsers insertbin uridownloader \ - mpegts player isoff $(WAYLAND_DIR) $(OPENCV_DIR) + mpegts player isoff $(WAYLAND_DIR) $(OPENCV_DIR) $(SCTP_DIR) .PHONY: independent-subdirs $(INDEPENDENT_SUBDIRS) diff --git a/gst-libs/gst/sctp/Makefile.am b/gst-libs/gst/sctp/Makefile.am new file mode 100644 index 000000000..54d6589e1 --- /dev/null +++ b/gst-libs/gst/sctp/Makefile.am @@ -0,0 +1,17 @@ +lib_LTLIBRARIES = libgstsctp-1.0.la + +libgstsctp_1_0_la_SOURCES = \ + sctpsendmeta.c \ + sctpreceivemeta.c + +libgstsctp_1_0_la_CFLAGS = \ + $(GST_PLUGINS_BASE_CFLAGS) \ + $(GST_BASE_CFLAGS) \ + $(GST_CFLAGS) + +libgstsctp_1_0_la_LIBADD = $(GST_LIBS) $(GST_BASE_LIBS) + +libgstsctp_1_0_includedir = $(includedir)/gstreamer-1.0/gst/sctp +libgstsctp_1_0_include_HEADERS = \ + sctpsendmeta.h \ + sctpreceivemeta.h diff --git a/gst-libs/gst/sctp/sctpreceivemeta.c b/gst-libs/gst/sctp/sctpreceivemeta.c new file mode 100644 index 000000000..9fcff236f --- /dev/null +++ b/gst-libs/gst/sctp/sctpreceivemeta.c @@ -0,0 +1,90 @@ +/* + * Copyright (c) 2015, Collabora Ltd. + * + * Redistribution and use in source and binary forms, with or without modification, + * are permitted provided that the following conditions are met: + * + * 1. Redistributions of source code must retain the above copyright notice, this + * list of conditions and the following disclaimer. + * + * 2. Redistributions in binary form must reproduce the above copyright notice, this + * list of conditions and the following disclaimer in the documentation and/or other + * materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED + * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, + * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR + * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) + * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY + * OF SUCH DAMAGE. + */ + +#include "sctpreceivemeta.h" + +static gboolean gst_sctp_receive_meta_init (GstMeta * meta, gpointer params, + GstBuffer * buffer); +static gboolean gst_sctp_receive_meta_transform (GstBuffer * transbuf, + GstMeta * meta, GstBuffer * buffer, GQuark type, gpointer data); + +GType +gst_sctp_receive_meta_api_get_type (void) +{ + static const gchar *tags[] = { NULL }; + static volatile GType type; + if (g_once_init_enter (&type)) { + GType _type = gst_meta_api_type_register ("GstSctpReceiveMetaAPI", tags); + g_once_init_leave (&type, _type); + } + return type; +} + +const GstMetaInfo * +gst_sctp_receive_meta_get_info (void) +{ + static const GstMetaInfo *gst_sctp_receive_meta_info = NULL; + + if (g_once_init_enter (&gst_sctp_receive_meta_info)) { + const GstMetaInfo *meta = gst_meta_register (GST_SCTP_RECEIVE_META_API_TYPE, + "GstSctpReceiveMeta", + sizeof (GstSctpReceiveMeta), + gst_sctp_receive_meta_init, + (GstMetaFreeFunction) NULL, + gst_sctp_receive_meta_transform); + g_once_init_leave (&gst_sctp_receive_meta_info, meta); + } + return gst_sctp_receive_meta_info; +} + +static gboolean +gst_sctp_receive_meta_init (GstMeta * meta, gpointer params, GstBuffer * buffer) +{ + GstSctpReceiveMeta *gst_sctp_receive_meta = (GstSctpReceiveMeta *) meta; + gst_sctp_receive_meta->ppid = 0; + return TRUE; +} + +static gboolean +gst_sctp_receive_meta_transform (GstBuffer * transbuf, GstMeta * meta, + GstBuffer * buffer, GQuark type, gpointer data) +{ + GstSctpReceiveMeta *gst_sctp_receive_meta = (GstSctpReceiveMeta *) meta; + gst_sctp_buffer_add_receive_meta (transbuf, gst_sctp_receive_meta->ppid); + return TRUE; +} + +GstSctpReceiveMeta * +gst_sctp_buffer_add_receive_meta (GstBuffer * buffer, guint32 ppid) +{ + GstSctpReceiveMeta *gst_sctp_receive_meta = NULL; + + g_return_val_if_fail (GST_IS_BUFFER (buffer), NULL); + gst_sctp_receive_meta = + (GstSctpReceiveMeta *) gst_buffer_add_meta (buffer, + GST_SCTP_RECEIVE_META_INFO, NULL); + gst_sctp_receive_meta->ppid = ppid; + return gst_sctp_receive_meta; +} diff --git a/gst-libs/gst/sctp/sctpreceivemeta.h b/gst-libs/gst/sctp/sctpreceivemeta.h new file mode 100644 index 000000000..f3be3288a --- /dev/null +++ b/gst-libs/gst/sctp/sctpreceivemeta.h @@ -0,0 +1,53 @@ +/* + * Copyright (c) 2015, Collabora Ltd. + * + * Redistribution and use in source and binary forms, with or without modification, + * are permitted provided that the following conditions are met: + * + * 1. Redistributions of source code must retain the above copyright notice, this + * list of conditions and the following disclaimer. + * + * 2. Redistributions in binary form must reproduce the above copyright notice, this + * list of conditions and the following disclaimer in the documentation and/or other + * materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED + * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, + * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR + * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) + * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY + * OF SUCH DAMAGE. + */ + +#ifndef __GST_SCTP_RECEIVE_META_H__ +#define __GST_SCTP_RECEIVE_META_H__ + +#include <gst/gst.h> + +G_BEGIN_DECLS + +#define GST_SCTP_RECEIVE_META_API_TYPE (gst_sctp_receive_meta_api_get_type()) +#define GST_SCTP_RECEIVE_META_INFO (gst_sctp_receive_meta_get_info()) +typedef struct _GstSctpReceiveMeta GstSctpReceiveMeta; + +struct _GstSctpReceiveMeta +{ + GstMeta meta; + + guint32 ppid; +}; + +GType gst_sctp_receive_meta_api_get_type (void); +const GstMetaInfo *gst_sctp_receive_meta_get_info (void); +GstSctpReceiveMeta *gst_sctp_buffer_add_receive_meta (GstBuffer * buffer, + guint32 ppid); + +#define gst_sctp_buffer_get_receive_meta(b) ((GstSctpReceiveMeta *)gst_buffer_get_meta((b), GST_SCTP_RECEIVE_META_TYPE)) + +G_END_DECLS + +#endif /* __GST_SCTP_RECEIVE_META_H__ */ diff --git a/gst-libs/gst/sctp/sctpsendmeta.c b/gst-libs/gst/sctp/sctpsendmeta.c new file mode 100644 index 000000000..e2083af9b --- /dev/null +++ b/gst-libs/gst/sctp/sctpsendmeta.c @@ -0,0 +1,99 @@ +/* + * Copyright (c) 2015, Collabora Ltd. + * + * Redistribution and use in source and binary forms, with or without modification, + * are permitted provided that the following conditions are met: + * + * 1. Redistributions of source code must retain the above copyright notice, this + * list of conditions and the following disclaimer. + * + * 2. Redistributions in binary form must reproduce the above copyright notice, this + * list of conditions and the following disclaimer in the documentation and/or other + * materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED + * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, + * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR + * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) + * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY + * OF SUCH DAMAGE. + */ + +#include "sctpsendmeta.h" + +static gboolean gst_sctp_send_meta_init (GstMeta * meta, gpointer params, + GstBuffer * buffer); +static gboolean gst_sctp_send_meta_transform (GstBuffer * transbuf, + GstMeta * meta, GstBuffer * buffer, GQuark type, gpointer data); + +GType +gst_sctp_send_meta_api_get_type (void) +{ + static const gchar *tags[] = { NULL }; + static volatile GType type; + if (g_once_init_enter (&type)) { + GType _type = gst_meta_api_type_register ("GstSctpSendMetaAPI", tags); + g_once_init_leave (&type, _type); + } + return type; +} + +const GstMetaInfo * +gst_sctp_send_meta_get_info (void) +{ + static const GstMetaInfo *gst_sctp_send_meta_info = NULL; + + if (g_once_init_enter (&gst_sctp_send_meta_info)) { + const GstMetaInfo *meta = gst_meta_register (GST_SCTP_SEND_META_API_TYPE, + "GstSctpSendMeta", + sizeof (GstSctpSendMeta), + gst_sctp_send_meta_init, + (GstMetaFreeFunction) NULL, + gst_sctp_send_meta_transform); + g_once_init_leave (&gst_sctp_send_meta_info, meta); + } + return gst_sctp_send_meta_info; +} + +static gboolean +gst_sctp_send_meta_init (GstMeta * meta, gpointer params, GstBuffer * buffer) +{ + GstSctpSendMeta *gst_sctp_send_meta = (GstSctpSendMeta *) meta; + gst_sctp_send_meta->ppid = 0; + gst_sctp_send_meta->ordered = TRUE; + gst_sctp_send_meta->pr = GST_SCTP_SEND_META_PARTIAL_RELIABILITY_NONE; + gst_sctp_send_meta->pr_param = 0; + return TRUE; +} + +static gboolean +gst_sctp_send_meta_transform (GstBuffer * transbuf, GstMeta * meta, + GstBuffer * buffer, GQuark type, gpointer data) +{ + GstSctpSendMeta *gst_sctp_send_meta = (GstSctpSendMeta *) meta; + gst_sctp_buffer_add_send_meta (transbuf, gst_sctp_send_meta->ppid, + gst_sctp_send_meta->ordered, gst_sctp_send_meta->pr, + gst_sctp_send_meta->pr_param); + return TRUE; +} + +GstSctpSendMeta * +gst_sctp_buffer_add_send_meta (GstBuffer * buffer, guint32 ppid, + gboolean ordered, GstSctpSendMetaPartiallyReliability pr, guint32 pr_param) +{ + GstSctpSendMeta *gst_sctp_send_meta = NULL; + + g_return_val_if_fail (GST_IS_BUFFER (buffer), NULL); + gst_sctp_send_meta = + (GstSctpSendMeta *) gst_buffer_add_meta (buffer, GST_SCTP_SEND_META_INFO, + NULL); + gst_sctp_send_meta->ppid = ppid; + gst_sctp_send_meta->ordered = ordered; + gst_sctp_send_meta->pr = pr; + gst_sctp_send_meta->pr_param = pr_param; + return gst_sctp_send_meta; +} diff --git a/gst-libs/gst/sctp/sctpsendmeta.h b/gst-libs/gst/sctp/sctpsendmeta.h new file mode 100644 index 000000000..8a7cd0b63 --- /dev/null +++ b/gst-libs/gst/sctp/sctpsendmeta.h @@ -0,0 +1,65 @@ +/* + * Copyright (c) 2015, Collabora Ltd. + * + * Redistribution and use in source and binary forms, with or without modification, + * are permitted provided that the following conditions are met: + * + * 1. Redistributions of source code must retain the above copyright notice, this + * list of conditions and the following disclaimer. + * + * 2. Redistributions in binary form must reproduce the above copyright notice, this + * list of conditions and the following disclaimer in the documentation and/or other + * materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED + * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, + * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR + * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) + * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY + * OF SUCH DAMAGE. + */ + +#ifndef __GST_SCTP_SEND_META_H__ +#define __GST_SCTP_SEND_META_H__ + +#include <gst/gst.h> + +G_BEGIN_DECLS + +typedef enum +{ + GST_SCTP_SEND_META_PARTIAL_RELIABILITY_NONE, + GST_SCTP_SEND_META_PARTIAL_RELIABILITY_TTL, + GST_SCTP_SEND_META_PARTIAL_RELIABILITY_BUF, + GST_SCTP_SEND_META_PARTIAL_RELIABILITY_RTX +} GstSctpSendMetaPartiallyReliability; + +#define GST_SCTP_SEND_META_API_TYPE (gst_sctp_send_meta_api_get_type()) +#define GST_SCTP_SEND_META_INFO (gst_sctp_send_meta_get_info()) +typedef struct _GstSctpSendMeta GstSctpSendMeta; + +struct _GstSctpSendMeta +{ + GstMeta meta; + + guint32 ppid; + gboolean ordered; + GstSctpSendMetaPartiallyReliability pr; + guint32 pr_param; +}; + +GType gst_sctp_send_meta_api_get_type (void); +const GstMetaInfo *gst_sctp_send_meta_get_info (void); +GstSctpSendMeta *gst_sctp_buffer_add_send_meta (GstBuffer * buffer, + guint32 ppid, gboolean ordered, GstSctpSendMetaPartiallyReliability pr, + guint32 pr_param); + +#define gst_sctp_buffer_get_send_meta(b) ((GstSctpSendMeta *)gst_buffer_get_meta((b), GST_SCTP_SEND_META_TYPE)) + +G_END_DECLS + +#endif /* __GST_SCTP_SEND_META_H__ */ |