store.h

Go to the documentation of this file.

 
#ifndef VOLK_STORE_H
#define VOLK_STORE_H
 
/*
 * Add new back end headers here.
 */
#include "volksdata/store_htable.h"
#include "volksdata/store_mdb.h"

 
/*
 * Define backend types.
 *
 * Add new store implementations to this table.
 */
#define BACKEND_TBL                                                           \
/*          #enum suffix#store if       */\
    ENTRY(  HTABLE,     htstore_int  )  \
    ENTRY(  MDB,        mdbstore_int ) \
 

typedef enum {
#define ENTRY(a, b) \
    VOLK_STORE_##a,
BACKEND_TBL
#undef ENTRY
} VOLK_StoreType;
 

typedef struct store_t {
    VOLK_StoreType                  type;   
    char *                          id;     
 
    const VOLK_StoreInt *           sif;    
    void *                          data;   
} VOLK_Store;
 

const VOLK_StoreInt *
VOLK_store_int (VOLK_StoreType type);
 

const char *
VOLK_store_type_label (VOLK_StoreType type);
 

VOLK_Store *
VOLK_store_new (
        const VOLK_StoreType store_type, const char *store_id, size_t size,
        bool clear);
 

void
VOLK_store_free (VOLK_Store *store);
 

size_t
VOLK_store_size (const VOLK_Store *store);
 

VOLK_StoreFeature
VOLK_store_features (const VOLK_Store *store);
 

char *
VOLK_store_id (const VOLK_Store *store);
 

VOLK_rc
VOLK_store_begin (VOLK_Store *store, VOLK_StoreFlags flags, void **txn);
 

VOLK_rc
VOLK_store_commit (VOLK_Store *store, void *txn);
 

void
VOLK_store_abort (VOLK_Store *store, void *txn);
 

VOLK_rc
VOLK_store_update_ctx_txn (
        VOLK_Store *store, void *txn, const VOLK_Buffer *old_c,
        const VOLK_Buffer *new_c);
 
#define VOLK_store_update_ctx(store, ...) \
    VOLK_store_update_txn (store, NULL, __VA_ARGS__)
 

void *
VOLK_store_add_init_txn (
        VOLK_Store *store, void *txn, const VOLK_Buffer *sc);

#define VOLK_store_add_init(store, ...) \
    VOLK_store_add_init_txn (store, NULL, __VA_ARGS__)
 

VOLK_rc
VOLK_store_add_iter (
        VOLK_Store *store, void *it, const VOLK_BufferTriple *sspo);
 

void
VOLK_store_add_abort (VOLK_Store *store, void *it);
 

VOLK_rc
VOLK_store_add_done (VOLK_Store *store, void *it);
 

VOLK_rc
VOLK_store_add_term_txn (VOLK_Store *store, void *txn, VOLK_Buffer *sterm);

#define VOLK_store_add_term(store, ...) \
    VOLK_store_add_term_txn (store, NULL, __VA_ARGS__)
 

void *
VOLK_store_lookup_txn (
        const VOLK_Store *store, void *txn,
        const VOLK_Buffer *ss, const VOLK_Buffer *sp, const VOLK_Buffer *so,
        const VOLK_Buffer *sc, size_t *ct);

#define VOLK_store_lookup(store, ...) \
    VOLK_store_lookup_txn (store, NULL, __VA_ARGS__)
 

VOLK_rc
VOLK_store_iter_next (
        VOLK_Store *store, void *it, VOLK_BufferTriple *sspo,
        VOLK_Buffer **ctx);
 

void
VOLK_store_iter_free (VOLK_Store *store, void *it);
 

void *
VOLK_store_iter_txn (const VOLK_Store *store, void *it);
 

VOLK_rc
VOLK_store_remove_txn (
        VOLK_Store *store, void *txn,
        const VOLK_Buffer *ss, const VOLK_Buffer *sp, const VOLK_Buffer *so,
        const VOLK_Buffer *sc, size_t *ct);

#define VOLK_store_remove(store, ...) \
    VOLK_store_remove_txn (store, NULL, __VA_ARGS__)
 

VOLK_Buffer **
VOLK_store_ctx_list_txn (VOLK_Store *store, void *txn);

#define VOLK_store_ctx_list(store) \
    VOLK_store_ctx_list_txn (store, NULL)

 
#endif  // VOLK_STORE_H