#include <gst/gst.h>
#include "gsttriggercontrolsource.h"
-#include "gstinterpolationcontrolsourceprivate.h"
#include "gst/glib-compat-private.h"
+#include <math.h>
+
#define GST_CAT_DEFAULT controller_debug
GST_DEBUG_CATEGORY_STATIC (GST_CAT_DEFAULT);
-enum
-{
- PROP_TOLERANCE = 1,
-};
-
-#define _do_init \
- GST_DEBUG_CATEGORY_INIT (GST_CAT_DEFAULT, "trigger control source", 0, \
- "timeline value trigger control source")
-
-G_DEFINE_TYPE_WITH_CODE (GstTriggerControlSource, gst_trigger_control_source,
- GST_TYPE_TIMED_VALUE_CONTROL_SOURCE, _do_init);
-
struct _GstTriggerControlSourcePrivate
{
gint64 tolerance;
/* returns the default value of the property, except for times with specific values */
/* needed for one-shot events, such as notes and triggers */
-static inline const GValue *
-_interpolate_trigger_get (GstTimedValueControlSource * self,
- GSequenceIter * iter, GstClockTime timestamp)
+
+static inline const gdouble
+_interpolate_trigger (GstTimedValueControlSource * self, GSequenceIter * iter,
+ GstClockTime timestamp)
{
GstControlPoint *cp;
-
- /* check if there is a value at the registered timestamp */
- if (iter) {
- gint64 tolerance = ((GstTriggerControlSource *) self)->priv->tolerance;
- cp = g_sequence_get (iter);
- if (GST_CLOCK_DIFF (cp->timestamp, timestamp) <= tolerance) {
- return &cp->value;
- } else {
- if ((iter = g_sequence_iter_next (iter))) {
- cp = g_sequence_get (iter);
- if (GST_CLOCK_DIFF (timestamp, cp->timestamp) <= tolerance) {
- return &cp->value;
- }
+ gint64 tolerance = ((GstTriggerControlSource *) self)->priv->tolerance;
+ gboolean found = FALSE;
+
+ cp = g_sequence_get (iter);
+ if (GST_CLOCK_DIFF (cp->timestamp, timestamp) <= tolerance) {
+ found = TRUE;
+ } else {
+ if ((iter = g_sequence_iter_next (iter))) {
+ cp = g_sequence_get (iter);
+ if (GST_CLOCK_DIFF (timestamp, cp->timestamp) <= tolerance) {
+ found = TRUE;
}
}
}
- if (self->nvalues > 0)
- return &self->default_value;
- else
- return NULL;
+ if (found) {
+ return cp->value;
+ }
}
-#define DEFINE_TRIGGER_GET_FUNC_COMPARABLE(type) \
-static inline const GValue * \
-_interpolate_trigger_get_##type (GstTimedValueControlSource *self, GSequenceIter *iter, GstClockTime timestamp) \
-{ \
- GstControlPoint *cp; \
- \
- /* check if there is a value at the registered timestamp */ \
- if (iter) { \
- gint64 tolerance = ((GstTriggerControlSource *)self)->priv->tolerance; \
- gboolean found = FALSE; \
- cp = g_sequence_get (iter); \
- if (GST_CLOCK_DIFF (cp->timestamp,timestamp) <= tolerance ) { \
- found = TRUE; \
- } else { \
- if ((iter = g_sequence_iter_next (iter))) { \
- cp = g_sequence_get (iter); \
- if (GST_CLOCK_DIFF (timestamp, cp->timestamp) <= tolerance) { \
- found = TRUE; \
- } \
- } \
- } \
- if (found) { \
- g##type ret = g_value_get_##type (&cp->value); \
- if (g_value_get_##type (&self->minimum_value) > ret) \
- return &self->minimum_value; \
- else if (g_value_get_##type (&self->maximum_value) < ret) \
- return &self->maximum_value; \
- else \
- return &cp->value; \
- } \
- } \
- \
- if (self->nvalues > 0) \
- return &self->default_value; \
- else \
- return NULL; \
+static gboolean
+interpolate_trigger_get (GstTimedValueControlSource * self,
+ GstClockTime timestamp, gdouble * value)
+{
+ gboolean ret = FALSE;
+ GSequenceIter *iter;
+
+ g_mutex_lock (self->lock);
+
+ iter =
+ gst_timed_value_control_source_find_control_point_iter (self, timestamp);
+ if (iter) {
+ *value = _interpolate_trigger (self, iter, timestamp);
+ ret = TRUE;
+ }
+ g_mutex_unlock (self->lock);
+ return ret;
}
-#define DEFINE_TRIGGER_GET(type, ctype, get_func) \
-static gboolean \
-interpolate_trigger_get_##type (GstTimedValueControlSource *self, GstClockTime timestamp, GValue *value) \
-{ \
- const GValue *ret; \
- GSequenceIter *iter; \
- \
- g_mutex_lock (self->lock); \
- \
- iter = gst_timed_value_control_source_find_control_point_iter (self, timestamp); \
- ret = get_func (self, iter, timestamp); \
- if (!ret) { \
- g_mutex_unlock (self->lock); \
- return FALSE; \
- } \
- \
- g_value_copy (ret, value); \
- g_mutex_unlock (self->lock); \
- return TRUE; \
-} \
-\
-static gboolean \
-interpolate_trigger_get_##type##_value_array (GstTimedValueControlSource *self, \
- GstClockTime timestamp, GstClockTime interval, guint n_values, gpointer _values) \
-{ \
- guint i; \
- GstClockTime ts = timestamp; \
- GstClockTime next_ts = 0; \
- ctype *values = (ctype *) _values; \
- const GValue *ret_val = NULL; \
- ctype ret = 0; \
- GSequenceIter *iter1 = NULL, *iter2 = NULL; \
- gboolean triggered = FALSE; \
- \
- g_mutex_lock (self->lock); \
- for(i = 0; i < n_values; i++) { \
- if (!ret_val || ts >= next_ts) { \
- iter1 = gst_timed_value_control_source_find_control_point_iter (self, ts); \
- if (!iter1) { \
- if (G_LIKELY (self->values)) \
- iter2 = g_sequence_get_begin_iter (self->values); \
- else \
- iter2 = NULL; \
- } else { \
- iter2 = g_sequence_iter_next (iter1); \
- } \
- \
- if (iter2 && !g_sequence_iter_is_end (iter2)) { \
- GstControlPoint *cp; \
- \
- cp = g_sequence_get (iter2); \
- next_ts = cp->timestamp; \
- } else { \
- next_ts = GST_CLOCK_TIME_NONE; \
- } \
- \
- ret_val = get_func (self, iter1, ts); \
- if (!ret_val) { \
- g_mutex_unlock (self->lock); \
- return FALSE; \
- } \
- ret = g_value_get_##type (ret_val); \
- triggered = TRUE; \
- } else if (triggered) { \
- ret_val = get_func (self, iter1, ts); \
- if (!ret_val) { \
- g_mutex_unlock (self->lock); \
- return FALSE; \
- } \
- ret = g_value_get_##type (ret_val); \
- triggered = FALSE; \
- } \
- *values = ret; \
- ts += interval; \
- values++; \
- } \
- g_mutex_unlock (self->lock); \
- return TRUE; \
+static gboolean
+interpolate_trigger_get_value_array (GstTimedValueControlSource * self,
+ GstClockTime timestamp, GstClockTime interval, guint n_values,
+ gdouble * values)
+{
+ gboolean ret = FALSE;
+ guint i;
+ GstClockTime ts = timestamp;
+ GstClockTime next_ts = 0;
+ gdouble val;
+ GSequenceIter *iter1 = NULL, *iter2 = NULL;
+ gboolean triggered = FALSE;
+
+ g_mutex_lock (self->lock);
+ for (i = 0; i < n_values; i++) {
+ val = FP_NAN;
+ if (ts >= next_ts) {
+ iter1 = gst_timed_value_control_source_find_control_point_iter (self, ts);
+ if (!iter1) {
+ if (G_LIKELY (self->values))
+ iter2 = g_sequence_get_begin_iter (self->values);
+ else
+ iter2 = NULL;
+ } else {
+ iter2 = g_sequence_iter_next (iter1);
+ }
+
+ if (iter2 && !g_sequence_iter_is_end (iter2)) {
+ GstControlPoint *cp;
+
+ cp = g_sequence_get (iter2);
+ next_ts = cp->timestamp;
+ } else {
+ next_ts = GST_CLOCK_TIME_NONE;
+ }
+
+ if (iter1) {
+ val = _interpolate_trigger (self, iter1, ts);
+ ret = TRUE;
+ } else {
+ g_mutex_unlock (self->lock);
+ return FALSE;
+ }
+ triggered = TRUE;
+ } else if (triggered) {
+ if (iter1) {
+ val = _interpolate_trigger (self, iter1, ts);
+ ret = TRUE;
+ } else {
+ g_mutex_unlock (self->lock);
+ return FALSE;
+ }
+ triggered = FALSE;
+ }
+ *values = val;
+ ts += interval;
+ values++;
+ }
+ g_mutex_unlock (self->lock);
+ return ret;
}
-DEFINE_TRIGGER_GET_FUNC_COMPARABLE (int);
-DEFINE_TRIGGER_GET (int, gint, _interpolate_trigger_get_int);
-DEFINE_TRIGGER_GET_FUNC_COMPARABLE (uint);
-DEFINE_TRIGGER_GET (uint, guint, _interpolate_trigger_get_uint);
-DEFINE_TRIGGER_GET_FUNC_COMPARABLE (long);
-DEFINE_TRIGGER_GET (long, glong, _interpolate_trigger_get_long);
-DEFINE_TRIGGER_GET_FUNC_COMPARABLE (ulong);
-DEFINE_TRIGGER_GET (ulong, gulong, _interpolate_trigger_get_ulong);
-DEFINE_TRIGGER_GET_FUNC_COMPARABLE (int64);
-DEFINE_TRIGGER_GET (int64, gint64, _interpolate_trigger_get_int64);
-DEFINE_TRIGGER_GET_FUNC_COMPARABLE (uint64);
-DEFINE_TRIGGER_GET (uint64, guint64, _interpolate_trigger_get_uint64);
-DEFINE_TRIGGER_GET_FUNC_COMPARABLE (float);
-DEFINE_TRIGGER_GET (float, gfloat, _interpolate_trigger_get_float);
-DEFINE_TRIGGER_GET_FUNC_COMPARABLE (double);
-DEFINE_TRIGGER_GET (double, gdouble, _interpolate_trigger_get_double);
-
-DEFINE_TRIGGER_GET (boolean, gboolean, _interpolate_trigger_get);
-DEFINE_TRIGGER_GET (enum, gint, _interpolate_trigger_get);
-DEFINE_TRIGGER_GET (string, const gchar *, _interpolate_trigger_get);
+enum
+{
+ PROP_TOLERANCE = 1,
+};
+
+#define _do_init \
+ GST_DEBUG_CATEGORY_INIT (GST_CAT_DEFAULT, "trigger control source", 0, \
+ "timeline value trigger control source")
+
+G_DEFINE_TYPE_WITH_CODE (GstTriggerControlSource, gst_trigger_control_source,
+ GST_TYPE_TIMED_VALUE_CONTROL_SOURCE, _do_init);
/**
* gst_trigger_control_source_new:
return g_object_newv (GST_TYPE_TRIGGER_CONTROL_SOURCE, 0, NULL);
}
-static gboolean
-gst_trigger_control_source_bind (GstControlSource * csource, GParamSpec * pspec)
-{
- if (GST_CONTROL_SOURCE_CLASS
- (gst_trigger_control_source_parent_class)->bind (csource, pspec)) {
- gboolean ret = TRUE;
-
- GST_TIMED_VALUE_CONTROL_SOURCE_LOCK (csource);
- switch (gst_timed_value_control_source_get_base_value_type (
- (GstTimedValueControlSource *) csource)) {
- case G_TYPE_INT:
- csource->get_value =
- (GstControlSourceGetValue) interpolate_trigger_get_int;
- csource->get_value_array = (GstControlSourceGetValueArray)
- interpolate_trigger_get_int_value_array;
- break;
- case G_TYPE_UINT:
- csource->get_value =
- (GstControlSourceGetValue) interpolate_trigger_get_uint;
- csource->get_value_array = (GstControlSourceGetValueArray)
- interpolate_trigger_get_uint_value_array;
- break;
- case G_TYPE_LONG:
- csource->get_value =
- (GstControlSourceGetValue) interpolate_trigger_get_long;
- csource->get_value_array = (GstControlSourceGetValueArray)
- interpolate_trigger_get_long_value_array;
- break;
- case G_TYPE_ULONG:
- csource->get_value =
- (GstControlSourceGetValue) interpolate_trigger_get_ulong;
- csource->get_value_array = (GstControlSourceGetValueArray)
- interpolate_trigger_get_ulong_value_array;
- break;
- case G_TYPE_INT64:
- csource->get_value =
- (GstControlSourceGetValue) interpolate_trigger_get_int64;
- csource->get_value_array = (GstControlSourceGetValueArray)
- interpolate_trigger_get_int64_value_array;
- break;
- case G_TYPE_UINT64:
- csource->get_value =
- (GstControlSourceGetValue) interpolate_trigger_get_uint64;
- csource->get_value_array = (GstControlSourceGetValueArray)
- interpolate_trigger_get_uint64_value_array;
- break;
- case G_TYPE_FLOAT:
- csource->get_value =
- (GstControlSourceGetValue) interpolate_trigger_get_float;
- csource->get_value_array = (GstControlSourceGetValueArray)
- interpolate_trigger_get_float_value_array;
- break;
- case G_TYPE_DOUBLE:
- csource->get_value =
- (GstControlSourceGetValue) interpolate_trigger_get_double;
- csource->get_value_array = (GstControlSourceGetValueArray)
- interpolate_trigger_get_double_value_array;
- break;
- case G_TYPE_BOOLEAN:
- csource->get_value =
- (GstControlSourceGetValue) interpolate_trigger_get_boolean;
- csource->get_value_array = (GstControlSourceGetValueArray)
- interpolate_trigger_get_boolean_value_array;
- break;
- case G_TYPE_ENUM:
- csource->get_value =
- (GstControlSourceGetValue) interpolate_trigger_get_enum;
- csource->get_value_array = (GstControlSourceGetValueArray)
- interpolate_trigger_get_enum_value_array;
- break;
- case G_TYPE_STRING:
- csource->get_value =
- (GstControlSourceGetValue) interpolate_trigger_get_string;
- csource->get_value_array = (GstControlSourceGetValueArray)
- interpolate_trigger_get_string_value_array;
- break;
- default:
- ret = FALSE;
- break;
- }
-
- /* Incomplete implementation */
- if (!csource->get_value || !csource->get_value_array) {
- ret = FALSE;
- }
- gst_timed_value_control_invalidate_cache ((GstTimedValueControlSource *)
- csource);
-
- GST_TIMED_VALUE_CONTROL_SOURCE_UNLOCK (csource);
-
- return ret;
- }
- return FALSE;
-}
-
static void
gst_trigger_control_source_init (GstTriggerControlSource * self)
{
+ GstControlSource *csource = (GstControlSource *) self;
+
self->priv =
G_TYPE_INSTANCE_GET_PRIVATE (self, GST_TYPE_TRIGGER_CONTROL_SOURCE,
GstTriggerControlSourcePrivate);
+
+ csource->get_value = (GstControlSourceGetValue) interpolate_trigger_get;
+ csource->get_value_array = (GstControlSourceGetValueArray)
+ interpolate_trigger_get_value_array;
}
static void
gst_trigger_control_source_class_init (GstTriggerControlSourceClass * klass)
{
GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
- GstControlSourceClass *csource_class = GST_CONTROL_SOURCE_CLASS (klass);
g_type_class_add_private (klass, sizeof (GstTriggerControlSourcePrivate));
gobject_class->set_property = gst_trigger_control_source_set_property;
gobject_class->get_property = gst_trigger_control_source_get_property;
- csource_class->bind = gst_trigger_control_source_bind;
-
g_object_class_install_property (gobject_class, PROP_TOLERANCE,
g_param_spec_int64 ("tolerance", "Tolerance",
"Amount of ns a control time can be off to still trigger",
projects / platform / upstream / gstreamer.git / blobdiff