Files
cpython-source-deps/libdb_java/db.i
2017-09-04 13:40:25 -05:00

1691 lines
38 KiB
OpenEdge ABL

%{
#include "db_config.h"
#include "db_int.h"
#include "dbinc/txn.h"
#ifdef HAVE_CRYPTO
#define CRYPTO_ONLY(x) (x);
#else
#define CRYPTO_ONLY(x)
#endif
%}
#if defined(SWIGJAVA)
%include "db_java.i"
#elif defined(SWIGCSHARP)
%include "db_csharp.i"
#endif
typedef unsigned char u_int8_t;
typedef long int32_t;
typedef long long db_seq_t;
typedef long long pid_t;
#ifndef SWIGJAVA
typedef long long db_threadid_t;
#endif
typedef unsigned long u_int32_t;
typedef u_int32_t db_recno_t; /* Record number type. */
typedef u_int32_t db_timeout_t; /* Type of a timeout. */
typedef int db_recops;
typedef int db_lockmode_t;
typedef int DBTYPE;
typedef int DB_CACHE_PRIORITY;
/* Fake typedefs for SWIG */
typedef int db_ret_t; /* An int that is mapped to a void */
typedef int int_bool; /* An int that is mapped to a boolean */
%{
typedef int db_ret_t;
typedef int int_bool;
struct __db_lk_conflicts {
u_int8_t *lk_conflicts;
int lk_modes;
};
struct __db_out_stream {
void *handle;
int (*callback) __P((void *, const void *));
};
struct __db_repmgr_sites {
DB_REPMGR_SITE *sites;
u_int32_t nsites;
};
#define Db __db
#define Dbc __dbc
#define Dbt __db_dbt
#define DbEnv __db_env
#define DbLock __db_lock_u
#define DbLogc __db_log_cursor
#define DbLsn __db_lsn
#define DbMpoolFile __db_mpoolfile
#define DbSequence __db_sequence
#define DbTxn __db_txn
/* Suppress a compilation warning for an unused symbol */
void *unused = SWIG_JavaThrowException;
%}
struct Db; typedef struct Db DB;
struct Dbc; typedef struct Dbc DBC;
struct Dbt; typedef struct Dbt DBT;
struct DbEnv; typedef struct DbEnv DB_ENV;
struct DbLock; typedef struct DbLock DB_LOCK;
struct DbLogc; typedef struct DbLogc DB_LOGC;
struct DbLsn; typedef struct DbLsn DB_LSN;
struct DbMpoolFile; typedef struct DbMpoolFile DB_MPOOLFILE;
struct DbSequence; typedef struct Db DB_SEQUENCE;
struct DbTxn; typedef struct DbTxn DB_TXN;
/* Methods that allocate new objects */
%newobject Db::join(DBC **curslist, u_int32_t flags);
%newobject Db::dup(u_int32_t flags);
%newobject DbEnv::lock_get(u_int32_t locker,
u_int32_t flags, const DBT *object, db_lockmode_t lock_mode);
%newobject DbEnv::log_cursor(u_int32_t flags);
struct Db
{
%extend {
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
Db(DB_ENV *dbenv, u_int32_t flags) {
DB *self = NULL;
errno = db_create(&self, dbenv, flags);
if (errno == 0 && dbenv == NULL)
self->env->dbt_usercopy = __dbj_dbt_memcopy;
return self;
}
JAVA_EXCEPT(DB_RETOK_STD, DB2JDBENV)
db_ret_t associate(DB_TXN *txnid, DB *secondary,
int (*callback)(DB *, const DBT *, const DBT *, DBT *),
u_int32_t flags) {
return self->associate(self, txnid, secondary, callback, flags);
}
db_ret_t associate_foreign(DB *primary,
int (*callback)(DB *, const DBT *, DBT *, const DBT *, int *), u_int32_t flags) {
return self->associate_foreign(self, primary, callback, flags);
}
db_ret_t compact(DB_TXN *txnid, DBT *start, DBT *stop,
DB_COMPACT *c_data, u_int32_t flags, DBT *end) {
return self->compact(self, txnid, start, stop, c_data, flags,
end);
}
/*
* Should probably be db_ret_t, but maintaining backwards compatibility
* for now.
*/
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, NULL)
int close(u_int32_t flags) {
errno = self->close(self, flags);
return errno;
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, DB2JDBENV)
DBC *cursor(DB_TXN *txnid, u_int32_t flags) {
DBC *cursorp = NULL;
errno = self->cursor(self, txnid, &cursorp, flags);
return cursorp;
}
JAVA_EXCEPT(DB_RETOK_DBDEL, DB2JDBENV)
int del(DB_TXN *txnid, DBT *key, u_int32_t flags) {
return self->del(self, txnid, key, flags);
}
JAVA_EXCEPT_NONE
void err(int error, const char *message) {
self->err(self, error, message);
}
void errx(const char *message) {
self->errx(self, message);
}
JAVA_EXCEPT(DB_RETOK_EXISTS, DB2JDBENV)
int exists(DB_TXN *txnid, DBT *key, u_int32_t flags) {
return self->exists(self, txnid, key, flags);
}
#ifndef SWIGJAVA
int fd() {
int ret = 0;
errno = self->fd(self, &ret);
return ret;
}
#endif
JAVA_EXCEPT(DB_RETOK_DBGET, DB2JDBENV)
int get(DB_TXN *txnid, DBT *key, DBT *data, u_int32_t flags) {
return self->get(self, txnid, key, data, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, DB2JDBENV)
int_bool get_byteswapped() {
int ret = 0;
errno = self->get_byteswapped(self, &ret);
return ret;
}
jlong get_cachesize() {
u_int32_t gbytes = 0, bytes = 0;
errno = self->get_cachesize(self, &gbytes, &bytes, NULL);
return (jlong)gbytes * GIGABYTE + bytes;
}
u_int32_t get_cachesize_ncache() {
int ret = 0;
errno = self->get_cachesize(self, NULL, NULL, &ret);
return ret;
}
const char *get_filename() {
const char *ret = NULL;
errno = self->get_dbname(self, &ret, NULL);
return ret;
}
const char *get_dbname() {
const char *ret = NULL;
errno = self->get_dbname(self, NULL, &ret);
return ret;
}
u_int32_t get_encrypt_flags() {
u_int32_t ret = 0;
CRYPTO_ONLY(errno = self->get_encrypt_flags(self, &ret))
return ret;
}
/*
* This method is implemented in Java to avoid wrapping the object on
* every call.
*/
#ifndef SWIGJAVA
DB_ENV *get_env() {
DB_ENV *env = NULL;
errno = self->get_env(self, &env);
return env;
}
const char *get_errpfx() {
const char *ret = NULL;
errno = 0;
self->get_errpfx(self, &ret);
return ret;
}
#endif
u_int32_t get_flags() {
u_int32_t ret = 0;
errno = self->get_flags(self, &ret);
return ret;
}
int get_lorder() {
int ret = 0;
errno = self->get_lorder(self, &ret);
return ret;
}
DB_MPOOLFILE *get_mpf() {
errno = 0;
return self->get_mpf(self);
}
u_int32_t get_open_flags() {
u_int32_t ret = 0;
errno = self->get_open_flags(self, &ret);
return ret;
}
u_int32_t get_pagesize() {
u_int32_t ret = 0;
errno = self->get_pagesize(self, &ret);
return ret;
}
u_int32_t get_bt_minkey() {
u_int32_t ret = 0;
errno = self->get_bt_minkey(self, &ret);
return ret;
}
u_int32_t get_h_ffactor() {
u_int32_t ret = 0;
errno = self->get_h_ffactor(self, &ret);
return ret;
}
u_int32_t get_h_nelem() {
u_int32_t ret = 0;
errno = self->get_h_nelem(self, &ret);
return ret;
}
int get_re_delim() {
int ret = 0;
errno = self->get_re_delim(self, &ret);
return ret;
}
DB_CACHE_PRIORITY get_priority() {
DB_CACHE_PRIORITY ret;
errno = self->get_priority(self, &ret);
return ret;
}
u_int32_t get_re_len() {
u_int32_t ret = 0;
errno = self->get_re_len(self, &ret);
return ret;
}
int get_re_pad() {
int ret = 0;
errno = self->get_re_pad(self, &ret);
return ret;
}
const char *get_re_source() {
const char *ret = NULL;
errno = self->get_re_source(self, &ret);
return ret;
}
u_int32_t get_q_extentsize() {
u_int32_t ret = 0;
errno = self->get_q_extentsize(self, &ret);
return ret;
}
JAVA_EXCEPT_NONE
int_bool get_multiple() {
return self->get_multiple(self);
}
int_bool get_transactional() {
return self->get_transactional(self);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, DB2JDBENV)
DBTYPE get_type() {
DBTYPE type = (DBTYPE)0;
errno = self->get_type(self, &type);
return type;
}
DBC *join(DBC **curslist, u_int32_t flags) {
DBC *dbcp = NULL;
errno = self->join(self, curslist, &dbcp, flags);
return dbcp;
}
JAVA_EXCEPT(DB_RETOK_STD, DB2JDBENV)
db_ret_t key_range(DB_TXN *txnid, DBT *key, DB_KEY_RANGE *key_range,
u_int32_t flags) {
return self->key_range(self, txnid, key, key_range, flags);
}
db_ret_t open(DB_TXN *txnid, const char *file, const char *database,
DBTYPE type, u_int32_t flags, int mode) {
return self->open(self, txnid, file, database,
type, flags, mode);
}
JAVA_EXCEPT(DB_RETOK_DBGET, DB2JDBENV)
int pget(DB_TXN *txnid, DBT *key, DBT *pkey, DBT *data,
u_int32_t flags) {
return self->pget(self, txnid, key, pkey, data, flags);
}
JAVA_EXCEPT(DB_RETOK_DBPUT, DB2JDBENV)
int put(DB_TXN *txnid, DBT *key, DBT *data, u_int32_t flags) {
return self->put(self, txnid, key, data, flags);
}
JAVA_EXCEPT(DB_RETOK_STD, NULL)
db_ret_t remove(const char *file, const char *database,
u_int32_t flags) {
return self->remove(self, file, database, flags);
}
db_ret_t rename(const char *file, const char *database,
const char *newname, u_int32_t flags) {
return self->rename(self, file, database, newname, flags);
}
JAVA_EXCEPT(DB_RETOK_STD, DB2JDBENV)
db_ret_t set_append_recno(
int (*db_append_recno_fcn)(DB *, DBT *, db_recno_t)) {
return self->set_append_recno(self, db_append_recno_fcn);
}
db_ret_t set_bt_compare(
int (*bt_compare_fcn)(DB *, const DBT *, const DBT *)) {
return self->set_bt_compare(self, bt_compare_fcn);
}
db_ret_t set_bt_minkey(u_int32_t bt_minkey) {
return self->set_bt_minkey(self, bt_minkey);
}
db_ret_t set_bt_prefix(
size_t (*bt_prefix_fcn)(DB *, const DBT *, const DBT *)) {
return self->set_bt_prefix(self, bt_prefix_fcn);
}
db_ret_t set_cachesize(jlong bytes, int ncache) {
return self->set_cachesize(self,
(u_int32_t)(bytes / GIGABYTE),
(u_int32_t)(bytes % GIGABYTE), ncache);
}
db_ret_t set_dup_compare(
int (*dup_compare_fcn)(DB *, const DBT *, const DBT *)) {
return self->set_dup_compare(self, dup_compare_fcn);
}
db_ret_t set_encrypt(const char *passwd, u_int32_t flags) {
return self->set_encrypt(self, passwd, flags);
}
JAVA_EXCEPT_NONE
#ifndef SWIGJAVA
void set_errcall(
void (*db_errcall_fcn)(const DB_ENV *, const char *, const char *)) {
self->set_errcall(self, db_errcall_fcn);
}
void set_errpfx(const char *errpfx) {
self->set_errpfx(self, errpfx);
}
#endif /* SWIGJAVA */
JAVA_EXCEPT(DB_RETOK_STD, DB2JDBENV)
db_ret_t set_feedback(void (*db_feedback_fcn)(DB *, int, int)) {
return self->set_feedback(self, db_feedback_fcn);
}
db_ret_t set_flags(u_int32_t flags) {
return self->set_flags(self, flags);
}
db_ret_t set_h_compare(
int (*h_compare_fcn)(DB *, const DBT *, const DBT *)) {
return self->set_h_compare(self, h_compare_fcn);
}
db_ret_t set_h_ffactor(u_int32_t h_ffactor) {
return self->set_h_ffactor(self, h_ffactor);
}
db_ret_t set_h_hash(
u_int32_t (*h_hash_fcn)(DB *, const void *, u_int32_t)) {
return self->set_h_hash(self, h_hash_fcn);
}
db_ret_t set_h_nelem(u_int32_t h_nelem) {
return self->set_h_nelem(self, h_nelem);
}
db_ret_t set_lorder(int lorder) {
return self->set_lorder(self, lorder);
}
#ifndef SWIGJAVA
void set_msgcall(void (*db_msgcall_fcn)(const DB_ENV *, const char *)) {
self->set_msgcall(self, db_msgcall_fcn);
}
#endif /* SWIGJAVA */
db_ret_t set_pagesize(u_int32_t pagesize) {
return self->set_pagesize(self, pagesize);
}
#ifndef SWIGJAVA
db_ret_t set_paniccall(void (* db_panic_fcn)(DB_ENV *, int)) {
return self->set_paniccall(self, db_panic_fcn);
}
#endif /* SWIGJAVA */
db_ret_t set_priority(DB_CACHE_PRIORITY priority) {
return self->set_priority(self, priority);
}
db_ret_t set_re_delim(int re_delim) {
return self->set_re_delim(self, re_delim);
}
db_ret_t set_re_len(u_int32_t re_len) {
return self->set_re_len(self, re_len);
}
db_ret_t set_re_pad(int re_pad) {
return self->set_re_pad(self, re_pad);
}
db_ret_t set_re_source(char *source) {
return self->set_re_source(self, source);
}
db_ret_t set_q_extentsize(u_int32_t extentsize) {
return self->set_q_extentsize(self, extentsize);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, DB2JDBENV)
void *stat(DB_TXN *txnid, u_int32_t flags) {
void *statp = NULL;
errno = self->stat(self, txnid, &statp, flags);
return statp;
}
JAVA_EXCEPT(DB_RETOK_STD, DB2JDBENV)
db_ret_t sync(u_int32_t flags) {
return self->sync(self, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, DB2JDBENV)
int truncate(DB_TXN *txnid, u_int32_t flags) {
u_int32_t count = 0;
errno = self->truncate(self, txnid, &count, flags);
return count;
}
JAVA_EXCEPT(DB_RETOK_STD, DB2JDBENV)
db_ret_t upgrade(const char *file, u_int32_t flags) {
return self->upgrade(self, file, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, NULL)
int_bool verify(const char *file, const char *database,
struct __db_out_stream outfile, u_int32_t flags) {
/*
* We can't easily #include "dbinc/db_ext.h" because of name
* clashes, so we declare this explicitly.
*/
extern int __db_verify_internal __P((DB *, const char *, const
char *, void *, int (*)(void *, const void *), u_int32_t));
errno = __db_verify_internal(self, file, database,
outfile.handle, outfile.callback, flags);
if (errno == DB_VERIFY_BAD) {
errno = 0;
return 0;
} else
return 1;
}
}
};
struct Dbc
{
%extend {
JAVA_EXCEPT(DB_RETOK_STD, NULL)
db_ret_t close() {
return self->close(self);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, DBC2JDBENV)
db_recno_t count(u_int32_t flags) {
db_recno_t count = 0;
errno = self->count(self, &count, flags);
return count;
}
JAVA_EXCEPT(DB_RETOK_DBCDEL, DBC2JDBENV)
int del(u_int32_t flags) {
return self->del(self, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, DBC2JDBENV)
DBC *dup(u_int32_t flags) {
DBC *newcurs = NULL;
errno = self->dup(self, &newcurs, flags);
return newcurs;
}
JAVA_EXCEPT(DB_RETOK_DBCGET, DBC2JDBENV)
int get(DBT* key, DBT *data, u_int32_t flags) {
return self->get(self, key, data, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, DBC2JDBENV)
DB_CACHE_PRIORITY get_priority() {
DB_CACHE_PRIORITY ret;
errno = self->get_priority(self, &ret);
return ret;
}
JAVA_EXCEPT(DB_RETOK_DBCGET, DBC2JDBENV)
int pget(DBT* key, DBT* pkey, DBT *data, u_int32_t flags) {
return self->pget(self, key, pkey, data, flags);
}
JAVA_EXCEPT(DB_RETOK_DBCPUT, DBC2JDBENV)
int put(DBT* key, DBT *data, u_int32_t flags) {
return self->put(self, key, data, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, DBC2JDBENV)
db_ret_t set_priority(DB_CACHE_PRIORITY priority) {
return self->set_priority(self, priority);
}
}
};
struct DbEnv
{
%extend {
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, NULL)
DbEnv(u_int32_t flags) {
DB_ENV *self = NULL;
errno = db_env_create(&self, flags);
if (errno == 0)
self->env->dbt_usercopy = __dbj_dbt_memcopy;
return self;
}
JAVA_EXCEPT(DB_RETOK_STD, NULL)
db_ret_t close(u_int32_t flags) {
return self->close(self, flags);
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t dbremove(DB_TXN *txnid, const char *file, const char *database,
u_int32_t flags) {
return self->dbremove(self, txnid, file, database, flags);
}
db_ret_t dbrename(DB_TXN *txnid, const char *file, const char *database,
const char *newname, u_int32_t flags) {
return self->dbrename(self,
txnid, file, database, newname, flags);
}
JAVA_EXCEPT_NONE
void err(int error, const char *message) {
self->err(self, error, message);
}
void errx(const char *message) {
self->errx(self, message);
}
#ifndef SWIGJAVA
u_int32_t get_thread_count() {
u_int32_t ret;
errno = self->get_thread_count(self, &ret);
return ret;
}
pid_t getpid() {
pid_t ret;
db_threadid_t junk;
__os_id(self, &ret, &junk);
return ret;
}
db_threadid_t get_threadid() {
pid_t junk;
db_threadid_t ret;
__os_id(self, &junk, &ret);
return ret;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t failchk(u_int32_t flags) {
return self->failchk(self, flags);
}
db_ret_t set_isalive(
int (*isalive_fcn)(DB_ENV *, pid_t, db_threadid_t)) {
return self->set_isalive(self, isalive_fcn);
}
db_ret_t set_thread_count(u_int32_t count) {
return self->set_thread_count(self, count);
}
db_ret_t set_thread_id(void (*thread_id_fcn)(DB_ENV *, pid_t *,
db_threadid_t *)) {
return self->set_thread_id(self, thread_id_fcn);
}
db_ret_t set_thread_id_string(char *(*thread_id_string_fcn)(DB_ENV *,
pid_t, db_threadid_t, char *)) {
return self->set_thread_id_string(self, thread_id_string_fcn);
}
#endif
DB_TXN *cdsgroup_begin() {
DB_TXN *tid = NULL;
errno = self->cdsgroup_begin(self, &tid);
return tid;
}
db_ret_t fileid_reset(const char *file, u_int32_t flags) {
return self->fileid_reset(self, file, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
const char **get_data_dirs() {
const char **ret;
errno = self->get_data_dirs(self, &ret);
return ret;
}
u_int32_t get_encrypt_flags() {
u_int32_t ret = 0;
CRYPTO_ONLY(errno = self->get_encrypt_flags(self, &ret))
return ret;
}
#ifndef SWIGJAVA
const char *get_errpfx() {
const char *ret;
errno = 0;
self->get_errpfx(self, &ret);
return ret;
}
#endif /* SWIGJAVA */
u_int32_t get_flags() {
u_int32_t ret;
errno = self->get_flags(self, &ret);
return ret;
}
const char *get_home() {
const char *ret;
errno = self->get_home(self, &ret);
return ret;
}
const char *get_intermediate_dir_mode() {
const char *ret;
errno = self->get_intermediate_dir_mode(self, &ret);
return ret;
}
u_int32_t get_open_flags() {
u_int32_t ret;
errno = self->get_open_flags(self, &ret);
return ret;
}
long get_shm_key() {
long ret;
errno = self->get_shm_key(self, &ret);
return ret;
}
const char *get_tmp_dir() {
const char *ret;
errno = self->get_tmp_dir(self, &ret);
return ret;
}
int_bool get_verbose(u_int32_t which) {
int ret;
errno = self->get_verbose(self, which, &ret);
return ret;
}
JAVA_EXCEPT_NONE
int_bool is_bigendian() {
return self->is_bigendian();
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t lsn_reset(const char *file, u_int32_t flags) {
return self->lsn_reset(self, file, flags);
}
db_ret_t open(const char *db_home, u_int32_t flags, int mode) {
return self->open(self, db_home, flags, mode);
}
JAVA_EXCEPT(DB_RETOK_STD, NULL)
db_ret_t remove(const char *db_home, u_int32_t flags) {
return self->remove(self, db_home, flags);
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t set_cachesize(jlong bytes, int ncache) {
return self->set_cachesize(self,
(u_int32_t)(bytes / GIGABYTE),
(u_int32_t)(bytes % GIGABYTE), ncache);
}
db_ret_t set_cache_max(jlong bytes) {
return self->set_cache_max(self,
(u_int32_t)(bytes / GIGABYTE),
(u_int32_t)(bytes % GIGABYTE));
}
db_ret_t set_data_dir(const char *dir) {
return self->set_data_dir(self, dir);
}
db_ret_t set_intermediate_dir_mode(const char *mode) {
return self->set_intermediate_dir_mode(self, mode);
}
db_ret_t set_encrypt(const char *passwd, u_int32_t flags) {
return self->set_encrypt(self, passwd, flags);
}
JAVA_EXCEPT_NONE
void set_errcall(void (*db_errcall_fcn)(const DB_ENV *, const char *,
const char *)) {
self->set_errcall(self, db_errcall_fcn);
}
#ifndef SWIGJAVA
void set_errpfx(const char *errpfx) {
self->set_errpfx(self, errpfx);
}
#endif
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t set_flags(u_int32_t flags, int_bool onoff) {
return self->set_flags(self, flags, onoff);
}
db_ret_t set_feedback(void (*env_feedback_fcn)(DB_ENV *, int, int)) {
return self->set_feedback(self, env_feedback_fcn);
}
db_ret_t set_mp_max_openfd(int maxopenfd) {
return self->set_mp_max_openfd(self, maxopenfd);
}
db_ret_t set_mp_max_write(int maxwrite, db_timeout_t maxwrite_sleep) {
return self->set_mp_max_write(self, maxwrite, maxwrite_sleep);
}
db_ret_t set_mp_mmapsize(size_t mp_mmapsize) {
return self->set_mp_mmapsize(self, mp_mmapsize);
}
JAVA_EXCEPT_NONE
void set_msgcall(void (*db_msgcall_fcn)(const DB_ENV *, const char *)) {
self->set_msgcall(self, db_msgcall_fcn);
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t set_paniccall(void (*db_panic_fcn)(DB_ENV *, int)) {
return self->set_paniccall(self, db_panic_fcn);
}
db_ret_t set_rpc_server(char *host,
long cl_timeout, long sv_timeout, u_int32_t flags) {
return self->set_rpc_server(self, NULL, host,
cl_timeout, sv_timeout, flags);
}
db_ret_t set_shm_key(long shm_key) {
return self->set_shm_key(self, shm_key);
}
db_ret_t set_timeout(db_timeout_t timeout, u_int32_t flags) {
return self->set_timeout(self, timeout, flags);
}
db_ret_t set_tmp_dir(const char *dir) {
return self->set_tmp_dir(self, dir);
}
db_ret_t set_tx_max(u_int32_t max) {
return self->set_tx_max(self, max);
}
db_ret_t set_app_dispatch(
int (*tx_recover)(DB_ENV *, DBT *, DB_LSN *, db_recops)) {
return self->set_app_dispatch(self, tx_recover);
}
db_ret_t set_event_notify(
void (*event_notify)(DB_ENV *, u_int32_t, void *)) {
return self->set_event_notify(self, event_notify);
}
db_ret_t set_tx_timestamp(time_t *timestamp) {
return self->set_tx_timestamp(self, timestamp);
}
db_ret_t set_verbose(u_int32_t which, int_bool onoff) {
return self->set_verbose(self, which, onoff);
}
/* Lock functions */
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
struct __db_lk_conflicts get_lk_conflicts() {
struct __db_lk_conflicts ret;
errno = self->get_lk_conflicts(self,
(const u_int8_t **)&ret.lk_conflicts, &ret.lk_modes);
return ret;
}
u_int32_t get_lk_detect() {
u_int32_t ret;
errno = self->get_lk_detect(self, &ret);
return ret;
}
u_int32_t get_lk_max_locks() {
u_int32_t ret;
errno = self->get_lk_max_locks(self, &ret);
return ret;
}
u_int32_t get_lk_max_lockers() {
u_int32_t ret;
errno = self->get_lk_max_lockers(self, &ret);
return ret;
}
u_int32_t get_lk_max_objects() {
u_int32_t ret;
errno = self->get_lk_max_objects(self, &ret);
return ret;
}
int lock_detect(u_int32_t flags, u_int32_t atype) {
int aborted;
errno = self->lock_detect(self, flags, atype, &aborted);
return aborted;
}
DB_LOCK *lock_get(u_int32_t locker,
u_int32_t flags, const DBT *object, db_lockmode_t lock_mode) {
DB_LOCK *lock = NULL;
if ((errno = __os_malloc(self->env, sizeof (DB_LOCK), &lock)) == 0)
errno = self->lock_get(self, locker, flags, object,
lock_mode, lock);
return lock;
}
u_int32_t lock_id() {
u_int32_t id;
errno = self->lock_id(self, &id);
return id;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t lock_id_free(u_int32_t id) {
return self->lock_id_free(self, id);
}
db_ret_t lock_put(DB_LOCK *lock) {
return self->lock_put(self, lock);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
DB_LOCK_STAT *lock_stat(u_int32_t flags) {
DB_LOCK_STAT *statp = NULL;
errno = self->lock_stat(self, &statp, flags);
return statp;
}
#ifndef SWIGJAVA
/* For Java, this is defined in native code */
db_ret_t lock_vec(u_int32_t locker, u_int32_t flags, DB_LOCKREQ *list,
int offset, int nlist)
{
DB_LOCKREQ *elistp;
return self->lock_vec(self, locker, flags, list + offset,
nlist, &elistp);
}
#endif
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t set_lk_conflicts(struct __db_lk_conflicts conflicts) {
return self->set_lk_conflicts(self,
conflicts.lk_conflicts, conflicts.lk_modes);
}
db_ret_t set_lk_detect(u_int32_t detect) {
return self->set_lk_detect(self, detect);
}
db_ret_t set_lk_max_lockers(u_int32_t max) {
return self->set_lk_max_lockers(self, max);
}
db_ret_t set_lk_max_locks(u_int32_t max) {
return self->set_lk_max_locks(self, max);
}
db_ret_t set_lk_max_objects(u_int32_t max) {
return self->set_lk_max_objects(self, max);
}
/* Log functions */
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
u_int32_t get_lg_bsize() {
u_int32_t ret;
errno = self->get_lg_bsize(self, &ret);
return ret;
}
const char *get_lg_dir() {
const char *ret;
errno = self->get_lg_dir(self, &ret);
return ret;
}
int get_lg_filemode() {
int ret;
errno = self->get_lg_filemode(self, &ret);
return ret;
}
u_int32_t get_lg_max() {
u_int32_t ret;
errno = self->get_lg_max(self, &ret);
return ret;
}
u_int32_t get_lg_regionmax() {
u_int32_t ret;
errno = self->get_lg_regionmax(self, &ret);
return ret;
}
char **log_archive(u_int32_t flags) {
char **list = NULL;
errno = self->log_archive(self, &list, flags);
return list;
}
JAVA_EXCEPT_NONE
static int log_compare(const DB_LSN *lsn0, const DB_LSN *lsn1) {
return log_compare(lsn0, lsn1);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
DB_LOGC *log_cursor(u_int32_t flags) {
DB_LOGC *cursor = NULL;
errno = self->log_cursor(self, &cursor, flags);
return cursor;
}
char *log_file(DB_LSN *lsn) {
char namebuf[DB_MAXPATHLEN];
errno = self->log_file(self, lsn, namebuf, sizeof namebuf);
return (errno == 0) ? strdup(namebuf) : NULL;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t log_flush(const DB_LSN *lsn_or_null) {
return self->log_flush(self, lsn_or_null);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
int_bool log_get_config(u_int32_t which) {
int ret;
errno = self->log_get_config(self, which, &ret);
return ret;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t log_put(DB_LSN *lsn, const DBT *data, u_int32_t flags) {
return self->log_put(self, lsn, data, flags);
}
db_ret_t log_print(DB_TXN *txn, const char *msg) {
return self->log_printf(self, txn, "%s", msg);
}
db_ret_t log_set_config(u_int32_t which, int_bool onoff) {
return self->log_set_config(self, which, onoff);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
DB_LOG_STAT *log_stat(u_int32_t flags) {
DB_LOG_STAT *sp = NULL;
errno = self->log_stat(self, &sp, flags);
return sp;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t set_lg_bsize(u_int32_t lg_bsize) {
return self->set_lg_bsize(self, lg_bsize);
}
db_ret_t set_lg_dir(const char *dir) {
return self->set_lg_dir(self, dir);
}
db_ret_t set_lg_filemode(int mode) {
return self->set_lg_filemode(self, mode);
}
db_ret_t set_lg_max(u_int32_t lg_max) {
return self->set_lg_max(self, lg_max);
}
db_ret_t set_lg_regionmax(u_int32_t lg_regionmax) {
return self->set_lg_regionmax(self, lg_regionmax);
}
/* Memory pool functions */
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
jlong get_cachesize() {
u_int32_t gbytes, bytes;
errno = self->get_cachesize(self, &gbytes, &bytes, NULL);
return (jlong)gbytes * GIGABYTE + bytes;
}
int get_cachesize_ncache() {
int ret;
errno = self->get_cachesize(self, NULL, NULL, &ret);
return ret;
}
jlong get_cache_max() {
u_int32_t gbytes, bytes;
errno = self->get_cache_max(self, &gbytes, &bytes);
return (jlong)gbytes * GIGABYTE + bytes;
}
int get_mp_max_openfd() {
int ret;
errno = self->get_mp_max_openfd(self, &ret);
return ret;
}
int get_mp_max_write() {
int maxwrite;
db_timeout_t sleep;
errno = self->get_mp_max_write(self, &maxwrite, &sleep);
return maxwrite;
}
db_timeout_t get_mp_max_write_sleep() {
int maxwrite;
db_timeout_t sleep;
errno = self->get_mp_max_write(self, &maxwrite, &sleep);
return sleep;
}
size_t get_mp_mmapsize() {
size_t ret;
errno = self->get_mp_mmapsize(self, &ret);
return ret;
}
DB_MPOOL_STAT *memp_stat(u_int32_t flags) {
DB_MPOOL_STAT *mp_stat = NULL;
errno = self->memp_stat(self, &mp_stat, NULL, flags);
return mp_stat;
}
DB_MPOOL_FSTAT **memp_fstat(u_int32_t flags) {
DB_MPOOL_FSTAT **mp_fstat = NULL;
errno = self->memp_stat(self, NULL, &mp_fstat, flags);
return mp_fstat;
}
int memp_trickle(int percent) {
int ret;
errno = self->memp_trickle(self, percent, &ret);
return ret;
}
/* Mutex functions */
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
u_int32_t mutex_get_align() {
u_int32_t ret;
errno = self->mutex_get_align(self, &ret);
return ret;
}
u_int32_t mutex_get_increment() {
u_int32_t ret;
errno = self->mutex_get_increment(self, &ret);
return ret;
}
u_int32_t mutex_get_max() {
u_int32_t ret;
errno = self->mutex_get_max(self, &ret);
return ret;
}
u_int32_t mutex_get_tas_spins() {
u_int32_t ret;
errno = self->mutex_get_tas_spins(self, &ret);
return ret;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t mutex_set_align(u_int32_t align) {
return self->mutex_set_align(self, align);
}
db_ret_t mutex_set_increment(u_int32_t increment) {
return self->mutex_set_increment(self, increment);
}
db_ret_t mutex_set_max(u_int32_t mutex_max) {
return self->mutex_set_increment(self, mutex_max);
}
db_ret_t mutex_set_tas_spins(u_int32_t tas_spins) {
return self->mutex_set_tas_spins(self, tas_spins);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
DB_MUTEX_STAT *mutex_stat(u_int32_t flags) {
DB_MUTEX_STAT *statp = NULL;
errno = self->mutex_stat(self, &statp, flags);
return statp;
}
/* Transaction functions */
u_int32_t get_tx_max() {
u_int32_t ret;
errno = self->get_tx_max(self, &ret);
return ret;
}
time_t get_tx_timestamp() {
time_t ret;
errno = self->get_tx_timestamp(self, &ret);
return ret;
}
db_timeout_t get_timeout(u_int32_t flag) {
db_timeout_t ret;
errno = self->get_timeout(self, &ret, flag);
return ret;
}
DB_TXN *txn_begin(DB_TXN *parent, u_int32_t flags) {
DB_TXN *tid = NULL;
errno = self->txn_begin(self, parent, &tid, flags);
return tid;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t txn_checkpoint(u_int32_t kbyte, u_int32_t min,
u_int32_t flags) {
return self->txn_checkpoint(self, kbyte, min, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
DB_PREPLIST *txn_recover(int count, u_int32_t flags) {
DB_PREPLIST *preplist;
long retcount;
/* Add a NULL element to terminate the array. */
if ((errno = __os_malloc(self->env,
(count + 1) * sizeof(DB_PREPLIST), &preplist)) != 0)
return NULL;
if ((errno = self->txn_recover(self, preplist, count,
&retcount, flags)) != 0) {
__os_free(self->env, preplist);
return NULL;
}
preplist[retcount].txn = NULL;
return preplist;
}
DB_TXN_STAT *txn_stat(u_int32_t flags) {
DB_TXN_STAT *statp = NULL;
errno = self->txn_stat(self, &statp, flags);
return statp;
}
/* Replication functions */
jlong rep_get_limit() {
u_int32_t gbytes, bytes;
errno = self->rep_get_limit(self, &gbytes, &bytes);
return (jlong)gbytes * GIGABYTE + bytes;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t rep_elect(u_int32_t nsites, int nvotes, u_int32_t flags) {
return self->rep_elect(self, nsites, nvotes, flags);
}
JAVA_EXCEPT(DB_RETOK_REPPMSG, JDBENV)
int rep_process_message(DBT *control, DBT *rec, int envid,
DB_LSN *ret_lsn) {
return self->rep_process_message(self, control, rec, envid,
ret_lsn);
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t rep_flush() {
return self->rep_flush(self);
}
db_ret_t rep_set_config(u_int32_t which, int_bool onoff) {
return self->rep_set_config(self, which, onoff);
}
db_ret_t rep_set_clockskew(u_int32_t fast_clock, u_int32_t slow_clock) {
return self->rep_set_clockskew(self, fast_clock, slow_clock);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
u_int32_t rep_get_clockskew_fast() {
u_int32_t fast_clock, slow_clock;
errno = self->rep_get_clockskew(self, &fast_clock, &slow_clock);
return fast_clock;
}
u_int32_t rep_get_clockskew_slow() {
u_int32_t fast_clock, slow_clock;
errno = self->rep_get_clockskew(self, &fast_clock, &slow_clock);
return slow_clock;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t rep_start(DBT *cdata, u_int32_t flags) {
return self->rep_start(self, cdata, flags);
}
db_ret_t rep_sync(u_int32_t flags) {
return self->rep_sync(self, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
int_bool rep_get_config(u_int32_t which) {
int ret;
errno = self->rep_get_config(self, which, &ret);
return ret;
}
DB_REP_STAT *rep_stat(u_int32_t flags) {
DB_REP_STAT *statp = NULL;
errno = self->rep_stat(self, &statp, flags);
return statp;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t rep_set_limit(jlong bytes) {
return self->rep_set_limit(self,
(u_int32_t)(bytes / GIGABYTE),
(u_int32_t)(bytes % GIGABYTE));
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
u_int32_t rep_get_request_min(){
u_int32_t min, max;
errno = self->rep_get_request(self, &min, &max);
return min;
}
u_int32_t rep_get_request_max(){
u_int32_t min, max;
errno = self->rep_get_request(self, &min, &max);
return max;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t rep_set_request(u_int32_t min, u_int32_t max) {
return self->rep_set_request(self, min, max);
}
db_ret_t rep_set_transport(int envid,
int (*send)(DB_ENV *, const DBT *, const DBT *,
const DB_LSN *, int, u_int32_t)) {
return self->rep_set_transport(self, envid, send);
}
/* Advanced replication functions. */
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
u_int32_t rep_get_nsites() {
u_int32_t ret;
errno = self->rep_get_nsites(self, &ret);
return ret;
}
u_int32_t rep_get_priority() {
u_int32_t ret;
errno = self->rep_get_priority(self, &ret);
return ret;
}
u_int32_t rep_get_timeout(int which) {
u_int32_t ret;
errno = self->rep_get_timeout(self, which, &ret);
return ret;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t rep_set_nsites(u_int32_t number) {
return self->rep_set_nsites(self, number);
}
db_ret_t rep_set_priority(u_int32_t priority) {
return self->rep_set_priority(self, priority);
}
db_ret_t rep_set_timeout(int which, db_timeout_t timeout) {
return self->rep_set_timeout(self, which, timeout);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
int repmgr_add_remote_site(const char * host, u_int32_t port,
u_int32_t flags) {
int eid;
errno = self->repmgr_add_remote_site(self, host, port, &eid, flags);
return eid;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t repmgr_get_ack_policy() {
int ret;
errno = self->repmgr_get_ack_policy(self, &ret);
return ret;
}
db_ret_t repmgr_set_ack_policy(int policy) {
return self->repmgr_set_ack_policy(self, policy);
}
db_ret_t repmgr_set_local_site(const char * host, u_int32_t port, u_int32_t flags) {
return self->repmgr_set_local_site(self, host, port, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
struct __db_repmgr_sites repmgr_site_list() {
struct __db_repmgr_sites sites;
errno = self->repmgr_site_list(self,
&sites.nsites, &sites.sites);
return sites;
}
JAVA_EXCEPT(DB_RETOK_STD, JDBENV)
db_ret_t repmgr_start(int nthreads, u_int32_t flags) {
return self->repmgr_start(self, nthreads, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, JDBENV)
DB_REPMGR_STAT *repmgr_stat(u_int32_t flags) {
DB_REPMGR_STAT *statp = NULL;
errno = self->repmgr_stat(self, &statp, flags);
return statp;
}
/* Convert DB errors to strings */
JAVA_EXCEPT_NONE
static const char *strerror(int error) {
return db_strerror(error);
}
/* Versioning information */
static int get_version_major() {
return DB_VERSION_MAJOR;
}
static int get_version_minor() {
return DB_VERSION_MINOR;
}
static int get_version_patch() {
return DB_VERSION_PATCH;
}
static const char *get_version_string() {
return DB_VERSION_STRING;
}
}
};
struct DbLock
{
%extend {
JAVA_EXCEPT_NONE
~DbLock() {
__os_free(NULL, self);
}
}
};
struct DbLogc
{
%extend {
JAVA_EXCEPT(DB_RETOK_STD, NULL)
db_ret_t close(u_int32_t flags) {
return self->close(self, flags);
}
JAVA_EXCEPT(DB_RETOK_LGGET, NULL)
int get(DB_LSN *lsn, DBT *data, u_int32_t flags) {
return self->get(self, lsn, data, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, NULL)
u_int32_t version(u_int32_t flags) {
u_int32_t result;
errno = self->version(self, &result, flags);
return result;
}
}
};
#ifndef SWIGJAVA
struct DbLsn
{
%extend {
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, NULL)
DbLsn(u_int32_t file, u_int32_t offset) {
DB_LSN *self = NULL;
if ((errno = __os_malloc(NULL, sizeof (DB_LSN), &self)) == 0) {
self->file = file;
self->offset = offset;
}
return self;
}
JAVA_EXCEPT_NONE
~DbLsn() {
__os_free(NULL, self);
}
u_int32_t get_file() {
return self->file;
}
u_int32_t get_offset() {
return self->offset;
}
}
};
#endif
struct DbMpoolFile
{
%extend {
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, NULL)
DB_CACHE_PRIORITY get_priority() {
DB_CACHE_PRIORITY ret;
errno = self->get_priority(self, &ret);
return ret;
}
JAVA_EXCEPT(DB_RETOK_STD, NULL)
db_ret_t set_priority(DB_CACHE_PRIORITY priority) {
return self->set_priority(self, priority);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, NULL)
u_int32_t get_flags() {
u_int32_t ret;
errno = self->get_flags(self, &ret);
return ret;
}
JAVA_EXCEPT(DB_RETOK_STD, NULL)
db_ret_t set_flags(u_int32_t flags, int_bool onoff) {
return self->set_flags(self, flags, onoff);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, NULL)
jlong get_maxsize() {
u_int32_t gbytes, bytes;
errno = self->get_maxsize(self, &gbytes, &bytes);
return (jlong)gbytes * GIGABYTE + bytes;
}
/* New method - no backwards compatibility version */
JAVA_EXCEPT(DB_RETOK_STD, NULL)
db_ret_t set_maxsize(jlong bytes) {
return self->set_maxsize(self,
(u_int32_t)(bytes / GIGABYTE),
(u_int32_t)(bytes % GIGABYTE));
}
}
};
struct DbSequence
{
%extend {
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, NULL)
DbSequence(DB *db, u_int32_t flags) {
DB_SEQUENCE *self = NULL;
errno = db_sequence_create(&self, db, flags);
return self;
}
JAVA_EXCEPT(DB_RETOK_STD, NULL)
db_ret_t close(u_int32_t flags) {
return self->close(self, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, NULL)
db_seq_t get(DB_TXN *txnid, int32_t delta, u_int32_t flags) {
db_seq_t ret = 0;
errno = self->get(self, txnid, delta, &ret, flags);
return ret;
}
int32_t get_cachesize() {
int32_t ret = 0;
errno = self->get_cachesize(self, &ret);
return ret;
}
DB *get_db() {
DB *ret = NULL;
errno = self->get_db(self, &ret);
return ret;
}
u_int32_t get_flags() {
u_int32_t ret = 0;
errno = self->get_flags(self, &ret);
return ret;
}
JAVA_EXCEPT(DB_RETOK_STD, NULL)
db_ret_t get_key(DBT *key) {
return self->get_key(self, key);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, NULL)
db_seq_t get_range_min() {
db_seq_t ret = 0;
errno = self->get_range(self, &ret, NULL);
return ret;
}
db_seq_t get_range_max() {
db_seq_t ret = 0;
errno = self->get_range(self, NULL, &ret);
return ret;
}
JAVA_EXCEPT(DB_RETOK_STD, NULL)
db_ret_t initial_value(db_seq_t val) {
return self->initial_value(self, val);
}
db_ret_t open(DB_TXN *txnid, DBT *key, u_int32_t flags) {
return self->open(self, txnid, key, flags);
}
db_ret_t remove(DB_TXN *txnid, u_int32_t flags) {
return self->remove(self, txnid, flags);
}
db_ret_t set_cachesize(int32_t size) {
return self->set_cachesize(self, size);
}
db_ret_t set_flags(u_int32_t flags) {
return self->set_flags(self, flags);
}
db_ret_t set_range(db_seq_t min, db_seq_t max) {
return self->set_range(self, min, max);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, NULL)
DB_SEQUENCE_STAT *stat(u_int32_t flags) {
DB_SEQUENCE_STAT *ret = NULL;
errno = self->stat(self, &ret, flags);
return ret;
}
}
};
struct DbTxn
{
%extend {
JAVA_EXCEPT(DB_RETOK_STD, NULL)
db_ret_t abort() {
return self->abort(self);
}
db_ret_t commit(u_int32_t flags) {
return self->commit(self, flags);
}
db_ret_t discard(u_int32_t flags) {
return self->discard(self, flags);
}
JAVA_EXCEPT_ERRNO(DB_RETOK_STD, TXN2JDBENV)
const char *get_name() {
const char *name = NULL;
errno = self->get_name(self, &name);
return name;
}
JAVA_EXCEPT_NONE
u_int32_t id() {
return self->id(self);
}
JAVA_EXCEPT(DB_RETOK_STD, TXN2JDBENV)
db_ret_t prepare(u_int8_t *gid) {
return self->prepare(self, gid);
}
db_ret_t set_timeout(db_timeout_t timeout, u_int32_t flags) {
return self->set_timeout(self, timeout, flags);
}
db_ret_t set_name(const char *name) {
return self->set_name(self, name);
}
}
};