X-Git-Url: http://git.indexdata.com/?p=idzebra-moved-to-github.git;a=blobdiff_plain;f=rset%2Frsmultiandor.c;h=91669dbf7f952bef02be30f64dd0a29fffdb1edb;hp=05aa3ff9df5c63e3f189e85935fe17a5ae2c7f97;hb=a66b7d79383ae700f3358731eecfe2aafed0e90d;hpb=97a7adeb9e5059463f039495cc01cfa448463a27 diff --git a/rset/rsmultiandor.c b/rset/rsmultiandor.c index 05aa3ff..91669db 100644 --- a/rset/rsmultiandor.c +++ b/rset/rsmultiandor.c @@ -1,5 +1,5 @@ /* This file is part of the Zebra server. - Copyright (C) 1995-2008 Index Data + Copyright (C) 1994-2010 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 @@ -52,7 +52,8 @@ static int r_forward_and(RSFD rfd, void *buf, TERMID *term, const void *untilbuf); static int r_forward_or(RSFD rfd, void *buf, TERMID *term, const void *untilbuf); -static void r_pos (RSFD rfd, double *current, double *total); +static void r_pos_and(RSFD rfd, double *current, double *total); +static void r_pos_or(RSFD rfd, double *current, double *total); static void r_get_terms(RSET ct, TERMID *terms, int maxterms, int *curterm); static const struct rset_control control_or = @@ -63,7 +64,7 @@ static const struct rset_control control_or = r_open_or, r_close, r_forward_or, - r_pos, + r_pos_or, r_read_or, r_write, }; @@ -76,7 +77,7 @@ static const struct rset_control control_and = r_open_and, r_close, r_forward_and, - r_pos, + r_pos_and, r_read_and, r_write, }; @@ -526,7 +527,8 @@ static int r_read_and (RSFD rfd, void *buf, TERMID *term) } if (p->skip) continue; /* skip again.. eventually tailcount will be 0 */ - (p->hits)++; + if (p->tailcount == 0) + (p->hits)++; return 1; } /* not tailing, forward until all records match, and set up */ @@ -604,21 +606,31 @@ static int r_forward_and(RSFD rfd, void *buf, TERMID *term, return r_read_and(rfd,buf,term); } -static void r_pos (RSFD rfd, double *current, double *total) +static void r_pos_x(RSFD rfd, double *current, double *total, int and_op) { RSET ct = rfd->rset; struct rfd_private *mrfd = (struct rfd_private *)(rfd->priv); - double cur, tot; - double scur = 0.0, stot = 0.0; + double ratio = and_op ? 0.0 : 1.0; int i; for (i = 0; ino_children; i++){ + double nratio, cur, tot; rset_pos(mrfd->items[i].fd, &cur, &tot); - yaz_log(log_level, "r_pos: %d %0.1f %0.1f", i, cur,tot); - scur += cur; - stot += tot; + yaz_log(log_level, "r_pos: %d %0.1f %0.1f", i, cur,tot); + + nratio = cur / tot; + if (and_op) + { + if (nratio > ratio) + ratio = nratio; + } + else + { + if (nratio < ratio) + ratio = nratio; + } } - if (stot < 1.0) { /* nothing there */ + if (ratio == 0.0 || ratio == 1.0) { /* nothing there */ *current = 0; *total = 0; yaz_log(log_level, "r_pos: NULL %0.1f %0.1f", *current, *total); @@ -626,11 +638,21 @@ static void r_pos (RSFD rfd, double *current, double *total) else { *current = (double) (mrfd->hits); - *total = *current*stot/scur; + *total = *current / ratio; yaz_log(log_level, "r_pos: = %0.1f %0.1f", *current, *total); } } +static void r_pos_and(RSFD rfd, double *current, double *total) +{ + r_pos_x(rfd, current, total, 1); +} + +static void r_pos_or(RSFD rfd, double *current, double *total) +{ + r_pos_x(rfd, current, total, 0); +} + static int r_write (RSFD rfd, const void *buf) { yaz_log (YLOG_FATAL, "multior set type is read-only"); @@ -666,6 +688,7 @@ static void r_get_terms(RSET ct, TERMID *terms, int maxterms, int *curterm) /* * Local variables: * c-basic-offset: 4 + * c-file-style: "Stroustrup" * indent-tabs-mode: nil * End: * vim: shiftwidth=4 tabstop=8 expandtab