open()

Open a connection to a Store. More...

Collaboration diagram for open():

Functions
static StoreHandle *	store_gdbm_open (const char *path, bool create)
	Open a connection to a Store - Implements StoreOps::open() -.
static StoreHandle *	store_lmdb_open (const char *path, bool create)
	Open a connection to a Store - Implements StoreOps::open() -.
static StoreHandle *	store_rocksdb_open (const char *path, bool create)
	Open a connection to a Store - Implements StoreOps::open() -.
static StoreHandle *	store_tdb_open (const char *path, bool create)
	Open a connection to a Store - Implements StoreOps::open() -.

Detailed Description

Open a connection to a Store.

Parameters

[in]	path	Path to the database file
[in]	create	Create the file if it's not there?

Return values

ptr	Success, Store pointer
NULL	Failure

The open function has the purpose of opening a backend-specific connection to the database file specified by the path parameter. Backends MUST return non-NULL specific handle information on success.

Function Documentation

store_gdbm_open()

static StoreHandle * store_gdbm_open ( const char * path, bool create )

static

Open a connection to a Store - Implements StoreOps::open() -.

Definition at line 42 of file gdbm.c.

{
  if (!path)
    return NULL;
 
  const int pagesize = 4096;
 
  GDBM_FILE db = gdbm_open((char *) path, pagesize,
                           create ? GDBM_WRCREAT : GDBM_WRITER, 00600, NULL);
  if (!db)
  {
    /* if rw failed try ro */
    db = gdbm_open((char *) path, pagesize, GDBM_READER, 00600, NULL);
  }
 
  // Return an opaque pointer
  return (StoreHandle *) db;
}

store_lmdb_open()

static StoreHandle * store_lmdb_open ( const char * path, bool create )

static

Open a connection to a Store - Implements StoreOps::open() -.

Definition at line 150 of file lmdb.c.

{
  if (!path)
    return NULL;
 
  if (!create && access(path, F_OK) != 0)
  {
    return NULL;
  }
 
  struct LmdbStoreData *sdata = lmdb_sdata_new();
 
  int rc = mdb_env_create(&sdata->env);
  if (rc != MDB_SUCCESS)
  {
    mutt_debug(LL_DEBUG2, "mdb_env_create: %s\n", mdb_strerror(rc));
    lmdb_sdata_free(&sdata);
    return NULL;
  }
 
  mdb_env_set_mapsize(sdata->env, LMDB_DB_SIZE);
 
  rc = mdb_env_open(sdata->env, path, MDB_NOSUBDIR, 0600);
  if (rc != MDB_SUCCESS)
  {
    mutt_debug(LL_DEBUG2, "mdb_env_open: %s\n", mdb_strerror(rc));
    goto fail_env;
  }
 
  rc = lmdb_get_read_txn(sdata);
  if (rc != MDB_SUCCESS)
  {
    mutt_debug(LL_DEBUG2, "mdb_txn_begin: %s\n", mdb_strerror(rc));
    goto fail_env;
  }
 
  rc = mdb_dbi_open(sdata->txn, NULL, MDB_CREATE, &sdata->db);
  if (rc != MDB_SUCCESS)
  {
    mutt_debug(LL_DEBUG2, "mdb_dbi_open: %s\n", mdb_strerror(rc));
    goto fail_dbi;
  }
 
  mdb_txn_reset(sdata->txn);
  sdata->txn_mode = TXN_UNINITIALIZED;
  // Return an opaque pointer
  return (StoreHandle *) sdata;
 
fail_dbi:
  mdb_txn_abort(sdata->txn);
  sdata->txn_mode = TXN_UNINITIALIZED;
  sdata->txn = NULL;
 
fail_env:
  mdb_env_close(sdata->env);
  lmdb_sdata_free(&sdata);
  return NULL;
}

Here is the call graph for this function:

store_rocksdb_open()

static StoreHandle * store_rocksdb_open ( const char * path, bool create )

static

Open a connection to a Store - Implements StoreOps::open() -.

Definition at line 77 of file rocksdb.c.

{
  if (!path)
    return NULL;
 
  struct RocksDbStoreData *sdata = rocksdb_sdata_new();
 
  /* RocksDB stores errors in form of strings */
  sdata->err = NULL;
 
  /* setup generic options, create new db and limit log to one file */
  sdata->options = rocksdb_options_create();
  if (create)
  {
    rocksdb_options_set_create_if_missing(sdata->options, 1);
  }
  rocksdb_options_set_keep_log_file_num(sdata->options, 1);
 
  /* setup read options, we verify with checksums */
  sdata->read_options = rocksdb_readoptions_create();
  rocksdb_readoptions_set_verify_checksums(sdata->read_options, 1);
 
  /* setup write options, no sync needed, disable WAL */
  sdata->write_options = rocksdb_writeoptions_create();
  rocksdb_writeoptions_set_sync(sdata->write_options, 0);
  rocksdb_writeoptions_disable_WAL(sdata->write_options, 1);
 
  rocksdb_options_set_compression(sdata->options, rocksdb_no_compression);
 
  /* open database and check for error in sdata->error */
  sdata->db = rocksdb_open(sdata->options, path, &sdata->err);
  if (sdata->err)
  {
    rocksdb_options_destroy(sdata->options);
    rocksdb_readoptions_destroy(sdata->read_options);
    rocksdb_writeoptions_destroy(sdata->write_options);
    rocksdb_sdata_free(&sdata);
    return NULL;
  }
 
  // Return an opaque pointer
  return (StoreHandle *) sdata;
}

Here is the call graph for this function:

store_tdb_open()

static StoreHandle * store_tdb_open ( const char * path, bool create )

static

Open a connection to a Store - Implements StoreOps::open() -.

Definition at line 42 of file tdb.c.

{
  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
 
  struct tdb_context *db = tdb_open(path, hash_size, flags,
                                    (create ? O_CREAT : 0) | O_RDWR, 00600);
 
  // Return an opaque pointer
  return (StoreHandle *) db;
}