From 30b9fabab69e5f3d63eab09a96a9aa7c669b9f38 Mon Sep 17 00:00:00 2001
From: Adrian Lang <lang@cosmocode.de>
Date: Mon, 18 Oct 2010 16:30:04 +0200
Subject: Fix subscription locking

  - use directories since working with them is atomic
  - delete stale locks after 5 minutes
---
 inc/subscription.php | 25 +++++++++++++++++++++----
 1 file changed, 21 insertions(+), 4 deletions(-)

(limited to 'inc/subscription.php')

diff --git a/inc/subscription.php b/inc/subscription.php
index f198402f9..78cb3ed0d 100644
--- a/inc/subscription.php
+++ b/inc/subscription.php
@@ -44,9 +44,26 @@ function subscription_filename($id) {
  *
  * @author Adrian Lang <lang@cosmocode.de>
  */
+function subscription_lock_filename ($id){
+    global $conf;
+    return $conf['lockdir'].'/_subscr_' . $id . '.lock';
+}
+
 function subscription_lock($id) {
-    $lockf = subscription_filename($id) . '.lock';
-    return !file_exists($lockf) && touch($lockf);
+    // FIXME merge this with the indexer lock generation, abstract out
+    global $conf;
+    $lock = subscription_lock_filename($id);
+    while(!@mkdir($lock,$conf['dmode'])){
+        usleep(50);
+        if(time()-@filemtime($lock) > 60*5){
+            // looks like a stale lock - remove it
+            @rmdir($lock);
+        }else{
+            return false;
+        }
+    }
+    if($conf['dperm']) chmod($lock, $conf['dperm']);
+    return true;
 }
 
 /**
@@ -58,8 +75,8 @@ function subscription_lock($id) {
  * @author Adrian Lang <lang@cosmocode.de>
  */
 function subscription_unlock($id) {
-    $lockf = subscription_filename($id) . '.lock';
-    return file_exists($lockf) && unlink($lockf);
+    $lockf = subscription_lock_filename($id);
+    return @rmdir($lockf);
 }
 
 /**
-- 
cgit v1.2.3