X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=rset%2Frsprox.c;h=4352e3e413c8c96cb2b3de5b0e9f9e90cd481052;hb=d195e3229385349f842d2f82b65ad8118d64aec5;hp=1c1827dba48d8124c9db73eb49bfda1759dc1c31;hpb=1dfb2eabceebab1841f13a07314171c00873409d;p=idzebra-moved-to-github.git diff --git a/rset/rsprox.c b/rset/rsprox.c index 1c1827d..4352e3e 100644 --- a/rset/rsprox.c +++ b/rset/rsprox.c @@ -1,4 +1,4 @@ -/* $Id: rsprox.c,v 1.19 2004-10-20 14:32:29 heikki Exp $ +/* $Id: rsprox.c,v 1.22 2005-01-04 19:59:59 adam Exp $ Copyright (C) 1995,1996,1997,1998,1999,2000,2001,2002,2003,2004 Index Data Aps @@ -39,11 +39,13 @@ static int r_forward(RSFD rfd, void *buf, TERMID *term, const void *untilbuf); static int r_read (RSFD rfd, void *buf, TERMID *term); static int r_write (RSFD rfd, const void *buf); static void r_pos (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 = { "prox", r_delete, + r_get_terms, r_open, r_close, r_forward, @@ -112,7 +114,7 @@ static RSFD r_open (RSET ct, int flag) if (flag & RSETF_WRITE) { - logf (LOG_FATAL, "prox set type is read-only"); + yaz_log (YLOG_FATAL, "prox set type is read-only"); return NULL; } rfd = rfd_create_base(ct); @@ -131,7 +133,7 @@ static RSFD r_open (RSET ct, int flag) } p->rfd = nmem_malloc(ct->nmem,sizeof(*p->rfd) * info->rset_no); } - logf(LOG_DEBUG,"rsprox (%s) open [%p] n=%d", + yaz_log(YLOG_DEBUG,"rsprox (%s) open [%p] n=%d", ct->control->desc, rfd, info->rset_no); for (i = 0; i < info->rset_no; i++) { @@ -300,7 +302,7 @@ static int r_read (RSFD rfd, void *buf, TERMID *term) static int r_write (RSFD rfd, const void *buf) { - logf (LOG_FATAL, "prox set type is read-only"); + yaz_log (YLOG_FATAL, "prox set type is read-only"); return -1; } @@ -309,11 +311,11 @@ static void r_pos (RSFD rfd, double *current, double *total) struct rset_prox_info *info = (struct rset_prox_info *)(rfd->rset->priv); struct rset_prox_rfd *p=(struct rset_prox_rfd *)(rfd->priv); int i; - double cur,tot=-1; - double scur=0,stot=0; - double r; + double r = 0.0; + double cur, tot = -1.0; + double scur = 0.0, stot = 0.0; - logf (LOG_DEBUG, "rsprox_pos"); + yaz_log (YLOG_DEBUG, "rsprox_pos"); for (i = 0; i < info->rset_no; i++) { @@ -334,6 +336,18 @@ static void r_pos (RSFD rfd, double *current, double *total) *current=p->hits; *total=*current/r ; } - logf(LOG_DEBUG,"prox_pos: [%d] %0.1f/%0.1f= %0.4f ", + yaz_log(YLOG_DEBUG,"prox_pos: [%d] %0.1f/%0.1f= %0.4f ", i,*current, *total, r); } + + + +static void r_get_terms(RSET ct, TERMID *terms, int maxterms, int *curterm) +{ + struct rset_prox_info *info = + (struct rset_prox_info *) ct->priv; + int i; + for (i=0;irset_no;i++) + rset_getterms(info->rset[i], terms, maxterms, curterm); +} +