processing upon lock release

diff --git a/src/lockmanager/gnunet-service-lockmanager.c b/src/lockmanager/gnunet-service-lockmanager.c
index f959a3c5e9c5c15375ba70e23394a6deac77ce5c..f7c01b1afabcb57d5962882f716bffcb265fa0b4 100644 (file)
--- a/src/lockmanager/gnunet-service-lockmanager.c
+++ b/src/lockmanager/gnunet-service-lockmanager.c
@@ -228,7 +228,6 @@ ll_find_lock_by_owner (const struct GNUNET_SERVER_Client *client,
  * @param client the client which currently owns this lock
  * @param domain_name the name of the locking domain
  * @param lock_num the number of the lock
- * @param tail the pointer to the tail of the global lock list
  */
 static void
 ll_add_lock (struct GNUNET_SERVER_Client *client,
@@ -533,6 +532,51 @@ handle_acquire (void *cls,
 }
 
 
+/**
+ * This function gives the lock to the first client in the wait list of the
+ * lock. If no clients are currently waiting for this lock, the lock is
+ * destroyed.
+ *
+ * @param ll_entry the lock list entry corresponding to a lock
+ */
+static void
+process_lock_release (struct LockList *ll_entry)
+{
+  struct WaitList *wl_entry;
+
+  wl_entry = ll_entry->wait_list_head;
+  if (NULL == wl_entry)
+    {
+      ll_remove_lock (ll_entry);
+      return;
+    }
+
+  while (NULL != wl_entry)
+    {
+      ll_wl_remove_client(ll_entry, wl_entry);
+
+      if (GNUNET_NO == cl_find_client (wl_entry->client, NULL))
+        {
+          LOG (GNUNET_ERROR_TYPE_DEBUG,
+               "Removing disconnected client from wait list\n");
+          wl_entry = ll_entry->wait_list_head;
+          continue;
+        }
+      
+      LOG (GNUNET_ERROR_TYPE_DEBUG,
+           "Giving lock to a client from wait list\n");
+      ll_entry->client = wl_entry->client;
+      send_success_msg (wl_entry->client,
+                        ll_entry->domain_name,
+                        ll_entry->lock_num);
+      return;
+    }
+  /* We ran out of clients in the wait list -- destroy lock */
+  ll_remove_lock (ll_entry);
+  return;
+}
+
+
 /**
  * Handle for GNUNET_MESSAGE_TYPE_LOCKMANAGER_RELEASE
  *
@@ -556,25 +600,21 @@ handle_release (void *cls,
   LOG (GNUNET_ERROR_TYPE_DEBUG,
        "Received a RELEASE message on lock with num: %d, domain: %s\n",
        lock_num, domain_name);
+  GNUNET_SERVER_receive_done (client, GNUNET_OK);
   if (GNUNET_YES == ll_find_lock (domain_name, lock_num, &ll_entry))
     {
-      if (NULL == ll_entry->wait_list_head)
-        {
-          ll_remove_lock (ll_entry);
-        }
-      else
+      if (client != ll_entry->client)
         {
-          /* Do furthur processing on lock's wait list here */
+          GNUNET_break (0);
+          return;
         }
+      process_lock_release (ll_entry);
     }
   else
     {
       LOG (GNUNET_ERROR_TYPE_DEBUG,
            "\t give lock doesn't exist\n");
     }
-  
-  
-  GNUNET_SERVER_receive_done (client, GNUNET_OK);
 }
 
 
@@ -594,19 +634,12 @@ client_disconnect_cb (void *cls, struct GNUNET_SERVER_Client *client)
   
   if (GNUNET_YES == cl_find_client (client, &cl_entry))
     {
-      struct LockList *lock;
+      struct LockList *ll_entry;
       
       cl_remove_client (cl_entry);
-      while (GNUNET_YES == ll_find_lock_by_owner (client, &lock))
+      while (GNUNET_YES == ll_find_lock_by_owner (client, &ll_entry))
         {
-          if (NULL == lock->wait_list_head)
-            {
-              ll_remove_lock (lock);
-            }
-          else
-            {
-              /* Do furthur processing on lock's wait list here */
-            }
+          process_lock_release (ll_entry);
         }
     }
   else GNUNET_break (0);