com.sleepycat.db.internal

Class DbEnv

public class DbEnv extends Object

Nested Class Summary
static classDbEnv.RepProcessMessage
Field Summary
protected booleanswigCMemOwn
Environmentwrapper
Constructor Summary
protected DbEnv(long cPtr, boolean cMemoryOwn)
DbEnv(int flags)
Method Summary
DbTxncdsgroup_begin()
voidclose(int flags)
voiddbremove(DbTxn txnid, String file, String database, int flags)
voiddbrename(DbTxn txnid, String file, String database, String newname, int flags)
voiderr(int error, String message)
voiderrx(String message)
voidfileid_reset(String file, int flags)
protected static longgetCPtr(DbEnv obj)
LogRecordHandlerget_app_dispatch()
longget_cachesize()
intget_cachesize_ncache()
String[]get_data_dirs()
intget_encrypt_flags()
ErrorHandlerget_errcall()
OutputStreamget_error_stream()
Stringget_errpfx()
EventHandlerget_event_notify()
FeedbackHandlerget_feedback()
intget_flags()
Stringget_home()
intget_lg_bsize()
Stringget_lg_dir()
intget_lg_filemode()
intget_lg_max()
intget_lg_regionmax()
byte[][]get_lk_conflicts()
intget_lk_detect()
intget_lk_max_lockers()
intget_lk_max_locks()
intget_lk_max_objects()
OutputStreamget_message_stream()
intget_mp_max_openfd()
intget_mp_max_write()
intget_mp_max_write_sleep()
longget_mp_mmapsize()
MessageHandlerget_msgcall()
intget_open_flags()
PanicHandlerget_paniccall()
longget_shm_key()
longget_timeout(int flag)
Stringget_tmp_dir()
intget_tx_max()
longget_tx_timestamp()
booleanget_verbose(int which)
static intget_version_major()
static intget_version_minor()
static intget_version_patch()
static Stringget_version_string()
booleanis_bigendian()
intlock_detect(int flags, int atype)
DbLocklock_get(int locker, int flags, DatabaseEntry object, int lock_mode)
intlock_id()
voidlock_id_free(int id)
voidlock_put(DbLock lock)
LockStatslock_stat(int flags)
voidlock_vec(int locker, int flags, LockRequest[] list, int offset, int count)
String[]log_archive(int flags)
static intlog_compare(LogSequenceNumber lsn0, LogSequenceNumber lsn1)
DbLogclog_cursor(int flags)
Stringlog_file(LogSequenceNumber lsn)
voidlog_flush(LogSequenceNumber lsn_or_null)
voidlog_print(DbTxn txn, String msg)
voidlog_put(LogSequenceNumber lsn, DatabaseEntry data, int flags)
LogStatslog_stat(int flags)
voidlsn_reset(String file, int flags)
CacheFileStats[]memp_fstat(int flags)
CacheStatsmemp_stat(int flags)
intmemp_trickle(int percent)
intmutex_get_align()
intmutex_get_increment()
intmutex_get_max()
intmutex_get_tas_spins()
voidmutex_set_align(int align)
voidmutex_set_increment(int increment)
voidmutex_set_max(int mutex_max)
voidmutex_set_tas_spins(int tas_spins)
MutexStatsmutex_stat(int flags)
voidopen(String db_home, int flags, int mode)
voidremove(String db_home, int flags)
intrepmgr_add_remote_site(String host, int port, int flags)
voidrepmgr_get_ack_policy()
voidrepmgr_set_ack_policy(int policy)
voidrepmgr_set_local_site(String host, int port, int flags)
ReplicationHostAddress[]repmgr_site_list()
voidrepmgr_start(int nthreads, int flags)
intrep_elect(int nsites, int nvotes, int flags)
voidrep_flush()
booleanrep_get_config(int which)
longrep_get_limit()
intrep_get_nsites()
intrep_get_priority()
intrep_get_timeout(int which)
intrep_process_message(DatabaseEntry control, DatabaseEntry rec, DbEnv.RepProcessMessage envid, LogSequenceNumber ret_lsn)
voidrep_set_config(int which, boolean onoff)
voidrep_set_limit(long bytes)
voidrep_set_nsites(int number)
voidrep_set_priority(int priority)
voidrep_set_timeout(int which, long timeout)
voidrep_set_transport(int envid, ReplicationTransport send)
voidrep_start(DatabaseEntry cdata, int flags)
ReplicationStatsrep_stat(int flags)
voidrep_sync(int flags)
voidset_app_dispatch(LogRecordHandler tx_recover)
voidset_cachesize(long bytes, int ncache)
voidset_data_dir(String dir)
voidset_encrypt(String passwd, int flags)
voidset_errcall(ErrorHandler db_errcall_fcn)
voidset_error_stream(OutputStream stream)
voidset_errpfx(String errpfx)
voidset_event_notify(EventHandler event_notify)
voidset_feedback(FeedbackHandler env_feedback_fcn)
voidset_flags(int flags, boolean onoff)
voidset_intermediate_dir(int mode, int flags)
voidset_lg_bsize(int lg_bsize)
voidset_lg_dir(String dir)
voidset_lg_filemode(int mode)
voidset_lg_max(int lg_max)
voidset_lg_regionmax(int lg_regionmax)
voidset_lk_conflicts(byte[][] conflicts)
voidset_lk_detect(int detect)
voidset_lk_max_lockers(int max)
voidset_lk_max_locks(int max)
voidset_lk_max_objects(int max)
voidset_message_stream(OutputStream stream)
voidset_mp_max_openfd(int maxopenfd)
voidset_mp_max_write(int maxwrite, int maxwrite_sleep)
voidset_mp_mmapsize(long mp_mmapsize)
voidset_msgcall(MessageHandler db_msgcall_fcn)
voidset_paniccall(PanicHandler db_panic_fcn)
voidset_rep_request(int min, int max)
voidset_rpc_server(String host, long cl_timeout, long sv_timeout, int flags)
voidset_shm_key(long shm_key)
voidset_timeout(long timeout, int flags)
voidset_tmp_dir(String dir)
voidset_tx_max(int max)
voidset_tx_timestamp(Date timestamp)
voidset_verbose(int which, boolean onoff)
static Stringstrerror(int error)
DbTxntxn_begin(DbTxn parent, int flags)
voidtxn_checkpoint(int kbyte, int min, int flags)
PreparedTransaction[]txn_recover(int count, int flags)
TransactionStatstxn_stat(int flags)

