+ }
+ sset->rset = rset;
+ return ZEBRA_OK;
+}
+
+
+ZEBRA_RES resultSetAddRPN (ZebraHandle zh, NMEM m, Z_RPNQuery *rpn,
+ int num_bases, char **basenames,
+ const char *setname)
+{
+ ZebraSet zebraSet;
+ int i;
+ ZEBRA_RES res;
+
+ zh->errCode = 0;
+ zh->errString = NULL;
+ zh->hits = 0;
+
+ zebraSet = resultSetAdd (zh, setname, 1);
+ if (!zebraSet)
+ return ZEBRA_FAIL;
+ zebraSet->locked = 1;
+ zebraSet->rpn = 0;
+ zebraSet->nmem = m;
+ zebraSet->rset_nmem = nmem_create();
+
+ zebraSet->num_bases = num_bases;
+ zebraSet->basenames =
+ nmem_malloc (zebraSet->nmem, num_bases * sizeof(*zebraSet->basenames));
+ for (i = 0; i<num_bases; i++)
+ zebraSet->basenames[i] = nmem_strdup (zebraSet->nmem, basenames[i]);
+
+ res = resultSetSearch(zh, zebraSet->nmem, zebraSet->rset_nmem,
+ rpn, zebraSet);
+ zh->hits = zebraSet->hits;
+ if (zebraSet->rset)
+ zebraSet->rpn = rpn;
+ zebraSet->locked = 0;
+ if (!zebraSet->rset)
+ return ZEBRA_FAIL;
+ return res;
+}
+
+void resultSetAddTerm (ZebraHandle zh, ZebraSet s, int reg_type,
+ const char *db, int set,
+ int use, const char *term)
+{
+ assert(zh); /* compiler shut up */
+ if (!s->nmem)
+ s->nmem = nmem_create ();
+ if (!s->term_entries)
+ {
+ int i;
+ s->term_entries_max = 1000;
+ s->term_entries =
+ nmem_malloc (s->nmem, s->term_entries_max *
+ sizeof(*s->term_entries));
+ for (i = 0; i < s->term_entries_max; i++)
+ s->term_entries[i].term = 0;
+ }
+ if (s->hits < s->term_entries_max)
+ {
+ s->term_entries[s->hits].reg_type = reg_type;
+ s->term_entries[s->hits].db = nmem_strdup (s->nmem, db);
+ s->term_entries[s->hits].set = set;
+ s->term_entries[s->hits].use = use;
+ s->term_entries[s->hits].term = nmem_strdup (s->nmem, term);
+ }
+ (s->hits)++;
+}
+
+ZebraSet resultSetAdd (ZebraHandle zh, const char *name, int ov)
+{
+ ZebraSet s;
+ int i;
+
+ for (s = zh->sets; s; s = s->next)
+ if (!strcmp (s->name, name))
+ break;
+
+ if (!log_level_set)
+ loglevels();
+ if (s)
+ {
+ yaz_log(log_level_resultsets, "updating result set %s", name);
+ if (!ov || s->locked)
+ return NULL;
+ if (s->rset)
+ {
+ if (s->cache_rfd)
+ rset_close(s->cache_rfd);
+ rset_delete (s->rset);
+ }
+ if (s->rset_nmem)
+ nmem_destroy (s->rset_nmem);
+ if (s->nmem)
+ nmem_destroy (s->nmem);
+ }
+ else
+ {
+ const char *sort_max_str = zebra_get_resource(zh, "sortmax", "1000");
+
+ yaz_log(log_level_resultsets, "adding result set %s", name);
+ s = (ZebraSet) xmalloc (sizeof(*s));
+ s->next = zh->sets;
+ zh->sets = s;
+ s->name = (char *) xmalloc (strlen(name)+1);
+ strcpy (s->name, name);
+
+ s->sort_info = (struct zset_sort_info *)
+ xmalloc (sizeof(*s->sort_info));
+ s->sort_info->max_entries = atoi(sort_max_str);
+ if (s->sort_info->max_entries < 2)
+ s->sort_info->max_entries = 2;
+
+ s->sort_info->entries = (struct zset_sort_entry **)
+ xmalloc (sizeof(*s->sort_info->entries) *
+ s->sort_info->max_entries);
+ s->sort_info->all_entries = (struct zset_sort_entry *)
+ xmalloc (sizeof(*s->sort_info->all_entries) *
+ s->sort_info->max_entries);
+ for (i = 0; i < s->sort_info->max_entries; i++)
+ s->sort_info->entries[i] = s->sort_info->all_entries + i;
+ }
+ s->locked = 0;
+ s->term_entries = 0;
+ s->hits = 0;
+ s->rset = 0;
+ s->rset_nmem = 0;
+ s->nmem = 0;
+ s->rpn = 0;
+ s->cache_position = 0;
+ s->cache_rfd = 0;