mariadb/src-bdbwrap/bdbw.h

#ifndef _BDBW_H
#define _BDBW_H

#if defined(__cplusplus)
extern "C" {
#if 0
}
#endif
#endif

int db_env_create_bdbw (struct __toku_db_env **, u_int32_t);
int txn_abort_bdbw (struct __toku_db_txn *);
int txn_begin_bdbw (struct __toku_db_env *env, struct __toku_db_txn *stxn, struct __toku_db_txn **txn, u_int32_t flags);
int txn_commit_bdbw (struct __toku_db_txn *, u_int32_t);
int db_create_bdbw (struct __toku_db **, struct __toku_db_env *, u_int32_t);


#if 0
typedef enum {
	DB_BTREE=1,
	//	DB_HASH=2,
	//	DB_RECNO=3,
	//	DB_QUEUE=4,
	//	DB_UNKNOWN=5			/* Figure it out on open. */
} DBTYPE;

typedef enum {
	DB_NOTICE_LOGFILE_CHANGED
} db_notices;

enum {
  DB_VERB_CHKPOINT = 0x0001,
  DB_VERB_DEADLOCK = 0x0002,
  DB_VERB_RECOVERY = 0x0004
  
};

typedef struct __toku_db DB;
typedef struct yobi_db_btree_stat DB_BTREE_STAT;
typedef struct __toku_db_env DB_ENV;
typedef struct yobi_db_key_range DB_KEY_RANGE;
typedef struct yobi_db_lsn DB_LSN;
typedef struct __toku_db_txn DB_TXN;
typedef struct __toku_db_txn_active DB_TXN_ACTIVE;
typedef struct __toku_db_txn_stat DB_TXN_STAT;
typedef struct yobi_dbc DBC;
typedef struct yobi_dbt DBT;

struct __toku_db {
  void *app_private;
  int  (*close) (DB *, u_int32_t);
  int  (*cursor) (DB *, DB_TXN *, DBC **, u_int32_t);
  int  (*del) (DB *, DB_TXN *, DBT *, u_int32_t);
  int  (*get) (DB *, DB_TXN *, DBT *, DBT *, u_int32_t);
  int  (*key_range) (DB *, DB_TXN *, DBT *, DB_KEY_RANGE *, u_int32_t);
  int  (*open) (DB *, DB_TXN *,
		const char *, const char *, DBTYPE, u_int32_t, int);
  int  (*put) (DB *, DB_TXN *, DBT *, DBT *, u_int32_t);
  int  (*remove) (DB *, const char *, const char *, u_int32_t);
  int  (*rename) (DB *, const char *, const char *, const char *, u_int32_t);
  int  (*set_bt_compare) (DB *,
			  int (*)(DB *, const DBT *, const DBT *));
  int  (*set_flags)    (DB *, u_int32_t);
  int  (*stat) (DB *, void *, u_int32_t);

