X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=index%2Flockidx.c;h=4904de47d10e9e610d4194952a1381aa7b1ee69c;hb=5adb31268b057741850de38eafd42baf8dc947ea;hp=20ece01d611f57de95ed17b721583c450136a9df;hpb=a4672c6ad0168d8c39b6806e33b90cba4151ac0d;p=idzebra-moved-to-github.git

diff --git a/index/lockidx.c b/index/lockidx.c
index 20ece01..4904de4 100644
--- a/index/lockidx.c
+++ b/index/lockidx.c
@@ -4,7 +4,13 @@
  * Sebastian Hammer, Adam Dickmeiss
  *
  * $Log: lockidx.c,v $
- * Revision 1.19  2000-09-05 14:04:05  adam
+ * Revision 1.21  2002-02-20 17:30:01  adam
+ * Work on new API. Locking system re-implemented
+ *
+ * Revision 1.20  2000/10/16 20:16:00  adam
+ * Fixed problem with close of lock file for WIN32.
+ *
+ * Revision 1.19  2000/09/05 14:04:05  adam
  * Updates for prefix 'yaz_' for YAZ log functions.
  *
  * Revision 1.18  2000/02/24 11:00:07  adam
@@ -83,12 +89,13 @@
 #include <errno.h>
 
 #include "index.h"
+#include "zserver.h"
 
 static ZebraLockHandle server_lock_main = NULL;
 static ZebraLockHandle server_lock_cmt = NULL;
 static ZebraLockHandle server_lock_org = NULL;
 
-int zebraIndexWait (int commitPhase)
+int zebraIndexWait (ZebraHandle zh, int commitPhase)
 {
     ZebraLockHandle h;
 
@@ -98,7 +105,7 @@ int zebraIndexWait (int commitPhase)
     {
 	char path[1024];
 
-	zebra_lock_prefix (common_resource, path);
+	zebra_lock_prefix (zh->service->res, path);
 	strcat (path, FNAME_COMMIT_LOCK);
 	server_lock_cmt = zebra_lock_create (path, 1);
 	if (!server_lock_cmt)
@@ -113,7 +120,7 @@ int zebraIndexWait (int commitPhase)
     {
 	char path[1024];
 
-	zebra_lock_prefix (common_resource, path);
+	zebra_lock_prefix (zh->service->res, path);
 	strcat (path, FNAME_ORG_LOCK);
 	server_lock_org = zebra_lock_create (path, 1);
 	if (!server_lock_org)
@@ -150,7 +157,7 @@ int zebraIndexWait (int commitPhase)
 }
 
 
-void zebraIndexLockMsg (const char *str)
+void zebraIndexLockMsg (ZebraHandle zh, const char *str)
 {
     char path[1024];
     int l, r, fd;
@@ -165,25 +172,32 @@ void zebraIndexLockMsg (const char *str)
         logf (LOG_FATAL|LOG_ERRNO, "write lock file");
         exit (1);
     }
-    zebra_lock_prefix (common_resource, path);
+    zebra_lock_prefix (zh->service->res, path);
     strcat (path, FNAME_TOUCH_TIME);
     fd = creat (path, 0666);
     close (fd);
 }
 
-void zebraIndexUnlock (void)
+void zebraIndexUnlock (ZebraHandle zh)
 {
     char path[1024];
     
-    zebra_lock_prefix (common_resource, path);
+    zebra_lock_prefix (zh->service->res, path);
     strcat (path, FNAME_MAIN_LOCK);
+#ifdef WIN32
+    zebra_lock_destroy (server_lock_main);
+    if (unlink (path) && errno != ENOENT)
+        logf (LOG_WARN|LOG_ERRNO, "unlink %s failed", path);
+#else
     if (unlink (path) && errno != ENOENT)
         logf (LOG_WARN|LOG_ERRNO, "unlink %s failed", path);
     zebra_lock_destroy (server_lock_main);
+#endif
     server_lock_main = 0;
 }
 
-int zebraIndexLock (BFiles bfs, int commitNow, const char *rval)
+int zebraIndexLock (BFiles bfs, ZebraHandle zh, int commitNow,
+                    const char *rval)
 {
     char path[1024];
     char buf[256];
@@ -192,7 +206,7 @@ int zebraIndexLock (BFiles bfs, int commitNow, const char *rval)
     if (server_lock_main)
         return 0;
 
-    zebra_lock_prefix (common_resource, path);
+    zebra_lock_prefix (zh->service->res, path);
     strcat (path, FNAME_MAIN_LOCK);
     while (1)
     {