X-Git-Url: http://git.indexdata.com/?p=idzebra-moved-to-github.git;a=blobdiff_plain;f=rset%2Frstemp.c;h=b492f0e5b1b23d890f91764105237090cc56af8a;hp=e32822b2e66b949c37898060bc69897ce3aaeacd;hb=5437b50633032595afe6f87dc0f989bc92a5aea8;hpb=896c0427df9d8eff5de6a1735dcd992e067df844

diff --git a/rset/rstemp.c b/rset/rstemp.c
index e32822b..b492f0e 100644
--- a/rset/rstemp.c
+++ b/rset/rstemp.c
@@ -1,5 +1,5 @@
-/* $Id: rstemp.c,v 1.33 2002-08-02 19:26:57 adam Exp $
-   Copyright (C) 1995,1996,1997,1998,1999,2000,2001,2002
+/* $Id: rstemp.c,v 1.55 2004-11-19 10:27:14 heikki Exp $
+   Copyright (C) 1995,1996,1997,1998,1999,2000,2001,2002,2003
    Index Data Aps
 
 This file is part of the Zebra server.
@@ -20,8 +20,6 @@ Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA
 02111-1307, USA.
 */
 
-
-
 #include <fcntl.h>
 #include <assert.h>
 #ifdef WIN32
@@ -34,26 +32,27 @@ Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA
 #include <stdio.h>
 
 #include <zebrautl.h>
-#include <rstemp.h>
+#include <rset.h>
 
-static void *r_create(RSET ct, const struct rset_control *sel, void *parms);
 static RSFD r_open (RSET ct, int flag);
 static void r_close (RSFD rfd);
 static void r_delete (RSET ct);
-static void r_rewind (RSFD rfd);
-static int r_count (RSET ct);
-static int r_read (RSFD rfd, void *buf, int *term_index);
+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_flush (RSFD rfd, int mk);
+static void r_reread (RSFD rfd);
+
 
 static const struct rset_control control = 
 {
     "temp",
-    r_create,
+    r_delete,
+    rset_get_one_term,
     r_open,
     r_close,
-    r_delete,
-    r_rewind,
-    r_count,
+    rset_default_forward,
+    r_pos, 
     r_read,
     r_write,
 };
@@ -61,66 +60,77 @@ static const struct rset_control control =
 const struct rset_control *rset_kind_temp = &control;
 
 struct rset_temp_info {
-    int     fd;
-    char   *fname;
-    size_t  key_size;      /* key size */
+    int     fd;            /* file descriptor for temp file */
+    char   *fname;         /* name of temp file */
     char   *buf_mem;       /* window buffer */
     size_t  buf_size;      /* size of window */
     size_t  pos_end;       /* last position in set */
-    size_t  pos_cur;       /* current position in set */
     size_t  pos_buf;       /* position of first byte in window */
     size_t  pos_border;    /* position of last byte+1 in window */
     int     dirty;         /* window is dirty */
-    int     hits;          /* no of hits */
+    zint     hits;          /* no of hits */
     char   *temp_path;
-    int     (*cmp)(const void *p1, const void *p2);
 };
 
 struct rset_temp_rfd {
-    struct rset_temp_info *info;
-    struct rset_temp_rfd *next;
-    int *countp;
     void *buf;
+    size_t  pos_cur;       /* current position in set */
+                           /* FIXME - term pos or what ??  */
+    zint cur; /* number of the current hit */
 };
 