Field Detail

swigCMemOwn

protected boolean swigCMemOwn

wrapper

public Environment wrapper

Constructor Detail

DbEnv

protected DbEnv(long cPtr, boolean cMemoryOwn)

DbEnv

public DbEnv(int flags)

Method Detail

cdsgroup_begin

public DbTxn cdsgroup_begin()

close

public void close(int flags)

dbremove

public void dbremove(DbTxn txnid, String file, String database, int flags)

dbrename

public void dbrename(DbTxn txnid, String file, String database, String newname, int flags)

err

public void err(int error, String message)

errx

public void errx(String message)

fileid_reset

public void fileid_reset(String file, int flags)

getCPtr

protected static long getCPtr(DbEnv obj)

get_app_dispatch

public LogRecordHandler get_app_dispatch()

get_cachesize

public long get_cachesize()

get_cachesize_ncache

public int get_cachesize_ncache()

get_data_dirs

public String[] get_data_dirs()

get_encrypt_flags

public int get_encrypt_flags()

get_errcall

public ErrorHandler get_errcall()

get_error_stream

public OutputStream get_error_stream()

get_errpfx

public String get_errpfx()

get_event_notify

public EventHandler get_event_notify()

get_feedback

public FeedbackHandler get_feedback()

get_flags

public int get_flags()

get_home

public String get_home()

