rset/rset.c

   1 /* $Id: rset.c,v 1.29 2004-08-31 10:43:39 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 RSET rset_create_base(const struct rset_control *sel, NMEM nmem)
  70         /* FIXME - Add keysize and cmp function */
  71         /* FIXME - Add a general key-func block for cmp, dump, etc */
  72 {
  73     RSET rnew;
  74     NMEM M;
  75     if (nmem)
  76         M=nmem;
  77     else
  78         M=nmem_create();
  79     rnew = (RSET) nmem_malloc(M,sizeof(*rnew));
  80  /* logf (LOG_DEBUG, "rs_create(%s) rs=%p (nm=%p)", sel->desc, rnew, nmem); */
  81     rnew->nmem=M;
  82     if (nmem)
  83         rnew->my_nmem=0;
  84     else
  85         rnew->my_nmem=1;
  86     rnew->control = sel;
  87     rnew->count = 1;
  88     rnew->priv = 0;
  89     rnew->free_list=NULL;
  90
  91     return rnew;
  92 }
  93
  94 void rset_delete (RSET rs)
  95 {
  96     (rs->count)--;
  97 /*  logf(LOG_DEBUG,"rs_delete(%s), rs=%p, count=%d",
  98             rs->control->desc, rs, rs->count); */
  99     if (!rs->count)
 100     {
 101         (*rs->control->f_delete)(rs);
 102         if (rs->my_nmem)
 103             nmem_destroy(rs->nmem);
 104     }
 105 }
 106
 107 RSET rset_dup (RSET rs)
 108 {
 109     (rs->count)++;
 110     return rs;
 111 }
 112
 113 #if 0
 114 void rset_default_pos (RSFD rfd, double *current, double *total)
 115 { /* This should never really be needed, but it is still used in */
 116   /* those rsets that we don't really plan to use, like isam-s */
 117     assert(rfd);
 118     assert(current);
 119     assert(total);
 120     *current=-1; /* signal that pos is not implemented */
 121     *total=-1;
 122 } /* rset_default_pos */
 123 #endif
 124
 125 int rset_default_forward(RSFD rfd, void *buf,
 126                            int (*cmpfunc)(const void *p1, const void *p2),
 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=(*cmpfunc)(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