X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;ds=sidebyside;f=index%2Fzserver.c;h=b4d6b898eb5ddd413219739f7c4d45bc61ca0a7e;hb=1aa248f52f0b5c72155a8f8423122a4b89bf3394;hp=5f2147bf2f8b750f4cfac4a891862341bc7641a3;hpb=523c53e5f1fd1e24828dc4a6979d34987241fe43;p=idzebra-moved-to-github.git

diff --git a/index/zserver.c b/index/zserver.c
index 5f2147b..b4d6b89 100644
--- a/index/zserver.c
+++ b/index/zserver.c
@@ -1,5 +1,5 @@
-/* $Id: zserver.c,v 1.102 2003-01-13 15:06:23 adam Exp $
-   Copyright (C) 1995,1996,1997,1998,1999,2000,2001,2002
+/* $Id: zserver.c,v 1.111 2003-09-05 12:35:06 adam Exp $
+   Copyright (C) 1995,1996,1997,1998,1999,2000,2001,2002,2003
    Index Data Aps
 
 This file is part of the Zebra server.
@@ -20,20 +20,23 @@ Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA
 02111-1307, USA.
 */
 
-
-
 #include <stdio.h>
 #include <assert.h>
 #include <fcntl.h>
 #ifdef WIN32
 #include <io.h>
 #include <process.h>
+#include <sys/locking.h>
 #else
 #include <unistd.h>
 #endif
 
+#include <errno.h>
 #include <yaz/log.h>
 #include <yaz/ill.h>
+#include <yaz/yaz-util.h>
+
+#include <sys/types.h>
 
 #include "zserver.h"
 
@@ -261,7 +264,7 @@ int bend_search (void *handle, bend_search_rr *r)
     switch (r->query->which)
     {
     case Z_Query_type_1: case Z_Query_type_101:
-	zebra_search_rpn (zh, r->decode, r->stream, r->query->u.type_1,
+	zebra_search_RPN (zh, r->stream, r->query->u.type_1,
 			  r->setname, &r->hits);
         zebra_result (zh, &r->errcode, &r->errstring);
         if (!r->errcode)
@@ -379,10 +382,11 @@ static int es_admin_request (ZebraHandle zh, Z_AdminEsRequest *r)
 	break;
     case Z_ESAdminOriginPartToKeep_drop:
 	yaz_log(LOG_LOG, "adm-drop");
+	zebra_drop_database (zh, r->toKeep->databaseName);
 	break;
     case Z_ESAdminOriginPartToKeep_create:
 	yaz_log(LOG_LOG, "adm-create %s", r->toKeep->databaseName);
-	zebra_admin_create (zh, r->toKeep->databaseName);
+	zebra_create_database (zh, r->toKeep->databaseName);
 	break;
     case Z_ESAdminOriginPartToKeep_import:
 	yaz_log(LOG_LOG, "adm-import");
@@ -518,7 +522,7 @@ int bend_esrequest (void *handle, bend_esrequest_rr *rr)
 	    if (notToKeep)
 	    {
 		int i;
-                zebra_begin_trans (zh);
+                zebra_begin_trans (zh, 1);
 		for (i = 0; i < notToKeep->num; i++)
 		{
 		    Z_External *rec = notToKeep->elements[i]->record;
@@ -640,33 +644,57 @@ int bend_esrequest (void *handle, bend_esrequest_rr *rr)
 
 static void bend_start (struct statserv_options_block *sob)
 {
+    if (sob->handle)
+	zebra_stop((ZebraService) sob->handle);
+    sob->handle = zebra_start(sob->configname);
+    if (!sob->handle)
+    {
+	yaz_log (LOG_FATAL, "Failed to read config `%s'", sob->configname);
+	exit (1);
+    }
 #ifdef WIN32
     
 #else
     if (!sob->inetd) 
     {
-        char *pidfile = "zebrasrv.pid";
-        int fd = creat (pidfile, 0666);
+	char pidfname[4096];
+        struct flock area;
+	int fd;
+
+	zebra_pidfname(sob->handle, pidfname);
+
+        fd = open (pidfname, O_EXCL|O_WRONLY|O_CREAT, 0666);
         if (fd == -1)
-            yaz_log (LOG_WARN|LOG_ERRNO, "creat %s", pidfile);
+        {
+            if (errno != EEXIST)
+            {
+                yaz_log(LOG_FATAL|LOG_ERRNO, "lock file %s", pidfname);
+                exit(1);
+            }
+            fd = open(pidfname, O_RDWR, 0666);
+            if (fd == -1)
+            {
+                yaz_log(LOG_FATAL|LOG_ERRNO, "lock file %s", pidfname);
+                exit(1);
+            }
+        }
+        area.l_type = F_WRLCK;
+        area.l_whence = SEEK_SET;
+        area.l_len = area.l_start = 0L;
+        if (fcntl (fd, F_SETLK, &area) == -1)
+        {
+            yaz_log(LOG_ERRNO|LOG_FATAL, "Zebra server already running");
+            exit(1);
+        }
         else
         {
 	    char pidstr[30];
 	
 	    sprintf (pidstr, "%ld", (long) getpid ());
 	    write (fd, pidstr, strlen(pidstr));
-	    close (fd);
         }
     }
 #endif
-    if (sob->handle)
-	zebra_stop((ZebraService) sob->handle);
-    sob->handle = zebra_start(sob->configname);
-    if (!sob->handle)
-    {
-	yaz_log (LOG_FATAL, "Failed to read config `%s'", sob->configname);
-	exit (1);
-    }
 }
 
 static void bend_stop(struct statserv_options_block *sob)
@@ -674,8 +702,12 @@ static void bend_stop(struct statserv_options_block *sob)
 #ifdef WIN32
 
 #else
-    if (!sob->inetd) 
-        unlink ("zebrasrv.pid");
+    if (!sob->inetd && sob->handle) 
+    {
+	char pidfname[4096];
+	zebra_pidfname(sob->handle, pidfname);
+        unlink (pidfname);
+    }
 #endif
     if (sob->handle)
     {