pidgin.yaz: libpurple/media.c comparison

comparison libpurple/media.c @ 26152:7be8c88d630c

Have all media sessions use a single pipeline. This temporarily breaks the audio levels.

author	Mike Ruprecht <maiku@soc.pidgin.im>
date	Sat, 31 Jan 2009 05:19:16 +0000
parents	4f013819e4e3
children	4cbf594b2f17

comparison

equal deleted inserted replaced

-:e6d548856fcd
+:7be8c88d630c
 	GHashTable *participants; /* FsParticipant table */
 	GList *streams;		/* PurpleMediaStream table */
 	GstElement *pipeline;
+	GstElement *confbin;
 };
 #define PURPLE_MEDIA_GET_PRIVATE(obj) (G_TYPE_INSTANCE_GET_PRIVATE((obj), PURPLE_TYPE_MEDIA, PurpleMediaPrivate))
 static void purple_media_class_init (PurpleMediaClass *klass);
 	purple_debug_info("media","purple_media_dispose\n");
 	purple_media_manager_remove_media(purple_media_manager_get(),
 			PURPLE_MEDIA(media));
-	if (priv->pipeline) {
+	if (priv->confbin) {
-		GstBus *bus = gst_pipeline_get_bus(GST_PIPELINE(priv->pipeline));
+		gst_element_set_state(GST_ELEMENT(priv->confbin),
-		gst_bus_remove_signal_watch(bus);
+				GST_STATE_NULL);
-		gst_object_unref(bus);
+		gst_bin_remove(GST_BIN(priv->pipeline), priv->confbin);
-		gst_element_set_state(priv->pipeline, GST_STATE_NULL);
+		priv->confbin = NULL;
-		gst_object_unref(priv->pipeline);
+		priv->conference = NULL;
-		priv->pipeline = NULL;
 	}
 	for (iter = priv->streams; iter; iter = g_list_next(iter)) {
 		PurpleMediaStream *stream = iter->data;
 		if (stream->stream) {
 			purple_media_session_free(sessions->data);
 		}
 		g_hash_table_destroy(priv->sessions);
 	}
-	gst_object_unref(priv->conference);
 	G_OBJECT_CLASS(parent_class)->finalize(media);
 }
 static void
 purple_media_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec)
 	g_return_if_fail(PURPLE_IS_MEDIA(object));
 	media = PURPLE_MEDIA(object);
 	switch (prop_id) {
-		case PROP_CONFERENCE:
+		case PROP_CONFERENCE: {
+			gchar *name;
 			if (media->priv->conference)
-				g_object_unref(media->priv->conference);
+				gst_object_unref(media->priv->conference);
 			media->priv->conference = g_value_get_object(value);
-			g_object_ref(media->priv->conference);
+			gst_object_ref(media->priv->conference);
+			name = g_strdup_printf("conf_%p",
+					media->priv->conference);
+			media->priv->confbin = gst_bin_new(name);
+			g_free(name);
+			gst_bin_add(GST_BIN(purple_media_get_pipeline(media)),
+					media->priv->confbin);
+			gst_bin_add(GST_BIN(media->priv->confbin),
+					GST_ELEMENT(media->priv->conference));
+			gst_element_set_state(GST_ELEMENT(
+					media->priv->confbin),
+					GST_STATE_PLAYING);
 			break;
+		}
 		case PROP_INITIATOR:
 			media->priv->initiator = g_value_get_boolean(value);
 			break;
 		default:
 			G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
 	GstPad *srcpad;
 	if (session->src)
 		gst_object_unref(session->src);
 	session->src = src;
-	gst_bin_add(GST_BIN(purple_media_get_pipeline(media)),
+	gst_bin_add(GST_BIN(session->media->priv->confbin),
 		    session->src);
 	g_object_get(session->session, "sink-pad", &sinkpad, NULL);
 	srcpad = gst_element_get_static_pad(src, "ghostsrc");
 	purple_debug_info("media", "connecting pad: %s\n",
 			purple_media_get_stream(media, sess_id, participant);
 	if (stream->sink)
 		gst_object_unref(stream->sink);
 	stream->sink = sink;
-	gst_bin_add(GST_BIN(purple_media_get_pipeline(media)),
+	gst_bin_add(GST_BIN(stream->session->media->priv->confbin),
 		    stream->sink);
 }
 GstElement *
 purple_media_get_src(PurpleMedia *media, const gchar *sess_id)
 				0, NULL, NULL);
 	}
 }
 static gboolean
-media_bus_call(GstBus *bus, GstMessage *msg, gpointer media)
+media_bus_call(GstBus *bus, GstMessage *msg, gpointer dummy)
 {
 	switch(GST_MESSAGE_TYPE(msg)) {
 		case GST_MESSAGE_EOS:
 			purple_debug_info("media", "End of Stream\n");
 			break;
 				g_free (debug);
 			}
 			break;
 		}
 		case GST_MESSAGE_ELEMENT: {
+			PurpleMedia *media = NULL;
+			if (FS_IS_CONFERENCE(GST_MESSAGE_SRC(msg))) {
+				GList *iter = purple_media_manager_get_media(
+						purple_media_manager_get());
+				for (; iter; iter = g_list_next(iter)) {
+					if (PURPLE_MEDIA(iter->data)->priv->conference
+							== FS_CONFERENCE(GST_MESSAGE_SRC(msg))) {
+						media = iter->data;
+						break;
+					}
+				}
+			}
 			if (gst_structure_has_name(msg->structure, "farsight-error")) {
 				FsError error_no;
 				gst_structure_get_enum(msg->structure, "error-no",
 						FS_TYPE_ERROR, (gint*)&error_no);
 				/*
 }
 GstElement *
 purple_media_get_pipeline(PurpleMedia *media)
 {
-	if (!media->priv->pipeline) {
+	static GstElement *pipeline = NULL;
+	if (!pipeline) {
 		GstBus *bus;
-		media->priv->pipeline = gst_pipeline_new(NULL);
+		media->priv->pipeline = pipeline = gst_pipeline_new(NULL);
 		bus = gst_pipeline_get_bus(GST_PIPELINE(media->priv->pipeline));
 		gst_bus_add_signal_watch(GST_BUS(bus));
 		g_signal_connect(G_OBJECT(bus), "message",
-				G_CALLBACK(media_bus_call), media);
+				G_CALLBACK(media_bus_call), NULL);
 		gst_bus_set_sync_handler(bus, gst_bus_sync_signal_handler, NULL);
 		gst_object_unref(bus);
+		gst_element_set_state(pipeline, GST_STATE_PLAYING);
-		gst_bin_add(GST_BIN(media->priv->pipeline), GST_ELEMENT(media->priv->conference));
+	}
-	}
+	media->priv->pipeline = pipeline;
 	return media->priv->pipeline;
 }
 void
 purple_media_error(PurpleMedia *media, const gchar *error, ...)
 	if (stream->sink == NULL)
 		stream->sink = purple_media_manager_get_element(
 			purple_media_manager_get(), type);
-	gst_bin_add(GST_BIN(purple_media_get_pipeline(stream->session->media)),
+	gst_bin_add(GST_BIN(stream->session->media->priv->confbin),
 		    stream->sink);
 	sinkpad = gst_element_get_static_pad(stream->sink, "ghostsink");
 	gst_pad_link(srcpad, sinkpad);
 	gst_element_set_state(stream->sink, GST_STATE_PLAYING);

Mercurial > pidgin.yaz

comparison libpurple/media.c @ 26152:7be8c88d630c