tdb.c

Go to the documentation of this file.

#include "config.h"
#include <stddef.h>
#include <fcntl.h>
#include <tdb.h>
#include "mutt/lib.h"
#include "lib.h"

static void *store_tdb_open(const char *path)
{
  if (!path)
    return NULL;

  /* TDB_NOLOCK - Don't do any locking
   * TDB_NOSYNC - Don't use synchronous transactions
   * TDB_INCOMPATIBLE_HASH - Better hashing
   */
  const int flags = TDB_NOLOCK | TDB_INCOMPATIBLE_HASH | TDB_NOSYNC;
  const int hash_size = 33533; // Based on test timings for 100K emails
  return tdb_open(path, hash_size, flags, O_CREAT | O_RDWR, 00600);
}

static void *store_tdb_fetch(void *store, const char *key, size_t klen, size_t *vlen)
{
  if (!store)
    return NULL;

  TDB_CONTEXT *db = store;
  TDB_DATA dkey;
  TDB_DATA data;

  dkey.dptr = (unsigned char *) key;
  dkey.dsize = klen;
  data = tdb_fetch(db, dkey);

  *vlen = data.dsize;
  return data.dptr;
}

static void store_tdb_free(void *store, void **ptr)
{
  FREE(ptr);
}

static int store_tdb_store(void *store, const char *key, size_t klen, void *value, size_t vlen)
{
  if (!store)
    return -1;

  TDB_CONTEXT *db = store;
  TDB_DATA dkey;
  TDB_DATA databuf;

  dkey.dptr = (unsigned char *) key;
  dkey.dsize = klen;

  databuf.dsize = vlen;
  databuf.dptr = value;

  return tdb_store(db, dkey, databuf, TDB_INSERT);
}

static int store_tdb_delete_record(void *store, const char *key, size_t klen)
{
  if (!store)
    return -1;

  TDB_CONTEXT *db = store;
  TDB_DATA dkey;

  dkey.dptr = (unsigned char *) key;
  dkey.dsize = klen;

  return tdb_delete(db, dkey);
}

static void store_tdb_close(void **ptr)
{
  if (!ptr || !*ptr)
    return;

  TDB_CONTEXT *db = *ptr;
  tdb_close(db);
  *ptr = NULL;
}

static const char *store_tdb_version(void)
{
  // TDB doesn't supply any version info
  return "tdb";
}

STORE_BACKEND_OPS(tdb)