2 * Copyright (C) 1994-1995, Index Data I/S
4 * Sebastian Hammer, Adam Dickmeiss
7 * Revision 1.13 1997-12-18 10:54:24 adam
8 * New method result set method rs_hits that returns the number of
9 * hits in result-set (if known). The ranked result set returns real
10 * number of hits but only when not combined with other operands.
12 * Revision 1.12 1997/10/31 12:37:01 adam
13 * Code calls xfree() instead of free().
15 * Revision 1.11 1997/09/09 13:38:15 adam
16 * Partial port to WIN95/NT.
18 * Revision 1.10 1996/10/29 13:55:20 adam
19 * Include of zebrautl.h instead of alexutil.h.
21 * Revision 1.9 1995/12/11 09:15:22 adam
22 * New set types: sand/sor/snot - ranked versions of and/or/not in
23 * ranked/semi-ranked result sets.
24 * Note: the snot not finished yet.
25 * New rset member: flag.
26 * Bug fix: r_delete in rsrel.c did free bad memory block.
28 * Revision 1.8 1995/10/12 12:41:55 adam
29 * Private info (buf) moved from struct rset_control to struct rset.
30 * Bug fixes in relevance.
32 * Revision 1.7 1995/10/10 14:00:03 adam
33 * Function rset_open changed its wflag parameter to general flags.
35 * Revision 1.6 1995/10/06 14:38:05 adam
36 * New result set method: r_score.
37 * Local no (sysno) and score is transferred to retrieveCtrl.
39 * Revision 1.5 1995/09/08 14:52:41 adam
40 * Work on relevance feedback.
42 * Revision 1.4 1995/09/08 08:54:04 adam
43 * More efficient and operation.
45 * Revision 1.3 1995/09/07 13:58:43 adam
46 * New parameter: result-set file descriptor (RSFD) to support multiple
47 * positions within the same result-set.
48 * Boolean operators: and, or, not implemented.
50 * Revision 1.2 1995/09/06 16:11:55 adam
51 * More work on boolean sets.
53 * Revision 1.1 1995/09/06 13:27:15 adam
54 * New set type: bool. Not finished yet.
66 static void *r_create(const struct rset_control *sel, void *parms,
68 static RSFD r_open (RSET ct, int flag);
69 static void r_close (RSFD rfd);
70 static void r_delete (RSET ct);
71 static void r_rewind (RSFD rfd);
72 static int r_count (RSET ct);
73 static int r_hits (RSET ct, void *oi);
74 static int r_read_and (RSFD rfd, void *buf);
75 static int r_read_or (RSFD rfd, void *buf);
76 static int r_read_not (RSFD rfd, void *buf);
77 static int r_write (RSFD rfd, const void *buf);
78 static int r_score (RSFD rfd, int *score);
80 static const rset_control control_and =
95 static const rset_control control_or =
110 static const rset_control control_not =
126 const rset_control *rset_kind_and = &control_and;
127 const rset_control *rset_kind_or = &control_or;
128 const rset_control *rset_kind_not = &control_not;
130 struct rset_bool_info {
134 int (*cmp)(const void *p1, const void *p2);
135 struct rset_bool_rfd *rfd_list;
138 struct rset_bool_rfd {
145 struct rset_bool_rfd *next;
146 struct rset_bool_info *info;
149 static void *r_create (const struct rset_control *sel, void *parms,
152 rset_bool_parms *bool_parms = parms;
153 struct rset_bool_info *info;
155 info = xmalloc (sizeof(*info));
156 info->key_size = bool_parms->key_size;
157 info->rset_l = bool_parms->rset_l;
158 info->rset_r = bool_parms->rset_r;
159 if (rset_is_volatile(info->rset_l) || rset_is_volatile(info->rset_r))
160 *flags |= RSET_FLAG_VOLATILE;
161 info->cmp = bool_parms->cmp;
162 info->rfd_list = NULL;
166 static RSFD r_open (RSET ct, int flag)
168 struct rset_bool_info *info = ct->buf;
169 struct rset_bool_rfd *rfd;
171 if (flag & RSETF_WRITE)
173 logf (LOG_FATAL, "bool set type is read-only");
176 rfd = xmalloc (sizeof(*rfd));
177 rfd->next = info->rfd_list;
178 info->rfd_list = rfd;
181 rfd->buf_l = xmalloc (info->key_size);
182 rfd->buf_r = xmalloc (info->key_size);
183 rfd->rfd_l = rset_open (info->rset_l, RSETF_READ|RSETF_SORT_SYSNO);
184 rfd->rfd_r = rset_open (info->rset_r, RSETF_READ|RSETF_SORT_SYSNO);
185 rfd->more_l = rset_read (info->rset_l, rfd->rfd_l, rfd->buf_l);
186 rfd->more_r = rset_read (info->rset_r, rfd->rfd_r, rfd->buf_r);
190 static void r_close (RSFD rfd)
192 struct rset_bool_info *info = ((struct rset_bool_rfd*)rfd)->info;
193 struct rset_bool_rfd **rfdp;
195 for (rfdp = &info->rfd_list; *rfdp; rfdp = &(*rfdp)->next)
198 xfree ((*rfdp)->buf_l);
199 xfree ((*rfdp)->buf_r);
200 rset_close (info->rset_l, (*rfdp)->rfd_l);
201 rset_close (info->rset_r, (*rfdp)->rfd_r);
202 *rfdp = (*rfdp)->next;
206 logf (LOG_FATAL, "r_close but no rfd match!");
210 static void r_delete (RSET ct)
212 struct rset_bool_info *info = ct->buf;
214 assert (info->rfd_list == NULL);
215 rset_delete (info->rset_l);
216 rset_delete (info->rset_r);
220 static void r_rewind (RSFD rfd)
222 struct rset_bool_info *info = ((struct rset_bool_rfd*)rfd)->info;
223 struct rset_bool_rfd *p = rfd;
225 logf (LOG_DEBUG, "rsbool_rewind");
226 rset_rewind (info->rset_l, p->rfd_l);
227 rset_rewind (info->rset_r, p->rfd_r);
228 p->more_l = rset_read (info->rset_l, p->rfd_l, p->buf_l);
229 p->more_r = rset_read (info->rset_r, p->rfd_r, p->buf_r);
232 static int r_count (RSET ct)
237 static int r_hits (RSET ct, void *oi)
242 static int r_read_and (RSFD rfd, void *buf)
244 struct rset_bool_rfd *p = rfd;
245 struct rset_bool_info *info = p->info;
247 while (p->more_l && p->more_r)
251 cmp = (*info->cmp)(p->buf_l, p->buf_r);
254 memcpy (buf, p->buf_l, info->key_size);
255 p->more_l = rset_read (info->rset_l, p->rfd_l, p->buf_l);
256 p->more_r = rset_read (info->rset_r, p->rfd_r, p->buf_r);
261 memcpy (buf, p->buf_r, info->key_size);
262 p->more_r = rset_read (info->rset_r, p->rfd_r, p->buf_r);
267 memcpy (buf, p->buf_l, info->key_size);
268 p->more_l = rset_read (info->rset_l, p->rfd_l, p->buf_l);
272 p->more_r = rset_read (info->rset_r, p->rfd_r, p->buf_r);
274 p->more_l = rset_read (info->rset_l, p->rfd_l, p->buf_l);
279 static int r_read_or (RSFD rfd, void *buf)
281 struct rset_bool_rfd *p = rfd;
282 struct rset_bool_info *info = p->info;
284 while (p->more_l || p->more_r)
288 if (p->more_l && p->more_r)
289 cmp = (*info->cmp)(p->buf_l, p->buf_r);
296 memcpy (buf, p->buf_l, info->key_size);
297 p->more_l = rset_read (info->rset_l, p->rfd_l, p->buf_l);
298 p->more_r = rset_read (info->rset_r, p->rfd_r, p->buf_r);
303 memcpy (buf, p->buf_r, info->key_size);
304 p->more_r = rset_read (info->rset_r, p->rfd_r, p->buf_r);
309 memcpy (buf, p->buf_l, info->key_size);
310 p->more_l = rset_read (info->rset_l, p->rfd_l, p->buf_l);
317 static int r_read_not (RSFD rfd, void *buf)
319 struct rset_bool_rfd *p = rfd;
320 struct rset_bool_info *info = p->info;
322 while (p->more_l || p->more_r)
326 if (p->more_l && p->more_r)
327 cmp = (*info->cmp)(p->buf_l, p->buf_r);
334 memcpy (buf, p->buf_l, info->key_size);
335 p->more_l = rset_read (info->rset_l, p->rfd_l, p->buf_l);
339 p->more_r = rset_read (info->rset_r, p->rfd_r, p->buf_r);
342 memcpy (buf, p->buf_l, info->key_size);
345 p->more_l = rset_read (info->rset_l, p->rfd_l, p->buf_l);
348 cmp = (*info->cmp)(p->buf_l, buf);
349 } while (cmp >= -1 && cmp <= 1);
352 p->more_r = rset_read (info->rset_r, p->rfd_r, p->buf_r);
355 cmp = (*info->cmp)(p->buf_r, buf);
356 } while (cmp >= -1 && cmp <= 1);
363 static int r_write (RSFD rfd, const void *buf)
365 logf (LOG_FATAL, "bool set type is read-only");
369 static int r_score (RSFD rfd, int *score)