Code cleanup and reorganization

Original commit message from CVS:
Code cleanup and reorganization
I ll now be able to make nice gtk-doc for this lib
Fixed latency bug on async_queue pop
X video window now comes immediatly
This commit is contained in:
Julien Moutte 2003-02-06 23:17:37 +00:00
parent 39e02b7779
commit bcea95f6cb
3 changed files with 886 additions and 720 deletions

File diff suppressed because it is too large Load diff

View file

@ -2,6 +2,7 @@
* Copyright (C) 1999,2000,2001,2002 Erik Walthinsen <omega@cse.ogi.edu> * Copyright (C) 1999,2000,2001,2002 Erik Walthinsen <omega@cse.ogi.edu>
* 2000,2001,2002 Wim Taymans <wtay@chello.be> * 2000,2001,2002 Wim Taymans <wtay@chello.be>
* 2002 Steve Baker <steve@stevebaker.org> * 2002 Steve Baker <steve@stevebaker.org>
* 2003 Julien Moutte <julien@moutte.net>
* *
* play.h: GstPlay object code * play.h: GstPlay object code
* *
@ -76,7 +77,9 @@ typedef struct _GstPlay GstPlay;
typedef struct _GstPlayClass GstPlayClass; typedef struct _GstPlayClass GstPlayClass;
typedef struct _GstPlayIdleData GstPlayIdleData; typedef struct _GstPlayIdleData GstPlayIdleData;
typedef guint (*GstPlayTimeoutAdd) (guint interval, GSourceFunc function, gpointer data); typedef guint (*GstPlayTimeoutAdd) ( guint interval,
GSourceFunc function,
gpointer data);
typedef guint (*GstPlayIdleAdd) (GSourceFunc function, gpointer data); typedef guint (*GstPlayIdleAdd) (GSourceFunc function, gpointer data);
struct _GstPlay struct _GstPlay
@ -117,10 +120,6 @@ struct _GstPlay
gint64 time_nanos; gint64 time_nanos;
gint64 length_nanos; gint64 length_nanos;
guint tick_timeout_id;
guint idle_timeout_id;
guint idle_signal_id;
GAsyncQueue *signal_queue; GAsyncQueue *signal_queue;
GstPlayTimeoutAdd timeout_add_func; GstPlayTimeoutAdd timeout_add_func;
@ -132,13 +131,22 @@ struct _GstPlayClass
GObjectClass parent_class; GObjectClass parent_class;
/* signals */ /* signals */
void (*information) (GstPlay* play, GstElement* element, GParamSpec *param); void (*information) ( GstPlay* play,
void (*state_changed) (GstPlay* play, GstElementState old_state, GstElementState new_state); GstElement* element,
void (*stream_end) (GstPlay* play); GParamSpec *param);
void (*time_tick) (GstPlay* play, gint64 time_nanos); void (*state_changed) ( GstPlay* play,
void (*stream_length) (GstPlay* play, gint64 length_nanos); GstElementState old_state,
void (*have_xid) (GstPlay* play, gint xid); GstElementState new_state);
void (*have_video_size) (GstPlay* play, gint width, gint height); void (*stream_end) ( GstPlay* play);
void (*time_tick) ( GstPlay* play,
gint64 time_nanos);
void (*stream_length) ( GstPlay* play,
gint64 length_nanos);
void (*have_xid) ( GstPlay* play,
gint xid);
void (*have_video_size) ( GstPlay* play,
gint width,
gint height);
}; };
struct _GstPlayIdleData struct _GstPlayIdleData
@ -147,35 +155,71 @@ struct _GstPlayIdleData
gpointer data; gpointer data;
}; };
GType gst_play_get_type (void);
GstPlay* gst_play_new (GstPlayPipeType pipe_type, GError **error); void
gst_play_seek_to_time ( GstPlay *play,
gint64 time_nanos);
void gst_play_seek_to_time (GstPlay *play, gint64 time_nanos); void
gst_play_need_new_video_window (GstPlay *play);
GstElement* gst_play_get_sink_element (GstPlay *play, GstElement *element); void
gst_play_set_idle_timeout_funcs ( GstPlay *play,
GstPlayTimeoutAdd timeout_add_func,
GstPlayIdleAdd idle_add_func);
GstElement*
gst_play_get_sink_element ( GstPlay *play,
GstElement *element);
gboolean gst_play_set_data_src (GstPlay *play, GstElement *data_src); /* Set/Get state */
gboolean gst_play_set_video_sink (GstPlay *play, GstElement *element);
gboolean gst_play_set_audio_sink (GstPlay *play, GstElement *element);
void gst_play_need_new_video_window (GstPlay *play);
GstElementStateReturn gst_play_set_state (GstPlay *play, GstElementState state); GstElementStateReturn
GstElementState gst_play_get_state (GstPlay *play); gst_play_set_state ( GstPlay *play,
GstElementState state);
GstElementState
gst_play_get_state (GstPlay *play);
gboolean gst_play_set_location (GstPlay *play, const gchar *location); /* Set/Get location */
gchar* gst_play_get_location (GstPlay *play);
void gst_play_set_volume (GstPlay *play, gfloat volume); gboolean
gfloat gst_play_get_volume (GstPlay *play); gst_play_set_location ( GstPlay *play,
const gchar *location);
gchar*
gst_play_get_location (GstPlay *play);
void gst_play_set_mute (GstPlay *play, gboolean mute); /* Set/Get volume */
gboolean gst_play_get_mute (GstPlay *play);
void gst_play_set_idle_timeout_funcs (GstPlay *play, GstPlayTimeoutAdd timeout_add_func, GstPlayIdleAdd idle_add_func); void
gst_play_set_volume ( GstPlay *play,
gfloat volume);
gfloat
gst_play_get_volume (GstPlay *play);
/* Set/Get mute */
void
gst_play_set_mute ( GstPlay *play,
gboolean mute);
gboolean
gst_play_get_mute (GstPlay *play);
/* Set sinks and data src */
gboolean
gst_play_set_data_src ( GstPlay *play,
GstElement *data_src);
gboolean
gst_play_set_video_sink ( GstPlay *play,
GstElement *video_sink);
gboolean
gst_play_set_audio_sink ( GstPlay *play,
GstElement *audio_sink);
GType
gst_play_get_type (void);
GstPlay *
gst_play_new ( GstPlayPipeType pipe_type,
GError **error);
#endif /* __GSTPLAY_H__ */ #endif /* __GSTPLAY_H__ */
/* modelines */
/* vim:set ts=8:sw=8:noet */

