2 * Copyright (C) 1994-1999, Index Data
4 * Sebastian Hammer, Adam Dickmeiss
7 * Revision 1.1 1999-05-12 15:24:25 adam
8 * First version of ISAMS.
17 static void *r_create(RSET ct, const struct rset_control *sel, void *parms);
18 static RSFD r_open (RSET ct, int flag);
19 static void r_close (RSFD rfd);
20 static void r_delete (RSET ct);
21 static void r_rewind (RSFD rfd);
22 static int r_count (RSET ct);
23 static int r_read (RSFD rfd, void *buf, int *term_index);
24 static int r_write (RSFD rfd, const void *buf);
26 static const struct rset_control control =
39 const struct rset_control *rset_kind_isams = &control;
43 struct rset_pp_info *next;
44 struct rset_isams_info *info;
47 struct rset_isams_info {
50 struct rset_pp_info *ispt_list;
53 static void *r_create(RSET ct, const struct rset_control *sel, void *parms)
55 rset_isams_parms *pt = parms;
56 struct rset_isams_info *info;
58 ct->flags |= RSET_FLAG_VOLATILE;
59 info = xmalloc (sizeof(*info));
62 info->ispt_list = NULL;
63 ct->no_rset_terms = 1;
64 ct->rset_terms = xmalloc (sizeof(*ct->rset_terms));
65 ct->rset_terms[0] = pt->rset_term;
69 RSFD r_open (RSET ct, int flag)
71 struct rset_isams_info *info = ct->buf;
72 struct rset_pp_info *ptinfo;
74 logf (LOG_DEBUG, "risams_open");
75 if (flag & RSETF_WRITE)
77 logf (LOG_FATAL, "ISAMS set type is read-only");
80 ptinfo = xmalloc (sizeof(*ptinfo));
81 ptinfo->next = info->ispt_list;
82 info->ispt_list = ptinfo;
83 ptinfo->pt = isams_pp_open (info->is, info->pos);
85 if (ct->rset_terms[0]->nn < 0)
86 ct->rset_terms[0]->nn = isams_pp_num (ptinfo->pt);
90 static void r_close (RSFD rfd)
92 struct rset_isams_info *info = ((struct rset_pp_info*) rfd)->info;
93 struct rset_pp_info **ptinfop;
95 for (ptinfop = &info->ispt_list; *ptinfop; ptinfop = &(*ptinfop)->next)
98 isams_pp_close ((*ptinfop)->pt);
99 *ptinfop = (*ptinfop)->next;
103 logf (LOG_FATAL, "r_close but no rfd match!");
107 static void r_delete (RSET ct)
109 struct rset_isams_info *info = ct->buf;
111 logf (LOG_DEBUG, "rsisams_delete");
112 assert (info->ispt_list == NULL);
113 rset_term_destroy (ct->rset_terms[0]);
114 xfree (ct->rset_terms);
118 static void r_rewind (RSFD rfd)
120 logf (LOG_DEBUG, "rsisams_rewind");
124 static int r_count (RSET ct)
129 static int r_read (RSFD rfd, void *buf, int *term_index)
132 return isams_pp_read( ((struct rset_pp_info*) rfd)->pt, buf);
135 static int r_write (RSFD rfd, const void *buf)
137 logf (LOG_FATAL, "ISAMS set type is read-only");