Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from http://www.ncbi.nlm.nih.gov/IEB/ToolBox/CPP_DOC/doxyhtml/bdb__env_8cpp_source.html below:

NCBI C++ ToolKit: src/db/bdb/bdb_env.cpp Source File

m_Transactional(

),

m_LogInMemory(

),

m_CheckPointEnable(

),

m_DeadLockMode(eDeadLock_Disable),

ret = db_env_create(&

, 0);

m_Transactional(

),

m_LogInMemory(

),

m_DirectLOG(

),

m_CheckPointEnable(

),

m_DeadLockMode(eDeadLock_Disable),

ret =

->set_flags(

, DB_DSYNC_DB, 1);

(ret,

);

cache_g = (unsigned) (cache_size / (

)1073741824);

cache_size = cache_size % 1073741824;

ncache =

(num_caches, 1);

->set_cachesize(

, cache_g, (

)cache_size, ncache);

(ret,

);

(ret,

);

ret =

->set_lg_bsize(

, lg_bsize);

(ret,

);

recover_requested =

& DB_RECOVER;

* db_home_param = db_home;

(strlen(db_home) == 0)

db_home_param =

;

(ret == DB_RUNRECOVERY) {

(

& DB_JOINENV) {

recover_flag =

;

(!recover_requested) {

(

& DB_INIT_TXN) {

recover_flag =

| DB_RECOVER | DB_CREATE;

ret =

->open(

, db_home_param, recover_flag, 0664);

(!recover_requested) {

((ret == DB_RUNRECOVERY) && (

& DB_INIT_TXN)) {

recover_flag =

| DB_RECOVER_FATAL | DB_CREATE;

recover_flag &= ~DB_RECOVER;

ret =

->open(

, db_home_param, recover_flag, 0664);

<< ret);

(db_home, DB_CREATE

|DB_THREAD|DB_INIT_LOCK|DB_INIT_MPOOL);

ret =

(db_home.c_str(),

DB_CREATE|DB_THREAD|DB_PRIVATE|DB_INIT_MPOOL);

(ret,

);

ret =

->set_lk_detect(

, DB_LOCK_DEFAULT);

(ret,

);

flag = DB_INIT_TXN |

DB_CREATE | DB_INIT_LOCK | DB_INIT_MPOOL;

flag |= DB_SYSTEM_MEM;

recover_flag = flag | DB_RECOVER | DB_CREATE;

(!(recover_flag & DB_SYSTEM_MEM)) {

recover_flag |= DB_PRIVATE;

ret =

(db_home.c_str(), recover_flag);

(!(recover_flag & DB_PRIVATE)) {

ret = db_env_create(&

, 0);

recover_flag = flag | DB_RECOVER_FATAL | DB_CREATE;

(!(recover_flag & DB_SYSTEM_MEM)) {

recover_flag |= DB_PRIVATE;

ret =

(db_home.c_str(), recover_flag);

(!(recover_flag & DB_PRIVATE)) {

ret = db_env_create(&

, 0);

(db_home, flag);

ret =

->set_flags(

, DB_CDB_ALLDB, 1);

(ret,

);

(db_home, DB_CREATE | DB_THREAD | DB_INIT_CDB | DB_INIT_MPOOL);

flag = DB_JOINENV;

(db_home, flag);

(trans_test) {

ret =

->txn_begin(

, 0, &txn, 0);

ret = txn->abort(txn);

(ret,

);

(

& DB_INIT_TXN) {

ret = db_env_create(&

, 0);

ret = db_env_create(&

, 0);

(log_dir.empty()) {

(3,

<< log_dir);

ret =

->set_lg_dir(

, log_dir.c_str());

(exception& ex)

(4,

<< ex.what());

ret =

->set_lg_max(

, lg_max);

ret =

->set_lk_max_locks(

, locks);

(ret,

);

ret =

->set_tx_max(

, tx_max);

ret =

->get_lk_max_locks(

, &lk_max);

(ret,

);

(ret,

);

ret =

->set_lk_max_lockers(

, max_lockers);

(ret,

);

ret =

->set_flags(

, DB_LOG_INMEMORY,

(on_off));

(ret,

);

ret =

->log_set_config(

, DB_LOG_IN_MEMORY, (

)on_off);

(ret,

);

ret =

->mutex_set_tas_spins(

, tas_spins);

(ret,

);

ret =

->set_tas_spins(

, tas_spins);

(ret,

);

->set_flags(

, DB_DIRECT_DB, (

)on_off);

->set_flags(

, DB_DIRECT_LOG, (

)on_off);

->log_set_config(

, DB_LOG_DIRECT, (

)on_off);

ret =

->set_flags(

, DB_LOG_AUTOREMOVE, (

)on_off);

(ret,

);

ret =

->log_set_config(

, DB_LOG_AUTO_REMOVE, (

)on_off);

(ret,

);

(ret,

);

->txn_checkpoint(

, 0, 0, DB_FORCE);

(ret,

);

->log_archive(

, &nm_list, DB_ARCH_ABS);

(nm_list !=

) {

db_timeout_t to = timeout;

ret =

->set_timeout(

, to, DB_SET_LOCK_TIMEOUT);

db_timeout_t to = timeout;

ret =

->set_timeout(

, to, DB_SET_TXN_TIMEOUT);

(ret,

);

ret =

->mutex_get_max(

, &maxp);

(ret,

);

ret =

->mutex_set_increment(

, inc);

(ret,

);

ret =

->mutex_get_increment(

, &inc);

(ret,

);

DB_MUTEX_STAT* stp = 0;

ret =

->mutex_stat(

, &stp, 0);

free_m = stp->st_mutex_free;

DB_MUTEX_STAT* stp = 0;

ret =

->mutex_stat(

, &stp, 0);

<<

<< stp->st_mutex_align <<

<<

<< stp->st_mutex_tas_spins <<

<<

<< stp->st_mutex_free <<

<<

<< stp->st_mutex_inuse <<

<<

<< stp->st_mutex_inuse_max <<

<<

<< stp->st_regsize <<

<<

<< stp->st_region_wait <<

<<

<< stp->st_region_nowait <<

DB_LOCK_STAT *stp = 0;

ret =

->lock_stat(

, &stp, 0);

<<

<< stp->st_cur_maxid <<

<<

<< stp->st_nmodes <<

<<

<< stp->st_maxlocks <<

<<

<< stp->st_maxlockers <<

<<

<< stp->st_maxobjects <<

<<

<< stp->st_nlocks <<

<<

<< stp->st_maxnlocks <<

<<

<< stp->st_nlockers <<

<<

<< stp->st_maxnlockers <<

<<

<< stp->st_nobjects <<

<<

<< stp->st_maxnobjects <<

<<

<< stp->st_nrequests <<

<<

<< stp->st_nreleases <<

<<

<< stp->st_nupgrade <<

<<

<< stp->st_ndowngrade <<

<<

<< stp->st_lock_wait <<

<<

<< stp->st_lock_nowait <<

<<

<< stp->st_ndeadlocks <<

<<

<< stp->st_locktimeout <<

<<

<< stp->st_nlocktimeouts <<

<<

<< stp->st_txntimeout <<

<<

<< stp->st_ntxntimeouts <<

<<

<< stp->st_regsize <<

<<

<< stp->st_region_wait <<

<<

<< stp->st_region_nowait <<

DB_MPOOL_STAT *stp = 0;

ret =

->memp_stat(

, &stp, 0, 0);

<<

<< stp->st_gbytes <<

<<

<< stp->st_bytes <<

<<

<< stp->st_ncache <<

<<

<< stp->st_regsize <<

<<

<< stp->st_mmapsize <<

<<

<< stp->st_maxopenfd <<

<<

<< stp->st_maxwrite <<

<<

<< stp->st_maxwrite_sleep <<

<<

<< stp->st_map <<

<<

<< stp->st_cache_hit <<

<<

<< stp->st_cache_miss <<

<<

<< stp->st_page_create <<

<<

<< stp->st_page_in <<

<<

<< stp->st_page_out <<

<<

<< stp->st_ro_evict <<

<<

<< stp->st_rw_evict <<

<<

<< stp->st_page_trickle <<

<<

<< stp->st_pages <<

<<

<< stp->st_page_clean <<

<<

<< stp->st_page_dirty <<

<<

<< stp->st_hash_buckets <<

<<

<< stp->st_hash_searches <<

<<

<< stp->st_hash_longest <<

<<

<< stp->st_hash_examined <<

<<

<< stp->st_hash_nowait <<

<<

<< stp->st_hash_wait <<

<<

<< stp->st_hash_max_nowait <<

<<

<< stp->st_hash_max_wait <<

<<

<< stp->st_region_wait <<

<<

<< stp->st_region_nowait <<

<<

<< stp->st_mvcc_frozen <<

<<

<< stp->st_mvcc_thawed <<

<<

<< stp->st_mvcc_freed <<

<<

<< stp->st_alloc <<

<<

<< stp->st_alloc_buckets <<

<<

<< stp->st_alloc_max_buckets <<

<<

<< stp->st_alloc_pages <<

<<

<< stp->st_alloc_max_pages <<

<<

<< stp->st_io_wait <<

db_timeout_t max_write_sleep;

->get_mp_max_write(

, &max_write, &max_write_sleep);

(ret,

);

<<

<< max_write <<

<<

<< max_write_sleep <<

ret =

->memp_trickle(

, percent, &nwr);

(ret,

);

=

;

+=

;

ret =

->set_mp_max_write(

, maxwrite, maxwrite_sleep);

(ret,

);

ret =

->get_mp_mmapsize(

, &map_size);

(ret,

);

ret =

->set_mp_mmapsize(

, map_size);

(ret,

);

u_int32_t detect = 0;

(detect_mode)

detect = DB_LOCK_DEFAULT;

detect = DB_LOCK_MAXLOCKS;

detect = DB_LOCK_MINWRITE;

detect = DB_LOCK_OLDEST;

detect = DB_LOCK_RANDOM;

detect = DB_LOCK_YOUNGEST;

ret =

->set_lk_detect(

, detect);

(ret,

);

ret =

->lock_detect(

, 0, detect, &aborted);

thread_delay,

(6,

<<

);

);

(8,

<<

);

(9,

<<

);

((ret = db_env_create(&dbenv, 0)) != 0) {

+

(db_strerror(ret));

dbenv->set_errfile(dbenv, stderr);

u_int32_t

= 0;

|= DB_CREATE | DB_INIT_LOG |

DB_INIT_MPOOL | DB_INIT_TXN | DB_USE_ENVIRON;

|= fatal_recover ? DB_RECOVER_FATAL : DB_RECOVER;

|= DB_PRIVATE;

((ret = dbenv->open(dbenv, path.c_str(),

, 0)) != 0) {

dbenv->close(dbenv, 0);

+

(db_strerror(ret));

ret = dbenv->close(dbenv, 0);

Wrapper around Berkeley DB environment structure.

Wrapper around Berkeley DB transaction structure.

Transaction checkpoint / memptrickle thread.

static void AddOnExitCallback(CBDB_Env &bdb_env)

shared_ptr< bool > m_StopThreadFlag

void operator()(void) const

CBDB_Env_OnAppExit(CBDB_Env &bdb_env)

BDB environment object a collection including support for some or all of caching, locking,...

Base BDB exception class.

void RequestStop()

Schedule thread Stop.

std::ofstream out("events_result.xml")

main entry point for tests

void AddOnExitAction(TFunc func)

Add callback to be executed from CNcbiApplicationAPI destructor.

static CNcbiApplicationGuard InstanceGuard(void)

Singleton method.

ETransSync

Enum controls if transaction is synchronous or not.

void StopCheckpointThread()

Stop transaction checkpoint thread.

void SetTransactionMax(unsigned tx_max)

Set number of active transaction see DB_ENV->set_tx_max for more details.

void SetDirectDB(bool on_off)

Turn off buffering of databases (DB_DIRECT_DB)

void PrintMemStat(CNcbiOstream &out)

Print memory statistics.

void BDB_RecoverEnv(const string &path, bool fatal_recover)

Run Berkeley DB recovery in private environment.

void SetCacheSize(Uint8 cache_size, int num_caches=1)

Set cache size for the environment.

bool m_Transactional

TRUE if transactional.

unsigned x_GetDeadLockDetect(EDeadLockDetect detect_mode)

void MutexSetMax(unsigned max)

Configure the total number of mutexes.

void CleanLog()

Remove all non-active log files.

ETransactionDiscovery

Modes to test if environment is transactional or not.

unsigned MutexGetFree()

Get number of free mutexes.

void SetDirectLog(bool on_off)

Turn off buffering of log files (DB_DIRECT_LOG)

void SetMpMaxWrite(int maxwrite, int maxwrite_sleep)

limits the number of sequential write operations scheduled by the library when flushing dirty pages f...

void LogFlush()

Flush all pending log records.

bool CheckRemove()

Try to Remove the environment, if DB_ENV::remove returns 0, but fails files ramain on disk anyway cal...

void SetLockTimeout(unsigned timeout)

Set timeout value for locks in microseconds (1 000 000 in sec)

size_t GetMpMmapSize()

Get the maximal size for mmap.

void SetTasSpins(unsigned tas_spins)

Specify that test-and-set mutexes should spin tas_spins times without blocking.

void SetLogInMemory(bool on_off)

Configure environment for non-durable in-memory logging.

void TransactionCheckpoint()

Flush the underlying memory pools, logs and data bases.

void SetMaxLocks(unsigned locks)

Set max number of locks in the database.

void StopBackgroundWriterThread()

Stop transaction checkpoint thread.

void SetLogRegionMax(unsigned size)

Set logging region size.

void SetLogAutoRemove(bool on_off)

If set, Berkeley DB will automatically remove log files that are no longer needed.

shared_ptr< bool > m_StopThreadFlag

void SetLkDetect(EDeadLockDetect detect_mode)

Set deadlock detect mode (call before open).

IServer_Monitor * m_Monitor

Monitoring interface.

void SetLogDir(const string &log_dir)

Path to directory where transaction logs are to be stored By default it is the same directory as envi...

EDeadLockDetect m_DeadLockMode

void SetLogFileMax(unsigned int lg_max)

Set maximum size of LOG files.

void LsnReset(const char *file_name)

Reset log sequence number.

void RunBackgroundWriter(TBackgroundFlags flags, unsigned thread_delay=30, int memp_trickle=0, unsigned err_max=0)

Schedule background maintenance thread which will do:

void SetTransactionTimeout(unsigned timeout)

Set timeout value for transactions in microseconds (1 000 000 in sec)

void LsnResetForMemLog(const char *file_name)

Reset log sequence number if environment logs are in memory.

unsigned m_CheckPointKB

Checkpoint KBytes.

void OpenPrivate(const string &db_home)

Open-create private environment.

#define BDB_THROW(errcode, message)

void SetWorkFlag(CBDB_Env::TBackgroundFlags flags)

unsigned MutexGetMax()

Get number of mutexes.

void DeadLockDetect()

Run deadlock detector.

unsigned int TEnvOpenFlags

OR-ed combination of EEnvOptions.

void MempSync()

Flushes modified pages in the cache to their backing files.

void MutexSetIncrement(unsigned inc)

Configure the number of additional mutexes to allocate.

void SetMaxLockObjects(unsigned lock_obj_max)

see DB_ENV->set_lk_max_objects for more details

unsigned m_MaxLockObjects

unsigned TBackgroundFlags

Background work flags (combination of EBackgroundWork)

void SetMaxLockers(unsigned max_lockers)

Set the maximum number of locking entities supported by the Berkeley DB environment.

CBDB_Transaction::ETransSync m_TransSync

void OpenWithLocks(const string &db_home)

Open environment with database locking (DB_INIT_LOCK)

void SetTransactionSync(CBDB_Transaction::ETransSync sync)

Set default syncronicity level.

void MempTrickle(int percent, int *nwrotep)

Ensures that a specified percent of the pages in the shared memory pool are clean,...

int x_Open(const char *db_home, int flags)

Opens BDB environment returns error code Throws no exceptions.

void Close()

Close the environment;.

DB_TXN * CreateTxn(DB_TXN *parent_txn=0, unsigned int flags=0)

Start transaction (DB_ENV->txn_begin)

unsigned MutexGetIncrement()

void SetMaxErrors(unsigned max_err)

Set maximum number of errors this thread tolerates 0 - unlimited.

CRef< CBDB_CheckPointThread > m_CheckThread

Checkpoint thread.

void OpenConcurrentDB(const string &db_home)

Open environment with CDB locking (DB_INIT_CDB)

bool Remove()

Non-force removal of BDB environment.

void ForceRemove()

Force remove BDB environment.

void OpenErrFile(const string &file_name)

Open error reporting file for the environment.

bool m_CheckPointEnable

Checkpoint enabled.

unsigned GetMaxLocks()

Get max locks.

void PrintMutexStat(CNcbiOstream &out)

Print mutex statistics.

EDeadLockDetect

Deadlock detection modes.

unsigned m_CheckPointMin

Checkpoint minutes.

void Open(const string &db_home, int flags)

Open environment.

void SetMpMmapSize(size_t map_size)

Set the maximal size for mmap.

void OpenWithTrans(const string &db_home, TEnvOpenFlags opt=0)

Open environment using transaction.

bool IsTransactional() const

Return TRUE if environment has been open as transactional.

#define BDB_CHECK(errnum, x_db_object__)

void ForceTransactionCheckpoint()

Forced checkpoint.

void SetErrPrefix(const string &s)

Set the prefix used during reporting of errors.

void SetLogBSize(unsigned lg_bsize)

Set the size of the in-memory log buffer, in bytes.

void RunCheckpointThread(unsigned thread_delay=30, int memp_trickle=0, unsigned err_max=0)

Deprecated version of RunBackgroundWriter.

void PrintLockStat(CNcbiOstream &out)

Print lock statistics.

void JoinEnv(const string &db_home, TEnvOpenFlags opt=0, ETransactionDiscovery trans_test=eTestTransactions)

Join the existing environment.

@ eEnvDefault

Use default from CBDB_Env.

@ eTransSync

Syncronous transaction.

@ eTestTransactions

Do a test to discover transactions.

@ eInspectTransactions

Ask the joined environment if it supports transactions.

@ eAssumeNoTransactions

Assume env. is non-transactional.

@ eAssumeTransactions

Assume env. is transactional.

@ eBackground_DeadLockDetect

@ eBackground_MempTrickle

@ eRunRecovery

Run DB recovery first.

@ ePrivate

Create private directory.

@ eThreaded

corresponds to DB_THREAD

@ eRunRecoveryFatal

Run DB recovery first.

@ eDeadLock_Youngest

Abort the youngest trans.

@ eDeadLock_MaxLocks

Abort trans with the greatest number of locks.

@ eDeadLock_MinWrite

Abort trans with the fewest write locks.

@ eDeadLock_Oldest

Abort the oldest trans.

@ eDeadLock_Default

Default deadlock detector.

@ eDeadLock_Disable

No deadlock detection performed.

@ eDeadLock_Random

Abort a random trans involved in the deadlock.

#define LOG_POST_X(err_subcode, message)

#define ERR_POST_X(err_subcode, message)

Error posting with default error code and given error subcode.

void Warning(CExceptionArgs_Base &args)

void Info(CExceptionArgs_Base &args)

TEntries GetEntries(const string &mask=kEmptyStr, TGetEntriesFlags flags=0) const

Get directory entries based on the specified "mask".

virtual bool Remove(TRemoveFlags flags=eRecursive) const

Remove a directory entry.

virtual bool Exists(void) const

Check if directory "dirname" exists.

bool Create(TCreateFlags flags=fCreate_Default) const

Create the directory using "dirname" passed in the constructor.

void Reset(void)

Reset reference object.

bool Empty(void) const THROWS_NONE

Check if CRef is empty – not pointing to any object, which means having a null value.

uint32_t Uint4

4-byte (32-bit) unsigned integer

uint64_t Uint8

8-byte (64-bit) unsigned integer

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

IO_PREFIX::ostream CNcbiOstream

Portable alias for ostream.

static string IntToString(int value, TNumToStringFlags flags=0, int base=10)

Convert int to string.

virtual bool IsActive()=0

Check if monitoring is active.

virtual void Send(const char *msg, size_t length)=0

Send message.

bool Run(TRunMode flags=fRunDefault)

Run the thread.

void Join(void **exit_data=0)

Wait for the thread termination.

Definition of all error codes used in bdb library (bdb.lib and ncbi_xcache_bdb.lib).

const struct ncbi::grid::netcache::search::fields::SIZE size

Common macro to detect used sanitizers and suppress memory leaks if run under LeakSanitizer.

#define NCBI_LSAN_DISABLE_GUARD

Defines classes: CDirEntry, CFile, CDir, CSymLink, CMemoryFile, CFileUtil, CFileLock,...

static SLJIT_INLINE sljit_ins msg(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4