View file

@ -2,6 +2,7 @@
* Copyright (C) 1999,2000,2001,2002 Erik Walthinsen <omega@cse.ogi.edu> * Copyright (C) 1999,2000,2001,2002 Erik Walthinsen <omega@cse.ogi.edu>
* 2000,2001,2002 Wim Taymans <wtay@chello.be> * 2000,2001,2002 Wim Taymans <wtay@chello.be>
* 2002 Steve Baker <steve@stevebaker.org> * 2002 Steve Baker <steve@stevebaker.org>
* 2003 Julien Moutte <julien@moutte.net>
* *
* playpipelines.c: Set up pipelines for playback * playpipelines.c: Set up pipelines for playback
* *
@ -22,13 +23,16 @@
*/ */
static gboolean static gboolean
gst_play_default_set_data_src (GstPlay *play, GstElement *datasrc, GstElement* parent) gst_play_default_set_data_src ( GstPlay *play,
GstElement *datasrc,
GstElement* parent)
{ {
g_return_val_if_fail (GST_IS_PLAY (play), FALSE); g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
g_return_val_if_fail (GST_IS_ELEMENT (datasrc), FALSE); g_return_val_if_fail (GST_IS_ELEMENT (datasrc), FALSE);
if (GST_IS_ELEMENT(play->source)) { if (GST_IS_ELEMENT(play->source)) {
/* we need to remove the existing data source before creating a new one */ /* we need to remove the existing data
source before creating a new one */
if (GST_IS_ELEMENT(play->autoplugger)){ if (GST_IS_ELEMENT(play->autoplugger)){
gst_element_unlink (play->autoplugger, play->source); gst_element_unlink (play->autoplugger, play->source);
} }
@ -51,7 +55,8 @@ gst_play_default_set_data_src (GstPlay *play, GstElement *datasrc, GstElement* p
*/ */
static gboolean static gboolean
gst_play_audio_setup (GstPlay *play, GError **error) gst_play_audio_setup ( GstPlay *play,
GError **error)
{ {
/* creating gst_bin */ /* creating gst_bin */
@ -105,7 +110,8 @@ gst_play_audio_setup (GstPlay *play, GError **error)
} }
static gboolean static gboolean
gst_play_simple_set_data_src (GstPlay *play, GstElement *datasrc) gst_play_simple_set_data_src ( GstPlay *play,
GstElement *datasrc)
{ {
return gst_play_default_set_data_src(play, datasrc, play->pipeline); return gst_play_default_set_data_src(play, datasrc, play->pipeline);
} }
@ -116,7 +122,8 @@ gst_play_simple_set_data_src (GstPlay *play, GstElement *datasrc)
*/ */
static gboolean static gboolean
gst_play_audiot_setup (GstPlay *play, GError **error) gst_play_audiot_setup ( GstPlay *play,
GError **error)
{ {
g_return_val_if_fail (GST_IS_PLAY(play), FALSE); g_return_val_if_fail (GST_IS_PLAY(play), FALSE);
@ -173,7 +180,8 @@ gst_play_audiot_setup (GstPlay *play, GError **error)
static gboolean static gboolean
gst_play_audiot_set_audio (GstPlay *play, GstElement *audio_sink) gst_play_audiot_set_audio ( GstPlay *play,
GstElement *audio_sink)
{ {
g_return_val_if_fail (GST_IS_PLAY(play), FALSE); g_return_val_if_fail (GST_IS_PLAY(play), FALSE);
g_return_val_if_fail (GST_IS_ELEMENT (audio_sink), FALSE); g_return_val_if_fail (GST_IS_ELEMENT (audio_sink), FALSE);
@ -200,14 +208,16 @@ gst_play_audiot_set_audio (GstPlay *play, GstElement *audio_sink)
static gboolean static gboolean
gst_play_audiot_set_auto (GstPlay *play, GstElement *autoplugger) gst_play_audiot_set_auto ( GstPlay *play,
GstElement *autoplugger)
{ {
g_return_val_if_fail (GST_IS_PLAY (play), FALSE); g_return_val_if_fail (GST_IS_PLAY (play), FALSE);
g_return_val_if_fail (GST_IS_ELEMENT (autoplugger), FALSE); g_return_val_if_fail (GST_IS_ELEMENT (autoplugger), FALSE);
if (play->autoplugger) { if (play->autoplugger) {
/* we need to remove the existing autoplugger before creating a new one */ /* we need to remove the existing autoplugger
before creating a new one */
gst_element_unlink (play->autoplugger, play->volume); gst_element_unlink (play->autoplugger, play->volume);
gst_element_unlink (play->autoplugger, play->source); gst_element_unlink (play->autoplugger, play->source);
gst_bin_remove (GST_BIN (play->pipeline), play->autoplugger); gst_bin_remove (GST_BIN (play->pipeline), play->autoplugger);
@ -228,7 +238,8 @@ gst_play_audiot_set_auto (GstPlay *play, GstElement *autoplugger)
*/ */
static gboolean static gboolean
gst_play_audioht_setup (GstPlay *play, GError **error) gst_play_audioht_setup ( GstPlay *play,
GError **error)
{ {
GstElement *audio_thread, *audio_queue; GstElement *audio_thread, *audio_queue;
@ -313,7 +324,8 @@ gst_play_audioht_setup (GstPlay *play, GError **error)
static gboolean static gboolean
gst_play_audioht_set_audio (GstPlay *play, GstElement *audio_sink) gst_play_audioht_set_audio ( GstPlay *play,
GstElement *audio_sink)
{ {
GstElement *audio_thread; GstElement *audio_thread;
@ -344,7 +356,8 @@ gst_play_audioht_set_audio (GstPlay *play, GstElement *audio_sink)
static gboolean static gboolean
gst_play_audioht_set_auto (GstPlay *play, GstElement *autoplugger) gst_play_audioht_set_auto ( GstPlay *play,
GstElement *autoplugger)
{ {
GstElement *audio_thread; GstElement *audio_thread;
@ -354,7 +367,8 @@ gst_play_audioht_set_auto (GstPlay *play, GstElement *autoplugger)
audio_thread = g_hash_table_lookup(play->other_elements, "audio_thread"); audio_thread = g_hash_table_lookup(play->other_elements, "audio_thread");
if (play->autoplugger) { if (play->autoplugger) {
/* we need to remove the existing autoplugger before creating a new one */ /* we need to remove the existing autoplugger
before creating a new one */
gst_element_unlink (play->autoplugger, audio_thread); gst_element_unlink (play->autoplugger, audio_thread);
gst_element_unlink (play->autoplugger, play->source); gst_element_unlink (play->autoplugger, play->source);
gst_bin_remove (GST_BIN (play->pipeline), play->autoplugger); gst_bin_remove (GST_BIN (play->pipeline), play->autoplugger);
@ -376,7 +390,8 @@ gst_play_audioht_set_auto (GstPlay *play, GstElement *autoplugger)
*/ */
static gboolean static gboolean
gst_play_video_setup (GstPlay *play, GError **error) gst_play_video_setup ( GstPlay *play,
GError **error)
{ {
GstElement *audio_bin, *audio_queue; GstElement *audio_bin, *audio_queue;
GstElement *video_queue, *video_bin; GstElement *video_queue, *video_bin;
@ -523,7 +538,8 @@ gst_play_video_setup (GstPlay *play, GError **error)
} }
static gboolean static gboolean
gst_play_video_set_data_src (GstPlay *play, GstElement *datasrc) gst_play_video_set_data_src ( GstPlay *play,
GstElement *datasrc)
{ {
GstElement *work_thread; GstElement *work_thread;
g_return_val_if_fail (GST_IS_PLAY(play), FALSE); g_return_val_if_fail (GST_IS_PLAY(play), FALSE);
@ -533,7 +549,8 @@ gst_play_video_set_data_src (GstPlay *play, GstElement *datasrc)
} }
static gboolean static gboolean
gst_play_video_set_auto (GstPlay *play, GstElement *autoplugger) gst_play_video_set_auto ( GstPlay *play,
GstElement *autoplugger)
{ {
GstElement *audio_bin, *video_bin, *work_thread; GstElement *audio_bin, *video_bin, *work_thread;
@ -546,7 +563,8 @@ gst_play_video_set_auto (GstPlay *play, GstElement *autoplugger)
work_thread = g_hash_table_lookup(play->other_elements, "work_thread"); work_thread = g_hash_table_lookup(play->other_elements, "work_thread");
if (play->autoplugger) { if (play->autoplugger) {
/* we need to remove the existing autoplugger before creating a new one */ /* we need to remove the existing autoplugger
before creating a new one */
gst_element_unlink (play->autoplugger, audio_bin); gst_element_unlink (play->autoplugger, audio_bin);
gst_element_unlink (play->autoplugger, play->source); gst_element_unlink (play->autoplugger, play->source);
gst_element_unlink (play->autoplugger, video_bin); gst_element_unlink (play->autoplugger, video_bin);
@ -567,7 +585,8 @@ gst_play_video_set_auto (GstPlay *play, GstElement *autoplugger)
static gboolean static gboolean
gst_play_video_set_video (GstPlay *play, GstElement *video_sink) gst_play_video_set_video ( GstPlay *play,
GstElement *video_sink)
{ {
GstElement *video_mate, *video_bin; GstElement *video_mate, *video_bin;
@ -588,18 +607,27 @@ gst_play_video_set_video (GstPlay *play, GstElement *video_sink)
play->video_sink_element = gst_play_get_sink_element (play, video_sink); play->video_sink_element = gst_play_get_sink_element (play, video_sink);
if (play->video_sink_element != NULL) { if (play->video_sink_element != NULL) {
g_signal_connect (G_OBJECT (play->video_sink_element), "have_xid", g_signal_connect ( G_OBJECT (play->video_sink_element),
G_CALLBACK (callback_video_have_xid), play); "have_xid",
g_signal_connect (G_OBJECT (play->video_sink_element), "have_size", G_CALLBACK (callback_video_have_xid),
G_CALLBACK (callback_video_have_size), play); play);
g_object_set(G_OBJECT(play->video_sink_element), "need_new_window", TRUE, "toplevel", FALSE, NULL); g_signal_connect ( G_OBJECT (play->video_sink_element),
"have_size",
G_CALLBACK (callback_video_have_size),
play);
g_object_set( G_OBJECT(play->video_sink_element),
"need_new_window",
TRUE,
"toplevel",
FALSE, NULL);
} }
return TRUE; return TRUE;
} }
static gboolean static gboolean
gst_play_video_set_audio (GstPlay *play, GstElement *audio_sink) gst_play_video_set_audio ( GstPlay *play,
GstElement *audio_sink)
{ {
GstElement *audio_bin; GstElement *audio_bin;