mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-26 19:51:11 +00:00
Code Issues 1 Projects Releases Wiki Activity

gst/gstqueue.*: Fix the spelling of "treshold" and make min_threshold actually affect the queue.

Browse source 
Original commit message from CVS:
* gst/gstqueue.c:
* gst/gstqueue.h:
Fix the spelling of "treshold" and make min_threshold actually
affect the queue.
This commit is contained in:
David Schleef 2004-01-15 20:37:07 +00:00
parent 2a75ec1544
commit 61c61cefda
5 changed files with 91 additions and 80 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
ChangeLog
View file

@ -1,3 +1,10 @@
2004-01-15 David Schleef <ds@schleef.org>
* gst/gstqueue.c:
* gst/gstqueue.h:
Fix the spelling of "treshold" and make min_threshold actually
affect the queue.
2004-01-15 David Schleef <ds@schleef.org> 2004-01-15 David Schleef <ds@schleef.org>
* gst/gstcaps.c: * gst/gstcaps.c:

80
gst/gstqueue.c
View file

@ -55,9 +55,9 @@ enum {
ARG_MAX_SIZE_BUFFERS, ARG_MAX_SIZE_BUFFERS,
ARG_MAX_SIZE_BYTES, ARG_MAX_SIZE_BYTES,
ARG_MAX_SIZE_TIME, ARG_MAX_SIZE_TIME,
ARG_MIN_TRESHOLD_BUFFERS, ARG_MIN_THRESHOLD_BUFFERS,
ARG_MIN_TRESHOLD_BYTES, ARG_MIN_THRESHOLD_BYTES,
ARG_MIN_TRESHOLD_TIME, ARG_MIN_THRESHOLD_TIME,
ARG_LEAKY, ARG_LEAKY,
ARG_MAY_DEADLOCK, ARG_MAY_DEADLOCK,
ARG_BLOCK_TIMEOUT ARG_BLOCK_TIMEOUT
@ -205,16 +205,16 @@ gst_queue_class_init (GstQueueClass *klass)
"Max. amount of data in the queue (in ns, 0=disable)", "Max. amount of data in the queue (in ns, 0=disable)",
0, G_MAXUINT64, 0, G_PARAM_READWRITE)); 0, G_MAXUINT64, 0, G_PARAM_READWRITE));
g_object_class_install_property (gobject_class, ARG_MIN_TRESHOLD_BYTES, g_object_class_install_property (gobject_class, ARG_MIN_THRESHOLD_BYTES,
g_param_spec_uint ("min-treshold-bytes", "Min. treshold (kB)", g_param_spec_uint ("min-threshold-bytes", "Min. threshold (kB)",
"Min. amount of data in the queue to allow reading (bytes, 0=disable)", "Min. amount of data in the queue to allow reading (bytes, 0=disable)",
0, G_MAXUINT, 0, G_PARAM_READWRITE)); 0, G_MAXUINT, 0, G_PARAM_READWRITE));
g_object_class_install_property (gobject_class, ARG_MIN_TRESHOLD_BUFFERS, g_object_class_install_property (gobject_class, ARG_MIN_THRESHOLD_BUFFERS,
g_param_spec_uint ("min-treshold-buffers", "Min. treshold (buffers)", g_param_spec_uint ("min-threshold-buffers", "Min. threshold (buffers)",
"Min. number of buffers in the queue to allow reading (0=disable)", "Min. number of buffers in the queue to allow reading (0=disable)",
0, G_MAXUINT, 0, G_PARAM_READWRITE)); 0, G_MAXUINT, 0, G_PARAM_READWRITE));
g_object_class_install_property (gobject_class, ARG_MIN_TRESHOLD_TIME, g_object_class_install_property (gobject_class, ARG_MIN_THRESHOLD_TIME,
g_param_spec_uint64 ("min-treshold-time", "Min. treshold (ns)", g_param_spec_uint64 ("min-threshold-time", "Min. threshold (ns)",
"Min. amount of data in the queue to allow reading (in ns, 0=disable)", "Min. amount of data in the queue to allow reading (in ns, 0=disable)",
0, G_MAXUINT64, 0, G_PARAM_READWRITE)); 0, G_MAXUINT64, 0, G_PARAM_READWRITE));
@ -269,9 +269,9 @@ gst_queue_init (GstQueue *queue)
queue->max_size.buffers = 250; /* high limit */ queue->max_size.buffers = 250; /* high limit */
queue->max_size.bytes = 0; /* unlimited */ queue->max_size.bytes = 0; /* unlimited */
queue->max_size.time = 0; /* unlimited */ queue->max_size.time = 0; /* unlimited */
queue->min_treshold.buffers = 0; /* no treshold */ queue->min_threshold.buffers = 0; /* no threshold */
queue->min_treshold.bytes = 0; /* no treshold */ queue->min_threshold.bytes = 0; /* no threshold */
queue->min_treshold.time = 0; /* no treshold */ queue->min_threshold.time = 0; /* no threshold */
queue->leaky = GST_QUEUE_NO_LEAK; queue->leaky = GST_QUEUE_NO_LEAK;
queue->may_deadlock = TRUE; queue->may_deadlock = TRUE;
@ -395,13 +395,13 @@ gst_queue_handle_pending_events (GstQueue *queue)
"-%" G_GUINT64_FORMAT " ns, %u elements", \ "-%" G_GUINT64_FORMAT " ns, %u elements", \
GST_DEBUG_PAD_NAME (pad), \ GST_DEBUG_PAD_NAME (pad), \
queue->cur_level.buffers, \ queue->cur_level.buffers, \
queue->min_treshold.buffers, \ queue->min_threshold.buffers, \
queue->max_size.buffers, \ queue->max_size.buffers, \
queue->cur_level.bytes, \ queue->cur_level.bytes, \
queue->min_treshold.bytes, \ queue->min_threshold.bytes, \
queue->max_size.bytes, \ queue->max_size.bytes, \
queue->cur_level.time, \ queue->cur_level.time, \
queue->min_treshold.time, \ queue->min_threshold.time, \
queue->max_size.time, \ queue->max_size.time, \
queue->queue->length) queue->queue->length)
@ -509,6 +509,7 @@ restart:
* to make things read-only. Also keep our list uptodate. */ * to make things read-only. Also keep our list uptodate. */
queue->cur_level.bytes -= GST_BUFFER_SIZE (data); queue->cur_level.bytes -= GST_BUFFER_SIZE (data);
queue->cur_level.buffers --; queue->cur_level.buffers --;
g_object_notify (G_OBJECT (queue), "current-level-buffers");
if (GST_BUFFER_DURATION (data) != GST_CLOCK_TIME_NONE) if (GST_BUFFER_DURATION (data) != GST_CLOCK_TIME_NONE)
queue->cur_level.time -= GST_BUFFER_DURATION (data); queue->cur_level.time -= GST_BUFFER_DURATION (data);
@ -604,6 +605,7 @@ restart:
/* Note that we only add buffers (not events) to the statistics */ /* Note that we only add buffers (not events) to the statistics */
if (GST_IS_BUFFER (data)) { if (GST_IS_BUFFER (data)) {
queue->cur_level.buffers++; queue->cur_level.buffers++;
g_object_notify (G_OBJECT (queue), "current-level-buffers");
queue->cur_level.bytes += GST_BUFFER_SIZE (data); queue->cur_level.bytes += GST_BUFFER_SIZE (data);
if (GST_BUFFER_DURATION (data) != GST_CLOCK_TIME_NONE) if (GST_BUFFER_DURATION (data) != GST_CLOCK_TIME_NONE)
queue->cur_level.time += GST_BUFFER_DURATION (data); queue->cur_level.time += GST_BUFFER_DURATION (data);
@ -642,24 +644,24 @@ restart:
"locked t:%p", g_thread_self ()); "locked t:%p", g_thread_self ());
if (queue->queue->length == 0 || if (queue->queue->length == 0 ||
(queue->min_treshold.buffers > 0 && (queue->min_threshold.buffers > 0 &&
queue->cur_level.buffers < queue->min_treshold.buffers) || queue->cur_level.buffers < queue->min_threshold.buffers) ||
(queue->min_treshold.bytes > 0 && (queue->min_threshold.bytes > 0 &&
queue->cur_level.bytes < queue->min_treshold.bytes) || queue->cur_level.bytes < queue->min_threshold.bytes) ||
(queue->min_treshold.time > 0 && (queue->min_threshold.time > 0 &&
queue->cur_level.time < queue->min_treshold.time)) { queue->cur_level.time < queue->min_threshold.time)) {
g_mutex_unlock (queue->qlock); g_mutex_unlock (queue->qlock);
g_signal_emit (G_OBJECT (queue), gst_queue_signals[SIGNAL_UNDERRUN], 0); g_signal_emit (G_OBJECT (queue), gst_queue_signals[SIGNAL_UNDERRUN], 0);
g_mutex_lock (queue->qlock); g_mutex_lock (queue->qlock);
STATUS (queue, "pre-empty wait"); STATUS (queue, "pre-empty wait");
while (queue->queue->length == 0 || while (queue->queue->length == 0 ||
(queue->min_treshold.buffers > 0 && (queue->min_threshold.buffers > 0 &&
queue->cur_level.buffers < queue->min_treshold.buffers) || queue->cur_level.buffers < queue->min_threshold.buffers) ||
(queue->min_treshold.bytes > 0 && (queue->min_threshold.bytes > 0 &&
queue->cur_level.bytes < queue->min_treshold.bytes) || queue->cur_level.bytes < queue->min_threshold.bytes) ||
(queue->min_treshold.time > 0 && (queue->min_threshold.time > 0 &&
queue->cur_level.time < queue->min_treshold.time)) { queue->cur_level.time < queue->min_threshold.time)) {
/* if there's a pending state change for this queue or its /* if there's a pending state change for this queue or its
* manager, switch back to iterator so bottom half of state * manager, switch back to iterator so bottom half of state
* change executes. */ * change executes. */
@ -930,14 +932,14 @@ gst_queue_set_property (GObject *object,
case ARG_MAX_SIZE_TIME: case ARG_MAX_SIZE_TIME:
queue->max_size.time = g_value_get_uint64 (value); queue->max_size.time = g_value_get_uint64 (value);
break; break;
case ARG_MIN_TRESHOLD_BYTES: case ARG_MIN_THRESHOLD_BYTES:
queue->max_size.bytes = g_value_get_uint (value); queue->min_threshold.bytes = g_value_get_uint (value);
break; break;
case ARG_MIN_TRESHOLD_BUFFERS: case ARG_MIN_THRESHOLD_BUFFERS:
queue->max_size.buffers = g_value_get_uint (value); queue->min_threshold.buffers = g_value_get_uint (value);
break; break;
case ARG_MIN_TRESHOLD_TIME: case ARG_MIN_THRESHOLD_TIME:
queue->max_size.time = g_value_get_uint64 (value); queue->min_threshold.time = g_value_get_uint64 (value);
break; break;
case ARG_LEAKY: case ARG_LEAKY:
queue->leaky = g_value_get_enum (value); queue->leaky = g_value_get_enum (value);
@ -983,14 +985,14 @@ gst_queue_get_property (GObject *object,
case ARG_MAX_SIZE_TIME: case ARG_MAX_SIZE_TIME:
g_value_set_uint64 (value, queue->max_size.time); g_value_set_uint64 (value, queue->max_size.time);
break; break;
case ARG_MIN_TRESHOLD_BYTES: case ARG_MIN_THRESHOLD_BYTES:
g_value_set_uint (value, queue->min_treshold.bytes); g_value_set_uint (value, queue->min_threshold.bytes);
break; break;
case ARG_MIN_TRESHOLD_BUFFERS: case ARG_MIN_THRESHOLD_BUFFERS:
g_value_set_uint (value, queue->min_treshold.buffers); g_value_set_uint (value, queue->min_threshold.buffers);
break; break;
case ARG_MIN_TRESHOLD_TIME: case ARG_MIN_THRESHOLD_TIME:
g_value_set_uint64 (value, queue->min_treshold.time); g_value_set_uint64 (value, queue->min_threshold.time);
break; break;
case ARG_LEAKY: case ARG_LEAKY:
g_value_set_enum (value, queue->leaky); g_value_set_enum (value, queue->leaky);

2
gst/gstqueue.h
View file

@ -65,7 +65,7 @@ struct _GstQueue {
guint64 time; /* amount of time */ guint64 time; /* amount of time */
} cur_level, /* currently in the queue */ } cur_level, /* currently in the queue */
max_size, /* max. amount of data allowed in the queue */ max_size, /* max. amount of data allowed in the queue */
min_treshold; /* min. amount of data required to wake reader */ min_threshold; /* min. amount of data required to wake reader */
/* whether we leak data, and at which end */ /* whether we leak data, and at which end */
gint leaky; gint leaky;

80
plugins/elements/gstqueue.c
View file

@ -55,9 +55,9 @@ enum {
ARG_MAX_SIZE_BUFFERS, ARG_MAX_SIZE_BUFFERS,
ARG_MAX_SIZE_BYTES, ARG_MAX_SIZE_BYTES,
ARG_MAX_SIZE_TIME, ARG_MAX_SIZE_TIME,
ARG_MIN_TRESHOLD_BUFFERS, ARG_MIN_THRESHOLD_BUFFERS,
ARG_MIN_TRESHOLD_BYTES, ARG_MIN_THRESHOLD_BYTES,
ARG_MIN_TRESHOLD_TIME, ARG_MIN_THRESHOLD_TIME,
ARG_LEAKY, ARG_LEAKY,
ARG_MAY_DEADLOCK, ARG_MAY_DEADLOCK,
ARG_BLOCK_TIMEOUT ARG_BLOCK_TIMEOUT
@ -205,16 +205,16 @@ gst_queue_class_init (GstQueueClass *klass)
"Max. amount of data in the queue (in ns, 0=disable)", "Max. amount of data in the queue (in ns, 0=disable)",
0, G_MAXUINT64, 0, G_PARAM_READWRITE)); 0, G_MAXUINT64, 0, G_PARAM_READWRITE));
g_object_class_install_property (gobject_class, ARG_MIN_TRESHOLD_BYTES, g_object_class_install_property (gobject_class, ARG_MIN_THRESHOLD_BYTES,
g_param_spec_uint ("min-treshold-bytes", "Min. treshold (kB)", g_param_spec_uint ("min-threshold-bytes", "Min. threshold (kB)",
"Min. amount of data in the queue to allow reading (bytes, 0=disable)", "Min. amount of data in the queue to allow reading (bytes, 0=disable)",
0, G_MAXUINT, 0, G_PARAM_READWRITE)); 0, G_MAXUINT, 0, G_PARAM_READWRITE));
g_object_class_install_property (gobject_class, ARG_MIN_TRESHOLD_BUFFERS, g_object_class_install_property (gobject_class, ARG_MIN_THRESHOLD_BUFFERS,
g_param_spec_uint ("min-treshold-buffers", "Min. treshold (buffers)", g_param_spec_uint ("min-threshold-buffers", "Min. threshold (buffers)",
"Min. number of buffers in the queue to allow reading (0=disable)", "Min. number of buffers in the queue to allow reading (0=disable)",
0, G_MAXUINT, 0, G_PARAM_READWRITE)); 0, G_MAXUINT, 0, G_PARAM_READWRITE));
g_object_class_install_property (gobject_class, ARG_MIN_TRESHOLD_TIME, g_object_class_install_property (gobject_class, ARG_MIN_THRESHOLD_TIME,
g_param_spec_uint64 ("min-treshold-time", "Min. treshold (ns)", g_param_spec_uint64 ("min-threshold-time", "Min. threshold (ns)",
"Min. amount of data in the queue to allow reading (in ns, 0=disable)", "Min. amount of data in the queue to allow reading (in ns, 0=disable)",
0, G_MAXUINT64, 0, G_PARAM_READWRITE)); 0, G_MAXUINT64, 0, G_PARAM_READWRITE));
@ -269,9 +269,9 @@ gst_queue_init (GstQueue *queue)
queue->max_size.buffers = 250; /* high limit */ queue->max_size.buffers = 250; /* high limit */
queue->max_size.bytes = 0; /* unlimited */ queue->max_size.bytes = 0; /* unlimited */
queue->max_size.time = 0; /* unlimited */ queue->max_size.time = 0; /* unlimited */
queue->min_treshold.buffers = 0; /* no treshold */ queue->min_threshold.buffers = 0; /* no threshold */
queue->min_treshold.bytes = 0; /* no treshold */ queue->min_threshold.bytes = 0; /* no threshold */
queue->min_treshold.time = 0; /* no treshold */ queue->min_threshold.time = 0; /* no threshold */
queue->leaky = GST_QUEUE_NO_LEAK; queue->leaky = GST_QUEUE_NO_LEAK;
queue->may_deadlock = TRUE; queue->may_deadlock = TRUE;
@ -395,13 +395,13 @@ gst_queue_handle_pending_events (GstQueue *queue)
"-%" G_GUINT64_FORMAT " ns, %u elements", \ "-%" G_GUINT64_FORMAT " ns, %u elements", \
GST_DEBUG_PAD_NAME (pad), \ GST_DEBUG_PAD_NAME (pad), \
queue->cur_level.buffers, \ queue->cur_level.buffers, \
queue->min_treshold.buffers, \ queue->min_threshold.buffers, \
queue->max_size.buffers, \ queue->max_size.buffers, \
queue->cur_level.bytes, \ queue->cur_level.bytes, \
queue->min_treshold.bytes, \ queue->min_threshold.bytes, \
queue->max_size.bytes, \ queue->max_size.bytes, \
queue->cur_level.time, \ queue->cur_level.time, \
queue->min_treshold.time, \ queue->min_threshold.time, \
queue->max_size.time, \ queue->max_size.time, \
queue->queue->length) queue->queue->length)
@ -509,6 +509,7 @@ restart:
* to make things read-only. Also keep our list uptodate. */ * to make things read-only. Also keep our list uptodate. */
queue->cur_level.bytes -= GST_BUFFER_SIZE (data); queue->cur_level.bytes -= GST_BUFFER_SIZE (data);
queue->cur_level.buffers --; queue->cur_level.buffers --;
g_object_notify (G_OBJECT (queue), "current-level-buffers");
if (GST_BUFFER_DURATION (data) != GST_CLOCK_TIME_NONE) if (GST_BUFFER_DURATION (data) != GST_CLOCK_TIME_NONE)
queue->cur_level.time -= GST_BUFFER_DURATION (data); queue->cur_level.time -= GST_BUFFER_DURATION (data);
@ -604,6 +605,7 @@ restart:
/* Note that we only add buffers (not events) to the statistics */ /* Note that we only add buffers (not events) to the statistics */
if (GST_IS_BUFFER (data)) { if (GST_IS_BUFFER (data)) {
queue->cur_level.buffers++; queue->cur_level.buffers++;
g_object_notify (G_OBJECT (queue), "current-level-buffers");
queue->cur_level.bytes += GST_BUFFER_SIZE (data); queue->cur_level.bytes += GST_BUFFER_SIZE (data);
if (GST_BUFFER_DURATION (data) != GST_CLOCK_TIME_NONE) if (GST_BUFFER_DURATION (data) != GST_CLOCK_TIME_NONE)
queue->cur_level.time += GST_BUFFER_DURATION (data); queue->cur_level.time += GST_BUFFER_DURATION (data);
@ -642,24 +644,24 @@ restart:
"locked t:%p", g_thread_self ()); "locked t:%p", g_thread_self ());
if (queue->queue->length == 0 || if (queue->queue->length == 0 ||
(queue->min_treshold.buffers > 0 && (queue->min_threshold.buffers > 0 &&
queue->cur_level.buffers < queue->min_treshold.buffers) || queue->cur_level.buffers < queue->min_threshold.buffers) ||
(queue->min_treshold.bytes > 0 && (queue->min_threshold.bytes > 0 &&
queue->cur_level.bytes < queue->min_treshold.bytes) || queue->cur_level.bytes < queue->min_threshold.bytes) ||
(queue->min_treshold.time > 0 && (queue->min_threshold.time > 0 &&
queue->cur_level.time < queue->min_treshold.time)) { queue->cur_level.time < queue->min_threshold.time)) {
g_mutex_unlock (queue->qlock); g_mutex_unlock (queue->qlock);
g_signal_emit (G_OBJECT (queue), gst_queue_signals[SIGNAL_UNDERRUN], 0); g_signal_emit (G_OBJECT (queue), gst_queue_signals[SIGNAL_UNDERRUN], 0);
g_mutex_lock (queue->qlock); g_mutex_lock (queue->qlock);
STATUS (queue, "pre-empty wait"); STATUS (queue, "pre-empty wait");
while (queue->queue->length == 0 || while (queue->queue->length == 0 ||
(queue->min_treshold.buffers > 0 && (queue->min_threshold.buffers > 0 &&
queue->cur_level.buffers < queue->min_treshold.buffers) || queue->cur_level.buffers < queue->min_threshold.buffers) ||
(queue->min_treshold.bytes > 0 && (queue->min_threshold.bytes > 0 &&
queue->cur_level.bytes < queue->min_treshold.bytes) || queue->cur_level.bytes < queue->min_threshold.bytes) ||
(queue->min_treshold.time > 0 && (queue->min_threshold.time > 0 &&
queue->cur_level.time < queue->min_treshold.time)) { queue->cur_level.time < queue->min_threshold.time)) {
/* if there's a pending state change for this queue or its /* if there's a pending state change for this queue or its
* manager, switch back to iterator so bottom half of state * manager, switch back to iterator so bottom half of state
* change executes. */ * change executes. */
@ -930,14 +932,14 @@ gst_queue_set_property (GObject *object,
case ARG_MAX_SIZE_TIME: case ARG_MAX_SIZE_TIME:
queue->max_size.time = g_value_get_uint64 (value); queue->max_size.time = g_value_get_uint64 (value);
break; break;
case ARG_MIN_TRESHOLD_BYTES: case ARG_MIN_THRESHOLD_BYTES:
queue->max_size.bytes = g_value_get_uint (value); queue->min_threshold.bytes = g_value_get_uint (value);
break; break;
case ARG_MIN_TRESHOLD_BUFFERS: case ARG_MIN_THRESHOLD_BUFFERS:
queue->max_size.buffers = g_value_get_uint (value); queue->min_threshold.buffers = g_value_get_uint (value);
break; break;
case ARG_MIN_TRESHOLD_TIME: case ARG_MIN_THRESHOLD_TIME:
queue->max_size.time = g_value_get_uint64 (value); queue->min_threshold.time = g_value_get_uint64 (value);
break; break;
case ARG_LEAKY: case ARG_LEAKY:
queue->leaky = g_value_get_enum (value); queue->leaky = g_value_get_enum (value);
@ -983,14 +985,14 @@ gst_queue_get_property (GObject *object,
case ARG_MAX_SIZE_TIME: case ARG_MAX_SIZE_TIME:
g_value_set_uint64 (value, queue->max_size.time); g_value_set_uint64 (value, queue->max_size.time);
break; break;
case ARG_MIN_TRESHOLD_BYTES: case ARG_MIN_THRESHOLD_BYTES:
g_value_set_uint (value, queue->min_treshold.bytes); g_value_set_uint (value, queue->min_threshold.bytes);
break; break;
case ARG_MIN_TRESHOLD_BUFFERS: case ARG_MIN_THRESHOLD_BUFFERS:
g_value_set_uint (value, queue->min_treshold.buffers); g_value_set_uint (value, queue->min_threshold.buffers);
break; break;
case ARG_MIN_TRESHOLD_TIME: case ARG_MIN_THRESHOLD_TIME:
g_value_set_uint64 (value, queue->min_treshold.time); g_value_set_uint64 (value, queue->min_threshold.time);
break; break;
case ARG_LEAKY: case ARG_LEAKY:
g_value_set_enum (value, queue->leaky); g_value_set_enum (value, queue->leaky);

2
plugins/elements/gstqueue.h
View file

@ -65,7 +65,7 @@ struct _GstQueue {
guint64 time; /* amount of time */ guint64 time; /* amount of time */
} cur_level, /* currently in the queue */ } cur_level, /* currently in the queue */
max_size, /* max. amount of data allowed in the queue */ max_size, /* max. amount of data allowed in the queue */
min_treshold; /* min. amount of data required to wake reader */ min_threshold; /* min. amount of data required to wake reader */
/* whether we leak data, and at which end */ /* whether we leak data, and at which end */
gint leaky; gint leaky;