mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-28 04:31:06 +00:00
Code Issues 1 Projects Releases Wiki Activity

Made a theorical libgstplay which refs/unrefs elements before putting them in AsyncQueue.

Browse source 
Original commit message from CVS:
Made a theorical libgstplay which refs/unrefs elements before putting them in AsyncQueue.
Added a "pipeline_error" signal which will later allow the player and apps to detect that pipeline was unable to play and why...
This version is NOT STABLE AT ALL. it will need fixes in core but i commit it as is so that we fix those problems
This commit is contained in:
Julien Moutte 2003-04-20 21:06:55 +00:00
parent 700a618147
commit 7b2a8e25dc
2 changed files with 42 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

44
gst-libs/gst/play/play.old.c
View file

@ -34,6 +34,7 @@ enum {
HAVE_VIS_XID,
HAVE_VIDEO_SIZE,
LAST_SIGNAL,
PIPELINE_ERROR,
};
/* this struct is used to decouple signals coming out of threaded pipelines */
@ -59,6 +60,10 @@ struct _GstPlaySignal
GstElement* element;
GParamSpec* param;
} info;
struct {
GstElement* element;
gchar* error;
} error;
} signal_data;
};
@ -338,6 +343,14 @@ gst_play_idle_signal (GstPlay *play)
case INFORMATION:
g_signal_emit (G_OBJECT (play), gst_play_signals[INFORMATION], 0,
signal->signal_data.info.element, signal->signal_data.info.param);
gst_object_unref (GST_OBJECT(signal->signal_data.info.element));
break;
case PIPELINE_ERROR:
if (gst_element_get_state(play->pipeline) == GST_STATE_PLAYING)
gst_element_set_state(play->pipeline, GST_STATE_READY);
g_signal_emit (G_OBJECT (play), gst_play_signals[PIPELINE_ERROR], 0,
signal->signal_data.error.element, signal->signal_data.error.error);
gst_object_unref (GST_OBJECT(signal->signal_data.error.element));
break;
default:
break;
@ -428,14 +441,23 @@ callback_bin_post_iterate ( GstBin *bin,
}
static void
callback_pipeline_error ( GObject *object,
GstObject *orig,
callback_pipeline_error ( GstElement *object,
GstElement *orig,
gchar *error,
GstPlay* play)
{
g_print ("Pipeline error: %s\n", error);
if (gst_element_get_state(play->pipeline) == GST_STATE_PLAYING)
gst_element_set_state(play->pipeline, GST_STATE_READY);
GstPlaySignal *signal;
signal = g_new0(GstPlaySignal, 1);
signal->signal_id = PIPELINE_ERROR;
signal->signal_data.error.element = orig;
signal->signal_data.error.error = 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
@ -450,6 +472,8 @@ callback_pipeline_deep_notify ( GstElement *element,
signal->signal_id = INFORMATION;
signal->signal_data.info.element = orig;
signal->signal_data.info.param = param;
gst_object_ref (GST_OBJECT(orig));
g_async_queue_push(play->signal_queue, signal);
@ -577,6 +601,16 @@ gst_play_class_init (GstPlayClass *klass)
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_PARAM,
G_TYPE_NONE, 2,
G_TYPE_OBJECT, G_TYPE_PARAM);
gst_play_signals [STATE_CHANGE] =
g_signal_new ("state_change",
G_TYPE_FROM_CLASS (klass),

3
gst-libs/gst/play/play.old.h
View file

@ -142,6 +142,9 @@ struct _GstPlayClass
void (*information) ( GstPlay* play,
GstElement* element,
GParamSpec *param);
void (*pipeline_error) ( GstPlay* play,
GstElement* element,
gchar *error);
void (*state_changed) ( GstPlay* play,
GstElementState old_state,
GstElementState new_state);