dataset.c

Go to the documentation of this file.

#include "volksdata/dataset.h"
 
 
VOLK_Dataset *
VOLK_dataset_new (VOLK_Store *store)
{
    VOLK_Dataset *ds = malloc (sizeof (*ds));
    NLNL (ds);
 
    ds->store = store;
    ds->gr = VOLK_term_set_new();
 
    return ds;
}
 
 
VOLK_Dataset *
VOLK_dataset_new_from_store_txn (void *txn, VOLK_Store *store)
{
    VOLK_Buffer **tdata = VOLK_store_ctx_list_txn (store, txn);
    NLNL (tdata);
    size_t i = 0;
    VOLK_Dataset *ds = malloc (sizeof (*ds));
    NLCHECK (ds, fail_ds);
 
    ds->store = store;
    ds->gr = VOLK_term_set_new();
    NLCHECK (ds->gr, fail_gr);
 
    while (tdata[i]) {
        VOLK_Term *t = VOLK_term_new_from_buffer (tdata[i]);
        VOLK_rc rc = VOLK_term_set_add (ds->gr, t, NULL);
        VOLK_buffer_free (tdata[i]);
        if (UNLIKELY (rc != VOLK_OK)) {
            VOLK_term_free (t);
            goto fail_t;
        }
        i++;
    }
    free (tdata);
 
    return ds;
 
fail_t:
    i++;  // tdata[i] was already freed.
fail_gr:
    VOLK_term_set_free (ds->gr);
fail_ds:
    while (tdata[i]) VOLK_buffer_free (tdata[i++]);
    free (tdata);
    return NULL;
}
 
 
void
VOLK_dataset_free (VOLK_Dataset *ds)
{
    VOLK_term_set_free (ds->gr);
    free (ds);
}
 
 
size_t
VOLK_dataset_size (VOLK_Dataset *ds)
{
    size_t
        ct = 0,
        i = 0;
    VOLK_Term *c = NULL;
    VOLK_rc rc;
    while ((rc = VOLK_term_set_next (ds->gr, &i, &c)) != VOLK_END) {
        RCCK (rc);  // FIXME This only returns an undefined size_t value.
        VOLK_Graph *gr = VOLK_graph_new (ds->store, c->data);
        ct += VOLK_graph_size (gr);
        VOLK_graph_free (gr);
    }
 
    return ct;
}
 
 
/*
 * Inline prototypes.
 */
VOLK_rc VOLK_dataset_add (VOLK_Dataset *ds, const VOLK_Graph *gr);
VOLK_rc VOLK_dataset_remove (VOLK_Dataset *ds, const VOLK_Graph *gr);
bool VOLK_dataset_contains (VOLK_Dataset *ds, const VOLK_Graph *gr);