More prints
[idzebra-moved-to-github.git] / rset / rsisamc.c
1 /*
2  * Copyright (C) 1994-2002, Index Data
3  * All rights reserved.
4  *
5  * $Id: rsisamc.c,v 1.11 2002-04-05 08:46:26 adam Exp $
6  */
7
8
9 #include <stdio.h>
10 #include <assert.h>
11 #include <zebrautl.h>
12 #include <rsisamc.h>
13
14 static void *r_create(RSET ct, const struct rset_control *sel, void *parms);
15 static RSFD r_open (RSET ct, int flag);
16 static void r_close (RSFD rfd);
17 static void r_delete (RSET ct);
18 static void r_rewind (RSFD rfd);
19 static int r_count (RSET ct);
20 static int r_read (RSFD rfd, void *buf, int *term_index);
21 static int r_write (RSFD rfd, const void *buf);
22
23 static const struct rset_control control = 
24 {
25     "isamc",
26     r_create,
27     r_open,
28     r_close,
29     r_delete,
30     r_rewind,
31     r_count,
32     r_read,
33     r_write,
34 };
35
36 const struct rset_control *rset_kind_isamc = &control;
37
38 struct rset_pp_info {
39     ISAMC_PP pt;
40     struct rset_pp_info *next;
41     struct rset_isamc_info *info;
42     int *countp;
43     void *buf;
44 };
45
46 struct rset_isamc_info {
47     ISAMC   is;
48     ISAMC_P pos;
49     int key_size;
50     int (*cmp)(const void *p1, const void *p2);
51     struct rset_pp_info *ispt_list;
52 };
53
54 static void *r_create(RSET ct, const struct rset_control *sel, void *parms)
55 {
56     rset_isamc_parms *pt = (rset_isamc_parms *) parms;
57     struct rset_isamc_info *info;
58
59     ct->flags |= RSET_FLAG_VOLATILE;
60     info = (struct rset_isamc_info *) xmalloc (sizeof(*info));
61     info->is = pt->is;
62     info->pos = pt->pos;
63     info->key_size = pt->key_size;
64     info->cmp = pt->cmp;
65     info->ispt_list = NULL;
66     ct->no_rset_terms = 1;
67     ct->rset_terms = (RSET_TERM *) xmalloc (sizeof(*ct->rset_terms));
68     ct->rset_terms[0] = pt->rset_term;
69     return info;
70 }
71
72 RSFD r_open (RSET ct, int flag)
73 {
74     struct rset_isamc_info *info = (struct rset_isamc_info *) ct->buf;
75     struct rset_pp_info *ptinfo;
76
77     logf (LOG_DEBUG, "risamc_open");
78     if (flag & RSETF_WRITE)
79     {
80         logf (LOG_FATAL, "ISAMC set type is read-only");
81         return NULL;
82     }
83     ptinfo = (struct rset_pp_info *) xmalloc (sizeof(*ptinfo));
84     ptinfo->next = info->ispt_list;
85     info->ispt_list = ptinfo;
86     ptinfo->pt = isc_pp_open (info->is, info->pos);
87     ptinfo->info = info;
88     if (ct->rset_terms[0]->nn < 0)
89         ct->rset_terms[0]->nn = isc_pp_num (ptinfo->pt);
90     ct->rset_terms[0]->count = 0;
91     ptinfo->countp = &ct->rset_terms[0]->count;
92     ptinfo->buf = xmalloc (info->key_size);
93     return ptinfo;
94 }
95
96 static void r_close (RSFD rfd)
97 {
98     struct rset_isamc_info *info = ((struct rset_pp_info*) rfd)->info;
99     struct rset_pp_info **ptinfop;
100
101     for (ptinfop = &info->ispt_list; *ptinfop; ptinfop = &(*ptinfop)->next)
102         if (*ptinfop == rfd)
103         {
104             xfree ((*ptinfop)->buf);
105             isc_pp_close ((*ptinfop)->pt);
106             *ptinfop = (*ptinfop)->next;
107             xfree (rfd);
108             return;
109         }
110     logf (LOG_FATAL, "r_close but no rfd match!");
111     assert (0);
112 }
113
114 static void r_delete (RSET ct)
115 {
116     struct rset_isamc_info *info = (struct rset_isamc_info *) ct->buf;
117
118     logf (LOG_DEBUG, "rsisamc_delete");
119     assert (info->ispt_list == NULL);
120     rset_term_destroy (ct->rset_terms[0]);
121     xfree (ct->rset_terms);
122     xfree (info);
123 }
124
125 static void r_rewind (RSFD rfd)
126 {   
127     logf (LOG_DEBUG, "rsisamc_rewind");
128     abort ();
129 }
130
131 static int r_count (RSET ct)
132 {
133     return 0;
134 }
135
136 static int r_read (RSFD rfd, void *buf, int *term_index)
137 {
138     struct rset_pp_info *pinfo = (struct rset_pp_info *) rfd;
139     int r;
140     *term_index = 0;
141     r = isc_pp_read(pinfo->pt, buf);
142     if (r > 0)
143     {
144         if (*pinfo->countp == 0 || (*pinfo->info->cmp)(buf, pinfo->buf) > 1)
145         {
146             memcpy (pinfo->buf, buf, pinfo->info->key_size);
147             (*pinfo->countp)++;
148         }
149     }
150     return r;
151 }
152
153 static int r_write (RSFD rfd, const void *buf)
154 {
155     logf (LOG_FATAL, "ISAMC set type is read-only");
156     return -1;
157 }