mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-23 02:01:12 +00:00
Code Issues 1 Projects Releases Wiki Activity

Rearranged the mutex locking, still have to think about it though...

Browse source 
Original commit message from CVS:
Rearranged the mutex locking, still have to think about it though...
This commit is contained in:
Wim Taymans 2001-01-06 19:09:40 +00:00
parent f130a170c2
commit 372b6f5887
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
gst/elements/gstqueue.c
View file

@ -195,11 +195,11 @@ gst_queue_chain (GstPad *pad, GstBuffer *buf)
while (queue->level_buffers >= queue->max_buffers) {
GST_DEBUG (0,"queue: %s waiting %d\n", name, queue->level_buffers);
STATUS("%s: O\n");
GST_UNLOCK (queue);
g_mutex_lock (queue->fulllock);
GST_UNLOCK (queue);
g_cond_wait (queue->fullcond, queue->fulllock);
g_mutex_unlock (queue->fulllock);
GST_LOCK (queue);
g_mutex_unlock (queue->fulllock);
STATUS("%s: O+\n");
GST_DEBUG (0,"queue: %s waiting done %d\n", name, queue->level_buffers);
}

4
plugins/elements/gstqueue.c
View file

@ -195,11 +195,11 @@ gst_queue_chain (GstPad *pad, GstBuffer *buf)
while (queue->level_buffers >= queue->max_buffers) {
GST_DEBUG (0,"queue: %s waiting %d\n", name, queue->level_buffers);
STATUS("%s: O\n");
GST_UNLOCK (queue);
g_mutex_lock (queue->fulllock);
GST_UNLOCK (queue);
g_cond_wait (queue->fullcond, queue->fulllock);
g_mutex_unlock (queue->fulllock);
GST_LOCK (queue);
g_mutex_unlock (queue->fulllock);
STATUS("%s: O+\n");
GST_DEBUG (0,"queue: %s waiting done %d\n", name, queue->level_buffers);
}