Initsandbox/mvlad/waltham-remoting

Signed-off-by: Marius Vlad <marius.vlad@collabora.com>

5 files changed, 311 insertions, 0 deletions

diff --git a/attic/waltham-renderer/meson.build b/attic/waltham-renderer/meson.build
new file mode 100644
index 0000000..9754bc9
--- /dev/null
+++ b/attic/waltham-renderer/meson.build
@@ -0,0 +1,27 @@
+
+libpixman_dep = dependency('pixman-1')
+dep_gstreamer = dependency('gstreamer-1.0')
+dep_gstreamer_app = dependency('gstreamer-app-1.0')
+dep_gstreamer_video = dependency('gstreamer-video-1.0')
+dep_gstreamer_alloc = dependency('gstreamer-allocators-1.0')
+
+deps_renderer_plugin = [
+    libwayland_dep,
+    libpixman_dep,
+    libweston_dep,
+    libwaltham_dep,
+    weston_dep,
+    dep_gstreamer, dep_gstreamer_app,
+    dep_gstreamer_video, dep_gstreamer_alloc
+]
+
+plugin_renderer = shared_library(
+	'waltham-renderer',
+	'waltham-renderer.c',
+	include_directories: common_inc,
+	dependencies: deps_renderer_plugin,
+	name_prefix: '',
+	install: true,
+	install_dir: plugin_install_dir,
+)
+env_modmap += 'renderer-plugin.so=@0@;'.format(plugin_renderer.full_path())
diff --git a/attic/waltham-renderer/pipeline_example_general.cfg b/attic/waltham-renderer/pipeline_example_general.cfg
new file mode 100644
index 0000000..31db32e
--- /dev/null
+++ b/attic/waltham-renderer/pipeline_example_general.cfg
@@ -0,0 +1 @@
+appsrc name=src ! videoconvert ! video/x-raw,format=I420 ! jpegenc ! rtpjpegpay ! udpsink name=sink host=YOUR_RECIEVER_IP port=YOUR_RECIEVER_PORT sync=false async=false
\ No newline at end of file
diff --git a/attic/waltham-renderer/pipeline_example_intel.cfg b/attic/waltham-renderer/pipeline_example_intel.cfg
new file mode 100644
index 0000000..8440bce
--- /dev/null
+++ b/attic/waltham-renderer/pipeline_example_intel.cfg
@@ -0,0 +1 @@
+appsrc name=src ! videoconvert ! video/x-raw,format=I420 ! mfxh264enc bitrate=3000000 rate-control=1 ! rtph264pay config-interval=1 ! udpsink name=sink host=YOUR_RECIEVER_IP port=YOUR_RECIEVER_PORT sync=false async=false
\ No newline at end of file
diff --git a/attic/waltham-renderer/pipeline_example_rcar.cfg b/attic/waltham-renderer/pipeline_example_rcar.cfg
new file mode 100644
index 0000000..2993365
--- /dev/null
+++ b/attic/waltham-renderer/pipeline_example_rcar.cfg
@@ -0,0 +1 @@
+appsrc name=src ! videoconvert ! video/x-raw,format=I420 ! omxh264enc bitrate=3000000 control-rate=2 ! rtph264pay ! udpsink name=sink host=YOUR_RECIEVER_IP port=YOUR_RECIEVER_PORT sync=false async=false
\ No newline at end of file
diff --git a/attic/waltham-renderer/waltham-renderer.c b/attic/waltham-renderer/waltham-renderer.c
new file mode 100644
index 0000000..cda354e
--- /dev/null
+++ b/attic/waltham-renderer/waltham-renderer.c
@@ -0,0 +1,281 @@
+/*
+ * Copyright (C) 2017 Advanced Driver Information Technology GmbH, Robert Bosch GmbH, Robert Bosch Car Multimedia GmbH, DENSO Corporation
+ *
+ * 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 (including the
+ * next paragraph) 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.
+ */
+
+#include <stdlib.h>
+#include <assert.h>
+#include <string.h>
+
+#include <gst/gst.h>
+#include <gst/video/gstvideometa.h>
+#include <gst/allocators/gstdmabuf.h>
+#include <gst/app/gstappsrc.h>
+
+#include <libweston/libweston.h>
+
+#include "transmitter_api.h"
+#include "waltham-renderer.h"
+#include "plugin.h"
+
+struct waltham_renderer {
+	struct renderer base;
+};
+
+struct GstAppContext {
+	GMainLoop *loop;
+	GstBus *bus;
+	GstElement *pipeline;
+	GstElement *appsrc;
+	GstBuffer *gstbuffer;
+};
+
+gboolean bus_message(GstBus *bus, GstMessage *message, gpointer p)
+{
+	struct GstAppContext *gstctx = p;
+
+	switch( GST_MESSAGE_TYPE(message)) {
+        case GST_MESSAGE_ERROR:
+	{
+		GError *err;
+		gchar *debug;
+
+		gst_message_parse_error(message, &err, &debug);
+		g_print("ERROR: %s\n", err->message);
+
+		g_error_free(err);
+		g_free(debug);
+		g_main_loop_quit(gstctx->loop);
+
+		return false;
+		break;
+	}
+
+	case GST_MESSAGE_STATE_CHANGED:
+	{
+		GstState oldstate, newstate;
+
+		gst_message_parse_state_changed(message, &oldstate, &newstate, NULL);
+		switch (newstate){
+		case GST_STATE_PAUSED:
+			fprintf(stderr, "%s: state is paused\n", GST_MESSAGE_SRC_NAME(message));
+			break;
+		case GST_STATE_READY:
+			fprintf(stderr, "%s: state is ready\n", GST_MESSAGE_SRC_NAME(message));
+			break;
+		case GST_STATE_VOID_PENDING:
+			fprintf(stderr, "%s: state is pending\n", GST_MESSAGE_SRC_NAME(message));
+			break;
+		case GST_STATE_NULL:
+			fprintf(stderr, "%s: state is NULL\n", GST_MESSAGE_SRC_NAME(message));
+			break;
+		case GST_STATE_PLAYING:
+			fprintf(stderr, "%s: state is playing\n", GST_MESSAGE_SRC_NAME(message));
+			break;
+		}
+		break;
+	}
+        default:
+		fprintf(stderr, "Unhandled message\n");
+		break;
+	}
+
+	return true;
+}
+
+static int
+gst_pipe_init(struct weston_transmitter_output *output, struct gst_settings *settings)
+{
+	struct GstAppContext *gstctx;
+	GstCaps *caps;
+	GError *gerror = NULL;
+	FILE * pFile;
+	size_t lSize;
+	char * pipe = NULL;
+	size_t res;
+
+	gstctx=zalloc(sizeof (*gstctx));
+	if(!gstctx){
+		weston_log("Enable to allocate memory\n");
+		return -1;
+	}
+
+	/* create gstreamer pipeline */
+	gst_init(NULL, NULL);
+	gstctx->loop = g_main_loop_new(NULL, FALSE);
+
+	/* read pipeline from file */
+	pFile = fopen("/etc/xdg/weston/transmitter_pipeline.cfg" , "rb");
+	if (pFile==NULL) {
+		weston_log("File open error\n");
+		return -1;
+	}
+
+	/* obtain file size */
+	fseek (pFile , 0 , SEEK_END);
+	lSize = ftell (pFile);
+	rewind (pFile);
+
+	/* allocate memory to contain the whole file: */
+	pipe = zalloc (sizeof(char) * lSize);
+	if (pipe == NULL) {
+		weston_log("Cannot allocate memory\n");
+		return -1;
+	}
+
+	/* copy the file into the buffer: */
+	res = fread (pipe,1,lSize,pFile);
+	if (res != lSize)
+	{
+		weston_log("File read error\n");
+		return -1;
+	}
+
+	/* close file */
+	fclose(pFile);
+	weston_log("Parsing GST pipeline:%s",pipe);
+	gstctx->pipeline = gst_parse_launch(pipe, &gerror);
+	free(pipe);
+	if(!gstctx->pipeline)
+		weston_log("Could not create gstreamer pipeline.\n");
+
+	gstctx->bus = gst_pipeline_get_bus((GstPipeline*)((void*)gstctx->pipeline));
+	gst_bus_add_watch(gstctx->bus, bus_message, &gstctx);
+
+	//gstctx->appsrc = (GstAppSrc*) gst_bin_get_by_name(GST_BIN(gstctx->pipeline), "src");
+	gstctx->appsrc = gst_bin_get_by_name(GST_BIN(gstctx->pipeline), "src");
+	if (!gstctx->appsrc)
+		return -1;
+
+	caps = gst_caps_new_simple("video/x-raw",
+				   "format", G_TYPE_STRING, "BGRx",
+				   "width", G_TYPE_INT, settings->width,
+				   "height", G_TYPE_INT, settings->height,
+				   NULL);
+	if (!caps)
+		return -1;
+
+	g_object_set(G_OBJECT(gstctx->appsrc),
+		     "caps", caps,
+		     "stream-type", 0,
+		     "format", GST_FORMAT_TIME,
+		     "is-live", TRUE,
+		     NULL);
+	gst_caps_unref(caps);
+
+	gst_element_set_state((GstElement*)((void*)gstctx->pipeline), GST_STATE_PLAYING);
+	output->renderer->ctx = gstctx;
+
+	weston_log("Gstreamer pipeline inited\n");
+
+	return 0;
+}
+
+static int
+recorder_enable(struct weston_transmitter_output *output)
+{
+	struct gst_settings *settings;
+
+	struct weston_transmitter_remote* remote = output->remote;
+
+	/*
+	 * Limitation:
+	 * Hard coding bitrate and crop params.
+	 * In case of gst-recorder case these were taken from weston.ini
+	 */
+	int32_t bitrate = 3000000;
+
+	settings = malloc(sizeof(* settings));
+	settings->ip = remote->addr;
+
+	settings->port = atoi(remote->port);
+
+	settings->bitrate = bitrate;
+	settings->width = output->renderer->surface_width;
+	settings->height = output->renderer->surface_height;
+
+	weston_log("gst-setting are :-->\n");
+	weston_log("ip = %s \n",settings->ip);
+	weston_log("port = %d \n",settings->port);
+	weston_log("bitrate = %d \n",settings->bitrate);
+	weston_log("width = %d \n",settings->width);
+	weston_log("height = %d \n",settings->height);
+
+	gst_pipe_init(output, settings);
+
+	weston_log("Enabling renderer display\n");
+
+	return 0;
+}
+
+static void waltham_renderer_repaint_output(struct weston_transmitter_output *output)
+{
+	GstBuffer *gstbuffer;
+	GstMemory *mem;
+	GstAllocator *allocator;
+	int stride = output->renderer->buf_stride;
+	gsize offset = 0;
+
+	if (!output->renderer->recorder_enabled) {
+		recorder_enable(output);
+		output->renderer->recorder_enabled = 1;
+	}
+
+	gstbuffer = gst_buffer_new();
+	allocator = gst_dmabuf_allocator_new();
+	mem = gst_dmabuf_allocator_alloc(allocator, output->renderer->dmafd,
+					 stride * output->renderer->surface_height);
+	gst_buffer_append_memory(gstbuffer, mem);
+	gst_buffer_add_video_meta_full(gstbuffer,
+				       GST_VIDEO_FRAME_FLAG_NONE,
+				       GST_VIDEO_FORMAT_BGRx,
+				       output->renderer->surface_width,
+				       output->renderer->surface_height,
+				       1,
+				       &offset,
+				       &stride);
+
+	gst_app_src_push_buffer(GST_APP_SRC(output->renderer->ctx->appsrc), gstbuffer);
+	gst_object_unref(allocator);
+}
+
+static int
+waltham_renderer_display_create(struct weston_transmitter_output *output)
+{
+	struct waltham_renderer *wth_renderer;
+
+	wth_renderer = zalloc(sizeof *wth_renderer);
+	if (wth_renderer == NULL)
+		return -1;
+
+	wth_renderer->base.repaint_output = waltham_renderer_repaint_output;
+	output->renderer = &wth_renderer->base;
+
+	weston_log("Created renderer display\n");
+
+	return 0;
+}
+
+WL_EXPORT struct waltham_renderer_interface waltham_renderer_interface = {
+		.display_create = waltham_renderer_display_create
+};