-static void *r_create(RSET ct, const struct rset_control *sel, void *parms)
+static int log_level=0;
+static int log_level_initialized=0;
+
+RSET rstemp_create( NMEM nmem, const struct key_control *kcontrol,
+                    int scope, 
+                    const char *temp_path,TERMID term)
 {
-    rset_temp_parms *temp_parms = (rset_temp_parms *) parms;
+    RSET rnew=rset_create_base(&control, nmem, kcontrol, scope,term);
     struct rset_temp_info *info;
-   
-    info = (struct rset_temp_info *) xmalloc (sizeof(struct rset_temp_info));
+    if (!log_level_initialized)
+    {
+        log_level=yaz_log_module_level("rstemp");
+        log_level_initialized=1;
+    }
+    info = (struct rset_temp_info *) nmem_malloc(rnew->nmem, sizeof(*info));
     info->fd = -1;
     info->fname = NULL;
-    info->key_size = temp_parms->key_size;
     info->buf_size = 4096;
-    info->buf_mem = (char *) xmalloc (info->buf_size);
-    info->pos_cur = 0;
+    info->buf_mem = (char *) nmem_malloc (rnew->nmem, info->buf_size);
     info->pos_end = 0;
     info->pos_buf = 0;
     info->dirty = 0;
-    info->hits = -1;
-    info->cmp = temp_parms->cmp;
-    if (!temp_parms->temp_path)
-	info->temp_path = NULL;
+    info->hits = 0;
+
+    if (!temp_path)
+        info->temp_path = NULL;
     else
+        info->temp_path = nmem_strdup(rnew->nmem,temp_path);
+    rnew->priv=info; 
+    return rnew;
+} /* rstemp_create */
+
+static void r_delete (RSET ct)
+{
+    struct rset_temp_info *info = (struct rset_temp_info*) ct->priv;
+
+    yaz_log (log_level, "r_delete: set size %ld", (long) info->pos_end);
+    if (info->fname)
     {
-	info->temp_path = (char *) xmalloc (strlen(temp_parms->temp_path)+1);
-	strcpy (info->temp_path, temp_parms->temp_path);
+        yaz_log (log_level, "r_delete: unlink %s", info->fname);
+        unlink (info->fname);
     }
-    ct->no_rset_terms = 1;
-    ct->rset_terms = (RSET_TERM *) xmalloc (sizeof(*ct->rset_terms));
-    ct->rset_terms[0] = temp_parms->rset_term;
-
-    return info;
 }
 
+
 static RSFD r_open (RSET ct, int flag)
 {
-    struct rset_temp_info *info = (struct rset_temp_info *) ct->buf;
-    struct rset_temp_rfd *rfd;
+    struct rset_temp_info *info = (struct rset_temp_info *) ct->priv;
+    RSFD rfd;
+    struct rset_temp_rfd *prfd;
 
-    assert (info->fd == -1);
-    if (info->fname)
+    if (info->fd == -1 && info->fname)
     {
         if (flag & RSETF_WRITE)
             info->fd = open (info->fname, O_BINARY|O_RDWR|O_CREAT, 0666);
@@ -128,17 +138,22 @@ static RSFD r_open (RSET ct, int flag)
             info->fd = open (info->fname, O_BINARY|O_RDONLY);
         if (info->fd == -1)
         {
-            logf (LOG_FATAL|LOG_ERRNO, "open %s", info->fname);
+            yaz_log (YLOG_FATAL|YLOG_ERRNO, "rstemp: open failed %s", info->fname);
             exit (1);
         }
     }
-    rfd = (struct rset_temp_rfd *) xmalloc (sizeof(*rfd));
-    rfd->info = info;
-    r_rewind (rfd);
-
-    rfd->countp = &ct->rset_terms[0]->count;
-    rfd->buf = xmalloc (info->key_size);
-
+    rfd = rfd_create_base(ct);
+    if (!rfd->priv){
+        prfd= (struct rset_temp_rfd *) nmem_malloc(ct->nmem, sizeof(*prfd));
+        rfd->priv=(void *)prfd;
+        prfd->buf = nmem_malloc (ct->nmem,ct->keycontrol->key_size);
+    } else
+        prfd= rfd->priv;
+    r_flush (rfd, 0);
+    prfd->pos_cur = 0;
+    info->pos_buf = 0;
+    r_reread (rfd);
+    prfd->cur=0;
     return rfd;
 }
 
