Back-ported the rsbetween from zebra 1.4

[idzebra-moved-to-github.git] / index / zserver.c

diff --git a/index/zserver.c b/index/zserver.c
index 3ba03d9..df9b589 100644 (file)
--- a/index/zserver.c
+++ b/index/zserver.c
@@ -1,4 +1,4 @@
-/* $Id: zserver.c,v 1.115 2004-05-05 16:22:18 mike Exp $
+/* $Id: zserver.c,v 1.117.2.1 2004-08-13 09:56:29 adam Exp $
    Copyright (C) 1995,1996,1997,1998,1999,2000,2001,2002,2003,2004
    Index Data Aps
 
@@ -383,6 +383,10 @@ int bend_delete (void *handle, bend_delete_rr *rr)
 
 static int es_admin_request (ZebraHandle zh, Z_AdminEsRequest *r)
 {
+    if (r->toKeep->databaseName)
+    {
+       yaz_log(LOG_LOG, "adm request database %s", r->toKeep->databaseName);
+    }
     switch (r->toKeep->which)
     {
     case Z_ESAdminOriginPartToKeep_reIndex:
@@ -409,6 +413,9 @@ static int es_admin_request (ZebraHandle zh, Z_AdminEsRequest *r)
        break;
     case Z_ESAdminOriginPartToKeep_commit:
        yaz_log(LOG_LOG, "adm-commit");
+       if (r->toKeep->databaseName)
+           zebra_select_database(zh, r->toKeep->databaseName);
+       zebra_commit(zh);
        break;
     case Z_ESAdminOriginPartToKeep_shutdown:
        yaz_log(LOG_LOG, "shutdown");
@@ -421,10 +428,6 @@ static int es_admin_request (ZebraHandle zh, Z_AdminEsRequest *r)
     default:
        yaz_log(LOG_LOG, "unknown admin");
     }
-    if (r->toKeep->databaseName)
-    {
-       yaz_log(LOG_LOG, "database %s", r->toKeep->databaseName);
-    }
     return 0;
 }
 
@@ -638,9 +641,11 @@ int bend_esrequest (void *handle, bend_esrequest_rr *rr)
                                    0, /* match */
                                    0, /* fname */
                                    rec->u.octet_aligned->buf,
-                                   rec->u.octet_aligned->len);
+                                   rec->u.octet_aligned->len,
+                                   0);
                                if (r)
                                {
+                                   yaz_log(LOG_WARN, "zebra_insert_record failed r=%d", r);
                                    rr->errcode = 224;
                                    rr->errstring = "insert_record failed";
                                }
@@ -658,8 +663,10 @@ int bend_esrequest (void *handle, bend_esrequest_rr *rr)
                                    1);
                                if (r)
                                {
+                                   yaz_log(LOG_WARN, "zebra_update_record failed r=%d", r);
                                    rr->errcode = 224;
-                                   rr->errstring = "update_record failed";
+                                   rr->errstring = 
+                                       "update_record failed";
                                }
                                break;
                            case 3:
@@ -674,6 +681,7 @@ int bend_esrequest (void *handle, bend_esrequest_rr *rr)
                                    0);
                                if (r)
                                {
+                                   yaz_log(LOG_WARN, "zebra_delete_record failed r=%d", r);
                                    rr->errcode = 224;
                                    rr->errstring = "delete_record failed";
                                }
@@ -700,7 +708,7 @@ static void bend_start (struct statserv_options_block *sob)
 {
     if (sob->handle)
        zebra_stop((ZebraService) sob->handle);
-    sob->handle = zebra_start(sob->configname, 0, 0);
+    sob->handle = zebra_start(sob->configname);
     if (!sob->handle)
     {
        yaz_log (LOG_FATAL, "Failed to read config `%s'", sob->configname);