-/* $Id: rset.c,v 1.53 2006-05-10 08:13:33 adam Exp $
- Copyright (C) 1995-2005
+/* $Id: rset.c,v 1.58 2007-01-17 15:35:48 adam Exp $
+ Copyright (C) 1995-2007
Index Data ApS
This file is part of the Zebra server.
for more details.
You should have received a copy of the GNU General Public License
-along with Zebra; see the file LICENSE.zebra. If not, write to the
-Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA
-02111-1307, USA.
+along with this program; if not, write to the Free Software
+Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
+
*/
#include <stdio.h>
return rnew;
}
+static void rset_close_int(RSET rs, RSFD rfd)
+{
+ RSFD *pfd;
+ (*rs->control->f_close)(rfd);
+
+ yaz_log(log_level, "rfd_delete_base: rfd=%p rs=%p priv=%p fl=%p",
+ rfd, rs, rfd->priv, rs->free_list);
+ for (pfd = &rs->use_list; *pfd; pfd = &(*pfd)->next)
+ if (*pfd == rfd)
+ {
+ *pfd = (*pfd)->next;
+ rfd->next = rs->free_list;
+ rs->free_list = rfd;
+ return;
+ }
+ yaz_log(YLOG_WARN, "rset_close handle not found. type=%s",
+ rs->control->desc);
+}
+
+void rset_set_hits_limit(RSET rs, zint l)
+{
+ rs->hits_limit = l;
+}
+
/**
\brief Closes a result set RFD handle
\param rfd the RFD handle.
*/
void rset_close(RSFD rfd)
{
- RSFD *pfd;
RSET rs = rfd->rset;
if (rs->hits_count == 0)
{
TERMID termid;
char buf[100];
+
while(rfd->counted_items <= rs->hits_limit
&& rset_default_read(rfd, buf, &termid))
;
yaz_log(log_level, "rset_close p=%p count=" ZINT_FORMAT, rs,
rs->hits_count);
}
- (*rs->control->f_close)(rfd);
-
- yaz_log(log_level, "rfd_delete_base: rfd=%p rs=%p priv=%p fl=%p",
- rfd, rs, rfd->priv, rs->free_list);
- for (pfd = &rs->use_list; *pfd; pfd = &(*pfd)->next)
- if (*pfd == rfd)
- {
- *pfd = (*pfd)->next;
- rfd->next = rs->free_list;
- rs->free_list = rfd;
- return;
- }
- yaz_log(YLOG_WARN, "rset_close handle not found. type=%s",
- rs->control->desc);
+ rset_close_int(rs, rfd);
}
/**
rset->hits_limit = 0;
rset->hits_round = 1000;
rset->keycontrol = kcontrol;
+
(*kcontrol->inc)(kcontrol);
rset->scope = scope;
rset->term = term;
(rs->refcount)++;
yaz_log(log_level, "rs_dup(%s), rs=%p, refcount=%d",
rs->control->desc, rs, rs->refcount);
- (*rs->keycontrol->inc)(rs->keycontrol);
return rs;
}
double cur, tot;
RSFD rfd = rset_open(rs, 0);
rset_pos(rfd, &cur, &tot);
- rset_close(rfd);
+ rset_close_int(rs, rfd);
return (zint) tot;
}
int rc = (*rset->control->f_read)(rfd, buf, term);
if (rc > 0)
{
- if (rfd->counted_items == 0 ||
- (rset->keycontrol->cmp)(buf, rfd->counted_buf) > rset->scope)
+ int got_scope;
+ if (rfd->counted_items == 0)
+ got_scope = rset->scope+1;
+ else
+ got_scope = rset->keycontrol->cmp(buf, rfd->counted_buf);
+
+#if 0
+ key_logdump_txt(YLOG_LOG, buf, "rset_default_read");
+ yaz_log(YLOG_LOG, "rset_scope=%d got_scope=%d", rset->scope, got_scope);
+#endif
+ if (got_scope > rset->scope)
{
memcpy(rfd->counted_buf, buf, rset->keycontrol->key_size);
rfd->counted_items++;