rygel r92 - in trunk: . src

[zeeshanak svn gnome org]

Author: zeeshanak
Date: Tue Oct 28 21:00:07 2008
New Revision: 92
URL: http://svn.gnome.org/viewvc/rygel?rev=92&view=rev

Log:
Copy the ConnectionManager code from gupnp-media-renderer.

Added:
   trunk/src/gupnp-connection-manager.vala
Modified:
   trunk/ChangeLog
   trunk/src/Makefile.am

Modified: trunk/src/Makefile.am
==============================================================================
--- trunk/src/Makefile.am	(original)
+++ trunk/src/Makefile.am	Tue Oct 28 21:00:07 2008
@@ -22,6 +22,9 @@
 			     gupnp-content-directory.h \
 			     gupnp-content-directory.c \
 			     gupnp-content-directory.vala \
+			     gupnp-connection-manager.h \
+			     gupnp-connection-manager.c \
+			     gupnp-connection-manager.vala \
 			     gupnp-media-receiver-registrar.h \
 			     gupnp-media-receiver-registrar.c \
 			     gupnp-media-receiver-registrar.vala \

Added: trunk/src/gupnp-connection-manager.vala
==============================================================================
--- (empty file)
+++ trunk/src/gupnp-connection-manager.vala	Tue Oct 28 21:00:07 2008
@@ -0,0 +1,146 @@
+/*
+ * Copyright (C) 2008 OpenedHand Ltd.
+ *
+ * Author: Jorn Baayen <jorn openedhand 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 GLib;
+using GUPnP;
+
+public class GUPnP.ConnectionManager : Service {
+    private string sink_protocol_info   = "http-get:*:audio/mpeg:*,http-get:*:application/ogg:*,http-get:*:audio/x-vorbis:*,http-get:*:audio/x-ms-wma:*,http-get:*:audio/x-ms-asf:*,http-get:*:audio/x-flac:*,http-get:*:audio/x-mod:*,http-get:*:audio/x-wav:*,http-get:*:audio/x-ac3:*,http-get:*:audio/x-m4a:*,http-get:*:video/x-theora:*,http-get:*:video/x-dirac:*,http-get:*:video/x-wmv:*,http-get:*:video/x-wma:*,http-get:*:video/x-msvideo:*,http-get:*:video/x-3ivx:*,http-get:*:video/x-3ivx:*,http-get:*:video/x-matroska:*,http-get:*:video/mpeg:*,http-get:*:video/x-ms-asf:*,http-get:*:video/x-divx:*,http-get:*:video/x-ms-wmv:*";
+    private string source_protocol_info = "";
+    private string connection_ids       = "0";
+
+    // Creates a list of supported sink protocols based on GStreamer's
+    // registry. We don't use this because of the spam it generates ..
+    /*
+    private void setup_sink_protocol_info () {
+        Gst.Registry reg = Gst.Registry.get_default ();
+
+        Gee.HashSet<string> mime_types =
+            new Gee.HashSet<string> (GLib.str_hash, GLib.str_equal);
+
+        weak List<Gst.ElementFactory> factories =
+                reg.get_feature_list (typeof (Gst.ElementFactory));
+        foreach (Gst.ElementFactory factory in factories) {
+            weak List<Gst.StaticPadTemplate> templates =
+                factory.staticpadtemplates;
+            foreach (weak Gst.StaticPadTemplate template in templates) {
+                if (template.direction != Gst.PadDirection.SINK) {
+                    continue;
+                }
+
+                Gst.Caps caps = template.static_caps.get ();
+                for (int i = 0; i < caps.get_size (); i++) {
+                    weak Gst.Structure str =
+                        template.static_caps.get_structure (i);
+
+                    mime_types.add (str.get_name ());
+                }
+            }
+        }
+
+        foreach (string type in mime_types) {
+            stdout.printf ("%s\n", type);
+        }
+    }
+    */
+
+    construct {
+        /* FIXME: Use Vala's syntax for connecting signals when Vala adds
+         * support for signal details. */
+        Signal.connect (this,
+                        "query-variable::SourceProtocolInfo",
+                        (GLib.Callback) this.query_source_protocol_info_cb,
+                        null);
+        Signal.connect (this,
+                        "query-variable::SinkProtocolInfo",
+                        (GLib.Callback) this.query_sink_protocol_info_cb,
+                        null);
+        Signal.connect (this,
+                        "query-variable::CurrentConnectionIDs",
+                        (GLib.Callback) this.query_current_connection_ids_cb,
+                        null);
+
+        Signal.connect (this,
+                        "action-invoked::GetProtocolInfo",
+                        (GLib.Callback) this.get_protocol_info_cb,
+                        null);
+        Signal.connect (this,
+                        "action-invoked::GetCurrentConnectionIDs",
+                        (GLib.Callback) this.get_current_connection_ids_cb,
+                        null);
+        Signal.connect (this,
+                        "action-invoked::GetCurrentConnectionInfo",
+                        (GLib.Callback) this.get_current_connection_info_cb,
+                        null);
+    }
+
+    private void query_source_protocol_info_cb (string var, Value val) {
+        val.init (typeof (string));
+        val.set_string (source_protocol_info);
+    }
+
+    private void query_sink_protocol_info_cb (string var, Value val) {
+        val.init (typeof (string));
+        val.set_string (sink_protocol_info);
+    }
+
+    private void query_current_connection_ids_cb (string var, Value val) {
+        val.init (typeof (string));
+        val.set_string (connection_ids);
+    }
+
+    private void get_protocol_info_cb (ServiceAction action) {
+        action.set ("Source", typeof (string), source_protocol_info,
+                    "Sink",   typeof (string), sink_protocol_info);
+
+        action.return ();
+    }
+
+    private void get_current_connection_ids_cb (ServiceAction action) {
+        action.set ("ConnectionIDs", typeof (string), connection_ids);
+
+        action.return ();
+    }
+
+    private void get_current_connection_info_cb (ServiceAction action) {
+        int connection_id;
+
+        action.get ("ConnectionID", typeof (int), out connection_id);
+        if (connection_id != 0) {
+            action.return_error (706, "Invalid connection reference");
+
+            return;
+        }
+
+        action.set ("ResID",                 typeof (int),    -1,
+                    "AVTransportID",         typeof (int),    -1,
+                    "ProtocolInfo",          typeof (string), "",
+                    "PeerConnectionManager", typeof (string), "",
+                    "PeerConnectionID",      typeof (int),    -1,
+                    "Direction",             typeof (string), "Input",
+                    "Status",                typeof (string), "Unknown");
+
+        action.return ();
+    }
+}