From 4ec5e11d0e4db05000b47db4c681d570431c1818 Mon Sep 17 00:00:00 2001
From: Adam Dickmeiss <adam@indexdata.dk>
Date: Wed, 13 Dec 1995 08:46:09 +0000
Subject: [PATCH] Locking uses F_WRLCK and F_RDLCK again!

---
 index/lockidx.c  |   12 +++++++++---
 index/lockutil.c |   13 ++++++++-----
 2 files changed, 17 insertions(+), 8 deletions(-)

diff --git a/index/lockidx.c b/index/lockidx.c
index eb833b2..dad7181 100644
--- a/index/lockidx.c
+++ b/index/lockidx.c
@@ -4,7 +4,10 @@
  * Sebastian Hammer, Adam Dickmeiss
  *
  * $Log: lockidx.c,v $
- * Revision 1.4  1995-12-12 16:00:57  adam
+ * Revision 1.5  1995-12-13 08:46:09  adam
+ * Locking uses F_WRLCK and F_RDLCK again!
+ *
+ * Revision 1.4  1995/12/12  16:00:57  adam
  * System call sync(2) used after update/commit.
  * Locking (based on fcntl) uses F_EXLCK and F_SHLCK instead of F_WRLCK
  * and F_RDLCK.
@@ -142,7 +145,7 @@ void zebraIndexLock (int commitNow)
         lock_fd = open (path, O_CREAT|O_RDWR|O_EXCL, 0666);
         if (lock_fd == -1)
         {
-            lock_fd = open (path, O_RDONLY);
+            lock_fd = open (path, O_RDWR);
             if (lock_fd == -1) 
             {
                 if (errno == ENOENT)
@@ -150,12 +153,15 @@ void zebraIndexLock (int commitNow)
                 logf (LOG_FATAL|LOG_ERRNO, "open %s", path);
                 exit (1);
             }
+            logf (LOG_LOG, "zebraLockNB");
             if (zebraLockNB (lock_fd, 1) == -1)
             {
                 if (errno == EWOULDBLOCK)
                 {
                     logf (LOG_LOG, "Waiting for other index process");
                     zebraLock (lock_fd, 1);
+                    zebraUnlock (lock_fd);
+                    close (lock_fd);
                     continue;
                 }
                 else
@@ -177,7 +183,7 @@ void zebraIndexLock (int commitNow)
                 }
                 else if (r == -1)
                 {
-                    logf (LOG_FATAL|LOG_ERRNO, "read  %s", path);
+                    logf (LOG_FATAL|LOG_ERRNO, "read %s", path);
                     exit (1);
                 }
                 if (*buf == 'r')
diff --git a/index/lockutil.c b/index/lockutil.c
index d626d70..7b83a52 100644
--- a/index/lockutil.c
+++ b/index/lockutil.c
@@ -4,7 +4,10 @@
  * Sebastian Hammer, Adam Dickmeiss
  *
  * $Log: lockutil.c,v $
- * Revision 1.3  1995-12-12 16:00:57  adam
+ * Revision 1.4  1995-12-13 08:46:10  adam
+ * Locking uses F_WRLCK and F_RDLCK again!
+ *
+ * Revision 1.3  1995/12/12  16:00:57  adam
  * System call sync(2) used after update/commit.
  * Locking (based on fcntl) uses F_EXLCK and F_SHLCK instead of F_WRLCK
  * and F_RDLCK.
@@ -53,7 +56,7 @@ static int intLock (int fd, int type, int cmd)
 
 int zebraLock (int fd, int wr)
 {
-#if 1
+#if 0
     return intLock (fd, wr ? F_EXLCK : F_SHLCK, F_SETLKW);
 #else
     return intLock (fd, wr ? F_WRLCK : F_RDLCK, F_SETLKW);
@@ -62,10 +65,10 @@ int zebraLock (int fd, int wr)
 
 int zebraLockNB (int fd, int wr)
 {
-#if 1
-    return intLock (fd, wr ? F_EXLCK : F_SHLCK, F_SETLKW);
+#if 0
+    return intLock (fd, wr ? F_EXLCK : F_SHLCK, F_SETLK);
 #else
-    return intLock (fd, wr ? F_WRLCK : F_RDLCK, F_SETLKW);
+    return intLock (fd, wr ? F_WRLCK : F_RDLCK, F_SETLK);
 #endif
 }
 
-- 
1.7.10.4