From def4917a078ded502c1e8d534a8a534ee6ef9ea1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Tomasz=20Mo=C5=84?= <desowin@gmail.com>
Date: Mon, 11 May 2009 21:17:04 +0200
Subject: [PATCH] revise mutex logic

---
 gdigi.c | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/gdigi.c b/gdigi.c
index 923552e..40bd7ee 100644
--- a/gdigi.c
+++ b/gdigi.c
@@ -394,9 +394,8 @@ GString *get_message_by_id(MessageID id)
     guint x, len;
     gboolean found = FALSE;
 
+    g_mutex_lock(message_queue_mutex);
     do {
-        g_mutex_lock(message_queue_mutex);
-
         len = g_queue_get_length(message_queue);
         for (x = 0; x<len; x++) {
             data = g_queue_peek_nth(message_queue, x);
@@ -410,8 +409,8 @@ GString *get_message_by_id(MessageID id)
         if (found == FALSE)
             g_cond_wait(message_queue_cond, message_queue_mutex);
 
-        g_mutex_unlock(message_queue_mutex);
     } while (found == FALSE);
+    g_mutex_unlock(message_queue_mutex);
 
     unpack_message(data);
 
@@ -668,9 +667,8 @@ GList *get_current_preset()
 
     send_message(REQUEST_PRESET, "\x04\x00", 2);
 
+    g_mutex_lock(message_queue_mutex);
     do {
-        g_mutex_lock(message_queue_mutex);
-
         len = g_queue_get_length(message_queue);
 
         for (x = 0; x<len && (found == FALSE); x++) {
@@ -704,10 +702,12 @@ GList *get_current_preset()
             }
 
             done = TRUE;
+        } else {
+            /* Receive Preset Start not found in message queue */
+            g_cond_wait(message_queue_cond, message_queue_mutex);
         }
-
-        g_mutex_unlock(message_queue_mutex);
     } while (done == FALSE);
+    g_mutex_unlock(message_queue_mutex);
 
     return list;
 }