X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=rset%2Frsisamb.c;h=50e9beab587e390fcd6f088c3f72fa96b67e7a86;hb=5437b50633032595afe6f87dc0f989bc92a5aea8;hp=094ba8513130cb46c40970043a8c9898411f4ae0;hpb=3c547fb0a2e275ef21871d865116e288114c0910;p=idzebra-moved-to-github.git diff --git a/rset/rsisamb.c b/rset/rsisamb.c index 094ba85..50e9bea 100644 --- a/rset/rsisamb.c +++ b/rset/rsisamb.c @@ -1,4 +1,4 @@ -/* $Id: rsisamb.c,v 1.25 2004-10-22 10:12:52 heikki Exp $ +/* $Id: rsisamb.c,v 1.28 2004-11-19 10:27:14 heikki Exp $ Copyright (C) 1995,1996,1997,1998,1999,2000,2001,2002,2003,2004 Index Data Aps @@ -26,9 +26,6 @@ Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA #include #include -#ifndef RSET_DEBUG -#define RSET_DEBUG 0 -#endif static RSFD r_open (RSET ct, int flag); static void r_close (RSFD rfd); @@ -63,21 +60,30 @@ struct rset_isamb_info { ISAMB_P pos; }; +static int log_level = 0; +static int log_level_initialized = 0; + RSET rsisamb_create( NMEM nmem, const struct key_control *kcontrol, int scope, ISAMB is, ISAMB_P pos, TERMID term) { - RSET rnew=rset_create_base(&control, nmem, kcontrol, scope, term); + RSET rnew = rset_create_base(&control, nmem, kcontrol, scope, term); struct rset_isamb_info *info; + if (!log_level_initialized) + { + log_level = yaz_log_module_level("rsisamb"); + log_level_initialized = 1; + } info = (struct rset_isamb_info *) nmem_malloc(rnew->nmem,sizeof(*info)); - info->is=is; - info->pos=pos; - rnew->priv=info; + info->is = is; + info->pos = pos; + rnew->priv = info; + yaz_log(log_level,"rsisamb_create"); return rnew; } static void r_delete (RSET ct) { - logf (LOG_DEBUG, "rsisamb_delete"); + yaz_log(log_level, "rsisamb_delete"); } RSFD r_open (RSET ct, int flag) @@ -88,62 +94,64 @@ RSFD r_open (RSET ct, int flag) if (flag & RSETF_WRITE) { - logf (LOG_FATAL, "ISAMB set type is read-only"); + yaz_log(YLOG_FATAL, "ISAMB set type is read-only"); return NULL; } - rfd=rfd_create_base(ct); + rfd = rfd_create_base(ct); if (rfd->priv) - ptinfo=(struct rset_pp_info *) (rfd->priv); + ptinfo = (struct rset_pp_info *) (rfd->priv); else { ptinfo = (struct rset_pp_info *)nmem_malloc(ct->nmem,sizeof(*ptinfo)); ptinfo->buf = nmem_malloc (ct->nmem,ct->keycontrol->key_size); - rfd->priv=ptinfo; + rfd->priv = ptinfo; } ptinfo->pt = isamb_pp_open (info->is, info->pos, ct->scope ); + yaz_log(log_level,"rsisamb_open"); return rfd; } static void r_close (RSFD rfd) { - struct rset_pp_info *ptinfo=(struct rset_pp_info *)(rfd->priv); + struct rset_pp_info *ptinfo = (struct rset_pp_info *)(rfd->priv); isamb_pp_close (ptinfo->pt); rfd_delete_base(rfd); + yaz_log(log_level,"rsisamb_close"); } static int r_forward(RSFD rfd, void *buf, TERMID *term, const void *untilbuf) { - struct rset_pp_info *pinfo=(struct rset_pp_info *)(rfd->priv); + struct rset_pp_info *pinfo = (struct rset_pp_info *)(rfd->priv); int rc; - rc=isamb_pp_forward(pinfo->pt, buf, untilbuf); + rc = isamb_pp_forward(pinfo->pt, buf, untilbuf); if (rc && term) - *term=rfd->rset->term; + *term = rfd->rset->term; + yaz_log(log_level,"rsisamb_forward"); return rc; } static void r_pos (RSFD rfd, double *current, double *total) { - struct rset_pp_info *pinfo=(struct rset_pp_info *)(rfd->priv); + struct rset_pp_info *pinfo = (struct rset_pp_info *)(rfd->priv); assert(rfd); isamb_pp_pos(pinfo->pt, current, total); -#if RSET_DEBUG - logf(LOG_DEBUG,"isamb.r_pos returning %0.1f/%0.1f", + yaz_log(log_level,"isamb.r_pos returning %0.1f/%0.1f", *current, *total); -#endif } static int r_read (RSFD rfd, void *buf, TERMID *term) { - struct rset_pp_info *pinfo=(struct rset_pp_info *)(rfd->priv); + struct rset_pp_info *pinfo = (struct rset_pp_info *)(rfd->priv); int rc; - rc=isamb_pp_read(pinfo->pt, buf); + rc = isamb_pp_read(pinfo->pt, buf); if (rc && term) - *term=rfd->rset->term; + *term = rfd->rset->term; + yaz_log(log_level,"isamb.r_read "); return rc; } static int r_write (RSFD rfd, const void *buf) { - logf (LOG_FATAL, "ISAMB set type is read-only"); + yaz_log(YLOG_FATAL, "ISAMB set type is read-only"); return -1; }