pidgin.yaz: pidgin/gtkmedia.c comparison

comparison pidgin/gtkmedia.c @ 26135:c334a9e17426

Wait to create the sinks until the frames are ready. This should hopefully be the end of the BadWindow errors.

author	Mike Ruprecht <maiku@soc.pidgin.im>
date	Mon, 19 Jan 2009 10:44:07 +0000
parents	6eeb500ce9a2
children	f6a98b2b8d92

comparison

equal deleted inserted replaced

-:997bbae7b80f
+:c334a9e17426
 pidgin_media_emit_message(PidginMedia *gtkmedia, const char *msg)
 {
 	g_signal_emit(gtkmedia, pidgin_media_signals[MESSAGE], 0, msg);
 }
+typedef struct
+{
+	PidginMedia *gtkmedia;
+	gchar *session_id;
+	gchar *participant;
+} PidginMediaRealizeData;
 static gboolean
-create_window (GstBus *bus, GstMessage *message, PidginMedia *gtkmedia)
+realize_cb_cb(PidginMediaRealizeData *data)
 {
-	char *name;
+	PidginMediaPrivate *priv = data->gtkmedia->priv;
+	gulong window_id;
-	if (GST_MESSAGE_TYPE(message) != GST_MESSAGE_ELEMENT)
-		return TRUE;
+	if (data->participant == NULL)
+		window_id = GDK_WINDOW_XWINDOW(priv->local_video->window);
-	if (!gst_structure_has_name(message->structure, "prepare-xwindow-id"))
+	else
-		return TRUE;
+		window_id = GDK_WINDOW_XWINDOW(priv->remote_video->window);
-	name = gst_object_get_name(GST_MESSAGE_SRC (message));
+	purple_media_set_output_window(priv->media, data->session_id,
+			data->participant, window_id);
-	/* The XOverlay's name is the sink's name with a suffix */
-	if (!strncmp(name, "purplevideosink", strlen("purplevideosink")))
+	g_free(data->session_id);
-		gst_x_overlay_set_xwindow_id(GST_X_OVERLAY(GST_MESSAGE_SRC(message)),
+	g_free(data->participant);
-					     GDK_WINDOW_XWINDOW(gtkmedia->priv->remote_video->window));
+	g_free(data);
-	else if (!strncmp(name, "purplelocalvideosink", strlen("purplelocalvideosink")))
-		gst_x_overlay_set_xwindow_id(GST_X_OVERLAY(GST_MESSAGE_SRC(message)),
-					     GDK_WINDOW_XWINDOW(gtkmedia->priv->local_video->window));
-	g_free(name);
-	return TRUE;
-}
-static gboolean
-realize_cb_cb(GstElement *element)
-{
-	gst_element_set_locked_state(element, FALSE);
-	gst_element_set_state(element, GST_STATE_PLAYING);
 	return FALSE;
 }
 static void
