X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=index%2Fzserver.c;h=85ff5d9a3de8eb4f9980a5c1219082c8f3e6e5a6;hb=8ddf739043beb068cac9287afa88ea92bf4d3ed6;hp=8aabcfaee08ecf28654c49c31581e8e0af4b6218;hpb=45708f1b509a55d335b7711d967071446bde4ecb;p=idzebra-moved-to-github.git diff --git a/index/zserver.c b/index/zserver.c index 8aabcfa..85ff5d9 100644 --- a/index/zserver.c +++ b/index/zserver.c @@ -1,10 +1,44 @@ /* - * Copyright (C) 1995-1998, Index Data I/S + * Copyright (C) 1995-1999, Index Data * All rights reserved. * Sebastian Hammer, Adam Dickmeiss * * $Log: zserver.c,v $ - * Revision 1.57 1998-04-03 14:45:18 adam + * Revision 1.67 1999-02-02 14:51:14 adam + * Updated WIN32 code specific sections. Changed header. + * + * Revision 1.66 1998/10/28 10:54:41 adam + * SDRKit integration. + * + * Revision 1.65 1998/10/18 07:54:54 adam + * Additional info added for diagnostics 114 (Unsupported use attribute) and + * 121 (Unsupported attribute set). + * + * Revision 1.64 1998/09/22 10:48:21 adam + * Minor changes in search API. + * + * Revision 1.63 1998/09/02 13:53:21 adam + * Extra parameter decode added to search routines to implement + * persistent queries. + * + * Revision 1.62 1998/08/06 14:35:28 adam + * Routine bend_deleterequest removed. + * + * Revision 1.61 1998/06/24 12:16:15 adam + * Support for relations on text operands. Open range support in + * DFA module (i.e. [-j], [g-]). + * + * Revision 1.60 1998/06/22 11:36:49 adam + * Added authentication check facility to zebra. + * + * Revision 1.59 1998/06/12 12:22:13 adam + * Work on Zebra API. + * + * Revision 1.58 1998/05/27 16:57:46 adam + * Zebra returns surrogate diagnostic for single records when + * appropriate. + * + * Revision 1.57 1998/04/03 14:45:18 adam * Fixed setting of last_in_set in bend_fetch. * * Revision 1.56 1998/03/05 08:45:13 adam @@ -212,7 +246,7 @@ #include #include #include -#ifdef WINDOWS +#ifdef WIN32 #include #include #else @@ -224,6 +258,13 @@ #include "zserver.h" +#ifndef ZEBRASDR +#define ZEBRASDR 0 +#endif +#if ZEBRASDR +#include "zebrasdr.h" +#endif + static int bend_sort (void *handle, bend_sort_rr *rr); bend_initresult *bend_init (bend_initrequest *q) @@ -231,6 +272,8 @@ bend_initresult *bend_init (bend_initrequest *q) bend_initresult *r = odr_malloc (q->stream, sizeof(*r)); ZebraHandle zh; struct statserv_options_block *sob; + char *user = NULL; + char *passwd = NULL; r->errcode = 0; r->errstring = 0; @@ -239,12 +282,34 @@ bend_initresult *bend_init (bend_initrequest *q) logf (LOG_DEBUG, "bend_init"); sob = statserv_getcontrol (); - if (!(zh = zebra_open (NULL, sob->configname))) + if (!(zh = zebra_open (sob->configname))) { logf (LOG_FATAL, "Failed to open Zebra `%s'", sob->configname); r->errcode = 1; return r; } + if (q->auth) + { + if (q->auth->which == Z_IdAuthentication_open) + { + char *openpass = xstrdup (q->auth->u.open); + char *cp = strchr (openpass, '/'); + if (cp) + { + *cp = '\0'; + user = nmem_strdup (odr_getmem (q->stream), openpass); + passwd = nmem_strdup (odr_getmem (q->stream), cp+1); + } + xfree (openpass); + } + } + if (zebra_auth (zh, user, passwd)) + { + r->errcode = 222; + r->errstring = user; + zebra_close (zh); + return r; + } r->handle = zh; return r; } @@ -262,12 +327,16 @@ bend_searchresult *bend_search (void *handle, bend_searchrequest *q, int *fd) switch (q->query->which) { case Z_Query_type_1: case Z_Query_type_101: - zebra_search_rpn (zh, q->stream, q->query->u.type_1, + zebra_search_rpn (zh, q->decode, q->stream, q->query->u.type_1, q->num_bases, q->basenames, q->setname); r->errcode = zh->errCode; r->errstring = zh->errString; r->hits = zh->hits; break; + case Z_Query_type_2: + r->errcode = 107; + r->errstring = "type-2"; + break; default: r->errcode = 107; } @@ -285,13 +354,19 @@ bend_fetchresult *bend_fetch (void *handle, bend_fetchrequest *q, int *num) r->last_in_set = 0; zebra_records_retrieve (zh, q->stream, q->setname, q->comp, q->format, 1, &retrievalRecord); - - if (zh->errCode) + if (zh->errCode) /* non Surrogate Diagnostic */ { r->errcode = zh->errCode; r->errstring = zh->errString; } - else + else if (retrievalRecord.errCode) /* Surrogate Diagnostic */ + { + q->surrogate_flag = 1; + r->errcode = retrievalRecord.errCode; + r->errstring = retrievalRecord.errString; + r->basename = retrievalRecord.base; + } + else /* Database Record */ { r->errcode = 0; r->basename = retrievalRecord.base; @@ -302,11 +377,6 @@ bend_fetchresult *bend_fetch (void *handle, bend_fetchrequest *q, int *num) return r; } -bend_deleteresult *bend_delete (void *handle, bend_deleterequest *q, int *num) -{ - return 0; -} - bend_scanresult *bend_scan (void *handle, bend_scanrequest *q, int *num) { ZebraScanEntry *entries; @@ -346,14 +416,15 @@ int bend_sort (void *handle, bend_sort_rr *rr) { ZebraHandle zh = handle; - zebra_sort (zh, rr->stream, rr->num_input_setnames, rr->input_setnames, + zebra_sort (zh, rr->stream, + rr->num_input_setnames, (const char **) rr->input_setnames, rr->output_setname, rr->sort_sequence, &rr->sort_status); rr->errcode = zh->errCode; rr->errstring = zh->errString; return 0; } -#ifndef WINDOWS +#ifndef WIN32 static void pre_init (struct statserv_options_block *sob) { char *pidfile = "zebrasrv.pid"; @@ -378,10 +449,13 @@ int main (int argc, char **argv) sob = statserv_getcontrol (); strcpy (sob->configname, FNAME_CONFIG); -#ifndef WINDOWS +#ifndef WIN32 sob->pre_init = pre_init; #endif statserv_setcontrol (sob); +#if ZEBRASDR + zebraSdr_std (); +#endif return statserv_main (argc, argv); }