X-Git-Url: http://git.indexdata.com/?p=idzebra-moved-to-github.git;a=blobdiff_plain;f=index%2Fzebrasrv.c;h=25f2d27f1c3aafa8cb6455e1ac26fe5939715b90;hp=6ecbecf3473ef02612bfdabdb058eb203baceba9;hb=8174591e6c5c002acca0db83c4c46e1d0265a9e2;hpb=86702aad7008abed6afef80feed08b3e4e1cbcd1 diff --git a/index/zebrasrv.c b/index/zebrasrv.c index 6ecbecf..25f2d27 100644 --- a/index/zebrasrv.c +++ b/index/zebrasrv.c @@ -1,4 +1,4 @@ -/* $Id: zebrasrv.c,v 1.9 2007-01-17 15:35:48 adam Exp $ +/* $Id: zebrasrv.c,v 1.16 2007-05-21 11:54:59 adam Exp $ Copyright (C) 1995-2007 Index Data ApS @@ -85,6 +85,8 @@ bend_initresult *bend_init (bend_initrequest *q) return r; } r->handle = zh; + + q->query_charset = odr_strdup(q->stream, zebra_get_encoding(zh)); if (q->auth) { if (q->auth->which == Z_IdAuthentication_open) @@ -113,7 +115,7 @@ bend_initresult *bend_init (bend_initrequest *q) r->errstring = user; return r; } - if (q->charneg_request) /* characater set and langauge negotiation? */ + if (q->charneg_request) /* characater set and language negotiation? */ { char **charsets = 0; int num_charsets; @@ -123,11 +125,9 @@ bend_initresult *bend_init (bend_initrequest *q) int i; NMEM nmem = nmem_create(); - yaz_log (YLOG_LOG, "character set and language negotiation"); - - yaz_get_proposal_charneg (nmem, q->charneg_request, - &charsets, &num_charsets, - &langs, &num_langs, &selected); + yaz_get_proposal_charneg(nmem, q->charneg_request, + &charsets, &num_charsets, + &langs, &num_langs, &selected); for (i = 0; i < num_charsets; i++) { @@ -152,21 +152,21 @@ bend_initresult *bend_init (bend_initrequest *q) } else { right_name = charsets[i]; } - if (odr_set_charset (q->decode, "UTF-8", right_name) == 0) + if (odr_set_charset(q->decode, "UTF-8", right_name) == 0) { - yaz_log (YLOG_LOG, "charset %d %s (proper name %s): OK", i, - charsets[i], right_name); - odr_set_charset (q->stream, right_name, "UTF-8"); + yaz_log(YLOG_LOG, "charset %d %s (proper name %s): OK", i, + charsets[i], right_name); + odr_set_charset(q->stream, right_name, "UTF-8"); if (selected) zebra_record_encoding(zh, right_name); zebra_octet_term_encoding(zh, right_name); q->charneg_response = - yaz_set_response_charneg (q->stream, charsets[i], - 0, selected); + yaz_set_response_charneg(q->stream, charsets[i], + 0, selected); break; } else { - yaz_log (YLOG_LOG, "charset %d %s (proper name %s): unsupported", i, - charsets[i], right_name); + yaz_log(YLOG_LOG, "charset %d %s (proper name %s): unsupported", i, + charsets[i], right_name); } } nmem_destroy(nmem); @@ -197,8 +197,8 @@ static void search_terms(ZebraHandle zh, bend_search_rr *r) r->search_info->list[0]->which = Z_OtherInfo_externallyDefinedInfo; ext = odr_malloc (r->stream, sizeof(*ext)); r->search_info->list[0]->information.externallyDefinedInfo = ext; - ext->direct_reference = - yaz_oidval_to_z3950oid (r->stream, CLASS_USERINFO, VAL_SEARCHRES1); + ext->direct_reference = odr_oiddup(r->stream, + yaz_oid_userinfo_searchresult_1); ext->indirect_reference = 0; ext->descriptor = 0; ext->which = Z_External_searchResult1; @@ -314,7 +314,7 @@ int bend_search(void *handle, bend_search_rr *r) } -int bend_fetch (void *handle, bend_fetch_rr *r) +int bend_fetch(void *handle, bend_fetch_rr *r) { ZebraHandle zh = (ZebraHandle) handle; ZebraRetrievalRecord retrievalRecord; @@ -343,7 +343,7 @@ int bend_fetch (void *handle, bend_fetch_rr *r) r->basename = retrievalRecord.base; r->record = retrievalRecord.buf; r->len = retrievalRecord.len; - r->output_format = retrievalRecord.format; + r->output_format = odr_oiddup(r->stream, retrievalRecord.format); } return 0; } @@ -399,7 +399,6 @@ void bend_close (void *handle) { zebra_close ((ZebraHandle) handle); xmalloc_trav("bend_close"); - nmem_print_list(); } int bend_sort (void *handle, bend_sort_rr *rr) @@ -596,7 +595,6 @@ int bend_esrequest (void *handle, bend_esrequest_rr *rr) for (i = 0; notToKeep && i < notToKeep->num; i++) { Z_External *rec = notToKeep->elements[i]->record; - struct oident *oident = 0; Odr_oct *opaque_recid = 0; zint *sysno = 0; zint sysno_tmp; @@ -616,10 +614,14 @@ int bend_esrequest (void *handle, bend_esrequest_rr *rr) } if (rec->direct_reference) { - oident = oid_getentbyoid(rec->direct_reference); - if (oident) + char oid_name_str[OID_STR_MAX]; + const char *oid_name = + yaz_oid_to_string_buf( + rec->direct_reference, + 0, oid_name_str); + if (oid_name) yaz_log (YLOG_LOG, "record %d type %s", i, - oident->desc); + oid_name); } switch (rec->which) { @@ -643,111 +645,58 @@ int bend_esrequest (void *handle, bend_esrequest_rr *rr) rec->u.octet_aligned->len, rec->u.octet_aligned->buf); } - if (oident && oident->value != VAL_TEXT_XML - && oident->value != VAL_SUTRS) - { - rr->errcode = YAZ_BIB1_ES_IMMEDIATE_EXECUTION_FAILED; - rr->errstring = "only XML update supported"; - break; - } if (rec->which == Z_External_octet) { - int action = 0; + enum zebra_recctrl_action_t action = action_update; + char recid_str[256]; + const char *match_criteria = 0; + ZEBRA_RES res; if (*toKeep->action == Z_IUOriginPartToKeep_recordInsert) - action = 1; - if (*toKeep->action == + action = action_insert; + else if (*toKeep->action == Z_IUOriginPartToKeep_recordReplace) - action = 2; - if (*toKeep->action == + action = action_replace; + else if (*toKeep->action == Z_IUOriginPartToKeep_recordDelete) - action = 3; - if (*toKeep->action == + action = action_delete; + else if (*toKeep->action == Z_IUOriginPartToKeep_specialUpdate) - action = 4; - - if (!action) + action = action_update; + else { rr->errcode = YAZ_BIB1_ES_IMMEDIATE_EXECUTION_FAILED; rr->errstring = "unsupported ES Update action"; break; } - else if (opaque_recid) + + if (opaque_recid) { - int r = zebra_admin_exchange_record ( - zh, - (const char *) rec->u.octet_aligned->buf, - rec->u.octet_aligned->len, - (const char *) opaque_recid->buf, - opaque_recid->len, - action); - if (r) + size_t l = opaque_recid->len; + if (l >= sizeof(recid_str)) { - zebra_result(zh, &rr->errcode, - &rr->errstring); + rr->errcode = YAZ_BIB1_ES_IMMEDIATE_EXECUTION_FAILED; + rr->errstring = "opaque record ID too large"; break; } - } - else - { - ZEBRA_RES r = ZEBRA_FAIL; - switch(action) { - case 1: - r = zebra_insert_record( - zh, - 0, /* recordType */ - sysno, - 0, /* match */ - 0, /* fname */ - (const char *) rec->u.octet_aligned->buf, - rec->u.octet_aligned->len, - 0); - if (r == ZEBRA_FAIL) - { - rr->errcode = - YAZ_BIB1_ES_IMMEDIATE_EXECUTION_FAILED; - rr->errstring = "insert_record failed"; - } - break; - case 2: - case 4: - r = zebra_update_record( - zh, - 0, /* recordType */ - sysno, - 0, /* match */ - 0, /* fname */ - (const char *) rec->u.octet_aligned->buf, - rec->u.octet_aligned->len, - 1); - if (r == ZEBRA_FAIL) - { - rr->errcode = - YAZ_BIB1_ES_IMMEDIATE_EXECUTION_FAILED; - rr->errstring = "update_record failed"; - } - break; - case 3: - r = zebra_delete_record( - zh, - 0, /* recordType */ - sysno, - 0, /* match */ - 0, /* fname */ - (const char *) rec->u.octet_aligned->buf, - rec->u.octet_aligned->len, - 0); - if (r == ZEBRA_FAIL) - { - rr->errcode = - YAZ_BIB1_ES_IMMEDIATE_EXECUTION_FAILED; - rr->errstring = "delete_record failed"; - } - break; - } - } + memcpy(recid_str, opaque_recid->buf, l); + recid_str[l] = '\0'; + match_criteria = recid_str; + } + res = zebra_update_record( + zh, action, + 0, /* recordType */ + sysno, match_criteria, 0, /* fname */ + (const char *) rec->u.octet_aligned->buf, + rec->u.octet_aligned->len); + if (res == ZEBRA_FAIL) + { + rr->errcode = + YAZ_BIB1_ES_IMMEDIATE_EXECUTION_FAILED; + rr->errstring = "update_record failed"; + } } } if (zebra_end_trans (zh) != ZEBRA_OK) @@ -776,7 +725,7 @@ static void bend_start (struct statserv_options_block *sob) zebra_stop((ZebraService) sob->handle); res_set(default_res, "profilePath", DEFAULT_PROFILE_PATH); res_set(default_res, "modulePath", DEFAULT_MODULE_PATH); - sob->handle = zebra_start(sob->configname); + sob->handle = zebra_start_res(sob->configname, default_res, 0); res_close(default_res); if (!sob->handle) {