  struct __toku_db_internal *i;
};
enum {
  DB_DBT_MALLOC = 0x002,
  DB_DBT_REALLOC = 0x010,
  DB_DBT_USERMEM = 0x020,
  DB_DBT_DUPOK  = 0x040
};
struct yobi_dbt {
  void	*app_private;
  void     *data;
  u_int32_t flags;
  u_int32_t size;
  u_int32_t ulen;
};
struct __toku_db_txn {
  int (*commit) (DB_TXN*, u_int32_t);
  u_int32_t (*id) (DB_TXN *);
};
struct yobi_dbc {
  int (*c_get) (DBC *, DBT *, DBT *, u_int32_t);
  int (*c_close) (DBC *);
  int (*c_del) (DBC *, u_int32_t);
};
struct __toku_db_env {
  // Methods used by MYSQL
  void (*err) (const DB_ENV *, int, const char *, ...);
  int  (*open) (DB_ENV *, const char *, u_int32_t, int);
  int  (*close) (DB_ENV *, u_int32_t);
  int  (*txn_checkpoint) (DB_ENV *, u_int32_t, u_int32_t, u_int32_t);
  int  (*log_flush) (DB_ENV *, const DB_LSN *);
  void (*set_errcall) (DB_ENV *, void (*)(const char *, char *));
  void (*set_errpfx) (DB_ENV *, const char *);
  void (*set_noticecall) (DB_ENV *, void (*)(DB_ENV *, db_notices));
  int  (*set_flags) (DB_ENV *, u_int32_t, int);
  int  (*set_data_dir) (DB_ENV *, const char *);
  int  (*set_tmp_dir) (DB_ENV *, const char *);
  int  (*set_verbose) (DB_ENV *, u_int32_t, int);
  int  (*set_lg_bsize) (DB_ENV *, u_int32_t);
  int  (*set_lg_dir) (DB_ENV *, const char *);
  int  (*set_lg_max) (DB_ENV *, u_int32_t);
  int  (*set_cachesize) (DB_ENV *, u_int32_t, u_int32_t, int);
  int  (*set_lk_detect) (DB_ENV *, u_int32_t);
  int  (*set_lk_max) (DB_ENV *, u_int32_t);
  int  (*log_archive) (DB_ENV *, char **[], u_int32_t);
  int  (*txn_stat) (DB_ENV *, DB_TXN_STAT **, u_int32_t);
  // Internal state
  void (*errcall)(const char *, char *);
  const char *errpfx;
  char *dir; /* A malloc'd copy of the directory. */
  u_int32_t open_flags;
  int       open_mode;
};
struct yobi_db_key_range {
  double less,equal,grater;
};
struct yobi_db_btree_stat {
  u_int32_t bt_ndata;
  u_int32_t bt_nkeys;
};
struct __toku_db_txn_stat {
  u_int32_t st_nactive;
  DB_TXN_ACTIVE *st_txnarray;
};
struct yobi_db_lsn {
  int hello;
};
struct __toku_db_txn_active {
  DB_LSN	lsn;
  u_int32_t	txnid;
};

#ifndef _YDB_WRAP_H
#define DB_VERSION_STRING "Yobiduck: Fractal DB (November 19, 2006)"
#else
#define DB_VERSION_STRING_ydb "Yobiduck: Fractal DB (November 19, 2006) (wrapped bdb)"
#endif

enum {
  DB_ARCH_ABS = 0x001,
  DB_ARCH_LOG = 0x004
};

enum {
  //DB_AFTER   =  1,
  DB_FIRST     = 10,
  DB_GET_BOTH  = 11,
  DB_LAST      = 18,
  DB_NEXT      = 19,
  DB_NEXT_DUP  = 20,
  DB_PREV      = 27,
  DB_SET       = 30,
  DB_SET_RANGE = 32,
  DB_RMW = 0x40000000
};

enum {
  DB_KEYEMPTY      = -30998,
  DB_KEYEXIST      = -30997,
  DB_LOCK_DEADLOCK = -30996,
  DB_NOTFOUND      = -30991
};


enum {
  DB_CREATE     = 0x0000001,
  DB_RDONLY     = 0x0000010,
  DB_RECOVER    = 0x0000020,
  DB_THREAD     = 0x0000040, 
  DB_TXN_NOSYNC = 0x0000100,
  
  DB_PRIVATE    = 0x0100000
};

enum {
  DB_LOCK_DEFAULT = 1,
  DB_LOCK_OLDEST  = 7,
  DB_LOCK_RANDOM  = 8 
};

enum {
  DB_DUP = 0x000002
};

enum {
  DB_NOOVERWRITE = 23
};

enum {
  DB_INIT_LOCK  = 0x001000,
  DB_INIT_LOG   = 0x002000,
  DB_INIT_MPOOL = 0x004000,
  DB_INIT_TXN   = 0x008000
};

int db_env_create (DB_ENV **, u_int32_t);

int txn_begin (DB_ENV *, DB_TXN *, DB_TXN **, u_int32_t);
int txn_abort (DB_TXN *);

int log_compare (const DB_LSN *, const DB_LSN *);

#endif

#if defined(__cplusplus)
}
#endif
#endif