get_lg_bsize

public int get_lg_bsize()

get_lg_dir

public String get_lg_dir()

get_lg_filemode

public int get_lg_filemode()

get_lg_max

public int get_lg_max()

get_lg_regionmax

public int get_lg_regionmax()

get_lk_conflicts

public byte[][] get_lk_conflicts()

get_lk_detect

public int get_lk_detect()

get_lk_max_lockers

public int get_lk_max_lockers()

get_lk_max_locks

public int get_lk_max_locks()

get_lk_max_objects

public int get_lk_max_objects()

get_message_stream

public OutputStream get_message_stream()

get_mp_max_openfd

public int get_mp_max_openfd()

get_mp_max_write

public int get_mp_max_write()

get_mp_max_write_sleep

public int get_mp_max_write_sleep()

get_mp_mmapsize

public long get_mp_mmapsize()

get_msgcall

public MessageHandler get_msgcall()

get_open_flags

public int get_open_flags()

get_paniccall

public PanicHandler get_paniccall()

get_shm_key

public long get_shm_key()

get_timeout

public long get_timeout(int flag)

get_tmp_dir

public String get_tmp_dir()

get_tx_max

public int get_tx_max()

get_tx_timestamp

public long get_tx_timestamp()

get_verbose

public boolean get_verbose(int which)

get_version_major

public static int get_version_major()

get_version_minor

public static int get_version_minor()

get_version_patch

public static int get_version_patch()

get_version_string

public static String get_version_string()

is_bigendian

public boolean is_bigendian()

lock_detect

public int lock_detect(int flags, int atype)

lock_get

public DbLock lock_get(int locker, int flags, DatabaseEntry object, int lock_mode)

lock_id

public int lock_id()

lock_id_free

public void lock_id_free(int id)

lock_put

public void lock_put(DbLock lock)

lock_stat

public LockStats lock_stat(int flags)

lock_vec

public void lock_vec(int locker, int flags, LockRequest[] list, int offset, int count)

log_archive

public String[] log_archive(int flags)

log_compare

public static int log_compare(LogSequenceNumber lsn0, LogSequenceNumber lsn1)

log_cursor

public DbLogc log_cursor(int flags)

log_file

public String log_file(LogSequenceNumber lsn)

log_flush

public void log_flush(LogSequenceNumber lsn_or_null)

log_print

public void log_print(DbTxn txn, String msg)

log_put

public void log_put(LogSequenceNumber lsn, DatabaseEntry data, int flags)

log_stat

public LogStats log_stat(int flags)

lsn_reset

public void lsn_reset(String file, int flags)

memp_fstat

public CacheFileStats[] memp_fstat(int flags)

memp_stat

public CacheStats memp_stat(int flags)

memp_trickle

public int memp_trickle(int percent)

mutex_get_align

public int mutex_get_align()

mutex_get_increment

public int mutex_get_increment()

mutex_get_max

public int mutex_get_max()

mutex_get_tas_spins

public int mutex_get_tas_spins()

mutex_set_align

public void mutex_set_align(int align)

mutex_set_increment

public void mutex_set_increment(int increment)

mutex_set_max

public void mutex_set_max(int mutex_max)

mutex_set_tas_spins

public void mutex_set_tas_spins(int tas_spins)

mutex_stat

public MutexStats mutex_stat(int flags)

open

public void open(String db_home, int flags, int mode)

remove

public void remove(String db_home, int flags)

repmgr_add_remote_site

public int repmgr_add_remote_site(String host, int port, int flags)

repmgr_get_ack_policy

public void repmgr_get_ack_policy()

repmgr_set_ack_policy

public void repmgr_set_ack_policy(int policy)

repmgr_set_local_site

public void repmgr_set_local_site(String host, int port, int flags)

repmgr_site_list

public ReplicationHostAddress[] repmgr_site_list()

repmgr_start

public void repmgr_start(int nthreads, int flags)

rep_elect

