eRunRecovery = (1 << 1),
66eRunRecoveryFatal = (1 << 2),
95 voidOpen(
const string& db_home,
int flags);
100 voidOpenWithLocks(
const string& db_home);
103 voidOpenPrivate(
const string& db_home);
108 voidOpenConcurrentDB(
const string& db_home);
116 voidOpenWithTrans(
const string& db_home,
TEnvOpenFlagsopt = 0);
124 voidOpenErrFile(
const string&
file_name);
127 voidSetErrPrefix(
const string& s);
133eInspectTransactions,
136eAssumeNoTransactions
146 voidJoinEnv(
const string& db_home,
147TEnvOpenFlags opt = 0,
148ETransactionDiscovery trans_test = eTestTransactions);
156 voidSetCacheSize(
Uint8cache_size,
170 boolIsTransactional()
const;
173 voidTransactionCheckpoint();
176 voidForceTransactionCheckpoint();
179 voidSetDirectDB(
boolon_off);
182 voidSetDirectLog(
boolon_off);
186 voidSetLogAutoRemove(
boolon_off);
189 voidSetLogFileMax(
unsigned intlg_max);
192 voidSetLogRegionMax(
unsigned size);
195 voidSetLogBSize(
unsignedlg_bsize);
198 voidSetLogInMemory(
boolon_off);
202 voidSetLogDir(
const string& log_dir);
209 voidSetMaxLocks(
unsignedlocks);
212 unsignedGetMaxLocks();
215 voidSetMaxLockObjects(
unsignedlock_obj_max);
218 voidSetMaxLockers(
unsignedmax_lockers);
227 voidSetLockTimeout(
unsignedtimeout);
230 voidSetTransactionTimeout(
unsignedtimeout);
234 voidSetTransactionMax(
unsignedtx_max);
238 voidSetTasSpins(
unsignedtas_spins);
241 voidMutexSetMax(
unsigned max);
244 unsignedMutexGetMax();
247 voidMutexSetIncrement(
unsignedinc);
249 unsignedMutexGetIncrement();
252 unsignedMutexGetFree();
278 voidLsnResetForMemLog(
const char*
file_name);
305 voidMempTrickle(
intpercent,
int*nwrotep);
317 voidSetMpMaxWrite(
intmaxwrite,
intmaxwrite_sleep);
320 voidSetMpMmapSize(
size_tmap_size);
323 size_tGetMpMmapSize();
326 const string&
GetPath()
const{
returnm_HomePath; }
359 voidSetLkDetect(EDeadLockDetect detect_mode);
362 voidDeadLockDetect();
372eBackground_MempTrickle = (1 << 0),
373eBackground_Checkpoint = (1 << 1),
374eBackground_DeadLockDetect = (1 << 2),
400 unsignedthread_delay = 30,
401 intmemp_trickle = 0,
402 unsignederr_max = 0);
405 voidStopBackgroundWriterThread();
408 voidRunCheckpointThread(
unsignedthread_delay = 30,
409 intmemp_trickle = 0,
410 unsignederr_max = 0);
413 voidStopCheckpointThread();
437 unsignedx_GetDeadLockDetect(EDeadLockDetect detect_mode);
Wrapper around Berkeley DB transaction structure.
Transaction checkpoint / memptrickle thread.
BDB environment object a collection including support for some or all of caching, locking,...
std::ofstream out("events_result.xml")
main entry point for tests
ETransSync
Enum controls if transaction is synchronous or not.
void BDB_RecoverEnv(const string &path, bool fatal_recover)
Run Berkeley DB recovery in private environment.
bool m_Transactional
TRUE if transactional.
ETransactionDiscovery
Modes to test if environment is transactional or not.
EEnvType
Environment types.
const string & GetPath() const
return the path to the environment
shared_ptr< bool > m_StopThreadFlag
void EnableCheckPoint(bool on_off)
When OFF calls to TransactionCheckpoint() will be ignored.
CBDB_Env & operator=(const CBDB_Env &)
void SetMonitor(IServer_Monitor *monitor)
Set monitor (class does NOT take ownership)
IServer_Monitor * m_Monitor
Monitoring interface.
EDeadLockDetect m_DeadLockMode
unsigned m_CheckPointKB
Checkpoint KBytes.
unsigned int TEnvOpenFlags
OR-ed combination of EEnvOptions.
EBackgroundWork
Background work flags.
unsigned m_MaxLockObjects
unsigned TBackgroundFlags
Background work flags (combination of EBackgroundWork)
CBDB_Transaction::ETransSync m_TransSync
DB_ENV * GetEnv()
Return underlying DB_ENV structure pointer for low level access.
CBDB_Env(const CBDB_Env &)
forbidden
IServer_Monitor * GetMonitor()
Get monitor.
CBDB_Transaction::ETransSync GetTransactionSync() const
Get default syncronicity setting.
CRef< CBDB_CheckPointThread > m_CheckThread
Checkpoint thread.
void SetCheckPointMin(unsigned m)
If the m parameter is non-zero, a checkpoint will be done if more than min minutes have passed since ...
void SetCheckPointKB(unsigned kb)
If the kb parameter is non-zero, a checkpoint will be done if more than kbyte kilobytes of log data h...
bool m_CheckPointEnable
Checkpoint enabled.
EDeadLockDetect
Deadlock detection modes.
unsigned m_CheckPointMin
Checkpoint minutes.
bool IsLogInMemory() const
@ eTestTransactions
Do a test to discover transactions.
@ eAssumeTransactions
Assume env. is transactional.
@ 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.
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.
const struct ncbi::grid::netcache::search::fields::SIZE size
static SERV_ITER x_Open(const char *service, int ismask, TSERV_Type types, unsigned int preferred_host, unsigned short preferred_port, double preference, const SConnNetInfo *net_info, SSERV_InfoCPtr skip[], size_t n_skip, int external, const char *arg, const char *val, SSERV_Info **info, HOST_INFO *host_info)
Portable reference counted smart and weak pointers using CWeakRef, CRef, CObject and CObjectEx.
Base interface for monitoring.
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