2000-12-28 22:12:02 +00:00
/* GStreamer
* Copyright ( C ) 1999 , 2000 Erik Walthinsen < omega @ cse . ogi . edu >
* 2000 Wim Taymans < wtay @ chello . be >
*
* gst . c : Initialization and non - pipeline operations
2000-01-30 09:03:00 +00:00
*
* 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 .
*/
2001-01-01 03:43:27 +00:00
# include <stdlib.h>
2002-02-16 03:24:50 +00:00
# include <stdio.h>
2001-01-01 03:43:27 +00:00
2000-12-28 22:12:02 +00:00
# include "gst_private.h"
2001-12-04 22:12:50 +00:00
# include "gst.h"
2001-01-19 00:01:42 +00:00
# include "gstqueue.h"
2002-04-11 20:35:18 +00:00
# ifndef GST_DISABLE_TYPE_FIND
2001-01-19 00:01:42 +00:00
# include "gsttypefind.h"
2001-06-25 20:36:02 +00:00
# endif
2000-01-30 09:03:00 +00:00
2001-02-24 00:23:21 +00:00
# define MAX_PATH_SPLIT 16
2001-10-17 10:21:27 +00:00
# define GST_PLUGIN_SEPARATOR ","
2000-12-29 10:02:17 +00:00
gchar * _gst_progname ;
2000-01-30 09:03:00 +00:00
extern gint _gst_trace_on ;
2001-02-23 19:09:18 +00:00
extern gboolean _gst_plugin_spew ;
2000-01-30 09:03:00 +00:00
2000-12-29 10:02:17 +00:00
2001-10-17 10:21:27 +00:00
static void load_plugin_func ( gpointer data , gpointer user_data ) ;
2002-02-15 16:14:21 +00:00
static void init_popt_callback ( poptContext context , enum poptCallbackReason reason ,
const struct poptOption * option , const char * arg , void * data ) ;
2002-02-16 18:27:04 +00:00
static void init_pre ( void ) ;
static void init_post ( void ) ;
2001-10-17 10:21:27 +00:00
static GSList * preload_plugins = NULL ;
WARNING: Don't grab this updated unless you're really, REALLY sure.
Original commit message from CVS:
WARNING: Don't grab this updated unless you're really, REALLY sure.
WARNING: Wait for the next one.
Whole lotta changes here, including a few random bits:
examples/*/Makefile: updated to use `libtool gcc`, not just `gcc`
gst/
gstbuffer.h: updated to new flag style
gst.c, gstdebug.h: added new debugging for function ptrs
gstpipeline.c: set type of parent_class to the class, not the object
gstthread.c: ditto
plugins/
cdparanoia/cdparanoia.c: added an argument type, updated some defaults
cobin/spindentity.c: updated to new do/while loopfunction style
mp3encode/lame/gstlame.c: argument types, whole lotta lame options
tests/: various changes
Now, for the big changes: Once again, the scheduling system has changed.
And once again, it broke a whole bunch of things. The gist of the change
is that there is now a function pointer for gst_pad_push and gst_pad_pull,
instead of a hard-wired function. Well, currently they are functions, but
that's for debugging purposes only, they just call the function pointer
after spewing lots of DEBUG().
This changed the GstPad structure a bit, and the GstPad API as well.
Where elements used to provide chain() and pull() functions, they provide
chain() and get() functions. gst_pad_set_pull[region]_function has been
changed to get_pad_set_get[region]_function. This means all the elements
out there that used to have pull functions need to be updated. The calls
to that function have been changed in the normal elements, but the names
of the functions passed is still _pull[region](), which is an aesthetic
issue more than anything.
As for what doesn't work yet, just about anything dealing with Connections
is hosed, meaning threaded stuff won't work. This will be fixed about 12
hours from now, after I've slept, etc. The simplefake.c test works in
both cothreaded and chained cases, but not much else will work due to the
Connection problem. Needless to say, don't grab this unless you *need*
these features *now*, else wait to update this stuff until tomorrow.
I'm going to sleep now.
2000-12-16 10:18:09 +00:00
2001-09-13 21:16:25 +00:00
const gchar * g_log_domain_gstreamer = " GStreamer " ;
static void
debug_log_handler ( const gchar * log_domain ,
GLogLevelFlags log_level ,
const gchar * message ,
gpointer user_data )
{
g_log_default_handler ( log_domain , log_level , message , user_data ) ;
g_on_error_query ( NULL ) ;
}
2002-02-15 16:14:21 +00:00
enum {
ARG_INFO_MASK = 1 ,
ARG_DEBUG_MASK ,
ARG_MASK ,
2002-04-07 23:32:16 +00:00
ARG_MASK_HELP ,
2002-02-15 16:14:21 +00:00
ARG_PLUGIN_SPEW ,
ARG_PLUGIN_PATH ,
ARG_PLUGIN_LOAD ,
ARG_SCHEDULER
} ;
# ifndef NUL
# define NUL '\0'
# endif
/* FIXME: put in the extended mask help */
static const struct poptOption options [ ] = {
{ NULL , NUL , POPT_ARG_CALLBACK | POPT_CBFLAG_PRE | POPT_CBFLAG_POST , & init_popt_callback , 0 , NULL , NULL } ,
{ " gst-info-mask " , NUL , POPT_ARG_INT | POPT_ARGFLAG_STRIP , NULL , ARG_INFO_MASK , " info bitmask " , " MASK " } ,
{ " gst-debug-mask " , NUL , POPT_ARG_INT | POPT_ARGFLAG_STRIP , NULL , ARG_DEBUG_MASK , " debugging bitmask " , " MASK " } ,
{ " gst-mask " , NUL , POPT_ARG_INT | POPT_ARGFLAG_STRIP , NULL , ARG_MASK , " bitmask for both info and debugging " , " MASK " } ,
2002-04-07 23:32:16 +00:00
{ " gst-mask-help " , NUL , POPT_ARG_NONE | POPT_ARGFLAG_STRIP , NULL , ARG_MASK_HELP , " how to set the level of diagnostic output (-mask values) " , NULL } ,
2002-02-15 16:14:21 +00:00
{ " gst-plugin-spew " , NUL , POPT_ARG_NONE | POPT_ARGFLAG_STRIP , NULL , ARG_PLUGIN_SPEW , " enable verbose plugin loading diagnostics " , NULL } ,
{ " gst-plugin-path " , NUL , POPT_ARG_STRING | POPT_ARGFLAG_STRIP , NULL , ARG_PLUGIN_PATH , " ' " G_SEARCHPATH_SEPARATOR_S " '--separated path list for loading plugins " , " PATHS " } ,
2002-02-20 20:17:30 +00:00
{ " gst-plugin-load " , NUL , POPT_ARG_STRING | POPT_ARGFLAG_STRIP , NULL , ARG_PLUGIN_LOAD , " comma-separated list of plugins to preload in addition to the list stored in env variable GST_PLUGIN_PATH " , " PLUGINS " } ,
2002-02-15 16:14:21 +00:00
{ " gst-scheduler " , NUL , POPT_ARG_STRING | POPT_ARGFLAG_STRIP , NULL , ARG_SCHEDULER , " scheduler to use ('basic' is the default) " , " SCHEDULER " } ,
POPT_TABLEEND
} ;
/**
* gst_init_get_popt_table :
*
* Returns a popt option table with GStreamer ' s argument specifications . The
* table is set up to use popt ' s callback method , so whenever the parsing is
* actually performed ( via a poptGetContext ( ) ) , the GStreamer libraries will
* be initialized .
*
* Returns : a pointer to the static GStreamer option table . No free is necessary .
*/
const struct poptOption *
gst_init_get_popt_table ( void )
{
return options ;
}
2000-01-30 09:03:00 +00:00
/**
* gst_init :
* @ argc : pointer to application ' s argc
* @ argv : pointer to application ' s argv
*
2000-02-02 06:26:44 +00:00
* Initializes the GStreamer library , setting up internal path lists ,
* registering built - in elements , and loading standard plugins .
2000-01-30 09:03:00 +00:00
*/
2000-11-04 18:54:07 +00:00
void
2002-02-24 17:08:07 +00:00
gst_init ( int * argc , char * * argv [ ] )
{
gst_init_with_popt_table ( argc , argv , NULL ) ;
}
/**
* gst_init_with_popt_table :
* @ argc : pointer to application ' s argc
* @ argv : pointer to application ' s argv
* @ popt_options : pointer to a popt table to append
*
* Initializes the GStreamer library , parsing the options , setting up internal path lists ,
* registering built - in elements , and loading standard plugins .
*/
void
gst_init_with_popt_table ( int * argc , char * * argv [ ] , const struct poptOption * popt_options )
2000-11-04 18:54:07 +00:00
{
2002-02-15 16:14:21 +00:00
poptContext context ;
2002-02-16 03:24:50 +00:00
gint nextopt , i , j , nstrip ;
gchar * * temp ;
2002-02-24 17:08:07 +00:00
const struct poptOption * options ;
/* this is probably hacky, no? */
const struct poptOption options_with [ ] = {
{ NULL , NUL , POPT_ARG_INCLUDE_TABLE , poptHelpOptions , 0 , " Help options: " , NULL } ,
{ NULL , NUL , POPT_ARG_INCLUDE_TABLE , ( struct poptOption * ) gst_init_get_popt_table ( ) , 0 , " GStreamer options: " , NULL } ,
{ NULL , NUL , POPT_ARG_INCLUDE_TABLE , ( struct poptOption * ) popt_options , 0 , " Application options: " , NULL } ,
POPT_TABLEEND
} ;
const struct poptOption options_without [ ] = {
{ NULL , NUL , POPT_ARG_INCLUDE_TABLE , poptHelpOptions , 0 , " Help options: " , NULL } ,
{ NULL , NUL , POPT_ARG_INCLUDE_TABLE , ( struct poptOption * ) gst_init_get_popt_table ( ) , 0 , " GStreamer options: " , NULL } ,
POPT_TABLEEND
} ;
2002-02-15 16:14:21 +00:00
2002-02-16 18:27:04 +00:00
if ( ! argc | | ! argv ) {
if ( argc | | argv )
g_warning ( " gst_init: Only one of arg or argv was NULL " ) ;
init_pre ( ) ;
init_post ( ) ;
return ;
}
2002-02-24 17:08:07 +00:00
if ( popt_options = = NULL ) {
options = options_without ;
} else {
options = options_with ;
}
2002-02-15 16:14:21 +00:00
context = poptGetContext ( " GStreamer " , * argc , ( const char * * ) * argv , options , 0 ) ;
2002-02-16 03:24:50 +00:00
while ( ( nextopt = poptGetNextOpt ( context ) ) > 0 ) ; /* do nothing, it's all callbacks */
2002-02-15 16:14:21 +00:00
if ( nextopt ! = - 1 ) {
g_print ( " Error on option %s: %s. \n Run '%s --help' to see a full list of available command line options. \n " ,
poptBadOption ( context , 0 ) ,
poptStrerror ( nextopt ) ,
( * argv ) [ 0 ] ) ;
exit ( 1 ) ;
}
2002-02-16 03:24:50 +00:00
/* let's do this once there are 1.6.3 popt debs out
* argc = poptStrippedArgv ( context , * argc , * argv ) ; */
/* until then we'll do a very basic arg permutation
this will break gst - launch - o */
temp = * argv + 1 ;
i = 1 ;
nstrip = 0 ;
g_assert ( * argc > 0 ) ;
while ( i + + < * argc & & * temp [ 0 ] = = ' - ' ) {
for ( j = 1 ; j < * argc - 1 ; j + + )
( * argv ) [ j ] = ( * argv ) [ j + 1 ] ;
( * argv ) [ * argc - 1 ] = * temp ;
nstrip + + ;
}
* argc - = nstrip ;
2002-02-15 16:14:21 +00:00
}
static void
add_path_func ( gpointer data , gpointer user_data )
{
GST_INFO ( GST_CAT_GST_INIT , " Adding plugin path: \" %s \" " , ( gchar * ) data ) ;
gst_plugin_add_path ( ( gchar * ) data ) ;
}
static void
prepare_for_load_plugin_func ( gpointer data , gpointer user_data )
{
preload_plugins = g_slist_prepend ( preload_plugins , data ) ;
}
static void
load_plugin_func ( gpointer data , gpointer user_data )
{
gboolean ret ;
ret = gst_plugin_load ( ( gchar * ) data ) ;
if ( ret )
GST_INFO ( GST_CAT_GST_INIT , " Loaded plugin: \" %s \" " , ( gchar * ) data ) ;
else
GST_INFO ( GST_CAT_GST_INIT , " Failed to load plugin: \" %s \" " , ( gchar * ) data ) ;
g_free ( data ) ;
}
static void
parse_number ( const gchar * number , guint32 * val )
{
/* handle either 0xHEX or dec */
if ( * ( number + 1 ) = = ' x ' ) {
sscanf ( number + 2 , " %08x " , val ) ;
} else {
sscanf ( number , " %d " , val ) ;
}
}
2000-01-30 09:03:00 +00:00
2002-02-15 16:14:21 +00:00
static void
split_and_iterate ( const gchar * stringlist , gchar * separator , GFunc iterator )
{
gchar * * strings ;
gint j = 0 ;
gchar * lastlist = g_strdup ( stringlist ) ;
2000-01-30 09:03:00 +00:00
2002-02-15 16:14:21 +00:00
while ( lastlist ) {
strings = g_strsplit ( lastlist , separator , MAX_PATH_SPLIT ) ;
g_free ( lastlist ) ;
lastlist = NULL ;
2000-08-28 20:20:55 +00:00
2002-02-15 16:14:21 +00:00
while ( strings [ j ] ) {
iterator ( strings [ j ] , NULL ) ;
if ( + + j = = MAX_PATH_SPLIT ) {
lastlist = g_strdup ( strings [ j ] ) ;
g_strfreev ( strings ) ;
j = 0 ;
break ;
}
}
2001-01-01 03:43:27 +00:00
}
2002-02-15 16:14:21 +00:00
}
2001-01-01 03:43:27 +00:00
2002-02-16 18:27:04 +00:00
static void
init_pre ( void )
{
if ( ! g_thread_supported ( ) )
g_thread_init ( NULL ) ;
g_type_init ( ) ;
}
2002-02-15 16:14:21 +00:00
static void
init_post ( void )
{
GLogLevelFlags llf ;
2002-02-20 21:31:16 +00:00
const gchar * plugin_path ;
2002-02-15 16:14:21 +00:00
# ifndef GST_DISABLE_TRACE
GstTrace * gst_trace ;
# endif
2001-09-13 21:16:25 +00:00
llf = G_LOG_LEVEL_CRITICAL | G_LOG_LEVEL_ERROR | G_LOG_FLAG_FATAL ;
g_log_set_handler ( g_log_domain_gstreamer , llf , debug_log_handler , NULL ) ;
2002-02-15 16:14:21 +00:00
2001-06-24 21:18:28 +00:00
GST_INFO ( GST_CAT_GST_INIT , " Initializing GStreamer Core Library " ) ;
2002-02-15 16:14:21 +00:00
2001-10-17 10:21:27 +00:00
gst_object_get_type ( ) ;
gst_pad_get_type ( ) ;
gst_real_pad_get_type ( ) ;
gst_ghost_pad_get_type ( ) ;
2002-04-11 20:35:18 +00:00
gst_element_factory_get_type ( ) ;
2001-10-17 10:21:27 +00:00
gst_element_get_type ( ) ;
2002-04-11 20:35:18 +00:00
gst_type_factory_get_type ( ) ;
gst_scheduler_factory_get_type ( ) ;
2001-10-21 18:00:31 +00:00
gst_bin_get_type ( ) ;
2001-09-10 19:46:01 +00:00
# ifndef GST_DISABLE_AUTOPLUG
2002-04-11 20:35:18 +00:00
gst_autoplug_factory_get_type ( ) ;
2001-09-10 19:46:01 +00:00
# endif
2002-02-20 21:31:16 +00:00
plugin_path = g_getenv ( " GST_PLUGIN_PATH " ) ;
split_and_iterate ( plugin_path , G_SEARCHPATH_SEPARATOR_S , add_path_func ) ;
2000-11-04 18:54:07 +00:00
_gst_cpu_initialize ( ) ;
2001-03-20 18:29:00 +00:00
_gst_props_initialize ( ) ;
_gst_caps_initialize ( ) ;
2000-11-04 18:54:07 +00:00
_gst_plugin_initialize ( ) ;
2001-10-17 10:21:27 +00:00
_gst_event_initialize ( ) ;
2000-11-04 18:54:07 +00:00
_gst_buffer_initialize ( ) ;
2001-06-17 13:55:55 +00:00
_gst_buffer_pool_initialize ( ) ;
2000-01-30 09:03:00 +00:00
2001-10-17 10:21:27 +00:00
/* if we need to preload plugins */
if ( preload_plugins ) {
g_slist_foreach ( preload_plugins , load_plugin_func , NULL ) ;
g_slist_free ( preload_plugins ) ;
preload_plugins = NULL ;
}
2000-01-30 09:03:00 +00:00
/* register some standard builtin types */
2002-04-11 20:35:18 +00:00
gst_element_factory_new ( " bin " , gst_bin_get_type ( ) , & gst_bin_details ) ;
gst_element_factory_new ( " pipeline " , gst_pipeline_get_type ( ) , & gst_pipeline_details ) ;
gst_element_factory_new ( " thread " , gst_thread_get_type ( ) , & gst_thread_details ) ;
gst_element_factory_new ( " queue " , gst_queue_get_type ( ) , & gst_queue_details ) ;
# ifndef GST_DISABLE_TYPE_FIND
gst_element_factory_new ( " typefind " , gst_type_find_get_type ( ) , & gst_type_find_details ) ;
2001-06-25 20:36:02 +00:00
# endif
2000-01-30 09:03:00 +00:00
2001-06-25 20:36:02 +00:00
# ifndef GST_DISABLE_TRACE
2000-01-30 09:03:00 +00:00
_gst_trace_on = 0 ;
if ( _gst_trace_on ) {
2000-11-04 18:54:07 +00:00
gst_trace = gst_trace_new ( " gst.trace " , 1024 ) ;
gst_trace_set_default ( gst_trace ) ;
2000-01-30 09:03:00 +00:00
}
2001-12-14 22:59:21 +00:00
# endif /* GST_DISABLE_TRACE */
2001-03-09 12:31:07 +00:00
if ( _gst_progname = = NULL ) {
_gst_progname = g_strdup ( " gstprog " ) ;
}
2002-04-07 23:32:16 +00:00
}
2001-03-09 12:31:07 +00:00
2002-04-07 23:32:16 +00:00
static void
gst_mask_help ( void )
{
guint i ;
g_print ( " \n Mask (to be OR'ed) info/debug FLAGS \n " ) ;
g_print ( " -------------------------------------------------------- \n " ) ;
for ( i = 0 ; i < GST_CAT_MAX_CATEGORY ; i + + ) {
if ( gst_get_category_name ( i ) ) {
2001-05-25 21:00:07 +00:00
# if GST_DEBUG_COLOR
2002-04-07 23:32:16 +00:00
g_print ( " 0x%08x %s%s \033 [%sm%s \033 [00m \n " , 1 < < i ,
( gst_info_get_categories ( ) & ( 1 < < i ) ? " (enabled) " : " " ) ,
( gst_debug_get_categories ( ) & ( 1 < < i ) ? " /(enabled) " : " / " ) ,
_gst_category_colors [ i ] , gst_get_category_name ( i ) ) ;
2001-05-25 21:00:07 +00:00
# else
2002-04-07 23:32:16 +00:00
g_print ( " 0x%08x %s%s %s \n " , 1 < < i ,
( gst_info_get_categories ( ) & ( 1 < < i ) ? " (enabled) " : " " ) ,
( gst_debug_get_categories ( ) & ( 1 < < i ) ? " /(enabled) " : " / " ) ,
gst_get_category_name ( i ) ) ;
2001-05-25 21:00:07 +00:00
# endif
2001-01-01 03:43:27 +00:00
}
}
2002-02-15 16:14:21 +00:00
}
2002-04-07 23:32:16 +00:00
2001-01-01 03:43:27 +00:00
2002-02-15 16:14:21 +00:00
static void
init_popt_callback ( poptContext context , enum poptCallbackReason reason ,
const struct poptOption * option , const char * arg , void * data )
{
gint val = 0 ;
switch ( reason ) {
case POPT_CALLBACK_REASON_PRE :
2002-02-16 18:27:04 +00:00
init_pre ( ) ;
2002-02-15 16:14:21 +00:00
break ;
case POPT_CALLBACK_REASON_OPTION :
switch ( option - > val ) {
case ARG_INFO_MASK :
parse_number ( arg , & val ) ;
gst_info_set_categories ( val ) ;
break ;
case ARG_DEBUG_MASK :
parse_number ( arg , & val ) ;
gst_debug_set_categories ( val ) ;
break ;
case ARG_MASK :
parse_number ( arg , & val ) ;
gst_debug_set_categories ( val ) ;
gst_info_set_categories ( val ) ;
break ;
2002-04-07 23:32:16 +00:00
case ARG_MASK_HELP :
gst_mask_help ( ) ;
exit ( 0 ) ;
2002-02-15 16:14:21 +00:00
case ARG_PLUGIN_SPEW :
_gst_plugin_spew = TRUE ;
break ;
case ARG_PLUGIN_PATH :
split_and_iterate ( arg , G_SEARCHPATH_SEPARATOR_S , add_path_func ) ;
break ;
case ARG_PLUGIN_LOAD :
split_and_iterate ( arg , " , " , prepare_for_load_plugin_func ) ;
break ;
case ARG_SCHEDULER :
2002-04-11 20:35:18 +00:00
gst_scheduler_factory_set_default_name ( arg ) ;
2002-02-15 16:14:21 +00:00
break ;
default :
g_warning ( " option %d not recognized " , option - > val ) ;
break ;
}
break ;
case POPT_CALLBACK_REASON_POST :
init_post ( ) ;
break ;
}
2001-01-01 03:43:27 +00:00
}
2001-12-14 18:11:52 +00:00
static GSList * mainloops = NULL ;
2000-09-14 20:31:03 +00:00
/**
* gst_main :
*
* Enter the main GStreamer processing loop
*/
2000-11-04 18:54:07 +00:00
void
gst_main ( void )
{
2001-12-14 18:11:52 +00:00
GMainLoop * loop ;
loop = g_main_loop_new ( NULL , FALSE ) ;
mainloops = g_slist_prepend ( mainloops , loop ) ;
g_main_loop_run ( loop ) ;
2000-09-09 16:36:10 +00:00
}
2000-09-14 20:31:03 +00:00
/**
* gst_main_quit :
*
* Exits the main GStreamer processing loop
*/
2000-11-04 18:54:07 +00:00
void
gst_main_quit ( void )
{
2001-12-14 18:11:52 +00:00
if ( ! mainloops )
g_warning ( " Quit more loops than there are " ) ;
else {
GMainLoop * loop = mainloops - > data ;
mainloops = g_slist_delete_link ( mainloops , mainloops ) ;
g_main_loop_quit ( loop ) ;
}
2000-09-09 16:36:10 +00:00
}
2001-10-17 10:21:27 +00:00
/**
* gst_version :
* @ major : pointer to a guint to store the major version number
* @ minor : pointer to a guint to store the minor version number
* @ micro : pointer to a guint to store the micro version number
*
* Gets the version number of the GStreamer library
*/
void
gst_version ( guint * major , guint * minor , guint * micro )
{
g_return_if_fail ( major ) ;
g_return_if_fail ( minor ) ;
g_return_if_fail ( micro ) ;
* major = GST_VERSION_MAJOR ;
* minor = GST_VERSION_MINOR ;
* micro = GST_VERSION_MICRO ;
}