mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-11-28 20:51:13 +00:00
263255137e
gstgl doesn't undo/overwrite what GL state the examples are changing anymore. As such, the examples need to reset the GL state themselves to be able to play nice with libgstgl
358 lines
11 KiB
C++
358 lines
11 KiB
C++
/*
|
|
* GStreamer
|
|
* Copyright (C) 2008-2009 Julien Isorce <julien.isorce@gmail.com>
|
|
*
|
|
* 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.
|
|
*
|
|
* This library 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
|
|
* Library General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Library General Public
|
|
* License along with this library; if not, write to the
|
|
* Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
|
|
* Boston, MA 02110-1301, USA.
|
|
*/
|
|
|
|
#include <gst/video/videooverlay.h>
|
|
#include <gst/video/video.h>
|
|
#include <GL/gl.h>
|
|
#include "pipeline.h"
|
|
|
|
#define GST_MAP_GL (GST_MAP_FLAG_LAST << 1)
|
|
|
|
Pipeline::Pipeline(const WId id, const QString videoLocation):
|
|
m_winId(id),
|
|
m_videoLocation(videoLocation),
|
|
m_loop(NULL),
|
|
m_bus(NULL),
|
|
m_pipeline(NULL),
|
|
m_glimagesink(NULL)
|
|
{
|
|
create();
|
|
}
|
|
|
|
Pipeline::~Pipeline()
|
|
{
|
|
}
|
|
|
|
void Pipeline::create()
|
|
{
|
|
qDebug("Loading video: %s", m_videoLocation.toLatin1().data());
|
|
|
|
gst_init (NULL, NULL);
|
|
|
|
#ifdef WIN32
|
|
m_loop = g_main_loop_new (NULL, FALSE);
|
|
#endif
|
|
m_pipeline = gst_pipeline_new ("pipeline");
|
|
|
|
m_bus = gst_pipeline_get_bus (GST_PIPELINE (m_pipeline));
|
|
gst_bus_add_watch (m_bus, (GstBusFunc) bus_call, this);
|
|
gst_bus_set_sync_handler (m_bus, (GstBusSyncHandler) create_window, this, NULL);
|
|
gst_object_unref (m_bus);
|
|
|
|
GstElement* videosrc = gst_element_factory_make ("filesrc", "filesrc0");
|
|
GstElement* decodebin = gst_element_factory_make ("decodebin", "decodebin0");
|
|
m_glimagesink = gst_element_factory_make ("glimagesink", "sink0");
|
|
|
|
if (!videosrc || !decodebin || !m_glimagesink )
|
|
{
|
|
qDebug ("one element could not be found");
|
|
return;
|
|
}
|
|
|
|
g_object_set(G_OBJECT(videosrc), "num-buffers", 800, NULL);
|
|
g_object_set(G_OBJECT(videosrc), "location", m_videoLocation.toLatin1().data(), NULL);
|
|
g_signal_connect(G_OBJECT(m_glimagesink), "client-reshape", G_CALLBACK (reshapeCallback), NULL);
|
|
g_signal_connect(G_OBJECT(m_glimagesink), "client-draw", G_CALLBACK (drawCallback), NULL);
|
|
|
|
gst_bin_add_many (GST_BIN (m_pipeline), videosrc, decodebin, m_glimagesink, NULL);
|
|
|
|
gst_element_link_pads (videosrc, "src", decodebin, "sink");
|
|
|
|
g_signal_connect (decodebin, "pad-added", G_CALLBACK (cb_new_pad), this);
|
|
}
|
|
|
|
void Pipeline::start()
|
|
{
|
|
GstStateChangeReturn ret = gst_element_set_state (m_pipeline, GST_STATE_PLAYING);
|
|
if (ret == GST_STATE_CHANGE_FAILURE)
|
|
{
|
|
qDebug ("Failed to start up pipeline!");
|
|
|
|
/* check if there is an error message with details on the bus */
|
|
GstMessage* msg = gst_bus_poll (m_bus, GST_MESSAGE_ERROR, 0);
|
|
if (msg)
|
|
{
|
|
GError *err = NULL;
|
|
gst_message_parse_error (msg, &err, NULL);
|
|
qDebug ("ERROR: %s", err->message);
|
|
g_error_free (err);
|
|
gst_message_unref (msg);
|
|
}
|
|
return;
|
|
}
|
|
|
|
#ifdef WIN32
|
|
g_main_loop_run(m_loop);
|
|
#endif
|
|
}
|
|
|
|
//we don't want a thread safe stop in this example
|
|
void Pipeline::stop()
|
|
{
|
|
#ifdef WIN32
|
|
g_main_loop_quit(m_loop);
|
|
#else
|
|
emit stopRequested();
|
|
#endif
|
|
}
|
|
|
|
void Pipeline::unconfigure() const
|
|
{
|
|
gst_element_set_state (m_pipeline, GST_STATE_NULL);
|
|
gst_object_unref (m_pipeline);
|
|
}
|
|
|
|
void Pipeline::show()
|
|
{
|
|
emit showRequested();
|
|
}
|
|
|
|
//redraw the current frame in the drawable
|
|
void Pipeline::doExpose() const
|
|
{
|
|
if (m_pipeline && m_glimagesink)
|
|
gst_video_overlay_expose (GST_VIDEO_OVERLAY (m_glimagesink));
|
|
}
|
|
|
|
//post message to g_main_loop in order to call expose
|
|
//in the gt thread
|
|
void Pipeline::exposeRequested()
|
|
{
|
|
g_idle_add(cb_expose, this);
|
|
}
|
|
|
|
//rotate the cube
|
|
void Pipeline::doRotate()
|
|
{
|
|
m_xrot += 3.0f;
|
|
m_yrot += 2.0f;
|
|
m_zrot += 4.0f;
|
|
}
|
|
|
|
//post message to g_main_loop in order to call rotate
|
|
//in the gt thread
|
|
void Pipeline::rotateRequested()
|
|
{
|
|
g_idle_add(cb_rotate, this);
|
|
}
|
|
|
|
//-----------------------------------------------------------------------
|
|
//----------------------------- static members --------------------------
|
|
//-----------------------------------------------------------------------
|
|
|
|
float Pipeline::m_xrot = 0;
|
|
float Pipeline::m_yrot = 0;
|
|
float Pipeline::m_zrot = 0;
|
|
|
|
//client reshape callback
|
|
gboolean Pipeline::reshapeCallback (void *sink, void *context, guint width, guint height, gpointer data)
|
|
{
|
|
glViewport(0, 0, width, height);
|
|
glMatrixMode(GL_PROJECTION);
|
|
glLoadIdentity();
|
|
glMatrixMode(GL_MODELVIEW);
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
//client draw callback
|
|
gboolean Pipeline::drawCallback (void * sink, void *context, GstSample * sample, gpointer data)
|
|
{
|
|
static GTimeVal current_time;
|
|
static glong last_sec = current_time.tv_sec;
|
|
static gint nbFrames = 0;
|
|
|
|
GstVideoFrame v_frame;
|
|
GstVideoInfo v_info;
|
|
guint texture = 0;
|
|
GstBuffer *buf = gst_sample_get_buffer (sample);
|
|
GstCaps *caps = gst_sample_get_caps (sample);
|
|
|
|
gst_video_info_from_caps (&v_info, caps);
|
|
|
|
if (!gst_video_frame_map (&v_frame, &v_info, buf, (GstMapFlags) (GST_MAP_READ | GST_MAP_GL))) {
|
|
g_warning ("Failed to map the video buffer");
|
|
return TRUE;
|
|
}
|
|
|
|
texture = *(guint *) v_frame.data[0];
|
|
|
|
g_get_current_time (¤t_time);
|
|
nbFrames++ ;
|
|
|
|
if ((current_time.tv_sec - last_sec) >= 1)
|
|
{
|
|
qDebug ("GRAPHIC FPS = %d", nbFrames);
|
|
nbFrames = 0;
|
|
last_sec = current_time.tv_sec;
|
|
}
|
|
|
|
glEnable(GL_DEPTH_TEST);
|
|
|
|
glEnable (GL_TEXTURE_2D);
|
|
glBindTexture (GL_TEXTURE_2D, texture);
|
|
glTexParameteri (GL_TEXTURE_2D, GL_TEXTURE_MAG_FILTER, GL_LINEAR);
|
|
glTexParameteri (GL_TEXTURE_2D, GL_TEXTURE_MIN_FILTER, GL_LINEAR);
|
|
glTexParameteri (GL_TEXTURE_2D, GL_TEXTURE_WRAP_S, GL_CLAMP_TO_EDGE);
|
|
glTexParameteri (GL_TEXTURE_2D, GL_TEXTURE_WRAP_T, GL_CLAMP_TO_EDGE);
|
|
glTexEnvi (GL_TEXTURE_ENV, GL_TEXTURE_ENV_MODE, GL_REPLACE);
|
|
|
|
glClear(GL_COLOR_BUFFER_BIT | GL_DEPTH_BUFFER_BIT);
|
|
glMatrixMode(GL_MODELVIEW);
|
|
glLoadIdentity();
|
|
|
|
glScalef(0.5f,0.5f,0.5f);
|
|
|
|
glRotatef(m_xrot,1.0f,0.0f,0.0f);
|
|
glRotatef(m_yrot,0.0f,1.0f,0.0f);
|
|
glRotatef(m_zrot,0.0f,0.0f,1.0f);
|
|
|
|
glBegin(GL_QUADS);
|
|
// Front Face
|
|
glTexCoord2f(1.0f, 0.0f); glVertex3f(-1.0f, -1.0f, 1.0f);
|
|
glTexCoord2f(0.0f, 0.0f); glVertex3f( 1.0f, -1.0f, 1.0f);
|
|
glTexCoord2f(0.0f, 1.0f); glVertex3f( 1.0f, 1.0f, 1.0f);
|
|
glTexCoord2f(1.0f, 1.0f); glVertex3f(-1.0f, 1.0f, 1.0f);
|
|
// Back Face
|
|
glTexCoord2f(0.0f, 0.0f); glVertex3f(-1.0f, -1.0f, -1.0f);
|
|
glTexCoord2f(0.0f, 1.0f); glVertex3f(-1.0f, 1.0f, -1.0f);
|
|
glTexCoord2f(1.0f, 1.0f); glVertex3f( 1.0f, 1.0f, -1.0f);
|
|
glTexCoord2f(1.0f, 0.0f); glVertex3f( 1.0f, -1.0f, -1.0f);
|
|
// Top Face
|
|
glTexCoord2f(1.0f, 1.0f); glVertex3f(-1.0f, 1.0f, -1.0f);
|
|
glTexCoord2f(1.0f, 0.0f); glVertex3f(-1.0f, 1.0f, 1.0f);
|
|
glTexCoord2f(0.0f, 0.0f); glVertex3f( 1.0f, 1.0f, 1.0f);
|
|
glTexCoord2f(0.0f, 1.0f); glVertex3f( 1.0f, 1.0f, -1.0f);
|
|
// Bottom Face
|
|
glTexCoord2f(1.0f, 0.0f); glVertex3f(-1.0f, -1.0f, -1.0f);
|
|
glTexCoord2f(0.0f, 0.0f); glVertex3f( 1.0f, -1.0f, -1.0f);
|
|
glTexCoord2f(0.0f, 1.0f); glVertex3f( 1.0f, -1.0f, 1.0f);
|
|
glTexCoord2f(1.0f, 1.0f); glVertex3f(-1.0f, -1.0f, 1.0f);
|
|
// Right face
|
|
glTexCoord2f(0.0f, 0.0f); glVertex3f( 1.0f, -1.0f, -1.0f);
|
|
glTexCoord2f(0.0f, 1.0f); glVertex3f( 1.0f, 1.0f, -1.0f);
|
|
glTexCoord2f(1.0f, 1.0f); glVertex3f( 1.0f, 1.0f, 1.0f);
|
|
glTexCoord2f(1.0f, 0.0f); glVertex3f( 1.0f, -1.0f, 1.0f);
|
|
// Left Face
|
|
glTexCoord2f(1.0f, 0.0f); glVertex3f(-1.0f, -1.0f, -1.0f);
|
|
glTexCoord2f(0.0f, 0.0f); glVertex3f(-1.0f, -1.0f, 1.0f);
|
|
glTexCoord2f(0.0f, 1.0f); glVertex3f(-1.0f, 1.0f, 1.0f);
|
|
glTexCoord2f(1.0f, 1.0f); glVertex3f(-1.0f, 1.0f, -1.0f);
|
|
glEnd();
|
|
|
|
glLoadIdentity();
|
|
glDisable(GL_DEPTH_TEST);
|
|
glBindTexture (GL_TEXTURE_2D, 0);
|
|
|
|
gst_video_frame_unmap (&v_frame);
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
gboolean Pipeline::bus_call (GstBus *bus, GstMessage *msg, Pipeline* p)
|
|
{
|
|
switch (GST_MESSAGE_TYPE (msg))
|
|
{
|
|
case GST_MESSAGE_EOS:
|
|
qDebug ("End-of-stream");
|
|
p->stop();
|
|
break;
|
|
case GST_MESSAGE_ERROR:
|
|
{
|
|
gchar *debug = NULL;
|
|
GError *err = NULL;
|
|
gst_message_parse_error (msg, &err, &debug);
|
|
qDebug ("Error: %s", err->message);
|
|
g_error_free (err);
|
|
if (debug)
|
|
{
|
|
qDebug ("Debug deails: %s", debug);
|
|
g_free (debug);
|
|
}
|
|
p->stop();
|
|
break;
|
|
}
|
|
default:
|
|
break;
|
|
}
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
void Pipeline::cb_new_pad (GstElement* decodebin, GstPad* pad, Pipeline* p)
|
|
{
|
|
GstElement* glimagesink = p->getVideoSink();
|
|
GstPad* glpad = gst_element_get_static_pad (glimagesink, "sink");
|
|
|
|
//only link once
|
|
if (GST_PAD_IS_LINKED (glpad))
|
|
{
|
|
gst_object_unref (glpad);
|
|
return;
|
|
}
|
|
|
|
GstCaps* caps = gst_pad_get_current_caps (pad);
|
|
GstStructure* str = gst_caps_get_structure (caps, 0);
|
|
if (!g_strrstr (gst_structure_get_name (str), "video"))
|
|
{
|
|
gst_caps_unref (caps);
|
|
gst_object_unref (glpad);
|
|
return;
|
|
}
|
|
gst_caps_unref (caps);
|
|
|
|
GstPadLinkReturn ret = gst_pad_link (pad, glpad);
|
|
if (ret != GST_PAD_LINK_OK)
|
|
g_warning ("Failed to link with decodebin!\n");
|
|
|
|
p->show();
|
|
}
|
|
|
|
gboolean Pipeline::cb_expose (gpointer data)
|
|
{
|
|
((Pipeline*)data)->doExpose();
|
|
return FALSE;
|
|
}
|
|
|
|
gboolean Pipeline::cb_rotate (gpointer data)
|
|
{
|
|
((Pipeline*)data)->doRotate();
|
|
return FALSE;
|
|
}
|
|
|
|
GstBusSyncReply Pipeline::create_window (GstBus* bus, GstMessage* message, const Pipeline* p)
|
|
{
|
|
// ignore anything but 'prepare-window-handle' element messages
|
|
if (GST_MESSAGE_TYPE (message) != GST_MESSAGE_ELEMENT)
|
|
return GST_BUS_PASS;
|
|
|
|
if (!gst_is_video_overlay_prepare_window_handle_message (message))
|
|
return GST_BUS_PASS;
|
|
|
|
qDebug ("setting window handle");
|
|
|
|
//Passing 0 as the window_handle will tell the overlay to stop using that window and create an internal one.
|
|
//In the directdrawsink's gst_video_overlay_set_window_handle implementation, window_handle (parameter 2) is casted to HWND before it used.
|
|
gst_video_overlay_set_window_handle (GST_VIDEO_OVERLAY (GST_MESSAGE_SRC (message)), (guintptr)p->winId());
|
|
|
|
gst_message_unref (message);
|
|
|
|
return GST_BUS_DROP;
|
|
}
|