X-Git-Url: http://git.indexdata.com/?p=idzebra-moved-to-github.git;a=blobdiff_plain;f=rset%2Frset.c;h=f653a21eee12aab680f8f3c96273f41390a1450f;hp=ef3696d024ccb0b351c9b4f2baf024aaa4b81ac0;hb=65fef82ef22eb87bc6a569cc934bd0284be854cf;hpb=ecb3935e78cd9bcfdebafdee0834cfb1060d7b5e diff --git a/rset/rset.c b/rset/rset.c index ef3696d..f653a21 100644 --- a/rset/rset.c +++ b/rset/rset.c @@ -1,8 +1,5 @@ -/* $Id: rset.c,v 1.53 2006-05-10 08:13:33 adam Exp $ - Copyright (C) 1995-2005 - Index Data ApS - -This file is part of the Zebra server. +/* This file is part of the Zebra server. + Copyright (C) Index Data Zebra is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free @@ -15,11 +12,14 @@ FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License -along with Zebra; see the file LICENSE.zebra. If not, write to the -Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA -02111-1307, USA. +along with this program; if not, write to the Free Software +Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA + */ +#if HAVE_CONFIG_H +#include +#endif #include #include #include @@ -30,34 +30,35 @@ Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA static int log_level = 0; static int log_level_initialized = 0; + /** \brief Common constuctor for RFDs \param rs Result set handle. - - Creates an rfd. Either allocates a new one, in which case the priv - pointer is null, and will have to be filled in, or picks up one + + Creates an rfd. Either allocates a new one, in which case the priv + pointer is null, and will have to be filled in, or picks up one from the freelist, in which case the priv is already allocated, - and presumably everything that hangs from it as well + and presumably everything that hangs from it as well */ RSFD rfd_create_base(RSET rs) { RSFD rnew = rs->free_list; - if (rnew) + if (rnew) { rs->free_list = rnew->next; assert(rnew->rset==rs); - yaz_log(log_level, "rfd_create_base (fl): rfd=%p rs=%p fl=%p priv=%p", - rnew, rs, rs->free_list, rnew->priv); - } + yaz_log(log_level, "rfd_create_base (fl): rfd=%p rs=%p fl=%p priv=%p", + rnew, rs, rs->free_list, rnew->priv); + } else { rnew = nmem_malloc(rs->nmem, sizeof(*rnew)); rnew->counted_buf = nmem_malloc(rs->nmem, rs->keycontrol->key_size); rnew->priv = 0; rnew->rset = rs; - yaz_log(log_level, "rfd_create_base (new): rfd=%p rs=%p fl=%p priv=%p", - rnew, rs, rs->free_list, rnew->priv); + yaz_log(log_level, "rfd_create_base (new): rfd=%p rs=%p fl=%p priv=%p", + rnew, rs, rs->free_list, rnew->priv); } rnew->next = rs->use_list; rs->use_list = rnew; @@ -65,33 +66,58 @@ RSFD rfd_create_base(RSET rs) return rnew; } +static void rset_close_int(RSET rs, RSFD rfd) +{ + RSFD *pfd; + (*rs->control->f_close)(rfd); + + yaz_log(log_level, "rfd_delete_base: rfd=%p rs=%p priv=%p fl=%p", + rfd, rs, rfd->priv, rs->free_list); + for (pfd = &rs->use_list; *pfd; pfd = &(*pfd)->next) + if (*pfd == rfd) + { + *pfd = (*pfd)->next; + rfd->next = rs->free_list; + rs->free_list = rfd; + return; + } + yaz_log(YLOG_WARN, "rset_close handle not found. type=%s", + rs->control->desc); +} + +void rset_set_hits_limit(RSET rs, zint l) +{ + yaz_log(log_level, "rset_set_hits_limit %p l=" ZINT_FORMAT, rs, l); + rs->hits_limit = l; +} + /** \brief Closes a result set RFD handle \param rfd the RFD handle. */ void rset_close(RSFD rfd) { - RSFD *pfd; RSET rs = rfd->rset; if (rs->hits_count == 0) { TERMID termid; char buf[100]; - while(rfd->counted_items <= rs->hits_limit + + while (rfd->counted_items <= rs->hits_limit && rset_default_read(rfd, buf, &termid)) ; - + rs->hits_count = rfd->counted_items; yaz_log(log_level, "rset_close rset=%p hits_count=" ZINT_FORMAT " hits_limit=" ZINT_FORMAT, rs, rs->hits_count, rs->hits_limit); rs->hits_approx = 0; - if (rs->hits_count > rs->hits_limit) + if (rs->hits_count > rs->hits_limit && rs->hits_limit > 0) { double cur, tot; zint est; - rset_pos(rfd, &cur, &tot); + rset_pos(rfd, &cur, &tot); if (tot > 0) { int i; double ratio = cur/tot; @@ -113,23 +139,11 @@ void rset_close(RSFD rfd) rs->hits_approx = 1; } } - yaz_log(log_level, "rset_close p=%p count=" ZINT_FORMAT, rs, + yaz_log(log_level, "rset_close(%s) p=%p count=" ZINT_FORMAT, + rs->control->desc, rs, rs->hits_count); } - (*rs->control->f_close)(rfd); - - yaz_log(log_level, "rfd_delete_base: rfd=%p rs=%p priv=%p fl=%p", - rfd, rs, rfd->priv, rs->free_list); - for (pfd = &rs->use_list; *pfd; pfd = &(*pfd)->next) - if (*pfd == rfd) - { - *pfd = (*pfd)->next; - rfd->next = rs->free_list; - rs->free_list = rfd; - return; - } - yaz_log(YLOG_WARN, "rset_close handle not found. type=%s", - rs->control->desc); + rset_close_int(rs, rfd); } /** @@ -141,30 +155,29 @@ void rset_close(RSFD rfd) \param term Information about term for it (NULL for none). \param no_children number of child rsets (0 for none) \param children child rsets (NULL for none). - - Creates an rfd. Either allocates a new one, in which case the priv - pointer is null, and will have to be filled in, or picks up one + + Creates an rfd. Either allocates a new one, in which case the priv + pointer is null, and will have to be filled in, or picks up one from the freelist, in which case the priv is already allocated, - and presumably everything that hangs from it as well + and presumably everything that hangs from it as well */ -RSET rset_create_base(const struct rset_control *sel, +RSET rset_create_base(const struct rset_control *sel, NMEM nmem, struct rset_key_control *kcontrol, int scope, TERMID term, int no_children, RSET *children) { RSET rset; assert(nmem); - if (!log_level_initialized) + if (!log_level_initialized) { log_level = yaz_log_module_level("rset"); log_level_initialized = 1; } rset = (RSET) nmem_malloc(nmem, sizeof(*rset)); - yaz_log(log_level, "rs_create(%s) rs=%p (nm=%p)", sel->desc, rset, nmem); - yaz_log(log_level, " ref_id=%s limit=" ZINT_FORMAT, - (term && term->ref_id ? term->ref_id : "null"), - rset->hits_limit); + yaz_log(log_level, "rs_create(%s) rs=%p (nm=%p)", sel->desc, rset, nmem); + yaz_log(log_level, " ref_id=%s", + (term && term->ref_id ? term->ref_id : "null")); rset->nmem = nmem; rset->control = sel; rset->refcount = 1; @@ -175,6 +188,7 @@ RSET rset_create_base(const struct rset_control *sel, rset->hits_limit = 0; rset->hits_round = 1000; rset->keycontrol = kcontrol; + (*kcontrol->inc)(kcontrol); rset->scope = scope; rset->term = term; @@ -197,7 +211,7 @@ RSET rset_create_base(const struct rset_control *sel, /** \brief Destructor RSETs \param rs Handle for result set. - + Destroys a result set and all its children. The f_delete method of control is called for the result set. */ @@ -205,7 +219,7 @@ void rset_delete(RSET rs) { (rs->refcount)--; yaz_log(log_level, "rs_delete(%s), rs=%p, refcount=%d", - rs->control->desc, rs, rs->refcount); + rs->control->desc, rs, rs->refcount); if (!rs->refcount) { int i; @@ -222,7 +236,7 @@ void rset_delete(RSET rs) /** \brief Test for last use of RFD \param rfd RFD handle. - + Returns 1 if this RFD is the last reference to it; 0 otherwise. */ int rfd_is_last(RSFD rfd) @@ -235,19 +249,18 @@ int rfd_is_last(RSFD rfd) /** \brief Duplicate an RSET \param rs Handle for result set. - + Duplicates a result set by incrementing the reference count to it. */ RSET rset_dup (RSET rs) { (rs->refcount)++; yaz_log(log_level, "rs_dup(%s), rs=%p, refcount=%d", - rs->control->desc, rs, rs->refcount); - (*rs->keycontrol->inc)(rs->keycontrol); + rs->control->desc, rs, rs->refcount); return rs; } -/** +/** \brief Estimates hit count for result set. \param rs Result Set. @@ -261,7 +274,7 @@ zint rset_count(RSET rs) double cur, tot; RSFD rfd = rset_open(rs, 0); rset_pos(rfd, &cur, &tot); - rset_close(rfd); + rset_close_int(rs, rfd); return (zint) tot; } @@ -307,6 +320,11 @@ struct ord_list *ord_list_dup(NMEM nmem, struct ord_list *list) return n; } +void ord_list_print(struct ord_list *list) +{ + for (; list; list = list->next) + yaz_log(YLOG_LOG, "ord_list %d", list->ord); +} /** \brief Creates a TERMID entry. \param name Term/Name buffer with given length @@ -358,8 +376,17 @@ int rset_default_read(RSFD rfd, void *buf, TERMID *term) int rc = (*rset->control->f_read)(rfd, buf, term); if (rc > 0) { - if (rfd->counted_items == 0 || - (rset->keycontrol->cmp)(buf, rfd->counted_buf) > rset->scope) + int got_scope; + if (rfd->counted_items == 0) + got_scope = rset->scope+1; + else + got_scope = rset->keycontrol->cmp(buf, rfd->counted_buf); + +#if 0 + key_logdump_txt(YLOG_LOG, buf, "rset_default_read"); + yaz_log(YLOG_LOG, "rset_scope=%d got_scope=%d", rset->scope, got_scope); +#endif + if (got_scope > rset->scope) { memcpy(rfd->counted_buf, buf, rset->keycontrol->key_size); rfd->counted_items++; @@ -380,16 +407,16 @@ int rset_default_forward(RSFD rfd, void *buf, TERMID *term, assert (rset->control->f_forward != rset_default_forward); return rset->control->f_forward(rfd, buf, term, untilbuf); } - + while ((more = rset_read(rfd, buf, term)) > 0) { - if ((rfd->rset->keycontrol->cmp)(untilbuf, buf) <= 1) + if ((rfd->rset->keycontrol->cmp)(untilbuf, buf) < rset->scope) break; } if (log_level) - yaz_log (log_level, "rset_default_forward exiting m=%d c=%d", - more, rset->scope); - + yaz_log(log_level, "rset_default_forward exiting rfd=%p scope=%d m=%d c=%d", + rfd, rset->scope, more, rset->scope); + return more; } @@ -403,9 +430,16 @@ void rset_visit(RSET rset, int level) rset_visit(rset->children[i], level+1); } +int rset_no_write(RSFD rfd, const void *buf) +{ + yaz_log(YLOG_FATAL, "%s set type is read-only", rfd->rset->control->desc); + return -1; +} + /* * Local variables: * c-basic-offset: 4 + * c-file-style: "Stroustrup" * indent-tabs-mode: nil * End: * vim: shiftwidth=4 tabstop=8 expandtab