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__blobcache_8cpp_source.html below:

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

= path + cache +

+

+

(blob_lock.GetLockVector(), blob_lock.GetTimeout())

(blob_lock.GetLockVector(), blob_lock.GetTimeout())

(

<<

(

<<

(end-pos)<<

<<pos<<

<<end);

(*bytes_read == 0) {

reserve = requested_size / 2;

(reserve > 1 * 1024 * 1024) {

reserve = 1 * 1024 * 1024;

requested_size + reserve;

blob_id_ext,

& blob_key,

& owner,

(blob_lock.GetLockVector(), blob_lock.GetTimeout())

(

);

}

(exception& ) {

}

(exception& ) {

}

(exception & ex) {

(1,

<< ex.what()

* bytes_written = 0)

(

);

.append(

);

*bytes_written =

;

(exception& ) {

*bytes_written =

;

);

err =

;

(eCannotOpenOverflowFile, err);

);

hist_value = 512;

(

= 0;

< 100; ++

) {

(*hist)[hist_value] = 0;

(hist->

()) {

(it == hist->

()) {

(time_t time_in_secs,

* day,

* hour)

*day =

(time_in_secs / (24 * 60 * 60));

secs_in_day =

(time_in_secs % (24 * 60 * 60));

*hour = secs_in_day / 3600;

(ta_stat.

== day && ta_stat.

== hour) {

(ta_stat.

== day && ta_stat.

== hour) {

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

<<

;

<<

<<

<<

;

<<

<<

;

<<

<<

<<

;

<<

<<

;

(it->second > 0) {

<< it->first <<

<< it->second <<

;

(it == hist_end) {

& sect_name_postfix)

postfix(sect_name_postfix);

sect_stat(

);

(!postfix.empty()) {

sect_stat.append(

);

sect_stat.append(postfix);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

pair.append(put_count);

(!put_history.empty()) {

put_history.append(

);

put_history.append(pair);

pair.append(get_count);

(!get_history.empty()) {

get_history.append(

);

get_history.append(pair);

reg->

(sect_stat,

,

);

reg->

(sect_stat,

,

);

sect_hist(

);

(!postfix.empty()) {

sect_hist.append(

);

sect_hist.append(postfix);

(it->second > 0) {

var_name =

;

(it == hist_end) {

&

= it->first;

<<

<<

<<

<<

<<

<<

;

&

= it->first;

<<

<<

<<

<<

<<

<<

<<

;

m_ReadOnly(

),

m_InitIfDirty(

),

m_JoinedEnv(

),

m_LockTimeout(20 * 1000),

m_BLOB_SplitStore(0),

m_CacheAttrDB_RO1(0),

m_CacheAttrDB_RO2(0),

m_VersionFlag(eDropOlder),

m_WSync(eWriteNoSync),

m_PurgeBatchSize(150),

m_PurgeStopSignal(0, 100),

m_CleanLogOnPurge(0),

m_PurgeNowRunning(

),

m_RunPurgeThread(

),

m_PurgeThreadDelay(10),

m_CheckPointInterval(24 * (1024 * 1024)),

m_OverflowLimit(512 * 1024),

m_MaxTTL_prolong(0),

m_SaveStatistics(

),

m_RoundRobinVolumes(0),

(

<<exc);

(exception& exc) {

(

<<exc.

());

lock_file_path =

+ lock_file;

& cache_name,

cache_ram_size,

log_mem_size)

((!fl.empty() || fl_clean.

())

&& s_OpenedDirs.count(

) == 0)

(

(

);

(!fl_clean.

()) {

writer.

(pid.data(), pid.size());

err_file =

+

+

(cache_name) +

;

needs_recovery =

;

<< cache_name <<

);

<< cache_name <<

);

<< cache_name <<

);

needs_recovery =

;

needs_recovery =

;

(log_mem_size == 0) {

(cache_ram_size) {

(cache_ram_size > (500 * 1024 * 1024)) {

cache_num = (

)((cache_ram_size) /

(250 * 1024 * 1024));

(cache_num > 10) {

(checkpoint_KB == 0) {

(needs_recovery) {

(5,

<<

);

cache_blob_db_name =

attr_db_name =

id_idx_name =

timeline_precision = 5 * 60;

(timeline_precision > (5 * 60)) {

timeline_precision = 5 * 60;

(timeline_precision < (1 * 60)) {

timeline_precision = 1 * 60;

max_blob_id = 0;

max_blob_id =

(max_blob_id, blob_id);

<< cache_name <<

<< cache_path);

);

& cache_name,

cache_blob_db_name =

attr_db_name =

<< cache_name <<

<< cache_path);

<<

<<

);

<<

);

(exception& ex) {

<<

<< ex.what()

timeout,

max_timeout)

= max_timeout > timeout ? max_timeout : timeout;

split_coord[2];

(coord[0] != split_coord[0] || coord[1] != split_coord[1]) {

time_to_live,

& owner)

time_t curr = time(0);

blob_id = 0;

coord[2]={0,};

ret = cur.

();

split_coord[2];

(coord[0] != split_coord[0] || coord[1] != split_coord[1]) {

&

,

time_to_live,

& owner,

coord[2] = {0,};

overflow = 0, old_overflow = 0;

time_t curr = time(0);

(

);

.append(

);

blob_lock, do_blob_lock,

&coord[0], &coord[1],

blob_id = blob_lock.

();

(!oveflow_file.is_open() || oveflow_file.bad()) {

err =

;

(eCannotOpenOverflowFile, err);

split_coord[2];

(coord[0] != split_coord[0] || coord[1] != split_coord[1]) {

coord[0] = coord[1] = 0;

ret = cur.

();

(blob_id != old_blob_id) {

);

=

;

blob_updated = 0;

blob_stored = 0;

blob_stored, blob_updated, (

)

, overflow);

&

,

time_to_live,

& owner)

time_to_live,

& owner)

blob_size = 0;

ttl, blob_id, volume_id, split_id;

(!blob_id)

;

blob_id, volume_id, split_id);

(!rec_exists)

;

blob_size = (size_t)entry.

();

(blob_id == 0)

;

coords[0] = volume_id;

coords[1] = split_id;

(ret !=

)

;

time_t curr = time(0);

(

!= found_key )

time_t curr = time(0);

volume_id = 0, split_id = 0;

(!blob_id)

;

ret = cur.

();

(max_time == 0 || max_time >= (

)curr) {

unique_ptr<CNcbiIfstream>

(!overflow_file->is_open()) {

overflow_file->read((

*)

, buf_size);

(!*overflow_file) {

(coords[0] != volume_id ||

coords[1] != split_id) {

coords[0] = volume_id;

coords[1] = split_id;

& file_length,

unique_ptr<CNcbiIfstream>

(!overflow_file->is_open()) {

file_length = (size_t) entry.

();

time_t curr = time(0);

volume_id = 0, split_id = 0;

ret = cur.

();

(max_time == 0 || max_time >= (

) curr) {

unique_ptr<IReader> rd;

rd.release();

(coords[0] != volume_id ||

coords[1] != split_id) {

coords[0] = volume_id;

coords[1] = split_id;

);

);

blob_descr->

.reset();

time_t curr = time(0);

volume_id = 0, split_id = 0;

ret = cur.

();

(max_time == 0 || max_time >= (

) curr) {

blob_descr->

.reset(

(blob_descr->

.get()) {

(coords[0] != volume_id ||

coords[1] != split_id) {

coords[0] = volume_id;

coords[1] = split_id;

** ptr = &blob_descr->

;

unique_ptr<CBDB_RawFile::TBuffer>

(

blob_descr->

.reset(

time_to_live,

& owner)

time_to_live, owner);

&

,

time_to_live,

& owner)

time_t curr = time(0);

coord[2] = {0,};

blob_lock, do_id_lock,

&coord[0], &coord[1],

blob_lock.

(),

vector<SCacheDescr> cache_elements;

cache_elements.push_back(

(0 == read_count) {

(vector<SCacheDescr>, it, cache_elements) {

vector<SCacheDescr> cache_elements;

cache_elements.push_back(

(0 == read_count) {

(vector<SCacheDescr>, it, cache_elements) {

& overflow_file_path,

overflow_file.write(

,

);

(overflow_file.bad()) {

overflow_file.close();

err(

);

err += overflow_file_path;

time_t curr = time(0);

=

;

+=

;

+=

;

(!delete_candidates.

()) {

;

(batch_size < 10) {

candidates = delete_candidates.

();

cleaned_candidates = delete_candidates.

();

(cleaned_candidates != candidates) {

=

;

+=

;

candidates = cleaned_candidates;

id_trans_time = 0.0;

exp_check_time = 0.0;

del_time = 0.0;

deleted_cnt = 0;

vector<unsigned> blob_id_vect(batch_size);

vector<SCacheDescr> blob_batch_vect(batch_size);

vector<SCacheDescr> blob_exp_vect(batch_size);

blob_id_vect.resize(0);

blob_batch_vect.resize(0);

blob_exp_vect.resize(0);

(

= 0; en.valid() &&

< batch_size; ++

) {

blob_id = *en;

blob_id_vect.push_back(blob_id);

(blob_id_vect.size()) {

vector<unsigned>::const_iterator it = blob_id_vect.begin();

blob_id = *it;

cur.

<< blob_id;

(blob_id != bid) {

((++it) == blob_id_vect.end())

cur.

<< (blob_id = *it);

blob_batch_vect.push_back(

(it == blob_id_vect.end()) {

((blob_id + 1) == *it) {

cur.

<< (blob_id = *it);

(blob_batch_vect.size()) {

(

= 0;

< blob_batch_vect.size(); ++

) {

blob_exp_vect.push_back(blob_descr);

deleted_batch_cnt = 0;

(blob_exp_vect.size()) {

(

= 0;

< blob_exp_vect.size(); ++

) {

+=

;

deleted_batch_cnt += blob_deleted;

deleted_cnt += deleted_batch_cnt;

=

;

+=

;

+=

;

+=

;

+=

;

+=

;

*interrupted =

;

(access_timeout == 0) {

scan_interrupted =

;

(scan_interrupted) {

time_t gc_start = time(0);

split_store_blobs = bv.count();

tl_count = timeline_blobs.

();

vector<SCacheDescr> cache_entries;

cache_entries.reserve(1000);

db_recs = 0;

first_key, last_key;

next_exp_key;

(

flag =

; flag;) {

time_t curr = time(0);

cur.

<< last_key;

(rec_cnt = 0; rec_cnt < batch_size; ++rec_cnt) {

cache_entries.push_back(

next_exp_key =

;

next_exp_key =

;

first_key = last_key;

(rec_cnt == (batch_size - 1)) {

(first_key == last_key) {

(

);

+=

;

(cache_entries.size() > 0) {

(

= 0;

< cache_entries.size(); ++

) {

+=

;

<<

(exception& ex) {

<<

cache_entries.resize(0);

(24,

<<

);

(scan_interrupted) {

time_in_purge = 0;

time_t curr = time(0);

time_in_purge = (unsigned)curr - (

)gc_start;

time_t access_timeout)

(

.empty() && access_timeout == 0) {

vector<SCacheDescr> cache_entries;

recs_scanned = 0;

time_t curr = time(0);

(access_timeout && access_timeout < timeout) {

timeout = (

)access_timeout;

to = timeout;

(access_timeout && (!(curr - to > db_time_stamp))) {

cache_entries.push_back(

(0 == read_count) {

(vector<SCacheDescr>, it, cache_entries) {

& cache_name,

& err_file,

->

(cache_path, DB_INIT_MPOOL | DB_USE_ENVIRON);

DB_CREATE | DB_INIT_MPOOL | DB_PRIVATE | DB_USE_ENVIRON);

(26,

+

(cache_path));

cache_blob_db_name =

attr_db_name =

bak =

+ attr_db_name +

;

FILE* fl = fopen(bak.c_str(),

);

(27,

+ attr_db_name);

(28,

);

exp_time = time_stamp + timeout;

ttl = attr_db.

;

*exp_time = db_time_stamp + timeout;

(curr - timeout > db_time_stamp) {

timeout = (unsigned)time(0);

(old_ts < timeout) {

(max_time == 0 || max_time >= timeout) {

(access_type) {

blob_id, volume_id, split_id;

coords[2] = { volume_id, split_id };

(29,

<<

);

ov_(

);

( (*it)->IsFile() ) {

ext = (*it)->GetExt();

& blob_id,

& volume_id,

& split_id)

}

(exception& ex) {

(30,

<< path

<<

<< ex.what());

}

(exception& ex) {

(31,

<< file_path

<<

<< ex.what());

(eInvalidOperation,

);

time_t curr = time(0);

coords[2] = {0,};

split_coord[2] = {0,};

blob_expired =

;

blob_expired =

;

blob_expired =

;

(!blob_expired) {

(overflow == 1) {

(split_coord[0] != coords[0] ||

split_coord[1] != coords[1]) {

(overflow == 1) {

coords[2] = {0,};

split_coord[2] = {0,};

delete_split =

;

(split_coord[0] != coords[0] ||

split_coord[1] != coords[1]) {

delete_split =

;

(!blob_id)

;

&

,

* volume_id,

* split_id,

* overflow)

blob_id = 0;

(blob_id == 0) {

ret = cur.

();

blob_lock.

(blob_id);

blob_lock.

(blob_id);

*overflow = *volume_id = *split_id = 0;

(blob_id_ext == 0) {

blob_id = blob_id_ext;

blob_lock.

(blob_id);

blob_lock.

(blob_id);

);

& owner)

& owner)

& owner)

& owner)

& x_subkey)

* x_CreateInstance(

( !driver_params ) {

str_path = path ?

(!path || str_path !=

) {

& driver,

unique_ptr<CBDB_Cache> drv;

(driver.empty() || driver == m_DriverName) {

drv.release();

& path =

overflow_limit = (unsigned)

(overflow_limit) {

drv->SetOverflowLimit(overflow_limit);

log_mem_size =

checkpoint_bytes = (unsigned)

, 24 * 1024 * 1024);

drv->SetCheckpoint(checkpoint_bytes);

checkpoint_delay =

drv->SetCheckpointDelay(checkpoint_delay);

log_file_max = (unsigned)

, 200 * 1024 * 1024);

drv->SetLogFileMax(log_file_max);

transaction_log_path =

(transaction_log_path != path) {

drv->SetLogDir(transaction_log_path);

drv->SetWriteSync(w_sync ?

ttl_prolong =

drv->SetTTL_Prolongation(ttl_prolong);

max_blob_size =(unsigned)

drv->SetMaxBlobSize(max_blob_size);

rr_volumes =

drv->SetRR_Volumes(rr_volumes);

memp_trickle =

drv->SetMempTrickle(memp_trickle);

ConfigureICache(drv.get(), params);

batch_size =

drv->SetPurgeBatchSize(batch_size);

batch_sleep =

drv->SetBatchSleep(batch_sleep);

purge_clean_factor =

drv->CleanLogOnPurge(purge_clean_factor);

purge_thread_delay =

tas_spins =

drv->OpenReadOnly(path.c_str(), name.c_str(), (

)mem_size);

drv->Open(path, name,

(

)log_mem_size);

(!drv->IsJoinedEnv()) {

->SetDirectDB(direct_db);

->SetDirectLog(direct_log);

->SetTasSpins(tas_spins);

->SetMpMaxWrite(0, 0);

drv->RunPurgeThread(purge_thread_delay);

drv->StartPurgeThread();

drv.release();

: m_BlobCache(blob_cache),

& path,

& name,

timeout = 24 * 60 * 60;

bdb_cache.

(path.c_str(),

static const char * kCFParam_log_mem_size

static const char * kCFParam_lock_default

static const char * kCFParam_write_sync

static void s_GetDayHour(time_t time_in_secs, unsigned *day, unsigned *hour)

Compute current hour of day.

static const char * kCFParam_direct_db

static const char * kCFParam_transaction_log_path

const char * kBDBCacheStartedFileName

static const char * kCFParam_path

static const char * kCFParam_max_blob_size

static void s_MakeOverflowFileName(string &buf, const string &path, const string &cache, const string &key, int version, const string &subkey)

static const char * kCFParam_ttl_prolong

static const char * kCFParam_mem_size

static const char * kCFParam_lock_pid_lock

static const char * kCFParam_drop_if_dirty

static const char * kCFParam_purge_thread

static const char * kCFParam_direct_log

static const char * kCFParam_purge_thread_delay

static const char * kCFParam_checkpoint_bytes

static const char * kCFParam_purge_clean_log

static const char * kCFParam_lock

static const char * kCFParam_TAS_spins

static const char * kCFParam_purge_batch_size

static const char * kCFParam_read_only

static const char * kCFParam_memp_trickle

static const char * kCFParam_checkpoint_delay

static const char * kCFParam_overflow_limit

static const char * kCFParam_rr_volumes

static const char * kCFParam_name

static const char * kCFParam_log_file_max

static const char * kCFParam_use_transactions

static const char * kCFParam_purge_batch_sleep

ICache interface implementation on top of Berkeley DB.

Berkeley BDB file cursor.

Wrapper around Berkeley DB transaction structure.

ncbi::TMaskedQueryRegions mask

BLOB demultiplexer implements round-robin volume rotation.

CBDB_RawFile::TBuffer * m_RawBuffer

CBDB_Cache::TBlobLock m_BlobLock

virtual ERW_Result PendingCount(size_t *count)

Via parameter "count" (which is guaranteed to be supplied non-NULL) return the number of bytes that a...

unsigned char * m_BufferPtr

virtual ~CBDB_CacheIReader()

CNcbiIfstream * m_OverflowFile

CBDB_CacheIReader & operator=(const CBDB_CacheIReader &)

CBDB_CacheIReader(CBDB_Cache &bdb_cache, CNcbiIfstream *overflow_file, CBDB_Cache::TBlobLock &blob_lock)

CBDB_CacheIReader(CBDB_Cache &bdb_cache, CBDB_RawFile::TBuffer *raw_buffer, CBDB_Cache::TBlobLock &blob_lock)

virtual ERW_Result Read(void *buf, size_t count, size_t *bytes_read)

Read as many as "count" bytes into a buffer pointed to by the "buf" argument.

CBDB_CacheIReader(const CBDB_CacheIReader &)

bool m_Flushed

FALSE until Flush() called.

virtual ~CBDB_CacheIWriter()

CBDB_CacheIWriter(CBDB_Cache &bdb_cache, const char *path, unsigned blob_id_ext, const string &blob_key, int version, const string &subkey, SCache_AttrDB &attr_db, unsigned int ttl, time_t request_time, const string &owner, CBDB_Cache::TBlobLock &blob_lock)

CSimpleBufferT< unsigned char, CCacheBufferResizeStrategy > TBuffer

CNcbiOfstream * m_OverflowFile

virtual ERW_Result Flush(void)

Flush pending data (if any) down to output device.

CBDB_Cache::TBlobLock m_BlobLock

unsigned m_BlobSize

Number of bytes written.

void x_WriteOverflow(const char *buf, streamsize count)

CBDB_CacheIWriter(const CBDB_CacheIWriter &)

CBDB_Cache::EWriteSyncMode m_WSync

virtual ERW_Result Write(const void *buf, size_t count, size_t *bytes_written=0)

Write up to "count" bytes from the buffer pointed to by the "buf" argument onto the output device.

unsigned m_Overflow

Overflow file created.

string m_OverflowFilePath

CBDB_CacheIWriter & operator=(const CBDB_CacheIWriter &)

Class factory for BDB implementation of ICache.

virtual ICache * x_CreateInstance(const string &driver=kEmptyStr, CVersionInfo version=NCBI_INTERFACE_VERSION(ICache), const TPluginManagerParamTree *params=0) const

CICacheCF< CBDB_Cache > TParent

CBDB_Cache_OnAppExit(CBDB_Cache &bdb_cache)

static void AddOnExitCallback(CBDB_Cache &bdb_cache)

shared_ptr< bool > m_StopThreadFlag

void operator()(void) const

BDB cache implementation.

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

BDB errno exception class.

Base BDB exception class.

Berkeley DB file cursor class.

Buffer resize strategy, to balance memory reallocs and heap consumption.

static size_t GetNewCapacity(size_t, size_t requested_size)

Thread class, peridically calls ICache::Purge to remove obsolete elements.

Utility class for ICache class factories.

CPIDGuard – Process guard.

Reallocable memory buffer (no memory copy overhead) Mimics vector<>, without the overhead of explicit...

const value_type * data() const

void resize(size_type new_size)

void reserve(size_type new_size)

void RequestStop()

Schedule thread Stop.

void AddObject(time_t tm, unsigned object_id)

Add object to the timeline.

bool RemoveObject(time_t object_time, unsigned object_id)

Remove object from the time line, object_time defines time slot.

void EnumerateObjects(TBitVector *objects) const

Enumerate all objects registered in the timeline.

void ExtractObjects(time_t tm, TBitVector *objects)

Extracts all objects up to 'tm' and puts them into 'objects' vector.

unsigned GetDiscrFactor() const

Time discretization factor.

definition of a Culling tree

BLOB cache read/write/maintenance interface.

EKeepVersions

If to keep already cached versions of the BLOB when storing another version of it (not necessarily a ...

@ eDropOlder

Delete the earlier (than the one being stored) versions of the BLOB.

@ eDropAll

Delete all versions of the BLOB, even those which are newer than the one being stored.

@ eKeepAll

Do not delete other versions of cache entries.

int TFlags

Bitwise OR of "EFlags" flags.

EBlobVersionValidity

BLOB version existence and validity – from the point of view of the underlying cache implementation.

@ fTimeStampOnCreate

Cache element is created with a certain timestamp (default)

@ fTimeStampOnRead

Timestamp is updated every on every access (read or write)

@ fExpireLeastFrequentlyUsed

Expire objects older than a certain time frame Example: If object is not accessed within a week it is...

@ fPurgeOnStartup

Expired objects should be deleted on cache mount (Open)

@ fCheckExpirationAlways

Expiration timeout is checked on any access to cache element.

int TTimeStampFlags

Holds a bitwise OR of "ETimeStampFlags".

A very basic data-read interface.

A very basic data-write interface.

Constant iterator designed to enumerate "ON" bits.

bool valid() const noexcept

Checks if iterator is still valid.

Bitvector Bit-vector container with runtime compression of bits.

bool any() const noexcept

Returns true if any bits in this bitset are set, and otherwise returns false.

bvector< Alloc > & set(size_type n, bool val=true)

Sets bit n if val is true, clears bit n if val is false.

void optimize(bm::word_t *temp_block=0, optmode opt_mode=opt_compress, statistics *stat=0)

Optimize memory bitvector's memory allocation.

enumerator first() const

Returns enumerator pointing on the first non-zero bit.

void clear(const size_type *ids, size_type ids_size, bm::sort_order so=bm::BM_UNKNOWN)

clear list of bits in this bitset

size_type count() const noexcept

population count (count of ON bits)

container_type::const_iterator const_iterator

container_type::iterator iterator

const_iterator begin() const

const_iterator end() const

const_iterator upper_bound(const key_type &key) const

iterator_bool insert(const value_type &val)

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.

#define ITERATE(Type, Var, Cont)

ITERATE macro to sequence through container elements.

TOwnerStatMap m_OwnerStatMap

time_t ComputeMaxTime(time_t start) const

Compute maximum TTL.

void DropBlob(const string &key, int version, const string &subkey, bool for_update, unsigned *blob_id, unsigned *coord)

Delete BLOB.

void RunPurgeThread(unsigned purge_delay=30)

Schedule a background Purge thread (cleans the cache from the obsolete entries) SetPurgeBatchSize and...

EErrGetPut

Put/Get errors.

CBDB_FieldUint4 ttl

time-to-live

void SetOverflowLimit(unsigned limit)

CFastMutex m_DB_Lock

Database lock.

unsigned m_CheckPointDelay

Trnasaction checkpoint interval (minutes)

CBDB_BlobSplitStore< TBitVector, CBDB_BlobDeMux_RoundRobin, CFastMutex > TSplitStore

Split store for BLOBs.

unsigned m_PurgeCount

Number of times we run purge.

CBDB_FieldUint4 volume_id

demux coord[0]

bool m_RunPurgeThread

Run a background purge thread.

unsigned m_CleanLogOnPurge

Number of bytes stored in cache since last checkpoint Clean log on Purge (factor)

virtual bool SameCacheParams(const TCacheParams *params) const

SCache_AttrDB * m_CacheAttrDB_RO1

Cache attributes r-only1.

CTimeLine< TBitVector > TTimeLine

void AddInternalError(const string &client, SBDB_CacheUnitStatistics::EErrGetPut operation)

CBDB_FieldUint4 blob_id

BLOB counter.

TTimeStampFlags m_TimeStampFlag

Time stamp flag.

void AddNoBlobError(EErrGetPut operation)

virtual void SetBlobVersionAsCurrent(const string &key, const string &subkey, int version)

Set current valid version for a BLOB.

bool m_JoinedEnv

Joined environment.

SCache_AttrDB * m_CacheAttrDB

Cache attributes database.

void AddExplDelete(const string &client)

unsigned GetBatchSleep() const

void AddStore(time_t tm, unsigned store, unsigned update, unsigned blob_size, unsigned overflow)

void x_Store(unsigned blob_id, const string &key, int version, const string &subkey, const void *data, size_t size, unsigned int time_to_live, const string &owner, bool do_blob_lock)

void AddProtocolError(const string &client, SBDB_CacheUnitStatistics::EErrGetPut operation)

time_t m_LastTimeLineCheck

CPIDGuard * m_PidGuard

Cache lock.

CBDB_FieldString owner_name

owner's name

SBDB_CacheUnitStatistics & GlobalStatistics()

unsigned GetNextBlobId(bool lock_id)

Get next BLOB id out from the atomic couter.

unsigned err_communication

Communication error.

void x_AddErrGetPut(EErrGetPut operation)

CFastLocalTime m_LocalTimer

Fast local timer.

EWriteSyncMode GetWriteSync() const

double blobs_size_db

Current size of all BLOBs.

ETRansact

Underlying BDB database can be configured using transactional or non-transactional API.

unsigned m_MempTrickle

memp_trickle parameter (percent)

IServer_Monitor * m_Monitor

Pointer to monitoring interface.

CFastMutex m_CARO1_Lock

Database lock.

void NCBI_BDB_ICacheEntryPoint(CPluginManager< ICache >::TDriverInfoList &info_list, CPluginManager< ICache >::EEntryPointRequest method)

void RegisterOverflow(const string &key, int version, const string &subkey, unsigned time_to_live, const string &owner)

Register BLOB object as overflow file.

void AddToTimeLine(unsigned blob_id, time_t exp_time)

Add BLOB to expiration timeline.

TBitVector m_GC_Deleted

BLOB ids deleted by GC.

void InitHistorgam(TBlobSizeHistogram *hist)

bool m_ReadOnly

read-only flag

EBlobCheckinMode

BLOB check-in mode.

friend class CBDB_CacheIReader

unsigned blobs_read_total

Number of reads.

unsigned m_PurgeBatchSize

Number of records to process in Purge() (with locking)

bool GetSizeEx(const string &key, int version, const string &subkey, size_t *size)

void RegisterProtocolError(SBDB_CacheUnitStatistics::EErrGetPut operation, const string &owner)

virtual void GetBlobOwner(const string &key, int version, const string &subkey, string *owner)

Retrieve BLOB owner.

void StopPurge()

Request to stop Purge.

unsigned m_MaxTTL_prolong

Number of m_MaxTimeout values object lives (read-prolongation)

void Store(unsigned blob_id_ext, const string &key, int version, const string &subkey, const void *data, size_t size, unsigned int time_to_live=0, const string &owner=kEmptyStr)

void AddNeverRead(const string &client)

CFastMutex m_CARO2_Lock

Database lock.

void NCBI_EntryPoint_xcache_bdb(CPluginManager< ICache >::TDriverInfoList &info_list, CPluginManager< ICache >::EEntryPointRequest method)

void x_UpdateOwnerStatOnDelete(const string &owner, bool expl_delete)

update BLOB owners' statistics on BLOB delete

void RegisterNoBlobError(SBDB_CacheUnitStatistics::EErrGetPut operation, const string &owner)

void RegisterCommError(SBDB_CacheUnitStatistics::EErrGetPut operation, const string &owner)

TLockVector m_LockVector

BLOB lock vector.

void AddInternalError(EErrGetPut operation)

virtual IReader * GetReadStream(const string &key, int version, const string &subkey)

Return sequential stream interface to read BLOB data.

void AddStore(const string &client, time_t tm, unsigned store, unsigned update, unsigned blob_size, unsigned overflow)

time_t m_NextExpTime

Time of the next blob expiration.

unsigned err_blob_get

retrive errors

EWriteSyncMode

Suggest page size.

bool m_Closed

Double-close safeguard flag.

virtual bool Read(const string &key, int version, const string &subkey, void *buf, size_t buf_size)

Fetch the BLOB.

EBlobCheckinRes BlobCheckIn(unsigned blob_id_ext, const string &key, int version, const string &subkey, EBlobCheckinMode mode, TBlobLock &blob_lock, bool do_id_lock, unsigned *volume_id, unsigned *split_id, unsigned *overflow)

Check if BLOB exists, create registration record if necessary.

void SetTTL_Prolongation(unsigned ttl_prolong)

Maximum limit for read updates (blob expires eventually even if it is accessed) 0 - unlimited prolong...

virtual void Remove(const string &key)

unsigned err_blob_put

store errors

unsigned m_LockTimeout

Lock timeout (ms)

CSemaphore m_PurgeStopSignal

TRUE when Purge processing requested to stop.

unsigned m_MaxTimeout

Maximum time to live.

void Init()

Drop all collected statistics.

unsigned m_OverflowLimit

Overflow limit (objects lower than that stored as BLOBs)

void EvaluateTimeLine(bool *interrupted)

Evaluate timeline BLOBs as deletion candidates.

const SBDB_CacheStatistics & GetStatistics() const

Get cache operations statistics.

void x_PidLock(ELockMode lm)

CBDB_FieldUint4 upd_count

update counter

void RegisterInternalError(SBDB_CacheUnitStatistics::EErrGetPut operation, const string &owner)

virtual void SetVersionRetention(EKeepVersions policy)

Set version retention policy.

virtual bool HasBlobs(const string &key, const string &subkey)

Check if any BLOB exists (any version)

bool DropBlobWithExpCheck(const string &key, int version, const string &subkey, CBDB_Transaction &trans)

Drop BLOB with time expiration check.

bool m_InitIfDirty

Delete DB if it wasn't closed clean.

virtual size_t GetSize(const string &key, int version, const string &subkey)

Check if BLOB exists, return BLOB size.

void PrintStatistics(CNcbiOstream &out) const

SCache_IdIDX * m_CacheIdIDX_RO

Cache id index r-only.

unsigned err_protocol

Protocol errors.

void KillBlob(const string &key, int version, const string &subkey, int overflow, unsigned blob_id)

const char * kBDBCacheDriverName

string m_LogDir

Transaction log location.

bool m_PurgeNowRunning

Flag that Purge is already running.

void WriteOverflow(CNcbiOfstream &overflow_file, const string &overflow_file_path, const char *buf, streamsize count)

Write to the overflow file with error checking If write failes, method deletes the file to avoid file...

shared_ptr< bool > m_StopThreadFlag

EBlobCheckinRes

Result of BLOB check-in process.

CBDB_Env * m_Env

Common environment for cache DBs.

unsigned m_LogSizeMax

transaction log size

virtual time_t GetAccessTime(const string &key, int version, const string &subkey)

Return last access time for the specified cache entry.

CBDB_FieldUint4 max_time

max ttl limit for BLOB

IWriter * GetWriteStream(unsigned blob_id_ext, const string &key, int version, const string &subkey, bool do_id_lock, unsigned int time_to_live=0, const string &owner=kEmptyStr)

IReader * x_CreateOverflowReader(const string &key, int version, const string &subkey, size_t &file_length, TBlobLock &blob_lock)

void StartPurgeThread()

Start background thread.

unsigned GetMaxBlobSize() const

Get max allowed BLOB size.

void x_DropOverflow(const string &key, int version, const string &subkey)

time_t x_ComputeExpTime(int time_stamp, unsigned ttl, int timeout)

bool x_RetrieveBlobAttributes(const string &key, int version, const string &subkey, int &overflow, unsigned int &ttl, unsigned int &blob_id, unsigned int &volume_id, unsigned int &split_id)

1.

unsigned GetBlobId(const string &key, int version, const string &subkey)

Determines BLOB size (requires fetched attribute record)

virtual void SetFlags(TFlags flags)

Pass flags to the underlying storage.

bool IsSaveStatistics(void) const

SBDB_CacheUnitStatistics m_GlobalStat

TBlobSizeHistogram blob_size_hist

Blob size historgam.

void AddCommError(EErrGetPut operation)

ELockMode

Locking modes to protect cache instance.

void x_DropBlob(const string &key, int version, const string &subkey, int overflow, unsigned blob_id, CBDB_Transaction &trans)

friend class CBDB_CacheIWriter

TTimeLine * m_TimeLine

BLOB expiration timeline.

unsigned blobs_db

Current database number of records.

void AddBlobQuotaError(const string &client)

void OpenReadOnly(const string &cache_path, const string &cache_name, unsigned int cache_ram_size=0)

Open local cache in read-only mode.

bool IsLocked(unsigned blob_id)

Check if BLOB is locked.

unsigned err_no_blob

BLOB not found errors.

CFastMutex m_IDIDX_Lock_RO

Database lock.

unsigned m_CheckPointInterval

Trnasaction checkpoint interval (bytes)

bool IsReadOnly() const

Return TRUE if cache is read-only.

const string & GetName() const

unsigned blobs_stored_total

Total number of blobs.

virtual void Purge(time_t access_timeout)

Delete all BLOBs older than specified.

unsigned blobs_expl_deleted_total

BLOBs explicitly removed.

SBDB_CacheUnitStatistics()

void AddCommError(const string &client, SBDB_CacheUnitStatistics::EErrGetPut operation)

void x_PerformCheckPointNoLock(unsigned bytes_written)

SCache_AttrDB * m_CacheAttrDB_RO2

Cache attributes r-only2.

void AddNoBlobError(const string &client, SBDB_CacheUnitStatistics::EErrGetPut operation)

virtual void SetTimeStampPolicy(TTimeStampFlags policy, unsigned int timeout, unsigned int max_timeout=0)

Set timestamp update policy.

void ConvertToRegistry(IRWRegistry *reg, const string &sect_name_postfix) const

Convert statistics into registry sections and entries.

unsigned m_Timeout

Timeout expiration policy.

CBDB_FieldUint4 read_count

read counter

unsigned err_blob_over_quota

BLOB max quota.

unsigned blobs_overflow_total

number of overflow blobs

TTimeAccess time_access

Hourly access history.

void Open(const string &cache_path, const string &cache_name, ELockMode lm=eNoLock, Uint8 cache_ram_size=0, ETRansact use_trans=eUseTrans, unsigned int log_mem_size=0)

Open local cache instance (read-write access) If cache does not exists it is created.

unsigned blob_size_max_total

Largest BLOB ever.

CacheKey(const string &x_key, int x_version, const string &x_subkey)

void x_UpdateAccessTime(const string &key, int version, const string &subkey, EBlobAccessType access_type, CBDB_Transaction &trans)

Transactional update of access time attributes.

void SetPurgeBatchSize(unsigned batch_size)

Number of records in scanned at once by Purge Cache is exclusively locks an internal mutex while scan...

TSplitStore * m_BLOB_SplitStore

Cache BLOB storage.

void PrintStatistics(CNcbiOstream &out) const

virtual TFlags GetFlags()

Retrieve the effective combination of flags from the underlying storage.

unsigned m_BatchSleep

Sleep interval (milliseconds) between batches.

virtual TTimeStampFlags GetTimeStampPolicy() const

Get timestamp policy.

bool x_CheckTimeStampExpired(SCache_AttrDB &attr_db, time_t curr, time_t *exp_time=0)

CBDB_FieldInt4 overflow

overflow flag

EKeepVersions m_VersionFlag

Version retention policy.

SBDB_CacheStatistics m_Statistics

Stat counters.

EBlobAccessType

access type for "UpdateAccessTime" methods

bool operator<(const CacheKey &cache_key) const

void BDB_ConfigureCache(CBDB_Cache &bdb_cache, const string &path, const string &name, unsigned timeout, ICache::TTimeStampFlags tflags)

Utility for simple cache configuration.

void StopPurgeThread()

Stop background thread.

unsigned err_internal

Internal errors of all sorts.

void AddProtocolError(EErrGetPut operation)

unsigned GetPurgeBatchSize() const

SCache_IdIDX * m_CacheIdIDX

Cache id index.

void SetBatchSleep(unsigned sleep)

Set sleep in milliseconds between Purge batches (for low priority Purge processes)

void AddRead(const string &client, time_t tm)

CRef< CCacheCleanerThread > m_PurgeThread

Purge thread.

void ConvertToRegistry(IRWRegistry *reg) const

unsigned blobs_updates_total

How many updates registered.

unsigned blobs_purge_deleted_total

BLOBs garbage collected.

unsigned GetOverflowLimit() const

double blobs_size_total

Size of BLOBs total.

void BDB_Register_Cache(void)

Register NCBI_BDB_ICacheEntryPoint.

unsigned m_RoundRobinVolumes

Number of rotated volumes.

void Verify(const string &cache_path, const string &cache_name, const string &err_file=0, bool force_remove=false)

Run verification of the cache database.

CAtomicCounter m_BlobIdCounter

Atomic counter for BLOB ids.

virtual bool IsOpen() const

string m_Path

Path to storage.

CBDB_FieldUint4 split_id

demux coord[1]

bool x_FetchBlobAttributes(const string &key, int version, const string &subkey)

void CleanLog()

Remove all non-active LOG files.

virtual EKeepVersions GetVersionRetention() const

Get version retention.

void Unlock()

Unlock cache access.

void AddPurgeDelete(const string &client)

virtual void GetBlobAccess(const string &key, int version, const string &subkey, SBlobAccessDescr *blob_descr)

Get BLOB access using BlobAccessDescr.

virtual int GetTimeout() const

Get expiration timeout.

CBDB_FieldUint4 time_stamp

access timestamp

void InitStatistics()

Drop the previously collected statistics.

void Lock()

Lock cache access.

string m_Name

Cache name.

CFastMutex m_TimeLine_Lock

static void AddToHistogram(TBlobSizeHistogram *hist, unsigned size)

unsigned m_PurgeThreadDelay

Delay in seconds between Purge runs.

deque< SBDB_TimeAccessStatistics > TTimeAccess

CBDB_CacheHolder(ICache *blob_cache, ICache *id_cache)

unsigned blobs_never_read_total

BLOBs never read before.

@ eErr_Unknown

no info on operation

@ eNoTrans

Non-transactional environment.

@ eUseTrans

Use transaction environment.

@ eBlobCheckIn_Create

If record does not exist - create.

@ eBlobCheckIn

Check if record exists.

@ eBlobCheckIn_Created

BLOB record created.

@ eBlobCheckIn_Found

Existing BLOB.

@ EBlobCheckIn_NotFound

BLOB does not exist.

@ eNoLock

Do not lock-protect cache instance.

@ ePidLock

Create PID lock on cache (exception if failed)

void OpenProjections()

Try to open all storage files in all projections This is only possible when object de-mux has fixed n...

EBDB_ErrCode Delete(unsigned id, CBDB_RawFile::EIgnoreError on_error=CBDB_RawFile::eThrowOnError)

Delete BLOB.

virtual void SetTransaction(ITransaction *trans)

Establish transaction association.

void FreeUnusedMem()

Reclaim unused memory.

EBDB_ErrCode ReadRealloc(unsigned id, CBDB_RawFile::TBuffer &buffer)

Read BLOB into vector.

EBDB_ErrCode UpdateInsert(unsigned id, const void *data, size_t size, unsigned *coord)

Update or insert BLOB.

void Save(typename TDeMuxStore::ECompact compact_vectors=TDeMuxStore::eCompact)

Save storage dictionary (demux disposition).

EBDB_ErrCode Fetch(unsigned id, void **buf, size_t buf_size, CBDB_RawFile::EReallocMode allow_realloc, size_t *blob_size)

Fetch LOB record directly into the provided '*buf'.

void SetEnv(CBDB_Env &env)

Associate with the environment. Should be called before opening.

EBDB_ErrCode BlobSize(unsigned id, size_t *blob_size)

Get size of the BLOB.

void GetIdVector(TBitVector *bv) const

Get all id of all BLOBs stored.

EBDB_ErrCode GetCoordinates(unsigned id, unsigned *coords)

Find (demux) coordinates by BLOB id.

void Open(const string &storage_name, CBDB_RawFile::EOpenMode open_mode, CBDB_RawFile::EDBType db_type=CBDB_RawFile::eBtree)

Open storage (reads storage dictionary into memory)

void AssignCoordinates(unsigned id, const unsigned *coords)

Assing de-mux coordinates.

unsigned int Truncate()

Empty the database. Return number of records removed.

EBDB_ErrCode Delete(EIgnoreError on_error=eThrowOnError)

Delete record corresponding to the current key value.

void SetCondition(ECondition cond_from, ECondition cond_to=eNotSet)

Set search condition(type of interval)

EBDB_ErrCode FetchFirst()

EBDB_ErrCode Update(CBDB_File::EAfterWrite write_flag=CBDB_File::eDiscardData)

void Verify(const char *filename, const char *database, FILE *backup)

Run database verification (DB->verify)

void Open(const string &filename, EOpenMode open_mode, bool support_dirty_read=false, unsigned rec_len=0)

Open file with specified access mode.

EBDB_ErrCode Insert(EAfterWrite write_flag=eDiscardData)

Insert new record.

unsigned CountRecs(bool bFast=false)

Compute database statistic, return number of records.

void SetEnv(CBDB_Env &env)

Associate file with environment.

virtual void SetTransaction(ITransaction *trans)

Establish transaction association.

void InitMultiFetch(size_t buffer_size, EMultiFetchMode mfm=eFetchAll)

Init multi-row fetch.

EBDB_ErrCode

BDB Return codes.

EBDB_ErrCode Fetch(EFetchDirection fdir=eDefault)

Fetch record.

CBDB_ConditionHandle From

EBDB_ErrCode Delete(CBDB_File::EIgnoreError on_error=CBDB_File::eThrowOnError)

EBDB_ErrCode Fetch()

Fetches the record corresponding to the current key value.

@ eReadWriteCreate

read-write, create if it doesn't exist

@ eReadModifyUpdate

Use DB_RMW (write locking) on fetch.

virtual string GetString() const

virtual void ToString(string &str) const

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.

virtual void Commit()

Commit transaction.

void CleanLog()

Remove all non-active log files.

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)

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 SetLogAutoRemove(bool on_off)

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

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...

void SetLogFileMax(unsigned int lg_max)

Set maximum size of LOG files.

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)

#define BDB_THROW(errcode, message)

unsigned int TEnvOpenFlags

OR-ed combination of EEnvOptions.

unsigned TBackgroundFlags

Background work flags (combination of EBackgroundWork)

void OpenWithLocks(const string &db_home)

Open environment with database locking (DB_INIT_LOCK)

void SetTransactionSync(CBDB_Transaction::ETransSync sync)

Set default syncronicity level.

bool Remove()

Non-force removal of BDB environment.

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...

void ForceRemove()

Force remove BDB environment.

void OpenErrFile(const string &file_name)

Open error reporting file for the environment.

void Open(const string &db_home, int flags)

Open environment.

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.

void ForceTransactionCheckpoint()

Forced checkpoint.

bool IsRecovery() const

If it is DB_RUNRECOVERY error.

void SetLogBSize(unsigned lg_bsize)

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

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

Join the existing environment.

@ eTransASync

Non-durable asyncronous transaction.

@ eEnvDefault

Use default from CBDB_Env.

@ eTransSync

Syncronous transaction.

@ eBackground_DeadLockDetect

@ eBackground_MempTrickle

@ eNoAssociation

No association tracking.

@ eRunRecovery

Run DB recovery first.

@ eThreaded

corresponds to DB_THREAD

@ eDeadLock_Default

Default deadlock detector.

void Set(TValue new_value) THROWS_NONE

Set atomic counter value.

TValue Add(int delta) THROWS_NONE

Atomically add value (=delta), and return new counter value.

#define LOG_POST_X(err_subcode, message)

#define ERR_POST_X(err_subcode, message)

Error posting with default error code and given error subcode.

#define ERR_POST(message)

Error posting with file, line number information but without error codes.

#define NCBI_USER_THROW(message)

Throw a quick-and-dirty runtime exception of type 'CException' with the given error message and error...

void Error(CExceptionArgs_Base &args)

void Warning(CExceptionArgs_Base &args)

virtual const char * what(void) const noexcept

Standard report (includes full backlog).

void Info(CExceptionArgs_Base &args)

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

Get directory entries based on the specified "mask".

static string CreateAbsolutePath(const string &path, ERelativeToWhat rtw=eRelativeToCwd)

Get an absolute path from some, possibly relative, path.

virtual bool Exists(void) const

Check the entry existence.

Int8 GetLength(void) const

Get size of file.

virtual bool Remove(TRemoveFlags flags=eRecursive) const

Remove a directory entry.

static string MakePath(const string &dir=kEmptyStr, const string &base=kEmptyStr, const string &ext=kEmptyStr)

Assemble a path from basic components.

static string AddTrailingPathSeparator(const string &path)

Add trailing path separator, if needed.

virtual bool Exists(void) const

Check if directory "dirname" exists.

virtual ERW_Result Write(const void *buf, size_t count, size_t *bytes_written=0)

Virtual methods from IWriter.

bool Create(TCreateFlags flags=fCreate_Default) const

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

virtual bool Remove(TRemoveFlags flags=eRecursive) const

Delete existing directory.

const string & GetPath(void) const

Get entry path.

virtual bool Exists(void) const

Check existence of file.

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.

static void NCBI_EntryPointImpl(TDriverInfoList &info_list, EEntryPointRequest method)

Entry point implementation.

#define NCBI_INTERFACE_VERSION(iface)

Macro to construct CVersionInfo class using interface name (relies on CInterfaceVersion class)

list< SDriverInfo > TDriverInfoList

List of driver information.

EEntryPointRequest

Actions performed by the entry point.

uint32_t Uint4

4-byte (32-bit) unsigned integer

uint64_t Uint8

8-byte (64-bit) unsigned integer

static TPid GetPid(void)

Get process identifier (pid) for the current process.

bool Set(const string &section, const string &name, const string &value, TFlags flags=0, const string &comment=kEmptyStr)

Set the configuration parameter value.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

ERW_Result

Result codes for I/O operations.

IO_PREFIX::ofstream CNcbiOfstream

Portable alias for ofstream.

IO_PREFIX::ostream CNcbiOstream

Portable alias for ostream.

IO_PREFIX::ifstream CNcbiIfstream

Portable alias for ifstream.

IO_PREFIX::streampos CNcbiStreampos

Portable alias for streampos.

@ eRW_Eof

End of data, should be considered permanent.

@ eRW_Error

Unrecoverable error, no retry possible.

@ eRW_Success

Everything is okay, I/O completed.

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

Convert size_t to string.

static string DoubleToString(double value, int precision=-1, TNumToStringFlags flags=0)

Convert double to string.

static int CompareNocase(const CTempString s1, SIZE_TYPE pos, SIZE_TYPE n, const char *s2)

Case-insensitive compare of a substring with another string.

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

Convert int to string.

static string & Replace(const string &src, const string &search, const string &replace, string &dst, SIZE_TYPE start_pos=0, SIZE_TYPE max_replace=0, SIZE_TYPE *num_replace=0)

Replace occurrences of a substring within a string.

static int Compare(const CTempString s1, SIZE_TYPE pos, SIZE_TYPE n, const char *s2, ECase use_case=eCase)

Compare of a substring with another string.

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

Convert UInt to string.

static string ULongToString(unsigned long value, TNumToStringFlags flags=0, int base=10)

Convert unsigned long to string.

static enable_if< is_arithmetic< TNumeric >::value||is_convertible< TNumeric, Int8 >::value, string >::type NumericToString(TNumeric value, TNumToStringFlags flags=0, int base=10)

Convert numeric value 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.

bool TryLock(unsigned id)

Try to acquire lock of specified id.

void TakeFrom(CLockVectorGuard &lg)

Transfer lock ownership from another lock.

void Lock(void)

Acquire mutex for the current thread with no nesting checks.

void FreeUnusedMem()

Reclaim unused memory.

void Lock(unsigned id)

Acquire lock.

unsigned GetId() const

Get BLOB id.

bool IsLocked(unsigned id) const

Check if id is locked or not.

void Unlock()

Unlocks the lock.

void SetId(unsigned id)

Assign Id (no locking)

bool TryWait(unsigned int timeout_sec=0, unsigned int timeout_nsec=0)

Timed wait.

void Post(unsigned int count=1)

Increment the semaphore by "count".

void Join(void **exit_data=0)

Wait for the thread termination.

void Unlock(void)

Release mutex with no owner or nesting checks.

double Elapsed(void) const

Return time elapsed since first Start() or last Restart() call (in seconds).

string AsString(const CTimeFormat &format=kEmptyStr, TSeconds out_tz=eCurrentTimeZone) const

Transform time to string.

int GetLocalTimezone(void)

Get difference in seconds between UTC and current local time (daylight information included)

CTime GetFastLocalTime(void)

Quick and dirty getter of local time.

@ eStart

Start timer immediately after creating.

const TTreeType * FindNode(const TKeyType &key, TNodeSearchMode sflag=eImmediateAndTop) const

Search for node.

const TValue & GetValue(void) const

Return node's value.

@ eNonCompatible

major, minor does not match

operation

Bit operations.

unsigned int

A callback function used to compare two keys in a database.

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

if(yy_accept[yy_current_state])

const string version

version string

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

const struct ncbi::grid::netcache::search::fields::KEY key

const struct ncbi::grid::netcache::search::fields::SUBKEY subkey

Defines process management classes.

Defines NCBI C++ exception handling.

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

Multi-threading – mutexes; rw-locks; semaphore.

Defines: CTimeFormat - storage class for time format.

std::istream & in(std::istream &in_, double &x_)

Int4 delta(size_t dimension_, const Int4 *score_)

Helper classes and templates to implement plugins.

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

static CNamedPipeClient * client

Cache accession for internal in-memory storage.

unique_ptr< IReader > reader

BDB cache statistics (covers one elemntary unit of measurements)

BDB cache access statistics.

SCacheDescr(string x_key, int x_version, string x_subkey, int x_overflow, unsigned x_blob_id)

BLOB ID -> key, value, subkey index.

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