X-Git-Url: http://git.indexdata.com/?p=idzebra-moved-to-github.git;a=blobdiff_plain;f=index%2Fzebraapi.c;h=d53606415ed88db93f2df5082cb40bd7cdbbbb4a;hp=b4283b59f2551b9d28fcea2fb94bffa0dd051517;hb=810bce66201f40acfd7e8577d3997e6ea385f1cf;hpb=2da0f67191a2222daaecab6892082777b77b37f3 diff --git a/index/zebraapi.c b/index/zebraapi.c index b4283b5..d536064 100644 --- a/index/zebraapi.c +++ b/index/zebraapi.c @@ -1,4 +1,4 @@ -/* $Id: zebraapi.c,v 1.165 2005-05-06 18:59:35 adam Exp $ +/* $Id: zebraapi.c,v 1.175 2005-06-09 10:39:53 adam Exp $ Copyright (C) 1995-2005 Index Data ApS @@ -69,7 +69,7 @@ static void zebra_flush_reg (ZebraHandle zh) { ASSERTZH; yaz_log(log_level, "zebra_flush_reg"); - zh->errCode = 0; + zebra_clearError(zh); zebraExplain_flush (zh->reg->zei, zh); extract_flushWriteKeys (zh, 1 /* final */); @@ -115,6 +115,7 @@ ZebraHandle zebra_open (ZebraService zs) zh->num_basenames = 0; zh->basenames = 0; + zh->approx_limit = 1000000000; zh->trans_no = 0; zh->trans_w_no = 0; @@ -147,7 +148,9 @@ ZebraHandle zebra_open (ZebraService zs) zh->store_data_buf = 0; - zh->m_limit = zebra_limit_create(0, 0); + zh->m_limit = zebra_limit_create(1, 0); + + zh->nmem_error = nmem_create(); return zh; } @@ -167,11 +170,13 @@ ZebraService zebra_start_res (const char *configName, Res def_res, Res over_res) log_level_initialized = 1; } - yaz_log(log_level, "zebra_start %s",configName); + yaz_log(YLOG_LOG, "zebra_start %s %s",configName, ZEBRAVER); assert(configName); if ((res = res_open (configName, def_res, over_res))) { + const char *passwd_plain = 0; + const char *passwd_encrypt = 0; ZebraService zh = xmalloc(sizeof(*zh)); yaz_log (YLOG_DEBUG, "Read resources `%s'", configName); @@ -183,16 +188,23 @@ ZebraService zebra_start_res (const char *configName, Res def_res, Res over_res) zebra_chdir (zh); zebra_mutex_cond_init (&zh->session_lock); - if (!res_get (zh->global_res, "passwd")) + passwd_plain = res_get (zh->global_res, "passwd"); + passwd_encrypt = res_get (zh->global_res, "passwd.c"); + + if (!passwd_plain && !passwd_encrypt) zh->passwd_db = NULL; else { - zh->passwd_db = passwd_db_open (); + zh->passwd_db = passwd_db_open(); if (!zh->passwd_db) yaz_log (YLOG_WARN|YLOG_ERRNO, "passwd_db_open failed"); else - passwd_db_file (zh->passwd_db, - res_get (zh->global_res, "passwd")); + { + if (passwd_plain) + passwd_db_file_plain(zh->passwd_db, passwd_plain); + if (passwd_encrypt) + passwd_db_file_crypt(zh->passwd_db, passwd_encrypt); + } } zh->path_root = res_get (zh->global_res, "root"); zh->nmem = nmem_create(); @@ -266,15 +278,27 @@ struct zebra_register *zebra_register_open (ZebraService zs, const char *name, reg->dh = data1_createx (DATA1_FLAG_XML); if (!reg->dh) + { + xfree(reg); return 0; + } reg->bfs = bfs_create (res_get (res, "register"), reg_path); if (!reg->bfs) { data1_destroy(reg->dh); + xfree(reg); return 0; } if (useshadow) - bf_cache (reg->bfs, res_get (res, "shadow")); + { + if (bf_cache (reg->bfs, res_get (res, "shadow")) == ZEBRA_FAIL) + { + bfs_destroy(reg->bfs); + data1_destroy(reg->dh); + xfree(reg); + return 0; + } + } getcwd(cwd, sizeof(cwd)-1); profilePath = res_get_def(res, "profilePath", DEFAULT_PROFILE_PATH); @@ -406,7 +430,7 @@ ZEBRA_RES zebra_admin_shutdown (ZebraHandle zh) { ASSERTZH; yaz_log(log_level, "zebra_admin_shutdown"); - zh->errCode = 0; + zebra_clearError(zh); zebra_mutex_cond_lock (&zh->service->session_lock); zh->service->stop_flag = 1; @@ -419,7 +443,7 @@ ZEBRA_RES zebra_admin_start (ZebraHandle zh) ZebraService zs; ASSERTZH; yaz_log(log_level, "zebra_admin_start"); - zh->errCode = 0; + zebra_clearError(zh); zs = zh->service; zebra_mutex_cond_lock (&zs->session_lock); zebra_mutex_cond_unlock (&zs->session_lock); @@ -540,6 +564,8 @@ ZEBRA_RES zebra_close (ZebraHandle zh) zebra_limit_destroy(zh->m_limit); + nmem_destroy(zh->nmem_error); + xfree(zh->path_reg); xfree(zh); return ZEBRA_OK; @@ -665,8 +691,6 @@ static void zebra_select_register (ZebraHandle zh, const char *new_reg) zh->lock_shadow = 0; } zebra_close_res(zh); - - return -1; } } } @@ -728,8 +752,6 @@ void map_basenames (ZebraHandle zh, ODR stream, yaz_log(log_level, "map_basenames "); assert(stream); - zh->errCode = 0; - info.zh = zh; info.num_bases = *num_bases; @@ -759,7 +781,6 @@ ZEBRA_RES zebra_select_database (ZebraHandle zh, const char *basename) ASSERTZH; yaz_log(log_level, "zebra_select_database %s",basename); assert(basename); - zh->errCode = 0; return zebra_select_databases (zh, 1, &basename); } @@ -844,6 +865,12 @@ ZEBRA_RES zebra_select_databases (ZebraHandle zh, int num_bases, return ZEBRA_OK; } +ZEBRA_RES zebra_set_approx_limit(ZebraHandle zh, zint approx_limit) +{ + zh->approx_limit = approx_limit; + return ZEBRA_OK; +} + ZEBRA_RES zebra_search_RPN(ZebraHandle zh, ODR o, Z_RPNQuery *query, const char *setname, zint *hits) { @@ -854,7 +881,7 @@ ZEBRA_RES zebra_search_RPN(ZebraHandle zh, ODR o, Z_RPNQuery *query, assert(hits); assert(setname); yaz_log(log_level, "zebra_search_rpn"); - zh->errCode = 0; + zebra_clearError(zh); zh->hits = 0; *hits = 0; @@ -868,11 +895,11 @@ ZEBRA_RES zebra_search_RPN(ZebraHandle zh, ODR o, Z_RPNQuery *query, return r; } -ZEBRA_RES zebra_records_retrieve (ZebraHandle zh, ODR stream, - const char *setname, - Z_RecordComposition *comp, - oid_value input_format, int num_recs, - ZebraRetrievalRecord *recs) +ZEBRA_RES zebra_records_retrieve(ZebraHandle zh, ODR stream, + const char *setname, + Z_RecordComposition *comp, + oid_value input_format, int num_recs, + ZebraRetrievalRecord *recs) { ZebraMetaRecord *poset; int i; @@ -885,17 +912,15 @@ ZEBRA_RES zebra_records_retrieve (ZebraHandle zh, ODR stream, assert(num_recs>0); yaz_log(log_level, "zebra_records_retrieve n=%d", num_recs); - zh->errCode = 0; + zebra_clearError(zh); if (!zh->res) { - zh->errCode = YAZ_BIB1_SPECIFIED_RESULT_SET_DOES_NOT_EXIST; - zh->errString = odr_strdup(stream, setname); + zebra_setError(zh, YAZ_BIB1_SPECIFIED_RESULT_SET_DOES_NOT_EXIST, + setname); return ZEBRA_FAIL; } - zh->errCode = 0; - if (zebra_begin_read (zh) == ZEBRA_FAIL) return ZEBRA_FAIL; @@ -906,8 +931,8 @@ ZEBRA_RES zebra_records_retrieve (ZebraHandle zh, ODR stream, if (!poset) { yaz_log (YLOG_DEBUG, "zebraPosSetCreate error"); - zh->errCode = YAZ_BIB1_SPECIFIED_RESULT_SET_DOES_NOT_EXIST; - zh->errString = nmem_strdup (stream->mem, setname); + zebra_setError(zh, YAZ_BIB1_SPECIFIED_RESULT_SET_DOES_NOT_EXIST, + setname); ret = ZEBRA_FAIL; } else @@ -926,11 +951,18 @@ ZEBRA_RES zebra_records_retrieve (ZebraHandle zh, ODR stream, { char *buf; int len; + zebra_snippets *hit_snippet = zebra_snippets_create(); + + zebra_snippets_hit_vector(zh, setname, poset[i].sysno, + hit_snippet); + recs[i].errCode = zebra_record_fetch(zh, poset[i].sysno, poset[i].score, + hit_snippet, stream, input_format, comp, &recs[i].format, &buf, &len, &recs[i].base, &recs[i].errString); + recs[i].len = len; if (len > 0) { @@ -941,14 +973,14 @@ ZEBRA_RES zebra_records_retrieve (ZebraHandle zh, ODR stream, recs[i].buf = buf; recs[i].score = poset[i].score; recs[i].sysno = poset[i].sysno; + zebra_snippets_destroy(hit_snippet); } else { - char num_str[20]; - - sprintf (num_str, ZINT_FORMAT, pos_array[i]); - zh->errCode = YAZ_BIB1_PRESENT_REQUEST_OUT_OF_RANGE; - zh->errString = odr_strdup (stream, num_str); + if (ret == ZEBRA_OK) /* only need to set it once */ + zebra_setError_zint(zh, + YAZ_BIB1_PRESENT_REQUEST_OUT_OF_RANGE, + pos_array[i]); ret = ZEBRA_FAIL; break; } @@ -982,11 +1014,11 @@ ZEBRA_RES zebra_scan_PQF(ZebraHandle zh, ODR stream, const char *query, return res; } -ZEBRA_RES zebra_scan (ZebraHandle zh, ODR stream, Z_AttributesPlusTerm *zapt, - oid_value attributeset, - int *position, - int *num_entries, ZebraScanEntry **entries, - int *is_partial) +ZEBRA_RES zebra_scan(ZebraHandle zh, ODR stream, Z_AttributesPlusTerm *zapt, + oid_value attributeset, + int *position, + int *num_entries, ZebraScanEntry **entries, + int *is_partial) { ZEBRA_RES res; ASSERTZH; @@ -997,7 +1029,7 @@ ZEBRA_RES zebra_scan (ZebraHandle zh, ODR stream, Z_AttributesPlusTerm *zapt, assert(is_partial); assert(entries); yaz_log(log_level, "zebra_scan"); - zh->errCode = 0; + zebra_clearError(zh); if (zebra_begin_read (zh) == ZEBRA_FAIL) { *entries = 0; @@ -1017,6 +1049,7 @@ ZEBRA_RES zebra_sort (ZebraHandle zh, ODR stream, Z_SortKeySpecList *sort_sequence, int *sort_status) { + ZEBRA_RES res; ASSERTZH; assert(stream); assert(num_input_setnames>0); @@ -1024,12 +1057,13 @@ ZEBRA_RES zebra_sort (ZebraHandle zh, ODR stream, assert(sort_sequence); assert(sort_status); yaz_log(log_level, "zebra_sort"); - zh->errCode = 0; - if (zebra_begin_read (zh) == ZEBRA_FAIL) + zebra_clearError(zh); + if (zebra_begin_read(zh) == ZEBRA_FAIL) return ZEBRA_FAIL; - resultSetSort (zh, stream->mem, num_input_setnames, input_setnames, - output_setname, sort_sequence, sort_status); - return zebra_end_read(zh); + res = resultSetSort(zh, stream->mem, num_input_setnames, input_setnames, + output_setname, sort_sequence, sort_status); + zebra_end_read(zh); + return res; } int zebra_deleteResultSet(ZebraHandle zh, int function, @@ -1040,7 +1074,7 @@ int zebra_deleteResultSet(ZebraHandle zh, int function, ASSERTZH; assert(statuses); yaz_log(log_level, "zebra_deleteResultSet n=%d",num_setnames); - zh->errCode = 0; + zebra_clearError(zh);; if (zebra_begin_read(zh)) return Z_DeleteStatus_systemProblemAtTarget; switch (function) @@ -1075,7 +1109,7 @@ int zebra_errCode (ZebraHandle zh) const char *zebra_errString (ZebraHandle zh) { - const char *e=""; + const char *e = 0; if (zh) e= diagbib1_str (zh->errCode); yaz_log(log_level, "zebra_errString: %s",e); @@ -1084,7 +1118,7 @@ const char *zebra_errString (ZebraHandle zh) char *zebra_errAdd (ZebraHandle zh) { - char *a=""; + char *a = 0; if (zh) a= zh->errString; yaz_log(log_level, "zebra_errAdd: %s",a); @@ -1107,7 +1141,7 @@ ZEBRA_RES zebra_auth (ZebraHandle zh, const char *user, const char *pass) ZebraService zs; ASSERTZH; - zh->errCode = 0; + zebra_clearError(zh); zs= zh->service; sprintf(u, "perm.%.30s", user ? user : "anonymous"); @@ -1130,7 +1164,7 @@ ZEBRA_RES zebra_admin_import_begin (ZebraHandle zh, const char *database, ASSERTZH; yaz_log(log_level, "zebra_admin_import_begin db=%s rt=%s", database, record_type); - zh->errCode = 0; + zebra_clearError(zh); if (zebra_select_database(zh, database) == ZEBRA_FAIL) return ZEBRA_FAIL; return zebra_begin_trans(zh, 1); @@ -1140,7 +1174,7 @@ ZEBRA_RES zebra_admin_import_end (ZebraHandle zh) { ASSERTZH; yaz_log(log_level, "zebra_admin_import_end"); - zh->errCode = 0; + zebra_clearError(zh); return zebra_end_trans(zh); } @@ -1151,7 +1185,7 @@ ZEBRA_RES zebra_admin_import_segment (ZebraHandle zh, Z_Segment *segment) int i; ASSERTZH; yaz_log(log_level, "zebra_admin_import_segment"); - zh->errCode = 0; + zebra_clearError(zh); for (i = 0; inum_segmentRecords; i++) { Z_NamePlusRecord *npr = segment->segmentRecords[i]; @@ -1197,7 +1231,7 @@ ZEBRA_RES zebra_admin_exchange_record (ZebraHandle zh, assert(rec_buf); yaz_log(log_level, "zebra_admin_exchange_record ac=%d", action); - zh->errCode = 0; + zebra_clearError(zh); if (!recid_buf || recid_len <= 0 || recid_len >= sizeof(recid_z)) return ZEBRA_FAIL; @@ -1279,20 +1313,20 @@ static int delete_SU_handle(void *handle, int ord) return 0; } -ZEBRA_RES zebra_drop_database (ZebraHandle zh, const char *database) +ZEBRA_RES zebra_drop_database(ZebraHandle zh, const char *db) { ZEBRA_RES ret = ZEBRA_OK; ASSERTZH; - yaz_log(log_level, "zebra_drop_database"); - zh->errCode = 0; + yaz_log(log_level, "zebra_drop_database %s", db); + zebra_clearError(zh); - if (zebra_select_database (zh, database) == ZEBRA_FAIL) + if (zebra_select_database (zh, db) == ZEBRA_FAIL) return ZEBRA_FAIL; if (zebra_begin_trans (zh, 1) == ZEBRA_FAIL) return ZEBRA_FAIL; if (zh->reg->isamb) { - zebraExplain_curDatabase (zh->reg->zei, database); + zebraExplain_curDatabase (zh->reg->zei, db); zebraExplain_trav_ord(zh->reg->zei, zh, delete_SU_handle); zebraExplain_removeDatabase(zh->reg->zei, zh); @@ -1306,25 +1340,24 @@ ZEBRA_RES zebra_drop_database (ZebraHandle zh, const char *database) return ret; } -ZEBRA_RES zebra_create_database (ZebraHandle zh, const char *database) +ZEBRA_RES zebra_create_database (ZebraHandle zh, const char *db) { ASSERTZH; - yaz_log(log_level, "zebra_create_database %s", database); - assert(database); - zh->errCode = 0; + yaz_log(log_level, "zebra_create_database %s", db); + assert(db); + zebra_clearError(zh); - if (zebra_select_database (zh, database) == ZEBRA_FAIL) + if (zebra_select_database (zh, db) == ZEBRA_FAIL) return ZEBRA_FAIL; if (zebra_begin_trans (zh, 1)) return ZEBRA_FAIL; /* announce database */ - if (zebraExplain_newDatabase (zh->reg->zei, database, 0 + if (zebraExplain_newDatabase (zh->reg->zei, db, 0 /* explainDatabase */)) { zebra_end_trans (zh); - zh->errCode = YAZ_BIB1_ES_IMMEDIATE_EXECUTION_FAILED; - zh->errString = "database already exist"; + zebra_setError(zh, YAZ_BIB1_ES_IMMEDIATE_EXECUTION_FAILED, db); return ZEBRA_FAIL; } return zebra_end_trans (zh); @@ -1339,7 +1372,7 @@ int zebra_string_norm (ZebraHandle zh, unsigned reg_id, assert(input_str); assert(output_str); yaz_log(log_level, "zebra_string_norm "); - zh->errCode = 0; + zebra_clearError(zh); if (!zh->reg->zebra_maps) return -1; wrbuf = zebra_replace(zh->reg->zebra_maps, reg_id, "", @@ -1362,7 +1395,7 @@ static void zebra_set_state (ZebraHandle zh, int val, int seqno) FILE *f; ASSERTZH; yaz_log(log_level, "zebra_set_state v=%d seq=%d", val, seqno); - zh->errCode = 0; + zebra_clearError(zh); sprintf (state_fname, "state.%s.LCK", zh->reg_name); fname = zebra_mk_fname (res_get(zh->res, "lockDir"), state_fname); @@ -1382,7 +1415,7 @@ static void zebra_get_state (ZebraHandle zh, char *val, int *seqno) ASSERTZH; yaz_log(log_level, "zebra_get_state "); - zh->errCode = 0; + zebra_clearError(zh); sprintf (state_fname, "state.%s.LCK", zh->reg_name); fname = zebra_mk_fname (res_get(zh->res, "lockDir"), state_fname); f = fopen (fname, "r"); @@ -1442,8 +1475,8 @@ ZEBRA_RES zebra_begin_trans(ZebraHandle zh, int rw) zebra_select_default_database(zh); if (!zh->res) { - zh->errCode = YAZ_BIB1_TEMPORARY_SYSTEM_ERROR; - zh->errString = "zebra_begin_trans: no database selected"; + zebra_setError(zh, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, + "zebra_begin_trans: no database selected"); return ZEBRA_FAIL; } ASSERTZHRES; @@ -1453,9 +1486,10 @@ ZEBRA_RES zebra_begin_trans(ZebraHandle zh, int rw) { if (rw && !strchr(zh->user_perm, 'w')) { - zh->errCode = - YAZ_BIB1_ES_PERMISSION_DENIED_ON_ES_CANNOT_MODIFY_OR_DELETE; - zh->errString = 0; + zebra_setError( + zh, + YAZ_BIB1_ES_PERMISSION_DENIED_ON_ES_CANNOT_MODIFY_OR_DELETE, + 0); return ZEBRA_FAIL; } } @@ -1476,8 +1510,8 @@ ZEBRA_RES zebra_begin_trans(ZebraHandle zh, int rw) } if (zh->trans_no != 1) { - zh->errCode = YAZ_BIB1_TEMPORARY_SYSTEM_ERROR; - zh->errString = "zebra_begin_trans: write trans not allowed within read trans"; + zebra_setError(zh, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, + "zebra_begin_trans: no write trans within read"); return ZEBRA_FAIL; } if (zh->reg) @@ -1487,7 +1521,7 @@ ZEBRA_RES zebra_begin_trans(ZebraHandle zh, int rw) } zh->trans_w_no = zh->trans_no; - zh->errCode = 0; + zebra_clearError(zh); zh->records_inserted = 0; zh->records_updated = 0; @@ -1563,9 +1597,9 @@ ZEBRA_RES zebra_begin_trans(ZebraHandle zh, int rw) zh->trans_no--; zh->trans_w_no = 0; - zh->errCode = YAZ_BIB1_TEMPORARY_SYSTEM_ERROR; - zh->errString = "zebra_begin_trans: cannot open register"; - yaz_log(YLOG_FATAL, zh->errString); + zebra_setError(zh, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, + "zebra_begin_trans: cannot open register"); + yaz_log(YLOG_FATAL, "%s", zh->errString); return ZEBRA_FAIL; } } @@ -1582,7 +1616,7 @@ ZEBRA_RES zebra_begin_trans(ZebraHandle zh, int rw) zebra_flush_reg (zh); return ZEBRA_OK; } - zh->errCode = 0; + zebra_clearError(zh); #if HAVE_SYS_TIMES_H times (&zh->tms1); #endif @@ -1674,8 +1708,8 @@ ZEBRA_RES zebra_end_transaction (ZebraHandle zh, ZebraTransactionStatus *status) if (!zh->res || !zh->reg) { - zh->errCode = YAZ_BIB1_TEMPORARY_SYSTEM_ERROR; - zh->errString = "zebra_end_trans: no open transaction"; + zebra_setError(zh, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, + "zebra_end_trans: no open transaction"); return ZEBRA_FAIL; } if (zh->trans_no != zh->trans_w_no) @@ -1748,7 +1782,7 @@ int zebra_repository_update (ZebraHandle zh, const char *path) { ASSERTZH; assert(path); - zh->errCode = 0; + zebra_clearError(zh); yaz_log (log_level, "updating %s", path); repositoryUpdate (zh, path); return zh->errCode; @@ -1758,7 +1792,7 @@ int zebra_repository_delete (ZebraHandle zh, const char *path) { ASSERTZH; assert(path); - zh->errCode = 0; + zebra_clearError(zh); yaz_log (log_level, "deleting %s", path); repositoryDelete (zh, path); return zh->errCode; @@ -1769,7 +1803,7 @@ int zebra_repository_show (ZebraHandle zh, const char *path) ASSERTZH; assert(path); yaz_log(log_level, "zebra_repository_show"); - zh->errCode = 0; + zebra_clearError(zh); repositoryShow (zh, path); return zh->errCode; } @@ -1781,7 +1815,7 @@ static int zebra_commit_ex(ZebraHandle zh, int clean_only) const char *rval; BFiles bfs; ASSERTZH; - zh->errCode = 0; + zebra_clearError(zh); zebra_select_default_database(zh); if (!zh->res) @@ -1855,19 +1889,23 @@ ZEBRA_RES zebra_init(ZebraHandle zh) BFiles bfs = 0; ASSERTZH; yaz_log(log_level, "zebra_init"); - zh->errCode = 0; + zebra_clearError(zh); zebra_select_default_database(zh); if (!zh->res) { - zh->errCode = YAZ_BIB1_DATABASE_UNAVAILABLE; + zebra_setError(zh, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, + "cannot select default database"); return ZEBRA_FAIL; } rval = res_get (zh->res, "shadow"); bfs = bfs_create (res_get (zh->res, "register"), zh->path_reg); if (!bfs) + { + zebra_setError(zh, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, "bfs_create"); return ZEBRA_FAIL; + } if (rval && *rval) bf_cache (bfs, rval); @@ -1882,7 +1920,7 @@ ZEBRA_RES zebra_compact(ZebraHandle zh) BFiles bfs; ASSERTZH; yaz_log(log_level, "zebra_compact"); - zh->errCode = 0; + zebra_clearError(zh); if (!zh->res) { zh->errCode = YAZ_BIB1_DATABASE_UNAVAILABLE; @@ -1906,7 +1944,7 @@ void zebra_shadow_enable(ZebraHandle zh, int value) { ASSERTZH; yaz_log(log_level, "zebra_shadow_enable"); - zh->errCode = 0; + zebra_clearError(zh); zh->shadow_enable = value; } @@ -1915,7 +1953,7 @@ ZEBRA_RES zebra_octet_term_encoding(ZebraHandle zh, const char *encoding) ASSERTZH; assert(encoding); yaz_log(log_level, "zebra_octet_term_encoding"); - zh->errCode = 0; + zebra_clearError(zh); if (zh->iconv_to_utf8 != 0) yaz_iconv_close(zh->iconv_to_utf8); @@ -1938,7 +1976,7 @@ ZEBRA_RES zebra_record_encoding (ZebraHandle zh, const char *encoding) { ASSERTZH; yaz_log(log_level, "zebra_record_encoding"); - zh->errCode = 0; + zebra_clearError(zh); xfree(zh->record_encoding); zh->record_encoding = 0; if (encoding) @@ -1952,7 +1990,7 @@ void zebra_set_resource(ZebraHandle zh, const char *name, const char *value) assert(name); assert(value); yaz_log(log_level, "zebra_set_resource %s:%s", name, value); - zh->errCode = 0; + zebra_clearError(zh); res_set(zh->res, name, value); } @@ -1964,7 +2002,7 @@ const char *zebra_get_resource(ZebraHandle zh, assert(name); assert(defaultvalue); v = res_get_def (zh->res, name, (char *)defaultvalue); - zh->errCode = 0; + zebra_clearError(zh); yaz_log(log_level, "zebra_get_resource %s:%s", name, v); return v; } @@ -2114,9 +2152,9 @@ ZEBRA_RES zebra_delete_record (ZebraHandle zh, */ ZEBRA_RES zebra_search_PQF(ZebraHandle zh, const char *pqf_query, - const char *setname, zint *numhits) + const char *setname, zint *hits) { - zint hits = 0; + zint lhits = 0; ZEBRA_RES res = ZEBRA_OK; Z_RPNQuery *query; ODR odr = odr_createmem(ODR_ENCODE); @@ -2135,14 +2173,14 @@ ZEBRA_RES zebra_search_PQF(ZebraHandle zh, const char *pqf_query, res = ZEBRA_FAIL; } else - res = zebra_search_RPN(zh, odr, query, setname, &hits); + res = zebra_search_RPN(zh, odr, query, setname, &lhits); odr_destroy(odr); - yaz_log(log_level, "Hits: " ZINT_FORMAT, hits); + yaz_log(log_level, "Hits: " ZINT_FORMAT, lhits); - if (numhits) - *numhits = hits; + if (hits) + *hits = lhits; return res; } @@ -2200,10 +2238,31 @@ struct BFiles_struct *zebra_get_bfs(ZebraHandle zh) /* --------------------------------------------------------------------------- Set limit for search/scan */ -ZEBRA_RES zebra_set_limit(ZebraHandle zh, int exclude_flag, zint *ids) +ZEBRA_RES zebra_set_limit(ZebraHandle zh, int complement_flag, zint *ids) { ASSERTZH; zebra_limit_destroy(zh->m_limit); - zh->m_limit = zebra_limit_create(exclude_flag, ids); + zh->m_limit = zebra_limit_create(complement_flag, ids); return ZEBRA_OK; } + +/* + Set Error code + addinfo +*/ +void zebra_setError(ZebraHandle zh, int code, const char *addinfo) +{ + zh->errCode = code; + nmem_reset(zh->nmem_error); + zh->errString = addinfo ? nmem_strdup(zh->nmem_error, addinfo) : 0; +} + +void zebra_setError_zint(ZebraHandle zh, int code, zint i) +{ + char vstr[60]; + sprintf(vstr, ZINT_FORMAT, i); + + zh->errCode = code; + nmem_reset(zh->nmem_error); + zh->errString = nmem_strdup(zh->nmem_error, vstr); +} +