mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-06-06 23:48:53 +00:00
Code Issues 1 Projects Releases Wiki Activity

a bunch of changes including the beginnings of a direct (non-callback) and an array update method

Browse source 
Original commit message from CVS:
a bunch of changes including the beginnings of a direct (non-callback) and an array update method
This commit is contained in:
Steve Baker 2001-09-12 11:24:51 +00:00
parent 205f90dae3
commit e4cbf57c8d
2 changed files with 311 additions and 74 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

300
gst/gstdparammanager.c
View file

@ -28,11 +28,13 @@
static void gst_dpman_base_class_init (GstDParamManagerClass *klass); static void gst_dpman_base_class_init (GstDParamManagerClass *klass);
static void gst_dpman_class_init (GstDParamManagerClass *klass); static void gst_dpman_class_init (GstDParamManagerClass *klass);
static void gst_dpman_init (GstDParamManager *dpman); static void gst_dpman_init (GstDParamManager *dpman);
static GstDParamWrapper* gst_dpman_new_wrapper(GstDParamManager *dpman, gchar *dparam_name, GType type, GstDPMUpdateMethod update_method);
static GstDParamWrapper* gst_dpman_get_wrapper(GstDParamManager *dpman, gchar *dparam_name);
static void gst_dpman_state_change (GstElement *element, gint state, GstDParamManager *dpman); static void gst_dpman_state_change (GstElement *element, gint state, GstDParamManager *dpman);
static void gst_dpman_caps_changed (GstPad *pad, GstCaps *caps, GstDParamManager *dpman); static void gst_dpman_caps_changed (GstPad *pad, GstCaps *caps, GstDParamManager *dpman);
static guint gst_dpman_first_countdown_synchronous(GstDParamManager *dpman, guint frames, gint64 timestamp); static guint gst_dpman_preprocess_synchronous(GstDParamManager *dpman, guint frames, gint64 timestamp);
static guint gst_dpman_first_countdown_noop(GstDParamManager *dpman, guint frames, gint64 timestamp); static guint gst_dpman_preprocess_noop(GstDParamManager *dpman, guint frames, gint64 timestamp);
static guint gst_dpman_countdown_noop(GstDParamManager *dpman, guint frame_count); static guint gst_dpman_process_noop(GstDParamManager *dpman, guint frame_count);
GType GType
gst_dpman_get_type (void) gst_dpman_get_type (void)
@ -77,11 +79,11 @@ gst_dpman_class_init (GstDParamManagerClass *klass)
klass->modes = g_hash_table_new(g_str_hash,g_str_equal); klass->modes = g_hash_table_new(g_str_hash,g_str_equal);
gst_dpman_register_mode (klass, "synchronous", gst_dpman_register_mode (klass, "synchronous",
gst_dpman_first_countdown_synchronous, gst_dpman_countdown_noop, NULL, NULL); gst_dpman_preprocess_synchronous, gst_dpman_process_noop, NULL, NULL);
gst_dpman_register_mode (klass, "asynchronous", gst_dpman_register_mode (klass, "asynchronous",
gst_dpman_first_countdown_noop, gst_dpman_countdown_noop, NULL, NULL); gst_dpman_preprocess_noop, gst_dpman_process_noop, NULL, NULL);
gst_dpman_register_mode (klass, "disabled", gst_dpman_register_mode (klass, "disabled",
gst_dpman_first_countdown_noop, gst_dpman_countdown_noop, NULL, NULL); gst_dpman_preprocess_noop, gst_dpman_process_noop, NULL, NULL);
} }
@ -122,7 +124,7 @@ gst_dpman_new (gchar *name, GstElement *parent)
} }
/** /**
* gst_dpman_add_required_dparam: * gst_dpman_add_required_dparam_callback:
* @dpman: GstDParamManager instance * @dpman: GstDParamManager instance
* @dparam_name: a parameter name unique to this GstDParamManager * @dparam_name: a parameter name unique to this GstDParamManager
* @type: the GValue type that this parameter will store * @type: the GValue type that this parameter will store
@ -132,32 +134,90 @@ gst_dpman_new (gchar *name, GstElement *parent)
* Returns: true if it was successfully added * Returns: true if it was successfully added
*/ */
gboolean gboolean
gst_dpman_add_required_dparam (GstDParamManager *dpman, gst_dpman_add_required_dparam_callback (GstDParamManager *dpman,
gchar *dparam_name, gchar *dparam_name,
GType type, GType type,
GstDpmUpdateFunction update_func, GstDPMUpdateFunction update_func,
gpointer update_data) gpointer update_data)
{ {
GstDParamWrapper* dpwrap; GstDParamWrapper* dpwrap;
g_return_val_if_fail (dpman != NULL, FALSE); g_return_val_if_fail (dpman != NULL, FALSE);
g_return_val_if_fail (GST_IS_DPMAN (dpman), FALSE); g_return_val_if_fail (GST_IS_DPMAN (dpman), FALSE);
g_return_val_if_fail (dparam_name != NULL, FALSE);
g_return_val_if_fail (update_func != NULL, FALSE); g_return_val_if_fail (update_func != NULL, FALSE);
g_return_val_if_fail(g_hash_table_lookup(GST_DPMAN_DPARAMS(dpman), dparam_name) == NULL, FALSE); dpwrap = gst_dpman_new_wrapper(dpman, dparam_name, type, GST_DPMAN_CALLBACK);
GST_DEBUG(GST_CAT_PARAMS,"adding required dparam: %s\n", dparam_name); g_return_val_if_fail (dpwrap != NULL, FALSE);
GST_DEBUG(GST_CAT_PARAMS,"adding required callback dparam '%s' of type %s\n", dparam_name, g_type_name(type));
dpwrap = g_new0(GstDParamWrapper,1);
dpwrap->dparam_name = dparam_name;
dpwrap->update_func = update_func; dpwrap->update_func = update_func;
dpwrap->update_data = update_data; dpwrap->update_data = update_data;
dpwrap->value = g_new0(GValue,1);
g_value_init(dpwrap->value, type);
g_hash_table_insert(GST_DPMAN_DPARAMS(dpman), dparam_name, dpwrap); return TRUE;
GST_DPMAN_DPARAMS_LIST(dpman) = g_slist_append(GST_DPMAN_DPARAMS_LIST(dpman), dpwrap); }
/**
* gst_dpman_add_required_dparam_direct:
* @dpman: GstDParamManager instance
* @dparam_name: a parameter name unique to this GstDParamManager
* @type: the GValue type that this parameter will store
* @update_data: pointer to the member to be updated
*
* Returns: true if it was successfully added
*/
gboolean
gst_dpman_add_required_dparam_direct (GstDParamManager *dpman,
gchar *dparam_name,
GType type,
gpointer update_data)
{
GstDParamWrapper* dpwrap;
g_return_val_if_fail (dpman != NULL, FALSE);
g_return_val_if_fail (GST_IS_DPMAN (dpman), FALSE);
g_return_val_if_fail (update_data != NULL, FALSE);
dpwrap = gst_dpman_new_wrapper(dpman, dparam_name, type, GST_DPMAN_DIRECT);
g_return_val_if_fail (dpwrap != NULL, FALSE);
GST_DEBUG(GST_CAT_PARAMS,"adding required direct dparam '%s' of type %s\n", dparam_name, g_type_name(type));
dpwrap->update_data = update_data;
return TRUE;
}
/**
* gst_dpman_add_required_dparam_array:
* @dpman: GstDParamManager instance
* @dparam_name: a parameter name unique to this GstDParamManager
* @type: the GValue type that this parameter will store
* @update_data: pointer to where the array will be stored
*
* Returns: true if it was successfully added
*/
gboolean
gst_dpman_add_required_dparam_array (GstDParamManager *dpman,
gchar *dparam_name,
GType type,
gpointer update_data)
{
GstDParamWrapper* dpwrap;
g_return_val_if_fail (dpman != NULL, FALSE);
g_return_val_if_fail (GST_IS_DPMAN (dpman), FALSE);
g_return_val_if_fail (update_data != NULL, FALSE);
dpwrap = gst_dpman_new_wrapper(dpman, dparam_name, type, GST_DPMAN_ARRAY);
g_return_val_if_fail (dpwrap != NULL, FALSE);
GST_DEBUG(GST_CAT_PARAMS,"adding required array dparam '%s' of type %s\n", dparam_name, g_type_name(type));
dpwrap->update_data = update_data;
return TRUE; return TRUE;
} }
@ -177,7 +237,7 @@ gst_dpman_remove_required_dparam (GstDParamManager *dpman, gchar *dparam_name)
g_return_if_fail (GST_IS_DPMAN (dpman)); g_return_if_fail (GST_IS_DPMAN (dpman));
g_return_if_fail (dparam_name != NULL); g_return_if_fail (dparam_name != NULL);
dpwrap = g_hash_table_lookup(GST_DPMAN_DPARAMS(dpman), dparam_name); dpwrap = gst_dpman_get_wrapper(dpman, dparam_name);
g_return_if_fail(dpwrap != NULL); g_return_if_fail(dpwrap != NULL);
g_return_if_fail(dpwrap->dparam == NULL); g_return_if_fail(dpwrap->dparam == NULL);
@ -211,7 +271,7 @@ gst_dpman_attach_dparam (GstDParamManager *dpman, gchar *dparam_name, GstDParam
g_return_val_if_fail (GST_IS_DPARAM (dparam), FALSE); g_return_val_if_fail (GST_IS_DPARAM (dparam), FALSE);
g_return_val_if_fail (dparam != NULL, FALSE); g_return_val_if_fail (dparam != NULL, FALSE);
dpwrap = g_hash_table_lookup(GST_DPMAN_DPARAMS(dpman), dparam_name); dpwrap = gst_dpman_get_wrapper(dpman, dparam_name);
g_return_val_if_fail(dpwrap != NULL, FALSE); g_return_val_if_fail(dpwrap != NULL, FALSE);
g_return_val_if_fail(dpwrap->value != NULL, FALSE); g_return_val_if_fail(dpwrap->value != NULL, FALSE);
@ -239,7 +299,7 @@ gst_dpman_dettach_dparam (GstDParamManager *dpman, gchar *dparam_name)
g_return_if_fail (GST_IS_DPMAN (dpman)); g_return_if_fail (GST_IS_DPMAN (dpman));
g_return_if_fail (dparam_name != NULL); g_return_if_fail (dparam_name != NULL);
dpwrap = g_hash_table_lookup(GST_DPMAN_DPARAMS(dpman), dparam_name); dpwrap = gst_dpman_get_wrapper(dpman, dparam_name);
g_return_if_fail(dpwrap); g_return_if_fail(dpwrap);
@ -273,12 +333,34 @@ gst_dpman_get_dparam (GstDParamManager *dpman, gchar *name)
return dpwrap->dparam; return dpwrap->dparam;
} }
/**
* gst_dpman_get_dparam_type:
* @dpman: GstDParamManager instance
* @name: the name of dparam
*
* Returns: the type that this dparam requires/uses
*/
GType
gst_dpman_get_dparam_type (GstDParamManager *dpman, gchar *name)
{
GstDParamWrapper* dpwrap;
g_return_val_if_fail (dpman != NULL, 0);
g_return_val_if_fail (GST_IS_DPMAN (dpman), 0);
g_return_val_if_fail (name != NULL, 0);
dpwrap = g_hash_table_lookup(GST_DPMAN_DPARAMS(dpman), name);
g_return_val_if_fail (dpwrap != NULL, 0);
return G_VALUE_TYPE(dpwrap->value);
}
/** /**
* gst_dpman_register_mode * gst_dpman_register_mode
* @klass: GstDParamManagerClass class instance * @klass: GstDParamManagerClass class instance
* @modename: the unique name of the new mode * @modename: the unique name of the new mode
* @firstcountdownfunc: the function which will be called before each buffer is processed * @preprocessfunc: the function which will be called before each buffer is processed
* @countdownfunc: the function which may be called throughout the processing of a buffer * @processfunc: the function which may be called throughout the processing of a buffer
* @setupfunc: the function which initialises the mode when activated * @setupfunc: the function which initialises the mode when activated
* @teardownfunc: the function which frees any resources the mode uses * @teardownfunc: the function which frees any resources the mode uses
* *
@ -286,21 +368,21 @@ gst_dpman_get_dparam (GstDParamManager *dpman, gchar *name)
void void
gst_dpman_register_mode (GstDParamManagerClass *klass, gst_dpman_register_mode (GstDParamManagerClass *klass,
gchar *modename, gchar *modename,
GstDpmModeFirstCountdownFunction firstcountdownfunc, GstDPMModePreProcessFunction preprocessfunc,
GstDpmModeCountdownFunction countdownfunc, GstDPMModeProcessFunction processfunc,
GstDpmModeSetupFunction setupfunc, GstDPMModeSetupFunction setupfunc,
GstDpmModeTeardownFunction teardownfunc) GstDPMModeTeardownFunction teardownfunc)
{ {
GstDpmMode *mode; GstDPMMode *mode;
g_return_if_fail (klass != NULL); g_return_if_fail (klass != NULL);
g_return_if_fail (modename != NULL); g_return_if_fail (modename != NULL);
g_return_if_fail (GST_IS_DPMAN_CLASS (klass)); g_return_if_fail (GST_IS_DPMAN_CLASS (klass));
mode = g_new0(GstDpmMode,1); mode = g_new0(GstDPMMode,1);
mode->firstcountdownfunc = firstcountdownfunc; mode->preprocessfunc = preprocessfunc;
mode->countdownfunc = countdownfunc; mode->processfunc = processfunc;
mode->setupfunc = setupfunc; mode->setupfunc = setupfunc;
mode->teardownfunc = teardownfunc; mode->teardownfunc = teardownfunc;
@ -318,7 +400,7 @@ gst_dpman_register_mode (GstDParamManagerClass *klass,
gboolean gboolean
gst_dpman_set_mode(GstDParamManager *dpman, gchar *modename) gst_dpman_set_mode(GstDParamManager *dpman, gchar *modename)
{ {
GstDpmMode *mode=NULL; GstDPMMode *mode=NULL;
GstDParamManagerClass *oclass; GstDParamManagerClass *oclass;
g_return_val_if_fail (dpman != NULL, FALSE); g_return_val_if_fail (dpman != NULL, FALSE);
@ -380,6 +462,40 @@ gst_dpman_set_rate_change_pad(GstDParamManager *dpman, GstPad *pad)
G_CALLBACK (gst_dpman_caps_changed), dpman); G_CALLBACK (gst_dpman_caps_changed), dpman);
} }
static GstDParamWrapper*
gst_dpman_get_wrapper(GstDParamManager *dpman, gchar *dparam_name)
{
g_return_val_if_fail (dpman != NULL, NULL);
g_return_val_if_fail (GST_IS_DPMAN (dpman), NULL);
g_return_val_if_fail (dparam_name != NULL, NULL);
return g_hash_table_lookup(GST_DPMAN_DPARAMS(dpman), dparam_name);
}
static GstDParamWrapper*
gst_dpman_new_wrapper(GstDParamManager *dpman, gchar *dparam_name, GType type, GstDPMUpdateMethod update_method)
{
GstDParamWrapper* dpwrap;
g_return_val_if_fail (dpman != NULL, NULL);
g_return_val_if_fail (GST_IS_DPMAN (dpman), NULL);
g_return_val_if_fail (dparam_name != NULL, NULL);
g_return_val_if_fail(gst_dpman_get_wrapper(dpman, dparam_name) == NULL, NULL);
dpwrap = g_new0(GstDParamWrapper,1);
dpwrap->dparam_name = dparam_name;
dpwrap->update_method = update_method;
dpwrap->value = g_new0(GValue,1);
g_value_init(dpwrap->value, type);
g_hash_table_insert(GST_DPMAN_DPARAMS(dpman), dparam_name, dpwrap);
GST_DPMAN_DPARAMS_LIST(dpman) = g_slist_append(GST_DPMAN_DPARAMS_LIST(dpman), dpwrap);
return dpwrap;
}
static void static void
gst_dpman_state_change (GstElement *element, gint state, GstDParamManager *dpman) gst_dpman_state_change (GstElement *element, gint state, GstDParamManager *dpman)
{ {
@ -419,11 +535,12 @@ gst_dpman_caps_changed (GstPad *pad, GstCaps *caps, GstDParamManager *dpman)
} }
static guint static guint
gst_dpman_first_countdown_synchronous(GstDParamManager *dpman, guint frames, gint64 timestamp) gst_dpman_preprocess_synchronous(GstDParamManager *dpman, guint frames, gint64 timestamp)
{ {
GSList *dwraps; GSList *dwraps;
GstDParam *dparam; GstDParam *dparam;
GstDParamWrapper *dpwrap; GstDParamWrapper *dpwrap;
int x;
g_return_val_if_fail (dpman != NULL, frames); g_return_val_if_fail (dpman != NULL, frames);
g_return_val_if_fail (GST_IS_DPMAN (dpman), frames); g_return_val_if_fail (GST_IS_DPMAN (dpman), frames);
@ -436,23 +553,124 @@ gst_dpman_first_countdown_synchronous(GstDParamManager *dpman, guint frames, gin
if (dparam && (GST_DPARAM_READY_FOR_UPDATE(dparam) || if (dparam && (GST_DPARAM_READY_FOR_UPDATE(dparam) ||
(GST_DPARAM_NEXT_UPDATE_TIMESTAMP(dparam) < timestamp))){ (GST_DPARAM_NEXT_UPDATE_TIMESTAMP(dparam) < timestamp))){
// this will make dpwrap->value contain the latest value.
// now we just need to get it to the element
GST_DPARAM_DO_UPDATE(dparam, timestamp); GST_DPARAM_DO_UPDATE(dparam, timestamp);
GST_DPMAN_DO_UPDATE(dpwrap);
switch (dpwrap->update_method) {
// direct method - set the value directly in the struct of the element
case GST_DPMAN_DIRECT:
GST_DEBUG(GST_CAT_PARAMS, "doing direct update\n");
switch (G_VALUE_TYPE(dpwrap->value)){
case G_TYPE_CHAR:
*(gchar*)dpwrap->update_data = g_value_get_char(dpwrap->value);
case G_TYPE_UCHAR:
*(guchar*)dpwrap->update_data = g_value_get_uchar(dpwrap->value);
case G_TYPE_BOOLEAN:
*(gboolean*)dpwrap->update_data = g_value_get_boolean(dpwrap->value);
case G_TYPE_INT:
*(gint*)dpwrap->update_data = g_value_get_int(dpwrap->value);
case G_TYPE_UINT:
*(guint*)dpwrap->update_data = g_value_get_uint(dpwrap->value);
case G_TYPE_LONG:
*(glong*)dpwrap->update_data = g_value_get_long(dpwrap->value);
case G_TYPE_ULONG:
*(gulong*)dpwrap->update_data = g_value_get_ulong(dpwrap->value);
case G_TYPE_FLOAT:
*(gfloat*)dpwrap->update_data = g_value_get_float(dpwrap->value);
case G_TYPE_DOUBLE:
*(gdouble*)dpwrap->update_data = g_value_get_double(dpwrap->value);
case G_TYPE_POINTER:
*(gpointer*)dpwrap->update_data = g_value_get_pointer(dpwrap->value);
default:
break;
}
break;
// callback method - call the element's callback so it can do what it likes
case GST_DPMAN_CALLBACK:
GST_DEBUG(GST_CAT_PARAMS, "doing callback update\n");
GST_DPMAN_DO_UPDATE(dpwrap);
break;
// array method - generate an array of the right size
// with each value being the same (in synchronous update mode)
case GST_DPMAN_ARRAY:
GST_DEBUG(GST_CAT_PARAMS, "doing array update\n");
switch (G_VALUE_TYPE(dpwrap->value)){
case G_TYPE_CHAR:
(gchar*)dpwrap->update_data = g_new(gchar, frames);
*(gchar*)dpwrap->update_data = g_value_get_char(dpwrap->value);
for (x = 1 ; x < frames ; x++)
((gchar*)dpwrap->update_data)[x] = *(gchar*)dpwrap->update_data;
case G_TYPE_UCHAR:
(guchar*)dpwrap->update_data = g_new(guchar, frames);
*(guchar*)dpwrap->update_data = g_value_get_uchar(dpwrap->value);
for (x = 1 ; x < frames ; x++)
((guchar*)dpwrap->update_data)[x] = *(guchar*)dpwrap->update_data;
case G_TYPE_BOOLEAN:
(gboolean*)dpwrap->update_data = g_new(gboolean, frames);
*(gboolean*)dpwrap->update_data = g_value_get_boolean(dpwrap->value);
for (x = 1 ; x < frames ; x++)
((gboolean*)dpwrap->update_data)[x] = *(gboolean*)dpwrap->update_data;
case G_TYPE_INT:
(gint*)dpwrap->update_data = g_new(gint, frames);
*(gint*)dpwrap->update_data = g_value_get_int(dpwrap->value);
for (x = 1 ; x < frames ; x++)
((gint*)dpwrap->update_data)[x] = *(gint*)dpwrap->update_data;
case G_TYPE_UINT:
(guint*)dpwrap->update_data = g_new(guint, frames);
*(guint*)dpwrap->update_data = g_value_get_uint(dpwrap->value);
for (x = 1 ; x < frames ; x++)
((guint*)dpwrap->update_data)[x] = *(guint*)dpwrap->update_data;
case G_TYPE_LONG:
(glong*)dpwrap->update_data = g_new(glong, frames);
*(glong*)dpwrap->update_data = g_value_get_long(dpwrap->value);
for (x = 1 ; x < frames ; x++)
((glong*)dpwrap->update_data)[x] = *(glong*)dpwrap->update_data;
case G_TYPE_ULONG:
(gulong*)dpwrap->update_data = g_new(gulong, frames);
*(gulong*)dpwrap->update_data = g_value_get_ulong(dpwrap->value);
for (x = 1 ; x < frames ; x++)
((gulong*)dpwrap->update_data)[x] = *(gulong*)dpwrap->update_data;
case G_TYPE_FLOAT:
(gfloat*)dpwrap->update_data = g_new(gfloat, frames);
*(gfloat*)dpwrap->update_data = g_value_get_float(dpwrap->value);
for (x = 1 ; x < frames ; x++)
((gfloat*)dpwrap->update_data)[x] = *(gfloat*)dpwrap->update_data;
case G_TYPE_DOUBLE:
(gdouble*)dpwrap->update_data = g_new(gdouble, frames);
*(gdouble*)dpwrap->update_data = g_value_get_double(dpwrap->value);
for (x = 1 ; x < frames ; x++)
((gdouble*)dpwrap->update_data)[x] = *(gdouble*)dpwrap->update_data;
case G_TYPE_POINTER:
(gpointer*)dpwrap->update_data = g_new(gpointer, frames);
*(gpointer*)dpwrap->update_data = g_value_get_pointer(dpwrap->value);
for (x = 1 ; x < frames ; x++)
((gpointer*)dpwrap->update_data)[x] = *(gpointer*)dpwrap->update_data;
default:
break;
}
break;
default:
break;
}
} }
dwraps = g_slist_next(dwraps); dwraps = g_slist_next(dwraps);
} }
return frames; return frames;
} }
static guint static guint
gst_dpman_first_countdown_noop(GstDParamManager *dpman, guint frames, gint64 timestamp) gst_dpman_preprocess_noop(GstDParamManager *dpman, guint frames, gint64 timestamp)
{ {
return frames; return frames;
} }
static guint static guint
gst_dpman_countdown_noop(GstDParamManager *dpman, guint frame_count) gst_dpman_process_noop(GstDParamManager *dpman, guint frame_count)
{ {
return 0; return 0;
} }

75
gst/gstdparammanager.h
View file

@ -45,17 +45,23 @@ extern "C" {
#define GST_DPMAN_MODE_DATA(dpman) ((dpman)->mode_data) #define GST_DPMAN_MODE_DATA(dpman) ((dpman)->mode_data)
#define GST_DPMAN_RATE(dpman) ((dpman)->rate) #define GST_DPMAN_RATE(dpman) ((dpman)->rate)
typedef enum {
GST_DPMAN_CALLBACK,
GST_DPMAN_DIRECT,
GST_DPMAN_ARRAY,
} GstDPMUpdateMethod;
typedef struct _GstDParamManager GstDParamManager; typedef struct _GstDParamManager GstDParamManager;
typedef struct _GstDParamManagerClass GstDParamManagerClass; typedef struct _GstDParamManagerClass GstDParamManagerClass;
typedef struct _GstDpmMode GstDpmMode; typedef struct _GstDPMMode GstDPMMode;
typedef struct _GstDParamWrapper GstDParamWrapper; typedef struct _GstDParamWrapper GstDParamWrapper;
typedef guint (*GstDpmModeFirstCountdownFunction) (GstDParamManager *dpman, guint frames, gint64 timestamp); typedef guint (*GstDPMModePreProcessFunction) (GstDParamManager *dpman, guint frames, gint64 timestamp);
typedef guint (*GstDpmModeCountdownFunction) (GstDParamManager *dpman, guint frame_count); typedef guint (*GstDPMModeProcessFunction) (GstDParamManager *dpman, guint frame_count);
typedef void (*GstDpmModeSetupFunction) (GstDParamManager *dpman); typedef void (*GstDPMModeSetupFunction) (GstDParamManager *dpman);
typedef void (*GstDpmModeTeardownFunction) (GstDParamManager *dpman); typedef void (*GstDPMModeTeardownFunction) (GstDParamManager *dpman);
typedef void (*GstDpmUpdateFunction) (GValue *value, gpointer data); typedef void (*GstDPMUpdateFunction) (GValue *value, gpointer data);
struct _GstDParamManager { struct _GstDParamManager {
GstObject object; GstObject object;
@ -64,7 +70,7 @@ struct _GstDParamManager {
GSList *dparams_list; GSList *dparams_list;
gchar *mode_name; gchar *mode_name;
GstDpmMode* mode; GstDPMMode* mode;
gpointer mode_data; gpointer mode_data;
gint64 timestamp; gint64 timestamp;
@ -78,32 +84,36 @@ struct _GstDParamManagerClass {
/* signal callbacks */ /* signal callbacks */
}; };
struct _GstDpmMode { struct _GstDPMMode {
GstDpmModeFirstCountdownFunction firstcountdownfunc; GstDPMModePreProcessFunction preprocessfunc;
GstDpmModeCountdownFunction countdownfunc; GstDPMModeProcessFunction processfunc;
GstDpmModeSetupFunction setupfunc; GstDPMModeSetupFunction setupfunc;
GstDpmModeTeardownFunction teardownfunc; GstDPMModeTeardownFunction teardownfunc;
}; };
struct _GstDParamWrapper { struct _GstDParamWrapper {
gchar *dparam_name; gchar *dparam_name;
GValue *value; GValue *value;
GstDParam *dparam; GstDParam *dparam;
GstDpmUpdateFunction update_func; GstDPMUpdateMethod update_method;
gpointer update_data; gpointer update_data;
GstDPMUpdateFunction update_func;
}; };
#define GST_DPMAN_FIRST_COUNTDOWNFUNC(dpman) (((dpman)->mode)->firstcountdownfunc) #define GST_DPMAN_PREPROCESSFUNC(dpman) (((dpman)->mode)->preprocessfunc)
#define GST_DPMAN_COUNTDOWNFUNC(dpman) (((dpman)->mode)->countdownfunc) #define GST_DPMAN_PROCESSFUNC(dpman) (((dpman)->mode)->processfunc)
#define GST_DPMAN_SETUPFUNC(dpman) (((dpman)->mode)->setupfunc) #define GST_DPMAN_SETUPFUNC(dpman) (((dpman)->mode)->setupfunc)
#define GST_DPMAN_TEARDOWNFUNC(dpman) (((dpman)->mode)->teardownfunc) #define GST_DPMAN_TEARDOWNFUNC(dpman) (((dpman)->mode)->teardownfunc)
#define GST_DPMAN_FIRST_COUNTDOWN(dpman, buffer_size, timestamp) \ #define GST_DPMAN_PREPROCESS(dpman, buffer_size, timestamp) \
(GST_DPMAN_FIRST_COUNTDOWNFUNC(dpman)(dpman, buffer_size, timestamp)) (GST_DPMAN_PREPROCESSFUNC(dpman)(dpman, buffer_size, timestamp))
#define GST_DPMAN_COUNTDOWN(dpman, frame_countdown, frame_count) \ #define GST_DPMAN_PROCESS(dpman, frame_count) \
(GST_DPMAN_PROCESSFUNC(dpman)(dpman, frame_count))
#define GST_DPMAN_PROCESS_COUNTDOWN(dpman, frame_countdown, frame_count) \
(frame_countdown-- || \ (frame_countdown-- || \
(frame_countdown = GST_DPMAN_COUNTDOWNFUNC(dpman)(dpman, frame_count))) (frame_countdown = GST_DPMAN_PROCESS(dpman, frame_count)))
#define GST_DPMAN_DO_UPDATE(dpwrap) ((dpwrap->update_func)(dpwrap->value, dpwrap->update_data)) #define GST_DPMAN_DO_UPDATE(dpwrap) ((dpwrap->update_func)(dpwrap->value, dpwrap->update_data))
@ -111,25 +121,34 @@ GType gst_dpman_get_type (void);
GstDParamManager* gst_dpman_new (gchar *name, GstElement *parent); GstDParamManager* gst_dpman_new (gchar *name, GstElement *parent);
void gst_dpman_set_parent (GstDParamManager *dpman, GstElement *parent); void gst_dpman_set_parent (GstDParamManager *dpman, GstElement *parent);
gboolean gst_dpman_add_required_dparam (GstDParamManager *dpman, gboolean gst_dpman_add_required_dparam_callback (GstDParamManager *dpman,
gchar *dparam_name, gchar *dparam_name,
GType type, GType type,
GstDpmUpdateFunction update_func, GstDPMUpdateFunction update_func,
gpointer update_data); gpointer update_data);
gboolean gst_dpman_add_required_dparam_direct (GstDParamManager *dpman,
gchar *dparam_name,
GType type,
gpointer update_data);
gboolean gst_dpman_add_required_dparam_array (GstDParamManager *dpman,
gchar *dparam_name,
GType type,
gpointer update_data);
void gst_dpman_remove_required_dparam (GstDParamManager *dpman, gchar *dparam_name); void gst_dpman_remove_required_dparam (GstDParamManager *dpman, gchar *dparam_name);
gboolean gst_dpman_attach_dparam (GstDParamManager *dpman, gchar *dparam_name, GstDParam *dparam); gboolean gst_dpman_attach_dparam (GstDParamManager *dpman, gchar *dparam_name, GstDParam *dparam);
void gst_dpman_dettach_dparam (GstDParamManager *dpman, gchar *dparam_name); void gst_dpman_dettach_dparam (GstDParamManager *dpman, gchar *dparam_name);
GstDParam* gst_dpman_get_dparam(GstDParamManager *dpman, gchar *name); GstDParam* gst_dpman_get_dparam(GstDParamManager *dpman, gchar *name);
GType gst_dpman_get_dparam_type (GstDParamManager *dpman, gchar *name);
void gst_dpman_set_rate_change_pad(GstDParamManager *dpman, GstPad *pad); void gst_dpman_set_rate_change_pad(GstDParamManager *dpman, GstPad *pad);
gboolean gst_dpman_set_mode(GstDParamManager *dpman, gchar *modename); gboolean gst_dpman_set_mode(GstDParamManager *dpman, gchar *modename);
void gst_dpman_register_mode (GstDParamManagerClass *klass, void gst_dpman_register_mode (GstDParamManagerClass *klass,
gchar *modename, gchar *modename,
GstDpmModeFirstCountdownFunction firstcountdownfunc, GstDPMModePreProcessFunction preprocessfunc,
GstDpmModeCountdownFunction countdownfunc, GstDPMModeProcessFunction processfunc,
GstDpmModeSetupFunction setupfunc, GstDPMModeSetupFunction setupfunc,
GstDpmModeTeardownFunction teardownfunc); GstDPMModeTeardownFunction teardownfunc);
#ifdef __cplusplus #ifdef __cplusplus
} }