Extended the result set system. Added support for filtering/limits.

[idzebra-moved-to-github.git] / index / kcontrol.c

diff --git a/index/kcontrol.c b/index/kcontrol.c
new file mode 100644 (file)
index 0000000..ad7f81f
--- /dev/null
+++ b/index/kcontrol.c
@@ -0,0 +1,76 @@
+/* $Id: kcontrol.c,v 1.1 2005-05-03 09:11:34 adam Exp $
+   Copyright (C) 1995-2005
+   Index Data ApS
+
+This file is part of the Zebra server.
+
+Zebra is free software; you can redistribute it and/or modify it under
+the terms of the GNU General Public License as published by the Free
+Software Foundation; either version 2, or (at your option) any later
+version.
+
+Zebra is distributed in the hope that it will be useful, but WITHOUT ANY
+WARRANTY; without even the implied warranty of MERCHANTABILITY or
+FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
+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.
+*/
+
+#include <assert.h>
+#include "index.h"
+
+struct context_control {
+    int ref_count;
+    void (*filter_destroy)(void *data);
+};
+
+static void my_inc(struct rset_key_control *kc)
+{
+    struct context_control *cp;
+
+    assert(kc);
+    cp = kc->context;
+    (cp->ref_count)++;
+}
+
+static void my_dec(struct rset_key_control *kc)
+{
+    struct context_control *cp;
+
+    assert(kc);
+    cp = kc->context;
+    (cp->ref_count)--;
+    if (cp->ref_count == 0)
+    {
+       if (cp->filter_destroy)
+           (*cp->filter_destroy)(kc->filter_data);
+       xfree(cp);
+       xfree(kc);
+    }
+}
+
+struct rset_key_control *zebra_key_control_create(ZebraHandle zh)
+{
+    struct rset_key_control *kc = xmalloc(sizeof(*kc));
+    struct context_control *cp = xmalloc(sizeof(*cp));
+
+    kc->context = cp;
+    kc->key_size = sizeof(struct it_key);
+    kc->scope = 2;
+    kc->cmp = key_compare_it;
+    kc->key_logdump_txt = key_logdump_txt;
+    kc->getseq = key_get_seq;
+    zebra_limit_for_rset(zh->m_limit, 
+                        &kc->filter_func,
+                        &cp->filter_destroy,
+                        &kc->filter_data);
+    kc->inc = my_inc;
+    kc->dec = my_dec;
+    cp->ref_count = 1;
+    return kc;
+}
+