gst/gstbus.c: Fix some typos.

Original commit message from CVS:
* gst/gstbus.c: (gst_bus_class_init):
Fix some typos.
* gst/gstqueue.c: (gst_queue_loop):
Don't assume a miniobject that isn't a buffer is an
event (it could be that there is a refcounting
problem somewhere and the pointer is stale and
refers to an already destroyed miniobject).
This commit is contained in:
Tim-Philipp Müller 2005-11-03 12:16:49 +00:00
parent e4f8d3b6de
commit 5c2af06cc5
4 changed files with 21 additions and 4 deletions

View file

@ -1,3 +1,14 @@
2005-11-03 Tim-Philipp Müller <tim at centricular dot net>
* gst/gstbus.c: (gst_bus_class_init):
Fix some typos.
* gst/gstqueue.c: (gst_queue_loop):
Don't assume a miniobject that isn't a buffer is an
event (it could be that there is a refcounting
problem somewhere and the pointer is stale and
refers to an already destroyed miniobject).
2005-11-03 Julien MOUTTE <julien@moutte.net>
* gst/gstpad.c: (gst_pad_alloc_buffer): Fix some typos.

View file

@ -172,7 +172,7 @@ gst_bus_class_init (GstBusClass * klass)
* @bus: the object which received the signal
* @message: the message that has been posted synchronously
*
* A message has been posted on the bus. This signal is emited from the
* A message has been posted on the bus. This signal is emitted from the
* thread that posted the message so one has to be carefull with locking.
*/
gst_bus_signals[SYNC_MESSAGE] =
@ -186,7 +186,7 @@ gst_bus_class_init (GstBusClass * klass)
* @bus: the object which received the signal
* @message: the message that has been posted asynchronously
*
* A message has been posted on the bus. This signal is emited from a
* A message has been posted on the bus. This signal is emitted from a
* GSource added to the mainloop.
*/
gst_bus_signals[ASYNC_MESSAGE] =

View file

@ -824,7 +824,7 @@ restart:
GST_DEBUG_OBJECT (queue, "pausing queue, reason %s", flowname);
gst_pad_pause_task (queue->srcpad);
}
} else {
} else if (GST_IS_EVENT (data)) {
if (GST_EVENT_TYPE (data) == GST_EVENT_EOS) {
queue->cur_level.buffers = 0;
queue->cur_level.bytes = 0;
@ -841,6 +841,9 @@ restart:
GST_QUEUE_MUTEX_LOCK_CHECK (queue, out_flushing);
if (restart == TRUE)
goto restart;
} else {
g_warning ("Unexpected object in queue %s (refcounting problem?)",
GST_OBJECT_NAME (queue));
}
STATUS (queue, "after _get()");

View file

@ -824,7 +824,7 @@ restart:
GST_DEBUG_OBJECT (queue, "pausing queue, reason %s", flowname);
gst_pad_pause_task (queue->srcpad);
}
} else {
} else if (GST_IS_EVENT (data)) {
if (GST_EVENT_TYPE (data) == GST_EVENT_EOS) {
queue->cur_level.buffers = 0;
queue->cur_level.bytes = 0;
@ -841,6 +841,9 @@ restart:
GST_QUEUE_MUTEX_LOCK_CHECK (queue, out_flushing);
if (restart == TRUE)
goto restart;
} else {
g_warning ("Unexpected object in queue %s (refcounting problem?)",
GST_OBJECT_NAME (queue));
}
STATUS (queue, "after _get()");