*/
/**
* SECTION:element-identity
+ * @title: identity
*
* Dummy element that passes incoming data through unmodified. It has some
* useful diagnostic functions, such as offset and timestamp checking.
#define DEFAULT_CHECK_IMPERFECT_TIMESTAMP FALSE
#define DEFAULT_CHECK_IMPERFECT_OFFSET FALSE
#define DEFAULT_SIGNAL_HANDOFFS TRUE
+#define DEFAULT_TS_OFFSET 0
+#define DEFAULT_DROP_ALLOCATION FALSE
+#define DEFAULT_EOS_AFTER -1
enum
{
PROP_LAST_MESSAGE,
PROP_DUMP,
PROP_SYNC,
+ PROP_TS_OFFSET,
PROP_CHECK_IMPERFECT_TIMESTAMP,
PROP_CHECK_IMPERFECT_OFFSET,
- PROP_SIGNAL_HANDOFFS
+ PROP_SIGNAL_HANDOFFS,
+ PROP_DROP_ALLOCATION,
+ PROP_EOS_AFTER
};
DEFAULT_SLEEP_TIME, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
g_object_class_install_property (gobject_class, PROP_ERROR_AFTER,
g_param_spec_int ("error-after", "Error After", "Error after N buffers",
- G_MININT, G_MAXINT, DEFAULT_ERROR_AFTER,
+ -1, G_MAXINT, DEFAULT_ERROR_AFTER,
G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
g_object_class_install_property (gobject_class, PROP_DROP_PROBABILITY,
g_param_spec_float ("drop-probability", "Drop Probability",
g_param_spec_boolean ("sync", "Synchronize",
"Synchronize to pipeline clock", DEFAULT_SYNC,
G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
+ g_object_class_install_property (gobject_class, PROP_TS_OFFSET,
+ g_param_spec_int64 ("ts-offset", "Timestamp offset for synchronisation",
+ "Timestamp offset in nanoseconds for synchronisation, negative for earlier sync",
+ G_MININT64, G_MAXINT64, DEFAULT_TS_OFFSET,
+ G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
g_object_class_install_property (gobject_class,
PROP_CHECK_IMPERFECT_TIMESTAMP,
g_param_spec_boolean ("check-imperfect-timestamp",
/**
* GstIdentity:signal-handoffs
*
- * If set to #TRUE, the identity will emit a handoff signal when handling a buffer.
- * When set to #FALSE, no signal will be emitted, which might improve performance.
+ * If set to %TRUE, the identity will emit a handoff signal when handling a buffer.
+ * When set to %FALSE, no signal will be emitted, which might improve performance.
*/
g_object_class_install_property (gobject_class, PROP_SIGNAL_HANDOFFS,
g_param_spec_boolean ("signal-handoffs",
"Signal handoffs", "Send a signal before pushing the buffer",
DEFAULT_SIGNAL_HANDOFFS, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
+ g_object_class_install_property (gobject_class, PROP_DROP_ALLOCATION,
+ g_param_spec_boolean ("drop-allocation", "Drop allocation query",
+ "Don't forward allocation queries", DEFAULT_DROP_ALLOCATION,
+ G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
+
+ /**
+ * GstIdentity:eos-after
+ *
+ * EOS after N buffers.
+ *
+ * Since: 1.16
+ **/
+ g_object_class_install_property (gobject_class, PROP_EOS_AFTER,
+ g_param_spec_int ("eos-after", "EOS After", "EOS after N buffers",
+ -1, G_MAXINT, DEFAULT_EOS_AFTER,
+ G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
+
/**
* GstIdentity::handoff:
* @identity: the identity instance
"Identity",
"Generic",
"Pass data without modification", "Erik Walthinsen <omega@cse.ogi.edu>");
- gst_element_class_add_pad_template (gstelement_class,
- gst_static_pad_template_get (&srctemplate));
- gst_element_class_add_pad_template (gstelement_class,
- gst_static_pad_template_get (&sinktemplate));
+ gst_element_class_add_static_pad_template (gstelement_class, &srctemplate);
+ gst_element_class_add_static_pad_template (gstelement_class, &sinktemplate);
gstelement_class->change_state =
GST_DEBUG_FUNCPTR (gst_identity_change_state);
{
identity->sleep_time = DEFAULT_SLEEP_TIME;
identity->error_after = DEFAULT_ERROR_AFTER;
+ identity->error_after_counter = DEFAULT_ERROR_AFTER;
identity->drop_probability = DEFAULT_DROP_PROBABILITY;
identity->drop_buffer_flags = DEFAULT_DROP_BUFFER_FLAGS;
identity->datarate = DEFAULT_DATARATE;
identity->dump = DEFAULT_DUMP;
identity->last_message = NULL;
identity->signal_handoffs = DEFAULT_SIGNAL_HANDOFFS;
+ identity->ts_offset = DEFAULT_TS_OFFSET;
g_cond_init (&identity->blocked_cond);
+ identity->eos_after = DEFAULT_EOS_AFTER;
+ identity->eos_after_counter = DEFAULT_EOS_AFTER;
gst_base_transform_set_gap_aware (GST_BASE_TRANSFORM_CAST (identity), TRUE);
}
GST_OBJECT_LOCK (identity);
+ if (identity->flushing) {
+ GST_OBJECT_UNLOCK (identity);
+ return GST_FLOW_FLUSHING;
+ }
+
while (identity->blocked)
g_cond_wait (&identity->blocked_cond, GST_OBJECT_GET_LOCK (identity));
+ if (identity->flushing) {
+ GST_OBJECT_UNLOCK (identity);
+ return GST_FLOW_FLUSHING;
+ }
if ((clock = GST_ELEMENT (identity)->clock)) {
GstClockReturn cret;
GstClockTime timestamp;
+ GstClockTimeDiff ts_offset = identity->ts_offset;
timestamp = running_time + GST_ELEMENT (identity)->base_time +
identity->upstream_latency;
+ if (ts_offset < 0) {
+ ts_offset = -ts_offset;
+ if (ts_offset < timestamp)
+ timestamp -= ts_offset;
+ else
+ timestamp = 0;
+ } else
+ timestamp += ts_offset;
/* save id if we need to unlock */
identity->clock_id = gst_clock_new_single_shot_id (clock, timestamp);
gst_clock_id_unref (identity->clock_id);
identity->clock_id = NULL;
}
- if (cret == GST_CLOCK_UNSCHEDULED)
- ret = GST_FLOW_EOS;
+ if (cret == GST_CLOCK_UNSCHEDULED || identity->flushing)
+ ret = GST_FLOW_FLUSHING;
}
GST_OBJECT_UNLOCK (identity);
}
} else {
if (GST_EVENT_TYPE (event) == GST_EVENT_FLUSH_START) {
GST_OBJECT_LOCK (identity);
+ identity->flushing = TRUE;
if (identity->clock_id) {
GST_DEBUG_OBJECT (identity, "unlock clock wait");
gst_clock_id_unschedule (identity->clock_id);
}
GST_OBJECT_UNLOCK (identity);
+ } else if (GST_EVENT_TYPE (event) == GST_EVENT_FLUSH_STOP) {
+ GST_OBJECT_LOCK (identity);
+ identity->flushing = FALSE;
+ GST_OBJECT_UNLOCK (identity);
}
ret = GST_BASE_TRANSFORM_CLASS (parent_class)->sink_event (trans, event);
const gchar * action, GstBuffer * buf, gsize size)
{
gchar dts_str[64], pts_str[64], dur_str[64];
- gchar *flag_str;
+ gchar *flag_str, *meta_str;
GST_OBJECT_LOCK (identity);
flag_str = gst_buffer_get_flags_string (buf);
+ meta_str = gst_buffer_get_meta_string (buf);
g_free (identity->last_message);
identity->last_message = g_strdup_printf ("%s ******* (%s:%s) "
"(%" G_GSIZE_FORMAT " bytes, dts: %s, pts: %s, duration: %s, offset: %"
G_GINT64_FORMAT ", " "offset_end: % " G_GINT64_FORMAT
- ", flags: %08x %s) %p", action,
+ ", flags: %08x %s, meta: %s) %p", action,
GST_DEBUG_PAD_NAME (GST_BASE_TRANSFORM_CAST (identity)->sinkpad), size,
print_pretty_time (dts_str, sizeof (dts_str), GST_BUFFER_DTS (buf)),
print_pretty_time (pts_str, sizeof (pts_str), GST_BUFFER_PTS (buf)),
print_pretty_time (dur_str, sizeof (dur_str), GST_BUFFER_DURATION (buf)),
GST_BUFFER_OFFSET (buf), GST_BUFFER_OFFSET_END (buf),
- GST_BUFFER_FLAGS (buf), flag_str, buf);
+ GST_BUFFER_FLAGS (buf), flag_str, meta_str ? meta_str : "none", buf);
g_free (flag_str);
GST_OBJECT_UNLOCK (identity);
identity->prev_offset_end = GST_BUFFER_OFFSET_END (buf);
identity->prev_offset = GST_BUFFER_OFFSET (buf);
- if (identity->error_after >= 0) {
- identity->error_after--;
- if (identity->error_after == 0)
+ if (identity->error_after_counter >= 0) {
+ identity->error_after_counter--;
+ if (identity->error_after_counter == 0)
goto error_after;
}
+ if (identity->eos_after_counter >= 0) {
+ identity->eos_after_counter--;
+ if (identity->eos_after_counter == 0)
+ goto eos_after;
+ }
+
if (identity->drop_probability > 0.0) {
if ((gfloat) (1.0 * rand () / (RAND_MAX)) < identity->drop_probability)
goto dropped;
(_("Failed after iterations as requested.")), (NULL));
return GST_FLOW_ERROR;
}
+eos_after:
+ {
+ GST_DEBUG_OBJECT (identity, "EOS after iterations as requested.");
+ return GST_FLOW_EOS;
+ }
dropped:
{
if (!identity->silent) {
case PROP_SYNC:
identity->sync = g_value_get_boolean (value);
break;
+ case PROP_TS_OFFSET:
+ identity->ts_offset = g_value_get_int64 (value);
+ break;
case PROP_CHECK_IMPERFECT_TIMESTAMP:
identity->check_imperfect_timestamp = g_value_get_boolean (value);
break;
case PROP_SIGNAL_HANDOFFS:
identity->signal_handoffs = g_value_get_boolean (value);
break;
+ case PROP_DROP_ALLOCATION:
+ identity->drop_allocation = g_value_get_boolean (value);
+ break;
+ case PROP_EOS_AFTER:
+ identity->eos_after = g_value_get_int (value);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
case PROP_SYNC:
g_value_set_boolean (value, identity->sync);
break;
+ case PROP_TS_OFFSET:
+ g_value_set_int64 (value, identity->ts_offset);
+ break;
case PROP_CHECK_IMPERFECT_TIMESTAMP:
g_value_set_boolean (value, identity->check_imperfect_timestamp);
break;
case PROP_SIGNAL_HANDOFFS:
g_value_set_boolean (value, identity->signal_handoffs);
break;
+ case PROP_DROP_ALLOCATION:
+ g_value_set_boolean (value, identity->drop_allocation);
+ break;
+ case PROP_EOS_AFTER:
+ g_value_set_int (value, identity->eos_after);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
identity = GST_IDENTITY (trans);
+ if (identity->eos_after != DEFAULT_EOS_AFTER
+ && identity->error_after != DEFAULT_ERROR_AFTER)
+ goto both_afters_defined;
+
identity->offset = 0;
identity->prev_timestamp = GST_CLOCK_TIME_NONE;
identity->prev_duration = GST_CLOCK_TIME_NONE;
identity->prev_offset_end = GST_BUFFER_OFFSET_NONE;
identity->prev_offset = GST_BUFFER_OFFSET_NONE;
+ identity->error_after_counter = identity->error_after;
+ identity->eos_after_counter = identity->eos_after;
return TRUE;
+
+ /* ERROR */
+both_afters_defined:
+ {
+ GST_ELEMENT_ERROR (identity, CORE, FAILED,
+ (_("eos-after and error-after can't both be defined.")), (NULL));
+ return FALSE;
+ }
}
static gboolean
identity = GST_IDENTITY (base);
+ if (GST_QUERY_TYPE (query) == GST_QUERY_ALLOCATION &&
+ identity->drop_allocation) {
+ GST_DEBUG_OBJECT (identity, "Dropping allocation query.");
+ return FALSE;
+ }
+
ret = GST_BASE_TRANSFORM_CLASS (parent_class)->query (base, direction, query);
if (GST_QUERY_TYPE (query) == GST_QUERY_LATENCY) {
break;
case GST_STATE_CHANGE_READY_TO_PAUSED:
GST_OBJECT_LOCK (identity);
+ identity->flushing = FALSE;
identity->blocked = TRUE;
GST_OBJECT_UNLOCK (identity);
if (identity->sync)
break;
case GST_STATE_CHANGE_PAUSED_TO_READY:
GST_OBJECT_LOCK (identity);
+ identity->flushing = TRUE;
if (identity->clock_id) {
GST_DEBUG_OBJECT (identity, "unlock clock wait");
gst_clock_id_unschedule (identity->clock_id);
projects / platform / upstream / gstreamer.git / blobdiff