|
Packit |
0652a1 |
/*
|
|
Packit |
0652a1 |
* GStreamer
|
|
Packit |
0652a1 |
* Copyright (C) 2008-2009 Julien Isorce <julien.isorce@gmail.com>
|
|
Packit |
0652a1 |
*
|
|
Packit |
0652a1 |
* This library is free software; you can redistribute it and/or
|
|
Packit |
0652a1 |
* modify it under the terms of the GNU Library General Public
|
|
Packit |
0652a1 |
* License as published by the Free Software Foundation; either
|
|
Packit |
0652a1 |
* version 2 of the License, or (at your option) any later version.
|
|
Packit |
0652a1 |
*
|
|
Packit |
0652a1 |
* This library is distributed in the hope that it will be useful,
|
|
Packit |
0652a1 |
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
Packit |
0652a1 |
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
Packit |
0652a1 |
* Library General Public License for more details.
|
|
Packit |
0652a1 |
*
|
|
Packit |
0652a1 |
* You should have received a copy of the GNU Library General Public
|
|
Packit |
0652a1 |
* License along with this library; if not, write to the
|
|
Packit |
0652a1 |
* Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
|
|
Packit |
0652a1 |
* Boston, MA 02110-1301, USA.
|
|
Packit |
0652a1 |
*/
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
#ifdef HAVE_CONFIG_H
|
|
Packit |
0652a1 |
#include "config.h"
|
|
Packit |
0652a1 |
#endif
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
#include <gst/gst.h>
|
|
Packit |
0652a1 |
#include <gtk/gtk.h>
|
|
Packit |
0652a1 |
#include <gdk/gdk.h>
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
#include "../gstgtk.h"
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
#ifdef HAVE_X11
|
|
Packit |
0652a1 |
#include <X11/Xlib.h>
|
|
Packit |
0652a1 |
#endif
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
static GstBusSyncReply create_window (GstBus* bus, GstMessage* message, GtkWidget* widget)
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
GtkAllocation allocation;
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
if (gst_gtk_handle_need_context (bus, message, NULL))
|
|
Packit |
0652a1 |
return GST_BUS_DROP;
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
// ignore anything but 'prepare-window-handle' element messages
|
|
Packit |
0652a1 |
if (GST_MESSAGE_TYPE (message) != GST_MESSAGE_ELEMENT)
|
|
Packit |
0652a1 |
return GST_BUS_PASS;
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
if (!gst_is_video_overlay_prepare_window_handle_message (message))
|
|
Packit |
0652a1 |
return GST_BUS_PASS;
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
g_print ("setting window handle %p\n", widget);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gst_video_overlay_set_gtk_window (GST_VIDEO_OVERLAY (GST_MESSAGE_SRC (message)), widget);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gtk_widget_get_allocation (widget, &allocation);
|
|
Packit |
0652a1 |
gst_video_overlay_set_render_rectangle (GST_VIDEO_OVERLAY (GST_MESSAGE_SRC (message)), allocation.x, allocation.y, allocation.width, allocation.height);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gst_message_unref (message);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
return GST_BUS_DROP;
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
static gboolean
|
|
Packit |
0652a1 |
resize_cb (GtkWidget * widget, GdkEvent * event, gpointer sink)
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
GtkAllocation allocation;
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gtk_widget_get_allocation (widget, &allocation);
|
|
Packit |
0652a1 |
gst_video_overlay_set_render_rectangle (GST_VIDEO_OVERLAY (sink), allocation.x, allocation.y, allocation.width, allocation.height);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
return G_SOURCE_CONTINUE;
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
static void end_stream_cb(GstBus* bus, GstMessage* message, GstElement* pipeline)
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
GError *error = NULL;
|
|
Packit |
0652a1 |
gchar *details;
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
switch (GST_MESSAGE_TYPE (message)) {
|
|
Packit |
0652a1 |
case GST_MESSAGE_ERROR:
|
|
Packit |
0652a1 |
gst_message_parse_error (message, &error, &details);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
g_print("Error %s\n", error->message);
|
|
Packit |
0652a1 |
g_print("Details %s\n", details);
|
|
Packit |
0652a1 |
/* fallthrough */
|
|
Packit |
0652a1 |
case GST_MESSAGE_EOS:
|
|
Packit |
0652a1 |
g_print("End of stream\n");
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gst_element_set_state (pipeline, GST_STATE_NULL);
|
|
Packit |
0652a1 |
gst_object_unref(pipeline);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gtk_main_quit();
|
|
Packit |
0652a1 |
break;
|
|
Packit |
0652a1 |
case GST_MESSAGE_WARNING:
|
|
Packit |
0652a1 |
gst_message_parse_warning (message, &error, &details);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
g_print("Warning %s\n", error->message);
|
|
Packit |
0652a1 |
g_print("Details %s\n", details);
|
|
Packit |
0652a1 |
break;
|
|
Packit |
0652a1 |
default:
|
|
Packit |
0652a1 |
break;
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
static gboolean expose_cb(GtkWidget* widget, cairo_t *cr, GstElement* videosink)
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
gst_video_overlay_expose (GST_VIDEO_OVERLAY (videosink));
|
|
Packit |
0652a1 |
return FALSE;
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
static void destroy_cb(GtkWidget* widget, GdkEvent* event, GstElement* pipeline)
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
g_print("Close\n");
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gst_element_set_state (pipeline, GST_STATE_NULL);
|
|
Packit |
0652a1 |
gst_object_unref(pipeline);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gtk_main_quit();
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
static void button_state_null_cb(GtkWidget* widget, GstElement* pipeline)
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
gst_element_set_state (pipeline, GST_STATE_NULL);
|
|
Packit |
0652a1 |
g_print ("GST_STATE_NULL\n");
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
static void button_state_ready_cb(GtkWidget* widget, GstElement* pipeline)
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
gst_element_set_state (pipeline, GST_STATE_READY);
|
|
Packit |
0652a1 |
g_print ("GST_STATE_READY\n");
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
static void button_state_paused_cb(GtkWidget* widget, GstElement* pipeline)
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
gst_element_set_state (pipeline, GST_STATE_PAUSED);
|
|
Packit |
0652a1 |
g_print ("GST_STATE_PAUSED\n");
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
static void button_state_playing_cb(GtkWidget* widget, GstElement* pipeline)
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
gst_element_set_state (pipeline, GST_STATE_PLAYING);
|
|
Packit |
0652a1 |
g_print ("GST_STATE_PLAYING\n");
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
static gchar* slider_fps_cb (GtkScale* scale, gdouble value, GstElement* pipeline)
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
//change the video frame rate dynamically
|
|
Packit |
0652a1 |
return g_strdup_printf ("video framerate: %0.*g", gtk_scale_get_digits (scale), value);
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gint main (gint argc, gchar *argv[])
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
#ifdef HAVE_X11
|
|
Packit |
0652a1 |
XInitThreads ();
|
|
Packit |
0652a1 |
#endif
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gtk_init (&argc, &argv);
|
|
Packit |
0652a1 |
gst_init (&argc, &argv);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
GstElement* pipeline = gst_pipeline_new ("pipeline");
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
//window that contains an area where the video is drawn
|
|
Packit |
0652a1 |
GtkWidget* window = gtk_window_new(GTK_WINDOW_TOPLEVEL);
|
|
Packit |
0652a1 |
gtk_widget_set_size_request (window, 640, 480);
|
|
Packit |
0652a1 |
gtk_window_move (GTK_WINDOW (window), 300, 10);
|
|
Packit |
0652a1 |
gtk_window_set_title (GTK_WINDOW (window), "glimagesink implement the gstvideooverlay interface");
|
|
Packit |
0652a1 |
GdkGeometry geometry;
|
|
Packit |
0652a1 |
geometry.min_width = 1;
|
|
Packit |
0652a1 |
geometry.min_height = 1;
|
|
Packit |
0652a1 |
geometry.max_width = -1;
|
|
Packit |
0652a1 |
geometry.max_height = -1;
|
|
Packit |
0652a1 |
gtk_window_set_geometry_hints (GTK_WINDOW (window), window, &geometry, GDK_HINT_MIN_SIZE);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
//window to control the states
|
|
Packit |
0652a1 |
GtkWidget* window_control = gtk_window_new (GTK_WINDOW_TOPLEVEL);
|
|
Packit |
0652a1 |
geometry.min_width = 1;
|
|
Packit |
0652a1 |
geometry.min_height = 1;
|
|
Packit |
0652a1 |
geometry.max_width = -1;
|
|
Packit |
0652a1 |
geometry.max_height = -1;
|
|
Packit |
0652a1 |
gtk_window_set_geometry_hints (GTK_WINDOW (window_control), window_control, &geometry, GDK_HINT_MIN_SIZE);
|
|
Packit |
0652a1 |
gtk_window_set_resizable (GTK_WINDOW (window_control), FALSE);
|
|
Packit |
0652a1 |
gtk_window_move (GTK_WINDOW (window_control), 10, 10);
|
|
Packit |
0652a1 |
GtkWidget* grid = gtk_grid_new ();
|
|
Packit |
0652a1 |
gtk_container_add (GTK_CONTAINER (window_control), grid);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
//control state null
|
|
Packit |
0652a1 |
GtkWidget* button_state_null = gtk_button_new_with_label ("GST_STATE_NULL");
|
|
Packit |
0652a1 |
g_signal_connect (G_OBJECT (button_state_null), "clicked",
|
|
Packit |
0652a1 |
G_CALLBACK (button_state_null_cb), pipeline);
|
|
Packit |
0652a1 |
gtk_grid_attach (GTK_GRID (grid), button_state_null, 0, 1, 1, 1);
|
|
Packit |
0652a1 |
gtk_widget_show (button_state_null);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
//control state ready
|
|
Packit |
0652a1 |
GtkWidget* button_state_ready = gtk_button_new_with_label ("GST_STATE_READY");
|
|
Packit |
0652a1 |
g_signal_connect (G_OBJECT (button_state_ready), "clicked",
|
|
Packit |
0652a1 |
G_CALLBACK (button_state_ready_cb), pipeline);
|
|
Packit |
0652a1 |
gtk_grid_attach (GTK_GRID (grid), button_state_ready, 0, 2, 1, 1);
|
|
Packit |
0652a1 |
gtk_widget_show (button_state_ready);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
//control state paused
|
|
Packit |
0652a1 |
GtkWidget* button_state_paused = gtk_button_new_with_label ("GST_STATE_PAUSED");
|
|
Packit |
0652a1 |
g_signal_connect (G_OBJECT (button_state_paused), "clicked",
|
|
Packit |
0652a1 |
G_CALLBACK (button_state_paused_cb), pipeline);
|
|
Packit |
0652a1 |
gtk_grid_attach (GTK_GRID (grid), button_state_paused, 0, 3, 1, 1);
|
|
Packit |
0652a1 |
gtk_widget_show (button_state_paused);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
//control state playing
|
|
Packit |
0652a1 |
GtkWidget* button_state_playing = gtk_button_new_with_label ("GST_STATE_PLAYING");
|
|
Packit |
0652a1 |
g_signal_connect (G_OBJECT (button_state_playing), "clicked",
|
|
Packit |
0652a1 |
G_CALLBACK (button_state_playing_cb), pipeline);
|
|
Packit |
0652a1 |
gtk_grid_attach (GTK_GRID (grid), button_state_playing, 0, 4, 1, 1);
|
|
Packit |
0652a1 |
gtk_widget_show (button_state_playing);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
//change framerate
|
|
Packit |
0652a1 |
GtkWidget* slider_fps = gtk_scale_new_with_range (GTK_ORIENTATION_VERTICAL, 1, 30, 2);
|
|
Packit |
0652a1 |
g_signal_connect (G_OBJECT (slider_fps), "format-value",
|
|
Packit |
0652a1 |
G_CALLBACK (slider_fps_cb), pipeline);
|
|
Packit |
0652a1 |
gtk_grid_attach (GTK_GRID (grid), slider_fps, 1, 0, 1, 5);
|
|
Packit |
0652a1 |
gtk_widget_show (slider_fps);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gtk_widget_show (grid);
|
|
Packit |
0652a1 |
gtk_widget_show (window_control);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
//configure the pipeline
|
|
Packit |
0652a1 |
g_signal_connect(G_OBJECT(window), "delete-event", G_CALLBACK(destroy_cb), pipeline);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
GstElement* videosrc = gst_element_factory_make ("videotestsrc", "videotestsrc");
|
|
Packit |
0652a1 |
GstElement* upload = gst_element_factory_make ("glupload", "glupload");
|
|
Packit |
0652a1 |
GstElement* glfiltercube = gst_element_factory_make ("glfiltercube", "glfiltercube");
|
|
Packit |
0652a1 |
GstElement* videosink = gst_element_factory_make ("glimagesink", "glimagesink");
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
GstCaps *caps = gst_caps_new_simple("video/x-raw",
|
|
Packit |
0652a1 |
"width", G_TYPE_INT, 640,
|
|
Packit |
0652a1 |
"height", G_TYPE_INT, 480,
|
|
Packit |
0652a1 |
"framerate", GST_TYPE_FRACTION, 25, 1,
|
|
Packit |
0652a1 |
"format", G_TYPE_STRING, "RGBA",
|
|
Packit |
0652a1 |
NULL) ;
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gst_bin_add_many (GST_BIN (pipeline), videosrc, upload, glfiltercube, videosink, NULL);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gboolean link_ok = gst_element_link_filtered(videosrc, upload, caps) ;
|
|
Packit |
0652a1 |
gst_caps_unref(caps) ;
|
|
Packit |
0652a1 |
if(!link_ok)
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
g_warning("Failed to link videosrc to glfiltercube!\n") ;
|
|
Packit |
0652a1 |
return -1;
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
if(!gst_element_link_many(upload, glfiltercube, videosink, NULL))
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
g_warning("Failed to link glfiltercube to videosink!\n") ;
|
|
Packit |
0652a1 |
return -1;
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
//area where the video is drawn
|
|
Packit |
0652a1 |
GtkWidget* area = gtk_drawing_area_new();
|
|
Packit |
0652a1 |
gtk_widget_set_redraw_on_allocate (area, TRUE);
|
|
Packit |
0652a1 |
gtk_container_add (GTK_CONTAINER (window), area);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gtk_widget_realize(area);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
//set window id on this event
|
|
Packit |
0652a1 |
GstBus* bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
|
|
Packit |
0652a1 |
gst_bus_set_sync_handler (bus, (GstBusSyncHandler) create_window, area, NULL);
|
|
Packit |
0652a1 |
gst_bus_add_signal_watch (bus);
|
|
Packit |
0652a1 |
g_signal_connect(bus, "message::error", G_CALLBACK(end_stream_cb), pipeline);
|
|
Packit |
0652a1 |
g_signal_connect(bus, "message::warning", G_CALLBACK(end_stream_cb), pipeline);
|
|
Packit |
0652a1 |
g_signal_connect(bus, "message::eos", G_CALLBACK(end_stream_cb), pipeline);
|
|
Packit |
0652a1 |
gst_object_unref (bus);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
//needed when being in GST_STATE_READY, GST_STATE_PAUSED
|
|
Packit |
0652a1 |
//or resizing/obscuring the window
|
|
Packit |
0652a1 |
g_signal_connect(area, "draw", G_CALLBACK(expose_cb), videosink);
|
|
Packit |
0652a1 |
g_signal_connect(area, "configure-event", G_CALLBACK(resize_cb), videosink);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
//start
|
|
Packit |
0652a1 |
GstStateChangeReturn ret = gst_element_set_state (pipeline, GST_STATE_PLAYING);
|
|
Packit |
0652a1 |
if (ret == GST_STATE_CHANGE_FAILURE)
|
|
Packit |
0652a1 |
{
|
|
Packit |
0652a1 |
g_print ("Failed to start up pipeline!\n");
|
|
Packit |
0652a1 |
return -1;
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gtk_widget_show_all (window);
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
gtk_main();
|
|
Packit |
0652a1 |
|
|
Packit |
0652a1 |
return 0;
|
|
Packit |
0652a1 |
}
|
|
Packit |
0652a1 |
|