PROP_MIN_THRESHOLD_BYTES,
PROP_MIN_THRESHOLD_TIME,
PROP_LEAKY,
- /* FILL ME */
+ PROP_SILENT
};
/* default property values */
GST_TYPE_QUEUE_LEAKY, GST_QUEUE_NO_LEAK,
G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
+ /**
+ * GstQueue:silent
+ *
+ * Don't emit queue signals. Makes queues more lightweight if no signals are
+ * needed.
+ *
+ * Since: 0.10.31
+ */
+ g_object_class_install_property (gobject_class, PROP_SILENT,
+ g_param_spec_boolean ("silent", "Silent",
+ "Don't emit queue signals", FALSE,
+ G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
+
gobject_class->finalize = gst_queue_finalize;
/* Registering debug symbols for function pointers */
* the user defined as "full". Note that this only applies to buffers.
* We always handle events and they don't count in our statistics. */
while (gst_queue_is_filled (queue)) {
- GST_QUEUE_MUTEX_UNLOCK (queue);
- g_signal_emit (queue, gst_queue_signals[SIGNAL_OVERRUN], 0);
- GST_QUEUE_MUTEX_LOCK_CHECK (queue, out_flushing);
+ if (!queue->silent) {
+ GST_QUEUE_MUTEX_UNLOCK (queue);
+ g_signal_emit (queue, gst_queue_signals[SIGNAL_OVERRUN], 0);
+ GST_QUEUE_MUTEX_LOCK_CHECK (queue, out_flushing);
+ } else {
+ if (queue->srcresult != GST_FLOW_OK)
+ goto out_flushing;
+ }
/* we recheck, the signal could have changed the thresholds */
if (!gst_queue_is_filled (queue))
GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "queue is not full");
- GST_QUEUE_MUTEX_UNLOCK (queue);
- g_signal_emit (queue, gst_queue_signals[SIGNAL_RUNNING], 0);
- GST_QUEUE_MUTEX_LOCK_CHECK (queue, out_flushing);
+ if (!queue->silent) {
+ GST_QUEUE_MUTEX_UNLOCK (queue);
+ g_signal_emit (queue, gst_queue_signals[SIGNAL_RUNNING], 0);
+ GST_QUEUE_MUTEX_LOCK_CHECK (queue, out_flushing);
+ } else {
+ if (queue->srcresult != GST_FLOW_OK)
+ goto out_flushing;
+ }
break;
}
}
GST_QUEUE_MUTEX_LOCK_CHECK (queue, out_flushing);
while (gst_queue_is_empty (queue)) {
- GST_QUEUE_MUTEX_UNLOCK (queue);
- g_signal_emit (queue, gst_queue_signals[SIGNAL_UNDERRUN], 0);
- GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "queue is empty");
- GST_QUEUE_MUTEX_LOCK_CHECK (queue, out_flushing);
+ if (!queue->silent) {
+ GST_QUEUE_MUTEX_UNLOCK (queue);
+ g_signal_emit (queue, gst_queue_signals[SIGNAL_UNDERRUN], 0);
+ GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "queue is empty");
+ GST_QUEUE_MUTEX_LOCK_CHECK (queue, out_flushing);
+ } else {
+ GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "queue is empty");
+ if (queue->srcresult != GST_FLOW_OK)
+ goto out_flushing;
+ }
/* we recheck, the signal could have changed the thresholds */
while (gst_queue_is_empty (queue)) {
GST_QUEUE_WAIT_ADD_CHECK (queue, out_flushing);
}
- GST_QUEUE_MUTEX_UNLOCK (queue);
- g_signal_emit (queue, gst_queue_signals[SIGNAL_RUNNING], 0);
- g_signal_emit (queue, gst_queue_signals[SIGNAL_PUSHING], 0);
- GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "queue is not empty");
-
- GST_QUEUE_MUTEX_LOCK_CHECK (queue, out_flushing);
+ if (!queue->silent) {
+ GST_QUEUE_MUTEX_UNLOCK (queue);
+ g_signal_emit (queue, gst_queue_signals[SIGNAL_RUNNING], 0);
+ g_signal_emit (queue, gst_queue_signals[SIGNAL_PUSHING], 0);
+ GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "queue is not empty");
+ GST_QUEUE_MUTEX_LOCK_CHECK (queue, out_flushing);
+ } else {
+ GST_CAT_DEBUG_OBJECT (queue_dataflow, queue, "queue is not empty");
+ if (queue->srcresult != GST_FLOW_OK)
+ goto out_flushing;
+ }
}
ret = gst_queue_push_one (queue);
case PROP_LEAKY:
queue->leaky = g_value_get_enum (value);
break;
+ case PROP_SILENT:
+ queue->silent = g_value_get_boolean (value);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
case PROP_LEAKY:
g_value_set_enum (value, queue->leaky);
break;
+ case PROP_SILENT:
+ g_value_set_boolean (value, queue->silent);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;