public int rep_elect(int nsites, int nvotes, int flags)

rep_flush

public void rep_flush()

rep_get_config

public boolean rep_get_config(int which)

rep_get_limit

public long rep_get_limit()

rep_get_nsites

public int rep_get_nsites()

rep_get_priority

public int rep_get_priority()

rep_get_timeout

public int rep_get_timeout(int which)

rep_process_message

public int rep_process_message(DatabaseEntry control, DatabaseEntry rec, DbEnv.RepProcessMessage envid, LogSequenceNumber ret_lsn)

rep_set_config

public void rep_set_config(int which, boolean onoff)

rep_set_limit

public void rep_set_limit(long bytes)

rep_set_nsites

public void rep_set_nsites(int number)

rep_set_priority

public void rep_set_priority(int priority)

rep_set_timeout

public void rep_set_timeout(int which, long timeout)

rep_set_transport

public void rep_set_transport(int envid, ReplicationTransport send)

rep_start

public void rep_start(DatabaseEntry cdata, int flags)

rep_stat

public ReplicationStats rep_stat(int flags)

rep_sync

public void rep_sync(int flags)

set_app_dispatch

public void set_app_dispatch(LogRecordHandler tx_recover)

set_cachesize

public void set_cachesize(long bytes, int ncache)

set_data_dir

public void set_data_dir(String dir)

set_encrypt

public void set_encrypt(String passwd, int flags)

set_errcall

public void set_errcall(ErrorHandler db_errcall_fcn)

set_error_stream

public void set_error_stream(OutputStream stream)

set_errpfx

public void set_errpfx(String errpfx)

set_event_notify

public void set_event_notify(EventHandler event_notify)

set_feedback

public void set_feedback(FeedbackHandler env_feedback_fcn)

set_flags

public void set_flags(int flags, boolean onoff)

set_intermediate_dir

public void set_intermediate_dir(int mode, int flags)

set_lg_bsize

public void set_lg_bsize(int lg_bsize)

set_lg_dir

public void set_lg_dir(String dir)

set_lg_filemode

public void set_lg_filemode(int mode)

set_lg_max

public void set_lg_max(int lg_max)

set_lg_regionmax

public void set_lg_regionmax(int lg_regionmax)

set_lk_conflicts

public void set_lk_conflicts(byte[][] conflicts)

set_lk_detect

public void set_lk_detect(int detect)

set_lk_max_lockers

public void set_lk_max_lockers(int max)

set_lk_max_locks

public void set_lk_max_locks(int max)

set_lk_max_objects

public void set_lk_max_objects(int max)

set_message_stream

public void set_message_stream(OutputStream stream)

set_mp_max_openfd

public void set_mp_max_openfd(int maxopenfd)

set_mp_max_write

public void set_mp_max_write(int maxwrite, int maxwrite_sleep)

set_mp_mmapsize

public void set_mp_mmapsize(long mp_mmapsize)

set_msgcall

public void set_msgcall(MessageHandler db_msgcall_fcn)

set_paniccall

public void set_paniccall(PanicHandler db_panic_fcn)

set_rep_request

public void set_rep_request(int min, int max)

set_rpc_server

public void set_rpc_server(String host, long cl_timeout, long sv_timeout, int flags)

set_shm_key

public void set_shm_key(long shm_key)

set_timeout

public void set_timeout(long timeout, int flags)

set_tmp_dir

public void set_tmp_dir(String dir)

set_tx_max

public void set_tx_max(int max)

set_tx_timestamp

public void set_tx_timestamp(Date timestamp)

set_verbose

public void set_verbose(int which, boolean onoff)

strerror

public static String strerror(int error)

txn_begin

public DbTxn txn_begin(DbTxn parent, int flags)

txn_checkpoint

public void txn_checkpoint(int kbyte, int min, int flags)

txn_recover

public PreparedTransaction[] txn_recover(int count, int flags)

txn_stat

public TransactionStats txn_stat(int flags)