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

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

NCBI C++ ToolKit: src/app/netcache/memory_man.cpp Source File

s_fdMemManStamp = 0xFEEDFEEDFEEDFEED;

s_MaxAllPools = 200;

s_VerifyUnavailable(

* ptr,

size_idx)

(

p = 0; p < s_MaxAllPools; ++p) {

(

* next_block = page->

; next_block; next_block = *(

**)next_block) {

(next_block == ptr) {

s_MaxAllPtr = 20000;

s_GivePtr(

* ptr,

size_idx)

** p = s_AllPtr + (size_idx * s_MaxAllPtr);

(

= 0;

< s_MaxAllPtr; ++

, ++p) {

(*p ==

) {

s_TakePtr(

* ptr,

size_idx)

** p = s_AllPtr + (size_idx * s_MaxAllPtr);

(

= 0;

< s_MaxAllPtr; ++

, ++p) {

{ 8, 16, 24, 32, 40, 48, 56, 64, 72, 80, 96, 112, 128, 152, 176, 208, 248,

296, 352, 416, 496, 592, 704, 840, 1008, 1208, 1448, 1736, 2080, 2496,

sz_ind = 0, sz = 0, lookup_ind = 0;

* ptr = mmap(

,

, PROT_READ | PROT_WRITE,

MAP_PRIVATE | MAP_ANONYMOUS, -1, 0);

(ptr == MAP_FAILED) {

reentry =

;

(

<<

<<

<< errno

(munmap(ptr,

) != 0) {

(SoftFatal,

<<

<< errno

(munmap(ptr,

) == 0);

aligned_ptr = ptr, new_size =

;

(aligned_ptr == ptr) {

((ptr + new_size > aligned_ptr) && (ptr + new_size - aligned_ptr >=

)) {

(

((

*)ptr, aligned_ptr - ptr)) {

new_size -= (aligned_ptr - ptr);

page->real_ptr = (

*)ptr;

(

*)page;

page->real_ptr = page;

(

*)page;

(aligned_ptr == ptr) {

((

*)ptr, aligned_ptr - ptr);

(

*)aligned_ptr;

list_head->

== list_head;

(page->

&& memcmp(page->

, &s_fdMemManStamp,

(s_fdMemManStamp)) == 0) {

*(

**)block =

;

*(

**)block =

;

*

= next_block;

next_block = *(

**)next_block;

(; to_fill != 0; --to_fill) {

next_block = *(

**)next_block;

(page->

&& memcmp(page->

, &s_fdMemManStamp,

(s_fdMemManStamp)) == 0) {

memcpy(pool->

[

], &s_fdMemManStamp,

(s_fdMemManStamp));

(page->

&& memcmp(page->

, &s_fdMemManStamp,

(s_fdMemManStamp)) == 0) {

memcpy(

, &s_fdMemManStamp,

(s_fdMemManStamp));

(page->

&& memcmp(page->

, &s_fdMemManStamp,

(s_fdMemManStamp)) == 0) {

(page->

&& memcmp(page->

, &s_fdMemManStamp,

(s_fdMemManStamp)) == 0) {

(page->

&& memcmp(page->

, &s_fdMemManStamp,

(s_fdMemManStamp)) == 0) {

memcpy(pool->

, &glob_pool.

[1], cnt_copy *

(

*));

memcpy(pool->

[

], &s_fdMemManStamp,

(s_fdMemManStamp));

glob_pool.

*

(

*));

to_copy *

(

*));

* ptr =

;

memcpy(&page[1], &s_fdMemManStamp,

(s_fdMemManStamp));

(page->

&& memcmp(page->

, &s_fdMemManStamp,

(s_fdMemManStamp)) == 0) {

lock_AllPools.

();

* ptr =

;

s_GivePtr(ptr,size_idx);

(

[size_idx].lists[0].list_head.block_size != 0 &&

(memcmp(ptr, &s_fdMemManStamp,

(s_fdMemManStamp)) != 0) {

memset(ptr, 0,

(s_fdMemManStamp));

lock_AllPools.

();

s_TakePtr(ptr,size_idx);

(memcmp(ptr, &s_fdMemManStamp,

(s_fdMemManStamp)) == 0) {

memcpy(ptr, &s_fdMemManStamp,

(s_fdMemManStamp));

s_VerifyUnavailable(ptr, size_idx);

(memcmp(ptr, &s_fdMemManStamp,

(s_fdMemManStamp)) == 0) {

memcpy(ptr, &s_fdMemManStamp,

(s_fdMemManStamp));

(page->

&& memcmp(page->

, &s_fdMemManStamp,

(s_fdMemManStamp)) == 0) {

lock_AllPools.

();

(

->thread_num == 0) {

->mm_pool = pool_set;

(

->thread_num < s_MaxAllPools) {

s_AllMemPoolsSet[

->thread_num] =

->mm_pool;

->stat->SetMMStat(&

->mm_pool->stat);

m_TaskName =

;

(cnt_blocks == 0) {

memcpy(

, pool.

, cnt_blocks *

(

*));

total_data = 0;

total_data +=

;

total_data = 0;

total_data +=

;

total_data = 0;

total_data = 0;

total_data +=

;

(was_blocks == is_blocks) {

(is_blocks > was_blocks) {

diff = is_blocks - was_blocks;

diff = was_blocks - is_blocks;

(start_blocks[

] == 0 && end_blocks[

] == 0)

proxy << low_size <<

<<

<<

;

(start_blocks[

] == end_blocks[

]) {

proxy <<

proxy <<

<< endl;

proxy <<

;

proxy <<

proxy << endl <<

<< endl;

proxy << endl <<

<< endl;

proxy << low_size <<

<<

<<

;

low_size =

+ 1;

proxy <<

;

<<

proxy <<

is(

), iss(

), eol(

), qt(

);

#

defined(NCBI_COMPILER_GCC) || defined(NCBI_COMPILER_ANY_CLANG)

(

* ptr)

()

#

defined(NCBI_COMPILER_GCC) || defined(NCBI_COMPILER_ANY_CLANG)

[] (

* ptr)

()

s_MallocHook(

,

* caller)

s_ReallocHook(

* mem_ptr,

,

* caller)

s_FreeHook(

* mem_ptr,

* caller)

s_InitMallocHook(

)

__malloc_hook = &s_MallocHook;

__realloc_hook = &s_ReallocHook;

__free_hook = &s_FreeHook;

void (*__MALLOC_HOOK_VOLATILE __malloc_initialize_hook) (void) = &s_InitMallocHook;

* realloc(

* mem_ptr,

)

(

* mem_ptr)

malloc_usable_size(

* mem_ptr)

virtual ~CMMFlusher(void)

virtual void ExecuteSlice(TSrvThreadNum thr_num)

This is the main method to do all work this task should do.

Mutex created to have minimum possible size (its size is 4 bytes) and to sleep using kernel capabilit...

void Unlock(void)

Unlock the mutex.

void Lock(void)

Lock the mutex.

Class used in all diagnostic logging.

CSrvDiagMsg & PrintExtra(void)

Starts "extra" message.

CSrvDiagMsg & PrintParam(CTempString name, CTempString value)

Adds parameter to "request-start" or "extra" message.

void Flush(void)

Finishes current message and prepare to start new one.

Stream-like class to help unify printing some text messages to diagnostics and to any socket.

Task controlling a socket.

CSrvSocketTask & WriteText(CTempString message)

Write text into socket.

CSrvSocketTask & WriteNumber(NumType num)

Write number into socket as string, i.e.

T GetAverage(void) const

Get average of all values in the set.

void Initialize(void)

Initialize all data members.

void AddValue(T value)

Add next value into the set.

void AddValues(const CSrvStatTerm< T > &other)

Add all values from another set.

T GetMaximum(void) const

Get maximum value in the set.

Main working entity in TaskServer.

void RunAfter(Uint4 delay_sec)

This call is basically equivalent to SetRunnable() but with guarantee that task will be scheduled for...

static bool IsInShutdown(void)

Checks if TaskServer received request to shutdown.

static DLIST_TYPE *DLIST_NAME() next(DLIST_LIST_TYPE *list, DLIST_TYPE *item)

uint8_t Uint1

1-byte (8-bit) unsigned integer

uint32_t Uint4

4-byte (32-bit) unsigned integer

uint16_t Uint2

2-byte (16-bit) unsigned integer

int64_t Int8

8-byte (64-bit) signed 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.

static string UInt8ToString_DataSize(Uint8 value, TNumToStringFlags flags=0, unsigned int max_digits=3)

Convert UInt8 to string using "software" qualifiers.

where boath are integers</td > n< td ></td > n</tr > n< tr > n< td > tse</td > n< td > optional</td > n< td > String</td > n< td class=\"description\"> TSE option controls what blob is smart and slim</td> n<td> orig</td> n</tr> n<tr> n<td> last_modified</td> n<td> optional</td> n<td> Integer</td> n<td class=\"description\"> The blob last modification If provided then the exact match will be requested with n the Cassandra storage corresponding field value</td> n<td> Positive integer Not provided means that the most recent match will be selected</td> n<td></td> n</tr> n<tr> n<td> use_cache</td> n<td> optional</td> n<td> String</td> n<td class=\"description\"> The option controls if the Cassandra LMDB cache and or database should be used It n affects the seq id resolution step and the blob properties lookup step The following n options are available

if(yy_accept[yy_current_state])

static SMMFreePageGrades s_FreePages[kMMCntBlockSizes]

static Uint2 kMMSizeIndexes[kMMMaxBlockSize/8+1]

static void s_InitPoolsSet(SMMMemPoolsSet *pool_set)

static const size_t kMMAllocPageMask

static bool s_TryUnmap(void *ptr, size_t size)

static void s_PutToPool(SMMBlocksPool *pool, void *ptr, SMMStat *stat)

void AssignThreadMemMgr(SSrvThread *thr)

static CMMFlusher * s_Flusher

static void * s_GetFromGlobal(Uint2 size_idx, SMMStat *stat)

static SMMMemPoolsSet * s_GetCurPoolsSet(void)

static void s_DeallocMemory(void *ptr)

static const Uint1 kMMCntFreeGrades

static bool s_IsInFreeList(SMMPageHeader *page)

static void s_IncPoolIdx(Uint2 &idx)

static void s_SysFree(void *ptr, size_t size)

static const size_t kMMOSPageMask

static bool s_RemoveFromFreeList(SMMPageHeader *page, Uint2 size_idx)

static const Uint2 kMMCntBlocksInPool

static bool s_HadMemMgrInit

static void s_PrintBlocksState(CSrvPrintProxy &proxy, Int8 *start_blocks, Int8 *end_blocks)

static SMMPageHeader * s_AllocNewPage(Uint2 size_idx, SMMStat *)

static void * s_FillPool(SMMBlocksPool *pool, SMMStat *stat)

static void s_FreeListAddTail(SMMPageHeader *list_head, SMMPageHeader *page)

static void * s_FillFromFreePages(SMMBlocksPool *pool, Uint2 size_idx, SMMStat *stat)

static const Uint4 kMMPageDataSize

static void s_DoUnmap(void *ptr, size_t size)

static void s_FreeListAddHead(SMMPageHeader *list_head, SMMPageHeader *page)

static void * s_DoMmap(size_t size)

static Int8 s_TotalPageCount

#define __NC_MEMMAN_DEBUG

static Uint8 s_TotalSysMem

static Uint2 kMMCntForSize[kMMCntBlockSizes]

static const Uint2 kMMDrainBatchSize

static SMMPageHeader * s_GetPageByPtr(void *ptr)

static size_t s_CalcBigPageSize(size_t size)

static const int kMMFlushPeriod

static void s_LowLevelInit(void)

static void s_FlushPoolSet(SMMMemPoolsSet *pool_set)

static bool s_IsFreeListEmpty(SMMPageHeader *list_head)

static bool s_HadLowLevelInit

static void s_FreeListRemove(SMMPageHeader *page)

static void * s_AllocMemory(size_t size)

static const Uint4 kMMAllocPageSize

If for some reason kMMAllocPageSize is changed then kMMMaxBlockSize will change too and thus probably...

void ReleaseThreadMemMgr(SSrvThread *thr)

static void s_DrainPool(SMMBlocksPool *pool, void *ptr, SMMStat *stat)

void FinalizeMemoryMan(void)

static void s_PutToFreeList(SMMPageHeader *page, Uint2 size_idx, bool to_head)

static void * s_SysAlloc(size_t size)

static void * s_GetFromPool(SMMBlocksPool *pool, SMMStat *stat)

static void s_PrintSizeDiff(CSrvPrintProxy &proxy, Uint2 size_idx, Int8 was_blocks, Int8 is_blocks)

Uint8 s_UserBlAlloced[kMMCntBlockSizes]

static const Uint2 kMMOSPageSize

This is Linux standard on x86_64.

static void s_DeallocBigPage(SMMPageHeader *page, SMMStat *)

static SMMStateStat s_StartState

static Uint2 s_CalcSizeIndex(size_t size)

static SMMMemPoolsSet s_GlobalPoolsSet

static const Uint2 kMMMaxBlockSize

static void * s_FillFromPage(SMMBlocksPool *pool, Uint2 size_idx, SMMPageHeader *page)

#define __NC_MEMMAN_PERTHREAD_STAT_ARG(x)

static void s_ReleaseToFreePages(void **blocks, Uint2 cnt, Uint2 size_idx, SMMStat *)

size_t GetMemSize(void *ptr)

static void * s_AllocBigPage(size_t size, SMMStat *)

Uint8 s_UserBlFreed[kMMCntBlockSizes]

static SMMMemPoolsSet s_MainPoolsSet

static const Uint2 kMMBlockSizes[kMMCntBlockSizes]

Uint8 s_SysBlFreed[kMMCntBlockSizes]

static void * s_ReallocMemory(void *ptr, size_t size)

static void * s_SysAllocLongWay(size_t ptr, size_t size)

Uint8 s_SysBlAlloced[kMMCntBlockSizes]

static const Uint2 kMMCntBlockSizes

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

#define SRV_LOG(sev, msg)

Macro to be used for printing log messages.

std::enable_if< std::is_unsigned< T >::value, string >::type g_ToSizeStr(T size)

string g_ToSmartStr(T num)

T AtomicAdd(T volatile &var, T add_value)

T AtomicSub(T volatile &var, T sub_value)

void * blocks[kMMCntBlocksInPool]

SMMFreePageList lists[kMMCntFreeGrades]

SMMBlocksPool pools[kMMCntBlockSizes]

void PrintToLogs(CRequestContext *ctx, CSrvPrintProxy &proxy)

Uint8 m_SysBlAlloced[kMMCntBlockSizes]

void TransferEndState(SMMStat *src_stat)

CSrvStatTerm< Uint8 > m_TotalDataMem

CSrvStatTerm< Uint8 > m_TotalSysMem

void CopyEndState(SMMStat *src_stat)

Uint8 m_UserBlAlloced[kMMCntBlockSizes]

SMMStateStat m_StartState

void x_PrintUnstructured(CSrvPrintProxy &proxy)

void SaveEndStateStat(SMMStat *src_stat)

Uint8 m_UserBlFreed[kMMCntBlockSizes]

Uint8 m_SysBlFreed[kMMCntBlockSizes]

void PrintToSocket(CSrvPrintProxy &proxy)

void CopyStartState(SMMStat *src_stat)

void AddStats(SMMStat *src_stat)

void PrintState(CSrvSocketTask &task)

void InitStartState(void)

Int8 m_UserBlocks[kMMCntBlockSizes]

Int8 m_SysBlocks[kMMCntBlockSizes]

static DP_BlockInfo * blocks

Uint2 TSrvThreadNum

Type for thread number in TaskServer.

CRef< CTestThread > thr[k_NumThreadsMax]

SSrvThread * GetCurThread(void)

void InitCurThreadStorage(void)

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