@@ -147,7 +162,8 @@ static RSFD r_open (RSET ct, int flag)
  */
 static void r_flush (RSFD rfd, int mk)
 {
-    struct rset_temp_info *info = ((struct rset_temp_rfd*) rfd)->info;
+    /* struct rset_temp_info *info = ((struct rset_temp_rfd*) rfd)->info; */
+    struct rset_temp_info *info = rfd->rset->priv;
 
     if (!info->fname && mk)
     {
@@ -163,21 +179,21 @@ static void r_flush (RSFD rfd, int mk)
 
         if (info->fd == -1)
         {
-            logf (LOG_FATAL|LOG_ERRNO, "mkstemp %s", template);
+            yaz_log (YLOG_FATAL|YLOG_ERRNO, "rstemp: mkstemp %s", template);
             exit (1);
         }
-        info->fname = (char *) xmalloc (strlen(template)+1);
+        info->fname= nmem_malloc(rfd->rset->nmem,strlen(template)+1);
         strcpy (info->fname, template);
 #else
         char *s = (char*) tempnam (info->temp_path, "zrs");
-        info->fname = (char *) xmalloc (strlen(s)+1);
+        info->fname= nmem_malloc(rfd->rset->nmem,strlen(template)+1);
         strcpy (info->fname, s);
 
-        logf (LOG_DEBUG, "creating tempfile %s", info->fname);
+        yaz_log (log_level, "creating tempfile %s", info->fname);
         info->fd = open (info->fname, O_BINARY|O_RDWR|O_CREAT, 0666);
         if (info->fd == -1)
         {
-            logf (LOG_FATAL|LOG_ERRNO, "open %s", info->fname);
+            yaz_log (YLOG_FATAL|YLOG_ERRNO, "rstemp: open %s", info->fname);
             exit (1);
         }
 #endif
@@ -185,11 +201,11 @@ static void r_flush (RSFD rfd, int mk)
     if (info->fname && info->fd != -1 && info->dirty)
     {
         size_t count;
-	int r;
+        int r;
         
         if (lseek (info->fd, info->pos_buf, SEEK_SET) == -1)
         {
-            logf (LOG_FATAL|LOG_ERRNO, "lseek %s", info->fname);
+            yaz_log (YLOG_FATAL|YLOG_ERRNO, "rstemp: lseek %s", info->fname);
             exit (1);
         }
         count = info->buf_size;
@@ -198,9 +214,9 @@ static void r_flush (RSFD rfd, int mk)
         if ((r = write (info->fd, info->buf_mem, count)) < (int) count)
         {
             if (r == -1)
-                logf (LOG_FATAL|LOG_ERRNO, "read %s", info->fname);
+                yaz_log (YLOG_FATAL|YLOG_ERRNO, "rstemp: write %s", info->fname);
             else
-                logf (LOG_FATAL, "write of %ld but got %ld",
+                yaz_log (YLOG_FATAL, "rstemp: write of %ld but got %ld",
                       (long) count, (long) r);
             exit (1);
         }
@@ -210,38 +226,17 @@ static void r_flush (RSFD rfd, int mk)
 
 static void r_close (RSFD rfd)
 {
-    struct rset_temp_info *info = ((struct rset_temp_rfd*)rfd)->info;
-
+    /*struct rset_temp_rfd *mrfd = (struct rset_temp_rfd*) rfd->priv; */
+    struct rset_temp_info *info = (struct rset_temp_info *)rfd->rset->priv;
     r_flush (rfd, 0);
     if (info->fname && info->fd != -1)
     {
         close (info->fd);
         info->fd = -1;
-    }
-    xfree (((struct rset_temp_rfd *)rfd)->buf);
-    xfree (rfd);
+    } /* FIXME - Is this right, don't we risk closing the file too early ?*/
+    rfd_delete_base(rfd);
 }
 
-static void r_delete (RSET ct)
-{
-    struct rset_temp_info *info = (struct rset_temp_info*) ct->buf;
-
-    if (info->fname)
-        unlink (info->fname);        
-    xfree (info->buf_mem);
-    logf (LOG_DEBUG, "r_delete: set size %ld", (long) info->pos_end);
-    if (info->fname)
-    {
-        logf (LOG_DEBUG, "r_delete: unlink %s", info->fname);
-        unlink (info->fname);
-        xfree (info->fname);
-    }
-    if (info->temp_path)
-	xfree (info->temp_path);
-    rset_term_destroy (ct->rset_terms[0]);
-    xfree (ct->rset_terms);
-    xfree (info);
-}
 
 /* r_reread:
       read from file to window if file is assocated with set -
@@ -249,14 +244,16 @@ static void r_delete (RSET ct)
  */
 static void r_reread (RSFD rfd)
 {
-    struct rset_temp_info *info = ((struct rset_temp_rfd*)rfd)->info;
+    struct rset_temp_rfd *mrfd = (struct rset_temp_rfd*) rfd->priv; 
+    struct rset_temp_info *info = (struct rset_temp_info *)rfd->rset->priv;
 
     if (info->fname)
     {
         size_t count;
-	int r;
+        int r;
 
-        info->pos_border = info->pos_cur + info->buf_size;
+        info->pos_border = mrfd->pos_cur +
+            info->buf_size;
         if (info->pos_border > info->pos_end)
             info->pos_border = info->pos_end;
         count = info->pos_border - info->pos_buf;
@@ -264,15 +261,15 @@ static void r_reread (RSFD rfd)
         {
             if (lseek (info->fd, info->pos_buf, SEEK_SET) == -1)
             {
-                logf (LOG_FATAL|LOG_ERRNO, "lseek %s", info->fname);
+                yaz_log (YLOG_FATAL|YLOG_ERRNO, "rstemp: lseek %s", info->fname);
                 exit (1);
             }
             if ((r = read (info->fd, info->buf_mem, count)) < (int) count)
             {
                 if (r == -1)
-                    logf (LOG_FATAL|LOG_ERRNO, "read %s", info->fname);
+                    yaz_log (YLOG_FATAL|YLOG_ERRNO, "rstemp: read %s", info->fname);
                 else
-                    logf (LOG_FATAL, "read of %ld but got %ld",
+                    yaz_log (YLOG_FATAL, "read of %ld but got %ld",
                           (long) count, (long) r);
                 exit (1);
             }
@@ -282,69 +279,62 @@ static void r_reread (RSFD rfd)
         info->pos_border = info->pos_end;
 }
 
-static void r_rewind (RSFD rfd)
-{
-    struct rset_temp_info *info = ((struct rset_temp_rfd*)rfd)->info;
-
-    r_flush (rfd, 0);
-    info->pos_cur = 0;
-    info->pos_buf = 0;
-    r_reread (rfd);
-}
-
-static int r_count (RSET ct)
-{
-    struct rset_temp_info *info = (struct rset_temp_info *) ct->buf;
-
-    return info->pos_end / info->key_size;
-}
 
-static int r_read (RSFD rfd, void *buf, int *term_index)
+static int r_read (RSFD rfd, void *buf, TERMID *term)
 {
-    struct rset_temp_rfd *mrfd = (struct rset_temp_rfd*) rfd;
-    struct rset_temp_info *info = mrfd->info;
+    struct rset_temp_rfd *mrfd = (struct rset_temp_rfd*) rfd->priv;  
+    struct rset_temp_info *info = (struct rset_temp_info *)rfd->rset->priv;
 
-    size_t nc = info->pos_cur + info->key_size;
+    size_t nc = mrfd->pos_cur + rfd->rset->keycontrol->key_size;
 
-    if (nc > info->pos_border)
+    if (mrfd->pos_cur < info->pos_buf || nc > info->pos_border)
     {
         if (nc > info->pos_end)
             return 0;
         r_flush (rfd, 0);
-        info->pos_buf = info->pos_cur;
+        info->pos_buf = mrfd->pos_cur;
         r_reread (rfd);
     }
-    memcpy (buf, info->buf_mem + (info->pos_cur - info->pos_buf),
-            info->key_size);
-    info->pos_cur = nc;
-    *term_index = 0;
-
-    if (*mrfd->countp == 0 || (*info->cmp)(buf, mrfd->buf) > 1)
-    {
-        memcpy (mrfd->buf, buf, mrfd->info->key_size);
-        (*mrfd->countp)++;
-    }
+    memcpy (buf, info->buf_mem + (mrfd->pos_cur - info->pos_buf),
+            rfd->rset->keycontrol->key_size);
+    if (term)
+        *term=rfd->rset->term; 
+        /* FIXME - should we store and return terms ?? */
+    mrfd->pos_cur = nc;
+    mrfd->cur++;
     return 1;
 }
 
 static int r_write (RSFD rfd, const void *buf)
 {
-    struct rset_temp_info *info = ((struct rset_temp_rfd*)rfd)->info;
+    struct rset_temp_rfd *mrfd = (struct rset_temp_rfd*) rfd->priv;  
+    struct rset_temp_info *info = (struct rset_temp_info *)rfd->rset->priv;
 
-    size_t nc = info->pos_cur + info->key_size;
+    size_t nc = mrfd->pos_cur + rfd->rset->keycontrol->key_size;
 
     if (nc > info->pos_buf + info->buf_size)
     {
         r_flush (rfd, 1);
-        info->pos_buf = info->pos_cur;
+        info->pos_buf = mrfd->pos_cur;
         if (info->pos_buf < info->pos_end)
             r_reread (rfd);
     }
     info->dirty = 1;
-    memcpy (info->buf_mem + (info->pos_cur - info->pos_buf), buf,
-            info->key_size);
-    info->pos_cur = nc;
+    memcpy (info->buf_mem + (mrfd->pos_cur - info->pos_buf), buf,
+            rfd->rset->keycontrol->key_size);
+    mrfd->pos_cur = nc;
     if (nc > info->pos_end)
         info->pos_border = info->pos_end = nc;
+    info->hits++;
     return 1;
 }
+
+static void r_pos (RSFD rfd, double  *current, double  *total)
+{
+    /* struct rset_temp_rfd *mrfd = (struct rset_temp_rfd*) rfd; */
+    struct rset_temp_rfd *mrfd = (struct rset_temp_rfd*) rfd->priv;  
+    struct rset_temp_info *info = (struct rset_temp_info *)rfd->rset->priv;
+    
+    *current=(double) mrfd->cur;
+    *total=(double) info->hits;
+}