rygel r344 - trunk/src/plugins/test

[zeeshanak svn gnome org]

Author: zeeshanak
Date: Sun Dec 14 20:22:17 2008
New Revision: 344
URL: http://svn.gnome.org/viewvc/rygel?rev=344&view=rev

Log:
Add a video item to test plugin.

Streams video from 'videotestsrc is-live=true ! theoraenc ! oggmux'.

Added:
   trunk/src/plugins/test/rygel-test-video-item.vala
Modified:
   trunk/src/plugins/test/Makefile.am
   trunk/src/plugins/test/rygel-test-content-dir.vala

Modified: trunk/src/plugins/test/Makefile.am
==============================================================================
--- trunk/src/plugins/test/Makefile.am	(original)
+++ trunk/src/plugins/test/Makefile.am	Sun Dec 14 20:22:17 2008
@@ -14,6 +14,8 @@
 		rygel-test-content-dir.c \
 		rygel-test-audio-item.h \
 		rygel-test-audio-item.c \
+                rygel-test-video-item.h \
+                rygel-test-video-item.c \
 		rygel-test-plugin.h \
 		rygel-test-plugin.c
 
@@ -23,6 +25,9 @@
                            rygel-test-audio-item.h \
                            rygel-test-audio-item.c \
                            rygel-test-audio-item.vala \
+                           rygel-test-video-item.h \
+                           rygel-test-video-item.c \
+                           rygel-test-video-item.vala \
                            rygel-test-plugin.h \
                            rygel-test-plugin.c \
                            rygel-test-plugin.vala

Modified: trunk/src/plugins/test/rygel-test-content-dir.vala
==============================================================================
--- trunk/src/plugins/test/rygel-test-content-dir.vala	(original)
+++ trunk/src/plugins/test/rygel-test-content-dir.vala	Sun Dec 14 20:22:17 2008
@@ -46,6 +46,10 @@
                                               this.root_container.id,
                                               "Sine Wave",
                                               streamer));
+        this.items.append (new TestVideoItem ("smtpe",
+                                              this.root_container.id,
+                                              "SMTPE",
+                                              streamer));
 
         // Now we know how many top-level items we have
         this.root_container.child_count = this.items.length ();

Added: trunk/src/plugins/test/rygel-test-video-item.vala
==============================================================================
--- (empty file)
+++ trunk/src/plugins/test/rygel-test-video-item.vala	Sun Dec 14 20:22:17 2008
@@ -0,0 +1,109 @@
+/*
+ * Copyright (C) 2008 Zeeshan Ali (Khattak) <zeeshanak gnome org>.
+ * Copyright (C) 2008 Nokia Corporation, all rights reserved.
+ *
+ * Author: Zeeshan Ali (Khattak) <zeeshanak gnome org>
+ *                               <zeeshan ali nokia com>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program 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 General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+ * 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.
+ */
+
+using Rygel;
+using GUPnP;
+using Gee;
+using Gst;
+
+/**
+ * Represents Test video item.
+ */
+public class Rygel.TestVideoItem : Rygel.MediaItem {
+    const string TEST_PATH = "/test.ogg";
+    const string TEST_MIMETYPE = "application/ogg";
+    const string TEST_AUTHOR = "Zeeshan Ali (Khattak)";
+
+    private Streamer streamer;
+
+    public TestVideoItem (string   id,
+                          string   parent_id,
+                          string   title,
+                          Streamer streamer) {
+        base (id, parent_id, title, MediaItem.VIDEO_CLASS);
+        this.mime = TEST_MIMETYPE;
+        this.author = TEST_AUTHOR;
+        this.uri = streamer.create_uri_for_path (TEST_PATH);
+
+        this.streamer = streamer;
+
+        streamer.stream_available += this.on_stream_available;
+    }
+
+    private void on_stream_available (Streamer streamer,
+                                      Stream   stream,
+                                      string   path) {
+        if (path != TEST_PATH) {
+            /* Not our path and therefore not interesting. */
+            stream.reject ();
+            return;
+        }
+
+        // FIXME: This should be done by GstStream
+        stream.set_mime_type (TestVideoItem.TEST_MIMETYPE);
+
+        try {
+            Element src = this.create_gst_source ();
+            // Ask streamer to handle the stream for us but use our source in
+            // the pipeline.
+            streamer.stream_from_gst_source (src, stream);
+        } catch (Error error) {
+            critical ("Error in attempting to start streaming %s: %s",
+                      path,
+                      error.message);
+
+            return;
+        }
+    }
+
+    private Element create_gst_source () throws Error {
+        Bin bin = new Bin (this.title);
+
+        dynamic Element src = ElementFactory.make ("videotestsrc", null);
+        Element encoder = ElementFactory.make ("theoraenc", null);
+        Element muxer = ElementFactory.make ("oggmux", null);
+
+        if (src == null || muxer == null || encoder == null) {
+            throw new GstStreamError.MISSING_PLUGIN ("Required plugin missing");
+        }
+
+        // Tell the source to behave like a live source
+        src.is_live = true;
+
+        // Add elements to our source bin
+        bin.add_many (src, muxer, encoder);
+        // Link them
+        src.link_many (muxer, encoder);
+
+        // Now add the encoder's src pad to the bin
+        Pad pad = muxer.get_static_pad ("src");
+        var ghost = new GhostPad (bin.name + "." + pad.name, pad);
+        bin.add_pad (ghost);
+
+        return bin;
+    }
+}
+