mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-20 23:36:38 +00:00
Code Issues 1 Projects Releases Wiki Activity
gstreamer/gst-libs/gst/play/play.old.c
David Schleef 37d7aecdb6 Remove all usage of gst_pad_get_caps(), and replace it with gst_pad_get_allowed_caps() or gst_pad_get_negotiated_cap(). 
Original commit message from CVS:
Remove all usage of gst_pad_get_caps(), and replace it with
gst_pad_get_allowed_caps() or gst_pad_get_negotiated_cap().
2004-01-12 03:40:18 +00:00

1376 lines
36 KiB
C
Raw Blame History

/* GStreamer
* Copyright (C) 1999,2000,2001,2002 Erik Walthinsen <omega@cse.ogi.edu>
* 2000,2001,2002 Wim Taymans <wtay@chello.be>
* 2002 Steve Baker <steve@stevebaker.org>
* 2003 Julien Moutte <julien@moutte.net>
*
* play.c: GstPlay object code
*
* 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., 59 Temple Place - Suite 330,
* Boston, MA 02111-1307, USA.
*/
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#include <string.h>
#include "play.h"
enum
{
STREAM_END,
INFORMATION,
STATE_CHANGE,
STREAM_LENGTH,
TIME_TICK,
HAVE_VIDEO_OUT,
HAVE_VIS_VIDEO_OUT,
HAVE_VIDEO_SIZE,
HAVE_VIS_SIZE,
PIPELINE_ERROR,
/* put additional signals before this comment */
LAST_SIGNAL
};
/* this struct is used to decouple signals coming out of threaded pipelines */
typedef struct _GstPlaySignal GstPlaySignal;
struct _GstPlaySignal
{
gint signal_id;
union
{
struct
{
gint width;
gint height;
} video_size;
struct
{
gpointer video_out;
} video_out;
struct
{
GstElementState old_state;
GstElementState new_state;
} state;
struct
{
GstObject *object;
GParamSpec *param;
} info;
struct
{
GstElement *element;
char *error;
} error;
} signal_data;
};
enum
{
ARG_0,
ARG_LOCATION,
ARG_VOLUME,
ARG_MUTE,
/* FILL ME */
};
static guint gst_play_signals[LAST_SIGNAL] = { 0 };
static GstElementClass *parent_class = NULL;
/* ============================================================= */
/* */
/* Private Methods */
/* */
/* ============================================================= */
/* =========================================== */
/* */
/* Tool Box */
/* */
/* =========================================== */
static GQuark
gst_play_error_quark (void)
{
static GQuark quark = 0;
if (quark == 0)
{
quark = g_quark_from_static_string ("gst-play-error-quark");
}
return quark;
}
/* GError creation when plugin is missing
* If we want to make error messages less
* generic and have more errors than only
* plug-ins, move the message creation to the switch */
static void
gst_play_error_plugin (GstPlayError type, GError ** error)
{
gchar *name;
if (error == NULL)
return;
switch (type)
{
case GST_PLAY_ERROR_THREAD:
name = g_strdup ("thread");
break;
case GST_PLAY_ERROR_QUEUE:
name = g_strdup ("queue");
break;
case GST_PLAY_ERROR_FAKESINK:
name = g_strdup ("fakesink");
break;
case GST_PLAY_ERROR_VOLUME:
name = g_strdup ("volume");
break;
case GST_PLAY_ERROR_COLORSPACE:
name = g_strdup ("colorspace");
break;
case GST_PLAY_ERROR_GNOMEVFSSRC:
name = g_strdup ("gnomevfssrc");
break;
default:
name = g_strdup ("unknown");
break;
}
*error = g_error_new (GST_PLAY_ERROR,
type,
"The %s plug-in could not be found. "
"This plug-in is essential for libgstplay. "
"Please install it and verify that it works "
"by running 'gst-inspect %s'", name, name);
g_free (name);
return;
}
static void
gst_play_set_property (GObject * object,
guint prop_id,
const GValue * value, GParamSpec * pspec)
{
GstPlay *play;
g_return_if_fail (object != NULL);
g_return_if_fail (GST_IS_PLAY (object));
play = GST_PLAY (object);
switch (prop_id)
{
case ARG_LOCATION:
gst_play_set_location (play, g_value_get_string (value));
break;
case ARG_VOLUME:
gst_play_set_volume (play, g_value_get_float (value));
break;
case ARG_MUTE:
gst_play_set_mute (play, g_value_get_boolean (value));
break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
}
}
static void
gst_play_get_property (GObject * object,
guint prop_id, GValue * value, GParamSpec * pspec)
{
GstPlay *play;
g_return_if_fail (object != NULL);
g_return_if_fail (GST_IS_PLAY (object));
play = GST_PLAY (object);
switch (prop_id)
{
case ARG_LOCATION:
g_value_set_string (value, gst_play_get_location (play));
break;
case ARG_VOLUME:
g_value_set_float (value, gst_play_get_volume (play));
break;
case ARG_MUTE:
g_value_set_boolean (value, gst_play_get_mute (play));
break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
}
}
/* =========================================== */
/* */
/* Event Handlers, Callbacks */
/* */
/* =========================================== */
static gboolean
gst_play_get_length_callback (GstPlay * play)
{
gint64 value;
GstFormat format = GST_FORMAT_TIME;
gboolean query_worked = FALSE;
if ((play->audio_sink_element != NULL) &&
(GST_IS_ELEMENT (play->audio_sink_element)))
{
query_worked =
gst_element_query (play->audio_sink_element, GST_QUERY_TOTAL, &format,
&value);
}
else if ((play->video_sink_element != NULL) &&
(GST_IS_ELEMENT (play->video_sink_element)))
{
query_worked =
gst_element_query (play->video_sink_element, GST_QUERY_TOTAL, &format,
&value);
}
if (query_worked)
{
g_signal_emit (G_OBJECT (play), gst_play_signals[STREAM_LENGTH], 0,
value);
play->length_nanos = value;
return FALSE;
}
else
{
if (play->get_length_attempt-- < 1)
{
/* we've tried enough times, give up */
return FALSE;
}
}
return (gst_element_get_state (play->pipeline) == GST_STATE_PLAYING);
}
static gboolean
gst_play_tick_callback (GstPlay * play)
{
gint secs;
g_return_val_if_fail (play != NULL, FALSE);
g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
play->clock = gst_bin_get_clock (GST_BIN (play->pipeline));
play->time_nanos = gst_clock_get_time (play->clock);
secs = (gint) (play->time_nanos / GST_SECOND);
if (secs != play->time_seconds)
{
play->time_seconds = secs;
g_signal_emit (G_OBJECT (play), gst_play_signals[TIME_TICK], 0,
play->time_nanos);
}
return (gst_element_get_state (play->pipeline) == GST_STATE_PLAYING);
}
static gboolean
gst_play_default_idle (GstPlayIdleData * idle_data)
{
if (idle_data->func (idle_data->data))
{
/* call this function again in the future */
return TRUE;
}
/* this function should no longer be called */
g_free (idle_data);
return FALSE;
}
static guint
gst_play_default_timeout_add (guint interval,
GSourceFunc function, gpointer data)
{
GstPlayIdleData *idle_data = g_new0 (GstPlayIdleData, 1);
idle_data->func = function;
idle_data->data = data;
return g_timeout_add (interval, (GSourceFunc) gst_play_default_idle,
idle_data);
}
static guint
gst_play_default_idle_add (GSourceFunc function, gpointer data)
{
GstPlayIdleData *idle_data = g_new0 (GstPlayIdleData, 1);
idle_data->func = function;
idle_data->data = data;
return g_idle_add ((GSourceFunc) gst_play_default_idle, idle_data);
}
static gboolean
gst_play_idle_callback (GstPlay * play)
{
g_return_val_if_fail (play != NULL, FALSE);
g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
return gst_bin_iterate (GST_BIN (play->pipeline));
}
static gboolean
gst_play_idle_signal (GstPlay * play)
{
GstPlaySignal *signal;
gint queue_length;
g_return_val_if_fail (play != NULL, FALSE);
g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
signal = g_async_queue_try_pop (play->signal_queue);
if (signal == NULL)
{
return FALSE;
}
switch (signal->signal_id)
{
case HAVE_VIDEO_OUT:
g_signal_emit (G_OBJECT (play), gst_play_signals[HAVE_VIDEO_OUT], 0,
signal->signal_data.video_out.video_out);
break;
case HAVE_VIS_VIDEO_OUT:
g_signal_emit (G_OBJECT (play), gst_play_signals[HAVE_VIS_VIDEO_OUT], 0,
signal->signal_data.video_out.video_out);
break;
case HAVE_VIDEO_SIZE:
g_signal_emit (G_OBJECT (play), gst_play_signals[HAVE_VIDEO_SIZE], 0,
signal->signal_data.video_size.width,
signal->signal_data.video_size.height);
break;
case HAVE_VIS_SIZE:
g_signal_emit (G_OBJECT (play), gst_play_signals[HAVE_VIS_SIZE], 0,
signal->signal_data.video_size.width,
signal->signal_data.video_size.height);
break;
case STATE_CHANGE:
g_signal_emit (G_OBJECT (play), gst_play_signals[STATE_CHANGE], 0,
signal->signal_data.state.old_state,
signal->signal_data.state.new_state);
break;
case INFORMATION:
g_signal_emit (G_OBJECT (play), gst_play_signals[INFORMATION], 0,
signal->signal_data.info.object,
signal->signal_data.info.param);
gst_object_unref (signal->signal_data.info.object);
break;
case PIPELINE_ERROR:
if (gst_element_get_state (play->pipeline) == GST_STATE_PLAYING)
if (gst_element_set_state (play->pipeline, GST_STATE_READY) !=
GST_STATE_SUCCESS)
g_warning ("PIPELINE_ERROR: set to READY failed");
g_signal_emit (G_OBJECT (play), gst_play_signals[PIPELINE_ERROR], 0,
signal->signal_data.error.element,
signal->signal_data.error.error);
if (signal->signal_data.error.error)
g_free (signal->signal_data.error.error);
gst_object_unref (GST_OBJECT (signal->signal_data.error.element));
break;
default:
break;
}
g_free (signal);
queue_length = g_async_queue_length (play->signal_queue);
return (queue_length > 0);
}
static gboolean
gst_play_idle_eos (GstPlay * play)
{
g_signal_emit (G_OBJECT (play), gst_play_signals[STREAM_END], 0);
return FALSE;
}
static void
callback_audio_sink_eos (GstElement * element, GstPlay * play)
{
play->idle_add_func ((GSourceFunc) gst_play_idle_eos, play);
}
static void
callback_video_have_video_out (GstElement * element,
gpointer video_out, GstPlay * play)
{
GstPlaySignal *signal;
signal = g_new0 (GstPlaySignal, 1);
signal->signal_id = HAVE_VIDEO_OUT;
signal->signal_data.video_out.video_out = video_out;
g_async_queue_push (play->signal_queue, signal);
play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
}
static void
callback_video_have_vis_video_out (GstElement * element,
gpointer video_out, GstPlay * play)
{
GstPlaySignal *signal;
signal = g_new0 (GstPlaySignal, 1);
signal->signal_id = HAVE_VIS_VIDEO_OUT;
signal->signal_data.video_out.video_out = video_out;
g_async_queue_push (play->signal_queue, signal);
play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
}
static void
callback_video_have_size (GstElement * element,
gint width, gint height, GstPlay * play)
{
GstPlaySignal *signal;
signal = g_new0 (GstPlaySignal, 1);
signal->signal_id = HAVE_VIDEO_SIZE;
signal->signal_data.video_size.width = width;
signal->signal_data.video_size.height = height;
g_async_queue_push (play->signal_queue, signal);
play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
}
static void
callback_video_have_vis_size (GstElement * element,
gint width, gint height, GstPlay * play)
{
GstPlaySignal *signal;
signal = g_new0 (GstPlaySignal, 1);
signal->signal_id = HAVE_VIS_SIZE;
signal->signal_data.video_size.width = width;
signal->signal_data.video_size.height = height;
g_async_queue_push (play->signal_queue, signal);
play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
}
static void
callback_pipeline_error (GstElement * object,
GstElement * orig, char *error, GstPlay * play)
{
GstPlaySignal *signal;
signal = g_new0 (GstPlaySignal, 1);
signal->signal_id = PIPELINE_ERROR;
signal->signal_data.error.element = orig;
signal->signal_data.error.error = g_strdup (error);
gst_object_ref (GST_OBJECT (orig));
g_async_queue_push (play->signal_queue, signal);
play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
}
static void
callback_pipeline_deep_notify (GstObject * element,
GstObject * orig,
GParamSpec * param, GstPlay * play)
{
GstPlaySignal *signal;
signal = g_new0 (GstPlaySignal, 1);
signal->signal_id = INFORMATION;
signal->signal_data.info.object = orig;
signal->signal_data.info.param = param;
gst_object_ref (orig);
g_async_queue_push (play->signal_queue, signal);
play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
}
static void
callback_pipeline_state_change (GstElement * element,
GstElementState old,
GstElementState state, GstPlay * play)
{
GstPlaySignal *signal;
g_return_if_fail (play != NULL);
g_return_if_fail (element != NULL);
g_return_if_fail (GST_IS_ELEMENT (element));
g_return_if_fail (GST_IS_PLAY (play));
g_return_if_fail (element == play->pipeline);
/*g_print ("got state change %s to %s\n", gst_element_state_get_name (old), gst_element_state_get_name (state)); */
/* do additional stuff depending on state */
if (GST_IS_PIPELINE (play->pipeline))
{
switch (state)
{
case GST_STATE_PLAYING:
play->idle_add_func ((GSourceFunc) gst_play_idle_callback, play);
play->timeout_add_func (200,
(GSourceFunc) gst_play_tick_callback, play);
if (play->length_nanos == 0LL)
{
/* try to get the length up to 16 times */
play->get_length_attempt = 16;
play->timeout_add_func (200,
(GSourceFunc)
gst_play_get_length_callback, play);
}
break;
default:
break;
}
}
signal = g_new0 (GstPlaySignal, 1);
signal->signal_id = STATE_CHANGE;
signal->signal_data.state.old_state = old;
signal->signal_data.state.new_state = state;
g_async_queue_push (play->signal_queue, signal);
play->idle_add_func ((GSourceFunc) gst_play_idle_signal, play);
}
/* split static pipeline functions to a seperate file */
#include "playpipelines.c"
/* =========================================== */
/* */
/* Init & Class init */
/* */
/* =========================================== */
static void
gst_play_dispose (GObject * object)
{
GstPlay *play;
g_return_if_fail (object != NULL);
g_return_if_fail (GST_IS_PLAY (object));
play = GST_PLAY (object);
/* Removing all sources */
while (g_source_remove_by_user_data (play));
G_OBJECT_CLASS (parent_class)->dispose (object);
}
static void
gst_play_class_init (GstPlayClass * klass)
{
GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
parent_class = g_type_class_ref (GST_TYPE_OBJECT);
klass->information = NULL;
klass->state_changed = NULL;
klass->stream_end = NULL;
gobject_class->dispose = gst_play_dispose;
gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_play_set_property);
gobject_class->get_property = GST_DEBUG_FUNCPTR (gst_play_get_property);
g_object_class_install_property (gobject_class,
ARG_LOCATION,
g_param_spec_string ("location",
"location of file",
"location of the file to play",
NULL,
G_PARAM_READWRITE));
g_object_class_install_property (gobject_class,
ARG_VOLUME,
g_param_spec_float ("volume",
"Playing volume",
"Playing volume",
0, 1.0, 0,
G_PARAM_READWRITE));
g_object_class_install_property (gobject_class,
ARG_MUTE,
g_param_spec_boolean ("mute",
"Volume muted",
"Playing volume muted",
FALSE,
G_PARAM_READWRITE));
gst_play_signals[INFORMATION] =
g_signal_new ("information",
G_TYPE_FROM_CLASS (klass),
G_SIGNAL_RUN_FIRST,
G_STRUCT_OFFSET (GstPlayClass, information),
NULL, NULL,
gst_marshal_VOID__OBJECT_PARAM,
G_TYPE_NONE, 2, G_TYPE_OBJECT, G_TYPE_PARAM);
gst_play_signals[PIPELINE_ERROR] =
g_signal_new ("pipeline_error",
G_TYPE_FROM_CLASS (klass),
G_SIGNAL_RUN_FIRST,
G_STRUCT_OFFSET (GstPlayClass, pipeline_error),
NULL, NULL,
gst_marshal_VOID__OBJECT_STRING,
G_TYPE_NONE, 2, G_TYPE_OBJECT, G_TYPE_STRING);
gst_play_signals[STATE_CHANGE] =
g_signal_new ("state_change",
G_TYPE_FROM_CLASS (klass),
G_SIGNAL_RUN_FIRST,
G_STRUCT_OFFSET (GstPlayClass, state_changed),
NULL, NULL,
gst_marshal_VOID__INT_INT,
G_TYPE_NONE, 2, G_TYPE_INT, G_TYPE_INT);
gst_play_signals[STREAM_END] =
g_signal_new ("stream_end",
G_TYPE_FROM_CLASS (klass),
G_SIGNAL_RUN_FIRST,
G_STRUCT_OFFSET (GstPlayClass, stream_end),
NULL, NULL, gst_marshal_VOID__VOID, G_TYPE_NONE, 0);
gst_play_signals[TIME_TICK] =
g_signal_new ("time_tick",
G_TYPE_FROM_CLASS (klass),
G_SIGNAL_RUN_FIRST,
G_STRUCT_OFFSET (GstPlayClass, time_tick),
NULL, NULL,
gst_marshal_VOID__INT64, G_TYPE_NONE, 1, G_TYPE_INT64);
gst_play_signals[STREAM_LENGTH] =
g_signal_new ("stream_length",
G_TYPE_FROM_CLASS (klass),
G_SIGNAL_RUN_FIRST,
G_STRUCT_OFFSET (GstPlayClass, stream_length),
NULL, NULL,
gst_marshal_VOID__INT64, G_TYPE_NONE, 1, G_TYPE_INT64);
gst_play_signals[HAVE_VIDEO_OUT] =
g_signal_new ("have_video_out",
G_TYPE_FROM_CLASS (klass),
G_SIGNAL_RUN_FIRST,
G_STRUCT_OFFSET (GstPlayClass, have_video_out),
NULL, NULL,
gst_marshal_VOID__POINTER, G_TYPE_NONE, 1, G_TYPE_INT);
gst_play_signals[HAVE_VIS_VIDEO_OUT] =
g_signal_new ("have_vis_video_out",
G_TYPE_FROM_CLASS (klass),
G_SIGNAL_RUN_FIRST,
G_STRUCT_OFFSET (GstPlayClass, have_vis_video_out),
NULL, NULL,
gst_marshal_VOID__POINTER, G_TYPE_NONE, 1, G_TYPE_INT);
gst_play_signals[HAVE_VIDEO_SIZE] =
g_signal_new ("have_video_size",
G_TYPE_FROM_CLASS (klass),
G_SIGNAL_RUN_FIRST,
G_STRUCT_OFFSET (GstPlayClass, have_video_size),
NULL, NULL,
gst_marshal_VOID__INT_INT,
G_TYPE_NONE, 2, G_TYPE_INT, G_TYPE_INT);
gst_play_signals[HAVE_VIS_SIZE] =
g_signal_new ("have_vis_size",
G_TYPE_FROM_CLASS (klass),
G_SIGNAL_RUN_FIRST,
G_STRUCT_OFFSET (GstPlayClass, have_vis_size),
NULL, NULL,
gst_marshal_VOID__INT_INT,
G_TYPE_NONE, 2, G_TYPE_INT, G_TYPE_INT);
gst_control_init (NULL, NULL);
}
static void
gst_play_init (GstPlay * play)
{
play->pipeline = NULL;
play->source = NULL;
play->autoplugger = NULL;
play->audio_sink = NULL;
play->audio_sink_element = NULL;
play->video_sink = NULL;
play->video_sink_element = NULL;
play->volume = NULL;
play->other_elements = g_hash_table_new (g_str_hash, g_str_equal);
gst_play_set_idle_timeout_funcs (play,
gst_play_default_timeout_add,
gst_play_default_idle_add);
}
/* ============================================================= */
/* */
/* Public Methods */
/* */
/* ============================================================= */
/* =========================================== */
/* */
/* Toolbox */
/* */
/* =========================================== */
/**
* gst_play_seek_to_time:
* @play: a #GstPlay.
* @time_nanos: a #gint64 indicating a time position.
*
* Performs a seek on @play until @time_nanos.
*/
void
gst_play_seek_to_time (GstPlay * play, gint64 time_nanos)
{
GstEvent *s_event;
guint8 prev_state;
gboolean audio_seek_worked = FALSE;
gboolean video_seek_worked = FALSE;
gboolean visualization_seek_worked = FALSE;
g_return_if_fail (play != NULL);
g_return_if_fail (GST_IS_PLAY (play));
if (time_nanos < 0LL)
{
play->seek_time = 0LL;
}
else if (time_nanos < 0LL)
{
play->seek_time = play->length_nanos;
}
else
{
play->seek_time = time_nanos;
}
/*g_print("doing seek to %lld\n", play->seek_time); */
prev_state = GST_STATE (play->pipeline);
if (gst_play_set_state (play, GST_STATE_PAUSED) != GST_STATE_SUCCESS)
g_warning ("gst_play_seek: setting to READY failed\n");
s_event = gst_event_new_seek (GST_FORMAT_TIME |
GST_SEEK_METHOD_SET |
GST_SEEK_FLAG_FLUSH, play->seek_time);
if (play->audio_sink_element != NULL)
{
gst_event_ref (s_event);
audio_seek_worked =
gst_element_send_event (play->audio_sink_element, s_event);
}
if (play->visualization_sink_element != NULL)
{
gst_event_ref (s_event);
visualization_seek_worked =
gst_element_send_event (play->visualization_sink_element, s_event);
}
if (play->video_sink_element != NULL)
{
gst_event_ref (s_event);
video_seek_worked =
gst_element_send_event (play->video_sink_element, s_event);
}
gst_event_unref (s_event);
if (audio_seek_worked || video_seek_worked)
{
play->time_nanos = gst_clock_get_time (play->clock);
g_signal_emit (G_OBJECT (play), gst_play_signals[TIME_TICK], 0,
play->time_nanos);
}
if (gst_element_set_state (play->pipeline, prev_state) != GST_STATE_SUCCESS)
g_warning ("gst_play_seek_to_time: setting to READY failed\n");
}
/**
* gst_play_need_new_video_window:
* @play: a #GstPlay.
*
* Request a new video window for @play.
*/
void
gst_play_need_new_video_window (GstPlay * play)
{
g_return_if_fail (play != NULL);
g_return_if_fail (GST_IS_PLAY (play));
if (GST_IS_ELEMENT (play->video_sink_element))
{
g_object_set (G_OBJECT (play->video_sink_element),
"need_new_window", TRUE, NULL);
}
if (GST_IS_ELEMENT (play->visualization_sink_element))
{
g_object_set (G_OBJECT (play->visualization_sink_element),
"need_new_window", TRUE, NULL);
}
}
void
gst_play_set_idle_timeout_funcs (GstPlay * play,
GstPlayTimeoutAdd timeout_add_func,
GstPlayIdleAdd idle_add_func)
{
g_return_if_fail (play != NULL);
g_return_if_fail (GST_IS_PLAY (play));
play->timeout_add_func = timeout_add_func;
play->idle_add_func = idle_add_func;
}
/**
* gst_play_get_sink_element:
* @play: a #GstPlay.
* @element: a #GstElement.
* @sink_type: a #GstPlaySinkType.
*
* Searches recursively for a sink #GstElement with
* type @sink_type in @element which is supposed to be a #GstBin.
*
* Returns: the sink #GstElement of @element.
*/
GstElement *
gst_play_get_sink_element (GstPlay * play,
GstElement * element, GstPlaySinkType sink_type)
{
GList *elements = NULL;
const GList *pads = NULL;
gboolean has_src, has_correct_type;
g_return_val_if_fail (play != NULL, NULL);
g_return_val_if_fail (element != NULL, NULL);
g_return_val_if_fail (GST_IS_PLAY (play), NULL);
g_return_val_if_fail (GST_IS_ELEMENT (element), NULL);
if (!GST_IS_BIN (element))
{
/* since its not a bin, we'll presume this
* element is a sink element */
return element;
}
elements = (GList *) gst_bin_get_list (GST_BIN (element));
/* traverse all elements looking for a src pad */
while (elements)
{
element = GST_ELEMENT (elements->data);
/* Recursivity :) */
if (GST_IS_BIN (element))
{
element = gst_play_get_sink_element (play, element, sink_type);
if (GST_IS_ELEMENT (element))
{
return element;
}
}
else
{
pads = gst_element_get_pad_list (element);
has_src = FALSE;
has_correct_type = FALSE;
while (pads)
{
/* check for src pad */
if (GST_PAD_DIRECTION (GST_PAD (pads->data)) == GST_PAD_SRC)
{
has_src = TRUE;
break;
}
else
{
/* If not a src pad checking caps */
gboolean has_video_cap = FALSE, has_audio_cap = FALSE;
const char *media_type;
media_type = gst_structure_get_name (gst_caps_get_structure (
gst_pad_get_negotiated_caps (GST_PAD (pads->data)), 0));
if (strcmp (media_type, "audio/x-raw-int") == 0)
{
has_audio_cap = TRUE;
}
if ((strcmp (media_type, "video/x-raw-yuv") == 0) ||
(strcmp (media_type, "video/x-raw-rgb") == 0))
{
has_video_cap = TRUE;
}
switch (sink_type)
{
case GST_PLAY_SINK_TYPE_AUDIO:
if (has_audio_cap)
has_correct_type = TRUE;
break;;
case GST_PLAY_SINK_TYPE_VIDEO:
if (has_video_cap)
has_correct_type = TRUE;
break;;
case GST_PLAY_SINK_TYPE_ANY:
if ((has_video_cap) || (has_audio_cap))
has_correct_type = TRUE;
break;;
default:
has_correct_type = FALSE;
}
}
pads = g_list_next (pads);
}
if ((!has_src) && (has_correct_type))
{
return element;
}
}
elements = g_list_next (elements);
}
/* we didn't find a sink element */
return NULL;
}
/* =========================================== */
/* */
/* State, Mute, Volume, Location */
/* */
/* =========================================== */
/**
* gst_play_set_state:
* @play: a #GstPlay.
* @state: a #GstElementState.
*
* Set state of @play 's pipeline to @state.
*
* Returns: a #GstElementStateReturn indicating if the operation succeeded.
*/
GstElementStateReturn
gst_play_set_state (GstPlay * play, GstElementState state)
{
g_return_val_if_fail (play != NULL, GST_STATE_FAILURE);
g_return_val_if_fail (GST_IS_PLAY (play), GST_STATE_FAILURE);
g_return_val_if_fail (GST_IS_ELEMENT (play->pipeline), GST_STATE_FAILURE);
return gst_element_set_state (play->pipeline, state);
}
/**
* gst_play_get_state:
* @play: a #GstPlay.
*
* Get state of @play 's pipeline.
*
* Returns: a #GstElementState indicating @play 's pipeline current state.
*/
GstElementState
gst_play_get_state (GstPlay * play)
{
g_return_val_if_fail (play != NULL, GST_STATE_FAILURE);
g_return_val_if_fail (GST_IS_PLAY (play), GST_STATE_FAILURE);
g_return_val_if_fail (play->pipeline, GST_STATE_FAILURE);
return gst_element_get_state (play->pipeline);
}
/**
* gst_play_set_location:
* @play: a #GstPlay.
* @location: a const #gchar indicating location to play
*
* Set location of @play to @location.
*
* Returns: TRUE if location was set successfully.
*/
gboolean
gst_play_set_location (GstPlay * play, const gchar * location)
{
GstElementState current_state;
g_return_val_if_fail (play != NULL, FALSE);
g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
g_return_val_if_fail (location != NULL, FALSE);
current_state = gst_play_get_state (play);
if (current_state != GST_STATE_READY)
{
if (gst_play_set_state (play, GST_STATE_READY) != GST_STATE_SUCCESS)
g_warning ("gst_play_set_location: setting to READY failed\n");
}
if (play->set_autoplugger)
{
if (!play->
set_autoplugger (play,
gst_element_factory_make ("spider",
"autoplugger")))
{
g_warning ("couldn't replace autoplugger\n");
return FALSE;
}
}
/* FIXME check for valid location (somehow) */
g_object_set (G_OBJECT (play->source), "location", location, NULL);
/* reset time/length values */
play->time_seconds = 0;
play->length_nanos = 0LL;
play->time_nanos = 0LL;
g_signal_emit (G_OBJECT (play), gst_play_signals[STREAM_LENGTH], 0, 0LL);
g_signal_emit (G_OBJECT (play), gst_play_signals[TIME_TICK], 0, 0LL);
play->need_stream_length = TRUE;
return TRUE;
}
/**
* gst_play_get_location:
* @play: a #GstPlay.
*
* Get current location of @play.
*
* Returns: a #gchar pointer to current location.
*/
gchar *
gst_play_get_location (GstPlay * play)
{
gchar *location;
g_return_val_if_fail (play != NULL, NULL);
g_return_val_if_fail (GST_IS_PLAY (play), NULL);
g_return_val_if_fail (GST_IS_ELEMENT (play->source), NULL);
g_object_get (G_OBJECT (play->source), "location", &location, NULL);
return location;
}
/**
* gst_play_set_volume:
* @play: a #GstPlay.
* @volume: a #gfloat indicating volume level.
*
* Set current volume of @play.
*/
void
gst_play_set_volume (GstPlay * play, gfloat volume)
{
g_return_if_fail (play != NULL);
g_return_if_fail (GST_IS_PLAY (play));
g_object_set (G_OBJECT (play->vol_dparam), "value_float", volume, NULL);
}
/**
* gst_play_get_volume:
* @play: a #GstPlay.
*
* Get current volume of @play.
*
* Returns: a #gfloat indicating current volume level.
*/
gfloat
gst_play_get_volume (GstPlay * play)
{
gfloat volume;
g_return_val_if_fail (play != NULL, 0);
g_return_val_if_fail (GST_IS_PLAY (play), 0);
g_object_get (G_OBJECT (play->vol_dparam), "value_float", &volume, NULL);
return volume;
}
/**
* gst_play_set_mute:
* @play: a #GstPlay.
* @mute: a #gboolean indicating wether audio is muted or not.
*
* Mutes/Unmutes audio playback of @play.
*/
void
gst_play_set_mute (GstPlay * play, gboolean mute)
{
g_return_if_fail (play != NULL);
g_return_if_fail (GST_IS_PLAY (play));
g_object_set (G_OBJECT (play->volume), "mute", mute, NULL);
}
/**
* gst_play_get_mute:
* @play: a #GstPlay.
*
* Get current muted status of @play.
*
* Returns: a #gboolean indicating if audio is muted or not.
*/
gboolean
gst_play_get_mute (GstPlay * play)
{
gboolean mute;
g_return_val_if_fail (play != NULL, 0);
g_return_val_if_fail (GST_IS_PLAY (play), 0);
g_object_get (G_OBJECT (play->volume), "mute", &mute, NULL);
return mute;
}
/* =========================================== */
/* */
/* Audio sink, Video sink, Data src */
/* */
/* =========================================== */
/**
* gst_play_set_data_src:
* @play: a #GstPlay.
* @data_src: a #GstElement.
*
* Set @data_src as the source element of @play.
*
* Returns: TRUE if call succeeded.
*/
gboolean
gst_play_set_data_src (GstPlay * play, GstElement * data_src)
{
g_return_val_if_fail (play != NULL, FALSE);
g_return_val_if_fail (data_src != NULL, FALSE);
g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
g_return_val_if_fail (GST_IS_ELEMENT (data_src), FALSE);
if (gst_play_get_state (play) != GST_STATE_READY)
{
if (gst_play_set_state (play, GST_STATE_READY) != GST_STATE_SUCCESS)
g_warning ("gst_play_set_data_src: setting to READY failed\n");
}
if (play->set_data_src)
{
return play->set_data_src (play, data_src);
}
/* if there is no set_data_src func, fail quietly */
return FALSE;
}
/**
* gst_play_set_video_sink:
* @play: a #GstPlay.
* @video_sink: a #GstElement.
*
* Set @video_sink as the video sink element of @play.
*
* Returns: TRUE if call succeeded.
*/
gboolean
gst_play_set_video_sink (GstPlay * play, GstElement * video_sink)
{
g_return_val_if_fail (play != NULL, FALSE);
g_return_val_if_fail (video_sink != NULL, FALSE);
g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
g_return_val_if_fail (GST_IS_ELEMENT (video_sink), FALSE);
if (gst_play_get_state (play) != GST_STATE_READY)
{
if (gst_play_set_state (play, GST_STATE_READY) != GST_STATE_SUCCESS)
g_warning ("gst_play_set_video_sink: setting to READY failed\n");
}
if (play->set_video_sink)
{
return play->set_video_sink (play, video_sink);
}
/* if there is no set_video_sink func, fail quietly */
return FALSE;
}
/**
* gst_play_set_audio_sink:
* @play: a #GstPlay.
* @audio_sink: a #GstElement.
*
* Set @audio_sink as the audio sink element of @play.
*
* Returns: TRUE if call succeeded.
*/
gboolean
gst_play_set_audio_sink (GstPlay * play, GstElement * audio_sink)
{
g_return_val_if_fail (play != NULL, FALSE);
g_return_val_if_fail (audio_sink != NULL, FALSE);
g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
g_return_val_if_fail (GST_IS_ELEMENT (audio_sink), FALSE);
if (gst_play_get_state (play) != GST_STATE_READY)
{
if (gst_play_set_state (play, GST_STATE_READY) != GST_STATE_SUCCESS)
g_warning ("gst_play_set_audio_sink: setting to READY failed\n");
}
if (play->set_audio_sink)
{
return play->set_audio_sink (play, audio_sink);
}
/* if there is no set_audio_sink func, fail quietly */
return FALSE;
}
/* =========================================== */
/* */
/* Object typing & Creation */
/* */
/* =========================================== */
GType
gst_play_get_type (void)
{
static GType play_type = 0;
if (!play_type)
{
static const GTypeInfo play_info = {
sizeof (GstPlayClass),
(GBaseInitFunc) NULL,
(GBaseFinalizeFunc) NULL,
(GClassInitFunc) gst_play_class_init,
NULL, NULL, sizeof (GstPlay),
0, (GInstanceInitFunc) gst_play_init,
NULL
};
play_type =
g_type_register_static (G_TYPE_OBJECT, "GstPlay", &play_info, 0);
}
return play_type;
}
GstPlay *
gst_play_new (GstPlayPipeType pipe_type, GError ** error)
{
GstPlay *play;
play = g_object_new (GST_TYPE_PLAY, NULL);
/* FIXME: looks like only VIDEO ever gets used ! */
switch (pipe_type)
{
case GST_PLAY_PIPE_VIDEO:
play->setup_pipeline = gst_play_video_setup;
play->teardown_pipeline = NULL;
play->set_data_src = gst_play_video_set_data_src;
play->set_autoplugger = gst_play_video_set_auto;
play->set_video_sink = gst_play_video_set_video;
play->set_audio_sink = gst_play_video_set_audio;
break;
case GST_PLAY_PIPE_VIDEO_VISUALISATION:
play->setup_pipeline = gst_play_video_vis_setup;
play->teardown_pipeline = NULL;
play->set_data_src = gst_play_video_set_data_src;
play->set_autoplugger = gst_play_video_set_auto;
play->set_video_sink = gst_play_video_vis_set_video;
play->set_audio_sink = gst_play_video_vis_set_audio;
break;
case GST_PLAY_PIPE_AUDIO:
/* we can reuse the threaded set functions */
play->setup_pipeline = gst_play_audio_setup;
play->teardown_pipeline = NULL;
play->set_data_src = gst_play_simple_set_data_src;
play->set_autoplugger = gst_play_audiot_set_auto;
play->set_video_sink = NULL;
play->set_audio_sink = gst_play_audiot_set_audio;
break;
case GST_PLAY_PIPE_AUDIO_THREADED:
play->setup_pipeline = gst_play_audiot_setup;
play->teardown_pipeline = NULL;
play->set_data_src = gst_play_simple_set_data_src;
play->set_autoplugger = gst_play_audiot_set_auto;
play->set_video_sink = NULL;
play->set_audio_sink = gst_play_audiot_set_audio;
break;
case GST_PLAY_PIPE_AUDIO_HYPER_THREADED:
play->setup_pipeline = gst_play_audioht_setup;
play->teardown_pipeline = NULL;
play->set_data_src = gst_play_simple_set_data_src;
play->set_autoplugger = gst_play_audioht_set_auto;
play->set_video_sink = NULL;
play->set_audio_sink = gst_play_audioht_set_audio;
break;
default:
g_warning ("unknown pipeline type: %d\n", pipe_type);
}
/* init pipeline */
if ((play->setup_pipeline) && (!play->setup_pipeline (play, error)))
{
g_object_unref (play);
return NULL;
}
if (play->pipeline)
{
/* connect to pipeline events */
g_signal_connect (G_OBJECT (play->pipeline),
"deep_notify",
G_CALLBACK (callback_pipeline_deep_notify), play);
g_signal_connect (G_OBJECT (play->pipeline),
"state_change",
G_CALLBACK (callback_pipeline_state_change), play);
g_signal_connect (G_OBJECT (play->pipeline),
"error", G_CALLBACK (callback_pipeline_error), play);
}
if (play->volume)
{
play->vol_dpman = gst_dpman_get_manager (play->volume);
play->vol_dparam = gst_dpsmooth_new (G_TYPE_FLOAT);
g_object_set (G_OBJECT (play->vol_dparam),
"update_period", 2000000LL, NULL);
g_object_set (G_OBJECT (play->vol_dparam),
"slope_delta_float", 0.1F, NULL);
g_object_set (G_OBJECT (play->vol_dparam),
"slope_time", 10000000LL, NULL);
if (!gst_dpman_attach_dparam (play->vol_dpman,
"volume", play->vol_dparam))
g_warning ("could not attach dparam to volume element\n");
gst_dpman_set_mode (play->vol_dpman, "asynchronous");
gst_play_set_volume (play, 0.9);
}
play->signal_queue = g_async_queue_new ();
return play;
}
Reference in a new issue View git blame Copy permalink