rset/rset.c

   1 /* $Id: rset.c,v 1.32 2004-09-03 14:59:50 heikki Exp $
   2    Copyright (C) 1995,1996,1997,1998,1999,2000,2001,2002,2003,2004
   3    Index Data Aps
   4
   5 This file is part of the Zebra server.
   6
   7 Zebra is free software; you can redistribute it and/or modify it under
   8 the terms of the GNU General Public License as published by the Free
   9 Software Foundation; either version 2, or (at your option) any later
  10 version.
  11
  12 Zebra is distributed in the hope that it will be useful, but WITHOUT ANY
  13 WARRANTY; without even the implied warranty of MERCHANTABILITY or
  14 FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
  15 for more details.
  16
  17 You should have received a copy of the GNU General Public License
  18 along with Zebra; see the file LICENSE.zebra.  If not, write to the
  19 Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA
  20 02111-1307, USA.
  21 */
  22
  23
  24
  25 #include <stdio.h>
  26 #include <string.h>
  27 #include <zebrautl.h>
  28 #include <assert.h>
  29 #include <yaz/nmem.h>
  30 #include <rset.h>
  31
  32
  33 /* creates an rfd. Either allocates a new one, in which case the priv */
  34 /* pointer is null, and will have to be filled in, or picks up one */
  35 /* from the freelist, in which case the priv is already allocated, */
  36 /* and presumably everything that hangs from it as well */
  37
  38 RSFD rfd_create_base(RSET rs)
  39 {
  40     RSFD rnew=rs->free_list;
  41     if (rnew) {
  42         rs->free_list=rnew->next;
  43         assert(rnew->rset==rs);
  44   /*    logf(LOG_DEBUG,"rfd-create_base (fl): rfd=%p rs=%p fl=%p priv=%p",
  45                        rnew, rs, rs->free_list, rnew->priv); */
  46     } else {
  47         rnew=nmem_malloc(rs->nmem, sizeof(*rnew));
  48         rnew->priv=NULL;
  49         rnew->rset=rs;
  50   /*    logf(LOG_DEBUG,"rfd_create_base (new): rfd=%p rs=%p fl=%p priv=%p",
  51                        rnew, rs, rs->free_list, rnew->priv); */
  52     }
  53     rnew->next=NULL; /* not part of any (free?) list */
  54     return rnew;
  55 }
  56
  57 /* puts an rfd into the freelist of the rset. Only when the rset gets */
  58 /* deleted, will all the nmem disappear */
  59 void rfd_delete_base(RSFD rfd)
  60 {
  61     RSET rs=rfd->rset;
  62  /* logf(LOG_DEBUG,"rfd_delete_base: rfd=%p rs=%p priv=%p fl=%p",
  63             rfd, rs, rfd->priv, rs->free_list); */
  64     assert(NULL == rfd->next);
  65     rfd->next=rs->free_list;
  66     rs->free_list=rfd;
  67 }
  68
  69
  70 RSET rset_create_base(const struct rset_control *sel,
  71                       NMEM nmem, const struct key_control *kcontrol)
  72 {
  73     RSET rnew;
  74     NMEM M;
  75     /* assert(nmem); */ /* can not yet be used, api/t4 fails */
  76     if (nmem)
  77         M=nmem;
  78     else
  79         M=nmem_create();
  80     rnew = (RSET) nmem_malloc(M,sizeof(*rnew));
  81  /* logf (LOG_DEBUG, "rs_create(%s) rs=%p (nm=%p)", sel->desc, rnew, nmem); */
  82     rnew->nmem=M;
  83     if (nmem)
  84         rnew->my_nmem=0;
  85     else
  86         rnew->my_nmem=1;
  87     rnew->control = sel;
  88     rnew->count = 1;
  89     rnew->priv = 0;
  90     rnew->free_list=NULL;
  91     rnew->keycontrol=kcontrol;
  92     return rnew;
  93 }
  94
  95 void rset_delete (RSET rs)
  96 {
  97     (rs->count)--;
  98 /*  logf(LOG_DEBUG,"rs_delete(%s), rs=%p, count=%d",
  99             rs->control->desc, rs, rs->count); */
 100     if (!rs->count)
 101     {
 102         (*rs->control->f_delete)(rs);
 103         if (rs->my_nmem)
 104             nmem_destroy(rs->nmem);
 105     }
 106 }
 107
 108 RSET rset_dup (RSET rs)
 109 {
 110     (rs->count)++;
 111     return rs;
 112 }
 113
 114 #if 0
 115 void rset_default_pos (RSFD rfd, double *current, double *total)
 116 { /* This should never really be needed, but it is still used in */
 117   /* those rsets that we don't really plan to use, like isam-s */
 118     assert(rfd);
 119     assert(current);
 120     assert(total);
 121     *current=-1; /* signal that pos is not implemented */
 122     *total=-1;
 123 } /* rset_default_pos */
 124 #endif
 125
 126 int rset_default_forward(RSFD rfd, void *buf,
 127                            const void *untilbuf)
 128 {
 129     int more=1;
 130     int cmp=2;
 131     logf (LOG_DEBUG, "rset_default_forward starting '%s' (ct=%p rfd=%p)",
 132                     rfd->rset->control->desc, rfd->rset, rfd);
 133     /* key_logdump(LOG_DEBUG, untilbuf); */
 134     while ( (cmp==2) && (more))
 135     {
 136         logf (LOG_DEBUG, "rset_default_forward looping m=%d c=%d",more,cmp);
 137         more=rset_read(rfd, buf);
 138         if (more)
 139             cmp=(rfd->rset->keycontrol->cmp)(untilbuf,buf);
 140 /*        if (more)
 141             key_logdump(LOG_DEBUG,buf); */
 142     }
 143     logf (LOG_DEBUG, "rset_default_forward exiting m=%d c=%d",more,cmp);
 144
 145     return more;
 146 }
 147