--- /dev/null
+/*
+ * GStreamer
+ * Copyright (C) 2005 Thomas Vander Stichele <thomas@apestaart.org>
+ * Copyright (C) 2005 Ronald S. Bultje <rbultje@ronald.bitfreak.net>
+ * Copyright (C) 2018 nnstreamer <nnstreamer sec>
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in
+ * all copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ *
+ * Alternatively, the contents of this file may be used under the
+ * GNU Lesser General Public License Version 2.1 (the "LGPL"), in
+ * which case the following provisions apply instead of the ones
+ * mentioned above:
+ *
+ * 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.
+ *
+ * @file tensor_sink.c
+ * @date 15 June 2018
+ * @brief GStreamer plugin to handle tensor stream
+ * @see http://github.com/TO-BE-DETERMINED-SOON
+ * @see https://github.sec.samsung.net/STAR/nnstreamer
+ * @author Jaeyun Jung <jy1210.jung@samsung.com>
+ *
+ */
+
+/**
+ * SECTION:element-tensor_sink
+ *
+ * Sink element for tensor stream.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include <config.h>
+#endif
+
+#include "tensor_sink.h"
+
+GST_DEBUG_CATEGORY_STATIC (gst_tensor_sink_debug);
+#define GST_CAT_DEFAULT gst_tensor_sink_debug
+
+/* TensorSink signals and args */
+enum
+{
+ /* FILL ME */
+ LAST_SIGNAL
+};
+
+enum
+{
+ PROP_0,
+ PROP_SILENT
+};
+
+static GstStaticPadTemplate sinktemplate = GST_STATIC_PAD_TEMPLATE ("sink",
+ GST_PAD_SINK,
+ GST_PAD_ALWAYS,
+ GST_STATIC_CAPS_ANY);
+
+#define _do_init \
+ GST_DEBUG_CATEGORY_INIT (gst_tensor_sink_debug, "tensor_sink", 0, "tensor_sink element");
+#define gst_tensor_sink_parent_class parent_class
+G_DEFINE_TYPE_WITH_CODE (GstTensorSink, gst_tensor_sink, GST_TYPE_BASE_SINK,
+ _do_init);
+
+static void gst_tensor_sink_set_property (GObject * object, guint prop_id,
+ const GValue * value, GParamSpec * pspec);
+static void gst_tensor_sink_get_property (GObject * object, guint prop_id,
+ GValue * value, GParamSpec * pspec);
+
+static gboolean gst_tensor_sink_start (GstBaseSink * basesink);
+static gboolean gst_tensor_sink_stop (GstBaseSink * basesink);
+static gboolean gst_tensor_sink_event (GstBaseSink * basesink,
+ GstEvent * event);
+static gboolean gst_tensor_sink_query (GstBaseSink * basesink,
+ GstQuery * query);
+
+
+/* initialize tensor_sink's class */
+static void
+gst_tensor_sink_class_init (GstTensorSinkClass * klass)
+{
+ GObjectClass *gobject_class;
+ GstElementClass *gstelement_class;
+ GstBaseSinkClass *gstbasesink_class;
+
+ gobject_class = G_OBJECT_CLASS (klass);
+ gstelement_class = GST_ELEMENT_CLASS (klass);
+ gstbasesink_class = GST_BASE_SINK_CLASS (klass);
+
+ /* gobject methods */
+ gobject_class->set_property = gst_tensor_sink_set_property;
+ gobject_class->get_property = gst_tensor_sink_get_property;
+
+ /* properties */
+ /* TODO: add necessary properties */
+ g_object_class_install_property (gobject_class, PROP_SILENT,
+ g_param_spec_boolean ("silent", "Silent", "Produce verbose output ?",
+ FALSE, G_PARAM_READWRITE));
+
+ gst_element_class_set_static_metadata (gstelement_class,
+ "Tensor_Sink",
+ "Sink/Tensor",
+ "Sink element to handle tensor stream", "nnstreamer <nnstreamer sec>");
+
+ gst_element_class_add_static_pad_template (gstelement_class, &sinktemplate);
+
+ /* basesink methods */
+ /* TODO: add necessary methods */
+ gstbasesink_class->start = GST_DEBUG_FUNCPTR (gst_tensor_sink_start);
+ gstbasesink_class->stop = GST_DEBUG_FUNCPTR (gst_tensor_sink_stop);
+ gstbasesink_class->event = GST_DEBUG_FUNCPTR (gst_tensor_sink_event);
+ gstbasesink_class->query = GST_DEBUG_FUNCPTR (gst_tensor_sink_query);
+}
+
+/* initialize tensor_sink element */
+static void
+gst_tensor_sink_init (GstTensorSink * tensor_sink)
+{
+ /* TODO: init properties */
+ tensor_sink->silent = FALSE;
+
+ gst_base_sink_set_sync (GST_BASE_SINK (tensor_sink), FALSE);
+}
+
+/* gobject methods */
+static void
+gst_tensor_sink_set_property (GObject * object, guint prop_id,
+ const GValue * value, GParamSpec * pspec)
+{
+ GstTensorSink *tensor_sink;
+
+ tensor_sink = GST_TENSOR_SINK (object);
+
+ switch (prop_id) {
+ case PROP_SILENT:
+ tensor_sink->silent = g_value_get_boolean (value);
+ break;
+
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+ break;
+ }
+}
+
+static void
+gst_tensor_sink_get_property (GObject * object, guint prop_id,
+ GValue * value, GParamSpec * pspec)
+{
+ GstTensorSink *tensor_sink;
+
+ tensor_sink = GST_TENSOR_SINK (object);
+
+ switch (prop_id) {
+ case PROP_SILENT:
+ g_value_set_boolean (value, tensor_sink->silent);
+ break;
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+ break;
+ }
+}
+
+/* basesink methods */
+static gboolean
+gst_tensor_sink_start (GstBaseSink * basesink)
+{
+ /* TODO: init resources */
+ return TRUE;
+}
+
+static gboolean
+gst_tensor_sink_stop (GstBaseSink * basesink)
+{
+ /* TODO: free resources */
+ return TRUE;
+}
+
+static gboolean
+gst_tensor_sink_event (GstBaseSink * basesink, GstEvent * event)
+{
+ GstEventType type;
+
+ type = GST_EVENT_TYPE (event);
+
+ /* TODO: add event handler */
+ switch (type) {
+ case GST_EVENT_CAPS:
+ break;
+
+ default:
+ break;
+ }
+
+ return GST_BASE_SINK_CLASS (parent_class)->event (basesink, event);
+}
+
+static gboolean
+gst_tensor_sink_query (GstBaseSink * basesink, GstQuery * query)
+{
+ gboolean res = FALSE;
+ GstQueryType type;
+
+ type = GST_QUERY_TYPE (query);
+
+ /* TODO: add query handler */
+ switch (type) {
+ case GST_QUERY_FORMATS:
+ gst_query_set_formats (query, 2, GST_FORMAT_DEFAULT, GST_FORMAT_BYTES);
+ res = TRUE;
+ break;
+
+ default:
+ res = GST_BASE_SINK_CLASS (parent_class)->query (basesink, query);
+ break;
+ }
+
+ return res;
+}
--- /dev/null
+/*
+ * GStreamer
+ * Copyright (C) 2005 Thomas Vander Stichele <thomas@apestaart.org>
+ * Copyright (C) 2005 Ronald S. Bultje <rbultje@ronald.bitfreak.net>
+ * Copyright (C) 2018 nnstreamer <nnstreamer sec>
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a
+ * copy of this software and associated documentation files (the "Software"),
+ * to deal in the Software without restriction, including without limitation
+ * the rights to use, copy, modify, merge, publish, distribute, sublicense,
+ * and/or sell copies of the Software, and to permit persons to whom the
+ * Software is furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in
+ * all copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+ * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+ * DEALINGS IN THE SOFTWARE.
+ *
+ * Alternatively, the contents of this file may be used under the
+ * GNU Lesser General Public License Version 2.1 (the "LGPL"), in
+ * which case the following provisions apply instead of the ones
+ * mentioned above:
+ *
+ * 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.
+ *
+ * @file tensor_sink.h
+ * @date 15 June 2018
+ * @brief GStreamer plugin to handle tensor stream
+ * @see http://github.com/TO-BE-DETERMINED-SOON
+ * @see https://github.sec.samsung.net/STAR/nnstreamer
+ * @author Jaeyun Jung <jy1210.jung@samsung.com>
+ *
+ */
+
+#ifndef __GST_TENSOR_SINK_H__
+#define __GST_TENSOR_SINK_H__
+
+#include <gst/gst.h>
+#include <gst/base/gstbasesink.h>
+
+G_BEGIN_DECLS
+
+/* #defines don't like whitespacey bits */
+#define GST_TYPE_TENSOR_SINK \
+ (gst_tensor_sink_get_type())
+#define GST_TENSOR_SINK(obj) \
+ (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_TENSOR_SINK,GstTensorSink))
+#define GST_TENSOR_SINK_CLASS(klass) \
+ (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_TENSOR_SINK,GstTensorSinkClass))
+#define GST_IS_TENSOR_SINK(obj) \
+ (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_TENSOR_SINK))
+#define GST_IS_TENSOR_SINK_CLASS(klass) \
+ (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_TENSOR_SINK))
+
+typedef struct _GstTensorSink GstTensorSink;
+typedef struct _GstTensorSinkClass GstTensorSinkClass;
+
+struct _GstTensorSink {
+ GstBaseSink element;
+
+ gboolean silent;
+};
+
+struct _GstTensorSinkClass {
+ GstBaseSinkClass parent_class;
+};
+
+GType gst_tensor_sink_get_type (void);
+
+G_END_DECLS
+
+#endif /* __GST_TENSOR_SINK_H__ */
projects / platform / upstream / nnstreamer.git / commitdiff