-realize_cb(GtkWidget *widget, GstElement *element)
+realize_cb(GtkWidget *widget, PidginMediaRealizeData *data)
 {
-	g_timeout_add(0, (GSourceFunc)realize_cb_cb, element);
+	g_timeout_add(0, (GSourceFunc)realize_cb_cb, data);
 }
 static void
 pidgin_media_error_cb(PidginMedia *media, const char *error, PidginMedia *gtkmedia)
 {
 	GtkWidget *send_widget = NULL, *recv_widget = NULL;
 	GstElement *audiosendbin = NULL, *audiosendlevel = NULL;
 	GstElement *videosendbin = NULL;
 	gboolean audiorecvbool = FALSE;
 	gboolean videorecvbool = FALSE;
-	GstBus *bus;
 	gboolean is_initiator;
 	PurpleMediaSessionType type = purple_media_get_session_type(media, sid);
 	if (type & PURPLE_MEDIA_AUDIO) {
 		if (!audiosendbin && (type & PURPLE_MEDIA_SEND_AUDIO)) {
 			audiorecvbool = TRUE;
 		}
 	} else if (type & PURPLE_MEDIA_VIDEO) {
 		if (!videosendbin && (type & PURPLE_MEDIA_SEND_VIDEO)) {
 			purple_media_video_init_src(&videosendbin);
-			gst_element_set_locked_state(videosendbin, TRUE);
 			purple_media_set_src(media, sid, videosendbin);
+			gst_element_set_state(videosendbin, GST_STATE_PLAYING);
 		}
 		if (!videorecvbool && (type & PURPLE_MEDIA_RECV_VIDEO)) {
 			videorecvbool = TRUE;
 		}
 	}
 		gtk_widget_show(send_widget);
 	} else
 		send_widget = gtkmedia->priv->send_widget;
 	if (videorecvbool) {
+		PidginMediaRealizeData *data;
 		GtkWidget *aspect;
 		GtkWidget *remote_video;
 		GtkWidget *plug;
 		GtkWidget *socket;
 		g_signal_connect(G_OBJECT(socket), "plug-removed",
 				G_CALLBACK(plug_removed_cb), NULL);
 		gtk_container_add(GTK_CONTAINER(aspect), socket);
 		gtk_widget_show(socket);
+		data = g_new0(PidginMediaRealizeData, 1);
+		data->gtkmedia = gtkmedia;
+		data->session_id = g_strdup(sid);
+		data->participant = g_strdup(gtkmedia->priv->screenname);
 		remote_video = gtk_drawing_area_new();
+		g_signal_connect(G_OBJECT(remote_video), "realize",
+				G_CALLBACK(realize_cb), data);
 		gtk_container_add(GTK_CONTAINER(plug), remote_video);
 		gtk_widget_set_size_request (GTK_WIDGET(remote_video), 100, -1);
 		gtk_widget_show(remote_video);
 		gtk_widget_show(aspect);
 		gtkmedia->priv->remote_video = remote_video;
 	}
 	if (videosendbin) {
+		PidginMediaRealizeData *data;
 		GtkWidget *aspect;
 		GtkWidget *local_video;
 		GtkWidget *plug;
 		GtkWidget *socket;
 		g_signal_connect(G_OBJECT(socket), "plug-removed",
 				G_CALLBACK(plug_removed_cb), NULL);
 		gtk_container_add(GTK_CONTAINER(aspect), socket);
 		gtk_widget_show(socket);
+		data = g_new0(PidginMediaRealizeData, 1);
+		data->gtkmedia = gtkmedia;
+		data->session_id = g_strdup(sid);
+		data->participant = NULL;
 		local_video = gtk_drawing_area_new();
 		g_signal_connect(G_OBJECT(local_video), "realize",
-				G_CALLBACK(realize_cb), videosendbin);
+				G_CALLBACK(realize_cb), data);
 		gtk_container_add(GTK_CONTAINER(plug), local_video);
 		gtk_widget_set_size_request (GTK_WIDGET(local_video), 100, -1);
 		gtk_widget_show(local_video);
 		gtk_widget_show(aspect);
 		gtk_widget_show(gtkmedia->priv->send_progress);
 		gtk_widget_show(gtkmedia->priv->mute);
 	}
-	bus = gst_pipeline_get_bus(GST_PIPELINE(pipeline));
+	if (audiorecvbool || audiosendbin) {
-	if (videorecvbool || videosendbin)
+		GstBus *bus = gst_pipeline_get_bus(GST_PIPELINE(pipeline));
-		g_signal_connect(bus, "sync-message::element",
-				G_CALLBACK(create_window), gtkmedia);
-	if (audiorecvbool || audiosendbin)
 		g_signal_connect(G_OBJECT(bus), "message::element",
 				G_CALLBACK(level_message_cb), gtkmedia);
+		gst_object_unref(bus);
-	gst_object_unref(bus);
+	}
 	if (send_widget != NULL)
 		gtkmedia->priv->send_widget = send_widget;
 	if (recv_widget != NULL)
 		gtkmedia->priv->recv_widget = recv_widget;

Mercurial > pidgin.yaz

comparison pidgin/gtkmedia.c @ 26135:c334a9e17426